lock

Documentation

Index

• Constants
• Variables
• type Lock
• type LockDB
• type LockFactory
  • func NewLockFactory(conn *sql.DB) LockFactory
  • func NewTestLockFactory(db LockDB) LockFactory
• type LockID
  • func NewBuildTrackingLockID(buildID int) LockID
  • func NewContainerCreatingLockID(containerID int) LockID
  • func NewPipelineSchedulingLockLockID(pipelineID int) LockID
  • func NewResourceConfigCheckingLockID(resourceConfigID int) LockID
  • func NewTaskLockID(taskName string) LockID
  • func NewVolumeCreatingLockID(volumeID int) LockID

Constants

const (
	LockTypeResourceConfigChecking = iota
	LockTypeBuildTracking
	LockTypePipelineScheduling
	LockTypeBatch
	LockTypeVolumeCreating
	LockTypeContainerCreating
)

Variables

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

Types

type Lock

type Lock interface {
	Acquire() (bool, error)
	Release() error
}

type LockDB

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

type LockFactory

type LockFactory interface {
	NewLock(logger lager.Logger, ids LockID) Lock
}

func NewLockFactory

func NewLockFactory(conn *sql.DB) LockFactory

func NewTestLockFactory

func NewTestLockFactory(db LockDB) LockFactory

type LockID

type LockID []int

func NewBuildTrackingLockID

func NewBuildTrackingLockID(buildID int) LockID

func NewContainerCreatingLockID

func NewContainerCreatingLockID(containerID int) LockID

func NewPipelineSchedulingLockLockID

func NewPipelineSchedulingLockLockID(pipelineID int) LockID

func NewResourceConfigCheckingLockID

func NewResourceConfigCheckingLockID(resourceConfigID int) LockID

func NewTaskLockID

func NewTaskLockID(taskName string) LockID

func NewVolumeCreatingLockID

func NewVolumeCreatingLockID(volumeID int) LockID