1
session, err := client.Realtime.Connect(ctx, meshapi.RealtimeConnectParams{
2
    Model: "openai/gpt-realtime-mini",
3
})
4
if err != nil {
5
    log.Fatal(err)
6
}
7
defer session.Close()

1
err = session.Send(ctx, map[string]any{
2
    "type": "session.update",
3
    "session": map[string]any{
4
        "type":         "realtime",
5
        "modalities":   []string{"audio", "text"},
6
        "voice":        "alloy",
7
        "instructions": "You are a helpful assistant.",
8
    },
9
})

1
// pcmBytes is raw 16-bit PCM at 24 kHz mono
2
err = session.SendAudio(ctx, pcmBytes)

1
msg, err := session.Receive(ctx)
2
if err == io.EOF {
3
    fmt.Println("session closed")
4
} else if err != nil {
5
    log.Fatal(err)
6
}
7
8
if msg.Audio != nil {
9
    // binary audio frame — play or buffer
10
    playAudio(msg.Audio)
11
} else if msg.Event != nil {
12
    fmt.Println("event type:", msg.Event["type"])
13
}

1
msgCh, errCh := session.Events(ctx)
2
3
for msg := range msgCh {
4
    switch {
5
    case msg.Audio != nil:
6
        playAudio(msg.Audio)
7
    case msg.Event != nil:
8
        switch msg.Event["type"] {
9
        case "response.text.delta":
10
            fmt.Print(msg.Event["delta"])
11
        case "response.done":
12
            fmt.Println("\n[done]")
13
        case "error":
14
            log.Printf("server error: %v", msg.Event)
15
        }
16
    }
17
}
18
19
if err := <-errCh; err != nil {
20
    log.Fatal(err)
21
}

1
session, _ := client.Realtime.Connect(ctx, meshapi.RealtimeConnectParams{
2
    Model: "openai/gpt-realtime-mini",
3
})
4
defer session.Close()
5
6
// Configure
7
session.Send(ctx, map[string]any{
8
    "type": "session.update",
9
    "session": map[string]any{
10
        "type":       "realtime",
11
        "modalities": []string{"audio", "text"},
12
        "voice":      "alloy",
13
    },
14
})
15
16
// Stream microphone audio
17
go func() {
18
    for chunk := range micCh {
19
        session.SendAudio(ctx, chunk)
20
    }
21
    session.Send(ctx, map[string]any{"type": "input_audio_buffer.commit"})
22
    session.Send(ctx, map[string]any{"type": "response.create"})
23
}()
24
25
// Play response audio
26
msgCh, _ := session.Events(ctx)
27
for msg := range msgCh {
28
    if msg.Audio != nil {
29
        speaker.Write(msg.Audio)
30
    }
31
}

1
msg, err := session.Receive(ctx)
2
if err != nil {
3
    var re *meshapi.RealtimeError
4
    if errors.As(err, &re) {
5
        fmt.Println("code:", re.Code)    // "invalid_api_key", "insufficient_quota", …
6
        fmt.Println("message:", re.Message)
7
    }
8
}