Documentation ¶
Index ¶
Constants ¶
View Source
const (
GoCatVersion = "2.0.0"
)
Variables ¶
View Source
var Aggregator = CatLocalAggregator{
Event: newEventAggregator(),
Transaction: newTransactionAggregator(),
Metric: newMetricAggregator(),
}
View Source
var Manager = catMessageManager{ // contains filtered or unexported fields }
View Source
var Monitor = &catMonitor{ scheduleMixin: makeScheduleMixedIn(signalMonitorExit), collectors: []Collector{ &memStatsCollector{}, &cpuInfoCollector{ lastTime: &cpu.TimesStat{}, lastCPUTime: 0, }, }, }
View Source
var Router = &catRouterConfig{ scheduleMixin: makeScheduleMixedIn(signalRouterExit), sample: 1.0, routers: make([]config.ServerAddress, 0), ticker: nil, }
View Source
var Scheduler = catScheduler{ // contains filtered or unexported fields }
View Source
var Sender = &catMessageSender{ scheduleMixin: makeScheduleMixedIn(signalSenderExit), normal: make(chan message.Messager, normalPriorityQueueSize), high: make(chan message.Messager, highPriorityQueueSize), chConn: make(chan net.Conn), encoder: encoder.NewPlainTextEncoder(), buf: bytes.NewBuffer([]byte{}), conn: nil, }
Functions ¶
func AddMonitorCollector ¶
func AddMonitorCollector(collector Collector)
func Background ¶
func Background(p scheduleMixer)
Types ¶
type Buf ¶
func (*Buf) WriteUInt64 ¶
type CatLocalAggregator ¶
type CatLocalAggregator struct { Event *eventAggregator Transaction *transactionAggregator Metric *metricAggregator }
func (*CatLocalAggregator) Background ¶
func (p *CatLocalAggregator) Background()
Click to show internal directories.
Click to hide internal directories.