meb

package module

Go to main page

Versions in this module

v0

v0.7.0

Aug 27, 2026

Changes in this version

+ var ErrStoreClosed = fmt.Errorf("store is closed")

+ type BatchWriter struct

+ func (bw *BatchWriter) AddFacts(facts []Fact) error

+ func (bw *BatchWriter) Cancel()

+ func (bw *BatchWriter) Count() uint64

+ func (bw *BatchWriter) Flush() error

type MEBStore

+ func (m *MEBStore) Compact(ratio float64) error

+ func (m *MEBStore) GetTriples(triples []TripleKey) ([]TripleResult, error)

+ func (m *MEBStore) GetVectors(ids []uint64) ([]VectorResult, error)

+ func (m *MEBStore) Health() StoreHealth

+ func (m *MEBStore) NewBatchWriter() *BatchWriter

type StoreHealth

+ DiskUsage int64

+ LSMSize int64

+ MemoryInUse uint64

+ StoreOpen bool

+ ValueLogSize int64

+ type TripleKey struct

+ Object any

+ Predicate string

+ Subject string

+ type TripleResult struct

+ Fact Fact

+ Found bool

+ Key TripleKey

+ type VectorResult struct

+ Found bool

+ ID uint64

+ Vec []float32

v0.6.1

Jul 26, 2026

Changes in this version

type MEBStore

+ func (st *MEBStore) HNSWIndex() *vector.HNSWIndex

v0.6.0

Jul 23, 2026

Changes in this version

type MEBStore

+ func (m *MEBStore) DebugInfo() StoreHealth

+ type StoreHealth struct

+ CircuitBreakerMetrics circuit.MetricsSnapshot

+ CircuitBreakerState string

+ LastGCTimeNano int64

+ NumFacts uint64

+ NumVectors int64

+ ReadOnly bool

+ VectorCapacity int

+ VectorFullDim int

+ WALSizeBytes int64

type WAL

+ func (w *WAL) AppendBatch(entries []walEntry) error

+ func (w *WAL) WALPath() string

v0.5.0

Jun 28, 2026

Changes in this version

+ const DefaultCandidateMultiplier

+ var ErrEmptyBatch = fmt.Errorf("empty batch")

+ var ErrFactNotFound = fmt.Errorf("fact not found")

+ var ErrInvalidFact = fmt.Errorf("invalid fact")

+ var ErrInvalidQuery = fmt.Errorf("invalid query")

+ var ErrStoreReadOnly = fmt.Errorf("store is read-only")

+ var ErrUnknownTriplePrefix = fmt.Errorf("unknown triple key prefix")

+ var ErrWALClosed = fmt.Errorf("WAL is closed")

+ func CountFacts(seq iter.Seq2[Fact, error]) (int, error)

+ func Filter(seq iter.Seq2[Fact, error], pred func(Fact) bool) iter.Seq2[Fact, error]

+ func Map[T any](seq iter.Seq2[Fact, error], fn func(Fact) (T, error)) iter.Seq2[T, error]

+ func MustValue[T any](f Fact) T

+ func ShouldPruneTriple(value []byte, wantEntityType uint16, wantPublic bool) bool

+ func ValueOrDefault[T any](f Fact, defaultVal T) T

+ func Value[T any](f Fact) (T, bool)

+ type Builder struct

+ func NewBuilder(store Store) *Builder

+ func (b *Builder) CandidateMultiplier(multiplier int) *Builder

+ func (b *Builder) Execute(ctx context.Context) ([]Result, error)

+ func (b *Builder) FilterFirst() *Builder

+ func (b *Builder) InTopic(topicID uint32) *Builder

+ func (b *Builder) JoinWithLFTJ(relations []query.RelationPattern, resultVars []string) *Builder

+ func (b *Builder) Limit(n int) *Builder

+ func (b *Builder) SimilarTo(vec []float32) *Builder

+ func (b *Builder) SimilarToWithThreshold(vec []float32, threshold float32) *Builder

+ func (b *Builder) Where(predicate string, object interface{}) *Builder

+ type Fact struct

+ Object any

+ Predicate string

+ Subject string

+ func Collect(seq iter.Seq2[Fact, error]) ([]Fact, error)

+ func First(seq iter.Seq2[Fact, error]) (Fact, error)

+ func NewFact(subject, predicate string, object any) Fact

+ func (f Fact) IsValid() bool

+ func (f Fact) String() string

+ type FilterOpt struct

+ Object interface{}

+ Predicate string

+ type MEBStore struct

+ func NewMEBStore(cfg *store.Config) (*MEBStore, error)

