resourceupdatev2

Documentation

Overview

package: resourceupdatev2 Path: cmd/agent/services/resourceupdatev2/resourceupdate.go

Index

• Variables
• func InitHashList() (*apicontractsv2resources.HashList, error)
• func InitHashListv2() (*apicontractsv2resources.HashList, error)
• func SendResource(action rortypes.ResourceAction, input *unstructured.Unstructured)
• type ResourceCacheWorkQueue
  • 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) SetRetrycount(uid string, count int)

Variables

var ResourceCache resourcecache

Functions

func InitHashList

func InitHashList() (*apicontractsv2resources.HashList, error)

func InitHashListv2

func InitHashListv2() (*apicontractsv2resources.HashList, error)

func SendResource

func SendResource(action rortypes.ResourceAction, input *unstructured.Unstructured)

Types

type ResourceCacheWorkQueue

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

func NewResourceCacheWorkQueue

func NewResourceCacheWorkQueue() ResourceCacheWorkQueue

func (*ResourceCacheWorkQueue) AddResource

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

func (*ResourceCacheWorkQueue) AddResourceSet

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

func (*ResourceCacheWorkQueue) ConsumeWorkQeue

func (wq *ResourceCacheWorkQueue) ConsumeWorkQeue() *ResourceCacheWorkQueue

func (*ResourceCacheWorkQueue) DeepCopy

func (wq *ResourceCacheWorkQueue) DeepCopy() *ResourceCacheWorkQueue

func (*ResourceCacheWorkQueue) DeleteByUid

func (wq *ResourceCacheWorkQueue) DeleteByUid(uid string)

func (*ResourceCacheWorkQueue) GetQuedResourceByUid

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

func (*ResourceCacheWorkQueue) GetRetrycount

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

func (*ResourceCacheWorkQueue) ItemCount

func (wq *ResourceCacheWorkQueue) ItemCount() int

func (*ResourceCacheWorkQueue) NeedToRun

func (wq *ResourceCacheWorkQueue) NeedToRun() bool

func (*ResourceCacheWorkQueue) SetRetrycount

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