draftrag

type AnthropicLLMConfig struct {
	BaseURL          string   `yaml:"base_url"`
	APIKey           string   `yaml:"api_key"`
	Model            string   `yaml:"model"`
	AnthropicVersion string   `yaml:"anthropic_version"`
	Temperature      *float64 `yaml:"temperature,omitempty"`
	MaxTokens        *int     `yaml:"max_tokens,omitempty"`
}

type AnthropicLLMOptions struct {
	// BaseURL — базовый URL Anthropic API (например, "https://api.anthropic.com").
	BaseURL string
	// APIKey — ключ доступа. Передаётся в заголовке X-API-Key.
	APIKey string
	// Model — имя модели. Если пустая строка, используется claude-3-haiku-20240307.
	Model string
	// AnthropicVersion — версия API. Если пустая строка, используется "2023-06-01".
	AnthropicVersion string

	// Temperature — параметр генерации; если nil, параметр не передаётся в запросе.
	Temperature *float64
	// MaxTokens — лимит выходных токенов; если nil, используется дефолт (1024).
	MaxTokens *int

	// HTTPClient — опциональный клиент; если nil, используется http.DefaultClient.
	HTTPClient *http.Client
	// Timeout — опциональный таймаут на один вызов Generate (не применяется к GenerateStream).
	Timeout time.Duration
}

type BasicChunkerConfig struct {
	ChunkSize    int `yaml:"chunk_size"`
	ChunkOverlap int `yaml:"chunk_overlap"`
}

type BasicChunkerOptions struct {
	// ChunkSize — целевой размер чанка в рунах (обязательно > 0).
	ChunkSize int
	// Overlap — перекрытие между чанками в рунах (обязательно >= 0 и < ChunkSize).
	Overlap int
	// MaxChunks — максимальное количество возвращаемых чанков (>= 0). 0 означает “без лимита”.
	//
	// Если MaxChunks > 0, чанкер возвращает префикс первых MaxChunks чанков (best-effort, без ошибки).
	MaxChunks int
}

type BatchReranker = domain.BatchReranker

type CacheOptions struct {
	// MaxSize — максимальное количество записей в LRU-кэше.
	// 0 → 1000.
	MaxSize int

	// Redis — опциональный Redis L2 кэш.
	Redis RedisCacheOptions

	// Logger — опциональный структурированный логгер для событий кэша.
	// nil означает no-op.
	Logger Logger
}

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

type ChromaDBOptions struct {
	// BaseURL — базовый URL ChromaDB HTTP API. Если пустая строка, используется http://localhost:8000.
	BaseURL string
	// Collection — имя коллекции (обязательно).
	Collection string
	// CollectionUUID — UUID коллекции (заполняется после CreateChromaCollection,
	// т.к. ChromaDB 0.5+ требует UUID в URL).
	CollectionUUID string
	// Dimension — фиксированная размерность embedding-векторов (обязательно > 0).
	Dimension int
	// HTTP таймаут (по умолчанию: 10s)
	Timeout time.Duration
}

type ChromaDBStoreConfig struct {
	BaseURL    string `yaml:"base_url"`
	Collection string `yaml:"collection"`
	Dimension  int    `yaml:"dimension"`
	AuthToken  string `yaml:"auth_token,omitempty"`
}

type Chunk = domain.Chunk

type Chunker = domain.Chunker

type ChunkerConfig struct {
	Type     string                 `yaml:"type"`
	Basic    *BasicChunkerConfig    `yaml:"basic,omitempty"`
	Semantic *SemanticChunkerConfig `yaml:"semantic,omitempty"`
}

type CircuitBreakerConfig struct {
	MaxFailures int           `yaml:"max_failures"`
	ResetAfter  time.Duration `yaml:"reset_after"`
}

type CircuitBreakerStats = resilience.Stats

type CircuitState = resilience.CircuitState

type Closer = domain.Closer

type ComponentHealth struct {
	Name   string
	Health HealthCheckFunc
}

