mq

type Client struct {
	// contains filtered or unexported fields
}

type ClientOptionFunc func(*clientOptions)

type Consumer interface {
	// Subscribe topic 是主题，相同主题不同 channel 可以分发相同消息实现广播
	Subscribe(ctx context.Context, topic string, channel string) (<-chan Message, error)
	// Close 停止消费
	Close(ctx context.Context) error
}

type DecodeFunc func(ctx context.Context, message Message, args interface{}) error

type EncodeFunc func(ctx context.Context, args interface{}) (Message, error)

type ErrorHandler interface {
	Handle(err error)
}

type ErrorHandlerFunc func(err error)

type HandleFunc func(ctx context.Context, message Message)

type Handler interface {
	Handle(ctx context.Context, message Message)
}

type Message interface {
	// Metadata 元数据
	Metadata() metadata.Metadata
	// Payload 荷载信息
	Payload() Payload
	// Err 错误
	Err() error
	// UniKey 消息唯一键 用于消息去重(已经消费的消息不再消费)
	UniKey() string

	// Check 检查消息完整性
	Check() error
	// Marshal 序列化消息
	Marshal() ([]byte, error)
	// UnMarshal 解析消息
	UnMarshal([]byte) error
}

type MessageOption func(x *MessageV1)

type MessageV1 messagev1.Message

type Payload []byte

type Producer interface {
	// Publish topic 是主题 向 topic 投递消息，监听此 topic 的 Producer 可以收到消息
	Publish(ctx context.Context, topic string, message Message) error
	// Close 停止消费
	Close(ctx context.Context) error
}

type Server struct {
	// contains filtered or unexported fields
}

type ServerOptionFunc func(*serverOptions)