broker

type Config struct {
	config.Config `field:"-"`
	ErrorHandler  Handler            `field:"-"`
	Codec         codec.ICodec       `field:"-"` // Codec
	Registry      registry.IRegistry `field:"-"` // Registry used for clustering
	Context       context.Context    `field:"-"`
	TLSConfig     *tls.Config        `field:"-"`
	PrefixName    string             `field:"-"`
	Name          string             `field:"-"`
	Addrs         []string

	// Handler executed when error happens in broker mesage
	// processing
	Secure bool

	BroadcastVersion string
	RegisterTTL      time.Duration `field:"register_ttl"`
	RegisterInterval time.Duration
}

type Handler func(IEvent) error

type IBroker interface {
	String() string // 返回对象名称
	Init(...Option) error
	Config() *Config
	Address() string
	Start() error // 开始阻塞监听
	Close() error
	Publish(topic string, m *Message, opts ...PublishOption) error
	Subscribe(topic string, h Handler, opts ...SubscribeOption) (ISubscriber, error)
}

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

type ISubscriber interface {
	Config() *SubscribeConfig
	Topic() string
	Unsubscribe() error
}

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

type Option func(*Config)

type PublishConfig struct {
	Codec         codec.ICodec
	SerializeType codec.SerializeType
	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type PublishOption func(*PublishConfig)

type SubscribeConfig struct {
	// AutoAck defaults to true. When a handler returns
	// with a nil error the message is acked.
	AutoAck bool
	// Subscribers with the same queue name
	// will create a shared subscription where each
	// receives a subset of messages.
	Queue string

	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type SubscribeOption func(*SubscribeConfig)