type Config struct {
	Pipeline     PipelineConfig     `yaml:"pipeline"`
	Store        StoreConfig        `yaml:"store"`
	Embedder     EmbedderConfig     `yaml:"embedder"`
	LLM          LLMConfig          `yaml:"llm"`
	Chunker      ChunkerConfig      `yaml:"chunker,omitempty"`
	Reranker     RerankerConfig     `yaml:"reranker,omitempty"`
	Resilience   ResilienceConfig   `yaml:"resilience,omitempty"`
	CostTracking CostTrackingConfig `yaml:"cost_tracking,omitempty"`
}

type ContextualChunkerOptions struct {
	// Base — базовый Chunker, чьи чанки будут обогащены контекстом (обязательно).
	Base Chunker
	// ContextKey — ключ в Document.Metadata, откуда берётся контекст (обязательно).
	ContextKey string
	// Template — шаблон, содержащий {context} и {content} плейсхолдеры (обязательно).
	Template string
}

type CostSnapshot = domain.CostSnapshot

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

type CostTrackingConfig struct {
	Enabled bool `yaml:"enabled"`
}

type DeepSeekLLMConfig struct {
	BaseURL string        `yaml:"base_url"`
	APIKey  string        `yaml:"api_key"`
	Model   string        `yaml:"model"`
	Timeout time.Duration `yaml:"timeout"`
}

type DeepSeekLLMOptions struct {
	// BaseURL — базовый URL DeepSeek API. Если пустая строка, используется https://api.deepseek.com.
	BaseURL string
	// APIKey — ключ доступа. Передаётся в заголовке Authorization: Bearer.
	APIKey string
	// Model — имя модели. Если пустая строка, используется deepseek-chat.
	Model string

	Temperature *float64
	MaxTokens   *int

	HTTPClient *http.Client
	Timeout    time.Duration
}

type Document = domain.Document

type DocumentStore = domain.DocumentStore

type EmbedCacheStats = cache.Stats

type Embedder = domain.Embedder

type EmbedderConfig struct {
	Type             string                          `yaml:"type"`
	Ollama           *OllamaEmbedderConfig           `yaml:"ollama,omitempty"`
	OpenAICompatible *OpenAICompatibleEmbedderConfig `yaml:"openai_compatible,omitempty"`
	Mistral          *MistralEmbedderConfig          `yaml:"mistral,omitempty"`
}

type ExternalDeps struct {
	DB         *sql.DB
	HTTPClient *http.Client
}

type FallbackLLMProvider struct {
	*resilience.FallbackLLMProvider
}

type FallbackStats = resilience.FallbackStats

type FallbackStreamingLLMProvider struct {
	*resilience.FallbackStreamingLLMProvider
}

type FallbackUsageAwareLLMProvider struct {
	*resilience.FallbackUsageAwareLLMProvider
}

type Handler = domain.Handler

type HealthCheckFunc func(context.Context) error

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

type HealthCheckerResult struct {
	Name    string `json:"name"`
	Healthy bool   `json:"healthy"`
	Error   string `json:"error,omitempty"`
}

type HookStage = domain.HookStage

type Hooks = domain.Hooks

type HybridConfig = domain.HybridConfig

type HybridSearcher = domain.HybridSearcher

type IndexBatchError = domain.IndexBatchError

type IndexBatchResult = domain.IndexBatchResult

type InlineCitation = domain.InlineCitation

type LLMConfig struct {
	Type             string                     `yaml:"type"`
	Ollama           *OllamaLLMConfig           `yaml:"ollama,omitempty"`
	OpenAICompatible *OpenAICompatibleLLMConfig `yaml:"openai_compatible,omitempty"`
	Anthropic        *AnthropicLLMConfig        `yaml:"anthropic,omitempty"`
	DeepSeek         *DeepSeekLLMConfig         `yaml:"deepseek,omitempty"`
	Mistral          *MistralLLMConfig          `yaml:"mistral,omitempty"`
}

type LLMProvider = domain.LLMProvider

type LLMReranker = reranker.LLMReranker

type LLMRerankerConfig struct {
	BatchSize  int `yaml:"batch_size"`
	MaxRetries int `yaml:"max_retries"`
}

type LLMRerankerOption interface {
	// contains filtered or unexported methods
}

type LogField = domain.LogField

type LogLevel = domain.LogLevel

type Logger = domain.Logger

type MemoryStoreConfig struct{}

