lock

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

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 interface {
	Acquire() (bool, error)
	Release() error
	AfterRelease(func() error)
}

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

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

type LockID []int

type PgxConnector struct {
	PgxConfig pgx.ConnConfig
}

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