storage

Jul 22, 2026

Changes in this version

+ const DefaultAnalysisPageSize

+ type AnalysisPager interface

+ CountAnalyses func() (int, error)

+ ListAnalysesPage func(offset, limit int) ([]*AnalysisRecord, error)

type IncidentPager

+ CountIncidentsByStatus func() (IncidentStatusCounts, error)

type IncidentSearchPager

+ CountIncidentsMatchingByStatus func(query string) (IncidentStatusCounts, error)

+ type IncidentStatusCounts struct

+ AIDetect StatusCounts

+ Total StatusCounts

+ Webhook StatusCounts

+ func AssembleStatusCounts(total, ai StatusCounts) IncidentStatusCounts

+ func StatusCountsOf(recs []*IncidentRecord) IncidentStatusCounts

+ type StatusCounts struct

+ Acked int

+ Open int

+ Resolved int

+ Total int

Jul 20, 2026

Changes in this version

+ const DefaultIncidentPageSize

+ type IncidentCounts struct

+ AIDetect int

+ Total int

+ Webhook int

+ type IncidentPager interface

+ CountIncidents func() (IncidentCounts, error)

+ ListIncidentsPage func(origin string, offset, limit int) ([]*IncidentRecord, error)

+ type IncidentSearchPager interface

+ CountIncidentsMatching func(query string) (IncidentCounts, error)

+ SearchIncidentsPage func(query, origin string, offset, limit int) ([]*IncidentRecord, error)

Jul 6, 2026

Changes in this version

+ const OriginAIDetect

+ const OriginWebhook

+ func OriginFromSource(source string) string

+ func RunSQLMigrations(db *sql.DB, fsys fs.FS, dir, ledgerTable string) error

type IncidentRecord

+ Origin string

+ func (r *IncidentRecord) EffectiveOrigin() string

+ type RangeLister interface

+ ListIncidentsInRange func(start, end time.Time, limit int) ([]*IncidentRecord, error)

+ type SQLAccessor interface

+ DB func() *sql.DB

Jun 28, 2026

Changes in this version

+ const DefaultDataDir

+ const DefaultOrgID

+ const DomainAnalyses

+ const DomainBlobs

+ const DomainIncidents

+ const ModelStateNamespace

+ var ErrInvalidModelKey = errors.New("storage: invalid model-state key component")

+ var ErrUnknownDomain = errors.New("storage: unknown lifecycle domain")

+ func NormalizeOrgID(s string) string

+ func WithMigrationLock(db *sql.DB, fn func() error) error

type AnalysisRecord

+ OrgID string

+ type Blob struct

+ Data []byte

+ Name string

+ type BlobCreator interface

+ CreateBlobIfAbsent func(key string, data []byte) (written bool, err error)

type Config

+ Postgres PostgresOptions

type IncidentRecord

+ OrgID string

+ type Lifecycle interface

+ DeleteByID func(domain, id string) error

+ PurgeOlderThan func(domain string, cutoff time.Time) (int, error)

+ type ModelState struct

+ Agent string

+ Data []byte

+ Key string

+ OrgID string

+ UpdatedAt time.Time

+ Version int

+ type ModelStore struct

+ func NewModelStore(p Provider) *ModelStore

+ func (s *ModelStore) Get(orgID, agent, key string) (*ModelState, error)

+ func (s *ModelStore) List(orgID, agent string) ([]*ModelState, error)

+ func (s *ModelStore) Purge(orgID, agent, key string) error

+ func (s *ModelStore) Put(orgID, agent, key string, version int, data []byte) error

+ type PostgresOptions struct

+ DSN string

+ MaxIncidents int

type Provider

+ func NewPostgres(opts PostgresOptions) (Provider, error)

+ ListBlobs func(prefix string) ([]Blob, error)

+ type Searcher interface

+ SearchAnalyses func(query string, limit int) ([]*AnalysisRecord, error)

+ SearchIncidents func(query string, limit int) ([]*IncidentRecord, error)

May 31, 2026

Changes in this version

+ type AnalysisRecord struct

+ DurationMs int64

+ Error string

+ Finding *core.AIFinding

+ ID string

+ IncidentID string

+ Model string

+ RawResponse string

+ RequestedAt time.Time

+ RequestedBy string

+ Status string

+ ToolCalls []AnalysisToolCall

+ type AnalysisToolCall struct

+ Args json.RawMessage

+ DurationMs int64

+ Error string

+ Name string

+ Output json.RawMessage

type Provider

+ DeleteAnalysis func(id string) error

+ GetAnalysis func(id string) (*AnalysisRecord, error)

+ ListAnalyses func(limit int) ([]*AnalysisRecord, error)

+ ListAnalysesByIncident func(incidentID string, limit int) ([]*AnalysisRecord, error)

+ SaveAnalysis func(rec *AnalysisRecord) error

May 18, 2026

Changes in this version

type IncidentRecord

+ AssignedMemberIDs []string

+ AssignedTeamID string

+ ResolvedAt *time.Time

May 13, 2026

Changes in this version

type IncidentRecord

+ ChannelsEnabled []string

+ OnCallError string

May 8, 2026

Changes in this version

+ const MaxIncidentsDefault

+ var ErrNotFound = errors.New("storage: not found")

+ var ErrUnsupported = errors.New("storage: backend not implemented")

+ type Config struct

+ Database DatabaseOptions

+ File FileOptions

+ Redis RedisOptions

+ Type string

+ type DatabaseOptions struct

+ DSN string

+ Driver string

+ MaxIncidents int

+ type FileOptions struct

+ DataDir string

+ MaxIncidents int

+ type IncidentRecord struct

+ AckedAt *time.Time

+ ChannelsNotified []string

+ Content map[string]interface{}

+ CreatedAt time.Time

+ ID string

+ NotifyError string

+ NotifyStatus string

+ OnCallTriggered bool

+ Resolved bool

+ Service string

+ Source string

+ TeamID string

+ Title string

+ type Provider interface

+ Close func() error

+ GetIncident func(id string) (*IncidentRecord, error)

+ ListIncidents func(limit int) ([]*IncidentRecord, error)

+ ReadBlob func(name string) ([]byte, error)

+ SaveIncident func(rec *IncidentRecord) error

+ UpdateIncidentAck func(id string, ackedAt time.Time) error

+ WriteBlob func(name string, data []byte) error

+ func New(c Config) (Provider, error)

+ func NewDatabase(_ DatabaseOptions) (Provider, error)

+ func NewFile(opts FileOptions) (Provider, error)

+ func NewMemory() Provider

+ func NewRedis(_ RedisOptions) (Provider, error)

+ type RedisOptions struct

+ DB int

+ Host string

+ InsecureSkipVerify bool

+ KeyPrefix string

+ MaxIncidents int

+ Password string

+ Port int