synthesizer

type AccumulateOption func(*AccumulateSynthesizer)

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

type AsyncTreeOption func(*AsyncTreeSummarizeSynthesizer)

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

type CompactAndRefineOption func(*CompactAndRefineSynthesizer)

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

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

type CompactSynthesizerOption func(*CompactSynthesizer)

type CustomPromptOption func(*CustomPromptSynthesizer)

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

type GenerationOption func(*GenerationSynthesizer)

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

type IncrementalOption func(*IncrementalSynthesizer)

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

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

type PipelineOption func(*PipelineSynthesizer)

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

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

type RefineSynthesizerOption func(*RefineSynthesizer)

type Response struct {
	// Content 生成的回答内容
	Content string `json:"content"`

	// SourceDocuments 引用的源文档
	SourceDocuments []rag.Document `json:"source_documents,omitempty"`

	// Metadata 元数据（包含 token 消耗、延迟等信息）
	Metadata map[string]any `json:"metadata,omitempty"`
}

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

type SimpleSynthesizerOption func(*SimpleSummarizeSynthesizer)

type StreamChunk struct {
	// Text 文本内容
	Text string

	// IsPartial 是否为部分结果（true 表示后续可能有更新）
	IsPartial bool

	// SourceDocs 当前块使用的源文档数量
	SourceDocs int

	// Metadata 元数据
	Metadata map[string]any
}

type StreamingSynthesizer interface {
	Synthesizer

	// SynthesizeStream 流式合成
	// docChan 是一个接收文档的通道，文档会在检索过程中陆续到达
	// 返回一个输出流通道
	SynthesizeStream(ctx context.Context, query string, docChan <-chan rag.Document) (<-chan StreamChunk, error)
}

type SynthesizeOption func(*synthesizeConfig)

type Synthesizer interface {
	// Name 返回合成器名称
	Name() string

	// Synthesize 合成响应
	// 接收查询和相关文档，返回生成的响应
	Synthesize(ctx context.Context, query string, docs []rag.Document, opts ...SynthesizeOption) (*Response, error)
}

type SynthesizerType string

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

type TreeSynthesizerOption func(*TreeSummarizeSynthesizer)