streaming

type Consumer interface {
	// Output gets messages until the given date.
	Output(endTime time.Time) (<-chan Messages, <-chan error)
	// Close closes the producer.
	Close() error
	// IsHealthy checks the health of the Consumer.
	IsHealthy() bool
}

type Error struct {
	Msgs []*Message
	Err  error
}

type Message struct {
	Topic string
	Key   []byte
	Data  []byte
}

type Messages []*Message

type Producer interface {
	// Name is the name of the producer.
	Name() string
	// Input is the message input channel.
	Input() chan<- *Message
	// Errors is the error output channel.
	Errors() <-chan *Error
	// Close closes the producer.
	Close() error
	// IsHealthy checks the health of the producer.
	IsHealthy() bool
}