redis

Documentation

Index

• type RedisClient
• type RedisPubSub
  • func (rPubSub *RedisPubSub) Close() error
  • func (rPubSub *RedisPubSub) Publish(msg string) error
  • func (rPubSub *RedisPubSub) ReceiveMessage() chan string
  • func (rPubSub *RedisPubSub) SetChannel(channel string) i.IPubSub
  • func (rPubSub *RedisPubSub) SetClient(iClient *i.IClient) i.IPubSub
• type RedisQueue
  • func (rq *RedisQueue) Dequeue() (string, error)
  • func (rq *RedisQueue) Enqueue(val string) error
  • func (rq *RedisQueue) SetClient(iClient *i.IClient) i.IQueue
  • func (rq *RedisQueue) SetTopic(topic string) i.IQueue

Types

type RedisClient

type RedisClient struct {
	redis.Client
}

type RedisPubSub

type RedisPubSub struct {
	RedisClient
	Channel string
}

func (*RedisPubSub) Close

func (rPubSub *RedisPubSub) Close() error

func (*RedisPubSub) Publish

func (rPubSub *RedisPubSub) Publish(msg string) error

func (*RedisPubSub) ReceiveMessage

func (rPubSub *RedisPubSub) ReceiveMessage() chan string

func (*RedisPubSub) SetChannel

func (rPubSub *RedisPubSub) SetChannel(channel string) i.IPubSub

func (*RedisPubSub) SetClient

func (rPubSub *RedisPubSub) SetClient(iClient *i.IClient) i.IPubSub

type RedisQueue

type RedisQueue struct {
	RedisClient
	Topic string
}

func (*RedisQueue) Dequeue

func (rq *RedisQueue) Dequeue() (string, error)

func (*RedisQueue) Enqueue

func (rq *RedisQueue) Enqueue(val string) error

func (*RedisQueue) SetClient

func (rq *RedisQueue) SetClient(iClient *i.IClient) i.IQueue

func (*RedisQueue) SetTopic

func (rq *RedisQueue) SetTopic(topic string) i.IQueue