vectorstore

Jun 19, 2026

Changes in this version

type SyncManager

+ func (s *SyncManager) SetRemoteMutex(mu *sync.Mutex)

Feb 1, 2026

Changes in this version

+ func CalculateMRR(results []SearchResult, relevantDocs []string) float64

+ func CalculateNDCG(results []SearchResult, expectedRanking []string, k int) float64

+ func CalculatePrecisionAtK(results []SearchResult, relevantDocs []string, k int) float64

+ func NewResilientChromemDB(path string, compress bool, logger *zap.Logger) (*chromem.DB, error)

+ func RecordHealthCheckResult(success bool)

+ func RecordQuarantineResult(success bool)

+ func UpdateHealthMetrics(health *MetadataHealth)

+ type BackgroundScanner struct

+ func NewBackgroundScanner(checker *MetadataHealthChecker, config *BackgroundScannerConfig, ...) *BackgroundScanner

+ func (s *BackgroundScanner) IsRunning() bool

+ func (s *BackgroundScanner) LastError() error

+ func (s *BackgroundScanner) LastHealth() *MetadataHealth

+ func (s *BackgroundScanner) Start(ctx context.Context)

+ func (s *BackgroundScanner) Stop()

+ type BackgroundScannerConfig struct

+ Interval time.Duration

+ OnDegraded func(health *MetadataHealth)

+ OnError func(err error)

+ OnRecovered func(health *MetadataHealth)

+ type CircuitBreaker struct

+ func NewCircuitBreaker(threshold int32, resetAfter time.Duration) *CircuitBreaker

+ func (cb *CircuitBreaker) Allow() bool

+ func (cb *CircuitBreaker) RecordFailure()

+ func (cb *CircuitBreaker) RecordSuccess()

+ func (cb *CircuitBreaker) State() string

+ type FallbackConfig struct

+ Enabled bool

+ HealthCheckInterval string

+ LocalPath string

+ SyncOnConnect bool

+ WALPath string

+ WALRetentionDays int

+ func (c *FallbackConfig) ApplyDefaults()

+ func (c *FallbackConfig) Validate() error

+ type FallbackStore struct

+ func NewFallbackStore(ctx context.Context, remote, local Store, health *HealthMonitor, wal *WAL, ...) (*FallbackStore, error)

+ func (fs *FallbackStore) AddDocuments(ctx context.Context, docs []Document) ([]string, error)

+ func (fs *FallbackStore) Close() error

+ func (fs *FallbackStore) CollectionExists(ctx context.Context, collectionName string) (bool, error)

+ func (fs *FallbackStore) CreateCollection(ctx context.Context, collectionName string, vectorSize int) error

+ func (fs *FallbackStore) DeleteCollection(ctx context.Context, collectionName string) error

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

+ func (fs *FallbackStore) DeleteDocumentsFromCollection(ctx context.Context, collectionName string, ids []string) error

+ func (fs *FallbackStore) ExactSearch(ctx context.Context, collectionName string, query string, k int) ([]SearchResult, error)

+ func (fs *FallbackStore) GetCollectionInfo(ctx context.Context, collectionName string) (*CollectionInfo, error)

+ func (fs *FallbackStore) IsolationMode() IsolationMode

+ func (fs *FallbackStore) ListCollections(ctx context.Context) ([]string, error)

+ func (fs *FallbackStore) Search(ctx context.Context, query string, k int) ([]SearchResult, error)

+ func (fs *FallbackStore) SearchInCollection(ctx context.Context, collectionName string, query string, k int, ...) ([]SearchResult, error)

+ func (fs *FallbackStore) SearchWithFilters(ctx context.Context, query string, k int, filters map[string]interface{}) ([]SearchResult, error)

+ func (fs *FallbackStore) SetIsolationMode(mode IsolationMode)

+ type GRPCHealthChecker struct

+ func NewGRPCHealthChecker(conn *grpc.ClientConn, logger *zap.Logger) *GRPCHealthChecker

