sync

type LockAction string

type LockName struct {
	Namespace    string
	Kind         string
	ResourceName string
	Key          string
	Type         LockType
}

type LockType string

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

type ReleaseNotifyCallbackFunc func(string)

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

type SyncLimitConfigFunc func(string) (int, error)

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

type Synchronization interface {
	// contains filtered or unexported methods
}

type Throttler interface {
	Add(key interface{}, priority int32, creationTime time.Time)
	// Next returns true if item should be processed by controller now or return false.
	Next(key interface{}) (interface{}, bool)
	// Remove notifies throttler that item processing is done. In responses the throttler triggers processing of previously throttled items.
	Remove(key interface{})
	// SetParallelism update throttler parallelism limit.
	SetParallelism(parallelism int)
}