veclite

Jul 12, 2026

Changes in this version

+ const DefaultWALCheckpointBytes

type Option

+ func WithWAL(enabled bool) Option

+ func WithWALCheckpoint(bytes int64) Option

Jul 9, 2026

Changes in this version

type EmbeddingProfile

+ func EmbedderProfile(e Embedder) (EmbeddingProfile, bool)

+ type ProfiledEmbedder interface

+ Profile func() EmbeddingProfile

Jun 23, 2026

Changes in this version

+ var ErrSharedReadRequiresReadOnly = errors.New("veclite: shared read requires read-only mode")

type DB

+ func (db *DB) Reload() error

type Option

+ func WithSharedRead(enabled bool) Option

Jun 21, 2026

Changes in this version

+ func ExpandEnvVars(s string) string

+ func ParseDuration(s string, defaultDur time.Duration) time.Duration

Jun 21, 2026

Changes in this version

type Collection

+ func (c *Collection) HybridSearchSpace(space string, query []float32, text string, opts ...SearchOption) ([]Result, error)

+ func (c *Collection) UpsertRecordByKey(keyField string, keyValue any, in RecordInput) (uint64, bool, error)

Jun 20, 2026

Changes in this version

+ const DefaultVectorSpace

+ var ErrInvalidVectorSpace = errors.New("veclite: invalid vector space")

+ var ErrProfileMismatch = errors.New("veclite: embedding profile mismatch")

+ var ErrVectorSpaceExists = errors.New("veclite: vector space already exists")

+ var ErrVectorSpaceNotFound = errors.New("veclite: vector space not found")

type Collection

+ func (c *Collection) AddVectorSpace(config VectorSpaceConfig) error

+ func (c *Collection) EmbeddingProfile() (EmbeddingProfile, bool)

+ func (c *Collection) HasVectorSpace(name string) bool

+ func (c *Collection) InsertRecord(in RecordInput) (uint64, error)

+ func (c *Collection) MultiSpaceSearch(queries map[string][]float32, opts ...SearchOption) ([]Result, error)

+ func (c *Collection) SearchSpace(space string, query []float32, opts ...SearchOption) ([]Result, error)

+ func (c *Collection) SetEmbeddingProfile(profile EmbeddingProfile) error

+ func (c *Collection) SetRecordVector(id uint64, space string, vector []float32) error

+ func (c *Collection) VectorSpace(name string) (VectorSpaceInfo, error)

+ func (c *Collection) VectorSpaces() []VectorSpaceInfo

type CollectionOption

+ func WithEmbeddingProfile(profile EmbeddingProfile) CollectionOption

+ func WithVectorSpace(config VectorSpaceConfig) CollectionOption

+ type EmbeddingProfile struct

+ Dimension int

+ Distance DistanceType

+ Model string

+ Normalize bool

+ Provider string

+ Version string

+ func (p EmbeddingProfile) Compatible(other EmbeddingProfile) error

+ func (p EmbeddingProfile) IsZero() bool

+ type FuseOption interface

+ func WithFusionTopK(n int) FuseOption

+ func WithFusionWeights(weights ...float64) FuseOption

+ func WithRRFK(k int) FuseOption

type Record

+ Vectors map[string][]float32

+ func (r *Record) VectorFor(space string) ([]float32, bool)

+ type RecordInput struct

+ Content string

+ ID uint64

+ Payload map[string]any

+ Vectors map[string][]float32

type Result

+ func FuseRRF(resultSets [][]Result, opts ...FuseOption) []Result

+ type VectorSpaceConfig struct

+ Dimension int

+ Distance DistanceType

+ HNSW *HNSWConfig

+ Modality string

+ Model string

+ Name string

+ Profile *EmbeddingProfile

+ Provider string

+ type VectorSpaceInfo struct

+ Dimension int

+ Distance DistanceType

+ IndexType string

+ Modality string

+ Model string

+ Name string

+ Profile *EmbeddingProfile

+ Provider string

+ VectorCount int

Jun 19, 2026

Changes in this version

type Collection

+ func (c *Collection) DeleteMetadataValue(key string) error

+ func (c *Collection) InsertTextDocument(content string, payload map[string]any) (uint64, error)

+ func (c *Collection) InsertTextDocumentWithOptions(content string, payload map[string]any, opts ...InsertOption) (uint64, error)

+ func (c *Collection) Metadata() map[string]any