+ func (g *GRPCHealthChecker) IsHealthy(ctx context.Context) bool

+ func (g *GRPCHealthChecker) WatchState(ctx context.Context, callback func(healthy bool)) error

+ type HealthChecker interface

+ IsHealthy func(ctx context.Context) bool

+ WatchState func(ctx context.Context, callback func(healthy bool)) error

+ type HealthMonitor struct

+ func NewHealthMonitor(ctx context.Context, checker HealthChecker, checkInterval time.Duration, ...) *HealthMonitor

+ func (hm *HealthMonitor) IsHealthy() bool

+ func (hm *HealthMonitor) LastCheck() time.Time

+ func (hm *HealthMonitor) RegisterCallback(cb func(bool)) error

+ func (hm *HealthMonitor) SetCallbackTimeout(timeout time.Duration)

+ func (hm *HealthMonitor) Start()

+ func (hm *HealthMonitor) Stop()

+ type MetadataHealth struct

+ CheckDuration time.Duration

+ Corrupt []string

+ CorruptCount int

+ Details map[string]string

+ Empty []string

+ Healthy []string

+ HealthyCount int

+ LastCheckTime time.Time

+ Total int

+ func (h *MetadataHealth) IsHealthy() bool

+ func (h *MetadataHealth) Status() string

+ type MetadataHealthChecker struct

+ func NewMetadataHealthChecker(path string, logger *zap.Logger) *MetadataHealthChecker

+ func (c *MetadataHealthChecker) Check(ctx context.Context) (*MetadataHealth, error)

+ type Metrics struct

+ func NewMetrics(logger *zap.Logger) *Metrics

+ func (m *Metrics) RecordDocuments(ctx context.Context, op, collection string, count int)

+ func (m *Metrics) RecordOperation(ctx context.Context, op, collection string, duration time.Duration, err error)

+ func (m *Metrics) RecordSearchResults(ctx context.Context, collection string, count int)

+ type MockHealthChecker struct

+ func NewMockHealthChecker() *MockHealthChecker

+ func (m *MockHealthChecker) IsHealthy(ctx context.Context) bool

+ func (m *MockHealthChecker) SetHealthy(healthy bool)

+ func (m *MockHealthChecker) WatchState(ctx context.Context, callback func(healthy bool)) error

+ type QualityMetrics struct

+ K int

+ MRR float64

+ NDCG float64

+ PrecisionAtK float64

+ func CalculateAllMetrics(results []SearchResult, expectedRanking []string, relevantDocs []string, k int) QualityMetrics

+ type StartupValidationConfig struct

+ FailOnCorruption bool

+ FailOnDegraded bool

+ type StartupValidationResult struct

+ ErrorCount int

+ Health *MetadataHealth

+ Messages []string

+ Passed bool

+ WarningCount int

+ func ValidateStartup(ctx context.Context, checker *MetadataHealthChecker, ...) (*StartupValidationResult, error)

+ type SyncManager struct

+ func NewSyncManager(ctx context.Context, wal *WAL, local, remote Store, health *HealthMonitor, ...) *SyncManager

+ func (s *SyncManager) Start()

+ func (s *SyncManager) Stop() error

+ func (s *SyncManager) TriggerSync()

+ type WAL struct

+ func NewWAL(path string, scrubber secrets.Scrubber, logger *zap.Logger) (*WAL, error)

+ func (w *WAL) Close() error

+ func (w *WAL) Compact(retentionDays int) error

+ func (w *WAL) MarkSynced(id string) error

+ func (w *WAL) PendingEntries() []WALEntry

+ func (w *WAL) RecordSyncAttempt(id string, err error) error

+ func (w *WAL) WriteEntry(ctx context.Context, entry WALEntry) error

+ type WALEntry struct

+ Checksum []byte

+ Docs []Document

+ ID string

+ IDs []string

+ LastAttempt time.Time

+ Operation string

+ RemoteState string

