broker

type Broker interface {
	Options() Options
	Connect() error
	Disconnect() error
	Publish(queue string, msg *Message, opts ...PublishOption) error
	Subscribe(queue string, handler Handler, opts ...SubscribeOption) (Subscriber, error)
	Name() string
}

type Handler func(Publication) error

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

type Option func(*Options)

type Options struct {
	Endpoints  []string
	Serializer serializer.Serializer
	Secure     bool
	TLSConfig  *tls.Config
	Context    context.Context
}

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

type PublishOption func(*PublishOptions)

type PublishOptions struct {
	Context context.Context
}

type SubscribeOption func(*SubscribeOptions)

type SubscribeOptions struct {
	AutoAck                      bool
	Queue                        string
	Context                      context.Context
	BeforeReceiveMessageCallback []func()
	OnReceiveMessageCallback     []func(*Message)
	AfterReceiveMessageCallback  []func()
	AvailableWorkersCount        func() int64
	DecrementAvailableWorkers    func()
}

type Subscriber interface {
	Options() SubscribeOptions
	Topic() string
	Unsubscribe() error
}