agent

Jul 7, 2026

Changes in this version

+ const SpikeSettingsBlobName

+ var ErrSpikeNoStorage = errors.New("spike settings: storage not configured")

+ func KnownBaselineMode(mode string) bool

+ func SaveSpikeSettings(st storage.Provider, s SpikeSettings) error

+ type BaselineFold struct

+ MinBaselineCount int

+ MinBucketSamples int

+ PollSeconds float64

+ RejectZ float64

+ SeasonalPeriod int

type Catalog

+ func (c *Catalog) SetBaselineFold(f BaselineFold)

type DetectEvent

+ BaselineStd float64

+ Explanation string

+ Score float64

type Pattern

+ BaselineAvg float64

+ BaselineVariance float64

+ Seasonal []stats.EWMA

+ SpikeBaselineMode string

+ type SpikeSettings struct

+ BaselineMode string

+ func DefaultSpikeSettings() SpikeSettings

+ func LoadSpikeSettings(st storage.Provider) SpikeSettings

Jul 6, 2026

Changes in this version

+ const SampleMaxLen

+ const SampleRingCap

+ func PushSample(ring []string, sample string, scrub core.Scrubber) []string

type Catalog

+ func (c *Catalog) RecordSample(patternID, sample string, scrub core.Scrubber)

type CatalogStore

+ func NewPostgresCatalogStore(db *sql.DB, orgID string, instanceIndex int) CatalogStore

type LearnExclusion

+ ExcludeLogPattern func(ctx context.Context, service, patternKey string) bool

type Pattern

+ Samples []string

type ShadowEvent

+ Service string

Jul 3, 2026

Changes in this version

+ const OverrideSourceLog

+ const OverrideSourceMetric

+ const OverrideSourceTrace

+ var ErrServiceExists = fmt.Errorf("service already exists")

+ var ErrServiceNotFound = fmt.Errorf("service not found")

+ func ContextWithOverrideOrg(ctx context.Context, org string) context.Context

+ func LogReadiness(p *Pattern, autoPromoteAfter int, pollInterval time.Duration) core.Readiness

+ func ResolveServiceOverride(ctx context.Context, in ServiceOverrideInput) string

+ func SetServiceOverride(o ServiceOverride)

type Catalog

+ func (c *Catalog) CreateService(name string) error

+ func (c *Catalog) DeleteService(name string) bool

+ func (c *Catalog) RenameService(oldName, newName string) error

+ func (c *Catalog) RepointService(patternID, service string) bool

+ func (c *Catalog) ResetPatterns() (patterns int, err error)

+ func (c *Catalog) ResetServices() (services int, err error)

+ func (c *Catalog) Service(name string) (ServiceInfo, bool)

type CatalogEdit

+ NewService string

type CatalogEditKind

+ const CatalogEditCreateService

+ const CatalogEditDeleteService

+ const CatalogEditRenameService

+ const CatalogEditRepointService

+ const CatalogEditResetPatterns

+ const CatalogEditResetServices

type CursorStore

+ func (s *CursorStore) Reset(ctx context.Context) error

type Miner

+ func (m *Miner) Reset()

+ type OverrideRule struct

+ CreatedAt time.Time

+ CreatedBy string

+ ID string

+ Match string

+ OrgID string

+ Service string

+ SourceType string

type ServiceInfo

+ Manual bool

+ type ServiceOverride interface

+ ResolveService func(ctx context.Context, in ServiceOverrideInput) (service string, ok bool)

+ type ServiceOverrideInput struct

+ Message string

+ Pattern string

+ Service string

+ Signal string

+ SourceType string

+ type ServiceOverrideStore struct

+ func LoadServiceOverrideStore(store storage.Provider) (*ServiceOverrideStore, error)

+ func (s *ServiceOverrideStore) CountForService(org, service string) int

+ func (s *ServiceOverrideStore) Delete(org, id string) (bool, error)

+ func (s *ServiceOverrideStore) List(org string) []OverrideRule

+ func (s *ServiceOverrideStore) Put(org string, in OverrideRule) (OverrideRule, error)

+ func (s *ServiceOverrideStore) RepointService(org, oldService, newService string) (int, error)

