redis_pubsub

Documentation

Index

• Variables
• type RdsPubSubMsg
  • func SharedRdsSubscribMsgInstance() *RdsPubSubMsg
  • func (r *RdsPubSubMsg) AddSubscribe(channel string, onRevMsg func(msg interface{}))
  • func (r *RdsPubSubMsg) IsRunning() bool
  • func (r *RdsPubSubMsg) Publish(channel string, msg interface{}) error
  • func (r *RdsPubSubMsg) Quit()
  • func (r *RdsPubSubMsg) Set(rdsCli redis.Cmdable)
  • func (r *RdsPubSubMsg) StartSubscription()

Variables

var (
	ERR_RedisNotInit = errors.New("redis not init")
)

Types

type RdsPubSubMsg

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

func SharedRdsSubscribMsgInstance

func SharedRdsSubscribMsgInstance() *RdsPubSubMsg

func (*RdsPubSubMsg) AddSubscribe

func (r *RdsPubSubMsg) AddSubscribe(channel string, onRevMsg func(msg interface{}))

func (*RdsPubSubMsg) IsRunning

func (r *RdsPubSubMsg) IsRunning() bool

func (*RdsPubSubMsg) Publish

func (r *RdsPubSubMsg) Publish(channel string, msg interface{}) error

func (*RdsPubSubMsg) Quit

func (r *RdsPubSubMsg) Quit()

func (*RdsPubSubMsg) Set

func (r *RdsPubSubMsg) Set(rdsCli redis.Cmdable)

func (*RdsPubSubMsg) StartSubscription

func (r *RdsPubSubMsg) StartSubscription()