factory

package
v0.0.0-...-f30a8d1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 11, 2024 License: Apache-2.0 Imports: 90 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// Resource types used in ovnk master
	PodType                               reflect.Type = reflect.TypeOf(&kapi.Pod{})
	ServiceType                           reflect.Type = reflect.TypeOf(&kapi.Service{})
	EndpointSliceType                     reflect.Type = reflect.TypeOf(&discovery.EndpointSlice{})
	PolicyType                            reflect.Type = reflect.TypeOf(&knet.NetworkPolicy{})
	NamespaceType                         reflect.Type = reflect.TypeOf(&kapi.Namespace{})
	NodeType                              reflect.Type = reflect.TypeOf(&kapi.Node{})
	EgressFirewallType                    reflect.Type = reflect.TypeOf(&egressfirewallapi.EgressFirewall{})
	EgressIPType                          reflect.Type = reflect.TypeOf(&egressipapi.EgressIP{})
	EgressIPNamespaceType                 reflect.Type = reflect.TypeOf(&egressIPNamespace{})
	EgressIPPodType                       reflect.Type = reflect.TypeOf(&egressIPPod{})
	EgressNodeType                        reflect.Type = reflect.TypeOf(&egressNode{})
	CloudPrivateIPConfigType              reflect.Type = reflect.TypeOf(&ocpcloudnetworkapi.CloudPrivateIPConfig{})
	EgressQoSType                         reflect.Type = reflect.TypeOf(&egressqosapi.EgressQoS{})
	EgressServiceType                     reflect.Type = reflect.TypeOf(&egressserviceapi.EgressService{})
	AdminNetworkPolicyType                reflect.Type = reflect.TypeOf(&anpapi.AdminNetworkPolicy{})
	BaselineAdminNetworkPolicyType        reflect.Type = reflect.TypeOf(&anpapi.BaselineAdminNetworkPolicy{})
	AddressSetNamespaceAndPodSelectorType reflect.Type = reflect.TypeOf(&addressSetNamespaceAndPodSelector{})
	PeerNamespaceSelectorType             reflect.Type = reflect.TypeOf(&peerNamespaceSelector{})
	AddressSetPodSelectorType             reflect.Type = reflect.TypeOf(&addressSetPodSelector{})
	LocalPodSelectorType                  reflect.Type = reflect.TypeOf(&localPodSelector{})
	NetworkAttachmentDefinitionType       reflect.Type = reflect.TypeOf(&nadapi.NetworkAttachmentDefinition{})
	MultiNetworkPolicyType                reflect.Type = reflect.TypeOf(&mnpapi.MultiNetworkPolicy{})
	IPAMClaimsType                        reflect.Type = reflect.TypeOf(&ipamclaimsapi.IPAMClaim{})
	UserDefinedNetworkType                reflect.Type = reflect.TypeOf(&userdefinednetworkapi.UserDefinedNetwork{})
	ClusterUserDefinedNetworkType         reflect.Type = reflect.TypeOf(&userdefinednetworkapi.ClusterUserDefinedNetwork{})

	// Resource types used in ovnk node
	NamespaceExGwType                         reflect.Type = reflect.TypeOf(&namespaceExGw{})
	EndpointSliceForStaleConntrackRemovalType reflect.Type = reflect.TypeOf(&endpointSliceForStaleConntrackRemoval{})
	ServiceForGatewayType                     reflect.Type = reflect.TypeOf(&serviceForGateway{})
	EndpointSliceForGatewayType               reflect.Type = reflect.TypeOf(&endpointSliceForGateway{})
	ServiceForFakeNodePortWatcherType         reflect.Type = reflect.TypeOf(&serviceForFakeNodePortWatcher{}) // only for unit tests
)

Functions

func WithUpdateHandlingForObjReplace

func WithUpdateHandlingForObjReplace(funcs cache.ResourceEventHandler) cache.ResourceEventHandlerFuncs

