Documentation
¶
Index ¶
- Constants
- type Aggregator
- func (self *Aggregator) Add(doc proto.SystemProfile) error
- func (self *Aggregator) Flush()
- func (self *Aggregator) Start() <-chan *qan.Report
- func (self *Aggregator) Status() map[string]string
- func (self *Aggregator) Stop()
- func (self *Aggregator) TimeEnd() time.Time
- func (self *Aggregator) TimeStart() time.Time
Constants ¶
View Source
const ( DefaultInterval = 60 // in seconds DefaultExampleQueries = true ReportChanBuffer = 1000 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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, config pc.QAN) *Aggregator
New returns configured *Aggregator
func (*Aggregator) Add ¶
func (self *Aggregator) Add(doc proto.SystemProfile) error
Add aggregates new system.profile document
func (*Aggregator) Flush ¶ added in v1.7.0
func (self *Aggregator) Flush()
func (*Aggregator) Start ¶ added in v1.7.0
func (self *Aggregator) Start() <-chan *qan.Report
func (*Aggregator) Status ¶ added in v1.7.0
func (self *Aggregator) Status() map[string]string
func (*Aggregator) Stop ¶ added in v1.7.0
func (self *Aggregator) Stop()
func (*Aggregator) TimeEnd ¶
func (self *Aggregator) TimeEnd() time.Time
TimeEnd returns end time for current interval
func (*Aggregator) TimeStart ¶
func (self *Aggregator) TimeStart() time.Time
TimeStart returns start time for current interval
Source Files
Click to show internal directories.
Click to hide internal directories.