mq

type Consumer interface {
	// Recv get recv record chan
	Recv() <-chan Record
	// Errors get errors chan
	Errors() <-chan error
	// Commit commit record offset
	Commit(record Record) error
}

type ConsumerF func(config config.Config) (Consumer, error)

type Producer interface {
	// Record create new record
	Record(key []byte, value []byte) (Record, error)
	// Send send record
	Send(record Record) error
	// Batch batch send message record
	Batch(records []Record) error
}

type ProducerF func(config config.Config) (Producer, error)

type Record interface {
	Key() []byte
	Value() []byte
}

type Register interface {
	Set(driver string, consumerF ConsumerF, producerF ProducerF)
	Get(driver string) (ConsumerF, ProducerF)
}

type Retry struct {
	Max     int
	Backoff time.Duration
	Handler func(record Record) bool
}