lock

Documentation

Index

• Variables
• type LocalLock
  • func (l *LocalLock) Lock(ctx context.Context) error
  • func (l *LocalLock) TryLock(ctx context.Context) error
  • func (l *LocalLock) Unlock() error
• type LocalLockFactory
  • func NewLocalLockFactory(ll *LocalLocks) *LocalLockFactory
  • func (l *LocalLockFactory) NewLock(key string) Lock
• type LocalLocks
  • func NewLocalLocks() *LocalLocks
• type Lock
• type LockFactory
• type PGLock
  • func NewPGLock(db *sql.DB, key string) *PGLock
  • func (l *PGLock) Lock(ctx context.Context) error
  • func (l *PGLock) TryLock(ctx context.Context) error
  • func (l *PGLock) Unlock() error
• type PGLockFactory
  • func NewPGLockFactory(db *sql.DB) *PGLockFactory
  • func (l *PGLockFactory) NewLock(key string) Lock

Variables

var ErrLocked = errors.New("already locked")

Types

type LocalLock

type LocalLock struct {
	// contains filtered or unexported fields
}

func (*LocalLock) Lock

func (l *LocalLock) Lock(ctx context.Context) error

func (*LocalLock) TryLock

func (l *LocalLock) TryLock(ctx context.Context) error

func (*LocalLock) Unlock

func (l *LocalLock) Unlock() error

type LocalLockFactory

type LocalLockFactory struct {
	// contains filtered or unexported fields
}

func NewLocalLockFactory

func NewLocalLockFactory(ll *LocalLocks) *LocalLockFactory

func (*LocalLockFactory) NewLock

func (l *LocalLockFactory) NewLock(key string) Lock

type LocalLocks

type LocalLocks struct {
	// contains filtered or unexported fields
}

func NewLocalLocks

func NewLocalLocks() *LocalLocks

type Lock

type Lock interface {
	Lock(ctx context.Context) error
	TryLock(ctx context.Context) error
	Unlock() error
}

type LockFactory

type LockFactory interface {
	NewLock(key string) Lock
}

type PGLock

type PGLock struct {
	// contains filtered or unexported fields
}

func NewPGLock

func NewPGLock(db *sql.DB, key string) *PGLock

func (*PGLock) Lock

func (l *PGLock) Lock(ctx context.Context) error

func (*PGLock) TryLock

func (l *PGLock) TryLock(ctx context.Context) error

func (*PGLock) Unlock

func (l *PGLock) Unlock() error

type PGLockFactory

type PGLockFactory struct {
	// contains filtered or unexported fields
}

func NewPGLockFactory

func NewPGLockFactory(db *sql.DB) *PGLockFactory

func (*PGLockFactory) NewLock

func (l *PGLockFactory) NewLock(key string) Lock