intelligence

Jun 4, 2026

Changes in this version

+ const DefaultQueueDepth

+ const DefaultShutdownTimeout

+ const DefaultWorkers

+ type AutoEmbedObserver struct

+ func NewAutoEmbedObserver(writer nodeWriter, embedder Embedder, pool *Pool, policies []EmbeddingPolicy) (*AutoEmbedObserver, error)

+ func (o *AutoEmbedObserver) OnNodeCreated(ctx context.Context, node *storage.Node)

+ func (o *AutoEmbedObserver) OnNodeDeleted(_ context.Context, _ uint64, _ string)

+ func (o *AutoEmbedObserver) OnNodeUpdated(_ context.Context, _ *storage.Node, _ *storage.Node)

+ type Embedder interface

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

+ type EmbeddingPolicy struct

+ Label string

+ SourceProperty string

+ TargetProperty string

+ type ErrNoIndexForTenant struct

+ TenantID string

+ func (e ErrNoIndexForTenant) Error() string

+ type LSAEmbedder struct

+ func NewLSAEmbedder(indexes *search.TenantLSAIndexes) *LSAEmbedder

+ func (e *LSAEmbedder) Embed(ctx context.Context, tenantID string, text string) ([]float32, error)

+ type Pool struct

+ func NewPool(cfg PoolConfig) *Pool

+ func (p *Pool) Dropped() uint64

+ func (p *Pool) InFlight() int64

+ func (p *Pool) Shutdown(ctx context.Context) int

+ func (p *Pool) Submit(ctx context.Context, task Task) bool

+ type PoolConfig struct

+ QueueDepth int

+ ShutdownTimeout time.Duration

+ Synchronous bool

+ Workers int

+ type Task interface

+ Execute func(ctx context.Context)

+ type TaskFunc func(ctx context.Context)

+ func (f TaskFunc) Execute(ctx context.Context)