+ func (s *ServiceOverrideStore) ResolveService(ctx context.Context, in ServiceOverrideInput) (string, bool)

Jun 29, 2026

Changes in this version

+ func SetLearnExclusion(x LearnExclusion)

+ type LearnExclusion interface

+ ExcludeFromLearning func(ctx context.Context, service, signal string) bool

Jun 28, 2026

Changes in this version

+ func EffectiveModeForOrg(org, yamlFloor string) string

+ func NewMetricReader(q *signalsources.PrometheusQuerier) analyzetools.MetricReader

+ func NewTraceReader(q *signalsources.TempoQuerier) analyzetools.TraceReader

+ func RegisterTypedBrain(sourceType string, mk BrainFactory)

+ func RegisteredTypedBrains() []string

+ func SetAISettingsResolver(r AISettingsResolver)

+ func SetCatalogStore(s CatalogStore)

+ func SetModeResolver(r ModeResolver)

type AIBundle

+ Runbooks *runbook.Manager

+ type AIProviderResolver interface

+ EffectiveProvider func(ctx context.Context) (provider string, ok bool)

+ type AISettingsResolver interface

+ EffectiveEnabled func(ctx context.Context) (enabled bool, ok bool)

+ EffectiveKey func(ctx context.Context) (key string, ok bool)

+ type BrainFactory func(name string, options map[string]any) (core.SignalLearner, core.SignalDetector, error)

+ type CatalogEdit struct

+ Kind CatalogEditKind

+ PatternID string

+ Service string

+ Tags []string

+ Verdict string

+ type CatalogEditKind string

+ const CatalogEditDelete

+ const CatalogEditEndServiceGrace

+ const CatalogEditLabel

+ const CatalogEditMarkKnown

+ const CatalogEditRestartServiceGrace

+ type CatalogStore interface

+ Curate func(edit CatalogEdit) error

+ Load func() (patterns map[string]*Pattern, services map[string]*ServiceInfo, err error)

+ Persist func(patterns map[string]*Pattern, services map[string]*ServiceInfo) error

+ Snapshot func() (patterns []*Pattern, services map[string]ServiceInfo, err error)

type DetectEvent

+ RuleSeverity string

+ type ModeResolver interface

+ Mode func(ctx context.Context, agent string) (mode string, ok bool)

type Pattern

+ OrgID string

type ServiceInfo

+ OrgID string

May 31, 2026

Changes in this version

type AIBundle

+ Analyze core.AIAgent

+ AnalyzeRate *ai.RateLimiter

+ Detect core.AIAgent

+ Router *router.Router

+ func BuildAIs(cfg config.AgentConfig, catalog *Catalog, store storage.Provider, ...) AIBundle

May 13, 2026

Changes in this version

+ type AIBundle struct

+ Cache *ai.ResultCache

+ Rate *ai.RateLimiter

+ SRE core.AISRE

+ func BuildAI(cfg config.AgentConfig, store storage.Provider, httpClient *http.Client) AIBundle

+ type DetectEvent struct

+ Baseline float64

+ DurationMs int64

+ Error string

+ Finding *core.AIFinding

+ Frequency int

+ ID string

+ Model string

+ Outcome string

+ PatternID string

+ RawResponse string

+ Samples []string

+ Service string

+ Source string

+ Template string

+ Timestamp time.Time

+ UserPrompt string

+ Verdict string

+ type DetectLog struct

+ func LoadDetectLog(store storage.Provider, max int) (*DetectLog, error)

+ func (d *DetectLog) All() []*DetectEvent

+ func (d *DetectLog) Clear() int

+ func (d *DetectLog) Dirty() bool

+ func (d *DetectLog) Get(id string) *DetectEvent

+ func (d *DetectLog) Len() int

+ func (d *DetectLog) Persist() error

+ func (d *DetectLog) Record(e *DetectEvent)

+ func (d *DetectLog) Stats() map[string]int

+ type Emitter func(f *core.AIFinding, r core.AgentResult, source, service string) error

type WorkerOptions

+ AI AIBundle

+ Detect *DetectLog

+ Emitter Emitter

May 8, 2026

Changes in this version

