nop

type Consumer struct {

	// Mock can be for mocking Consumer
	// see const above for supported values
	// Supported Values:
	// - "init_err" - returns err on NewConsumer
	// - "err" - every method returns an error
	// - "msg_err" - returns err on Consumer.Msg() call.
	// - "msg_done" - returns a nil task message done=true on Consumer.Msg() call.
	// - "msg_msg_done" - returns a non-nil task message and done=true Consumer.Msg() call.
	// - "stop_err" - returns err on Stop() method call
	Mock  string
	Stats info.Consumer
}

type Producer struct {
	// Mock can be set in order to
	// mock various return scenarios.
	//
	// Supported Values:
	// - "init_err" - returns err on NewProducer
	// - "err" - every method returns an error
	// - "send_err" - returns err when Producer.Send() is called.
	// - "stop_err" - returns err on Stop() method call
	Mock     string
	Messages map[string][]string // [topic]Messages
	Stats    info.Producer
	// contains filtered or unexported fields
}