+ SyncAttempts int

+ SyncError string

+ Synced bool

+ Timestamp time.Time

Jan 8, 2026

Changes in this version

+ var ErrInvalidTenant = errors.New("invalid tenant identifier")

+ var ErrMissingTenant = errors.New("tenant info missing from context")

+ var ErrTenantFilterInUserFilters = errors.New("user filters cannot contain tenant fields")

+ var OptionalTenantFields = []string

+ var RequiredTenantFields = []string

+ func ApplyTenantFilters(userFilters, tenantFilters map[string]interface{}) (map[string]interface{}, error)

+ func ContextWithTenant(ctx context.Context, tenant *TenantInfo) context.Context

+ func HasTenant(ctx context.Context) bool

+ func MergeFilters(base, override map[string]interface{}) map[string]interface

+ func ValidateFilterHasTenant(filters map[string]interface{}) error

+ type ChromemConfig struct

+ Compress bool

+ DefaultCollection string

+ Isolation IsolationMode

+ Path string

+ VectorSize int

+ func (c *ChromemConfig) ApplyDefaults()

+ func (c *ChromemConfig) Validate() error

+ type ChromemStore struct

+ func NewChromemStore(config ChromemConfig, embedder Embedder, logger *zap.Logger) (*ChromemStore, error)

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

+ func (s *ChromemStore) Close() error

+ func (s *ChromemStore) CollectionExists(ctx context.Context, collectionName string) (bool, error)

+ func (s *ChromemStore) CreateCollection(ctx context.Context, collectionName string, vectorSize int) error

+ func (s *ChromemStore) DeleteCollection(ctx context.Context, collectionName string) error

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

+ func (s *ChromemStore) DeleteDocumentsFromCollection(ctx context.Context, collectionName string, ids []string) error

+ func (s *ChromemStore) ExactSearch(ctx context.Context, collectionName string, query string, k int) ([]SearchResult, error)

+ func (s *ChromemStore) GetCollectionInfo(ctx context.Context, collectionName string) (*CollectionInfo, error)

+ func (s *ChromemStore) IsolationMode() IsolationMode

+ func (s *ChromemStore) ListCollections(ctx context.Context) ([]string, error)

+ func (s *ChromemStore) Search(ctx context.Context, query string, k int) ([]SearchResult, error)

+ func (s *ChromemStore) SearchInCollection(ctx context.Context, collectionName string, query string, k int, ...) ([]SearchResult, error)

+ func (s *ChromemStore) SearchWithFilters(ctx context.Context, query string, k int, filters map[string]interface{}) ([]SearchResult, error)

+ func (s *ChromemStore) SetIsolationMode(mode IsolationMode)

+ type ChromemStoreProvider struct

+ func NewChromemStoreProvider(config ProviderConfig, embedder Embedder, logger *zap.Logger) (*ChromemStoreProvider, error)

+ func (p *ChromemStoreProvider) Close() error

+ func (p *ChromemStoreProvider) GetOrgStore(ctx context.Context, tenant string) (Store, error)

+ func (p *ChromemStoreProvider) GetProjectStore(ctx context.Context, tenant, team, project string) (Store, error)

+ func (p *ChromemStoreProvider) GetTeamStore(ctx context.Context, tenant, team string) (Store, error)

+ func (p *ChromemStoreProvider) Registry() *registry.Registry

+ type FilesystemIsolation struct

+ func NewFilesystemIsolation() *FilesystemIsolation

+ func (f *FilesystemIsolation) InjectFilter(ctx context.Context, filters map[string]interface{}) (map[string]interface{}, error)

+ func (f *FilesystemIsolation) InjectMetadata(ctx context.Context, docs []Document) error

+ func (f *FilesystemIsolation) Mode() string

+ func (f *FilesystemIsolation) ValidateTenant(ctx context.Context) error

+ type FilterBuilder struct

+ func NewFilterBuilder() *FilterBuilder

