sync

Documentation

Index

• Constants
• type DatabaseLock
  • func NewDatabaseLock(logger lager.Logger) *DatabaseLock
  • func (dblock *DatabaseLock) InitDBLockRunner(retryInterval time.Duration, ttl time.Duration, owner string, lockDB db.LockDB, ...) ifrit.Runner

Constants

const (
	LockStatusHeld = iota
	LockStatusLost
)

Types

type DatabaseLock

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

func NewDatabaseLock

func NewDatabaseLock(logger lager.Logger) *DatabaseLock

func (*DatabaseLock) InitDBLockRunner

func (dblock *DatabaseLock) InitDBLockRunner(retryInterval time.Duration, ttl time.Duration, owner string, lockDB db.LockDB, callbackOnAcquiredLock func(), callbackOnLostLock func()) ifrit.Runner