redis

Documentation

Index

• type RedisClient
  • func NewRedisClient(logger *zap.Logger, opts *redis.Options, influxClient influxdb2.Client, ...) *RedisClient
  • func (c *RedisClient) Del(ctx context.Context, key string) error
  • func (c *RedisClient) Get(ctx context.Context, key string) (string, error)
  • func (c *RedisClient) LLen(ctx context.Context, key string) (int64, error)
  • func (c *RedisClient) LPush(ctx context.Context, key string, value string) error
  • func (c *RedisClient) Ping(ctx context.Context) error
  • func (c *RedisClient) RPop(ctx context.Context, key string) (string, error)
  • func (c *RedisClient) Set(ctx context.Context, key string, value string, expiration time.Duration) error

Types

type RedisClient

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

func NewRedisClient

func NewRedisClient(logger *zap.Logger, opts *redis.Options, influxClient influxdb2.Client, org string, bucket string) *RedisClient

func (*RedisClient) Del

func (c *RedisClient) Del(ctx context.Context, key string) error

func (*RedisClient) Get

func (c *RedisClient) Get(ctx context.Context, key string) (string, error)

func (*RedisClient) LLen

func (c *RedisClient) LLen(ctx context.Context, key string) (int64, error)

func (*RedisClient) LPush

func (c *RedisClient) LPush(ctx context.Context, key string, value string) error

func (*RedisClient) Ping

func (c *RedisClient) Ping(ctx context.Context) error

func (*RedisClient) RPop

func (c *RedisClient) RPop(ctx context.Context, key string) (string, error)

func (*RedisClient) Set

func (c *RedisClient) Set(ctx context.Context, key string, value string, expiration time.Duration) error