broker

type Any interface{}

type Binder func() Any

type Broker interface {
	Name() string

	Options() Options

	Address() string

	Init(...Option) error

	Connect() error

	Disconnect() error

	Publish(ctx context.Context, topic string, msg Any, opts ...PublishOption) error

	Subscribe(topic string, handler Handler, binder Binder, opts ...SubscribeOption) (Subscriber, error)
}

type Event interface {
	Topic() string

	Message() *Message
	RawMessage() interface{}

	Ack() error

	Error() error
}

type Handler func(ctx context.Context, evt Event) error

type Headers map[string]string

type Message struct {
	Headers Headers
	Body    Any
}

type Option func(*Options)

type Options struct {
	Addrs []string

	Codec encoding.Codec

	ErrorHandler Handler

	Secure    bool
	TLSConfig *tls.Config

	Context context.Context

	Tracings []tracing.Option
}

type PublishOption func(*PublishOptions)

type PublishOptions struct {
	Context context.Context
}

type SubscribeOption func(*SubscribeOptions)

type SubscribeOptions struct {
	AutoAck bool
	Queue   string
	Context context.Context
}

type Subscriber interface {
	// Options .
	Options() SubscribeOptions

	// Topic .
	Topic() string

	// Unsubscribe .
	Unsubscribe(removeFromManager bool) error
}

type SubscriberMap map[string]Subscriber

type SubscriberSyncMap struct {
	sync.RWMutex
	// contains filtered or unexported fields
}