rag

package

Go to main page

Versions in this module

v1

v1.10.0

Apr 16, 2026

v1.9.8

Apr 15, 2026

v1.9.7

Apr 14, 2026

v1.9.6

Apr 14, 2026

v1.9.5

Apr 14, 2026

v1.9.4

Apr 13, 2026

v1.9.2

Apr 8, 2026

v1.9.1

Apr 8, 2026

v1.9.0

Apr 1, 2026

v1.8.12

Mar 30, 2026

v1.8.11

Mar 26, 2026

v1.8.10

Mar 25, 2026

v1.8.9

Mar 22, 2026

v1.8.8

Mar 22, 2026

v1.8.7

Mar 22, 2026

v1.8.6

Mar 22, 2026

v1.8.5

Mar 22, 2026

v1.8.4

Mar 22, 2026

v1.8.3

Mar 22, 2026

v1.8.2

Mar 22, 2026

v1.8.1

Mar 22, 2026

v1.8.0

Mar 22, 2026

v1.7.9

Mar 22, 2026

v1.7.8

Mar 22, 2026

v1.7.7

Mar 22, 2026

v1.7.6

Mar 22, 2026

v1.7.5

Mar 22, 2026

v1.7.4

Mar 22, 2026

v1.7.3

Mar 22, 2026

v1.7.2

Mar 22, 2026

v1.7.1

Mar 22, 2026

v1.6.3

Mar 15, 2026

Changes in this version

type MultiHopConfig

+ MaxLLMCalls int

type ReasoningChain

+ LLMCalls int

v1.6.2

Mar 9, 2026

v1.6.1

Mar 9, 2026

v1.6.0

Mar 6, 2026

Changes in this version

+ type EntityExtractor interface

+ ExtractEntities func(ctx context.Context, text string) ([]Entity, error)

type GraphRAGConfig

+ AutoExtractEntities bool

+ type GraphRAGOption func(*GraphRAG)

+ func WithEntityExtractor(extractor EntityExtractor) GraphRAGOption

type QueryRouter

+ func (r *QueryRouter) RouteWithTransform(ctx context.Context, query string) (*TransformedRoutingDecision, error)

+ type TransformedRoutingDecision struct

+ ExpandedQueries []string

+ HyDEDocument string

v1.5.0

Mar 6, 2026

v1.4.6

Mar 3, 2026

Changes in this version

+ const FusionRRF

+ const FusionWeighted

type EnhancedRetriever

+ func (r *EnhancedRetriever) ExecuteRetrievalPipeline(ctx context.Context, query string) ([]RetrievalResult, error)

+ type EvalMetrics = core.EvalMetrics

type HybridRetrievalConfig

+ FusionAlgorithm string

+ FusionAlpha float64

+ RRFK int

+ type RetrievalMetrics = core.RetrievalMetrics

v1.3.0

Feb 26, 2026

v1.2.0

Feb 25, 2026

v1.1.0

Feb 24, 2026

v1.0.0

Feb 23, 2026

Changes in this version

+ type LowLevelSearchResult struct

+ ID string

+ Metadata map[string]any

+ Score float64

+ type LowLevelVectorStore interface

+ Delete func(ctx context.Context, id string) error

+ Search func(ctx context.Context, query []float64, topK int, filter map[string]any) ([]LowLevelSearchResult, error)

+ Store func(ctx context.Context, id string, vector []float64, metadata map[string]any) error

v0

v0.2.0

Feb 20, 2026

v0.1.0

Feb 20, 2026

Changes in this version

+ func EmbeddingSimilarity(a, b []float64) float64

+ func Float32ToFloat64(v []float32) []float64

+ func Float64ToFloat32(v []float64) []float32

+ func NewEmbeddingProviderFromConfig(cfg *config.Config, providerType EmbeddingProviderType) (embedding.Provider, error)

+ type ChainVisualization struct

+ Edges []VisualizationEdge

+ Nodes []VisualizationNode

+ type Chunk struct

+ Content string

+ EndPos int

+ Metadata map[string]any

+ StartPos int

+ TokenCount int

+ type ChunkingConfig struct

+ ChunkOverlap int

+ ChunkSize int

+ MinChunkSize int

+ PreserveCodeBlocks bool

+ PreserveHeaders bool

+ PreserveTables bool

