Documentation ¶
Index ¶
- type AcquireContainerLockEntry
- type AcquireParam
- type Acquirer
- type ContainerLock
- type ContainerUseParam
- type Control
- type KeyedLock
- type Locker
- func (l *Locker) AcquireContainerLock(ctx context.Context, entries map[string]*AcquireContainerLockEntry) (func(), error)
- func (l *Locker) LockForBuild(ctx context.Context, image string) (func(), error)
- func (l *Locker) LockForContainerSetup(ctx context.Context, name string) (func(), error)
- func (l *Locker) LockForNamespace() func()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AcquireContainerLockEntry ¶ added in v1.2.0
type AcquireContainerLockEntry struct { Exclusive bool Init bool // contains filtered or unexported fields }
func (*AcquireContainerLockEntry) ContainerLock ¶ added in v1.2.0
func (p *AcquireContainerLockEntry) ContainerLock() *ContainerLock
type AcquireParam ¶ added in v1.2.0
type Acquirer ¶ added in v1.2.0
type Acquirer struct {
// contains filtered or unexported fields
}
func NewAcquirer ¶ added in v1.2.0
func NewAcquirer() *Acquirer
func (*Acquirer) Release ¶ added in v1.2.0
func (a *Acquirer) Release(params map[string]AcquireParam)
type ContainerLock ¶
type ContainerLock struct {
// contains filtered or unexported fields
}
func (*ContainerLock) InitAcquired ¶
func (l *ContainerLock) InitAcquired() bool
func (*ContainerLock) Release ¶
func (l *ContainerLock) Release()
func (*ContainerLock) SetInitResult ¶
func (l *ContainerLock) SetInitResult(ok bool)
type ContainerUseParam ¶ added in v1.2.0
type Control ¶
type Control interface { LockForNamespace(ctx context.Context) (func(), error) LockForBuild(ctx context.Context, image string) (func(), error) LockForContainerSetup(ctx context.Context, name string) (func(), error) LockForContainerUse(ctx context.Context, params map[string]ContainerUseParam) (unlock func(), err error) }
func NewBeaconControl ¶
func NewBeaconControl(cli proto.BeaconServiceClient) Control
func NewControl ¶
func NewControl() Control
type KeyedLock ¶
type KeyedLock struct {
// contains filtered or unexported fields
}
func NewKeyedLock ¶
func NewKeyedLock() *KeyedLock
type Locker ¶
type Locker struct {
// contains filtered or unexported fields
}
func (*Locker) AcquireContainerLock ¶
func (*Locker) LockForBuild ¶
func (*Locker) LockForContainerSetup ¶
func (*Locker) LockForNamespace ¶
func (l *Locker) LockForNamespace() func()
Click to show internal directories.
Click to hide internal directories.