datasource

Documentation

Index

• func CalculateSamplesPercentile(samples []Sample, percentile float64) float64
• type Metric
  • func (m *Metric) SetSelector(selectors map[string]string)
• type PrometheusQuery
• type Query
• type Sample
• type SamplesOverview
  • func GetSamplesOverview(timeSeries *TimeSeries) *SamplesOverview
• type TimeSeries
  • func NewTimeSeries() *TimeSeries
  • func (ts *TimeSeries) AppendLabel(key, val string)
  • func (ts *TimeSeries) AppendSample(timestamp int64, val float64)
• type WorkloadKind

Functions

func CalculateSamplesPercentile

func CalculateSamplesPercentile(samples []Sample, percentile float64) float64

Types

type Metric

type Metric struct {
	// to be extended when new datasource is added
	Namespace     string
	Kind          string
	APIVersion    string
	WorkloadName  string
	PodName       string
	ContainerName string
	Resource      v1.ResourceName
	Selectors     string
}

func (*Metric) SetSelector

func (m *Metric) SetSelector(selectors map[string]string)

type PrometheusQuery

type PrometheusQuery struct {
	Query string
}

type Query

type Query struct {
	// to be extended when new datasource is added
	Prometheus *PrometheusQuery
}

type Sample

type Sample struct {
	Value     float64
	Timestamp int64
}

Sample is a single timestamped value of the metric.

type SamplesOverview

type SamplesOverview struct {
	AvgValue            float64
	MinValue            float64
	MaxValue            float64
	Percentile50thValue float64
	Percentile90thValue float64
	LastTimestamp       int64
	FirstTimestamp      int64
	Count               int
}

func GetSamplesOverview

func GetSamplesOverview(timeSeries *TimeSeries) *SamplesOverview

type TimeSeries

type TimeSeries struct {
	Labels  map[string]string
	Samples []Sample
}

TimeSeries represents a metric with given labels, with its values possibly changing in time.

func NewTimeSeries

func NewTimeSeries() *TimeSeries

func (*TimeSeries) AppendLabel

func (ts *TimeSeries) AppendLabel(key, val string)

func (*TimeSeries) AppendSample

func (ts *TimeSeries) AppendSample(timestamp int64, val float64)

type WorkloadKind

type WorkloadKind string

WorkloadKind is k8s resource kind

const (
	// workload kind is deployment
	WorkloadDeployment WorkloadKind = "Deployment"
)

Resource Name