eventbus

type EventBus interface {
	// Subscribe to a topic
	Subscribe(ctx context.Context, topic string, handle SubscribeHandler) (err error)
	// Unsubscribe to a topic
	Unsubscribe(ctx context.Context, topic string, handle SubscribeHandler) (err error)
	// SubscribeOnce subscribes to a topic once. Handler will be removed after executing
	SubscribeOnce(ctx context.Context, topic string, handle SubscribeHandler) (err error)

	// Publish post a message to the topic
	Publish(ctx context.Context, topic string, msg *Message) (err error)

	// HandleCount get the number of Handle subscriptions for a topic
	HandleCount(topic string) int
}

type Message struct {
	Key   string `json:"key"`
	Value []byte `json:"value"`
}

type SubscribeHandler func(msg *Message)