pubsub

Documentation

Index

• type Pubsub
  • func GetPubsub(connStr string) Pubsub
• type RedisPubsub
  • func GetRedisPubsub(connStr string) *RedisPubsub
  • func (rp *RedisPubsub) Close() error
  • func (rp *RedisPubsub) Del(key string) *redis.IntCmd
  • func (rp *RedisPubsub) Get(key string) *redis.StringCmd
  • func (rp *RedisPubsub) Publish(channel string, payload string) error
  • func (rp *RedisPubsub) Set(key string, value []byte) *redis.StatusCmd
  • func (rp *RedisPubsub) Subscribe(channel string) *redis.PubSub

Types

type Pubsub

type Pubsub interface {
	Publish(channel string, payload string) error
	Subscribe(channel string) *redis.PubSub
	Get(key string) *redis.StringCmd
	Del(key string) *redis.IntCmd
	Set(key string, value []byte) *redis.StatusCmd
	Close() error
}

func GetPubsub

func GetPubsub(connStr string) Pubsub

type RedisPubsub

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

func GetRedisPubsub

func GetRedisPubsub(connStr string) *RedisPubsub

func (*RedisPubsub) Close

func (rp *RedisPubsub) Close() error

func (*RedisPubsub) Del

func (rp *RedisPubsub) Del(key string) *redis.IntCmd

func (*RedisPubsub) Get

func (rp *RedisPubsub) Get(key string) *redis.StringCmd

func (*RedisPubsub) Publish

func (rp *RedisPubsub) Publish(channel string, payload string) error

func (*RedisPubsub) Set

func (rp *RedisPubsub) Set(key string, value []byte) *redis.StatusCmd

func (*RedisPubsub) Subscribe

func (rp *RedisPubsub) Subscribe(channel string) *redis.PubSub