WithUpdateHandlingForObjReplace decorates given cache.ResourceEventHandler with checking object replace case in the update event. when old and new object have different UIDs, then consider it as a replace and invoke delete handler for old object followed by add handler for new object.

Types

type AddHandlerFuncType

type AddHandlerFuncType func(namespace string, sel labels.Selector, funcs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)

type Handler

type Handler struct {
	// contains filtered or unexported fields
}

Handler represents an event handler and is private to the factory module

func (*Handler) OnAdd

func (h *Handler) OnAdd(obj interface{}, isInInitialList bool)

func (*Handler) OnDelete

func (h *Handler) OnDelete(obj interface{})

func (*Handler) OnUpdate

func (h *Handler) OnUpdate(oldObj, newObj interface{})

type NodeWatchFactory

type NodeWatchFactory interface {
	Shutdownable

	Start() error

	AddServiceHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)
	AddFilteredServiceHandler(namespace string, handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)
	RemoveServiceHandler(handler *Handler)

	AddFilteredEndpointSliceHandler(namespace string, sel labels.Selector, handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)
	RemoveEndpointSliceHandler(handler *Handler)

	AddPodHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)
	RemovePodHandler(handler *Handler)

	AddNamespaceHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)
	RemoveNamespaceHandler(handler *Handler)

	NodeInformer() cache.SharedIndexInformer
	NodeCoreInformer() coreinformers.NodeInformer
	LocalPodInformer() cache.SharedIndexInformer
	NamespaceInformer() coreinformers.NamespaceInformer
	PodCoreInformer() coreinformers.PodInformer
	APBRouteInformer() adminpolicybasedrouteinformer.AdminPolicyBasedExternalRouteInformer
	EgressIPInformer() egressipinformer.EgressIPInformer
	NADInformer() nadinformer.NetworkAttachmentDefinitionInformer
	UserDefinedNetworkInformer() userdefinednetworkinformer.UserDefinedNetworkInformer
	ClusterUserDefinedNetworkInformer() userdefinednetworkinformer.ClusterUserDefinedNetworkInformer
	RouteAdvertisementsInformer() routeadvertisementsinformer.RouteAdvertisementsInformer

	GetPods(namespace string) ([]*kapi.Pod, error)
	GetPod(namespace, name string) (*kapi.Pod, error)
	GetAllPods() ([]*kapi.Pod, error)
	GetNamespaces() ([]*kapi.Namespace, error)
	GetNode(name string) (*kapi.Node, error)
	GetNodes() ([]*kapi.Node, error)
	ListNodes(selector labels.Selector) ([]*kapi.Node, error)

	GetService(namespace, name string) (*kapi.Service, error)
	GetServices() ([]*kapi.Service, error)
	GetEndpointSlice(namespace, name string) (*discovery.EndpointSlice, error)
	GetServiceEndpointSlices(namespace, svcName, network string) ([]*discovery.EndpointSlice, error)

	GetNamespace(name string) (*kapi.Namespace, error)
}

NodeWatchFactory is an interface that ensures node components only use informers available in a node context; under the hood, it's all the same watchFactory.

If you add a new method here, make sure the underlying informer is started in factory.go NewNodeWatchFactory

type ObjectCacheInterface

type ObjectCacheInterface interface {
	GetPod(namespace, name string) (*kapi.Pod, error)
	GetAllPods() ([]*kapi.Pod, error)
	GetPods(namespace string) ([]*kapi.Pod, error)
	GetNodes() ([]*kapi.Node, error)
	GetNode(name string) (*kapi.Node, error)
	GetService(namespace, name string) (*kapi.Service, error)
	GetServiceEndpointSlices(namespace, svcName, network string) ([]*discovery.EndpointSlice, error)
	GetNamespace(name string) (*kapi.Namespace, error)
	GetNamespaces() ([]*kapi.Namespace, error)
}

ObjectCacheInterface represents the exported methods for getting kubernetes resources from the informer cache

type Shutdownable

type Shutdownable interface {
	Shutdown()
}

type WatchFactory

