scheduler

var Aggregator = CatLocalAggregator{
	Event:       newEventAggregator(),
	Transaction: newTransactionAggregator(),
	Metric:      newMetricAggregator(),
}

var Manager = catMessageManager{
	// contains filtered or unexported fields
}

var Monitor = &catMonitor{
	scheduleMixin: makeScheduleMixedIn(signalMonitorExit),
	collectors: []Collector{
		&memStatsCollector{},
		&cpuInfoCollector{
			lastTime:    &cpu.TimesStat{},
			lastCPUTime: 0,
		},
	},
}

var Router = &catRouterConfig{
	scheduleMixin: makeScheduleMixedIn(signalRouterExit),
	sample:        1.0,
	routers:       make([]config.ServerAddress, 0),
	ticker:        nil,
}

var Scheduler = catScheduler{
	// contains filtered or unexported fields
}

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,
}