interfaces

type BrokerGenerator = func(addr string) SaramaBroker

type ConsumerGroupInitialiser = func(addrs []string, groupID string, config *sarama.Config) (sarama.ConsumerGroup, error)

type Message interface {

	// GetData returns the message contents.
	GetData() []byte

	// GetHeader takes a key for the header and returns the value if the key exist in the header.
	GetHeader(key string) string

	// Context returns a context with traceid.
	Context() context.Context

	// Mark marks the message as consumed, but doesn't commit the offset to the backend
	Mark()

	// Commit marks the message as consumed and commits its offset to the backend
	Commit()

	// Release closes the UpstreamDone channel for this message
	Release()

	// CommitAndRelease marks a message as consumed, commits it and closes the UpstreamDone channel
	CommitAndRelease()

	// Offset returns the message offset
	Offset() int64

	// UpstreamDone returns the upstreamDone channel. Closing this channel notifies that the message has been consumed
	UpstreamDone() chan struct{}
}

type ProducerInitialiser = func(addrs []string, config *sarama.Config) (sarama.AsyncProducer, error)

type SaramaAsyncProducer = sarama.AsyncProducer

type SaramaBroker interface {
	Addr() string
	Connected() (bool, error)
	Open(conf *sarama.Config) error
	GetMetadata(request *sarama.MetadataRequest) (*sarama.MetadataResponse, error)
	Close() error
}

type SaramaConsumerGroup = sarama.ConsumerGroup

type SaramaConsumerGroupClaim = sarama.ConsumerGroupClaim

type SaramaConsumerGroupSession = sarama.ConsumerGroupSession