lock

Documentation

Index

• Constants
• Variables
• type Connector
• type DelegateConn
• type Lock
• type LockDB
• type LockFactory
  • func NewLockFactory(conn *RetryableConn) LockFactory
  • func NewTestLockFactory(db LockDB) LockFactory
• type LockID
  • func NewBuildTrackingLockID(buildID int) LockID
  • func NewContainerCreatingLockID(containerID int) LockID
  • func NewPipelineSchedulingLockLockID(pipelineID int) LockID
  • func NewResourceCheckingForJobLockID(jobID int) LockID
  • func NewResourceConfigCheckingLockID(resourceConfigID int) LockID
  • func NewResourceTypeCheckingLockID(resourceTypeID int) LockID
  • func NewTaskLockID(taskName string) LockID
  • func NewVolumeCreatingLockID(volumeID int) LockID
• type PgxConnector
  • func (c PgxConnector) Connect() (DelegateConn, error)
• type RetryableConn
  • func (c *RetryableConn) Exec(sql string, arguments ...interface{}) (pgx.CommandTag, error)
  • func (c *RetryableConn) QueryRow(sql string, args ...interface{}) *pgx.Row

Constants

const (
	LockTypeResourceConfigChecking = iota
	LockTypeResourceTypeChecking
	LockTypeBuildTracking
	LockTypePipelineScheduling
	LockTypeResourceCheckingForJob
	LockTypeBatch
	LockTypeVolumeCreating
	LockTypeContainerCreating
)

Variables

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

Types

type Connector

type Connector interface {
	Connect() (DelegateConn, error)
}

type DelegateConn

type DelegateConn interface {
	Query(sql string, args ...interface{}) (*pgx.Rows, error)
	QueryRow(sql string, args ...interface{}) *pgx.Row
	Exec(sql string, arguments ...interface{}) (commandTag pgx.CommandTag, err error)
}

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 *RetryableConn) 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 NewResourceCheckingForJobLockID

func NewResourceCheckingForJobLockID(jobID int) LockID

func NewResourceConfigCheckingLockID

func NewResourceConfigCheckingLockID(resourceConfigID int) LockID

func NewResourceTypeCheckingLockID

func NewResourceTypeCheckingLockID(resourceTypeID int) LockID

func NewTaskLockID

func NewTaskLockID(taskName string) LockID

func NewVolumeCreatingLockID

func NewVolumeCreatingLockID(volumeID int) LockID

type PgxConnector

type PgxConnector struct {
	PgxConfig pgx.ConnConfig
}

func (PgxConnector) Connect

func (c PgxConnector) Connect() (DelegateConn, error)

type RetryableConn

type RetryableConn struct {
	Connector Connector
	Conn      DelegateConn // *pgx.Conn
}

func (*RetryableConn) Exec

func (c *RetryableConn) Exec(sql string, arguments ...interface{}) (pgx.CommandTag, error)

func (*RetryableConn) QueryRow

func (c *RetryableConn) QueryRow(sql string, args ...interface{}) *pgx.Row