Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var KafkaProducer producer
Functions ¶
func Init ¶
func Init(aggr AggrSection)
func InitKakfa ¶
func InitKakfa(aggr AggrSection)
func SendToAggr ¶
func SendToAggr(items []*dataobj.MetricValue) error
SendToCentralAggr 1. 判断一组points是否应该发往中心进行聚合
Types ¶
type AggrSection ¶
type AggrSection struct {
Enabled bool `yaml:"enabled"`
Lateness int `yaml:"lateness"`
ApiPath string `yaml:"apiPath"`
ApiTimeout int `yaml:"apiTimeout"`
UpdateInterval int `yaml:"updateInterval"`
KafkaAddrs []string `yaml:"kafkaAddrs"`
KafkaAggrInTopic string `yaml:"kafkaAggrInTopic"`
KafkaAggrOutTopic string `yaml:"kafkaAggrOutTopic"`
}
var AggrConfig AggrSection
Click to show internal directories.
Click to hide internal directories.