type MetadataFilter = domain.MetadataFilter

type Middleware = domain.Middleware

type MilvusStoreConfig struct {
	Address    string `yaml:"address"`
	Collection string `yaml:"collection"`
	Dimension  int    `yaml:"dimension"`
	User       string `yaml:"user,omitempty"`
	Password   string `yaml:"password,omitempty"`
}

type MistralEmbedderConfig struct {
	APIKey  string        `yaml:"api_key"`
	Model   string        `yaml:"model"`
	Timeout time.Duration `yaml:"timeout"`
}

type MistralEmbedderOptions struct {
	// BaseURL — базовый URL Mistral API. Если пустая строка, используется https://api.mistral.ai.
	BaseURL string
	// APIKey — ключ доступа. Передаётся в заголовке Authorization: Bearer.
	APIKey string
	// Model — имя embeddings модели. Если пустая строка, используется mistral-embed.
	Model string

	// HTTPClient — опциональный клиент; если nil, используется http.DefaultClient.
	HTTPClient *http.Client
	// Timeout — опциональный таймаут на один вызов Embed.
	Timeout time.Duration
}

type MistralLLMConfig struct {
	BaseURL string        `yaml:"base_url"`
	APIKey  string        `yaml:"api_key"`
	Model   string        `yaml:"model"`
	Timeout time.Duration `yaml:"timeout"`
}

type MistralLLMOptions struct {
	// BaseURL — базовый URL Mistral API. Если пустая строка, используется https://api.mistral.ai.
	BaseURL string
	// APIKey — ключ доступа. Передаётся в заголовке Authorization: Bearer.
	APIKey string
	// Model — имя модели. Если пустая строка, используется mistral-large-latest.
	Model string

	Temperature *float64
	MaxTokens   *int

	HTTPClient *http.Client
	Timeout    time.Duration
}

type ModelPricing = domain.ModelPricing

type OllamaEmbedderConfig struct {
	BaseURL string        `yaml:"base_url"`
	Model   string        `yaml:"model"`
	APIKey  string        `yaml:"api_key"`
	Timeout time.Duration `yaml:"timeout"`
}

type OllamaEmbedderOptions struct {
	// BaseURL — базовый URL Ollama API. Если пустая строка, используется http://localhost:11434.
	BaseURL string
	// Model — имя модели эмбеддингов (обязательно).
	Model string
	// APIKey — опциональный ключ доступа (для кастомных инстансов с авторизацией).
	APIKey string

	// HTTPClient — опциональный клиент; если nil, используется http.DefaultClient.
	HTTPClient *http.Client
	// Timeout — опциональный таймаут на один вызов Embed.
	Timeout time.Duration
}

type OllamaLLMConfig struct {
	BaseURL string        `yaml:"base_url"`
	Model   string        `yaml:"model"`
	APIKey  string        `yaml:"api_key"`
	Timeout time.Duration `yaml:"timeout"`
}

type OllamaLLMOptions struct {
	// BaseURL — базовый URL Ollama API. Если пустая строка, используется http://localhost:11434.
	BaseURL string
	// Model — имя модели (обязательно).
	Model string
	// APIKey — опциональный ключ доступа (для кастомных инстансов с авторизацией).
	APIKey string

	// Temperature — параметр генерации; если nil, параметр не передаётся в запросе.
	Temperature *float64
	// MaxTokens — лимит выходных токенов; если nil, параметр не передаётся в запросе.
	MaxTokens *int

	// HTTPClient — опциональный клиент; если nil, используется http.DefaultClient.
	HTTPClient *http.Client
	// Timeout — опциональный таймаут на один вызов Generate.
	Timeout time.Duration
}

type OpenAICompatibleEmbedderConfig struct {
	BaseURL string        `yaml:"base_url"`
	Model   string        `yaml:"model"`
	APIKey  string        `yaml:"api_key"`
	Timeout time.Duration `yaml:"timeout"`
}

type OpenAICompatibleEmbedderOptions struct {
	// BaseURL — базовый URL провайдера (например, "https://api.openai.com").
	BaseURL string
	// APIKey — ключ доступа. Передаётся в заголовке Authorization: Bearer.
	APIKey string
	// Model — имя embeddings модели.
	Model string

	// HTTPClient — опциональный клиент; если nil, используется http.DefaultClient.
	HTTPClient *http.Client
	// Timeout — опциональный таймаут на один вызов Embed.
	Timeout time.Duration
}

