pubsub

type Consumer interface {
	Consume(context.Context, HandlerFunc) error
}

type HandlerFunc func(ctx context.Context, msg Message) error

type Message interface {
	// Ack nowledges and accepts a message
	Ack()
	// Nack (not acklowdges) a message and requeue it
	Nack()
	// Data returns the byte data of a message
	Data() []byte
}

type Producer interface {
	Produce(ctx context.Context, data []byte) error
}