+ func (c *Collection) SetMetadata(metadata map[string]any) error

+ func (c *Collection) SetMetadataValue(key string, value any) error

+ func (c *Collection) UpdateDocument(id uint64, content string, payload map[string]any) error

+ func (c *Collection) UpsertTextDocument(id uint64, content string, payload map[string]any) (uint64, error)

+ func (c *Collection) UpsertTextDocumentByKey(keyField string, keyValue any, content string, payload map[string]any) (uint64, bool, error)

type CollectionStats

+ TextOnlyCount int

+ VectorCount int

type DB

+ func (db *DB) DeleteMetadataValue(key string) error

+ func (db *DB) Metadata() map[string]any

+ func (db *DB) SetMetadata(metadata map[string]any) error

+ func (db *DB) SetMetadataValue(key string, value any) error

Apr 11, 2026

Changes in this version

+ const DistanceEuclideanSquared

type Collection

+ func (c *Collection) Reset() error

type DB

+ func (db *DB) GetEpisodeStore(name string) (*EpisodeStore, error)

+ func (db *DB) GetKnowledgeGraph(name string) (*KnowledgeGraph, error)

+ type EntitySnapshot = storage.EntitySnapshot

+ type EpisodeSnapshot = storage.EpisodeSnapshot

+ type EpisodeStoreSnapshot = storage.EpisodeStoreSnapshot

+ type GraphSnapshot = storage.GraphSnapshot

type Index

+ Clear func()

+ type RelationshipSnapshot = storage.RelationshipSnapshot

+ type TFEntry = storage.TFEntry

+ type TimeRangeSnapshot = storage.TimeRangeSnapshot

Feb 7, 2026

Changes in this version

+ type HNSWStats struct

+ EntryPointID uint64

+ MaxLevel int

+ NodeCount int

Jan 31, 2026

Changes in this version

+ func ExpandPath(path string) string

+ type Config struct

+ Embedder EmbedderConfig

+ func DefaultConfig() *Config

+ func LoadConfig(path string) (*Config, error)

type Embedder

+ func NewEmbedderFromConfig(cfg EmbedderConfig) (Embedder, error)

+ type EmbedderConfig struct

+ ONNX ONNXConfig

+ Ollama OllamaConfig

+ OpenAI OpenAIConfig

+ Provider string

+ type ONNXConfig struct

+ Model string

+ ModelDir string

+ type OllamaConfig struct

+ BaseURL string

+ Model string

+ Timeout string

+ type OpenAIConfig struct

+ APIKey string

+ BaseURL string

+ Dimension int

+ Model string

+ Timeout string

Jan 30, 2026

Changes in this version

type Collection

+ func (c *Collection) EnforceMemoryLimit(config MemoryConfig) int

+ func (c *Collection) StartMemoryLimiter(config MemoryConfig) func()

type CollectionOption

+ func WithMemoryLimits(config MemoryConfig) CollectionOption

type DB

+ func (db *DB) StartTTLCleaner(interval time.Duration, callback TTLCleanerCallback) func()

+ type MemoryConfig struct

+ CleanupInterval time.Duration

+ EvictionBatchSize int

+ EvictionPolicy string

+ MaxRecords int

+ type MemoryLimiter struct

+ func (ml *MemoryLimiter) Stop()

+ type TTLCleaner struct

+ func (tc *TTLCleaner) Stop()

+ type TTLCleanerCallback func(collection string, deleted int)

Jan 30, 2026

Changes in this version

+ const PayloadKeyArchived

+ const PayloadKeyChildChunks

+ const PayloadKeyConsolidatedFrom

+ const PayloadKeyConsolidationGroup

+ const PayloadKeyIsConsolidation

+ const PayloadKeyParentChunk

+ const PayloadKeyRole

+ const PayloadKeySessionID

+ const PayloadKeyThreadRoot

+ const PayloadKeyTurnNumber

type Collection

+ func (c *Collection) ArchiveRecord(id uint64) error

+ func (c *Collection) CleanupExpired() (int, error)

+ func (c *Collection) Consolidate(config ConsolidationConfig) (*ConsolidationResult, error)

+ func (c *Collection) CountExpired() int

+ func (c *Collection) ExpandConsolidation(consolidationID uint64) ([]*Record, error)

+ func (c *Collection) FindSimilarClusters(config ConsolidationConfig) ([]MemoryCluster, error)

