redcsync

Jul 23, 2019

Changes in this version

+ var ErrTimeout = errors.New("redcsync: acquire lock timeout")

+ type DelayFunc func(tries int) time.Duration

type Option

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

+ func SetRetryDelayFunc(delayFunc DelayFunc) Option

+ type Redcsync struct

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

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