type WatchFactory struct {
	// contains filtered or unexported fields
}

WatchFactory initializes and manages common kube watches

func NewClusterManagerWatchFactory

func NewClusterManagerWatchFactory(ovnClientset *util.OVNClusterManagerClientset) (*WatchFactory, error)

NewClusterManagerWatchFactory initializes a watch factory with significantly fewer informers to save memory + bandwidth. It is to be used by the cluster manager only mode process.

func NewMasterWatchFactory

func NewMasterWatchFactory(ovnClientset *util.OVNMasterClientset) (*WatchFactory, error)

NewMasterWatchFactory initializes a new watch factory for: a) ovnkube controller + cluster manager or b) ovnkube controller + node c) all-in-one a.k.a ovnkube controller + cluster-manager + node processes.

func NewNodeWatchFactory

func NewNodeWatchFactory(ovnClientset *util.OVNNodeClientset, nodeName string) (*WatchFactory, error)

NewNodeWatchFactory initializes a watch factory with significantly fewer informers to save memory + bandwidth. It is to be used by the node-only process.

TODO(jtanenba) originally the pod selector was only supposed to select pods local to the node commit 91046e889... changed that and pod selector selects all pods in the cluster fix the naming of the localPodSelector or figure out how to deal with selecting all pods everywhere.

func NewOVNKubeControllerWatchFactory

func NewOVNKubeControllerWatchFactory(ovnClientset *util.OVNKubeControllerClientset) (*WatchFactory, error)

NewOVNKubeControllerWatchFactory initializes a new watch factory for the ovnkube controller process

func (*WatchFactory) ANPInformer

func (*WatchFactory) AddCloudPrivateIPConfigHandler

func (wf *WatchFactory) AddCloudPrivateIPConfigHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)

AddCloudPrivateIPConfigHandler adds a handler function that will be executed on CloudPrivateIPConfig object changes

func (*WatchFactory) AddEgressFirewallHandler

func (wf *WatchFactory) AddEgressFirewallHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)

AddEgressFirewallHandler adds a handler function that will be executed on EgressFirewall object changes

func (*WatchFactory) AddEgressIPHandler

func (wf *WatchFactory) AddEgressIPHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)

AddEgressIPHandler adds a handler function that will be executed on EgressIP object changes

func (*WatchFactory) AddFilteredEndpointSliceHandler

func (wf *WatchFactory) AddFilteredEndpointSliceHandler(namespace string, sel labels.Selector, handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)

AddFilteredEndpointSliceHandler adds a handler function that will be executed on EndpointSlice object changes

func (*WatchFactory) AddFilteredNamespaceHandler

func (wf *WatchFactory) AddFilteredNamespaceHandler(namespace string, sel labels.Selector, handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error, priority int) (*Handler, error)

AddFilteredNamespaceHandler adds a handler function that will be executed when Namespace objects that match the given filters change

func (*WatchFactory) AddFilteredNodeHandler

func (wf *WatchFactory) AddFilteredNodeHandler(sel labels.Selector, handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)

AddFilteredNodeHandler dds a handler function that will be executed when Node objects that match the given label selector

func (*WatchFactory) AddFilteredPodHandler

func (wf *WatchFactory) AddFilteredPodHandler(namespace string, sel labels.Selector, handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error, priority int) (*Handler, error)

AddFilteredPodHandler adds a handler function that will be executed when Pod objects that match the given filters change

func (*WatchFactory) AddFilteredServiceHandler

func (wf *WatchFactory) AddFilteredServiceHandler(namespace string, handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)

AddFilteredServiceHandler adds a handler function that will be executed on all Service object changes for a specific namespace

func (*WatchFactory) AddIPAMClaimsHandler

func (wf *WatchFactory) AddIPAMClaimsHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)

AddIPAMClaimsHandler adds a handler function that will be executed on AddPersistentIPsobject changes

func (*WatchFactory) AddMultiNetworkPolicyHandler

