Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type RedisCache ¶
type RedisCache struct {
// contains filtered or unexported fields
}
func NewRedisCache ¶
func NewRedisCache(client *redis.Client) *RedisCache
func (*RedisCache) Del ¶
func (rs *RedisCache) Del(key string) error
type RedisPubSub ¶
type RedisPubSub struct {
// contains filtered or unexported fields
}
RedisPubSub implements the PublishSubscribe interface, but publishes to all subscribers. All subscribers will receive the message.
func NewRedisPubSub ¶
func NewRedisPubSub(client *redis.Client) *RedisPubSub
type RedisQueue ¶
type RedisQueue struct {
// contains filtered or unexported fields
}
RedisQueue implements the PublishSubscribe interface, but only publishes to one subscriber. Implemented by having Publishers push into a queue, and Subscribers read from the queue and pop off from the top.
func NewRedisQueue ¶
func NewRedisQueue(client *redis.Client, queueID, groupID string) *RedisQueue
NewRedisQueue creates a new queue and a group associated with that queue. Underlying mecahnism uses Redis Streams.
Source Files
Click to show internal directories.
Click to hide internal directories.