tts

type AvailabilityChangedEvent struct {
	TTS       TTS
	Available bool
}

type AvailabilityChangedHandler func(AvailabilityChangedEvent)

type ChunkedStream interface {
	Next() (*SynthesizedAudio, error)
	Close() error
}

type DoneStream interface {
	Done() bool
}

type ErrorEmitter struct {
	// contains filtered or unexported fields
}

type ExceptionStream interface {
	Exception() error
}

type FallbackAdapter struct {
	MetricsEmitter
	ErrorEmitter
	// contains filtered or unexported fields
}

type FallbackAdapterOptions struct {
	MaxRetryPerTTS int
	DisableRetries bool
	SampleRate     int
}

type MetricsEmitter struct {
	// contains filtered or unexported fields
}

type SentenceStreamPacer struct {
	// contains filtered or unexported fields
}

type SentenceStreamPacerOptions struct {
	MinRemainingAudio    time.Duration
	MinRemainingAudioSet bool
	MaxTextLength        int
	MaxTextLengthSet     bool
}

type StreamAdapter struct {
	MetricsEmitter
	ErrorEmitter
	// contains filtered or unexported fields
}

type SynthesizeStream interface {
	PushText(text string) error
	Flush() error
	Close() error
	Next() (*SynthesizedAudio, error)
}

type SynthesizedAudio struct {
	Frame           *model.AudioFrame `json:"frame"`
	RequestID       string            `json:"request_id"`
	IsFinal         bool              `json:"is_final"`
	SegmentID       string            `json:"segment_id"`
	DeltaText       string            `json:"delta_text"`
	TimedTranscript []TimedString     `json:"timed_transcript,omitempty"`
}

type TTS interface {
	Label() string
	Capabilities() TTSCapabilities
	SampleRate() int
	NumChannels() int
	Synthesize(ctx context.Context, text string) (ChunkedStream, error)
	Stream(ctx context.Context) (SynthesizeStream, error)
}

type TTSCapabilities struct {
	Streaming         bool `json:"streaming"`
	AlignedTranscript bool `json:"aligned_transcript"`
}

type TTSError struct {
	Type        string
	Timestamp   time.Time
	Label       string
	Err         error
	Recoverable bool
}

type TTSErrorHandler func(TTSError)

type TTSMetricsHandler func(*telemetry.TTSMetrics)

type TextReplaceBuffer struct {
	// contains filtered or unexported fields
}

type TextTransformBuffer struct {
	// contains filtered or unexported fields
}

type TimedString struct {
	Text            string  `json:"text"`
	StartTime       float64 `json:"start_time"`
	EndTime         float64 `json:"end_time"`
	Confidence      float64 `json:"confidence"`
	StartTimeOffset float64 `json:"start_time_offset"`
	SpeakerID       string  `json:"speaker_id"`
}