puller

Documentation

Index

• Constants
• type PullAggregator
  • func NewPullAggregator() (*PullAggregator, error)
  • func (pa *PullAggregator) AggregateMetric(agentList map[string]common.AgentInfo, metricArr []types.Metric, ...)
  • func (pa *PullAggregator) CalculateMetric() (map[string]interface{}, error)
  • func (pa *PullAggregator) StartAggregate() error
• type PullCaller
  • func NewPullCaller(agentList map[string]agentmetadata.AgentInfo) (PullCaller, error)
  • func (pc PullCaller) StartPull()

Constants

const (
	AgentUnhealthyCnt = 5
)

Types

type PullAggregator

type PullAggregator struct {
	Storage   v1.Storage
	CBStore   cbstore.CBStore
	AgentList map[string]common.AgentInfo
}

func NewPullAggregator

func NewPullAggregator() (*PullAggregator, error)

func (*PullAggregator) AggregateMetric

func (pa *PullAggregator) AggregateMetric(agentList map[string]common.AgentInfo, metricArr []types.Metric, aggregateType string)

func (*PullAggregator) CalculateMetric

func (pa *PullAggregator) CalculateMetric() (map[string]interface{}, error)

func (*PullAggregator) StartAggregate

func (pa *PullAggregator) StartAggregate() error

type PullCaller

type PullCaller struct {
	AgentList map[string]agentmetadata.AgentInfo
}

func NewPullCaller

func NewPullCaller(agentList map[string]agentmetadata.AgentInfo) (PullCaller, error)

func (PullCaller) StartPull

func (pc PullCaller) StartPull()