metricsquery

Documentation

Index

• func GenerateQueryParamsAvg(windowSeconds int64) *metriccache.QueryParam
• func GenerateQueryParamsLast(windowSeconds int64) *metriccache.QueryParam
• type MetricsQuery
  • func NewMetricsQuery(metricCache metriccache.MetricCache, ...) MetricsQuery

Functions

func GenerateQueryParamsAvg

func GenerateQueryParamsAvg(windowSeconds int64) *metriccache.QueryParam

func GenerateQueryParamsLast

func GenerateQueryParamsLast(windowSeconds int64) *metriccache.QueryParam

Types

type MetricsQuery

type MetricsQuery interface {
	CollectNodeAndPodMetricLast(collectResUsedIntervalSeconds int64) (
		*metriccache.NodeResourceMetric, []*metriccache.PodResourceMetric)

	CollectNodeMetricsAvg(windowSeconds int64) metriccache.NodeResourceQueryResult

	CollectNodeAndPodMetrics(queryParam *metriccache.QueryParam) (
		*metriccache.NodeResourceMetric, []*metriccache.PodResourceMetric)

	CollectContainerResMetricLast(containerID *string, collectResUsedIntervalSeconds int64) metriccache.ContainerResourceQueryResult

	CollectContainerThrottledMetricLast(containerID *string, collectResUsedIntervalSeconds int64) metriccache.ContainerThrottledQueryResult

	CollectPodMetric(podMeta *statesinformer.PodMeta, queryParam *metriccache.QueryParam) metriccache.PodResourceQueryResult
}

func NewMetricsQuery

func NewMetricsQuery(metricCache metriccache.MetricCache, statesInformer statesinformer.StatesInformer) MetricsQuery

NewMetricsQuery creates an instance which implements interface MetricsQuery.