func (wf *WatchFactory) AddMultiNetworkPolicyHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)

AddMultiNetworkPolicyHandler adds a handler function that will be executed on MultiNetworkPolicy object changes

func (*WatchFactory) AddNamespaceHandler

func (wf *WatchFactory) AddNamespaceHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)

AddNamespaceHandler adds a handler function that will be executed on Namespace object changes

func (*WatchFactory) AddNetworkAttachmentDefinitionHandler

func (wf *WatchFactory) AddNetworkAttachmentDefinitionHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)

AddNetworkAttachmentDefinitionHandler adds a handler function that will be executed on NetworkAttachmentDefinition object changes

func (*WatchFactory) AddNodeHandler

func (wf *WatchFactory) AddNodeHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error, priority int) (*Handler, error)

AddNodeHandler adds a handler function that will be executed on Node object changes

func (*WatchFactory) AddPodHandler

func (wf *WatchFactory) AddPodHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)

AddPodHandler adds a handler function that will be executed on Pod object changes

func (*WatchFactory) AddPolicyHandler

func (wf *WatchFactory) AddPolicyHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)

AddPolicyHandler adds a handler function that will be executed on NetworkPolicy object changes

func (*WatchFactory) AddServiceHandler

func (wf *WatchFactory) AddServiceHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{}) error) (*Handler, error)

AddServiceHandler adds a handler function that will be executed on Service object changes

func (*WatchFactory) BANPInformer

func (*WatchFactory) CertificateSigningRequestInformer

func (wf *WatchFactory) CertificateSigningRequestInformer() certificatesinformers.CertificateSigningRequestInformer

func (*WatchFactory) ClusterUserDefinedNetworkInformer

func (wf *WatchFactory) ClusterUserDefinedNetworkInformer() userdefinednetworkinformer.ClusterUserDefinedNetworkInformer

func (*WatchFactory) DNSNameResolverInformer

func (wf *WatchFactory) DNSNameResolverInformer() ocpnetworkinformerv1alpha1.DNSNameResolverInformer

func (*WatchFactory) EgressFirewallInformer

func (wf *WatchFactory) EgressFirewallInformer() egressfirewallinformer.EgressFirewallInformer

func (*WatchFactory) EgressIPInformer

func (wf *WatchFactory) EgressIPInformer() egressipinformer.EgressIPInformer

func (*WatchFactory) EgressQoSInformer

func (wf *WatchFactory) EgressQoSInformer() egressqosinformer.EgressQoSInformer

func (*WatchFactory) EgressServiceInformer

func (wf *WatchFactory) EgressServiceInformer() egressserviceinformer.EgressServiceInformer

func (*WatchFactory) EndpointSliceCoreInformer

func (wf *WatchFactory) EndpointSliceCoreInformer() discoveryinformers.EndpointSliceInformer

func (*WatchFactory) EndpointSliceInformer

func (wf *WatchFactory) EndpointSliceInformer() cache.SharedIndexInformer

func (*WatchFactory) GetAllPods

func (wf *WatchFactory) GetAllPods() ([]*kapi.Pod, error)

GetAllPods returns all the pods in the cluster

func (*WatchFactory) GetAllPodsBySelector

func (wf *WatchFactory) GetAllPodsBySelector(labelSelector metav1.LabelSelector) ([]*kapi.Pod, error)

GetAllPodsBySelector returns all the pods in all namespace by the label selector

func (*WatchFactory) GetCloudPrivateIPConfig

func (wf *WatchFactory) GetCloudPrivateIPConfig(name string) (*ocpcloudnetworkapi.CloudPrivateIPConfig, error)

func (*WatchFactory) GetEgressFirewall

func (wf *WatchFactory) GetEgressFirewall(namespace, name string) (*egressfirewallapi.EgressFirewall, error)

func (*WatchFactory) GetEgressIP

func (wf *WatchFactory) GetEgressIP(name string) (*egressipapi.EgressIP, error)

func (*WatchFactory) GetEgressIPs

