Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for currentNode (0.11 sec)

  1. pkg/proxy/nftables/proxier.go

    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",
    			"eventNode", node.Name, "currentNode", proxier.hostname)
    		return
    	}
    
    	if reflect.DeepEqual(proxier.nodeLabels, node.Labels) {
    		return
    	}
    
    	proxier.mu.Lock()
    	proxier.nodeLabels = map[string]string{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  2. pkg/proxy/iptables/proxier.go

    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",
    			"eventNode", node.Name, "currentNode", proxier.hostname)
    		return
    	}
    
    	if reflect.DeepEqual(proxier.nodeLabels, node.Labels) {
    		return
    	}
    
    	proxier.mu.Lock()
    	proxier.nodeLabels = map[string]string{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  3. pkg/proxy/ipvs/proxier.go

    // 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", "eventNode", node.Name, "currentNode", proxier.hostname)
    		return
    	}
    
    	if reflect.DeepEqual(proxier.nodeLabels, node.Labels) {
    		return
    	}
    
    	proxier.mu.Lock()
    	proxier.nodeLabels = map[string]string{}
    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