redis

Documentation

Index

• type RedisConsumerRepository
  • func NewConsumerRedis(rc *mredis.RedisConnection) *RedisConsumerRepository
  • func (rr *RedisConsumerRepository) Del(ctx context.Context, key string) error
  • func (rr *RedisConsumerRepository) Get(ctx context.Context, key string) error
  • func (rr *RedisConsumerRepository) Set(ctx context.Context, key, value string, ttl time.Duration) error

Types

type RedisConsumerRepository

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

RedisConsumerRepository is a Redis implementation of the Redis consumer.

func NewConsumerRedis

func NewConsumerRedis(rc *mredis.RedisConnection) *RedisConsumerRepository

NewConsumerRedis returns a new instance of RedisRepository using the given Redis connection.

func (*RedisConsumerRepository) Del

func (rr *RedisConsumerRepository) Del(ctx context.Context, key string) error

func (*RedisConsumerRepository) Get

func (rr *RedisConsumerRepository) Get(ctx context.Context, key string) error

func (*RedisConsumerRepository) Set

func (rr *RedisConsumerRepository) Set(ctx context.Context, key, value string, ttl time.Duration) error