mq

type Message interface {
	Topic() string
	ID() int64
	Timestamp() time.Time

	Data() []byte
	Extra() map[string][]string
}

type MessageArshaler interface {
	Marshal() ([]byte, error)
	Unmarshal([]byte) error
}

type MutMessage interface {
	Message

	AddExtra(string, string)
	SetSubOrderedKey(string)
	SetPubOrderedKey(string)
}

type Option interface {
	OptionScheme() string
}

type OptionApplier interface {
	Apply(Option)
}

type OptionApplyFunc func(Option)

type OrderedMessage interface {
	Message

	PubOrderedKey() string
	SubOrderedKey() string
}

type PubSub interface {
	// Publisher returns a publisher
	Publisher(ctx context.Context, options ...OptionApplier) (Publisher, error)
	// Subscriber returns a subscriber
	Subscriber(ctx context.Context, options ...OptionApplier) (Subscriber, error)
	// Close closes pub/sub endpoint
	Close() error
}

type Publisher interface {
	Topic() string
	Publish(context.Context, any) error
	PublishMessage(context.Context, Message) error
	Close()
}

type Subscriber interface {
	// Run starts consuming and handling messages with h
	Run(ctx context.Context, h func(context.Context, Message) error) <-chan error
	// Close closes this subscriber
	Close()
}