observ

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

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

type AlertEvent struct {
	RuleID     string    `json:"rule_id"`
	RuleName   string    `json:"rule_name"`
	Deployment string    `json:"deployment"`
	Container  string    `json:"container"`
	Metric     string    `json:"metric"`
	Value      float64   `json:"value"`
	Threshold  float64   `json:"threshold"`
	Comparison string    `json:"comparison"`
	State      string    `json:"state"`
	At         time.Time `json:"at"`
	// Targets and Action are copied from the rule so the event is self-contained
	// for the notification and action sinks.
	Targets []string `json:"targets,omitempty"`
	Action  string   `json:"action,omitempty"`

	// Snapshot is the top consuming containers at the moment a rule fired, so a
	// notification and the dashboard can show what was using the resource.
	Snapshot []Consumer `json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

type AlertRule struct {
	ID         string  `json:"id" yaml:"id"`
	Name       string  `json:"name" yaml:"name"`
	Deployment string  `json:"deployment,omitempty" yaml:"deployment,omitempty"`
	Metric     string  `json:"metric" yaml:"metric"`
	Comparison string  `json:"comparison" yaml:"comparison"`
	Threshold  float64 `json:"threshold" yaml:"threshold"`
	ForSeconds int     `json:"for_seconds" yaml:"for_seconds"`
	Enabled    bool    `json:"enabled" yaml:"enabled"`
	// Targets are the notification target ids this rule delivers to. Empty means
	// every configured target, which is the original behaviour.
	Targets []string `json:"targets,omitempty" yaml:"targets,omitempty"`
	// Action is an optional remediation taken when the rule fires. "" is notify
	// only; ActionRestart restarts the offending deployment.
	Action string `json:"action,omitempty" yaml:"action,omitempty"`
}

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

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

type Config struct {
	SampleIntervalSeconds  int  `yaml:"sample_interval_seconds" json:"sample_interval_seconds"`
	AutoRestart            bool `yaml:"auto_restart" json:"auto_restart"`
	RestartCooldownSeconds int  `yaml:"restart_cooldown_seconds" json:"restart_cooldown_seconds"`
	// RetentionDays bounds how far back stored history goes. Samples older than the recent
	// window are averaged into one point a minute, so a long retention is cheap.
	RetentionDays int `yaml:"retention_days" json:"retention_days"`
	// OTLPEndpoint is where metrics are pushed, if anywhere. An http or https URL speaks
	// OTLP/HTTP; a bare host:port speaks OTLP/gRPC. Left empty, the standard
	// OTEL_EXPORTER_OTLP_ENDPOINT environment variable is honoured instead, and with
	// neither set nothing is pushed and the metrics are still there to scrape.
	OTLPEndpoint string `yaml:"otlp_endpoint,omitempty" json:"otlp_endpoint,omitempty"`
	// Off unless turned on here, and still opt-in per rule after that.
	LogTriage bool `yaml:"log_triage" json:"log_triage"`
	// Bounds what an incident carries, and so the most a triage can be asked to read.
	TriageContextLines int `yaml:"triage_context_lines,omitempty" json:"triage_context_lines,omitempty"`
}

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

type Consumer struct {
	Deployment string  `json:"deployment"`
	Container  string  `json:"container"`
	Value      float64 `json:"value"`
}

type ContainerHealth struct {
	Container  string `json:"container"`
	Deployment string `json:"deployment"`
	Status     string `json:"status"`
}

type ContainerSample struct {
	Deployment  string
	Container   string
	CPUPercent  float64
	MemoryUsage uint64
	MemoryLimit uint64
	NetworkRx   uint64
	NetworkTx   uint64
}

type DeploymentRestartFunc func(dir string) error

type ExhaustedEvent struct {
	Container  string    `json:"container"`
	Deployment string    `json:"deployment"`
	Attempts   int       `json:"attempts"`
	At         time.Time `json:"at"`
}

type HealthSource func() ([]ContainerHealth, error)

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

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

type HostSample struct {
	CPUPercent    float64
	MemoryUsage   uint64
	MemoryLimit   uint64
	MemoryPercent float64
	DiskPercent   float64
}

type HostSource func() (HostSample, error)

type Incident struct {
	ID          string            `json:"id"`
	RuleID      string            `json:"rule_id"`
	RuleName    string            `json:"rule_name"`
	Deployment  string            `json:"deployment"`
	Service     string            `json:"service,omitempty"`
	Source      string            `json:"source,omitempty"`
	Level       string            `json:"level"`
	Fingerprint string            `json:"fingerprint"`
	Sample      string            `json:"sample"`
	Context     []string          `json:"context,omitempty"`
	Count       int               `json:"count"`
	FirstSeen   time.Time         `json:"first_seen"`
	LastSeen    time.Time         `json:"last_seen"`
	Targets     []string          `json:"targets,omitempty"`
	Triage      *Triage           `json:"triage,omitempty"`
	Responses   []ResponderResult `json:"responses,omitempty"`
}

type LatestPoint struct {
	SeriesKey
	Sample
}

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

type LogLine struct {
	Deployment string
	Service    string
	Source     string
	Level      string
	Message    string
	Raw        string
	At         time.Time
}

type LogRule struct {
	ID         string `json:"id" yaml:"id"`
	Name       string `json:"name" yaml:"name"`
	Enabled    bool   `json:"enabled" yaml:"enabled"`
	Deployment string `json:"deployment" yaml:"deployment"`
	Service    string `json:"service,omitempty" yaml:"service,omitempty"`
	Source     string `json:"source,omitempty" yaml:"source,omitempty"`
	// Defaults to error: a rule watching info is a rule watching everything.
	MinLevel string `json:"min_level,omitempty" yaml:"min_level,omitempty"`
	// Matched against the parsed message, not the raw line, so it cannot hit a timestamp
	// or a service name.
	Pattern       string `json:"pattern,omitempty" yaml:"pattern,omitempty"`
	MinCount      int    `json:"min_count,omitempty" yaml:"min_count,omitempty"`
	WindowSeconds int    `json:"window_seconds,omitempty" yaml:"window_seconds,omitempty"`
	// Repeats inside the cooldown are counted onto the open incident rather than raising
	// another.
	CooldownSeconds int `json:"cooldown_seconds,omitempty" yaml:"cooldown_seconds,omitempty"`
	// The only field that costs money to run, so it is off unless asked for.
	Triage     bool     `json:"triage,omitempty" yaml:"triage,omitempty"`
	Responders []string `json:"responders,omitempty" yaml:"responders,omitempty"`
	Targets    []string `json:"targets,omitempty" yaml:"targets,omitempty"`
}

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

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

type MetricSeries struct {
	Containers []string     `json:"containers"`
	Timestamps []int64      `json:"timestamps"` // unix seconds, ascending
	Values     [][]*float64 `json:"values"`     // [container][timestamp]
}

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

type RecoveryEvent struct {
	Container  string    `json:"container"`
	Deployment string    `json:"deployment"`
	At         time.Time `json:"at"`
}

type Responder interface {
	Name() string
	// Respond describes what it did in a sentence; both that and any error are recorded.
	Respond(ctx context.Context, incident Incident) (string, error)
}

type ResponderFunc struct {
	ResponderName string
	Fn            func(ctx context.Context, incident Incident) (string, error)
}

type ResponderResult struct {
	Responder string    `json:"responder"`
	Detail    string    `json:"detail,omitempty"`
	Error     string    `json:"error,omitempty"`
	At        time.Time `json:"at"`
}

type RestartFunc func(container string) error

type Sample struct {
	Time  time.Time `json:"time"`
	Value float64   `json:"value"`
}

type SeriesKey struct {
	Deployment string
	Container  string
	Metric     string
}

type StatsSource func() ([]ContainerSample, error)

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

type TimeSeriesResponse struct {
	Deployment string                  `json:"deployment"`
	Metrics    map[string]MetricSeries `json:"metrics"`
}

type Triage struct {
	Summary    string    `json:"summary,omitempty"`
	Cause      string    `json:"cause,omitempty"`
	NextStep   string    `json:"next_step,omitempty"`
	Severity   string    `json:"severity,omitempty"`
	Confidence string    `json:"confidence,omitempty"`
	Skipped    string    `json:"skipped,omitempty"`
	At         time.Time `json:"at,omitempty"`
}

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