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
}

type MessageBrokerDriver string

type MessageBrokerOptions struct {
	Db     int
	Driver MessageBrokerDriver
}