Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

console

package

Go to main page

Versions in this module

v2

v2.16.7

Jun 27, 2026

v2.16.6

Jun 16, 2026

v2.16.5

Jun 11, 2026

Changes in this version

+ const APMFrameSamples

+ const CaptureRingFrames

+ const Channels

+ const FrameDurationMs

+ const NumFFTBands

+ const PlaybackRingFrames

+ const SampleRate

+ const SamplesPerFrame

+ func BytesToSamples(data []byte) []int16

+ func ReadSessionMessage(r io.Reader) (*agent.AgentSessionMessage, error)

+ func SamplesToBytes(samples []int16) []byte

+ func WriteSessionMessage(w io.Writer, msg *agent.AgentSessionMessage) error

+ type AudioPipeline struct

+ Events chan *agent.AgentSessionEvent

+ Responses chan *agent.SessionResponse

+ func NewPipeline(cfg PipelineConfig) (*AudioPipeline, error)

+ func (p *AudioPipeline) AECStats() *apm.Stats

+ func (p *AudioPipeline) EnableAudio() error

+ func (p *AudioPipeline) FFTBands() [NumFFTBands]float64

+ func (p *AudioPipeline) HasAudio() bool

+ func (p *AudioPipeline) IsPlaying() bool

+ func (p *AudioPipeline) Level() float64

+ func (p *AudioPipeline) Muted() bool

+ func (p *AudioPipeline) SendRequest(req *agent.SessionRequest) error

+ func (p *AudioPipeline) SetMuted(muted bool)

+ func (p *AudioPipeline) SetPaused(paused bool)

+ func (p *AudioPipeline) Start(ctx context.Context) error

+ func (p *AudioPipeline) Stop()

+ type PipelineConfig struct

+ Conn net.Conn

+ InputDevice *portaudio.DeviceInfo

+ NoAEC bool

+ OutputDevice *portaudio.DeviceInfo

+ type RingBuffer struct

+ func NewRingBuffer(size int) *RingBuffer

+ func (rb *RingBuffer) Available() int

+ func (rb *RingBuffer) Read(out []int16) bool

+ func (rb *RingBuffer) ReadAvailable(out []int16) int

+ func (rb *RingBuffer) Reset()

+ func (rb *RingBuffer) WaitForData() bool

+ func (rb *RingBuffer) Write(samples []int16) int

+ type TCPServer struct

+ func NewTCPServer(addr string) (*TCPServer, error)

+ func (s *TCPServer) Accept() (net.Conn, error)

+ func (s *TCPServer) AcceptConn() (net.Conn, error)

+ func (s *TCPServer) Addr() net.Addr

+ func (s *TCPServer) Close() error

+ func (s *TCPServer) Conn() net.Conn