leak

type CLNodesCheck ¶

type CLNodesCheck struct {
	NumNodes        int
	Start           time.Time
	End             time.Time
	WarmUpDuration  time.Duration
	CPUThreshold    float64
	MemoryThreshold float64
}

ClNodesCheck contains thresholds which can be verified for each Chainlink node it is recommended to set some WarmUpDuration, 20% of overall test time to have more stable results

type CLNodesLeakDetector ¶

type CLNodesLeakDetector struct {
	Mode                  string
	CPUQuery, MemoryQuery string
	// contains filtered or unexported fields
}

CLNodesLeakDetector is Chainlink node specific resource leak detector can be used with both local and remote Chainlink node sets (DONs)

func NewCLNodesLeakDetector(c *ResourceLeakChecker, opts ...func(*CLNodesLeakDetector)) (*CLNodesLeakDetector, error)

func (cd *CLNodesLeakDetector) Check(t *CLNodesCheck) error

type CheckConfig ¶

type CheckConfig struct {
	Query          string
	Start          time.Time
	End            time.Time
	WarmUpDuration time.Duration
}

CheckConfig describes leak check configuration

type FakeQueryClient ¶

type FakeQueryClient struct {
	// contains filtered or unexported fields
}

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 ¶

type PromQuerier interface {
	Query(query string, timestamp time.Time) (*f.PrometheusQueryResponse, error)
}

PromQueries is an interface for querying Prometheus containing only methods we need for detecting resource leaks

type ResourceLeakChecker ¶

type ResourceLeakChecker struct {
	PrometheusURL string
	// contains filtered or unexported fields
}

ResourceLeakChecker is resource leak cheker instance

func NewResourceLeakChecker(opts ...func(*ResourceLeakChecker)) *ResourceLeakChecker

func (rc *ResourceLeakChecker) MeasureLeak(
	c *CheckConfig,
) (float64, error)

type ResourceLeakCheckerConfig ¶

type ResourceLeakCheckerConfig struct {
	PrometheusBaseURL string
}

ResourceLeakCheckerConfig is resource leak checker config with Prometheus base URL