+ func (b *FilterBuilder) Build() map[string]interface{}

+ func (b *FilterBuilder) With(key string, value interface{}) *FilterBuilder

+ func (b *FilterBuilder) WithMap(m map[string]interface{}) *FilterBuilder

+ func (b *FilterBuilder) WithTenant(tenant *TenantInfo) *FilterBuilder

+ type IsolationMode interface

+ InjectFilter func(ctx context.Context, filters map[string]interface{}) (map[string]interface{}, error)

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

+ Mode func() string

+ ValidateTenant func(ctx context.Context) error

+ func IsolationModeFromString(mode string) (IsolationMode, error)

+ type MetadataBuilder struct

+ func NewMetadataBuilder() *MetadataBuilder

+ func (b *MetadataBuilder) Build() map[string]interface{}

+ func (b *MetadataBuilder) With(key string, value interface{}) *MetadataBuilder

+ func (b *MetadataBuilder) WithMap(m map[string]interface{}) *MetadataBuilder

+ func (b *MetadataBuilder) WithTenant(tenant *TenantInfo) *MetadataBuilder

+ type NoIsolation struct

+ func NewNoIsolation() *NoIsolation

+ func (n *NoIsolation) InjectFilter(ctx context.Context, filters map[string]interface{}) (map[string]interface{}, error)

+ func (n *NoIsolation) InjectMetadata(ctx context.Context, docs []Document) error

+ func (n *NoIsolation) Mode() string

+ func (n *NoIsolation) ValidateTenant(ctx context.Context) error

+ type PayloadIsolation struct

+ func NewPayloadIsolation() *PayloadIsolation

+ func (p *PayloadIsolation) InjectFilter(ctx context.Context, filters map[string]interface{}) (map[string]interface{}, error)

+ func (p *PayloadIsolation) InjectMetadata(ctx context.Context, docs []Document) error

+ func (p *PayloadIsolation) Mode() string

+ func (p *PayloadIsolation) ValidateTenant(ctx context.Context) error

+ type ProviderConfig struct

+ BasePath string

+ Compress bool

+ LocalModeAcknowledged bool

+ VectorSize int

+ func (c *ProviderConfig) ApplyDefaults()

type QdrantConfig

+ Isolation IsolationMode

type QdrantStore

+ func (s *QdrantStore) IsolationMode() IsolationMode

+ func (s *QdrantStore) SetIsolationMode(mode IsolationMode)

type Store

+ func NewStore(cfg *config.Config, embedder Embedder, logger *zap.Logger, opts ...StoreOption) (Store, error)

+ func NewStoreFromProvider(provider string, chromemCfg *ChromemConfig, qdrantCfg *QdrantConfig, ...) (Store, error)

+ IsolationMode func() IsolationMode

+ SetIsolationMode func(mode IsolationMode)

+ type StoreOption func(store Store)

+ func WithIsolation(mode IsolationMode) StoreOption

+ type StoreProvider interface

+ Close func() error

+ GetOrgStore func(ctx context.Context, tenant string) (Store, error)

+ GetProjectStore func(ctx context.Context, tenant, team, project string) (Store, error)

+ GetTeamStore func(ctx context.Context, tenant, team string) (Store, error)

+ type TenantInfo struct

+ ProjectID string

+ TeamID string

+ TenantID string

+ func ExtractTenantFromFilters(filters map[string]interface{}) (*TenantInfo, error)

+ func MustTenantFromContext(ctx context.Context) *TenantInfo

+ func TenantFromContext(ctx context.Context) (*TenantInfo, error)

+ func (t *TenantInfo) TenantFilter() map[string]interface{}

+ func (t *TenantInfo) TenantMetadata() map[string]interface{}

+ func (t *TenantInfo) Validate() error

Dec 3, 2025

Changes in this version

+ var ErrCollectionExists = errors.New("collection already exists")

+ var ErrCollectionNotFound = errors.New("collection not found")

+ var ErrConnectionFailed = errors.New("failed to connect to Qdrant")