type OpenAICompatibleLLMConfig struct {
	BaseURL string        `yaml:"base_url"`
	Model   string        `yaml:"model"`
	APIKey  string        `yaml:"api_key"`
	Timeout time.Duration `yaml:"timeout"`
}

type OpenAICompatibleLLMOptions struct {
	// BaseURL — базовый URL провайдера (например, "https://api.openai.com").
	BaseURL string
	// APIKey — ключ доступа. Передаётся в заголовке Authorization: Bearer.
	APIKey string
	// Model — имя модели.
	Model string

	// Temperature — параметр генерации; если nil, параметр не передаётся в запросе.
	Temperature *float64
	// MaxOutputTokens — лимит выходных токенов; если nil, параметр не передаётся в запросе.
	MaxOutputTokens *int

	// HTTPClient — опциональный клиент; если nil, используется http.DefaultClient.
	HTTPClient *http.Client
	// Timeout — опциональный таймаут на один вызов Generate.
	Timeout time.Duration
}

type PGVectorMigrateOptions struct {
	PGVectorOptions

	// DDLTimeout — дефолтный таймаут для миграций, если у ctx нет deadline.
	// Если 0 — используется 30s.
	DDLTimeout time.Duration
}

type PGVectorOptions struct {
	// TableName — имя таблицы для хранения чанков.
	// В v1 поддерживается только простой идентификатор без схемы (например, "draftrag_chunks").
	TableName string

	// EmbeddingDimension — фиксированная размерность embedding-векторов.
	// При несоответствии размерности операции store возвращают ErrEmbeddingDimensionMismatch (errors.Is).
	EmbeddingDimension int

	// CreateExtension включает попытку выполнить `CREATE EXTENSION IF NOT EXISTS vector`.
	// Часто требует повышенных прав; при отсутствии прав будет возвращена ошибка.
	CreateExtension bool

	// IndexMethod — метод индекса: "ivfflat" (по умолчанию) или "hnsw".
	IndexMethod string

	// Lists — параметр ivfflat индекса (WITH (lists = N)).
	Lists int
}

type PGVectorRuntimeOptions struct {
	// SearchTimeout — дефолтный таймаут для Search*, если у ctx нет deadline.
	SearchTimeout time.Duration
	// UpsertTimeout — дефолтный таймаут для Upsert, если у ctx нет deadline.
	UpsertTimeout time.Duration
	// DeleteTimeout — дефолтный таймаут для Delete, если у ctx нет deadline.
	DeleteTimeout time.Duration

	// MaxTopK ограничивает topK в Search*. 0 означает “без лимита”.
	MaxTopK int
	// MaxParentIDs ограничивает количество ParentIDs в фильтре. 0 означает “без лимита”.
	MaxParentIDs int
	// MaxContentBytes ограничивает размер chunk.Content в байтах. 0 означает “без лимита”.
	MaxContentBytes int
}

type PGVectorStoreOptions struct {
	PGVectorOptions
	Runtime PGVectorRuntimeOptions
}

type PIICategories = piidetector.PIICategories

type PIIDetector = domain.PIIDetector

type ParentDocumentStore = domain.ParentDocumentStore

type ParentIDFilter = domain.ParentIDFilter

type PgvectorStoreConfig struct {
	TableName          string `yaml:"table_name"`
	EmbeddingDimension int    `yaml:"embedding_dimension"`
	CreateExtension    bool   `yaml:"create_extension"`
	IndexMethod        string `yaml:"index_method"`
	Lists              int    `yaml:"lists"`
}

type PineconeOptions struct {
	// APIKey — API ключ Pinecone (обязательно).
	APIKey string
	// Environment — окружение Pinecone (например, "us-east-1-aws").
	Environment string
	// ProjectID — ID проекта в Pinecone.
	ProjectID string
	// IndexName — имя индекса (обязательно).
	IndexName string
	// Dimension — размерность векторов (обязательно, > 0).
	Dimension int
	// Cloud — облачный провайдер (по умолчанию: "aws").
	Cloud string
	// Region — регион облака (по умолчанию: "us-west-2").
	Region string
	// Timeout — HTTP таймаут (по умолчанию: 30s).
	Timeout time.Duration
}

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

