Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultInterval = time.Duration(time.Minute)
Functions ¶
This section is empty.
Types ¶
type Aggregator ¶
type Aggregator struct {
// contains filtered or unexported fields
}
Aggregator aggregates system.profile document
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
Source Files
Click to show internal directories.
Click to hide internal directories.