host

type BundleHealth struct {
	Version     string            `json:"version,omitempty"`
	Unsupported map[string]string `json:"unsupported,omitempty"`
	Error       string            `json:"error,omitempty"`
}

type Clock interface {
	Now() time.Time
	After(d time.Duration) <-chan time.Time
}

type Deps struct {
	Facts hostfacts.Options
	// FSRoot is the root filesystem for kubelet detection and node_exporter.
	FSRoot            string
	MetricsCollectors []string
	OpenJournal       func(journal.Options) (JournalReader, error)
	// Roots overrides cfg.Trust.
	Roots        *bundle.Roots
	Clock        Clock
	Tunnel       tunnel.Options
	Logger       *slog.Logger
	Investigator Investigator
	// CollectInterval is the host state collection period.
	CollectInterval time.Duration
	Tick            time.Duration
	// Ticks replaces the internal tick timer.
	Ticks          <-chan time.Time
	OnCycle        func(time.Time)
	HealthInterval time.Duration
	BackoffBase    time.Duration
	BackoffMax     time.Duration
}

type Freshness struct {
	State   time.Time `json:"state,omitzero"`
	Metrics time.Time `json:"metrics,omitzero"`
	Journal time.Time `json:"journal,omitzero"`
}

type Health struct {
	Role              string             `json:"role"`
	Agent             protocol.AgentInfo `json:"agent"`
	TargetID          string             `json:"target_id"`
	WriterID          string             `json:"writer_id"`
	Incarnation       uint64             `json:"incarnation"`
	Epoch             string             `json:"epoch,omitempty"`
	Head              uint64             `json:"head"`
	Capabilities      []string           `json:"capabilities"`
	Freshness         Freshness          `json:"freshness"`
	Spool             SpoolHealth        `json:"spool"`
	Disk              disk.Report        `json:"disk"`
	TSDB              *TSDBHealth        `json:"tsdb,omitempty"`
	Metrics           *MetricsHealth     `json:"metrics,omitempty"`
	Bundle            BundleHealth       `json:"bundle"`
	Rules             []RuleHealth       `json:"rules"`
	UnavailableScopes map[string]string  `json:"unavailable_scopes"`
	ScrapeTargets     []ScrapeHealth     `json:"scrape_targets,omitempty"`
	RejectedEndpoints map[string]string  `json:"rejected_endpoints,omitempty"`
	Logs              LogsHealth         `json:"logs"`
	EvidenceLimited   []string           `json:"evidence_limited_rules"`
	Identity          machineState       `json:"identity"`
	AirGap            bool               `json:"airgap"`
	Errors            map[string]string  `json:"errors,omitempty"`
}

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

type Investigator interface {
	Tools() []client.Tool
	Call(ctx context.Context, name string, args json.RawMessage) (any, error)
}

type JournalReader interface {
	Refresh() error
	Next() (journal.Entry, bool)
	SaveCursor() error
	FileErrors() map[string]error
	Close() error
}

type LogsHealth struct {
	Files          int               `json:"files"`
	Streams        int               `json:"streams"`
	Lines          uint64            `json:"lines"`
	Gaps           uint64            `json:"gaps"`
	Journal        bool              `json:"journal"`
	JournalEntries uint64            `json:"journal_entries"`
	JournalErrors  map[string]string `json:"journal_file_errors,omitempty"`
}

type MetricsHealth struct {
	Series           int      `json:"series"`
	DroppedSeries    int      `json:"dropped_series"`
	DroppedFamilies  []string `json:"dropped_families,omitempty"`
	FailedCollectors []string `json:"failed_collectors,omitempty"`
	AppendErrors     int      `json:"append_errors"`
}

type RuleHealth struct {
	ID      string    `json:"id"`
	Version int       `json:"version"`
	Class   string    `json:"class"`
	State   string    `json:"state"`
	Reason  string    `json:"reason,omitempty"`
	Pending int       `json:"pending"`
	Firing  int       `json:"firing"`
	Last    time.Time `json:"last_eval,omitzero"`
}

type ScrapeHealth struct {
	URL       string    `json:"url"`
	Health    string    `json:"health"`
	Reason    string    `json:"reason,omitempty"`
	LastError string    `json:"last_error,omitempty"`
	Last      time.Time `json:"last_scrape,omitzero"`
	Series    int       `json:"series"`
}

type SessionStatus struct {
	Connected      bool            `json:"connected"`
	SessionID      string          `json:"session_id,omitempty"`
	Registered     bool            `json:"registered"`
	Committed      uint64          `json:"committed"`
	BacklogRecords int             `json:"backlog_records"`
	BacklogBytes   int64           `json:"backlog_bytes"`
	LastError      string          `json:"last_error,omitempty"`
	LastErrorCode  string          `json:"last_error_code,omitempty"`
	Halted         string          `json:"halted,omitempty"`
	Compat         protocol.Compat `json:"compat"`
	Exported       uint64          `json:"exported_through,omitempty"`
}

type SpoolHealth struct {
	Bytes                  int64     `json:"bytes"`
	Capacity               int64     `json:"capacity"`
	Records                int       `json:"records"`
	InFlightBytes          int64     `json:"in_flight_bytes"`
	Oldest                 time.Time `json:"oldest,omitzero"`
	ProjectedWindowSeconds float64   `json:"projected_window_seconds"`
	RebaselineRequired     bool      `json:"rebaseline_required"`
}

type Status struct {
	Health
	Session SessionStatus `json:"session"`
}

type TSDBHealth struct {
	Series           uint64  `json:"series"`
	Bytes            int64   `json:"bytes"`
	RetentionSeconds float64 `json:"retention_seconds"`
	MaxBytes         int64   `json:"max_bytes"`
}