tools

type ChangeFeed interface {
	// Changes returns every change record at or after `since`. A missing
	// or empty feed yields an empty slice and a nil error (a clean miss,
	// never a hard failure).
	Changes(ctx context.Context, since time.Time) ([]ChangeRecord, error)
}

type ChangeRecord struct {
	Timestamp time.Time `json:"timestamp"`
	Service   string    `json:"service"`
	Kind      string    `json:"kind"`
	Summary   string    `json:"summary"`
	Ref       string    `json:"ref,omitempty"`
}

type DependencyGraph struct {
	// contains filtered or unexported fields
}

type DescribeDependencies struct {
	Graph *DependencyGraph
	// Store is optional. When nil, neighbours are returned without the
	// has_recent_incident annotation.
	Store storage.Provider
}

type DescribeService struct {
	Catalog PatternCatalog
}

type GitRepo struct {
	// URL is the remote clone URL (https or scp-like git@host:org/repo).
	URL string
	// Branch optionally pins which branch to read; empty = default HEAD.
	Branch string
	// Service maps every commit in this repository to a service name.
	// Empty derives the service from the repository name in the URL.
	Service string
	// Token is an HTTPS access token / PAT used to authenticate to the
	// remote. Empty relies on ambient credentials.
	Token string
	// SSHKeyPath is the path to a private SSH key used for ssh / scp-like
	// remotes. Empty relies on the ambient SSH configuration.
	SSHKeyPath string
}

type LineRedactor interface {
	Scrub(s string) string
}

type PatternCatalog interface {
	Get(id string) *PatternView
	All() []*PatternView
	AllServices() map[string]ServiceInfo
}

type PatternHistory struct {
	Catalog PatternCatalog
}

type PatternView struct {
	ID        string
	Template  string
	Source    string
	Service   string
	RuleName  string
	Verdict   string
	Tags      []string
	Count     int
	Baseline  float64
	FirstSeen time.Time
	LastSeen  time.Time
}

type RecentChanges struct {
	Feed ChangeFeed
}

type RecentIncidents struct {
	Store storage.Provider
}

type RelatedLogs struct {
	Reader   SignalReader
	Redactor LineRedactor
	Services ServiceExtractor
}

type ServiceExtractor interface {
	Extract(message string) string
}

type ServiceInfo struct {
	FirstSeen time.Time
}

type SignalReader interface {
	// Sources returns the names of every configured source.
	Sources() []string
	// Pull returns signals from the named source at or after `since`.
	// The reader does no windowing or capping; callers filter and cap
	// client-side. An unknown source name yields an error.
	Pull(ctx context.Context, source string, since time.Time) ([]core.Signal, error)
}