cache

Dec 4, 2024

Changes in this version

+ var ErrEmptyInput = errors.New("empty input provided")

+ var ErrInvalidDelInput = errors.New("invalid input type for Del operation")

+ var ErrNilClient = errors.New("redis client is nil")

+ var ErrNilDB = errors.New("database connection is nil")

+ type Config struct

+ ConnectTimeout time.Duration

+ DB int

+ MaxRetries int

+ MaxRetryBackoff time.Duration

+ MinRetryBackoff time.Duration

+ OperationTimeout time.Duration

+ Password string

+ RedisURL string

+ type OptFunc func(*Config)

+ func WithDB(db int) OptFunc

+ func WithPassword(password string) OptFunc

+ func WithRedisURL(url string) OptFunc

+ type Persistent struct

+ func MustConnect(db *sqlx.DB, opts ...OptFunc) *Persistent

+ func NewWithOptions(db *sqlx.DB, cfg *Config) *Persistent

+ func (p *Persistent) Close() error

+ func (p *Persistent) Del(ctx context.Context, input interface{}) error

+ func (p *Persistent) DelByPattern(ctx context.Context, pattern string) error

+ func (p *Persistent) Get(ctx context.Context, key string, dest interface{}, query func() error) error

+ func (p *Persistent) GetDB() *sqlx.DB

+ func (p *Persistent) GetRedis() *redis.Client

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