Documentation
¶
Index ¶
- type FakeMultiClusterInformerManager
- func (m *FakeMultiClusterInformerManager) ForCluster(_ string, _ dynamic.Interface, _ time.Duration) genericmanager.SingleClusterInformerManager
- func (m *FakeMultiClusterInformerManager) GetSingleClusterManager(clusterName string) genericmanager.SingleClusterInformerManager
- func (m *FakeMultiClusterInformerManager) IsManagerExist(_ string) bool
- func (m *FakeMultiClusterInformerManager) Start(_ string)
- func (m *FakeMultiClusterInformerManager) Stop(_ string)
- func (m *FakeMultiClusterInformerManager) WaitForCacheSync(_ string) map[schema.GroupVersionResource]bool
- func (m *FakeMultiClusterInformerManager) WaitForCacheSyncWithTimeout(_ string, _ time.Duration) map[schema.GroupVersionResource]bool
- type FakeSingleClusterManager
- func (m *FakeSingleClusterManager) Context() context.Context
- func (m *FakeSingleClusterManager) ForResource(_ schema.GroupVersionResource, _ cache.ResourceEventHandler)
- func (m *FakeSingleClusterManager) GetClient() dynamic.Interface
- func (m *FakeSingleClusterManager) IsHandlerExist(_ schema.GroupVersionResource, _ cache.ResourceEventHandler) bool
- func (m *FakeSingleClusterManager) IsInformerSynced(_ schema.GroupVersionResource) bool
- func (m *FakeSingleClusterManager) Lister(gvr schema.GroupVersionResource) cache.GenericLister
- func (m *FakeSingleClusterManager) Start()
- func (m *FakeSingleClusterManager) Stop()
- func (m *FakeSingleClusterManager) WaitForCacheSync() map[schema.GroupVersionResource]bool
- func (m *FakeSingleClusterManager) WaitForCacheSyncWithTimeout(_ time.Duration) map[schema.GroupVersionResource]bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeMultiClusterInformerManager ¶
type FakeMultiClusterInformerManager struct {
// contains filtered or unexported fields
}
FakeMultiClusterInformerManager implements MultiClusterInformerManager interface. It is used to simulate MultiClusterInformerManager for testing.
func NewFakeMultiClusterInformerManager ¶
func NewFakeMultiClusterInformerManager(managers map[string]genericmanager.SingleClusterInformerManager) *FakeMultiClusterInformerManager
NewFakeMultiClusterInformerManager creates a new FakeMultiClusterInformerManager.
func (*FakeMultiClusterInformerManager) ForCluster ¶
func (m *FakeMultiClusterInformerManager) ForCluster(_ string, _ dynamic.Interface, _ time.Duration) genericmanager.SingleClusterInformerManager
ForCluster adds a cluster event handler to the informer.
func (*FakeMultiClusterInformerManager) GetSingleClusterManager ¶
func (m *FakeMultiClusterInformerManager) GetSingleClusterManager(clusterName string) genericmanager.SingleClusterInformerManager
GetSingleClusterManager returns the single cluster manager for the given cluster name.
func (*FakeMultiClusterInformerManager) IsManagerExist ¶
func (m *FakeMultiClusterInformerManager) IsManagerExist(_ string) bool
IsManagerExist returns true if the manager exists for the given cluster name.
func (*FakeMultiClusterInformerManager) Start ¶
func (m *FakeMultiClusterInformerManager) Start(_ string)
Start starts the informer.
func (*FakeMultiClusterInformerManager) Stop ¶
func (m *FakeMultiClusterInformerManager) Stop(_ string)
Stop stops the informer.
func (*FakeMultiClusterInformerManager) WaitForCacheSync ¶
func (m *FakeMultiClusterInformerManager) WaitForCacheSync(_ string) map[schema.GroupVersionResource]bool
WaitForCacheSync waits for the cache to sync.
func (*FakeMultiClusterInformerManager) WaitForCacheSyncWithTimeout ¶
func (m *FakeMultiClusterInformerManager) WaitForCacheSyncWithTimeout(_ string, _ time.Duration) map[schema.GroupVersionResource]bool
WaitForCacheSyncWithTimeout waits for the cache to sync with a timeout.
type FakeSingleClusterManager ¶
type FakeSingleClusterManager struct {
// contains filtered or unexported fields
}
FakeSingleClusterManager implements SingleClusterInformerManager interface. It is used to simulate SingleClusterInformerManager for testing.
func NewFakeSingleClusterManager ¶
func NewFakeSingleClusterManager(synced bool, handlerExists bool, listerFunc func(gvr schema.GroupVersionResource) cache.GenericLister) *FakeSingleClusterManager
NewFakeSingleClusterManager creates a new FakeSingleClusterManager.
func (*FakeSingleClusterManager) Context ¶
func (m *FakeSingleClusterManager) Context() context.Context
Context returns the context for the informer.
func (*FakeSingleClusterManager) ForResource ¶
func (m *FakeSingleClusterManager) ForResource(_ schema.GroupVersionResource, _ cache.ResourceEventHandler)
ForResource adds a resource event handler to the informer.
func (*FakeSingleClusterManager) GetClient ¶
func (m *FakeSingleClusterManager) GetClient() dynamic.Interface
GetClient returns the client for the informer.
func (*FakeSingleClusterManager) IsHandlerExist ¶
func (m *FakeSingleClusterManager) IsHandlerExist(_ schema.GroupVersionResource, _ cache.ResourceEventHandler) bool
IsHandlerExist returns true if the handler exists for the given GVR.
func (*FakeSingleClusterManager) IsInformerSynced ¶
func (m *FakeSingleClusterManager) IsInformerSynced(_ schema.GroupVersionResource) bool
IsInformerSynced returns true if the informer is synced.
func (*FakeSingleClusterManager) Lister ¶
func (m *FakeSingleClusterManager) Lister(gvr schema.GroupVersionResource) cache.GenericLister
Lister returns the lister for the given GVR.
func (*FakeSingleClusterManager) Start ¶
func (m *FakeSingleClusterManager) Start()
Start starts the informer.
func (*FakeSingleClusterManager) Stop ¶
func (m *FakeSingleClusterManager) Stop()
Stop stops the informer.
func (*FakeSingleClusterManager) WaitForCacheSync ¶
func (m *FakeSingleClusterManager) WaitForCacheSync() map[schema.GroupVersionResource]bool
WaitForCacheSync waits for the cache to sync.
func (*FakeSingleClusterManager) WaitForCacheSyncWithTimeout ¶
func (m *FakeSingleClusterManager) WaitForCacheSyncWithTimeout(_ time.Duration) map[schema.GroupVersionResource]bool
WaitForCacheSyncWithTimeout waits for the cache to sync with a timeout.
Source Files