Documentation
¶
Index ¶
- Variables
- type 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()
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ERR_RedisNotInit = errors.New("redis not init")
)
Functions ¶
This section is empty.
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()
Source Files
Click to show internal directories.
Click to hide internal directories.