leak

Jan 20, 2026

Changes in this version

+ const DefaultFrom

+ const DefaultOutputPath

+ const DefaultProfileType

+ const DefaultPyroscopeBinaryVersion

+ const DefaultTo

+ func WithProfileCLIPath(path string) func(*ProfileDumper)

type CLNodesLeakDetector

+ ContainerAliveQuery string

+ type ProfileDumper struct

+ func NewProfileDumper(pyroscopeURL string, opts ...func(*ProfileDumper)) *ProfileDumper

+ func (d *ProfileDumper) DownloadProfile(config *ProfileDumperConfig) (string, error)

+ func (d *ProfileDumper) InstallProfileCLI() (string, error)

+ func (d *ProfileDumper) MemoryProfile(config *ProfileDumperConfig) (string, error)

+ type ProfileDumperConfig struct

+ From string

+ OutputPath string

+ ProfileType string

+ PyroscopeURL string

+ ServiceName string

+ To string

Jan 16, 2026

Changes in this version

type ResourceLeakChecker

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

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