sync

type GetSyncLimit func(string) (int, error)

type LockKind string

type LockName struct {
	Namespace    string
	ResourceName string
	Key          string
	Kind         LockKind
}

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

type NextWorkflow func(string)

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

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

type Semaphore 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)
}