+ func (c *Collection) GetArchived() ([]*Record, error)

+ func (c *Collection) GetConsolidations() ([]*Record, error)

+ func (c *Collection) GetSession(sessionID string) ([]*Record, error)

+ func (c *Collection) GetSessionStats(sessionID string) (SessionStats, error)

+ func (c *Collection) GetThread(chunkID uint64) ([]*Record, error)

+ func (c *Collection) InsertTurn(turn ConversationTurn) (uint64, error)

+ func (c *Collection) InsertWithOptions(vector []float32, payload map[string]any, opts ...InsertOption) (uint64, error)

+ func (c *Collection) ListSessions() []string

+ func (c *Collection) SearchInSession(sessionID string, query []float32, opts ...SearchOption) ([]Result, error)

+ func (c *Collection) Subscribe(query []float32, opts ...SubscriptionOption) (*Subscription, error)

+ func (c *Collection) UnarchiveRecord(id uint64) error

+ func (c *Collection) Unsubscribe(subscriptionID string) error

+ type ConsolidationConfig struct

+ ArchiveOriginals bool

+ Embedder Embedder

+ Filters []Filter

+ MaxGroupSize int

+ MinGroupSize int

+ SimilarityThreshold float32

+ SummaryGenerator func([]*Record) (string, map[string]any, error)

+ type ConsolidationResult struct

+ ArchivedRecordIDs []uint64

+ Clusters []MemoryCluster

+ ClustersFound int

+ ConsolidatedRecordIDs []uint64

+ RecordsConsolidated int

+ type ConversationTurn struct

+ Content string

+ Importance float32

+ ParentChunkID uint64

+ Payload map[string]any

+ Role string

+ SessionID string

+ TTL time.Duration

+ TurnNumber int

+ Vector []float32

type DB

+ func (db *DB) CreateEpisodeStore(memoriesCollectionName string) (*EpisodeStore, error)

+ func (db *DB) CreateKnowledgeGraph(name string) (*KnowledgeGraph, error)

+ type DecayConfig struct

+ HalfLife time.Duration

+ Type DecayType

+ type DecayType string

+ const DecayExponential

+ const DecayGaussian

+ const DecayLinear

+ const DecayNone

+ type Entity struct

+ ID string

+ Name string

+ Properties map[string]any

+ Type string

+ Vector []float32

+ func (e *Entity) Clone() *Entity

+ type Episode struct

+ CreatedAt time.Time

+ ID string

+ Metadata map[string]any

+ RecordIDs []uint64

+ TimeRange TimeRange

+ Title string

+ Vector []float32

+ func (e *Episode) Duration() time.Duration

+ func (e *Episode) RecordCount() int

+ type EpisodeConfig struct

+ Filters []Filter

+ MaxRecords int

+ MinRecords int

+ SimilarityThreshold float32

+ TimeGapThreshold time.Duration

+ type EpisodeResult struct

+ Episode *Episode

+ EpisodeRecords []*Record

+ Result Result

+ type EpisodeStore struct

+ func (es *EpisodeStore) CreateEpisode(recordIDs []uint64, title string) (*Episode, error)

+ func (es *EpisodeStore) DeleteEpisode(episodeID string) error

+ func (es *EpisodeStore) DetectEpisodes(config EpisodeConfig) ([]*Episode, error)

+ func (es *EpisodeStore) ExpandEpisode(episodeID string) ([]*Record, error)

+ func (es *EpisodeStore) FindRecordEpisode(recordID uint64) (*Episode, error)

+ func (es *EpisodeStore) GetEpisode(episodeID string) (*Episode, error)

+ func (es *EpisodeStore) ListEpisodes() []*Episode

+ func (es *EpisodeStore) SearchEpisodes(query []float32, limit int) ([]*Episode, error)

+ func (es *EpisodeStore) SearchWithEpisodeExpansion(query []float32, opts ...SearchOption) ([]EpisodeResult, error)

+ type ExpandedSearchResult struct

+ Entity *Entity

+ RelatedEntities []*Entity

+ Relationships []*Relationship

+ Score float32

type Filter

+ func AccessCountAbove(n uint64) Filter

+ func AccessCountBelow(n uint64) Filter

+ func AccessedAfter(t time.Time) Filter

+ func AccessedBefore(t time.Time) Filter

+ func AgeNewerThan(d time.Duration) Filter

