collector

Documentation

Index

• Constants
• Variables
• func ReturnDiffTopicList(a, b []string) (diff []string)
• type Aggregator
  • func (a *Aggregator) AggregateMetric(kafkaConn *kafka.Consumer, topics []string) ([]string, error)
  • func (a *Aggregator) CalculateMetric(responseMap map[string]map[string]map[string][]float64, ...) (map[string]interface{}, error)
• type MetricCollector
  • func NewMetricCollector(aggregateType types.AggregateType, createOrder int) (MetricCollector, error)
  • func (mc *MetricCollector) Collector(wg *sync.WaitGroup) error
• type TelegrafMetric

Constants

const (
	DEFAULT                = "default"
	SUBSCRIBE_ALIVE_TOPICS = "subscribeAliveTopics"
	UNSUBSCRIBE            = "unsubscribe"
	CLOSE                  = "close"
	TOPIC_HEARTBEAT        = 6
)

Variables

var KafkaConfig *kafka.ConfigMap

Functions

func ReturnDiffTopicList

func ReturnDiffTopicList(a, b []string) (diff []string)

Types

type Aggregator

type Aggregator struct {
	AggregateType types.AggregateType
}

func (*Aggregator) AggregateMetric

func (a *Aggregator) AggregateMetric(kafkaConn *kafka.Consumer, topics []string) ([]string, error)

func (*Aggregator) CalculateMetric

func (a *Aggregator) CalculateMetric(responseMap map[string]map[string]map[string][]float64, tagMap map[string]map[string]string, aggregateType string) (map[string]interface{}, error)

type MetricCollector

type MetricCollector struct {
	CreateOrder       int
	ConsumerKafkaConn *kafka.Consumer
	AdminKafkaConn    *kafka.AdminClient
	Aggregator        Aggregator
	Ch                chan string
}

func NewMetricCollector

func NewMetricCollector(aggregateType types.AggregateType, createOrder int) (MetricCollector, error)

func (*MetricCollector) Collector

func (mc *MetricCollector) Collector(wg *sync.WaitGroup) error

type TelegrafMetric

type TelegrafMetric struct {
	Name      string                 `json:"name"`
	Tags      map[string]interface{} `json:"tags"`
	Fields    map[string]interface{} `json:"fields"`
	Timestamp int64                  `json:"timestamp"`
	TagInfo   map[string]interface{} `json:"tagInfo"`
}