fake

Documentation

Index

• type FakeFederatedInformerManager
  • func (f *FakeFederatedInformerManager) AddClusterEventHandlers(handlers ...*informermanager.ClusterEventHandler) error
  • func (f *FakeFederatedInformerManager) AddEventHandlerGenerator(generator *informermanager.EventHandlerGenerator) error
  • func (f *FakeFederatedInformerManager) AddPodEventHandler(handler *informermanager.ResourceEventHandlerWithClusterFuncs)
  • func (f *FakeFederatedInformerManager) AddResourceEventHandler(gvr schema.GroupVersionResource, ...)
  • func (f *FakeFederatedInformerManager) GetClusterDynamicClient(cluster string) (client dynamic.Interface, exists bool)
  • func (f *FakeFederatedInformerManager) GetClusterKubeClient(cluster string) (client kubernetes.Interface, exists bool)
  • func (f *FakeFederatedInformerManager) GetClusterRestConfig(cluster string) (config *rest.Config, exists bool)
  • func (f *FakeFederatedInformerManager) GetFederatedClusterLister() fedcorev1a1listers.FederatedClusterLister
  • func (f *FakeFederatedInformerManager) GetFederatedTypeConfigLister() fedcorev1a1listers.FederatedTypeConfigLister
  • func (f *FakeFederatedInformerManager) GetJoinedClusters() ([]*fedcorev1a1.FederatedCluster, error)
  • func (f *FakeFederatedInformerManager) GetNodeLister(cluster string) (lister corev1listers.NodeLister, informerSynced cache.InformerSynced, ...)
  • func (f *FakeFederatedInformerManager) GetPodLister(cluster string) (lister corev1listers.PodLister, informerSynced cache.InformerSynced, ...)
  • func (f *FakeFederatedInformerManager) GetReadyClusters() ([]*fedcorev1a1.FederatedCluster, error)
  • func (f *FakeFederatedInformerManager) GetResourceLister(gvk schema.GroupVersionKind, cluster string) (lister cache.GenericLister, informerSynced cache.InformerSynced, exists bool)
  • func (f *FakeFederatedInformerManager) GetResourceListerFromFactory(gvr schema.GroupVersionResource, cluster string) (lister interface{}, informerSynced cache.InformerSynced, exists bool)
  • func (f *FakeFederatedInformerManager) HasSynced() bool
  • func (f *FakeFederatedInformerManager) IsShutdown() bool
  • func (f *FakeFederatedInformerManager) Start(ctx context.Context)
• type FakeLister

Types

type FakeFederatedInformerManager

type FakeFederatedInformerManager struct {
	HasSync  bool
	Shutdown bool

	ReadyClusters              []*fedcorev1a1.FederatedCluster
	ReadyClusterDynamicClients map[string]dynamic.Interface
	NodeListers                map[string]FakeLister
	PodListers                 map[string]FakeLister
}

FakeFederatedInformerManager implements informermanager.FederatedInformerManager and should only be used in tests

func (*FakeFederatedInformerManager) AddClusterEventHandlers

func (f *FakeFederatedInformerManager) AddClusterEventHandlers(handlers ...*informermanager.ClusterEventHandler) error

func (*FakeFederatedInformerManager) AddEventHandlerGenerator

func (f *FakeFederatedInformerManager) AddEventHandlerGenerator(generator *informermanager.EventHandlerGenerator) error

func (*FakeFederatedInformerManager) AddPodEventHandler

func (f *FakeFederatedInformerManager) AddPodEventHandler(handler *informermanager.ResourceEventHandlerWithClusterFuncs)

func (*FakeFederatedInformerManager) AddResourceEventHandler

func (f *FakeFederatedInformerManager) AddResourceEventHandler(
	gvr schema.GroupVersionResource,
	handler *informermanager.FilteringResourceEventHandlerWithClusterFuncs,
)

func (*FakeFederatedInformerManager) GetClusterDynamicClient

func (f *FakeFederatedInformerManager) GetClusterDynamicClient(cluster string) (client dynamic.Interface, exists bool)

func (*FakeFederatedInformerManager) GetClusterKubeClient

func (f *FakeFederatedInformerManager) GetClusterKubeClient(cluster string) (client kubernetes.Interface, exists bool)

func (*FakeFederatedInformerManager) GetClusterRestConfig

func (f *FakeFederatedInformerManager) GetClusterRestConfig(cluster string) (config *rest.Config, exists bool)

func (*FakeFederatedInformerManager) GetFederatedClusterLister

func (f *FakeFederatedInformerManager) GetFederatedClusterLister() fedcorev1a1listers.FederatedClusterLister

func (*FakeFederatedInformerManager) GetFederatedTypeConfigLister

func (f *FakeFederatedInformerManager) GetFederatedTypeConfigLister() fedcorev1a1listers.FederatedTypeConfigLister

func (*FakeFederatedInformerManager) GetJoinedClusters

func (f *FakeFederatedInformerManager) GetJoinedClusters() ([]*fedcorev1a1.FederatedCluster, error)

func (*FakeFederatedInformerManager) GetNodeLister

func (f *FakeFederatedInformerManager) GetNodeLister(
	cluster string,
) (lister corev1listers.NodeLister, informerSynced cache.InformerSynced, exists bool)

func (*FakeFederatedInformerManager) GetPodLister

func (f *FakeFederatedInformerManager) GetPodLister(
	cluster string,
) (lister corev1listers.PodLister, informerSynced cache.InformerSynced, exists bool)

func (*FakeFederatedInformerManager) GetReadyClusters

func (f *FakeFederatedInformerManager) GetReadyClusters() ([]*fedcorev1a1.FederatedCluster, error)

func (*FakeFederatedInformerManager) GetResourceLister

func (f *FakeFederatedInformerManager) GetResourceLister(
	gvk schema.GroupVersionKind,
	cluster string,
) (lister cache.GenericLister, informerSynced cache.InformerSynced, exists bool)

func (*FakeFederatedInformerManager) GetResourceListerFromFactory

func (f *FakeFederatedInformerManager) GetResourceListerFromFactory(
	gvr schema.GroupVersionResource, cluster string,
) (lister interface{}, informerSynced cache.InformerSynced, exists bool)

func (*FakeFederatedInformerManager) HasSynced

func (f *FakeFederatedInformerManager) HasSynced() bool

func (*FakeFederatedInformerManager) IsShutdown

func (f *FakeFederatedInformerManager) IsShutdown() bool

func (*FakeFederatedInformerManager) Start

func (f *FakeFederatedInformerManager) Start(ctx context.Context)

type FakeLister

type FakeLister struct {
	PodLister  corev1listers.PodLister
	NodeLister corev1listers.NodeLister
	Synced     bool
}