spanembed

Jun 25, 2026

Changes in this version

+ const DefaultMaxTextBytes

type Candidate

+ ExistingFailHash string

+ ExistingFailModel string

+ type ChunkRecord struct

+ ContentHash string

+ Embeddings [][]float32

+ Model string

+ OrgID string

+ SessionID string

+ SpanID string

+ TraceID string

+ type FailureRecord struct

+ ContentHash string

+ ErrorDetail string

+ Model string

+ OrgID string

+ Reason string

+ SessionID string

+ SpanID string

+ TokenCount int

+ TraceID string

type PassConfig

+ MaxTextBytes int

type Report

+ ChunkRows int

+ Chunked int

+ FailuresByReason map[string]int

+ OversizeTokens []int

+ Oversized int

+ Poisoned int

type Sink

+ RecordFailure func(ctx context.Context, rec FailureRecord) error

+ UpsertSpanChunks func(ctx context.Context, rec ChunkRecord) error

type Store

+ func (s *Store) RecordFailure(ctx context.Context, rec FailureRecord) error

+ func (s *Store) UpsertSpanChunks(ctx context.Context, rec ChunkRecord) error

Jun 15, 2026

Changes in this version

+ const DefaultBatchSize

+ const DefaultTableName

+ var ErrNotInitialized = errors.New(...)

+ func ContentHash(text string) string

+ func RenderSpanText(input, output json.RawMessage) string

+ type Candidate struct

+ ExistingHash string

+ ExistingModel string

+ Input json.RawMessage

+ OrgID string

+ Output json.RawMessage

+ SessionID string

+ SpanID string

+ TraceID string

+ func (c *Candidate) Key() Key

+ type Hit struct

+ Model string

+ Score float32

+ SessionID string

+ Snippet string

+ SpanID string

+ StartedAt time.Time

+ TraceID string

+ UserPrompt string

+ type Key struct

+ OrgID string

+ SpanID string

+ TraceID string

+ type Pass struct

+ func NewPass(src Source, sink Sink, embedder embeddings.Embedder, cfg PassConfig, ...) (*Pass, error)

+ func (p *Pass) Run(ctx context.Context) (*Report, error)

+ type PassConfig struct

+ BatchSize int

+ Dimensions uint

+ Model string

+ type Record struct

+ ContentHash string

+ Embedding []float32

+ Model string

+ OrgID string

+ SessionID string

+ SpanID string

+ TraceID string

+ type Report struct

+ Embedded int

+ Empty int

+ Failed int

+ Pruned int64

+ Scanned int

+ UpToDate int

+ type Sink interface

+ PruneOrphans func(ctx context.Context) (int64, error)

+ Upsert func(ctx context.Context, rec Record) error

+ type Source interface

+ ListCandidates func(ctx context.Context, after Key, limit int) ([]Candidate, error)

+ type Store struct

+ func NewStore(pool *pgxpool.Pool, cfg StoreConfig, log *slog.Logger) (*Store, error)

+ func (s *Store) EnsureSchema(ctx context.Context) error

+ func (s *Store) ListCandidates(ctx context.Context, after Key, limit int) ([]Candidate, error)

+ func (s *Store) PruneOrphans(ctx context.Context) (int64, error)

+ func (s *Store) Search(ctx context.Context, orgID string, embedding []float32, topK int) ([]Hit, error)

+ func (s *Store) Upsert(ctx context.Context, rec Record) error

+ type StoreConfig struct

+ Dimensions uint

+ OrgID string

+ TableName string