Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for OnNodeAdd (0.16 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/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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top