lock

Documentation

Index

• Constants
• func GetLockLeaseConfig(identity string) *lease.LeaseLockConfig
• func LockConverge(ctx context.Context, getter kubernetes.KubeClientProvider, identity string) (func(bool), error)
• type InLockRunner
  • func NewInLockLocalRunner(getter kubernetes.KubeClientProvider, identity string) *InLockRunner
  • func NewInLockRunner(getter kubernetes.KubeClientProvider, identity string) *InLockRunner
  • func (r *InLockRunner) ResetLock(ctx context.Context) error
  • func (r *InLockRunner) Run(ctx context.Context, action func() error) error
  • func (r *InLockRunner) Stop()
  • func (r *InLockRunner) WithForceLock(f bool) *InLockRunner
  • func (r *InLockRunner) WithFullUnlock(f bool) *InLockRunner

Constants

const (
	AutoConvergerIdentity = "terraform-auto-converger"
)

Functions

func GetLockLeaseConfig

func GetLockLeaseConfig(identity string) *lease.LeaseLockConfig

func LockConverge

func LockConverge(ctx context.Context, getter kubernetes.KubeClientProvider, identity string) (func(bool), error)

Types

type InLockRunner

type InLockRunner struct {
	// contains filtered or unexported fields
}

func NewInLockLocalRunner

func NewInLockLocalRunner(getter kubernetes.KubeClientProvider, identity string) *InLockRunner

func NewInLockRunner

func NewInLockRunner(getter kubernetes.KubeClientProvider, identity string) *InLockRunner

func (*InLockRunner) ResetLock

func (r *InLockRunner) ResetLock(ctx context.Context) error

func (*InLockRunner) Run

func (r *InLockRunner) Run(ctx context.Context, action func() error) error

func (*InLockRunner) Stop

func (r *InLockRunner) Stop()

func (*InLockRunner) WithForceLock

func (r *InLockRunner) WithForceLock(f bool) *InLockRunner

func (*InLockRunner) WithFullUnlock

func (r *InLockRunner) WithFullUnlock(f bool) *InLockRunner