func (wf *WatchFactory) GetEgressIPs() ([]*egressipapi.EgressIP, error)

func (*WatchFactory) GetEndpointSlice

func (wf *WatchFactory) GetEndpointSlice(namespace, name string) (*discovery.EndpointSlice, error)

GetEndpointSlice returns the endpointSlice indexed by the given namespace and name

func (*WatchFactory) GetEndpointSlicesBySelector

func (wf *WatchFactory) GetEndpointSlicesBySelector(namespace string, labelSelector metav1.LabelSelector) ([]*discovery.EndpointSlice, error)

GetEndpointSlicesBySelector returns a list of EndpointSlices in a given namespace by the label selector

func (*WatchFactory) GetHandlerPriority

func (wf *WatchFactory) GetHandlerPriority(objType reflect.Type) (priority int)

GetHandlerPriority returns the priority of each objType's handler Priority of the handler is what determine which handler would get an event first This is relevant only for handlers that are sharing the same resources: Pods: shared by PodType (0), EgressIPPodType (1), AddressSetPodSelectorType (2), LocalPodSelectorType (3) Namespaces: shared by NamespaceType (0), EgressIPNamespaceType (1), PeerNamespaceSelectorType (3), AddressSetNamespaceAndPodSelectorType (4) Nodes: shared by NodeType (0), EgressNodeType (1) By default handlers get the defaultHandlerPriority which is 0 (highest priority). Higher the number, lower the priority to get an event. Example: EgressIPPodType will always get the pod event after PodType and AddressSetPodSelectorType will always get the event after PodType and EgressIPPodType NOTE: If you are touching this function to add a new object type that uses shared objects, please make sure to update `minHandlerPriority` if needed

func (*WatchFactory) GetIPAMClaim

func (wf *WatchFactory) GetIPAMClaim(namespace, name string) (*ipamclaimsapi.IPAMClaim, error)

GetIPAMClaim gets a specific IPAMClaim by the namespace/name

func (*WatchFactory) GetMultiNetworkPolicy

func (wf *WatchFactory) GetMultiNetworkPolicy(namespace, name string) (*mnpapi.MultiNetworkPolicy, error)

GetMultinetworkPolicy gets a specific multinetwork policy by the namespace/name

func (*WatchFactory) GetNAD

func (wf *WatchFactory) GetNAD(namespace, name string) (*nadapi.NetworkAttachmentDefinition, error)

GetNAD gets a specific NAD by the namespace/name

func (*WatchFactory) GetNADs

func (wf *WatchFactory) GetNADs(namespace string) ([]*nadapi.NetworkAttachmentDefinition, error)

GetNAD gets all NADs by the namespace

func (*WatchFactory) GetNamespace

func (wf *WatchFactory) GetNamespace(name string) (*kapi.Namespace, error)

GetNamespace returns a specific namespace

func (*WatchFactory) GetNamespaces

func (wf *WatchFactory) GetNamespaces() ([]*kapi.Namespace, error)

GetNamespaces returns a list of namespaces in the cluster

func (*WatchFactory) GetNamespacesBySelector

func (wf *WatchFactory) GetNamespacesBySelector(labelSelector metav1.LabelSelector) ([]*kapi.Namespace, error)

GetNamespacesBySelector returns a list of namespaces in the cluster by the label selector

func (*WatchFactory) GetNetworkPolicy

func (wf *WatchFactory) GetNetworkPolicy(namespace, name string) (*knet.NetworkPolicy, error)

GetNetworkPolicy gets a specific network policy by the namespace/name

func (*WatchFactory) GetNode

func (wf *WatchFactory) GetNode(name string) (*kapi.Node, error)

GetNode returns the node spec of a given node by name

func (*WatchFactory) GetNodes

func (wf *WatchFactory) GetNodes() ([]*kapi.Node, error)

GetNodes returns the node specs of all the nodes

func (*WatchFactory) GetNodesByLabelSelector

func (wf *WatchFactory) GetNodesByLabelSelector(labelSelector metav1.LabelSelector) ([]*kapi.Node, error)

