NewFactory creates a new Factory.

NewJSONUnmarshaller constructs a JSONUnmarshaller.

NewProtobufUnmarshaller constructs a ProtobufUnmarshaller.

NewSpanWriter initiates and returns a new kafka spanwriter.

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.

SpanWriter writes spans to kafka.

Marshaller encodes a span into a byte array to be sent to Kafka.

Unmarshaller decodes a byte array to a span.