+ func AgeOlderThan(d time.Duration) Filter

+ func CreatedAfter(t time.Time) Filter

+ func CreatedBefore(t time.Time) Filter

+ func ExpiredBefore(t time.Time) Filter

+ func HasTTLFilter() Filter

+ func ImportanceAbove(threshold float32) Filter

+ func ImportanceBelow(threshold float32) Filter

+ func ImportanceBetween(min, max float32) Filter

+ func NeverAccessed() Filter

+ func NotExpired() Filter

+ func UpdatedAfter(t time.Time) Filter

+ func UpdatedBefore(t time.Time) Filter

+ type InsertOption interface

+ func WithContentOption(content string) InsertOption

+ func WithExpiresAt(t time.Time) InsertOption

+ func WithImportance(score float32) InsertOption

+ func WithTTL(d time.Duration) InsertOption

+ type KnowledgeGraph struct

+ func (kg *KnowledgeGraph) AddEntity(entity Entity) error

+ func (kg *KnowledgeGraph) AddRelationship(rel Relationship) error

+ func (kg *KnowledgeGraph) DeleteEntity(entityID string) error

+ func (kg *KnowledgeGraph) DeleteRelationship(relID string) error

+ func (kg *KnowledgeGraph) GetEntity(entityID string) (*Entity, error)

+ func (kg *KnowledgeGraph) GetRelationship(relID string) (*Relationship, error)

+ func (kg *KnowledgeGraph) GetRelationships(entityID string, direction string) []*Relationship

+ func (kg *KnowledgeGraph) ListEntities(entityType string) []*Entity

+ func (kg *KnowledgeGraph) Name() string

+ func (kg *KnowledgeGraph) SearchWithExpansion(query []float32, traversalConfig TraversalConfig, opts ...SearchOption) ([]ExpandedSearchResult, error)

+ func (kg *KnowledgeGraph) Stats() KnowledgeGraphStats

+ func (kg *KnowledgeGraph) Traverse(startIDs []string, config TraversalConfig) (*TraversalResult, error)

+ func (kg *KnowledgeGraph) UpdateEntity(entity Entity) error

+ type KnowledgeGraphStats struct

+ EntityCount int

+ EntityTypes map[string]int

+ RelationshipCount int

+ RelationshipTypes map[string]int

+ type MatchEvent struct

+ Record *Record

+ Score float32

+ SubscriptionID string

+ Timestamp time.Time

+ type MemoryCluster struct

+ AverageImportance float32

+ Centroid []float32

+ ID string

+ Records []*Record

+ TimeRange TimeRange

type Record

+ AccessCount uint64

+ ExpiresAt time.Time

+ Importance float32

+ LastAccessedAt time.Time

+ func (r *Record) HasTTL() bool

+ func (r *Record) IsExpired() bool

+ func (r *Record) TTL() time.Duration

type RecordSnapshot

+ AccessCount uint64

+ ExpiresAt time.Time

+ Importance float32

+ LastAccessedAt time.Time

+ type Relationship struct

+ Bidirectional bool

+ ID string

+ Properties map[string]any

+ SourceID string

+ TargetID string

+ Type string

+ Weight float32

+ func (r *Relationship) Clone() *Relationship

type SearchOption

+ func WithAccessTracking(enabled bool) SearchOption

+ func WithDecay(decayType DecayType, halfLife time.Duration) SearchOption

+ func WithImportanceBoost(factor float32) SearchOption

+ type SessionStats struct

+ FirstTurn time.Time

+ LastTurn time.Time

+ Roles map[string]int

+ SessionID string

+ TurnCount int

+ type Subscription struct

+ Filters []Filter

+ ID string

+ Query []float32

+ Threshold float32

+ func (s *Subscription) Close() error

+ func (s *Subscription) Events() <-chan MatchEvent

+ func (s *Subscription) IsClosed() bool

+ type SubscriptionOption interface

+ func WithSubscriptionBufferSize(size int) SubscriptionOption

+ func WithSubscriptionFilter(f Filter) SubscriptionOption

+ func WithSubscriptionThreshold(threshold float32) SubscriptionOption

+ type TimeRange struct

+ End time.Time

+ Start time.Time

+ func (tr TimeRange) Duration() time.Duration

+ type TraversalConfig struct

+ Direction string

+ EntityTypes []string

+ MaxDepth int

+ MaxNodes int

+ MinWeight float32

