transport

type Consumer interface {
	// Messages returns a channel which receives messages.
	Messages() <-chan message.Message
}

type Producer interface {
	// Send sends a message to a topic.
	Send(topic string, message message.Message) error

	// Errors returns a channel which receives errors resulting asynchronously from sending messages.
	Errors() <-chan error
}