strategies

Jul 10, 2020

Changes in this version

type Interface

+ SetPrometheusScrapeInterval func(time.Duration)

+ SetRange func(query.TimeUnit, uint)

+ type Option func(Interface) error

+ func WithLabelMatchers(labelMatchers []*query.LabelMatcher) Option

+ func WithPrometheusScrapeInterval(prometheusScrapeInterval time.Duration) Option

+ func WithRange(timeUnit query.TimeUnit, qty uint) Option

+ func WithTaskRanksReceiver(receiver TaskRanksReceiver) Option

type TaskRankCpuSharesStrategy

+ func (s *TaskRankCpuSharesStrategy) SetPrometheusScrapeInterval(_ time.Duration)

+ func (s *TaskRankCpuSharesStrategy) SetRange(timeUnit query.TimeUnit, qty uint)

type TaskRankCpuUtilStrategy

+ func (s *TaskRankCpuUtilStrategy) SetPrometheusScrapeInterval(prometheusScrapeInterval time.Duration)

+ func (s *TaskRankCpuUtilStrategy) SetRange(timeUnit query.TimeUnit, qty uint)

Jun 26, 2020

Changes in this version

type Interface

+ Init func(prometheusScrapeInterval time.Duration)

type TaskRankCpuSharesStrategy

+ func (s *TaskRankCpuSharesStrategy) Init(time.Duration)

+ type TaskRankCpuUtilStrategy struct

+ func (s *TaskRankCpuUtilStrategy) Execute(data model.Value)

+ func (s *TaskRankCpuUtilStrategy) Init(prometheusScrapeInterval time.Duration)

+ func (s *TaskRankCpuUtilStrategy) SetLabelMatchers(labelMatchers []*query.LabelMatcher) error

+ func (s *TaskRankCpuUtilStrategy) SetTaskRanksReceiver(receiver TaskRanksReceiver)

+ func (s TaskRankCpuUtilStrategy) GetLabelMatchers() []*query.LabelMatcher

+ func (s TaskRankCpuUtilStrategy) GetMetric() string

+ func (s TaskRankCpuUtilStrategy) GetRange() (query.TimeUnit, uint)

Jun 12, 2020

Changes in this version

+ func Build(s Interface, labelMatchers []*query.LabelMatcher, receiver TaskRanksReceiver)

+ type Interface interface

+ Execute func(model.Value)

+ GetLabelMatchers func() []*query.LabelMatcher

+ GetMetric func() string

+ GetRange func() (query.TimeUnit, int)

+ SetLabelMatchers func([]*query.LabelMatcher)

+ SetTaskRanksReceiver func(TaskRanksReceiver)

+ type TaskRankCpuSharesStrategy struct

+ func (s *TaskRankCpuSharesStrategy) Execute(data model.Value)

+ func (s *TaskRankCpuSharesStrategy) SetLabelMatchers(labelMatchers []*query.LabelMatcher)

+ func (s *TaskRankCpuSharesStrategy) SetTaskRanksReceiver(receiver TaskRanksReceiver)

+ func (s TaskRankCpuSharesStrategy) GetLabelMatchers() []*query.LabelMatcher

+ func (s TaskRankCpuSharesStrategy) GetMetric() string

+ func (s TaskRankCpuSharesStrategy) GetRange() (query.TimeUnit, int)

+ type TaskRanksReceiver interface

+ Receive func([]entities.RankedTask)