aggregator

Documentation

Index

• Variables
• type Aggregator
  • func New(timeStart time.Time, agentID string, logger *logrus.Entry) *Aggregator
  • func (a *Aggregator) Add(ctx context.Context, doc proto.SystemProfile) error
  • func (a *Aggregator) Flush(ctx context.Context)
  • func (a *Aggregator) Start() <-chan *report.Report
  • func (a *Aggregator) Stop()
  • func (a *Aggregator) TimeEnd() time.Time
  • func (a *Aggregator) TimeStart() time.Time

Variables

var DefaultInterval = time.Duration(time.Minute)

Types

type Aggregator

type Aggregator struct {
	// contains filtered or unexported fields
}

Aggregator aggregates system.profile document

func New

func New(timeStart time.Time, agentID string, logger *logrus.Entry) *Aggregator

New returns configured *Aggregator

func (*Aggregator) Add

func (a *Aggregator) Add(ctx context.Context, doc proto.SystemProfile) error

Add aggregates new system.profile document

func (*Aggregator) Flush

func (a *Aggregator) Flush(ctx context.Context)

func (*Aggregator) Start

func (a *Aggregator) Start() <-chan *report.Report

func (*Aggregator) Stop

func (a *Aggregator) Stop()

func (*Aggregator) TimeEnd

func (a *Aggregator) TimeEnd() time.Time

TimeEnd returns end time for current interval

func (*Aggregator) TimeStart

func (a *Aggregator) TimeStart() time.Time

TimeStart returns start time for current interval