+ func (m *MEBStore) Add(atom ast.Atom) bool

+ func (m *MEBStore) AddDocument(docKey string, content []byte, vec []float32, metadata map[string]any) error

+ func (m *MEBStore) AddDocumentWithTopic(topicID uint32, docKey string, content []byte, vec []float32, ...) error

+ func (m *MEBStore) AddFact(fact Fact) error

+ func (m *MEBStore) AddFactBatch(facts []Fact) error

+ func (m *MEBStore) CircuitBreaker() *circuit.Breaker

+ func (m *MEBStore) CircuitBreakerMetrics() circuit.Metrics

+ func (m *MEBStore) CircuitBreakerMetricsSnapshot() circuit.MetricsSnapshot

+ func (m *MEBStore) Close() error

+ func (m *MEBStore) Contains(atom ast.Atom) bool

+ func (m *MEBStore) Count() uint64

+ func (m *MEBStore) DeleteDocument(docKey string) error

+ func (m *MEBStore) DeleteDocumentWithTopic(docKey string, topicID uint32) error

+ func (m *MEBStore) DeleteFactsBySubject(subject string) error

+ func (m *MEBStore) Dict() dict.Dictionary

+ func (m *MEBStore) Exists(s, p, o string) bool

+ func (m *MEBStore) Find() *Builder

+ func (m *MEBStore) FindSubjectsByObject(ctx context.Context, predicate, object string) iter.Seq[string]

+ func (m *MEBStore) GetContent(id uint64) ([]byte, error)

+ func (m *MEBStore) GetContentByKey(docKey string) ([]byte, error)

+ func (m *MEBStore) GetDocumentMetadata(docKey string) (map[string]any, error)

+ func (m *MEBStore) GetFacts(atom ast.Atom, callback func(ast.Atom) error) error

+ func (m *MEBStore) HasDocument(docKey string) (bool, error)

+ func (m *MEBStore) LFTJEngine() *query.LFTJEngine

+ func (m *MEBStore) ListPredicates() []ast.PredicateSym

+ func (m *MEBStore) LookupID(key string) (uint64, bool)

+ func (m *MEBStore) Merge(other factstore.ReadOnlyFactStore) error

+ func (m *MEBStore) MergeBatch(other factstore.ReadOnlyFactStore, batchSize int) error

+ func (m *MEBStore) RecalculateStats() (uint64, error)

+ func (m *MEBStore) RegisterTelemetrySink(sink TelemetrySink)

+ func (m *MEBStore) Reset() error

+ func (m *MEBStore) ResolveID(id uint64) (string, error)

+ func (m *MEBStore) RunValueLogGC(ratio float64) error

+ func (m *MEBStore) Scan(s, p, o string) iter.Seq2[Fact, error]

+ func (m *MEBStore) ScanContext(ctx context.Context, s, p, o string) iter.Seq2[Fact, error]

+ func (m *MEBStore) ScanInTopic(topicID uint32, s, p, o string) iter.Seq2[Fact, error]

+ func (m *MEBStore) ScanInTopicContext(ctx context.Context, topicID uint32, s, p, o string) iter.Seq2[Fact, error]

+ func (m *MEBStore) ScanSubjects(ctx context.Context) iter.Seq[string]

+ func (m *MEBStore) ScanSubjectsByPrefix(ctx context.Context, prefix string) iter.Seq[string]

+ func (m *MEBStore) ScanWithFilters(s, p, o string, filters []PredicateFilter) iter.Seq2[Fact, error]

+ func (m *MEBStore) ScanWithFiltersContext(ctx context.Context, s, p, o string, filters []PredicateFilter) iter.Seq2[Fact, error]

+ func (m *MEBStore) ScanWithPruning(ctx context.Context, s, p, o string, entityType uint16, wantPublic bool) iter.Seq2[Fact, error]

+ func (m *MEBStore) SetCircuitBreakerConfig(config *circuit.Config)

+ func (m *MEBStore) SetContent(id uint64, data []byte) error

+ func (m *MEBStore) SetDefaultEntityType(entityType uint16)

+ func (m *MEBStore) SetDefaultFlags(flags uint16)

+ func (m *MEBStore) SetRetention(maxFacts uint64) error

+ func (m *MEBStore) SetTopicID(topicID uint32)

+ func (m *MEBStore) TopicID() uint32

+ func (m *MEBStore) UnregisterTelemetrySink(sink TelemetrySink)

+ func (m *MEBStore) Update(fn func(*StoreTxn) error) error

+ func (m *MEBStore) Vectors() *vector.VectorRegistry

