kafka

Documentation

Index

• func New(brokers []string, autoInterval bool) *mtPublisher
• type MetricDataBuffer
• type MetricDataType
• type Partitioner

Functions

func New

func New(brokers []string, autoInterval bool) *mtPublisher

Types

type MetricDataBuffer

type MetricDataBuffer struct {
	Data []byte
	Type MetricDataType
}

type MetricDataType

type MetricDataType int

const (
	MetricData MetricDataType = iota
	MetricPoint
	MetricPointNoOrg
)

type Partitioner

type Partitioner interface {
	// contains filtered or unexported methods
}