lock

Documentation

Index

• Constants
• Variables
• type Lock
• type LockDB
• type LockFactory
  • func NewLockFactory(conn *sql.DB, acquire LogFunc, release LogFunc) LockFactory
  • func NewTestLockFactory(db LockDB) LockFactory
• type LockID
  • func NewActiveTasksLockID() LockID
  • func NewBuildTrackingLockID(buildID int) LockID
  • func NewDatabaseMigrationLockID() LockID
  • func NewJobSchedulingLockID(jobID int) LockID
  • func NewResourceConfigCheckingLockID(resourceConfigID int) LockID
  • func NewResourceScanningLockID() LockID
  • func NewTaskLockID(taskName string) LockID
  • func NewVolumeCreatingLockID(volumeID int) LockID
• type LogFunc

Constants

const (
	LockTypeResourceConfigChecking = iota
	LockTypeBuildTracking
	LockTypeBatch
	LockTypeVolumeCreating
	LockTypeContainerCreating
	LockTypeDatabaseMigration
	LockTypeActiveTasks
	LockTypeResourceScanning
	LockTypeJobScheduling
)

Variables

var ErrLostLock = errors.New("lock was lost while held, possibly due to connection breakage")

Types

type Lock

type Lock interface {
	Release() error
}

type LockDB

type LockDB interface {
	Acquire(id LockID) (bool, error)
	Release(id LockID) (bool, error)
}

type LockFactory

type LockFactory interface {
	Acquire(logger lager.Logger, ids LockID) (Lock, bool, error)
}

func NewLockFactory

func NewLockFactory(
	conn *sql.DB,
	acquire LogFunc,
	release LogFunc,
) LockFactory

func NewTestLockFactory

func NewTestLockFactory(db LockDB) LockFactory

type LockID

type LockID []int

func NewActiveTasksLockID

func NewActiveTasksLockID() LockID

func NewBuildTrackingLockID

func NewBuildTrackingLockID(buildID int) LockID

func NewDatabaseMigrationLockID

func NewDatabaseMigrationLockID() LockID

func NewJobSchedulingLockID

func NewJobSchedulingLockID(jobID int) LockID

func NewResourceConfigCheckingLockID

func NewResourceConfigCheckingLockID(resourceConfigID int) LockID

func NewResourceScanningLockID

func NewResourceScanningLockID() LockID

func NewTaskLockID

func NewTaskLockID(taskName string) LockID

func NewVolumeCreatingLockID

func NewVolumeCreatingLockID(volumeID int) LockID

type LogFunc

type LogFunc func(logger lager.Logger, id LockID)