Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

redsync

package module

Go to main page

Versions in this module

v4

v4.0.4

Apr 8, 2026

Changes in this version

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

+ type ErrNodeTaken struct

+ Node int

+ func (err ErrNodeTaken) Error() string

+ type ErrTaken struct

+ Nodes []int

+ func (err ErrTaken) Error() string

type Mutex

+ func (m *Mutex) TryLock() error

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

type Option

+ func WithFailFast(b bool) Option

+ func WithSetNXOnExtend() Option

+ func WithShufflePools(b bool) Option

+ type RedisError struct

+ Err error

+ Node int

+ func (e RedisError) Error() string

+ func (e RedisError) Unwrap() error

v4.0.3

Mar 12, 2022

v4.0.2

Mar 12, 2022

Changes in this version

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

type Mutex

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

type Option

+ func WithTimeoutFactor(factor float64) Option

v4.0.1

Jun 4, 2021

v4.0.0

Mar 13, 2021

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) Name() string

+ 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)

+ func (m *Mutex) Value() string

+ 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

+ func WithValue(v string) 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

Other modules containing this package

github.com/admpub/redsync