redisstarter

Apr 9, 2025

Changes in this version

+ type RedisConfig struct

+ InitFunc func(instance redis.UniversalClient)

type RedisKey

+ func (r RedisKey) RawKeyString(keyAppend ...interface{}) string

type RedisStarter

+ Config RedisConfig

+ LazyConfig func() RedisConfig

Jan 21, 2025

Changes in this version

+ type Locker struct

+ func TryAndGetLocker(key RedisKey, keyAppend ...interface{}) (*Locker, error)

+ func TryAndGetLockerWithContext(ctx context.Context, key RedisKey, keyAppend ...interface{}) (*Locker, error)

+ func (l *Locker) RawLocker() *redislock.Lock

+ func (l *Locker) Release() error

+ func (l *Locker) ReleaseWithCtx(ctx context.Context) error

Sep 28, 2024

Changes in this version

+ func ListCmd() *cmdList

+ func SortedSetCmd() *cmdSortedSet

type RedisKey

+ func NewRedisKey(keyFormat string, expire ...time.Duration) RedisKey

Jul 9, 2024

Changes in this version

+ func BloomCmd() *cmdBloom

+ type BloomInfo struct

+ Capacity int64

+ ExpansionRate int64

+ NumberOfFilters int64

+ NumberOfItemsInserted int64

+ Size int64

Jun 27, 2024

Changes in this version

+ func HashCmd() *cmdHash

+ func KeyCmd() *cmdKey

+ func LockWithDeadline(ctx context.Context, key string, lockTtl time.Duration, ...) error

+ func LockWithMaxRetry(ctx context.Context, key string, lockTtl time.Duration, ...) error

+ func OriginKeyString(keyFormat string, keyAppend ...interface{}) string

+ func QueueCmd() *cmdQueue

+ func RawLockerClient() *redislock.Client

+ func RawRedisClient() redis.UniversalClient

+ func SetCmd() *cmdSet

+ func StringCmd() *cmdString

+ func TopicCmd() *cmdTopic

+ func TryLock(key string, lockTtl time.Duration, executable func()) error

+ func TryLockWithContext(ctx context.Context, key string, lockTtl time.Duration, executable func()) error

+ type RedisKey struct

+ Expire time.Duration

+ KeyFormat string

+ type RedisStarter struct

+ InitFunc func(instance redis.UniversalClient)

+ LazyRedisConfig func() redis.UniversalOptions

+ RedisConfig redis.UniversalOptions

+ RedisSetting *parent.Setting

+ func (r *RedisStarter) Setting() *parent.Setting

+ func (r *RedisStarter) Start() (interface{}, error)

+ func (r *RedisStarter) Stop(maxWaitTime time.Duration) (gracefully, stopped bool, err error)