Versions in this module Expand all Collapse all v1 v1.5.0 Jan 30, 2026 v1.4.2 Jan 19, 2026 Changes in this version + func NewMux(opts ServerOptions) (http.Handler, error) + func StartServer(ctx context.Context, addr string, opts ServerOptions) error + type AuthConfig struct + Password string + Username string + type BrokerRuntime struct + CPUPercent float64 + MemBytes int64 + type MetricsProvider interface + Snapshot func(ctx context.Context) (*MetricsSnapshot, error) + func NewAggregatedPromMetricsClient(store metadata.Store, metricsURL string) MetricsProvider + func NewCompositeMetricsProvider(broker MetricsProvider, operatorURL string) MetricsProvider + func NewPromMetricsClient(url string) MetricsProvider + type MetricsSnapshot struct + AdminRequestErrorsTotal float64 + AdminRequestLatencyMS float64 + AdminRequestsTotal float64 + BrokerCPUPercent float64 + BrokerMemBytes int64 + BrokerRuntime map[string]BrokerRuntime + FetchRPS float64 + OperatorClusters float64 + OperatorEtcdSnapshotAccessOK float64 + OperatorEtcdSnapshotAgeSeconds float64 + OperatorEtcdSnapshotLastScheduleTS float64 + OperatorEtcdSnapshotLastSuccessTS float64 + OperatorEtcdSnapshotStale float64 + OperatorMetricsAvailable bool + ProduceRPS float64 + S3ErrorRate float64 + S3LatencyMS int + S3State string + type ServerOptions struct + Auth AuthConfig + Logger *log.Logger + Metrics MetricsProvider + Store metadata.Store
Go to main page