redsync

Apr 14, 2024

Changes in this version

type RedisError

+ func (e RedisError) Unwrap() error

Feb 17, 2024

Changes in this version

+ var ErrLockAlreadyExpired = errors.New("redsync: failed to unlock, lock was already expired")

type Option

+ func WithSetNXOnExtend() Option

Nov 2, 2023

Changes in this version

type Mutex

+ func (m *Mutex) TryLock() error

+ func (m *Mutex) TryLockContext(ctx context.Context) error

Sep 10, 2023

Changes in this version

type Option

+ func WithFailFast(b bool) Option

Sep 10, 2023

Changes in this version

type Option

+ func WithShufflePools(b bool) Option

Dec 2, 2022

Changes in this version

+ type ErrNodeTaken struct

+ Node int

+ func (err ErrNodeTaken) Error() string

+ type ErrTaken struct

+ Nodes []int

+ func (err ErrTaken) Error() string

+ type RedisError struct

+ Err error

+ Node int

+ func (err RedisError) Error() string

Dec 20, 2021

Changes in this version

type Option

+ func WithTimeoutFactor(factor float64) Option

Aug 29, 2021

Changes in this version

+ var ErrExtendFailed = errors.New("redsync: failed to extend lock")

type Mutex

+ func (m *Mutex) Until() time.Time

Mar 13, 2021

Changes in this version

type Mutex

+ func (m *Mutex) Value() string

type Option

+ func WithValue(v string) Option

Mar 13, 2021

Changes in this version

type Mutex

+ func (m *Mutex) Name() string

Sep 19, 2020

Changes in this version

+ var ErrFailed = errors.New("redsync: failed to acquire lock")

+ type DelayFunc func(tries int) time.Duration

+ type Mutex struct

+ func (m *Mutex) Extend() (bool, error)

+ func (m *Mutex) ExtendContext(ctx context.Context) (bool, error)

+ func (m *Mutex) Lock() error

+ func (m *Mutex) LockContext(ctx context.Context) error

+ func (m *Mutex) Unlock() (bool, error)

+ func (m *Mutex) UnlockContext(ctx context.Context) (bool, error)

+ func (m *Mutex) Valid() (bool, error)

+ func (m *Mutex) ValidContext(ctx context.Context) (bool, error)

+ type Option interface

+ Apply func(*Mutex)

+ func WithDriftFactor(factor float64) Option

+ func WithExpiry(expiry time.Duration) Option

+ func WithGenValueFunc(genValueFunc func() (string, error)) Option

+ func WithRetryDelay(delay time.Duration) Option

+ func WithRetryDelayFunc(delayFunc DelayFunc) Option

+ func WithTries(tries int) Option

+ type OptionFunc func(*Mutex)

+ func (f OptionFunc) Apply(mutex *Mutex)

+ type Redsync struct

+ func New(pools ...redis.Pool) *Redsync

+ func (r *Redsync) NewMutex(name string, options ...Option) *Mutex