broker

type Broker interface {
	Options() *Options
	NewProducer() (Producer, error)
	NewConsumer(opts ...SubscribeOption) (Consumer, error)
	Close() error
	Type() string
}

type Consumer interface {
	GroupID() string
	Topic() string
	Subscribe(topic string, h Handler) error
	Unsubscribe() error
}

type Event interface {
	Topic() string
	Message() *Message
	Error() error
	Ack() error
}

type Handler func(Event) error

type Message struct {
	Header map[string]interface{}
	Body   []byte
}

type Option func(*Options)

type Options struct {
	Addr         []string
	Kafka        *sarama.Config
	RabbitMq     *RabbitMq
	ErrorHandler Handler
}

type Producer interface {
	Publish(topic string, m *Message) error
}

type RabbitMq struct {
	ExchangeType    string
	ExchangeKey     string
	DurableExchange bool
	PrefetchCount   int
	PrefetchGlobal  bool

	Secure         bool
	TLSConfig      *tls.Config
	Authentication amqp.Authentication
}

type SubscribeOption func(*SubscribeOptions)

type SubscribeOptions struct {
	AutoAck bool
	GroupID string
}