+ func BuildSources(cfg config.AgentConfig) ([]core.SignalSource, []error)

+ type Catalog struct

+ func LoadCatalog(store storage.Provider) (*Catalog, error)

+ func (c *Catalog) All() []*Pattern

+ func (c *Catalog) AllServices() map[string]ServiceInfo

+ func (c *Catalog) Delete(patternID string) bool

+ func (c *Catalog) Dirty() bool

+ func (c *Catalog) EndServiceGrace(name string) bool

+ func (c *Catalog) Get(id string) *Pattern

+ func (c *Catalog) IsServiceInGrace(name string, graceDuration time.Duration) bool

+ func (c *Catalog) Label(patternID, verdict string, tags []string) bool

+ func (c *Catalog) Len() int

+ func (c *Catalog) MarkKnown(patternID string) bool

+ func (c *Catalog) Persist() error

+ func (c *Catalog) RegisterService(name string) bool

+ func (c *Catalog) RestartServiceGrace(name string) bool

+ func (c *Catalog) Upsert(patternID, template, source string, tickCount int, alpha float64, ...) *Pattern

+ type CursorStore struct

+ func NewCursorStore(rdb *redis.Client) *CursorStore

+ func (s *CursorStore) Get(ctx context.Context, source string) (time.Time, bool)

+ func (s *CursorStore) Set(ctx context.Context, source string, t time.Time) error

+ type MatchResult struct

+ Default bool

+ RuleName string

+ func (m MatchResult) Matched() bool

+ type Miner struct

+ func NewMiner(similarityThreshold float64, depth, maxChildren int) *Miner

+ func (m *Miner) AddCluster(id string, template string, size int)

+ func (m *Miner) Cluster(message string) (id string, template string, isNew bool)

+ func (m *Miner) Snapshot() []MinerCluster

+ type MinerCluster struct

+ ID string

+ Size int

+ Tokens []string

+ type Pattern struct

+ BaselineFrequency float64

+ Count int

+ FirstSeen time.Time

+ ID string

+ LastSeen time.Time

+ RuleName string

+ Service string

+ Source string

+ Tags []string

+ Template string

+ Verdict string

+ type Redactor struct

+ func NewRedactor(redactIPs bool, extra []string) (*Redactor, []error)

+ func (r *Redactor) Scrub(s string) string

+ func (r *Redactor) ScrubFields(fields map[string]interface{}) map[string]interface{}

+ type RegexMatcher struct

+ func NewRegexMatcher(cfg config.AgentRegexConfig) (*RegexMatcher, []error)

+ func (m *RegexMatcher) Match(message string) MatchResult

+ type RegexRule struct

+ Name string

+ Pattern *regexp.Regexp

+ type ServiceInfo struct

+ FirstSeen time.Time

+ type ServiceMatcher struct

+ func NewServiceMatcher(patterns []string) (*ServiceMatcher, []error)

+ func (m *ServiceMatcher) Extract(message string) string

+ type ShadowEvent struct

+ Count int

+ FirstSeen time.Time

+ LastSeen time.Time

+ Occurrences int

+ PatternID string

+ RuleName string

+ SampleMessage string

+ Source string

+ Template string

+ Verdict string

+ type ShadowLog struct

+ func LoadShadowLog(store storage.Provider, max int) (*ShadowLog, error)

+ func (s *ShadowLog) All() []*ShadowEvent

+ func (s *ShadowLog) Clear() int

+ func (s *ShadowLog) Dirty() bool

+ func (s *ShadowLog) Len() int

+ func (s *ShadowLog) Persist() error

+ func (s *ShadowLog) Record(source, patternID, template, sample, rule, verdict string, freq int)

+ func (s *ShadowLog) Stats() map[string]int

+ type Worker struct

+ func NewWorker(opt WorkerOptions) (*Worker, error)

+ func (w *Worker) Run(ctx context.Context)

+ type WorkerOptions struct

+ Catalog *Catalog

+ Cfg config.AgentConfig

+ Cursors *CursorStore

+ Matcher *RegexMatcher

+ Miner *Miner

+ Redactor *Redactor

+ Services *ServiceMatcher

+ Shadow *ShadowLog

+ Sources []core.SignalSource