Struct AsyncProducer

mocks/async_producer.go:16–29

AsyncProducer implements sarama's Producer interface for testing purposes. Before you can send messages to it's Input channel, you have to set expectations so it knows how to handle the input; it returns an error if the number of messages received is bigger then the number of expectations set. You c

// function in each expectation so that the message is checked by this function and
// an error is returned if the match fails.
type AsyncProducer struct {
	l               sync.Mutex
	t               ErrorReporter
	expectations    []*producerExpectation
	closed          chan struct{}
	input           chan *sarama.ProducerMessage
	successes       chan *sarama.ProducerMessage
	errors          chan *sarama.ProducerError
	isTransactional bool
	txnLock         sync.Mutex
	txnStatus       sarama.ProducerTxnStatusFlag
	lastOffset      int64
	*TopicConfig
}

// NewAsyncProducer instantiates a new Producer mock. The t argument should
// be the *testing.T instance of your test method. An error will be written to it if