Documentation
¶
Index ¶
- type Base
- type BaseStream
- func (s *BaseStream) Close() error
- func (s *BaseStream) Context() context.Context
- func (s *BaseStream) Emit(ctx context.Context, event Event) error
- func (s *BaseStream) EndInput() error
- func (s *BaseStream) Finish(err error)
- func (s *BaseStream) Flush(ctx context.Context) error
- func (s *BaseStream) Inputs() stream.Reader[StreamInput]
- func (s *BaseStream) Push(ctx context.Context, frame agents.AudioFrame) error
- func (s *BaseStream) Recv(ctx context.Context) (Event, error)
- type Capabilities
- type Event
- type EventType
- type StreamInput
- type VAD
- type VADStream
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Base ¶
type Base struct {
// contains filtered or unexported fields
}
func NewBase ¶
func NewBase(label string, capabilities Capabilities) *Base
func (*Base) Capabilities ¶
func (b *Base) Capabilities() Capabilities
func (*Base) EmitMetrics ¶
func (*Base) SetMinSilenceDuration ¶
type BaseStream ¶
type BaseStream struct {
// contains filtered or unexported fields
}
func NewBaseStream ¶
func NewBaseStream(parent context.Context, capacity int) *BaseStream
func (*BaseStream) Close ¶
func (s *BaseStream) Close() error
func (*BaseStream) Context ¶
func (s *BaseStream) Context() context.Context
func (*BaseStream) EndInput ¶
func (s *BaseStream) EndInput() error
func (*BaseStream) Finish ¶
func (s *BaseStream) Finish(err error)
func (*BaseStream) Inputs ¶
func (s *BaseStream) Inputs() stream.Reader[StreamInput]
func (*BaseStream) Push ¶
func (s *BaseStream) Push(ctx context.Context, frame agents.AudioFrame) error
type Capabilities ¶
type StreamInput ¶
type StreamInput struct {
Frame *agents.AudioFrame
Flush bool
}
Click to show internal directories.
Click to hide internal directories.