Versions in this module Expand all Collapse all v0 v0.4.1 Jul 18, 2019 v0.4.0 Jul 18, 2019 Changes in this version + type RedisClient struct + type RedisPubSub struct + Channel string + 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 struct + Topic string + 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
Go to main page