Package mock_metrics is a generated GoMock package.

NewTransport creates a new kafka transport.

Providers is a set of dependencies including ReaderMaker, WriterMaker and exported configs.

SpanFromMessage reads the message.

Trace takes a kafka.Writer and returns a decorated Writer.

WithLogger is an option that provides logging to writer.

WithReaderInterceptor instructs the Providers to accept the ReaderInterceptor so that users can change reader config during runtime.

WithReaderReload toggles whether the reader factory should reload cached instances upon OnReload event.

WithWriterInterceptor instructs the Providers to accept the WriterInterceptor so that users can change reader config during runtime.

WithWriterReload toggles whether the writer factory should reload cached instances upon OnReload event.

AggStats is a gauge group struct.

KafkaLogAdapter is an log adapter bridging kitlog and kafka.

ReaderConfig is a configuration object used to create new instances of Reader.

ReaderStats is a collection of metrics for kafka reader info.

Transport is a type which traces the interacting with kafka brokers.

Writer is a decorator around kafka.Writer that provides tracing capabilities.

WriterConfig is a configuration type used to create new instances of Writer.

WriterStats is a collection of metrics for kafka writer info.

ReaderMaker models a ReaderFactory.

WriterMaker models a WriterFactory.

ProvidersOptionFunc is the type of functional providersOption for Providers.

ReaderInterceptor is an interceptor that makes last minute change to a *kafka.ReaderConfig during kafka.Reader's creation.

WriterInterceptor is an interceptor that makes last minute change to a *kafka.Writer during its creation.

WriterOption is type that configures the Writer.