# Functions
No description provided by the author
NewMockBrokerReader creates a new mock instance.
NewMockBrokerWriter creates a new mock instance.
NewMockReader creates a new mock instance.
NewMockWriter creates a new mock instance.
NewReader based on brokers hosts, consumerGroup and topic.
NewReaderWithDLQ a reader with DLQ.
NewWriter based on brokers hosts, consumerGroup and topic.
# Structs
KafkaReader used as a default missy Reader implementation.
Message is a Kafka message.
MockBrokerReader is a mock of BrokerReader interface.
MockBrokerReaderMockRecorder is the mock recorder for MockBrokerReader.
MockBrokerWriter is a mock of BrokerWriter interface.
MockBrokerWriterMockRecorder is the mock recorder for MockBrokerWriter.
MockReader is a mock of Reader interface.
MockReaderMockRecorder is the mock recorder for MockReader.
MockWriter is a mock of Writer interface.
MockWriterMockRecorder is the mock recorder for MockWriter.
# Interfaces
BrokerReader interface used for underlying broker implementationgo:generate mockgen -package=messaging -destination broker_reader_mock.go -source reader.go BrokerReader.
BrokerWriter interface used for underlying broker implementationgo:generate mockgen -package=messaging -destination broker_writer_mock.go -source writer.go BrokerWriter.
Reader is used to read messages giving callback function.
Writer is used to write messages to underlying broker.
# Type aliases
ReadMessageFunc is a message reading callback function, on error message will not be committed to underlying.