testing

Documentation

Index

• type FakeResourceTracker
  • func CreateFakeResourceTracker[TObj kubernetes.Object](known []TObj, indexed map[ResourceTrackerIndexKey][]TObj) *FakeResourceTracker[TObj]
  • func (f *FakeResourceTracker[TObj]) KnownResources() ([]TObj, error)
  • func (f *FakeResourceTracker[TObj]) KnownResourcesByIndex(indexName string, indexValue string) ([]TObj, error)
  • func (f *FakeResourceTracker[TObj]) PublishAbnormalDeleteResource(res TObj, rawRes interface{}, resKey string)
  • func (f *FakeResourceTracker[TObj]) PublishAddResource(res TObj)
  • func (f *FakeResourceTracker[TObj]) PublishDeleteResource(res TObj)
  • func (f *FakeResourceTracker[TObj]) PublishUpdateResource(old, new TObj)
  • func (f *FakeResourceTracker[TObj]) RegisterAddedPodHandler(client chan TObj)
  • func (f *FakeResourceTracker[TObj]) RegisterDeletedPodHandler(objs chan resourceTracker.TrackerDeleteResource[TObj])
  • func (f *FakeResourceTracker[TObj]) RegisterUpdatedPodHandler(objs chan struct{ Old, New TObj })
  • func (f *FakeResourceTracker[TObj]) UnregisterAddedPodHandler(objs chan TObj)
  • func (f *FakeResourceTracker[TObj]) UnregisterDeletedPodHandler(objs chan resourceTracker.TrackerDeleteResource[TObj])
  • func (f *FakeResourceTracker[TObj]) UnregisterUpdatedPodHandler(objs chan struct{ Old, New TObj })
• type ResourceTrackerIndexKey

Types

type FakeResourceTracker

type FakeResourceTracker[TObj kubernetes.Object] struct {
	sync.RWMutex

	Resources        []TObj
	IndexedResources map[ResourceTrackerIndexKey][]TObj

	AddedResourceHandlerClients   map[chan TObj]bool
	DeletedResourceHandlerClients map[chan resourceTracker.TrackerDeleteResource[TObj]]bool
	UpdatedResourceHandlerClients map[chan struct{ Old, New TObj }]bool
}

func CreateFakeResourceTracker

func CreateFakeResourceTracker[TObj kubernetes.Object](known []TObj, indexed map[ResourceTrackerIndexKey][]TObj) *FakeResourceTracker[TObj]

func (*FakeResourceTracker[TObj]) KnownResources

func (f *FakeResourceTracker[TObj]) KnownResources() ([]TObj, error)

func (*FakeResourceTracker[TObj]) KnownResourcesByIndex

func (f *FakeResourceTracker[TObj]) KnownResourcesByIndex(indexName string, indexValue string) ([]TObj, error)

func (*FakeResourceTracker[TObj]) PublishAbnormalDeleteResource

func (f *FakeResourceTracker[TObj]) PublishAbnormalDeleteResource(res TObj, rawRes interface{}, resKey string)

func (*FakeResourceTracker[TObj]) PublishAddResource

func (f *FakeResourceTracker[TObj]) PublishAddResource(res TObj)

func (*FakeResourceTracker[TObj]) PublishDeleteResource

func (f *FakeResourceTracker[TObj]) PublishDeleteResource(res TObj)

func (*FakeResourceTracker[TObj]) PublishUpdateResource

func (f *FakeResourceTracker[TObj]) PublishUpdateResource(old, new TObj)

func (*FakeResourceTracker[TObj]) RegisterAddedPodHandler

func (f *FakeResourceTracker[TObj]) RegisterAddedPodHandler(client chan TObj)

func (*FakeResourceTracker[TObj]) RegisterDeletedPodHandler

func (f *FakeResourceTracker[TObj]) RegisterDeletedPodHandler(objs chan resourceTracker.TrackerDeleteResource[TObj])

func (*FakeResourceTracker[TObj]) RegisterUpdatedPodHandler

func (f *FakeResourceTracker[TObj]) RegisterUpdatedPodHandler(objs chan struct{ Old, New TObj })

func (*FakeResourceTracker[TObj]) UnregisterAddedPodHandler

func (f *FakeResourceTracker[TObj]) UnregisterAddedPodHandler(objs chan TObj)

func (*FakeResourceTracker[TObj]) UnregisterDeletedPodHandler

func (f *FakeResourceTracker[TObj]) UnregisterDeletedPodHandler(objs chan resourceTracker.TrackerDeleteResource[TObj])

func (*FakeResourceTracker[TObj]) UnregisterUpdatedPodHandler

func (f *FakeResourceTracker[TObj]) UnregisterUpdatedPodHandler(objs chan struct{ Old, New TObj })

type ResourceTrackerIndexKey

type ResourceTrackerIndexKey struct {
	IndexName, IndexValue string
}