cache

Jul 8, 2025

Changes in this version

type CommonProvider

+ func (p *CommonProvider) DelByPattern(ctx context.Context, pattern string, batchSize *int64) error

type Provider

+ DelByPattern func(ctx context.Context, pattern string, batchSize *int64) error

Jun 3, 2025

Changes in this version

+ type CommonProvider struct

+ func New(opts ...Option) (*CommonProvider, error)

+ func (p *CommonProvider) Close() error

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

+ func (p *CommonProvider) DecrBy(ctx context.Context, key string, decrement int64) (int64, error)

+ func (p *CommonProvider) Del(ctx context.Context, keys ...string) error

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

+ func (p *CommonProvider) GetDel(ctx context.Context, key string) (string, error)

+ func (p *CommonProvider) GetEx(ctx context.Context, key string, expiration time.Duration) (string, error)

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

+ func (p *CommonProvider) IncrBy(ctx context.Context, key string, value int64) (int64, error)

+ func (p *CommonProvider) Ping(ctx context.Context) (string, error)

+ func (p *CommonProvider) Set(ctx context.Context, key string, value any, expiration time.Duration) error

+ func (p *CommonProvider) SetNX(ctx context.Context, key string, value any, expiration time.Duration) error

+ type Option func(options *options) error

+ func WithClientName(clientName string) Option

+ func WithConnectionMaxIdleTime(connectionMaxIdleTime time.Duration) Option

+ func WithConnectionMaxLifetime(connectionMaxLifetime time.Duration) Option

+ func WithContextTimeoutEnabled(contextTimeoutEnabled bool) Option

+ func WithDB(db int) Option

+ func WithDialTimeout(dialTimeout time.Duration) Option

+ func WithHost(host string) Option

+ func WithMaxActiveConnections(maxActiveConnections int) Option

+ func WithMaxIdleConnections(maxIdleConnections int) Option

+ func WithMaxRetries(maxRetries int) Option

+ func WithMaxRetryBackoff(maxRetryBackoff time.Duration) Option

+ func WithMinIdleConnections(minIdleConnections int) Option

+ func WithMinRetryBackoff(minRetryBackoff time.Duration) Option

+ func WithPassword(password string) Option

+ func WithPoolFIFO(poolFIFO bool) Option

+ func WithPoolSize(poolSize int) Option

+ func WithPoolTimeout(poolTimeout time.Duration) Option

+ func WithPort(port int) Option

+ func WithReadTimeout(readTimeout time.Duration) Option

+ func WithUsername(username string) Option

+ func WithWriteTimeout(writeTimeout time.Duration) Option

+ type Provider interface

+ Close func() error

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

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

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

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

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

+ GetEx func(ctx context.Context, key string, expiration time.Duration) (string, error)

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

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

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

+ Set func(ctx context.Context, key string, value any, expiration time.Duration) error

+ SetNX func(ctx context.Context, key string, value any, expiration time.Duration) error