GetNodesByLabelSelector returns all the nodes selected by the label selector

func (*WatchFactory) GetNodesBySelector

func (wf *WatchFactory) GetNodesBySelector(selector labels.Selector) ([]*kapi.Node, error)

GetNodesBySelector returns all the nodes selected by the selector

func (*WatchFactory) GetPod

func (wf *WatchFactory) GetPod(namespace, name string) (*kapi.Pod, error)

GetPod returns the pod spec given the namespace and pod name

func (*WatchFactory) GetPods

func (wf *WatchFactory) GetPods(namespace string) ([]*kapi.Pod, error)

GetPods returns all the pods in a given namespace

func (*WatchFactory) GetPodsBySelector

func (wf *WatchFactory) GetPodsBySelector(namespace string, labelSelector metav1.LabelSelector) ([]*kapi.Pod, error)

GetPodsBySelector returns all the pods in a given namespace by the label selector

func (*WatchFactory) GetResourceHandlerFunc

func (wf *WatchFactory) GetResourceHandlerFunc(objType reflect.Type) (AddHandlerFuncType, error)

func (*WatchFactory) GetService

func (wf *WatchFactory) GetService(namespace, name string) (*kapi.Service, error)

GetService returns the service spec of a service in a given namespace

func (*WatchFactory) GetServiceEndpointSlices

func (wf *WatchFactory) GetServiceEndpointSlices(namespace, svcName, network string) ([]*discovery.EndpointSlice, error)

GetServiceEndpointSlices returns the endpointSlices associated with a service for the specified network if network is DefaultNetworkName the default endpointSlices are returned, otherwise the function looks for mirror endpointslices for the specified network.

func (*WatchFactory) GetServices

func (wf *WatchFactory) GetServices() ([]*kapi.Service, error)

GetServices returns all services

func (*WatchFactory) IPAMClaimsInformer

func (wf *WatchFactory) IPAMClaimsInformer() ipamclaimsinformer.IPAMClaimInformer

func (*WatchFactory) ListNodes

func (wf *WatchFactory) ListNodes(selector labels.Selector) ([]*kapi.Node, error)

ListNodes returns nodes that match a selector

func (*WatchFactory) LocalPodInformer

func (wf *WatchFactory) LocalPodInformer() cache.SharedIndexInformer

LocalPodInformer returns a shared Informer that may or may not only return pods running on the local node.

func (*WatchFactory) NADInformer

func (*WatchFactory) NamespaceCoreInformer

func (wf *WatchFactory) NamespaceCoreInformer() v1coreinformers.NamespaceInformer

func (*WatchFactory) NamespaceInformer

func (wf *WatchFactory) NamespaceInformer() v1coreinformers.NamespaceInformer

func (*WatchFactory) NodeCoreInformer

func (wf *WatchFactory) NodeCoreInformer() v1coreinformers.NodeInformer

func (*WatchFactory) NodeInformer

func (wf *WatchFactory) NodeInformer() cache.SharedIndexInformer

func (*WatchFactory) PodCoreInformer

func (wf *WatchFactory) PodCoreInformer() v1coreinformers.PodInformer

func (*WatchFactory) PodInformer

func (wf *WatchFactory) PodInformer() cache.SharedIndexInformer

func (*WatchFactory) RemoveAdminNetworkPolicyHandler

func (wf *WatchFactory) RemoveAdminNetworkPolicyHandler(handler *Handler)

RemoveAdminNetworkPolicyHandler removes an AdminNetworkPolicy object event handler function used only in unit tests

func (*WatchFactory) RemoveBaselineAdminNetworkPolicyHandler

func (wf *WatchFactory) RemoveBaselineAdminNetworkPolicyHandler(handler *Handler)

RemoveBaselineAdminNetworkPolicyHandler removes a BaselineAdminNetworkPolicy object event handler function used only in unit tests

func (*WatchFactory) RemoveCloudPrivateIPConfigHandler

