v9

Documentation

Index

• func NewRedisClientImplV9(client *redis.Client) core.IRedisClient
• type RedisClientImplV9
  • func (x *RedisClientImplV9) BLPop(ctx context.Context, timeout time.Duration, keys ...string) ([]string, error)
  • func (x *RedisClientImplV9) Del(ctx context.Context, keys ...string) error
  • func (x *RedisClientImplV9) Get(ctx context.Context, key string) ([]byte, error)
  • func (x *RedisClientImplV9) Keys(ctx context.Context, pattern string) ([]string, error)
  • func (x *RedisClientImplV9) RPushAndExpire(ctx context.Context, key string, value string, ttl time.Duration) error
  • func (x *RedisClientImplV9) SAdd(ctx context.Context, key string, members ...interface{}) error
  • func (x *RedisClientImplV9) SMembers(ctx context.Context, key string) ([]string, error)
  • func (x *RedisClientImplV9) SRem(ctx context.Context, key string, members ...interface{}) error
  • func (x *RedisClientImplV9) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) (string, error)
  • func (x *RedisClientImplV9) SetEX(ctx context.Context, key string, value interface{}, expiration time.Duration) error
  • func (x *RedisClientImplV9) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) (bool, error)

Functions

func NewRedisClientImplV9

func NewRedisClientImplV9(client *redis.Client) core.IRedisClient

Types

type RedisClientImplV9

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

func (*RedisClientImplV9) BLPop

func (x *RedisClientImplV9) BLPop(ctx context.Context, timeout time.Duration, keys ...string) ([]string, error)

func (*RedisClientImplV9) Del

func (x *RedisClientImplV9) Del(ctx context.Context, keys ...string) error

func (*RedisClientImplV9) Get

func (x *RedisClientImplV9) Get(ctx context.Context, key string) ([]byte, error)

func (*RedisClientImplV9) Keys

func (x *RedisClientImplV9) Keys(ctx context.Context, pattern string) ([]string, error)

func (*RedisClientImplV9) RPushAndExpire

func (x *RedisClientImplV9) RPushAndExpire(ctx context.Context, key string, value string, ttl time.Duration) error

func (*RedisClientImplV9) SAdd

func (x *RedisClientImplV9) SAdd(ctx context.Context, key string, members ...interface{}) error

func (*RedisClientImplV9) SMembers

func (x *RedisClientImplV9) SMembers(ctx context.Context, key string) ([]string, error)

func (*RedisClientImplV9) SRem

func (x *RedisClientImplV9) SRem(ctx context.Context, key string, members ...interface{}) error

func (*RedisClientImplV9) Set

func (x *RedisClientImplV9) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) (string, error)

func (*RedisClientImplV9) SetEX

func (x *RedisClientImplV9) SetEX(ctx context.Context, key string, value interface{}, expiration time.Duration) error

func (*RedisClientImplV9) SetNX

func (x *RedisClientImplV9) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) (bool, error)