factory

package
v0.0.0-...-361d573 Latest Latest
Warning

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

 Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 75 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{})
	EgressFwNodeType                      reflect.Type = reflect.TypeOf(&egressFwNode{})
	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{})

	// 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)

	AddEndpointSliceHandler(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
	LocalPodInformer() cache.SharedIndexInformer
	NamespaceInformer() coreinformers.NamespaceInformer
	PodCoreInformer() coreinformers.PodInformer
	APBRouteInformer() adminpolicybasedrouteinformer.AdminPolicyBasedExternalRouteInformer
	EgressIPInformer() egressipinformer.EgressIPInformer

	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)
	GetEndpointSlices(namespace, svcName string) ([]*discovery.EndpointSlice, error)
	GetEndpointSlice(namespace, name 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)
	GetEndpointSlices(namespace, svcName 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 (wf *WatchFactory) ANPInformer() anpinformer.AdminNetworkPolicyInformer

func (*WatchFactory) APBRouteInformer 

func (wf *WatchFactory) APBRouteInformer() adminpolicybasedrouteinformer.AdminPolicyBasedExternalRouteInformer

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) AddEndpointSliceHandler 

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

AddEndpointSliceHandler 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 (wf *WatchFactory) BANPInformer() anpinformer.BaselineAdminNetworkPolicyInformer

func (*WatchFactory) CertificateSigningRequestInformer 

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

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) GetEndpointSlices 

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

GetServiceEndpointSlice returns the endpointSlice associated with a service

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), EgressFwNodeType (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 multinetwork policy 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) 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) GetServices 

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

GetServices returns all services

func (*WatchFactory) IPAMClaimsInformer 

func (wf *WatchFactory) IPAMClaimsInformer() v1alpha1.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) 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) 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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.