Categorygithub.com/Clymene-project/Clymenepluginstoragekafka
package
2.2.7+incompatible
Repository: https://github.com/clymene-project/clymene.git
Documentation: pkg.go.dev
Overview
Versions
2
Dependencies
24
Dependents
17
Files
558 SLOC

# Functions

NewFactory creates a new Factory.
No description provided by the author
No description provided by the author
NewJSONUnmarshaller constructs a JSONUnmarshaller.
No description provided by the author
No description provided by the author
No description provided by the author
NewProtobufUnmarshaller constructs a ProtobufUnmarshaller.

# Constants

EncodingJSON is used for timeseries encoded as Protobuf-based JSON.
EncodingProto is used for timeseries encoded as Protobuf.

# Variables

AllEncodings is a list of all supported encodings.

# Structs

Factory implements storage.Factory and creates write-only storage components backed by kafka.
JSONUnmarshaller implements Unmarshaller.
Options stores the configuration options for Kafka.
ProtobufUnmarshaller implements Unmarshaller.
Writer writes metric to kafka.
No description provided by the author

# Interfaces

Marshaller encodes a metric into a byte array to be sent to Kafka.
No description provided by the author