+ SimilarityThreshold float64

+ Strategy ChunkingStrategy

+ func DefaultChunkingConfig() ChunkingConfig

+ type ChunkingStrategy string

+ const ChunkingDocument

+ const ChunkingFixed

+ const ChunkingRecursive

+ const ChunkingSemantic

+ type Clearable interface

+ ClearAll func(ctx context.Context) error

+ type ContextProvider interface

+ GenerateContext func(ctx context.Context, doc Document, chunk string) (string, error)

+ type ContextualRetrieval struct

+ func NewContextualRetrieval(retriever *HybridRetriever, contextProvider ContextProvider, ...) *ContextualRetrieval

+ func (r *ContextualRetrieval) CleanExpiredCache() int

+ func (r *ContextualRetrieval) IndexDocumentsWithContext(ctx context.Context, docs []Document) error

+ func (r *ContextualRetrieval) Retrieve(ctx context.Context, query string, queryEmbedding []float64) ([]RetrievalResult, error)

+ func (r *ContextualRetrieval) UpdateIDFStats(docs []Document)

+ type ContextualRetrievalConfig struct

+ BM25B float64

+ BM25K1 float64

+ CacheContexts bool

+ CacheTTL time.Duration

+ ChunkByTokens bool

+ ChunkOverlap int

+ ChunkSize int

+ ContextTemplate string

+ ContextWeight float64

+ MaxContextLength int

+ UseContextPrefix bool

+ UseReranking bool

+ func DefaultContextualRetrievalConfig() ContextualRetrievalConfig

+ type CrossEncoderConfig struct

+ BatchSize int

+ MaxLength int

+ ModelName string

+ OriginalWeight float64

+ ScoreWeight float64

+ func DefaultCrossEncoderConfig() CrossEncoderConfig

+ type CrossEncoderProvider interface

+ Score func(ctx context.Context, pairs []QueryDocPair) ([]float64, error)

+ type CrossEncoderReranker struct

+ func NewCrossEncoderReranker(provider CrossEncoderProvider, config CrossEncoderConfig, logger *zap.Logger) *CrossEncoderReranker

+ func (r *CrossEncoderReranker) Rerank(ctx context.Context, query string, results []RetrievalResult) ([]RetrievalResult, error)

+ type DedupStats struct

+ DedupByID int

+ DedupBySimilarity int

+ FinalCount int

+ TotalRetrieved int

+ type Document struct

+ Content string

+ Embedding []float64

+ ID string

+ Metadata map[string]any

+ type DocumentChunker struct

+ func NewDocumentChunker(config ChunkingConfig, tokenizer Tokenizer, logger *zap.Logger) *DocumentChunker

+ func (c *DocumentChunker) ChunkDocument(doc Document) []Chunk

+ type DocumentLister interface

+ ListDocumentIDs func(ctx context.Context, limit int, offset int) ([]string, error)

+ type Edge struct

+ ID string

+ Properties map[string]any

+ Source string

+ Target string

+ Type string

+ Weight float64

+ type EmbeddingProvider interface

+ EmbedDocuments func(ctx context.Context, documents []string) ([][]float64, error)

+ EmbedQuery func(ctx context.Context, query string) ([]float64, error)

+ Name func() string

+ type EmbeddingProviderType string

+ const EmbeddingCohere

+ const EmbeddingGemini

+ const EmbeddingJina

+ const EmbeddingOpenAI

+ const EmbeddingVoyage

+ type EnhancedRetriever struct

+ func NewCohereRetriever(apiKey string, logger *zap.Logger) *EnhancedRetriever

+ func NewEnhancedRetriever(cfg EnhancedRetrieverConfig, logger *zap.Logger) *EnhancedRetriever

+ func NewJinaRetriever(apiKey string, logger *zap.Logger) *EnhancedRetriever

+ func NewOpenAIRetriever(apiKey string, logger *zap.Logger) *EnhancedRetriever

+ func NewRetrieverFromConfig(cfg *config.Config, opts ...RetrieverOption) (*EnhancedRetriever, error)

+ func NewVoyageRetriever(apiKey string, logger *zap.Logger) *EnhancedRetriever

+ func (r *EnhancedRetriever) IndexDocumentsWithEmbedding(ctx context.Context, docs []Document) error

