aggregator

Documentation

Index

• Variables
• type Aggregator
  • func New(timeStart time.Time, agentID string) *Aggregator
  • func (a *Aggregator) Add(doc proto.SystemProfile) error
  • func (a *Aggregator) Flush()
  • func (a *Aggregator) Start() <-chan *report.Report
  • func (a *Aggregator) Status() map[string]string
  • 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 {

	// state
	sync.RWMutex // Lock() to protect internal consistency of the service
	// contains filtered or unexported fields
}

Aggregator aggregates system.profile document

func New

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

New returns configured *Aggregator

func (*Aggregator) Add

func (a *Aggregator) Add(doc proto.SystemProfile) error

Add aggregates new system.profile document

func (*Aggregator) Flush

func (a *Aggregator) Flush()

func (*Aggregator) Start

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

func (*Aggregator) Status

func (a *Aggregator) Status() map[string]string

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