mutex

Documentation

Index

• Variables
• type Locker
• type Mutex
  • func NewMutex(ctx context.Context, client *redis.Client, keySuffix string) *Mutex
  • func (m *Mutex) Lock() (rerr error)
  • func (m *Mutex) Unlock() error
  • func (m *Mutex) WithLockTimeout(d time.Duration) *Mutex
  • func (m *Mutex) WithWaitTimeout(d time.Duration) *Mutex
• type NonBlockingLocker
• type NonBlockingMutex
  • func NewNonBlockingMutex(ctx context.Context, client *redis.Client, keySuffix string) *NonBlockingMutex
  • func (m *NonBlockingMutex) TryLock() (bool, error)
  • func (m *NonBlockingMutex) Unlock() error
  • func (m *NonBlockingMutex) WithLockTimeout(d time.Duration) *NonBlockingMutex

Variables

var MutexPrefix = "mutex/"

var NonBlockingMutexPrefix = "non-blocking-mutex/"

Types

type Locker

type Locker interface {
	Lock() error
	Unlock() error
}

type Mutex

type Mutex struct {
	QueueKey string
	// contains filtered or unexported fields
}

func NewMutex

func NewMutex(ctx context.Context, client *redis.Client, keySuffix string) *Mutex

func (*Mutex) Lock

func (m *Mutex) Lock() (rerr error)

func (*Mutex) Unlock

func (m *Mutex) Unlock() error

func (*Mutex) WithLockTimeout

func (m *Mutex) WithLockTimeout(d time.Duration) *Mutex

func (*Mutex) WithWaitTimeout

func (m *Mutex) WithWaitTimeout(d time.Duration) *Mutex

type NonBlockingLocker

type NonBlockingLocker interface {
	TryLock() (bool, error)
	Unlock() error
}

type NonBlockingMutex

type NonBlockingMutex struct {
	Key string
	// contains filtered or unexported fields
}

func NewNonBlockingMutex

func NewNonBlockingMutex(ctx context.Context, client *redis.Client, keySuffix string) *NonBlockingMutex

func (*NonBlockingMutex) TryLock

func (m *NonBlockingMutex) TryLock() (bool, error)

func (*NonBlockingMutex) Unlock

func (m *NonBlockingMutex) Unlock() error

func (*NonBlockingMutex) WithLockTimeout

func (m *NonBlockingMutex) WithLockTimeout(d time.Duration) *NonBlockingMutex