workqueue

Aug 19, 2025

Changes in this version

+ type ResourceCacheWorkQueue struct

+ RetryCount map[string]int

+ 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)

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

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