- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for OnNodeAdd (0.16 sec)
-
pkg/proxy/node.go
return &NodePodCIDRHandler{ podCIDRs: podCIDRs, logger: klog.FromContext(ctx), } } var _ config.NodeHandler = &NodePodCIDRHandler{} // OnNodeAdd is a handler for Node creates. func (n *NodePodCIDRHandler) OnNodeAdd(node *v1.Node) { n.mu.Lock() defer n.mu.Unlock() podCIDRs := node.Spec.PodCIDRs // initialize podCIDRs if len(n.podCIDRs) == 0 && len(podCIDRs) > 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 3.5K bytes - Viewed (0) -
pkg/proxy/metaproxier/meta_proxier.go
proxier.ipv4Proxier.OnEndpointSlicesSynced() proxier.ipv6Proxier.OnEndpointSlicesSynced() } // OnNodeAdd is called whenever creation of new node object is observed. func (proxier *metaProxier) OnNodeAdd(node *v1.Node) { proxier.ipv4Proxier.OnNodeAdd(node) proxier.ipv6Proxier.OnNodeAdd(node) } // OnNodeUpdate is called whenever modification of an existing // node object is observed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 21 14:28:37 UTC 2024 - 5.9K bytes - Viewed (0) -
pkg/proxy/config/config.go
} } // NodeHandler is an abstract interface of objects which receive // notifications about node object changes. type NodeHandler interface { // OnNodeAdd is called whenever creation of new node object // is observed. OnNodeAdd(node *v1.Node) // OnNodeUpdate is called whenever modification of an existing // node object is observed. OnNodeUpdate(oldNode, node *v1.Node)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
pkg/proxy/node_test.go
r := recover() if r == nil && tt.expectPanic { t.Errorf("The code did not panic") } else if r != nil && !tt.expectPanic { t.Errorf("The code did panic") } }() n.OnNodeAdd(node) }) } } func TestNodePodCIDRHandlerUpdate(t *testing.T) { oldKlogOsExit := klog.OsExit defer func() { klog.OsExit = oldKlogOsExit }() klog.OsExit = customExit tests := []struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Sep 10 16:50:29 UTC 2023 - 3.5K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
proxier.mu.Unlock() // Sync unconditionally - this is called once per lifetime. proxier.syncProxyRules() } // OnNodeAdd is called whenever creation of new node object // is observed. func (proxier *Proxier) OnNodeAdd(node *v1.Node) { if node.Name != proxier.hostname { proxier.logger.Error(nil, "Received a watch event for a node that doesn't match the current node",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
proxier.mu.Unlock() // Sync unconditionally - this is called once per lifetime. proxier.syncProxyRules() } // OnNodeAdd is called whenever creation of new node object // is observed. func (proxier *Proxier) OnNodeAdd(node *v1.Node) { if node.Name != proxier.hostname { proxier.logger.Error(nil, "Received a watch event for a node that doesn't match the current node",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
proxier.mu.Unlock() // Sync unconditionally - this is called once per lifetime. proxier.syncProxyRules() } // OnNodeAdd is called whenever creation of new node object // is observed. func (proxier *Proxier) OnNodeAdd(node *v1.Node) { if node.Name != proxier.hostname {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0)