locker

type Interface ¶

type Interface interface {
	Lock(ctx context.Context) error
	Unlock(ctx context.Context) error
}

Interface is some form of lock implementation like achieved for in process locking using sync.Mutex.

type KubeLockLocker ¶

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

func NewKubeLockLocker(config KubeLockLockerConfig) (*KubeLockLocker, error)

func (d KubeLockLocker) Lock(ctx context.Context) error

func (d KubeLockLocker) Unlock(ctx context.Context) error

type KubeLockLockerConfig ¶

type KubeLockLockerConfig struct {
	Logger     micrologger.Logger
	RestConfig *rest.Config
}

type MutexLocker ¶

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

MutexLocker implements Interface using sync.Mutex. For now we use a shared instance of *MutexLocker for all IPAM related activity of network packages in the legacy controllers and ipam resources in the clusterapi controllers.

func NewMutexLocker(config MutexLockerConfig) (*MutexLocker, error)

func (l *MutexLocker) Lock(ctx context.Context) error

func (l *MutexLocker) Unlock(ctx context.Context) error

type MutexLockerConfig ¶

type MutexLockerConfig struct {
	Logger micrologger.Logger
}