type PipelineConfig struct {
	DefaultTopK                  int     `yaml:"default_top_k"`
	SystemPrompt                 string  `yaml:"system_prompt"`
	MaxContextChars              int     `yaml:"max_context_chars"`
	MaxContextChunks             int     `yaml:"max_context_chunks"`
	DedupByParentID              bool    `yaml:"dedup_by_parent_id"`
	MMREnabled                   bool    `yaml:"mmr_enabled"`
	MMRLambda                    float64 `yaml:"mmr_lambda"`
	MMRCandidatePool             int     `yaml:"mmr_candidate_pool"`
	IndexConcurrency             int     `yaml:"index_concurrency"`
	IndexBatchRateLimit          int     `yaml:"index_batch_rate_limit"`
	IndexBatchRateLimitPerWorker bool    `yaml:"index_batch_rate_limit_per_worker"`
	StreamBufferSize             int     `yaml:"stream_buffer_size"`
}

type PipelineOptions struct {
	// DefaultTopK — значение topK по умолчанию для Query/Answer.
	// Если 0, используется значение по умолчанию (5).
	// Если < 0, это считается ошибкой конфигурации (panic).
	DefaultTopK int
	// SystemPrompt — переопределение system prompt для Answer*. Пустая строка означает дефолт v1.
	SystemPrompt string
	// Chunker — опциональный чанкер; если не nil, Index индексирует чанки (Chunk→Embed→Upsert).
	Chunker Chunker
	// Hooks — опциональные хуки наблюдаемости для стадий pipeline (chunking/embed/search/generate).
	// nil означает no-op.
	Hooks Hooks

	// MaxContextChars — лимит размера секции “Контекст:” в prompt для Answer* (в символах).
	// 0 означает “без лимита”.
	MaxContextChars int
	// MaxContextChunks — лимит количества чанков, попадающих в секцию “Контекст:” в prompt для Answer*.
	// 0 означает “без лимита”.
	MaxContextChunks int

	// DedupByParentID включает дедупликацию retrieval sources по ParentID.
	// По умолчанию выключено (backward compatibility).
	DedupByParentID bool

	// MMREnabled включает MMR rerank/selection для retrieval sources (диверсификация контекста).
	// По умолчанию выключено (backward compatibility).
	MMREnabled bool
	// MMRLambda задаёт баланс релевантность/разнообразие в диапазоне [0..1].
	// Если 0 и MMR включён — используется значение по умолчанию (0.5).
	MMRLambda float64
	// MMRCandidatePool задаёт сколько кандидатов запросить у VectorStore до отбора.
	// Если 0 — используется topK запроса.
	MMRCandidatePool int

	// IndexConcurrency задаёт количество workers для параллельной индексации в IndexBatch.
	// Если 0 — используется значение по умолчанию (4).
	IndexConcurrency int
	// IndexBatchRateLimit задаёт максимальное количество вызовов Embed в секунду в IndexBatch.
	// Если 0 — без ограничений.
	IndexBatchRateLimit int
	// IndexBatchRateLimitPerWorker включает per-worker rate-limiter: каждый worker
	// индексирует документы с частотой IndexBatchRateLimit per second (а не весь
	// пул суммарно). Используется, когда у каждого worker'а свой внешний квотный
	// лимит (например, несколько подов с независимыми rate-limits в API-ключе).
	//
	// По умолчанию false (backward-compat): один общий ticker на пул.
	// При IndexBatchRateLimit=10 и IndexConcurrency=4:
	//   - false: 10 embed/sec суммарно на пул.
	//   - true:  10 embed/sec на каждого worker'а, т.е. 40 embed/sec суммарно.
	IndexBatchRateLimitPerWorker bool

	// StreamBufferSize задаёт ёмкость буфера канала streaming-вывода в Answer*.
	// 0 — unbuffered (backward-compat, OQ-2: токен передаётся синхронно).
	// N > 0 — producer (LLM-стрим) может обгонять consumer на N токенов
	// без блокировки; при заполнении буфера producer блокируется на send.
	// Используется для bounded backpressure между LLM и consuming кодом.
	StreamBufferSize int

	// Reranker — опциональный reranker, применяется после retrieval.
	// nil означает "без reranking".
	Reranker Reranker

	// QueryRewriter — опциональный rewriter для переписывания запроса перед retrieval.
	// Поддерживает 1:1 и 1:N режимы. nil означает "без переписывания".
	// При установке per-request Rewriter через SearchBuilder.Rewriter имеет приоритет.
	QueryRewriter QueryRewriter

	// @sk-task pii-guardrails#T2.1: PIIDetector опция (RQ-001, RQ-002)
	// PIIDetector — опциональный детектор PII.
	// Если установлен, содержимое документов и результатов retrieval
	// проходит через детектор для цензурирования PII.
	// nil означает "без обработки" (backward compatible).
	PIIDetector PIIDetector

	// @sk-task sub-query-decomposition#T1.2: QueryDecomposer опция (AC-001, AC-006)
	// QueryDecomposer — опциональный decomposer для разбиения запроса на под-вопросы.
	// Если установлен, Search(...).SubDecompose() включает декомпозицию.
	// nil означает "декомпозиция отключена".
	QueryDecomposer QueryDecomposer

	// @sk-task hierarchical-indices#T4.1: ParentContextEnabled опция (AC-004, RQ-004)
	// ParentContextEnabled включает сохранение parent-документа при индексации
	// и загрузку parent-контекста при retrieval. nil означает "default (true)".
	// При false pipeline пропускает как сохранение parent-сущности при индексации,
	// так и загрузку parent-контента при retrieval (AC-004).
	ParentContextEnabled *bool

	// @sk-task middleware-chain#T2.5: Middleware опция (AC-001, AC-004)
	// Middleware — опциональная цепочка middleware для стадий pipeline.
	// nil или пустой срез означает "без middleware" (backward compatible).
	Middleware []Middleware
}

type QdrantOptions struct {
	// URL адрес Qdrant сервера (по умолчанию: http://localhost:6333)
	URL string
	// Имя коллекции для хранения чанков
	Collection string
	// Размерность векторов (обязательно)
	Dimension int
	// HTTP таймаут (по умолчанию: 10s)
	Timeout time.Duration
}

type QdrantStoreConfig struct {
	URL        string        `yaml:"url"`
	Collection string        `yaml:"collection"`
	Dimension  int           `yaml:"dimension"`
	Timeout    time.Duration `yaml:"timeout"`
}

type QueryDecomposer = domain.QueryDecomposer

type QueryHistory = domain.QueryHistory

type QueryRewriter = domain.QueryRewriter

type RedisCacheClient interface {
	GetBytes(ctx context.Context, key string) ([]byte, error)
	SetBytes(ctx context.Context, key string, value []byte, ttl time.Duration) error
}

type RedisCacheOptions struct {
	// Client — Redis клиент; nil отключает Redis кэш.
	Client RedisCacheClient

	// TTL — время жизни записей в Redis (0 → без TTL).
	TTL time.Duration

	// KeyPrefix — префикс ключей в Redis ("" → дефолт `draftrag:embedder:`).
	KeyPrefix string
}

type RedisClient = cache.RedisClient

type Reranker = domain.Reranker

type RerankerConfig struct {
	Type string             `yaml:"type"`
	LLM  *LLMRerankerConfig `yaml:"llm,omitempty"`
}

type ResilienceConfig struct {
	Retry          *RetryConfig          `yaml:"retry,omitempty"`
	CircuitBreaker *CircuitBreakerConfig `yaml:"circuit_breaker,omitempty"`
}

type RetrievalResult = domain.RetrievalResult

type RetryConfig struct {
	MaxAttempts int           `yaml:"max_attempts"`
	BaseDelay   time.Duration `yaml:"base_delay"`
	MaxDelay    time.Duration `yaml:"max_delay"`
}

type RetryEmbedder struct {
	*resilience.RetryEmbedder
}

type RetryLLMProvider struct {
	*resilience.RetryLLMProvider
}

type RetryOptions struct {
	// MaxRetries — максимальное количество повторных попыток (0 → 3).
	MaxRetries int

	// BaseDelay — начальная задержка перед первым retry (0 → 100ms).
	BaseDelay time.Duration

	// MaxDelay — максимальная задержка (0 → 10s).
	MaxDelay time.Duration

	// Multiplier — множитель exponential backoff (0 → 2.0).
	Multiplier float64

	// JitterFactor — доля случайной составляющей (0 → 0.25).
	JitterFactor float64

	// CBThreshold — порог ошибок для перехода circuit breaker в open (0 → 5).
	CBThreshold int

	// CBTimeout — время восстановления circuit breaker (0 → 30s).
	CBTimeout time.Duration

	// Logger — опциональный структурированный логгер для retry/CB событий.
	// nil означает no-op.
	Logger Logger
}

type RewrittenQuery = domain.RewrittenQuery

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

type SemanticChunkerConfig struct {
	SimilarityThreshold float64 `yaml:"threshold"`
	MinChunkSize        int     `yaml:"min_chunk_size"`
	MaxChunkSize        int     `yaml:"max_chunk_size"`
}

type SemanticChunkerOptions struct {
	// Embedder — интерфейс для вычисления эмбеддингов (обязательно).
	Embedder Embedder
	// SimilarityThreshold — порог косинусного сходства [0.0–1.0].
	// При сходстве ниже порога начинается новый чанк.
	SimilarityThreshold float64
	// MinChunkSize — минимальный размер чанка в символах (>= 0).
	// 0 означает без минимума.
	MinChunkSize int
	// MaxChunkSize — максимальный размер чанка в символах (> MinChunkSize или 0).
	// 0 означает без максимума.
	MaxChunkSize int
}

type StageData = domain.StageData

type StageEndEvent = domain.StageEndEvent

type StageStartEvent = domain.StageStartEvent

type StoreConfig struct {
	Type     string               `yaml:"type"`
	Memory   *MemoryStoreConfig   `yaml:"memory,omitempty"`
	Pgvector *PgvectorStoreConfig `yaml:"pgvector,omitempty"`
	Qdrant   *QdrantStoreConfig   `yaml:"qdrant,omitempty"`
	ChromaDB *ChromaDBStoreConfig `yaml:"chromadb,omitempty"`
	Weaviate *WeaviateStoreConfig `yaml:"weaviate,omitempty"`
	Milvus   *MilvusStoreConfig   `yaml:"milvus,omitempty"`
}

type StreamingLLMProvider = domain.StreamingLLMProvider

type TokenBucketOptions struct {
	// TokensPerSecond — максимальное количество запросов в секунду.
	// 0 отключает rate limiting.
	TokensPerSecond float64

	// BurstSize — максимальный burst (пиковый размер очереди токенов).
	// Если 0, используется значение TokensPerSecond.
	BurstSize float64
}

type TokenUsage = domain.TokenUsage

type ToolCall = domain.ToolCall

type ToolCallingLLMProvider = domain.ToolCallingLLMProvider

type ToolDefinition = domain.ToolDefinition

type ToolResult = domain.ToolResult

type TransactionalDocumentStore = domain.TransactionalDocumentStore

type TransactionalTx = domain.TransactionalTx

type UsageAwareLLMProvider = domain.UsageAwareLLMProvider

type UsageAwareStreamingLLMProvider = domain.UsageAwareStreamingLLMProvider

type VectorStore = domain.VectorStore

type VectorStoreWithFilters = domain.VectorStoreWithFilters

type WeaviateOptions struct {
	// Host — адрес Weaviate, например "localhost:8080" (обязательно).
	Host string
	// Scheme — протокол: "http" или "https". По умолчанию "http".
	Scheme string
	// Collection — имя коллекции (Weaviate class, обязательно).
	Collection string
	// APIKey — API ключ для Weaviate Cloud (опционально).
	APIKey string
	// Timeout — HTTP таймаут (по умолчанию 10s).
	Timeout time.Duration
}

type WeaviateStoreConfig struct {
	Host       string `yaml:"host"`
	Scheme     string `yaml:"scheme"`
	Collection string `yaml:"collection"`
	APIKey     string `yaml:"api_key"`
}