package
1.0.5
Repository: https://github.com/cockroachdb/replicator.git
Documentation: pkg.go.dev

# Functions

NewMockClient instantiate a new client that always returns the given Consumer.
NewMockConsumer creates a consumer for the given set of messages.
NewMockPartitionConsumer sets the messages that the partition will return to the consumer.

# Structs

Message is used to abstract a Kafka message for testing purposes.
MockClient implements sarama.Client interface for testing purposes.
MockConsumer is a consumer for a fixed set of messages.
MockPartitionConsumer implements sarama.PartitionConsumer interface for testing purposes.