msgbs

type Article struct {
	ID    int64
	Title string
}

type Event string

type Message interface{}

type MessageBus interface {
	Publish(Event, Message) error
	Subscribe(Event)
	Unsubscribe(Event)
	Receive() interface{}
}

type RedisMessageBus struct {
	PubSubConn *redis.PubSubConn
	Conn       *redis.Conn
}

type Router map[Event][]SubscribeFunc

type SubscribeFunc func(context.Context, redis.Message) error

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

type Subscriber struct {
	MessageBus MessageBus
	Router     Router
	AppLog     applog.AppLog
}