aggregators

package

Go to main page

Versions in this module

v0

v0.1.0

Aug 30, 2026

Changes in this version

+ const EventAssistantThought

+ const EventAssistantTurnStarted

+ const EventAssistantTurnStopped

+ const EventCompletion

+ const EventRequestSummarization

+ const EventSummaryApplied

+ const EventUserMuteStarted

+ const EventUserMuteStopped

+ const EventUserTurnIdle

+ const EventUserTurnInferenceTriggered

+ const EventUserTurnMessageAdded

+ const EventUserTurnStarted

+ const EventUserTurnStopTimeout

+ const EventUserTurnStopped

type AssistantAggregator

+ func (a *AssistantAggregator) Cleanup(ctx context.Context) error

+ func (a *AssistantAggregator) HasFunctionCallsInProgress() bool

+ func (a *AssistantAggregator) Setup(ctx context.Context, s processor.Setup) error

+ func (a *AssistantAggregator) Summarizer() *Summarizer

+ type AssistantThought struct

+ Content string

+ Timestamp string

+ type AssistantTurnStopped struct

+ Content string

+ Interrupted bool

+ Timestamp string

+ type Completion struct

+ Completed bool

+ Text string

+ type FullResponse struct

+ func NewFullResponse(name string) *FullResponse

+ func (a *FullResponse) ProcessFrame(ctx context.Context, f frames.Frame, dir processor.Direction) error

+ type GateFunc func(frames.Frame) bool

+ type Gated struct

+ func NewGated(name string, cfg GatedConfig) *Gated

+ func (g *Gated) ProcessFrame(ctx context.Context, frame frames.Frame, dir processor.Direction) error

+ type GatedConfig struct

+ Close GateFunc

+ Direction processor.Direction

+ Open GateFunc

+ StartOpen bool

+ type GatedContext struct

+ func NewGatedContext(name string, cfg GatedContextConfig) *GatedContext

+ func (g *GatedContext) Cleanup(ctx context.Context) error

+ func (g *GatedContext) ProcessFrame(ctx context.Context, frame frames.Frame, dir processor.Direction) error

+ type GatedContextConfig struct

+ Notifier notify.Notifier

+ StartOpen bool

+ type LLMText struct

+ func NewLLMText(name string) *LLMText

+ func NewLLMTextWith(name string, aggregator text.Aggregator) *LLMText

+ func (p *LLMText) ProcessFrame(ctx context.Context, f frames.Frame, dir processor.Direction) error

+ func (p *LLMText) Reset()

type Option

+ func WithMuteStrategies(strategies ...turns.MuteStrategy) Option

+ func WithToolChangeMessages() Option

+ func WithTurns(cfg turns.Config) Option

+ func WithVAD(cfg VADConfig) Option

+ type Sentence struct

+ func NewSentence(name string) *Sentence

+ func NewSentenceWith(name string, tokenizer text.SentenceTokenizer) *Sentence

+ func (s *Sentence) ProcessFrame(ctx context.Context, f frames.Frame, dir processor.Direction) error

type Summarizer

+ func NewSummarizer(convo *frames.LLMContext, cfg frames.AutoSummarizationConfig, autoTrigger bool) *Summarizer

+ func (s *Summarizer) Cleanup(ctx context.Context)

+ func (s *Summarizer) ProcessFrame(ctx context.Context, f frames.Frame)

+ type SummaryApplied struct

+ NewMessageCount int

+ OriginalMessageCount int

+ PreservedMessageCount int

+ SummarizedMessageCount int

type UserAggregator

+ func (u *UserAggregator) Cleanup(ctx context.Context) error

+ func (u *UserAggregator) Push(ctx context.Context, f frames.Frame, dir processor.Direction) error

+ func (u *UserAggregator) Setup(ctx context.Context, s processor.Setup) error

+ type UserTurnMessageAdded struct

+ Content string

+ Timestamp string

+ UserID string

+ type UserTurnStopped struct

+ Content string

+ Strategy turns.StopStrategy

+ Timestamp string

+ UserID string

+ type VADConfig struct

+ Analyzer vad.Analyzer

+ AudioIdleTimeout *time.Duration

v0.0.5

Jul 13, 2026

v0.0.4

Jul 12, 2026

Changes in this version

+ type AssistantAggregator struct

+ func (a *AssistantAggregator) ProcessFrame(ctx context.Context, f frames.Frame, dir processor.Direction) error

+ type Option func(*options)

+ func WithSummarization(cfg SummarizeConfig) Option

+ func WithTurnTaking() Option

+ type Pair struct

+ func New(ctx *frames.LLMContext, opts ...Option) *Pair

+ func (p *Pair) Assistant() processor.Processor

+ func (p *Pair) Context() *frames.LLMContext

+ func (p *Pair) User() processor.Processor

+ type SummarizeConfig struct

+ KeepRecentMessages int

+ Summarizer Summarizer

+ Timeout time.Duration

+ TriggerTokens int

+ type Summarizer interface

+ Summarize func(ctx context.Context, prior string, dropped []frames.Message) (string, error)

+ type UserAggregator struct

+ func (u *UserAggregator) ProcessFrame(ctx context.Context, f frames.Frame, dir processor.Direction) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL