redis

Documentation

Index

• type RedisClient
  • func NewRedisClient(ctx context.Context, url string, pass string) (*RedisClient, error)
  • func (rdb *RedisClient) Close() error
  • func (rdb *RedisClient) Get(key string) (string, error)
  • func (rdb *RedisClient) Publish(key string, value string) error
  • func (rdb *RedisClient) Set(key string, value string, ttl time.Duration) error
  • func (rdb *RedisClient) Subscribe(ctx context.Context, key string) (*redis.PubSub, chan []byte, error)

Types

type RedisClient

type RedisClient struct {
	Client *redis.Client
	// contains filtered or unexported fields
}

RedisClient

func NewRedisClient

func NewRedisClient(ctx context.Context, url string, pass string) (*RedisClient, error)

RedisClient

func (*RedisClient) Close

func (rdb *RedisClient) Close() error

Close closes the redis connection

func (*RedisClient) Get

func (rdb *RedisClient) Get(key string) (string, error)

Get

func (*RedisClient) Publish

func (rdb *RedisClient) Publish(key string, value string) error

Publish

func (*RedisClient) Set

func (rdb *RedisClient) Set(key string, value string, ttl time.Duration) error

Set

func (*RedisClient) Subscribe

func (rdb *RedisClient) Subscribe(ctx context.Context, key string) (*redis.PubSub, chan []byte, error)

Subscribe to redis channel and return a channel of messages