resourceupdatev2

Documentation

Overview

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

Index

• Variables
• func SendResource(action apiresourcecontracts.ResourceAction, input *unstructured.Unstructured)
• type ResourceCacheWorkqueue
  • func (m *ResourceCacheWorkqueue) Add(resourceUpdate *apiresourcecontracts.ResourceUpdateModel)
  • func (m *ResourceCacheWorkqueue) DeleteByUid(uid string)
  • func (m ResourceCacheWorkqueue) GetByUid(uid string) (ResourceCacheWorkqueueObject, int)
  • func (wq ResourceCacheWorkqueue) ItemCount() int
  • func (wq ResourceCacheWorkqueue) NeedToRun() bool
• type ResourceCacheWorkqueueObject

Variables

var ResourceCache resourcecache

Functions

func SendResource

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

Types

type ResourceCacheWorkqueue

type ResourceCacheWorkqueue []ResourceCacheWorkqueueObject

func (*ResourceCacheWorkqueue) Add

func (m *ResourceCacheWorkqueue) Add(resourceUpdate *apiresourcecontracts.ResourceUpdateModel)

func (*ResourceCacheWorkqueue) DeleteByUid

func (m *ResourceCacheWorkqueue) DeleteByUid(uid string)

func (ResourceCacheWorkqueue) GetByUid

func (m ResourceCacheWorkqueue) GetByUid(uid string) (ResourceCacheWorkqueueObject, int)

func (ResourceCacheWorkqueue) ItemCount

func (wq ResourceCacheWorkqueue) ItemCount() int

func (ResourceCacheWorkqueue) NeedToRun

func (wq ResourceCacheWorkqueue) NeedToRun() bool

type ResourceCacheWorkqueueObject

type ResourceCacheWorkqueueObject struct {
	SubmittedTime  time.Time
	RetryCount     int
	ResourceUpdate *apiresourcecontracts.ResourceUpdateModel
}