sync

type BucketFunc func(Key) BucketKey

type BucketKey = string

type GetSyncLimit func(string) (int, error)

type IsSDDeleted func(string) bool

type Key = string

type LockName struct {
	Namespace string
	RepoName  string
}

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

type NextSD func(obj interface{})

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

type QueueFunc func(Key)

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

type Throttler interface {
	Init(wfs []v1alpha1.SimpleDeployment) error
	Add(key Key, priority int32, creationTime time.Time)
	// Admit returns if the item should be processed.
	Admit(key Key) bool
	// Remove notifies throttler that item processing is no longer needed
	Remove(key Key)
}