views

type Admission struct {
	WorkerCap      int64
	FreeBytes      uint64
	DiskFloorBytes uint64
	Held           bool
	// Pressure is the percent of the last 10 s some task waited, by
	// resource; a resource the kernel does not report is absent.
	Pressure map[string]float64
	// ResumesHeld is how many open runs the last restart still holds.
	ResumesHeld int
}

type AdmissionSource func(ctx context.Context) (Admission, error)

type Catalog struct {
	Metrics []Metric `json:"metrics"`
}

type CheckKey struct {
	Action  string
	Outcome string
}

type Correction struct {
	Class string    `json:"class"`
	What  string    `json:"what"`
	At    time.Time `json:"at"`
}

type CorrectionSource func(ctx context.Context) ([]Correction, error)

type CostEvent struct {
	Operation string
	Agent     string
	Model     string
	At        time.Time
	USD       float64
}

type CostKey struct {
	Operation string
	Agent     string
	Model     string
}

type CostTally struct {
	Events int64
	USD    float64
}

type Dashboard struct {
	UID    string  `json:"uid"`
	Title  string  `json:"title"`
	Panels []Panel `json:"panels"`
}

type Dispatch struct {
	Queued  int
	Held    int
	Running int
	// Remaining is the launches each bounded limit still allows, by name.
	Remaining map[string]int64
	// Slices maps a launched slice's assignment to the slice.
	Slices map[string]string
	// Stages is how many slices stand in each stage, and StageAges how long
	// the oldest of them has stood there, in seconds, by stage.
	Stages    map[string]int
	StageAges map[string]float64
	// LeadTime is the mean seconds from enqueue to merge of the slices merged
	// in the last day; nil when none merged.
	LeadTime *float64
}

type DispatchSource func(ctx context.Context) (Dispatch, error)

type FreeBytes func(path string) (uint64, error)

type GateKey struct {
	Gate     string
	Decision string
}

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

type GrafanaAccess struct {
	Password string `json:"password"`
}

type HandLabeled struct {
	Source         string       `json:"source"`
	Provenance     string       `json:"provenance"`
	From           time.Time    `json:"from"`
	Through        time.Time    `json:"through"`
	AttentionHours int64        `json:"attention_hours"`
	MergedSlices   []int        `json:"merged_slices"`
	Corrections    []Correction `json:"corrections"`
}

type History struct {
	Measurement *Measurement
	Pulls       []MergedPull
	Costs       []CostEvent
	Slices      map[string]string
}

type IContainers interface {
	docker.IServices
	SignalService(ctx context.Context, name string, signal string) error
	Exec(ctx context.Context, name string, spec docker.ExecSpec) (docker.ExecResult, error)
}

type LabEntry struct {
	Entry  string      `json:"entry"`
	Slice  string      `json:"slice"`
	At     time.Time   `json:"at"`
	Note   string      `json:"note"`
	Series []LabSample `json:"series"`
}

type LabSample struct {
	Metric string            `json:"metric"`
	Labels map[string]string `json:"labels"`
	Value  float64           `json:"value"`
}

type Measurement struct {
	At   time.Time
	Runs []Run
	Days []ouroboros.Rate
	// OperatorHours are the distinct UTC hours holding an operator-authored
	// message in any run, oldest first: an hour two runs share counts once.
	OperatorHours []time.Time
}

type MergedPull struct {
	Number   int
	MergedAt time.Time
	// Slice is the title's leading slice name, or empty.
	Slice string
	// Score is the ontology alignment score after the change, when the body
	// reports one; Signals are the signal table's after column.
	Score   *float64
	Signals map[string]float64
}

type Metric struct {
	Name       string     `json:"name"`
	Type       MetricType `json:"type"`
	Row        string     `json:"row"`
	Labels     []string   `json:"labels"`
	Definition string     `json:"definition"`
	Pending    string     `json:"pending,omitempty"`
}

type MetricType string

type Option func(views *Views) error

type Panel struct {
	ID          int    `json:"id"`
	Type        string `json:"type"`
	Title       string `json:"title"`
	Description string `json:"description"`
	FieldConfig struct {
		Defaults struct {
			Unit string `json:"unit"`
		} `json:"defaults"`
	} `json:"fieldConfig"`
	Targets []struct {
		Expr string `json:"expr"`
	} `json:"targets"`
}

type PullSource func(ctx context.Context) ([]MergedPull, error)

type PullState struct {
	Merges  map[string]int64
	Score   *float64
	Signals map[string]float64
}

type Retention struct {
	Bytes      uint64 `json:"bytes"`
	Derivation string `json:"derivation"`
}

type Run struct {
	Assignment string
	Agent      string
	Executor   string
	Model      string
	// Hours maps the start of each UTC hour to what the run added in it.
	Hours   map[time.Time]*Tally
	Total   *Tally
	Reading ouroboros.Reading
	// OperatorHours are the UTC hours holding an operator-authored message
	// sent into the run.
	OperatorHours map[time.Time]bool
}

type RunKey struct {
	Agent    string
	Executor string
	Model    string
	Slice    string
}

type SessionSource func(ctx context.Context) ([]SessionState, error)

type SessionState struct {
	Assignment string
	Agent      string
	Phase      string
}

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

type StackOption func(stack *Stack) error

type StackRecord struct {
	Prometheus        docker.OwnedRecord[Retention]     `json:"prometheus"`
	Grafana           docker.OwnedRecord[GrafanaAccess] `json:"grafana"`
	Addresses         []string                          `json:"addresses"`
	ScrapeTarget      string                            `json:"scrape_target"`
	BackfilledThrough time.Time                         `json:"backfilled_through"`
}

type Struggle struct {
	Week             ouroboros.Rate
	Day              ouroboros.Rate
	Compounding      ouroboros.Trend
	CompoundingDaily ouroboros.Trend
}

type Tally struct {
	Turns    int64
	Tokens   map[TokenKind]int64
	CostUSD  float64
	Gates    map[GateKey]int64
	Refusals map[string]int64
	Checks   map[CheckKey]int64
}

type TokenKind string

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