Versions in this module Expand all Collapse all v0 v0.1.2 Apr 10, 2026 Changes in this version + const DecayModeExponential + const DecayModeStep + const ProfileBalanced + const ProfileDeep + const ProfileFast + const StageFastPath + func FinalScore(cosSim, daysElapsed float64, cfg DecayConfig) float64 + func HybridMerge(stage3 []destination.TranslatedPayload, stage4 []destination.ScoredRecord, ...) []destination.TranslatedPayload + func IsFastPath(q CanonicalQuery) bool + func ProfileDecayEnabled(profile string) bool + func ProfileEnabled(stage int, profile string) bool + func StageName(stage int) string + func ValidProfile(p string) bool + type CanonicalQuery struct + ActorType string + Collection string + CursorOffset int + Destination string + Limit int + Namespace string + Profile string + Q string + RawCursor string + Subject string + func Normalize(p destination.QueryParams) (CanonicalQuery, error) + type CascadeResult struct + Debug *DebugInfo + Denial *PolicyDenial + FirewallResult *firewall.FilterResult + HasMore bool + NextCursor string + Profile string + Records []destination.TranslatedPayload + RetrievalStage int + SemanticUnavailable bool + SemanticUnavailableReason string + type CascadeRunner struct + func New(querier destination.Querier, logger *slog.Logger) *CascadeRunner + func (cr *CascadeRunner) Run(ctx context.Context, src *config.Source, q CanonicalQuery) (CascadeResult, error) + func (cr *CascadeRunner) WithDebug(enabled bool) *CascadeRunner + func (cr *CascadeRunner) WithDecayCounter(c prometheus.Counter) *CascadeRunner + func (cr *CascadeRunner) WithDestinations(dests map[string]*config.Destination) *CascadeRunner + func (cr *CascadeRunner) WithEmbeddingClient(c embedding.EmbeddingClient, embeddingLatency prometheus.Observer) *CascadeRunner + func (cr *CascadeRunner) WithExactCache(c *cache.ExactCache) *CascadeRunner + func (cr *CascadeRunner) WithFirewall(fw *firewall.RetrievalFirewall) *CascadeRunner + func (cr *CascadeRunner) WithRetrievalConfig(cfg config.RetrievalConfig) *CascadeRunner + func (cr *CascadeRunner) WithSemanticCache(c *cache.SemanticCache) *CascadeRunner + type DebugInfo struct + CacheHit bool + CacheType string + CandidatesPerStage map[string]int + PerStageLatencyMs map[string]float64 + StagesHit []string + TemporalDecayConfig struct{ ... } + TotalLatencyMs float64 + type DecayConfig struct + Enabled bool + HalfLifeDays float64 + Mode string + StepThresholdDays float64 + func ResolveDecay(global config.RetrievalConfig, destDecay config.DestinationDecayConfig, ...) DecayConfig + type PolicyDenial struct + Code string + Reason string + func (d *PolicyDenial) Error() string
Go to main page