+ var ErrEmbeddingFailed = errors.New("failed to generate embeddings")

+ var ErrEmptyDocuments = errors.New("empty or nil documents")

+ var ErrInvalidCollectionName = errors.New("invalid collection name")

+ var ErrInvalidConfig = errors.New("invalid configuration")

+ func IsTransientError(err error) bool

+ func ValidateCollectionName(name string) error

+ type CollectionInfo struct

+ Name string

+ PointCount int

+ VectorSize int

+ type CompressionLevel string

+ const CompressionLevelFolded

+ const CompressionLevelNone

+ const CompressionLevelSummary

+ type CompressionMetadata struct

+ Algorithm string

+ CompressedAt *time.Time

+ CompressedSize int

+ CompressionRatio float64

+ Level CompressionLevel

+ OriginalSize int

+ type Document struct

+ Collection string

+ Content string

+ ID string

+ Metadata map[string]interface{}

+ type Embedder interface

+ EmbedDocuments func(ctx context.Context, texts []string) ([][]float32, error)

+ EmbedQuery func(ctx context.Context, text string) ([]float32, error)

+ type QdrantConfig struct

+ CircuitBreakerThreshold int

+ CollectionName string

+ Distance qdrant.Distance

+ Host string

+ MaxMessageSize int

+ MaxRetries int

+ Port int

+ RetryBackoff time.Duration

+ UseTLS bool

+ VectorSize uint64

+ func (c *QdrantConfig) ApplyDefaults()

+ func (c QdrantConfig) Validate() error

+ type QdrantStore struct

+ func NewQdrantStore(config QdrantConfig, embedder Embedder) (*QdrantStore, error)

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

+ func (s *QdrantStore) Close() error

+ func (s *QdrantStore) CollectionExists(ctx context.Context, collectionName string) (bool, error)

+ func (s *QdrantStore) CreateCollection(ctx context.Context, collectionName string, vectorSize int) error

+ func (s *QdrantStore) DeleteCollection(ctx context.Context, collectionName string) error

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

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

+ func (s *QdrantStore) ExactSearch(ctx context.Context, collectionName string, query string, k int) ([]SearchResult, error)

+ func (s *QdrantStore) GetCollectionInfo(ctx context.Context, collectionName string) (*CollectionInfo, error)

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

+ func (s *QdrantStore) Search(ctx context.Context, query string, k int) ([]SearchResult, error)

+ func (s *QdrantStore) SearchInCollection(ctx context.Context, collectionName string, query string, k int, ...) ([]SearchResult, error)

+ func (s *QdrantStore) SearchWithFilters(ctx context.Context, query string, k int, filters map[string]interface{}) ([]SearchResult, error)

+ type SearchResult struct

+ Content string

+ ID string

+ Metadata map[string]interface{}

+ Score float32

+ type Store interface

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

+ Close func() error

+ CollectionExists func(ctx context.Context, collectionName string) (bool, error)

+ CreateCollection func(ctx context.Context, collectionName string, vectorSize int) error

+ DeleteCollection func(ctx context.Context, collectionName string) error

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

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

+ ExactSearch func(ctx context.Context, collectionName string, query string, k int) ([]SearchResult, error)

+ GetCollectionInfo func(ctx context.Context, collectionName string) (*CollectionInfo, error)

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

+ Search func(ctx context.Context, query string, k int) ([]SearchResult, error)

+ SearchInCollection func(ctx context.Context, collectionName string, query string, k int, ...) ([]SearchResult, error)

+ SearchWithFilters func(ctx context.Context, query string, k int, filters map[string]interface{}) ([]SearchResult, error)

+ type TroubleshootAdapter struct

+ func NewTroubleshootAdapter(store *QdrantStore) *TroubleshootAdapter

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

+ func (a *TroubleshootAdapter) SearchWithFilters(ctx context.Context, query string, k int, filters map[string]interface{}) ([]SearchResult, error)