Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RedisBroker ¶
type RedisBroker struct {
// contains filtered or unexported fields
}
func NewRedisBroker ¶
func NewRedisBroker(uuid util.UUID) *RedisBroker
func (*RedisBroker) Publish ¶
func (b *RedisBroker) Publish(msg []byte)
func (*RedisBroker) Subscribe ¶
func (b *RedisBroker) Subscribe() (ch chan []byte, err error)
func (*RedisBroker) Unsubscribe ¶
func (b *RedisBroker) Unsubscribe(ch chan []byte)
func (*RedisBroker) UnsubscribeAll ¶
func (b *RedisBroker) UnsubscribeAll()
type RedisRegistrar ¶
type RedisRegistrar struct{}
func NewRedisRegistrar ¶
func NewRedisRegistrar() *RedisRegistrar
func (*RedisRegistrar) IsRegistered ¶
func (rr *RedisRegistrar) IsRegistered(channel util.UUID) (registered bool)
Click to show internal directories.
Click to hide internal directories.