vcs_kafka

Documentation

Index

• func FmtField(fields []*Field) string
• func FmtTags(tags []*Tag) string
• func NewMetric(name string, tags map[string]string, fields map[string]interface{}, ...) *metric
• type Field
• type Kafka
  • func (k *Kafka) Description() string
  • func (k *Kafka) Gather(acc telegraf.Accumulator) error
  • func (Kafka) SampleConfig() string
• type KafkaLag
• type KafkaLagDetail
• type Tag

Functions

func FmtField

func FmtField(fields []*Field) string

func FmtTags

func FmtTags(tags []*Tag) string

func NewMetric

func NewMetric(
	name string,
	tags map[string]string,
	fields map[string]interface{},
	tm time.Time,
) *metric

Types

type Field

type Field struct {
	Key   string
	Value interface{}
}

type Kafka

type Kafka struct {
	Brokers               []string
	FilterTopics          string
	FilterConsummerGroups string
	Detail                bool
	Version               string
	Debug                 bool
	// contains filtered or unexported fields
}

func (*Kafka) Description

func (k *Kafka) Description() string

func (*Kafka) Gather

func (k *Kafka) Gather(acc telegraf.Accumulator) error

func (Kafka) SampleConfig

func (Kafka) SampleConfig() string

type KafkaLag

type KafkaLag struct {
	// contains filtered or unexported fields
}

type KafkaLagDetail

type KafkaLagDetail struct {
	// contains filtered or unexported fields
}

type Tag

type Tag struct {
	Key   string
	Value string
}