+ RelationshipTypes []string

+ type TraversalResult struct

+ Depths map[string]int

+ Entities []*Entity

+ Relationships []*Relationship

Jan 28, 2026

Changes in this version

+ var ErrNoEmbedder = errors.New("veclite: no embedder configured")

type Collection

+ func (c *Collection) ForEach(fn func(*Record) bool)

+ func (c *Collection) HybridSearch(query []float32, text string, opts ...SearchOption) ([]Result, error)

+ func (c *Collection) InsertDocument(vector []float32, content string, payload map[string]any) (uint64, error)

+ func (c *Collection) InsertText(text string, payload map[string]any) (uint64, error)

+ func (c *Collection) Iterate(opts ...IterOption) *Iterator

+ func (c *Collection) SearchStream(query []float32, fn SearchFunc, opts ...SearchOption) error

+ func (c *Collection) SearchText(text string, opts ...SearchOption) ([]Result, error)

+ func (c *Collection) TextSearch(query string, opts ...SearchOption) ([]Result, error)

type CollectionOption

+ func WithEmbedder(e Embedder) CollectionOption

+ func WithTextIndex(fields ...string) CollectionOption

type CollectionSnapshot

+ TextIndexSnapshot *InvertedIndexSnapshot

type DB

+ func (db *DB) Metrics() MetricsSnapshot

+ type Embedder interface

+ Dimension func() int

+ Embed func(text string) ([]float32, error)

+ EmbedBatch func(texts []string) ([][]float32, error)

+ type InvertedIndexSnapshot struct

+ DocCount int

+ DocLengths map[uint64]int

+ Fields []string

+ Postings map[string][]uint64

+ TotalDocLen int64

+ type IterOption interface

+ func IterLimit(n int) IterOption

+ func IterOffset(n int) IterOption

+ type Iterator struct

+ func (it *Iterator) Close()

+ func (it *Iterator) Next() (*Record, bool)

+ type Logger interface

+ Debug func(msg string, keysAndValues ...any)

+ Error func(msg string, keysAndValues ...any)

+ Info func(msg string, keysAndValues ...any)

+ type Metrics struct

+ func (m *Metrics) Snapshot() MetricsSnapshot

+ type MetricsSnapshot struct

+ AvgSearchTime time.Duration

+ DeleteCount int64

+ InsertCount int64

+ SearchCount int64

+ type NopLogger struct

+ func (NopLogger) Debug(string, ...any)

+ func (NopLogger) Error(string, ...any)

+ func (NopLogger) Info(string, ...any)

type Option

+ func WithLogger(l Logger) Option

type Record

+ Content string

type RecordSnapshot

+ Content string

+ type SearchFunc func(result Result) bool

type SearchOption

+ func WithContent(include bool) SearchOption

+ func WithLimit(n int) SearchOption

+ func WithOffset(n int) SearchOption

+ func WithTextWeight(w float64) SearchOption

+ func WithVectorWeight(w float64) SearchOption

Jan 28, 2026

Changes in this version

+ var ErrChecksumMismatch = errors.New("veclite: checksum mismatch")

+ var ErrFileLocked = errors.New("veclite: database file is locked by another process")

+ var ErrReadOnly = errors.New("veclite: database is read-only")

type FileStorage

+ func (f *FileStorage) Lock() error

+ func (f *FileStorage) Unlock() error

Jan 25, 2026

Changes in this version

type Collection

+ func (c *Collection) UpdateVector(id uint64, vector []float32) error

+ func (c *Collection) Upsert(id uint64, vector []float32, payload map[string]any) (uint64, error)

+ func (c *Collection) UpsertByKey(keyField string, keyValue any, vector []float32, payload map[string]any) (uint64, bool, error)

type Filter

+ func Between(key string, min, max float64) Filter

+ func GT(key string, value float64) Filter

+ func GTE(key string, value float64) Filter

+ func GreaterThan(key string, value float64) Filter

+ func GreaterThanOrEqual(key string, value float64) Filter

+ func LT(key string, value float64) Filter

+ func LTE(key string, value float64) Filter

+ func LessThan(key string, value float64) Filter

+ func LessThanOrEqual(key string, value float64) Filter

type HNSWIndex

+ func (h *HNSWIndex) HardDelete(id uint64) error

Jan 21, 2026

Changes in this version

+ const DistanceCosine

+ const DistanceDot

