Versions in this module Expand all Collapse all v0 v0.13.1 Jan 14, 2026 Changes in this version + func PromSingleValueResponse(val string) *f.PrometheusQueryResponse + func WithCPUQuery(q string) func(*CLNodesLeakDetector) + func WithMemoryQuery(q string) func(*CLNodesLeakDetector) + func WithPrometheusBaseURL(url string) func(*ResourceLeakChecker) + func WithQueryClient(c PromQuerier) func(*ResourceLeakChecker) + type CLNodesCheck struct + CPUThreshold float64 + End time.Time + MemoryThreshold float64 + NumNodes int + Start time.Time + WarmUpDuration time.Duration + type CLNodesLeakDetector struct + CPUQuery string + MemoryQuery string + Mode string + func NewCLNodesLeakDetector(c *ResourceLeakChecker, opts ...func(*CLNodesLeakDetector)) (*CLNodesLeakDetector, error) + func (cd *CLNodesLeakDetector) Check(t *CLNodesCheck) error + type CheckConfig struct + End time.Time + Query string + Start time.Time + WarmUpDuration time.Duration + type FakeQueryClient struct + func NewFakeQueryClient() *FakeQueryClient + func (qc *FakeQueryClient) Query(query string, timestamp time.Time) (*f.PrometheusQueryResponse, error) + func (qc *FakeQueryClient) SetResponses(sr *f.PrometheusQueryResponse, er *f.PrometheusQueryResponse) + type PromQuerier interface + Query func(query string, timestamp time.Time) (*f.PrometheusQueryResponse, error) + type ResourceLeakChecker struct + PrometheusURL string + func NewResourceLeakChecker(opts ...func(*ResourceLeakChecker)) *ResourceLeakChecker + func (rc *ResourceLeakChecker) MeasureLeak(c *CheckConfig) (float64, error) + type ResourceLeakCheckerConfig struct + PrometheusBaseURL string
Go to main page