package
0.17.3
Repository: https://github.com/go-graphite/go-carbon.git
Documentation: pkg.go.dev

# Functions

NewOptions returns Options struct filled with default values.

# Constants

OffsetNewest represents newest offset in Kafka.
OffsetOldest represents oldest offset in Kafka.
ProtocolMsgPack represents msgpack messages.
ProtocolPickle represents pickled messages.
ProtocolPlain represents graphite line protocol.
ProtocolProtobuf represents protobuf messages.

# Structs

Duration wrapper time.Duration for TOML.
Kafka receive metrics in protobuf or graphite line format from Kafka partitions.
Options contains all receiver's options that can be changed by user.

# Type aliases

Offset is a special type to define kafka offsets.
Protocol is a special type to allow user to define wire protocol in Config file as a simple text.