pubsub

type IMessageBroker interface {
	Publish(ctx context.Context, channel string, payload interface{}) error
	Subscribe(ctx context.Context, channel string, callback func(channel string, payload string)) func() error
}