sync

type BucketFunc func(Key) BucketKey

type BucketKey = string

type ChainThrottler []Throttler

type GetSyncLimit func(string) (int, error)

type IsWorkflowDeleted func(string) bool

type Key = string

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 QueueFunc func(Key)

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

type Throttler interface {
	Init(wfs []wfv1.Workflow) 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)
}