broker

type Broker interface {
	fmt.Stringer
	Publish(topic string, msg *Message, opt ...PublishOption) error
	Subscribe(topics []string, callBack CallBack, opt ...SubscribeOption) (Subscriber, error)
	Connect() error
	Disconnect() error
}

type CallBack func(event Event) error

type Event interface {
	Topic() string
	Ack() error
	Message() *Message
	Context() context.Context
}

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

type PublishOption func(*PublishOptions)

type PublishOptions struct {
	ExchangeName     string
	ExchangeType     string
	ExchangeAD       bool // exchange auto delete
	ExchangeDuration bool // exchange duration
	Context          context.Context
	QOS              int
	Retained         bool
	// kafka
	Part    int
	Replica int
}

type SubscribeOption func(*SubscribeOptions)

type SubscribeOptions struct {
	AutoAck          bool
	AutoDel          bool
	Duration         bool
	Queue            string
	ExchangeName     string
	ExchangeType     string
	ExchangeAD       bool // exchange auto delete
	ExchangeDuration bool // exchange duration
	QOS              int
	Context          context.Context
	// kafka
	Part    int
	Replica int
}

type Subscriber interface {
	Unsubscribe() error
	String() string
}