health

type AgentDetail struct {
	Hostname   string
	Labels     string
	Registered string
}

type AgentMetrics struct {
	Total  int
	Ready  int
	Agents []AgentDetail
}

type Checker interface {
	CheckHealth(ctx context.Context) error
}

type ClosureMetricsProvider struct {
	NATSInfoFn          func(ctx context.Context) (*NATSMetrics, error)
	StreamInfoFn        func(ctx context.Context) ([]StreamMetrics, error)
	KVInfoFn            func(ctx context.Context) ([]KVMetrics, error)
	ObjectStoreInfoFn   func(ctx context.Context) ([]ObjectStoreMetrics, error)
	JobStatsFn          func(ctx context.Context) (*JobMetrics, error)
	AgentStatsFn        func(ctx context.Context) (*AgentMetrics, error)
	ComponentRegistryFn func(ctx context.Context) ([]ComponentEntry, error)
}

type ComponentEntry struct {
	Type          string
	Hostname      string
	Status        string
	Conditions    []string
	Age           string
	CPUPercent    float64
	MemBytes      int64
	SubComponents map[string]SubComponentInfo
}

type ConsumerDetail struct {
	Name        string
	Pending     uint64
	AckPending  int
	Redelivered int
}

type ConsumerMetrics struct {
	Total     int
	Consumers []ConsumerDetail
}

type Health struct {
	// Checker performs dependency health checks.
	Checker Checker
	// StartTime records when the server started.
	StartTime time.Time
	// Version is the application version string.
	Version string
	// Metrics provides system metrics (optional, can be nil).
	Metrics MetricsProvider
	// SubComponents reports the status of internal services.
	SubComponents map[string]SubComponentInfo

	// MetricsRefreshInterval overrides the default metrics cache TTL
	// for the background refresh goroutine. Zero uses metricsCacheTTL.
	MetricsRefreshInterval time.Duration
	// contains filtered or unexported fields
}

type JobMetrics struct {
	Total       int
	Unprocessed int
	Processing  int
	Completed   int
	Failed      int
	DLQ         int
}

type KVMetrics struct {
	Name  string
	Keys  int
	Bytes uint64
}

type MetricsProvider interface {
	GetNATSInfo(ctx context.Context) (*NATSMetrics, error)
	GetStreamInfo(ctx context.Context) ([]StreamMetrics, error)
	GetKVInfo(ctx context.Context) ([]KVMetrics, error)
	GetObjectStoreInfo(ctx context.Context) ([]ObjectStoreMetrics, error)
	GetJobStats(ctx context.Context) (*JobMetrics, error)
	GetAgentStats(ctx context.Context) (*AgentMetrics, error)
	GetComponentRegistry(ctx context.Context) ([]ComponentEntry, error)
}

type NATSChecker struct {
	// NATSCheck verifies NATS connectivity.
	NATSCheck func() error
	// KVCheck verifies KV bucket accessibility.
	KVCheck func() error
}

type NATSMetrics struct {
	URL     string
	Version string
}

type ObjectStoreMetrics struct {
	Name string
	Size uint64
}

type StreamMetrics struct {
	Name      string
	Messages  uint64
	Bytes     uint64
	Consumers int
}

type SubComponentInfo struct {
	Status  string
	Address string // Empty means no network endpoint.
}