+ func (r *EnhancedRetriever) RetrieveWithProviders(ctx context.Context, query string) ([]RetrievalResult, error)

+ type EnhancedRetrieverConfig struct

+ EmbeddingProvider EmbeddingProvider

+ HybridConfig HybridRetrievalConfig

+ RerankProvider RerankProvider

+ type EnhancedTokenizer struct

+ func (t *EnhancedTokenizer) CountTokens(text string) int

+ func (t *EnhancedTokenizer) Encode(text string) []int

+ type Entity struct

+ ID string

+ Name string

+ Type string

+ type ExpansionResult struct

+ Expansions []string

+ Intent QueryIntent

+ Keywords []string

+ Original string

+ type GraphDocument struct

+ Content string

+ Entities []Entity

+ ID string

+ Metadata map[string]any

+ Title string

+ type GraphEmbedder interface

+ Embed func(ctx context.Context, text string) ([]float64, error)

+ type GraphRAG struct

+ func NewGraphRAG(graph *KnowledgeGraph, vectorStore GraphVectorStore, embedder GraphEmbedder, ...) *GraphRAG

+ func (r *GraphRAG) AddDocument(ctx context.Context, doc GraphDocument) error

+ func (r *GraphRAG) Retrieve(ctx context.Context, query string) ([]GraphRetrievalResult, error)

+ type GraphRAGConfig struct

+ GraphWeight float64

+ MaxGraphDepth int

+ MaxResults int

+ MinScore float64

+ VectorWeight float64

+ func DefaultGraphRAGConfig() GraphRAGConfig

+ type GraphRetrievalResult struct

+ Content string

+ GraphScore float64

+ ID string

+ Metadata map[string]any

+ RelatedNodes []*Node

+ Score float64

+ Source string

+ VectorScore float64

+ type GraphVectorResult struct

+ ID string

+ Metadata map[string]any

+ Score float64

+ type GraphVectorStore interface

+ Search func(ctx context.Context, embedding []float64, limit int) ([]GraphVectorResult, error)

+ Store func(ctx context.Context, id string, embedding []float64, metadata map[string]any) error

+ type HNSWConfig struct

+ EfConstruction int

+ EfSearch int

+ M int

+ MaxLevel int

+ Ml float64

+ func AdaptiveHNSWConfig(dataSize int) HNSWConfig

+ func DefaultHNSWConfig() HNSWConfig

+ type HNSWIndex struct

+ func NewHNSWIndex(config HNSWConfig, logger *zap.Logger) *HNSWIndex

+ func (idx *HNSWIndex) Add(vector []float64, id string) error

+ func (idx *HNSWIndex) Build(vectors [][]float64, ids []string) error

+ func (idx *HNSWIndex) Delete(id string) error

+ func (idx *HNSWIndex) Search(query []float64, k int) ([]SearchResult, error)

+ func (idx *HNSWIndex) Size() int

+ type HopType string

+ const HopTypeBridging

+ const HopTypeDecomposed

+ const HopTypeFollowUp

+ const HopTypeInitial

+ const HopTypeRefinement

+ const HopTypeVerification

+ type HybridRetrievalConfig struct

+ BM25B float64

+ BM25K1 float64

+ BM25Weight float64

+ MinScore float64

+ RerankTopK int

+ TopK int

+ UseBM25 bool

+ UseReranking bool

+ UseVector bool

+ VectorWeight float64

+ func DefaultHybridRetrievalConfig() HybridRetrievalConfig

+ type HybridRetriever struct

+ func NewHybridRetriever(config HybridRetrievalConfig, logger *zap.Logger) *HybridRetriever

+ func NewHybridRetrieverWithVectorStore(config HybridRetrievalConfig, vectorStore VectorStore, logger *zap.Logger) *HybridRetriever

+ func (r *HybridRetriever) IndexDocuments(docs []Document) error

+ func (r *HybridRetriever) Retrieve(ctx context.Context, query string, queryEmbedding []float64) ([]RetrievalResult, error)

+ type InMemoryVectorStore struct

+ func NewInMemoryVectorStore(logger *zap.Logger) *InMemoryVectorStore

+ func (s *InMemoryVectorStore) AddDocuments(ctx context.Context, docs []Document) error

+ func (s *InMemoryVectorStore) ClearAll(ctx context.Context) error