+ func (m *MEBStore) View(fn func(*StoreTxn) error) error

+ func (st *MEBStore) EnableHNSW(cfg *vector.HNSWConfig) error

+ func (st *MEBStore) EnableIVFPQ(cfg *vector.IVFPQConfig) error

+ func (st *MEBStore) IVFPQIndex() *vector.IVFPQIndex

+ func (st *MEBStore) TrainIVFPQ(topicID uint32) error

+ type NumericRange struct

+ Max float64

+ Min float64

+ type PredicateFilter struct

+ Type PredicateFilterType

+ Value interface{}

+ func MustPredicateFilter(filterType PredicateFilterType, value interface{}) *PredicateFilter

+ func NewPredicateFilter(filterType PredicateFilterType, value interface{}) (*PredicateFilter, error)

+ type PredicateFilterType string

+ const PredicateContains

+ const PredicateGT

+ const PredicateGTE

+ const PredicateLT

+ const PredicateLTE

+ const PredicateRange

+ const PredicateRegex

+ type QueryFilter struct

+ Object interface{}

+ Predicate string

+ type Result struct

+ Content string

+ ID uint64

+ Key string

+ Score float32

+ func (r Result) String() string

+ type Results []Result

+ func (rs Results) IDs() []uint64

+ func (rs Results) Keys() []string

+ func (rs Results) Scores() []float32

+ type Store interface

+ Dict func() dict.Dictionary

+ Exists func(s, p, o string) bool

+ GetContent func(id uint64) ([]byte, error)

+ LFTJEngine func() *query.LFTJEngine

+ ResolveID func(id uint64) (string, error)

+ Scan func(s, p, o string) iter.Seq2[Fact, error]

+ Vectors func() *vector.VectorRegistry

+ type StoreTxn struct

+ func (t *StoreTxn) AddFact(fact Fact) error

+ func (t *StoreTxn) AddFactBatch(facts []Fact) error

+ func (t *StoreTxn) AddFactBatchWithTopic(facts []Fact, topicID uint32) error

+ func (t *StoreTxn) AddHNSWVector(topicID uint32, localID uint64, fullVec []float32) error

+ func (t *StoreTxn) AddIVFVector(topicID uint32, localID uint64, fullVec []float32) error

+ func (t *StoreTxn) AddVector(id uint64, vec []float32) error

+ func (t *StoreTxn) AddVectorWithHash(id uint64, vec []float32, semanticHash uint8) error

+ func (t *StoreTxn) BadgerTxn() *badger.Txn

+ func (t *StoreTxn) DeleteDocument(docKey string) error

+ func (t *StoreTxn) DeleteDocumentWithTopic(docKey string, topicID uint32) error

+ func (t *StoreTxn) DeleteFactsBySubject(subject string) error

+ func (t *StoreTxn) DeleteVector(id uint64) bool

+ func (t *StoreTxn) Exists(s, p, o string) bool

+ func (t *StoreTxn) GetContent(id uint64) ([]byte, error)

+ func (t *StoreTxn) GetID(s string) (uint64, error)

+ func (t *StoreTxn) GetOrCreateID(s string) (uint64, error)

+ func (t *StoreTxn) GetString(id uint64) (string, error)

+ func (t *StoreTxn) HasVector(id uint64) bool

+ func (t *StoreTxn) Scan(ctx context.Context, s, p, o string) iterSeq2FactError

+ func (t *StoreTxn) ScanInTopic(ctx context.Context, topicID uint32, s, p, o string) iterSeq2FactError

+ func (t *StoreTxn) SearchHNSW(ctx context.Context, topicID uint32, queryVec []float32, k int) ([]Result, error)

+ func (t *StoreTxn) SearchHybrid(ctx context.Context, queryVec []float32, k int) ([]Result, error)

+ func (t *StoreTxn) SearchHybridWithFilters(ctx context.Context, queryVec []float32, k int, filters []FilterOpt) ([]Result, error)

+ func (t *StoreTxn) SearchIVFPQ(ctx context.Context, topicID uint32, queryVec []float32, k int) ([]Result, error)

+ func (t *StoreTxn) SetContent(id uint64, data []byte) error

+ type TelemetryEvent struct

+ Data map[string]any

+ Timestamp time.Time

+ Type string

+ type TelemetrySink interface

+ OnEvent func(event TelemetryEvent)

+ type WAL struct

+ func NewWAL(dataDir string) (*WAL, error)

+ func (w *WAL) Append(entry walEntry) error

+ func (w *WAL) Clear() error

+ func (w *WAL) Close() error

+ func (w *WAL) ReadAll() ([]walEntry, error)

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