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

# Functions

NewManager creates a new Manager.

# Structs

ConcurrentList is a list that maintains kafka offsets with thread-safe Insert and setToHighestContiguous operations.
Manager accepts kafka offsets and commits them using the provided kafka consumer The Manager is designed to be used in a scenario where the consumption of kafka offsets is decoupled from the processing of offsets asynchronously via goroutines.

# Type aliases

MarkOffset is a func that marks offsets in Kafka.