+ const DistanceEuclidean

type Collection

+ func (c *Collection) HasIndex() bool

+ func (c *Collection) IndexStats() *hnsw.IndexStats

+ func (c *Collection) IndexType() IndexType

+ func (c *Collection) SearchExplain(query []float32, opts ...SearchOption) (*SearchExplanation, error)

type CollectionOption

+ func WithHNSW(m, efConstruction int) CollectionOption

+ func WithHNSWConfig(config HNSWConfig) CollectionOption

type CollectionSnapshot

+ HNSWConfig *HNSWConfig

+ HNSWSnapshot *hnsw.Snapshot

+ IndexType IndexType

type CollectionStats

+ IndexType string

+ type DistanceType = floats.DistanceType

+ type HNSWConfig struct

+ EfConstruction int

+ EfSearch int

+ M int

+ type HNSWIndex struct

+ func NewHNSWIndex(dimension int, distanceType floats.DistanceType, m, efConstruction int) *HNSWIndex

+ func NewHNSWIndexWithConfig(dimension int, distanceType floats.DistanceType, config hnsw.Config) *HNSWIndex

+ func (h *HNSWIndex) Count() int

+ func (h *HNSWIndex) Delete(id uint64) error

+ func (h *HNSWIndex) Insert(id uint64, vector []float32) error

+ func (h *HNSWIndex) Internal() *hnsw.Index

+ func (h *HNSWIndex) Search(query []float32, k int) ([]IndexResult, error)

+ func (h *HNSWIndex) SearchWithEf(query []float32, k int, ef int) ([]IndexResult, error)

+ func (h *HNSWIndex) SetInternal(idx *hnsw.Index)

+ func (h *HNSWIndex) Stats() hnsw.IndexStats

+ func (h *HNSWIndex) Type() string

+ type Index interface

+ Count func() int

+ Delete func(id uint64) error

+ Insert func(id uint64, vector []float32) error

+ Search func(query []float32, k int) ([]IndexResult, error)

+ SearchWithEf func(query []float32, k int, ef int) ([]IndexResult, error)

+ Type func() string

+ type IndexResult struct

+ Distance float32

+ ID uint64

+ type IndexType string

+ const IndexTypeHNSW

+ const IndexTypeNone

+ type SearchExplanation struct

+ BruteForce bool

+ Duration time.Duration

+ IndexType string

+ LayersVisited int

+ NodesVisited int

+ Results []Result

type SearchOption

+ func WithEfSearch(ef int) SearchOption

Jan 21, 2026

Changes in this version

+ const Version

+ var ErrBatchSizeMismatch = errors.New("veclite: batch size mismatch")

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

+ var ErrCorruptedFile = errors.New("veclite: corrupted file")

+ var ErrDatabaseClosed = errors.New("veclite: database closed")

+ var ErrDimensionMismatch = errors.New("veclite: dimension mismatch")

+ var ErrEmptyVector = errors.New("veclite: empty vector")

+ var ErrInvalidPath = errors.New("veclite: invalid path")

+ var ErrInvalidVersion = errors.New("veclite: unsupported file version")

+ var ErrNotFound = errors.New("veclite: not found")

+ type Collection struct

+ func (c *Collection) All() []*Record

+ func (c *Collection) Clear()

+ func (c *Collection) Count() int

+ func (c *Collection) Delete(id uint64) error

+ func (c *Collection) DeleteWhere(filters ...Filter) (int, error)

+ func (c *Collection) Dimension() int

+ func (c *Collection) DistanceType() floats.DistanceType

+ func (c *Collection) Find(filters ...Filter) ([]*Record, error)

+ func (c *Collection) FindOne(filters ...Filter) (*Record, error)

+ func (c *Collection) Get(id uint64) (*Record, error)

+ func (c *Collection) GetVector(id uint64) ([]float32, error)

+ func (c *Collection) Insert(vector []float32, payload map[string]any) (uint64, error)

+ func (c *Collection) InsertBatch(vectors [][]float32, payloads []map[string]any) ([]uint64, error)

+ func (c *Collection) Name() string

+ func (c *Collection) Search(query []float32, opts ...SearchOption) ([]Result, error)

+ func (c *Collection) Stats() CollectionStats

+ func (c *Collection) Update(id uint64, payload map[string]any) error

+ type CollectionOption interface

+ func WithDimension(dim int) CollectionOption