func (wf *WatchFactory) RemoveCloudPrivateIPConfigHandler(handler *Handler)

RemoveCloudPrivateIPConfigHandler removes an CloudPrivateIPConfig object event handler function

func (*WatchFactory) RemoveEgressFirewallHandler

func (wf *WatchFactory) RemoveEgressFirewallHandler(handler *Handler)

RemoveEgressFirewallHandler removes an EgressFirewall object event handler function

func (*WatchFactory) RemoveEgressIPHandler

func (wf *WatchFactory) RemoveEgressIPHandler(handler *Handler)

RemoveEgressIPHandler removes an EgressIP object event handler function

func (*WatchFactory) RemoveEgressQoSHandler

func (wf *WatchFactory) RemoveEgressQoSHandler(handler *Handler)

RemoveEgressQoSHandler removes an EgressQoS object event handler function

func (*WatchFactory) RemoveEgressServiceHandler

func (wf *WatchFactory) RemoveEgressServiceHandler(handler *Handler)

func (*WatchFactory) RemoveEndpointSliceHandler

func (wf *WatchFactory) RemoveEndpointSliceHandler(handler *Handler)

RemoveEndpointSliceHandler removes a EndpointSlice object event handler function

func (*WatchFactory) RemoveIPAMClaimsHandler

func (wf *WatchFactory) RemoveIPAMClaimsHandler(handler *Handler)

RemoveIPAMClaimsHandler removes a PersistentIPs object event handler function

func (*WatchFactory) RemoveMultiNetworkPolicyHandler

func (wf *WatchFactory) RemoveMultiNetworkPolicyHandler(handler *Handler)

RemoveMultiNetworkPolicyHandler removes an MultiNetworkPolicy object event handler function

func (*WatchFactory) RemoveNamespaceHandler

func (wf *WatchFactory) RemoveNamespaceHandler(handler *Handler)

RemoveNamespaceHandler removes a Namespace object event handler function

func (*WatchFactory) RemoveNetworkAttachmentDefinitionHandler

func (wf *WatchFactory) RemoveNetworkAttachmentDefinitionHandler(handler *Handler)

RemoveNetworkAttachmentDefinitionHandler removes an NetworkAttachmentDefinition object event handler function

func (*WatchFactory) RemoveNodeHandler

func (wf *WatchFactory) RemoveNodeHandler(handler *Handler)

RemoveNodeHandler removes a Node object event handler function

func (*WatchFactory) RemovePodHandler

func (wf *WatchFactory) RemovePodHandler(handler *Handler)

RemovePodHandler removes a Pod object event handler function

func (*WatchFactory) RemovePolicyHandler

func (wf *WatchFactory) RemovePolicyHandler(handler *Handler)

RemovePolicyHandler removes a NetworkPolicy object event handler function

func (*WatchFactory) RemoveServiceHandler

func (wf *WatchFactory) RemoveServiceHandler(handler *Handler)

RemoveServiceHandler removes a Service object event handler function

func (*WatchFactory) RouteAdvertisementsInformer

func (wf *WatchFactory) RouteAdvertisementsInformer() routeadvertisementsinformer.RouteAdvertisementsInformer

func (*WatchFactory) ServiceCoreInformer

func (wf *WatchFactory) ServiceCoreInformer() v1coreinformers.ServiceInformer

func (*WatchFactory) ServiceInformer

func (wf *WatchFactory) ServiceInformer() cache.SharedIndexInformer

func (*WatchFactory) Shutdown

func (wf *WatchFactory) Shutdown()

func (*WatchFactory) Start

func (wf *WatchFactory) Start() error

Start starts the factory and begins processing events

func (*WatchFactory) Stop

func (wf *WatchFactory) Stop()

Stop stops the factory informers, and waits for their handlers to stop

func (*WatchFactory) UserDefinedNetworkInformer

func (wf *WatchFactory) UserDefinedNetworkInformer() userdefinednetworkinformer.UserDefinedNetworkInformer

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL