metric

May 16, 2017

Changes in this version

type ResourceSelector

+ UID types.UID

Sep 20, 2016

Changes in this version

+ const DefaultAggregation

+ const MaxAggregation

+ const MinAggregation

+ const SumAggregation

+ var AggregatingFunctions = map[AggregationName]func([]int64) int64

+ var DerivedResources = map[common.ResourceKind]common.ResourceKind

+ var HeapsterAllInOneDownloadConfig = map[common.ResourceKind]bool

+ var OnlyDefaultAggregation = AggregationNames

+ var OnlySumAggregation = AggregationNames

+ func HeapsterUnmarshalType(client client.HeapsterClient, path string, v interface{}) error

+ func MaxAggregate(values []int64) int64

+ func MinAggregate(values []int64) int64

+ func SumAggregate(values []int64) int64

+ type AggregationName string

+ type AggregationNames []AggregationName

+ type DataPoint struct

+ X int64

+ Y int64

+ type DataPoints []DataPoint

+ func DataPointsFromMetricJSONFormat(raw heapster.MetricResult) DataPoints

+ type HeapsterSelector struct

+ Path string

+ Resources []string

+ TargetResourceType common.ResourceKind

+ func NewHeapsterSelectorFromNativeResource(resourceType common.ResourceKind, namespace string, resourceNames []string) (HeapsterSelector, error)

+ func (self HeapsterSelector) DownloadMetric(client client.HeapsterClient, metricName string) MetricPromise

+ type HeapsterSelectors []HeapsterSelector

+ func (self HeapsterSelectors) DownloadAndAggregate(client client.HeapsterClient, metricNames []string, ...) MetricPromises

+ func (self HeapsterSelectors) DownloadMetric(client client.HeapsterClient, metricName string) MetricPromises

+ type Label map[common.ResourceKind][]string

+ func AggregatingMapFromDataList(metricList []Metric, metricName string) (map[int64][]int64, Label)

+ func (self Label) AddMetricLabel(other Label) Label

+ type Metric struct

+ Aggregate AggregationName

+ MetricName string

+ func AggregateData(metricList []Metric, metricName string, aggregationName AggregationName) Metric

+ type MetricPromise struct

+ Error chan error

+ Metric chan *Metric

+ func NewMetricPromise() MetricPromise

+ func (self MetricPromise) GetMetric() (*Metric, error)

+ type MetricPromises []MetricPromise

+ func NewMetricPromises(length int) MetricPromises

+ func (self MetricPromises) GetMetrics() ([]Metric, error)

+ func (self MetricPromises) PutMetrics(metrics []Metric, err error)

+ type ResourceSelector struct

+ LabelSelector *unversioned.LabelSelector

+ Namespace string

+ ResourceName string

+ ResourceType common.ResourceKind

+ Selector map[string]string

+ func (self *ResourceSelector) GetHeapsterSelector(cachedPods []api.Pod) (HeapsterSelector, error)

+ type SortableInt64 []int64

+ func (a SortableInt64) Len() int

+ func (a SortableInt64) Less(i, j int) bool

+ func (a SortableInt64) Swap(i, j int)