redis

Nov 6, 2023

Changes in this version

type Client

+ GetSet func(ctx context.Context, key string, value interface{}) (interface{}, error)

Oct 12, 2023

Changes in this version

+ const DialerSrv

+ const DialerTcp

+ const Nil

+ func GetFullyQualifiedKey(appId cfg.AppId, key string) string

+ func IsRetryableError(err error) bool

+ func NewBackoffExecutor(logger log.Logger, settings exec.BackoffSettings, name string) exec.Executor

+ func NewExecutor(logger log.Logger, settings exec.BackoffSettings, name string) exec.Executor

+ func NilChecker(_ interface{}, err error) exec.ErrorType

+ func OOMChecker(_ interface{}, err error) exec.ErrorType

+ func RetryableErrorChecker(_ interface{}, err error) exec.ErrorType

+ type Client interface

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

+ DBSize func(ctx context.Context) (int64, error)

+ Decr func(ctx context.Context, key string) (int64, error)

+ DecrBy func(ctx context.Context, key string, amount int64) (int64, error)

+ Del func(ctx context.Context, keys ...string) (int64, error)

+ Exists func(ctx context.Context, keys ...string) (int64, error)

+ Expire func(ctx context.Context, key string, ttl time.Duration) (bool, error)

+ FlushDB func(ctx context.Context) (string, error)

+ Get func(ctx context.Context, key string) (string, error)

+ GetDel func(ctx context.Context, key string) (interface{}, error)

+ HDel func(ctx context.Context, key string, fields ...string) (int64, error)

+ HExists func(ctx context.Context, key string, field string) (bool, error)

+ HGet func(ctx context.Context, key string, field string) (string, error)

+ HGetAll func(ctx context.Context, key string) (map[string]string, error)

+ HKeys func(ctx context.Context, key string) ([]string, error)

+ HMGet func(ctx context.Context, key string, fields ...string) ([]interface{}, error)

+ HMSet func(ctx context.Context, key string, pairs map[string]interface{}) error

+ HSet func(ctx context.Context, key string, field string, value interface{}) error

+ HSetNX func(ctx context.Context, key string, field string, value interface{}) (bool, error)

+ Incr func(ctx context.Context, key string) (int64, error)

+ IncrBy func(ctx context.Context, key string, amount int64) (int64, error)

+ IsAlive func(ctx context.Context) bool

+ LLen func(ctx context.Context, key string) (int64, error)

+ LPop func(ctx context.Context, key string) (string, error)

+ LPush func(ctx context.Context, key string, values ...interface{}) (int64, error)

+ LRem func(ctx context.Context, key string, count int64, value interface{}) (int64, error)

+ MGet func(ctx context.Context, keys ...string) ([]interface{}, error)

+ MSet func(ctx context.Context, pairs ...interface{}) error

+ PFAdd func(ctx context.Context, key string, els ...interface{}) (int64, error)

+ PFCount func(ctx context.Context, keys ...string) (int64, error)

+ PFMerge func(ctx context.Context, dest string, keys ...string) (string, error)

+ Pipeline func() Pipeliner

+ RPop func(ctx context.Context, key string) (string, error)

+ RPush func(ctx context.Context, key string, values ...interface{}) (int64, error)

+ SAdd func(ctx context.Context, key string, values ...interface{}) (int64, error)

+ SCard func(ctx context.Context, key string) (int64, error)

+ SDiff func(ctx context.Context, keys ...string) ([]string, error)

+ SDiffStore func(ctx context.Context, destination string, keys ...string) (int64, error)

+ SInter func(ctx context.Context, keys ...string) ([]string, error)

+ SInterStore func(ctx context.Context, destination string, keys ...string) (int64, error)

+ SIsMember func(ctx context.Context, key string, value interface{}) (bool, error)

+ SMembers func(ctx context.Context, key string) ([]string, error)

+ SMove func(ctx context.Context, sourceKey string, destKey string, member interface{}) (bool, error)

+ SPop func(ctx context.Context, key string) (string, error)

+ SRandMember func(ctx context.Context, key string) (string, error)

+ SRem func(ctx context.Context, key string, values ...interface{}) (int64, error)

+ SUnion func(ctx context.Context, keys ...string) ([]string, error)

+ SUnionStore func(ctx context.Context, destination string, keys ...string) (int64, error)

+ Set func(ctx context.Context, key string, value interface{}, ttl time.Duration) error

+ SetNX func(ctx context.Context, key string, value interface{}, ttl time.Duration) (bool, error)

+ ZAdd func(ctx context.Context, key string, score float64, member string) (int64, error)

+ ZAddArgs func(ctx context.Context, args ZAddArgs) (int64, error)

+ ZAddArgsIncr func(ctx context.Context, args ZAddArgs) (float64, error)

+ ZCard func(ctx context.Context, key string) (int64, error)

+ ZCount func(ctx context.Context, key string, min string, max string) (int64, error)

+ ZIncrBy func(ctx context.Context, key string, increment float64, member string) (float64, error)

+ ZMScore func(ctx context.Context, key string, members ...string) ([]float64, error)

+ ZRandMember func(ctx context.Context, key string, count int) ([]string, error)

+ ZRange func(ctx context.Context, key string, start int64, stop int64) ([]string, error)

+ ZRangeArgs func(ctx context.Context, args ZRangeArgs) ([]string, error)

+ ZRangeArgsWithScore func(ctx context.Context, args ZRangeArgs) ([]Z, error)

+ ZRank func(ctx context.Context, key string, member string) (int64, error)

+ ZRem func(ctx context.Context, key string, members ...string) (int64, error)

+ ZRevRank func(ctx context.Context, key string, member string) (int64, error)

+ ZScore func(ctx context.Context, key string, member string) (float64, error)

+ func NewClient(config cfg.Config, logger log.Logger, name string) (Client, error)

+ func NewClientWithInterfaces(logger log.Logger, baseRedis baseRedis.Cmdable, executor exec.Executor, ...) Client

+ func ProvideClient(config cfg.Config, logger log.Logger, name string) (Client, error)

+ type Dialer func(logger log.Logger, settings *Settings) func(context.Context, string, string) (net.Conn, error)

+ type ErrCmder interface

+ Err func() error

+ type Naming struct

+ Pattern string

+ type Pipeliner interface

+ type Settings struct

+ Address string

+ BackoffSettings exec.BackoffSettings

+ Dialer string

+ Name string

+ Naming Naming

+ func ReadSettings(config cfg.Config, name string) *Settings

+ type SrvNamingFactory func(appId cfg.AppId, name string) string

+ type Z struct

+ Member interface{}

+ Score float64

+ type ZAddArgs struct

+ Ch bool

+ GT bool

+ Incr bool

+ Key string

+ LT bool

+ Members []Z

+ NX bool

+ XX bool

+ type ZRangeArgs struct

+ ByLex bool

+ ByScore bool

+ Count int64

+ Key string

+ Offset int64

+ Rev bool

+ Start interface{}

+ Stop interface{}