Versions in this module Expand all Collapse all v0 v0.2.0 Oct 3, 2026 v0.1.0 Oct 1, 2026 Changes in this version + func Handler(logger *slog.Logger, checker Checker, startTime time.Time, version string, ...) []func(e *echo.Echo) + type AgentDetail struct + Hostname string + Labels string + Registered string + type AgentMetrics struct + Agents []AgentDetail + Ready int + Total int + type Checker interface + CheckHealth func(ctx context.Context) error + type ClosureMetricsProvider struct + AgentStatsFn func(ctx context.Context) (*AgentMetrics, error) + ComponentRegistryFn func(ctx context.Context) ([]ComponentEntry, error) + JobStatsFn func(ctx context.Context) (*JobMetrics, error) + KVInfoFn func(ctx context.Context) ([]KVMetrics, error) + NATSInfoFn func(ctx context.Context) (*NATSMetrics, error) + ObjectStoreInfoFn func(ctx context.Context) ([]ObjectStoreMetrics, error) + StreamInfoFn func(ctx context.Context) ([]StreamMetrics, error) + func (p *ClosureMetricsProvider) GetAgentStats(ctx context.Context) (*AgentMetrics, error) + func (p *ClosureMetricsProvider) GetComponentRegistry(ctx context.Context) ([]ComponentEntry, error) + func (p *ClosureMetricsProvider) GetJobStats(ctx context.Context) (*JobMetrics, error) + func (p *ClosureMetricsProvider) GetKVInfo(ctx context.Context) ([]KVMetrics, error) + func (p *ClosureMetricsProvider) GetNATSInfo(ctx context.Context) (*NATSMetrics, error) + func (p *ClosureMetricsProvider) GetObjectStoreInfo(ctx context.Context) ([]ObjectStoreMetrics, error) + func (p *ClosureMetricsProvider) GetStreamInfo(ctx context.Context) ([]StreamMetrics, error) + type ComponentEntry struct + Age string + CPUPercent float64 + Conditions []string + Hostname string + MemBytes int64 + Status string + SubComponents map[string]SubComponentInfo + Type string + type ConsumerDetail struct + AckPending int + Name string + Pending uint64 + Redelivered int + type ConsumerMetrics struct + Consumers []ConsumerDetail + Total int + type Health struct + Checker Checker + Metrics MetricsProvider + MetricsRefreshInterval time.Duration + StartTime time.Time + SubComponents map[string]SubComponentInfo + Version string + func New(logger *slog.Logger, checker Checker, startTime time.Time, version string, ...) *Health + func (h *Health) GetHealth(_ context.Context, _ gen.GetHealthRequestObject) (gen.GetHealthResponseObject, error) + func (h *Health) GetHealthReady(ctx context.Context, _ gen.GetHealthReadyRequestObject) (gen.GetHealthReadyResponseObject, error) + func (h *Health) GetHealthStatus(ctx context.Context, _ gen.GetHealthStatusRequestObject) (gen.GetHealthStatusResponseObject, error) + func (h *Health) StartMetricsRefresh(ctx context.Context) + type JobMetrics struct + Completed int + DLQ int + Failed int + Processing int + Total int + Unprocessed int + type KVMetrics struct + Bytes uint64 + Keys int + Name string + type MetricsProvider interface + GetAgentStats func(ctx context.Context) (*AgentMetrics, error) + GetComponentRegistry func(ctx context.Context) ([]ComponentEntry, error) + GetJobStats func(ctx context.Context) (*JobMetrics, error) + GetKVInfo func(ctx context.Context) ([]KVMetrics, error) + GetNATSInfo func(ctx context.Context) (*NATSMetrics, error) + GetObjectStoreInfo func(ctx context.Context) ([]ObjectStoreMetrics, error) + GetStreamInfo func(ctx context.Context) ([]StreamMetrics, error) + type NATSChecker struct + KVCheck func() error + NATSCheck func() error + func (c *NATSChecker) CheckHealth(_ context.Context) error + func (c *NATSChecker) CheckKV() error + func (c *NATSChecker) CheckNATS() error + type NATSMetrics struct + URL string + Version string + type ObjectStoreMetrics struct + Name string + Size uint64 + type StreamMetrics struct + Bytes uint64 + Consumers int + Messages uint64 + Name string + type SubComponentInfo struct + Address string + Status string
Go to main page