Versions in this module Expand all Collapse all v1 v1.52.0 Apr 9, 2026 Changes in this version + const CategoryBusinessCtx + const CategoryCorrection + const CategoryDataQuality + const CategoryEnhancement + const CategoryGeneral + const CategoryRelationship + const CategoryUsageGuidance + const ConfidenceHigh + const ConfidenceLow + const ConfidenceMedium + const DefaultDimension + const DefaultLimit + const DimensionEntity + const DimensionEvent + const DimensionKnowledge + const DimensionPreference + const DimensionRelationship + const MaxContentLen + const MaxEntityURNs + const MaxLimit + const MaxRelatedCols + const MinContentLen + const SourceAgentDiscovery + const SourceAutomation + const SourceEnrichmentGap + const SourceLineageEvent + const SourceUser + const StatusActive + const StatusArchived + const StatusStale + const StatusSuperseded + func NormalizeCategory(c string) string + func NormalizeConfidence(c string) string + func NormalizeDimension(d string) string + func NormalizeSource(s string) string + func ParseURNToTable(urn string) (semantic.TableIdentifier, error) + func ValidateCategory(c string) error + func ValidateConfidence(c string) error + func ValidateContent(text string) error + func ValidateDimension(d string) error + func ValidateEntityURNs(urns []string) error + func ValidateRelatedColumns(cols []RelatedColumn) error + func ValidateSource(s string) error + func ValidateStatus(s string) error + type Filter struct + Category string + CreatedBy string + Dimension string + EntityURN string + Limit int + Offset int + OrderBy string + Persona string + Since *time.Time + Source string + Status string + Until *time.Time + func (f *Filter) EffectiveLimit() int + type MiddlewareAdapter struct + func NewMiddlewareAdapter(store Store) *MiddlewareAdapter + func (a *MiddlewareAdapter) RecallForEntities(ctx context.Context, urns []string, persona string, limit int) ([]Snippet, error) + type Record struct + Category string + Confidence string + Content string + CreatedAt time.Time + CreatedBy string + Dimension string + Embedding []float32 + EntityURNs []string + ID string + LastVerified *time.Time + Metadata map[string]any + Persona string + RelatedColumns []RelatedColumn + Source string + StaleAt *time.Time + StaleReason string + Status string + UpdatedAt time.Time + type RecordUpdate struct + Category string + Confidence string + Content string + Dimension string + Embedding []float32 + Metadata map[string]any + type RelatedColumn struct + Column string + Relevance string + URN string + type ScoredRecord struct + Record Record + Score float64 + type Snippet struct + Category string + Confidence string + Content string + CreatedAt time.Time + Dimension string + ID string + type StalenessConfig struct + BatchSize int + Interval time.Duration + type StalenessWatcher struct + func NewStalenessWatcher(store Store, sp semantic.Provider, cfg StalenessConfig) *StalenessWatcher + func (w *StalenessWatcher) Start(_ context.Context) + func (w *StalenessWatcher) Stop() + type Store interface + Delete func(ctx context.Context, id string) error + EntityLookup func(ctx context.Context, urn string, persona string) ([]Record, error) + Get func(ctx context.Context, id string) (*Record, error) + Insert func(ctx context.Context, record Record) error + List func(ctx context.Context, filter Filter) ([]Record, int, error) + MarkStale func(ctx context.Context, ids []string, reason string) error + MarkVerified func(ctx context.Context, ids []string) error + Supersede func(ctx context.Context, oldID, newID string) error + Update func(ctx context.Context, id string, updates RecordUpdate) error + VectorSearch func(ctx context.Context, query VectorQuery) ([]ScoredRecord, error) + func NewNoopStore() Store + func NewPostgresStore(db *sql.DB) Store + type VectorQuery struct + Embedding []float32 + Limit int + MinScore float64 + Persona string + Status string
Go to main page