package
0.4.3-alpha
Repository: https://github.com/etf1/kafka-mongo-watcher.git
Documentation: pkg.go.dev
# Functions
AddTracingHeader simply adds a tracing header with application name and a timestamp to enable simple debugging.
NewClient returns a basic kafka client.
NewClientDebugger returns a kafka client that allows retrieve debug information from an original client.
NewClientLogger returns a kafka client that allows adding log information from an original client.
NewClientMetric returns a kafka client that allows adding trace information from an original client.
NewClientTracer returns a kafka client that allows adding trace information from an original client.
NewMockClient creates a new mock instance.
NewMockKafkaProducer creates a new mock instance.
# Constants
XTracingHeaderName corresponds to the X-Tracing header to is sent in Kafka messages with some tracing information.
# Structs
Header represents a message header.
Message is used over a channel that is filled by kafka transformer.
MockClient is a mock of Client interface.
MockClientMockRecorder is the mock recorder for MockClient.
MockKafkaProducer is a mock of KafkaProducer interface.
MockKafkaProducerMockRecorder is the mock recorder for MockKafkaProducer.