Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

leak

package

Go to main page

Versions in this module

v0

v0.13.2

Jan 16, 2026

Changes in this version

type ResourceLeakChecker

+ func (rc *ResourceLeakChecker) MeasureDelta(c *CheckConfig) (float64, error)

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