+ func WithDistanceType(t floats.DistanceType) CollectionOption

+ type CollectionSnapshot struct

+ CreatedAt time.Time

+ Dimension int

+ DistanceType floats.DistanceType

+ Name string

+ NextID uint64

+ Records []*RecordSnapshot

+ UpdatedAt time.Time

+ func NewCollectionSnapshot(name string, dimension int, distanceType floats.DistanceType) *CollectionSnapshot

+ type CollectionStats struct

+ Count int

+ Dimension int

+ DistanceType string

+ Name string

+ type DB struct

+ func Open(path string, opts ...Option) (*DB, error)

+ func (db *DB) Close() error

+ func (db *DB) Collection(name string) *Collection

+ func (db *DB) Collections() []string

+ func (db *DB) CreateCollection(name string, opts ...CollectionOption) (*Collection, error)

+ func (db *DB) DropCollection(name string) error

+ func (db *DB) GetCollection(name string) (*Collection, error)

+ func (db *DB) HasCollection(name string) bool

+ func (db *DB) IsClosed() bool

+ func (db *DB) Path() string

+ func (db *DB) Stats() DatabaseStats

+ func (db *DB) Sync() error

+ type DatabaseSnapshot struct

+ Collections map[string]*CollectionSnapshot

+ CreatedAt time.Time

+ UpdatedAt time.Time

+ Version uint32

+ func NewDatabaseSnapshot() *DatabaseSnapshot

+ type DatabaseStats struct

+ CollectionStats []CollectionStats

+ Collections int

+ Path string

+ TotalRecords int

+ type DimensionError struct

+ Expected int

+ Got int

+ func (e *DimensionError) Error() string

+ func (e *DimensionError) Unwrap() error

+ type FileStorage struct

+ func NewFileStorage(path string) *FileStorage

+ func (f *FileStorage) Close() error

+ func (f *FileStorage) Delete() error

+ func (f *FileStorage) Exists() bool

+ func (f *FileStorage) Load() (*DatabaseSnapshot, error)

+ func (f *FileStorage) Path() string

+ func (f *FileStorage) Save(snapshot *DatabaseSnapshot) error

+ type Filter interface

+ Match func(r *Record) bool

+ func And(filters ...Filter) Filter

+ func Contains(key, substr string) Filter

+ func Equal(key string, value any) Filter

+ func Exists(key string) Filter

+ func Glob(key, pattern string) Filter

+ func In(key string, values ...any) Filter

+ func Not(filter Filter) Filter

+ func NotEqual(key string, value any) Filter

+ func NotIn(key string, values ...any) Filter

+ func Or(filters ...Filter) Filter

+ func Prefix(key, prefix string) Filter

+ func Suffix(key, suffix string) Filter

+ type FilterFunc func(r *Record) bool

+ func (f FilterFunc) Match(r *Record) bool

+ type MemoryStorage struct

+ func NewMemoryStorage() *MemoryStorage

+ func (m *MemoryStorage) Close() error

+ func (m *MemoryStorage) Load() (*DatabaseSnapshot, error)

+ func (m *MemoryStorage) Save(snapshot *DatabaseSnapshot) error

+ type NotFoundError struct

+ ID string

+ Type string

+ func (e *NotFoundError) Error() string

+ func (e *NotFoundError) Unwrap() error

+ type Option interface

+ func WithReadOnly(enabled bool) Option

+ func WithSyncOnWrite(enabled bool) Option

+ type Record struct

+ CreatedAt time.Time

+ ID uint64

+ Payload map[string]any

+ UpdatedAt time.Time

+ Vector []float32

+ func (r *Record) Clone() *Record

+ type RecordSnapshot struct

+ CreatedAt time.Time

+ ID uint64

+ Payload map[string]any

+ UpdatedAt time.Time

+ Vector []float32

+ type Result struct

+ Record *Record

+ Score float32

+ type SearchOption interface

+ func Threshold(t float32) SearchOption

+ func TopK(k int) SearchOption

+ func WithFilter(f Filter) SearchOption

+ func WithFilters(filters ...Filter) SearchOption

+ type Storage interface

+ Close func() error

+ Load func() (*DatabaseSnapshot, error)

+ Save func(snapshot *DatabaseSnapshot) error

+ type StorageError struct

+ Err error

+ Op string

+ func (e *StorageError) Error() string

+ func (e *StorageError) Unwrap() error