Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for OnNodeAdd (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top