bus

type Bus interface {
	// Publish publishes arguments to the given topic subscribers
	// Publish block only when the buffer of one of the subscribers is full.
	Publish(topic string, args ...interface{})
	// CloseTopic unsubscribe all subscribers from given topic
	CloseTopic(topic string)
	// Subscribe subscribes to the given topic
	Subscribe(topic string, fn interface{}, options ...interface{}) error
	// Unsubscribe handler from the given topic
	Unsubscribe(topic string, fn interface{}) error
	// Stat ...
	Stat(ctx context.Context, limit, offset int64, orderBy, sort string) (stats Stats, total int64, err error)
	// Purge ...
	Purge()
}

type Stat struct {
	Topic       string
	Subscribers int
}

type Stats []Stat