streaming

type AudioDecoder interface {
	Decode(data []byte) ([]byte, error)
}

type AudioEncoder interface {
	Encode(pcm []byte) ([]byte, error)
}

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

type BidirectionalStream struct {
	ID     string
	Config StreamConfig
	State  StreamState
	// contains filtered or unexported fields
}

type StreamChunk struct {
	ID        string         `json:"id"`
	Type      StreamType     `json:"type"`
	Data      []byte         `json:"data"`
	Text      string         `json:"text,omitempty"`
	Timestamp time.Time      `json:"timestamp"`
	Sequence  int64          `json:"sequence"`
	IsFinal   bool           `json:"is_final"`
	Metadata  map[string]any `json:"metadata,omitempty"`
}

type StreamConfig struct {
	BufferSize     int           `json:"buffer_size"`
	MaxLatencyMS   int           `json:"max_latency_ms"`
	SampleRate     int           `json:"sample_rate"`
	Channels       int           `json:"channels"`
	EnableVAD      bool          `json:"enable_vad"`
	ChunkDuration  time.Duration `json:"chunk_duration"`
	ReconnectDelay time.Duration `json:"reconnect_delay"`
	// 新增字段
	HeartbeatInterval time.Duration `json:"heartbeat_interval"` // 心跳间隔，默认 30s
	HeartbeatTimeout  time.Duration `json:"heartbeat_timeout"`  // 心跳超时，默认 10s
	MaxReconnects     int           `json:"max_reconnects"`     // 最大重连次数，默认 5
	EnableHeartbeat   bool          `json:"enable_heartbeat"`   // 是否启用心跳
}

type StreamConnection interface {
	// ReadChunk 从连接读取一个数据块（阻塞直到有数据或出错）
	ReadChunk(ctx context.Context) (*StreamChunk, error)
	// WriteChunk 向连接写入一个数据块
	WriteChunk(ctx context.Context, chunk StreamChunk) error
	// Close 关闭连接
	Close() error
	// IsAlive 检查连接是否存活
	IsAlive() bool
}

type StreamHandler interface {
	OnInbound(ctx context.Context, chunk StreamChunk) (*StreamChunk, error)
	OnOutbound(ctx context.Context, chunk StreamChunk) error
	OnStateChange(state StreamState)
}

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

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

type StreamSession struct {
	ID         string
	Stream     *BidirectionalStream
	StartTime  time.Time
	EndTime    time.Time
	BytesSent  int64
	BytesRecv  int64
	ChunksSent int64
	ChunksRecv int64
	// contains filtered or unexported fields
}

type StreamState string

type StreamType string

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

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

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