+ func (s *InMemoryVectorStore) Count(ctx context.Context) (int, error)

+ func (s *InMemoryVectorStore) DeleteDocuments(ctx context.Context, ids []string) error

+ func (s *InMemoryVectorStore) ListDocumentIDs(ctx context.Context, limit int, offset int) ([]string, error)

+ func (s *InMemoryVectorStore) Search(ctx context.Context, queryEmbedding []float64, topK int) ([]VectorSearchResult, error)

+ func (s *InMemoryVectorStore) UpdateDocument(ctx context.Context, doc Document) error

+ type IndexType string

+ const IndexFlat

+ const IndexHNSW

+ const IndexIVF

+ type KnowledgeGraph struct

+ func NewKnowledgeGraph(logger *zap.Logger) *KnowledgeGraph

+ func (g *KnowledgeGraph) AddEdge(edge *Edge)

+ func (g *KnowledgeGraph) AddNode(node *Node)

+ func (g *KnowledgeGraph) GetNeighbors(nodeID string, depth int) []*Node

+ func (g *KnowledgeGraph) GetNode(id string) (*Node, bool)

+ func (g *KnowledgeGraph) QueryByType(nodeType string) []*Node

+ type LLMContextProvider struct

+ func NewLLMContextProvider(llmProvider func(context.Context, string) (string, error), logger *zap.Logger) *LLMContextProvider

+ func (p *LLMContextProvider) GenerateContext(ctx context.Context, doc Document, chunk string) (string, error)

+ type LLMReranker struct

+ func NewLLMReranker(provider LLMRerankerProvider, config LLMRerankerConfig, logger *zap.Logger) *LLMReranker

+ func (r *LLMReranker) Rerank(ctx context.Context, query string, results []RetrievalResult) ([]RetrievalResult, error)

+ type LLMRerankerConfig struct

+ MaxCandidates int

+ PromptTemplate string

+ Temperature float64

+ func DefaultLLMRerankerConfig() LLMRerankerConfig

+ type LLMRerankerProvider interface

+ ScoreRelevance func(ctx context.Context, query, document string) (float64, error)

+ type LLMTokenizerAdapter struct

+ func NewLLMTokenizerAdapter(inner lltok.Tokenizer, logger *zap.Logger) *LLMTokenizerAdapter

+ func (a *LLMTokenizerAdapter) CountTokens(text string) int

+ func (a *LLMTokenizerAdapter) Encode(text string) []int

+ type MilvusConfig struct

+ AutoCreateCollection bool

+ BaseURL string

+ BatchSize int

+ Collection string

+ ConsistencyLevel string

+ ContentField string

+ Database string

+ Host string

+ IndexParams map[string]any

+ IndexType MilvusIndexType

+ MetadataField string

+ MetricType MilvusMetricType

+ Password string

+ Port int

+ PrimaryField string

+ SearchParams map[string]any

+ Timeout time.Duration

+ Token string

+ Username string

+ VectorDimension int

+ VectorField string

+ type MilvusIndexType string

+ const MilvusIndexFlat

+ const MilvusIndexHNSW

+ const MilvusIndexIVFFlat

+ const MilvusIndexIVFPQ

+ const MilvusIndexIVFSQ8

+ type MilvusMetricType string

+ const MilvusMetricCosine

+ const MilvusMetricIP

+ const MilvusMetricL2

+ type MilvusStore struct

+ func NewMilvusStore(cfg MilvusConfig, logger *zap.Logger) *MilvusStore

+ func (s *MilvusStore) AddDocuments(ctx context.Context, docs []Document) error

+ func (s *MilvusStore) ClearAll(ctx context.Context) error

+ func (s *MilvusStore) Count(ctx context.Context) (int, error)

+ func (s *MilvusStore) DeleteDocuments(ctx context.Context, ids []string) error

+ func (s *MilvusStore) DropCollection(ctx context.Context) error

+ func (s *MilvusStore) Flush(ctx context.Context) error

+ func (s *MilvusStore) ListDocumentIDs(ctx context.Context, limit int, offset int) ([]string, error)

+ func (s *MilvusStore) Search(ctx context.Context, queryEmbedding []float64, topK int) ([]VectorSearchResult, error)

+ func (s *MilvusStore) UpdateDocument(ctx context.Context, doc Document) error

+ type MultiHopConfig struct

+ CacheTTL time.Duration

+ ConfidenceThreshold float64

+ ContextWindowSize int

+ DeduplicateResults bool

+ EnableCache bool

+ EnableLLMReasoning bool

+ EnableQueryRefinement bool

+ EnableVerification bool

+ HopTimeout time.Duration

+ MaxHops int

+ MinConfidence float64

+ MinHops int

+ ResultsPerHop int

+ SimilarityThreshold float64

+ TotalTimeout time.Duration

+ func DefaultMultiHopConfig() MultiHopConfig

+ type MultiHopReasoner struct

+ func NewMultiHopReasoner(config MultiHopConfig, retriever *HybridRetriever, ...) *MultiHopReasoner

+ func (r *MultiHopReasoner) Reason(ctx context.Context, query string) (*ReasoningChain, error)

+ func (r *MultiHopReasoner) ReasonBatch(ctx context.Context, queries []string) ([]*ReasoningChain, error)

+ type MultiStrategyDecision struct

+ Query string

+ Reasoning string

+ Strategies []StrategyWithWeight

+ Timestamp time.Time

+ type Node struct

+ CreatedAt time.Time

+ Embedding []float64

+ ID string

+ Label string

+ Properties map[string]any

+ Type string

+ type PineconeConfig struct

+ APIKey string

+ BaseURL string

+ ControllerBaseURL string

+ Index string

+ MetadataContentField string

+ Namespace string

+ Timeout time.Duration

+ type PineconeStore struct

+ func NewPineconeStore(cfg PineconeConfig, logger *zap.Logger) *PineconeStore

+ func (s *PineconeStore) AddDocuments(ctx context.Context, docs []Document) error

+ func (s *PineconeStore) ClearAll(ctx context.Context) error

+ func (s *PineconeStore) Count(ctx context.Context) (int, error)

+ func (s *PineconeStore) DeleteDocuments(ctx context.Context, ids []string) error

+ func (s *PineconeStore) ListDocumentIDs(ctx context.Context, limit int, offset int) ([]string, error)

+ func (s *PineconeStore) Search(ctx context.Context, queryEmbedding []float64, topK int) ([]VectorSearchResult, error)

+ func (s *PineconeStore) UpdateDocument(ctx context.Context, doc Document) error

+ type QdrantConfig struct

+ APIKey string

+ AutoCreateCollection bool

+ BaseURL string

+ Collection string

+ Distance string

+ Host string

+ PayloadContentField string

+ PayloadIDField string

+ PayloadMetadataField string

+ Port int

+ Timeout time.Duration

+ VectorSize int

+ Wait *bool

+ type QdrantStore struct

+ func NewQdrantStore(cfg QdrantConfig, logger *zap.Logger) *QdrantStore

+ func (s *QdrantStore) AddDocuments(ctx context.Context, docs []Document) error

+ func (s *QdrantStore) ClearAll(ctx context.Context) error

+ func (s *QdrantStore) Count(ctx context.Context) (int, error)

+ func (s *QdrantStore) DeleteDocuments(ctx context.Context, ids []string) error

+ func (s *QdrantStore) ListDocumentIDs(ctx context.Context, limit int, offset int) ([]string, error)

+ func (s *QdrantStore) Search(ctx context.Context, queryEmbedding []float64, topK int) ([]VectorSearchResult, error)

+ func (s *QdrantStore) UpdateDocument(ctx context.Context, doc Document) error

+ type QueryDocPair struct

+ Document string

+ Query string

+ type QueryFeatures struct

+ Complexity string

+ Entities []string

+ HasEntities bool

+ HasKeywords bool

+ Intent QueryIntent

+ IsQuestion bool

+ Keywords []string

+ Length string

+ WordCount int

+ type QueryIntent string

+ const IntentAggregation

+ const IntentAnalytical

+ const IntentCausal

+ const IntentComparison

+ const IntentCreative

+ const IntentExplanation

+ const IntentFactual

+ const IntentHypothetical

+ const IntentProcedural

+ const IntentTemporal

+ const IntentUnknown

+ type QueryLLMProvider interface

+ Complete func(ctx context.Context, prompt string) (string, error)

+ type QueryRouter struct

+ func NewQueryRouter(config QueryRouterConfig, queryTransformer *QueryTransformer, ...) *QueryRouter

+ func (r *QueryRouter) GetStrategyStats() map[RetrievalStrategy]StrategyStats

+ func (r *QueryRouter) RecordFeedback(feedback RoutingFeedback)

+ func (r *QueryRouter) Route(ctx context.Context, query string) (*RoutingDecision, error)

+ func (r *QueryRouter) RouteBatch(ctx context.Context, queries []string) ([]*RoutingDecision, error)

+ func (r *QueryRouter) RouteMulti(ctx context.Context, query string, maxStrategies int) (*MultiStrategyDecision, error)

+ type QueryRouterConfig struct

+ CacheTTL time.Duration

+ ConfidenceThreshold float64

+ DefaultStrategy RetrievalStrategy

+ EnableAdaptiveRouting bool

+ EnableCache bool

+ EnableFallback bool

+ EnableLLMRouting bool

+ FallbackStrategy RetrievalStrategy

+ LogDecisions bool

+ Strategies []StrategyConfig

+ func DefaultQueryRouterConfig() QueryRouterConfig

+ type QueryTransformConfig struct

+ CacheTTL time.Duration

+ DecomposeThreshold float64

+ EnableCache bool

+ EnableDecomposition bool

+ EnableExpansion bool

+ EnableHyDE bool

+ EnableIntentDetection bool

+ EnableRewriting bool

+ EnableStepBack bool

+ ExpansionDiversity float64

+ HyDEDocumentCount int

+ MaxExpansions int

+ MaxSubQueries int

+ RewriteForRetrieval bool

+ Temperature float64

+ UseLLM bool

+ func DefaultQueryTransformConfig() QueryTransformConfig

+ type QueryTransformer struct

+ func NewQueryTransformer(config QueryTransformConfig, llmProvider QueryLLMProvider, logger *zap.Logger) *QueryTransformer

+ func (t *QueryTransformer) Expand(ctx context.Context, query string) ([]string, error)

+ func (t *QueryTransformer) ExpandWithMetadata(ctx context.Context, query string) (*ExpansionResult, error)

+ func (t *QueryTransformer) Transform(ctx context.Context, query string) (*TransformedQuery, error)

+ func (t *QueryTransformer) TransformBatch(ctx context.Context, queries []string) ([]*TransformedQuery, error)

+ type ReasoningChain struct

+ CompletedAt time.Time

+ CreatedAt time.Time

+ FinalAnswer string

+ FinalContext string

+ Hops []ReasoningHop

+ ID string

+ Metadata map[string]any

+ OriginalQuery string

+ Status ReasoningStatus

+ TotalDedupByID int

+ TotalDedupBySimilarity int

+ TotalDuration time.Duration

+ TotalRetrieval int

+ UniqueDocuments int

+ func (c *ReasoningChain) FromJSON(data []byte) error

+ func (c *ReasoningChain) GetAllDocuments() []Document

+ func (c *ReasoningChain) GetHop(hopNum int) *ReasoningHop

+ func (c *ReasoningChain) GetTopDocuments(k int) []RetrievalResult

+ func (c *ReasoningChain) ToJSON() ([]byte, error)

+ func (c *ReasoningChain) Visualize() *ChainVisualization

+ type ReasoningHop struct

+ Confidence float64

+ Context string

+ DedupStats *DedupStats

+ Duration time.Duration

+ HopNumber int

+ ID string

+ Metadata map[string]any

+ Query string

+ Reasoning string

+ Results []RetrievalResult

+ Timestamp time.Time

+ TransformedQuery string

+ Type HopType

+ type ReasoningStatus string

+ const StatusCompleted

+ const StatusFailed

+ const StatusInProgress

+ const StatusTimeout

+ type RerankProvider interface

+ Name func() string

+ RerankSimple func(ctx context.Context, query string, documents []string, topN int) ([]rerank.RerankResult, error)

+ type RerankProviderType string

+ const RerankCohere

+ const RerankJina

+ const RerankVoyage

+ type Reranker interface

+ Rerank func(ctx context.Context, query string, results []RetrievalResult) ([]RetrievalResult, error)

+ type RerankerType string

+ const RerankerCrossEncoder

+ const RerankerLLM

+ const RerankerSimple

+ type RetrievalResult struct

+ BM25Score float64

+ Document Document

+ FinalScore float64

+ HybridScore float64

+ RerankScore float64

+ VectorScore float64

+ type RetrievalStrategy string

+ const StrategyBM25

+ const StrategyContextual

+ const StrategyDense

+ const StrategyGraphRAG

+ const StrategyHybrid

+ const StrategyMultiHop

+ const StrategySparse

+ const StrategyVector

+ type RetrieverOption func(*retrieverOptions)

+ func WithEmbeddingType(t EmbeddingProviderType) RetrieverOption

+ func WithLogger(l *zap.Logger) RetrieverOption

+ func WithRerankType(t RerankProviderType) RetrieverOption

+ type RoutingCondition struct

+ Operator string

+ Type string

+ Value string

+ Weight float64

+ type RoutingDecision struct

+ Confidence float64

+ Metadata map[string]any

+ Query string

+ Reasoning string

+ Scores map[RetrievalStrategy]float64

+ SelectedStrategy RetrievalStrategy

+ Timestamp time.Time

+ func (d *RoutingDecision) FromJSON(data []byte) error

+ func (d *RoutingDecision) ToJSON() ([]byte, error)

+ type RoutingFeedback struct

+ Query string

+ Score float64

+ SelectedStrategy RetrievalStrategy

+ Success bool

+ Timestamp time.Time

+ type SearchResult struct

+ Distance float64

+ ID string

+ Score float64

+ type SemanticCache struct

+ func NewSemanticCache(store VectorStore, config SemanticCacheConfig, logger *zap.Logger) *SemanticCache

+ func (c *SemanticCache) Clear(ctx context.Context) error

+ func (c *SemanticCache) Get(ctx context.Context, queryEmbedding []float64) (*Document, bool)

+ func (c *SemanticCache) Set(ctx context.Context, doc Document) error

+ type SemanticCacheConfig struct

+ SimilarityThreshold float64

+ type SimpleContextProvider struct

+ func NewSimpleContextProvider(logger *zap.Logger) *SimpleContextProvider

+ func (p *SimpleContextProvider) GenerateContext(ctx context.Context, doc Document, chunk string) (string, error)

+ type SimpleGraphEmbedder struct

+ func NewSimpleGraphEmbedder(config SimpleGraphEmbedderConfig, logger *zap.Logger) *SimpleGraphEmbedder

+ func (e *SimpleGraphEmbedder) Embed(ctx context.Context, text string) ([]float64, error)

+ type SimpleGraphEmbedderConfig struct

+ Dimension int

+ type SimpleReranker struct

+ func NewSimpleReranker(logger *zap.Logger) *SimpleReranker

+ func (r *SimpleReranker) Rerank(ctx context.Context, query string, results []RetrievalResult) ([]RetrievalResult, error)

+ type SimpleTokenizer struct

+ func (t *SimpleTokenizer) CountTokens(text string) int

+ func (t *SimpleTokenizer) Encode(text string) []int

+ type StrategyConfig struct

+ Conditions []RoutingCondition

+ Enabled bool

+ MaxTokens int

+ MinScore float64

+ Strategy RetrievalStrategy

+ Weight float64

+ type StrategyStats struct

+ AverageScore float64

+ Strategy RetrievalStrategy

+ SuccessRate float64

+ TotalCalls int

+ type StrategyWithWeight struct

+ Strategy RetrievalStrategy

+ Weight float64

+ type StructuralBlock struct

+ Content string

+ EndPos int

+ StartPos int

+ Type string

+ type Tokenizer interface

+ CountTokens func(text string) int

+ Encode func(text string) []int

+ func NewEstimatorAdapter(model string, maxTokens int, logger *zap.Logger) Tokenizer

+ func NewTiktokenAdapter(model string, logger *zap.Logger) (Tokenizer, error)

+ type TransformationType string

+ const TransformDecomposition

+ const TransformExpansion

+ const TransformHyDE

+ const TransformRewrite

+ const TransformStepBack

+ type TransformedQuery struct

+ Confidence float64

+ Entities []string

+ Intent QueryIntent

+ Keywords []string

+ Metadata map[string]any

+ Original string

+ SubQueries []string

+ Transformed string

+ Type TransformationType

+ func (tq *TransformedQuery) FromJSON(data []byte) error

+ func (tq *TransformedQuery) ToJSON() ([]byte, error)

+ type Triple struct

+ Object string

+ Predicate string

+ Subject string

+ type VectorIndex interface

+ Add func(vector []float64, id string) error

+ Build func(vectors [][]float64, ids []string) error

+ Delete func(id string) error

+ Search func(query []float64, k int) ([]SearchResult, error)

+ Size func() int

+ type VectorSearchResult struct

+ Distance float64

+ Document Document

+ Score float64

+ type VectorStore interface

+ AddDocuments func(ctx context.Context, docs []Document) error

+ Count func(ctx context.Context) (int, error)

+ DeleteDocuments func(ctx context.Context, ids []string) error

+ Search func(ctx context.Context, queryEmbedding []float64, topK int) ([]VectorSearchResult, error)

+ UpdateDocument func(ctx context.Context, doc Document) error

+ func NewPineconeVectorStore(cfg PineconeConfig, logger *zap.Logger) VectorStore

+ func NewVectorStoreFromConfig(cfg *config.Config, storeType VectorStoreType, logger *zap.Logger) (VectorStore, error)

+ type VectorStoreType string

+ const VectorStoreMemory

+ const VectorStoreMilvus

+ const VectorStorePinecone

+ const VectorStoreQdrant

+ const VectorStoreWeaviate

+ type VisualizationEdge struct

+ Label string

+ Source string

+ Target string

+ Weight float64

+ type VisualizationNode struct

+ ID string

+ Label string

+ Metadata map[string]any

+ Type string

+ type WeaviateConfig struct

+ APIKey string

+ AutoCreateSchema bool

+ BaseURL string

+ ClassName string

+ ContentProperty string

+ Distance string

+ DocIDProperty string

+ Host string

+ HybridAlpha float64

+ MetadataProperty string

+ Port int

+ Scheme string

+ Timeout time.Duration

+ VectorIndexType string

+ VectorSize int

+ type WeaviateStore struct

+ func NewWeaviateStore(cfg WeaviateConfig, logger *zap.Logger) *WeaviateStore

+ func (s *WeaviateStore) AddDocuments(ctx context.Context, docs []Document) error

+ func (s *WeaviateStore) BM25Search(ctx context.Context, queryText string, topK int) ([]VectorSearchResult, error)

+ func (s *WeaviateStore) ClearAll(ctx context.Context) error

+ func (s *WeaviateStore) Count(ctx context.Context) (int, error)

+ func (s *WeaviateStore) DeleteClass(ctx context.Context) error

+ func (s *WeaviateStore) DeleteDocuments(ctx context.Context, ids []string) error

+ func (s *WeaviateStore) GetSchema(ctx context.Context) (map[string]any, error)

+ func (s *WeaviateStore) HybridSearch(ctx context.Context, queryText string, queryEmbedding []float64, topK int) ([]VectorSearchResult, error)

+ func (s *WeaviateStore) ListDocumentIDs(ctx context.Context, limit int, offset int) ([]string, error)

+ func (s *WeaviateStore) Search(ctx context.Context, queryEmbedding []float64, topK int) ([]VectorSearchResult, error)

+ func (s *WeaviateStore) UpdateDocument(ctx context.Context, doc Document) error

+ type WebRetrievalResult struct

+ Content string

+ Score float64

+ Title string

+ URL string

+ type WebRetriever struct

+ func NewWebRetriever(config WebRetrieverConfig, localRetriever *HybridRetriever, ...) *WebRetriever

+ func (wr *WebRetriever) Retrieve(ctx context.Context, query string, queryEmbedding []float64) ([]RetrievalResult, error)

+ type WebRetrieverConfig struct

+ CacheTTL time.Duration

+ DeduplicateByURL bool

+ EnableCache bool

+ FallbackToLocal bool

+ FallbackToWeb bool

+ LocalWeight float64

+ MaxWebResults int

+ MinScore float64

+ ParallelSearch bool

+ TopK int

+ WebSearchTimeout time.Duration

+ WebWeight float64

+ func DefaultWebRetrieverConfig() WebRetrieverConfig

+ type WebSearchFunc func(ctx context.Context, query string, maxResults int) ([]WebRetrievalResult, error)

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