Versions in this module Expand all Collapse all v0 v0.1.1 Apr 30, 2024 v0.1.0 Apr 29, 2024 Changes in this version + const DefaultLogCronPeriod + const DefaultProcCronPeriod + const DefaultSendQueueMaxSize + const DefaultSendTaskSleepInterval + var GraphConnPools *backend.SafeRpcConnPools + var GraphNodeRing *rings.ConsistentHashNodeRing + var GraphQueues = make(map[string]*nlist.SafeListLimited) + var JudgeConnPools *backend.SafeRpcConnPools + var JudgeNodeRing *rings.ConsistentHashNodeRing + var JudgeQueues = make(map[string]*nlist.SafeListLimited) + var KafkaFilterQueues = make(map[string]*nlist.SafeListLimited) + var KafkaLogQueue *nlist.SafeListLimited + var KafkaQueue *nlist.SafeListLimited + var MinStep int + var TsdbConnPoolHelper *backend.TsdbConnPoolHelper + var TsdbQueue *nlist.SafeListLimited + func DestroyConnPools() + func Push2GraphSendQueue(items []*cmodel.MetaData) + func Push2JudgeSendQueue(items []*cmodel.MetaData) + func Push2KafkaLogSendQueue(items []*LogMetricItem) + func Push2KafkaSendQueue(items []*cmodel.MetaData) + func Push2TsdbSendQueue(items []*cmodel.MetaData) + func Start() + type KafkaItem struct + DsType string + Endpoint string + Metric string + Step int + Tags string + Timestamp int64 + Value float64 + func (this *KafkaItem) KafkaString() (s string) + type KafkaProducer struct + func NewKafkaProducer(name string, address []string) (*KafkaProducer, error) + func (this *KafkaProducer) AsyncClose() + func (this *KafkaProducer) Close() error + func (this *KafkaProducer) LogRun() + func (this *KafkaProducer) Name() string + func (this *KafkaProducer) Run() + type KafkaProducerPool struct + Address []string + Cnt int64 + MaxIdle int32 + MaxProducers int32 + Name string + New func(name string, address []string) (*KafkaProducer, error) + func NewKafkaProducerPool(name string, address []string, maxProducers int32, maxIdle int32) *KafkaProducerPool + func (this *KafkaProducerPool) Destroy() + func (this *KafkaProducerPool) Fetch() (*KafkaProducer, error) + func (this *KafkaProducerPool) ForceClose(producer *KafkaProducer) + func (this *KafkaProducerPool) Proc() string + func (this *KafkaProducerPool) Release(producer *KafkaProducer) + type LogMetricItem struct + Endpoint string + Metric string + Step int + Tags map[string]string + Timestamp int64 + Value string + func (this *LogMetricItem) KafkaString() (s string)
Go to main page