workqueue

package

v1.16.0 Latest Latest Go to latest Published: Mar 12, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ResourceCacheWorkQueue struct {
	*rorresources.ResourceSet
	RetryCount map[string]int
	// contains filtered or unexported fields
}

func NewResourceCacheWorkQueue() ResourceCacheWorkQueue

func (wq *ResourceCacheWorkQueue) AddResource(add *rorresources.Resource)

func (wq *ResourceCacheWorkQueue) AddResourceSet(add *rorresources.ResourceSet)

func (wq *ResourceCacheWorkQueue) ConsumeWorkQeue() *ResourceCacheWorkQueue

func (wq *ResourceCacheWorkQueue) DeepCopy() *ResourceCacheWorkQueue

func (wq *ResourceCacheWorkQueue) DeleteByUid(uid string)

func (wq *ResourceCacheWorkQueue) GetQuedResourceByUid(uid string) *rorresources.Resource

func (wq *ResourceCacheWorkQueue) GetRetrycount(uid string) int

func (wq *ResourceCacheWorkQueue) ItemCount() int

func (wq *ResourceCacheWorkQueue) NeedToRun() bool

func (wq *ResourceCacheWorkQueue) ReQueue(wqadd *ResourceCacheWorkQueue)

TODO use reQueueResource to add resources to the work queue

func (wq *ResourceCacheWorkQueue) ReQueueResource(resource *rorresources.Resource, retrycount int)

func (wq *ResourceCacheWorkQueue) SetRetrycount(uid string, count int)