Categorygithub.com/jaegertracing/jaegercmdingesterappconsumer
package
2.3.0+incompatible
Repository: https://github.com/jaegertracing/jaeger.git
Documentation: pkg.go.dev
Versions
2
Dependencies
14
Dependents
8
Files
502 SLOC

# Packages

# Functions

New is a constructor for a Consumer.
NewCommittingProcessor returns a processor that commits message offsets to Kafka.
NewProcessorFactory constructs a new ProcessorFactory.

# Structs

Consumer uses sarama to consume and handle messages from kafka.
Params are the parameters of a Consumer.
ProcessorFactory is a factory for creating startedProcessors.
ProcessorFactoryParams are the parameters of a ProcessorFactory.

# Interfaces

Message contains the parts of a sarama ConsumerMessage that we care about.