redsync

Mar 29, 2020

Changes in this version

type Mutex

+ func (m *Mutex) Valid() bool

Apr 5, 2019

Changes in this version

type Option

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

Nov 21, 2018

Changes in this version

+ type DelayFunc func(tries int) time.Duration

type Option

+ func SetRetryDelayFunc(delayFunc DelayFunc) Option

Jun 17, 2016

Changes in this version

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

+ type Mutex struct

+ func (m *Mutex) Extend() bool

+ func (m *Mutex) Lock() error

+ func (m *Mutex) Unlock() bool

+ type Option interface

+ Apply func(*Mutex)

+ func SetDriftFactor(factor float64) Option

+ func SetExpiry(expiry time.Duration) Option

+ func SetRetryDelay(delay time.Duration) Option

+ func SetTries(tries int) Option

+ type OptionFunc func(*Mutex)

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

+ type Pool interface

+ Get func() redis.Conn

+ type Redsync struct

+ func New(pools []Pool) *Redsync

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