Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NodeHandler (0.14 sec)

  1. pkg/controller/controller_utils_test.go

    			requestCount: 2,
    		},
    	}
    	for _, test := range tests {
    		node, _ := test.nodeHandler.Get(context.TODO(), test.nodeName, metav1.GetOptions{})
    		err := RemoveTaintOffNode(context.TODO(), test.nodeHandler, test.nodeName, node, test.taintsToRemove...)
    		assert.NoError(t, err, "%s: RemoveTaintOffNode() error = %v", test.name, err)
    
    		node, _ = test.nodeHandler.Get(context.TODO(), test.nodeName, metav1.GetOptions{})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  2. pkg/proxy/config/config.go

    	}
    	for i := range c.eventHandlers {
    		c.logger.V(4).Info("Calling handler.OnServiceDelete")
    		c.eventHandlers[i].OnServiceDelete(service)
    	}
    }
    
    // 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)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  3. pkg/controller/testutil/test_utils.go

    		if node.Name == nodes[i].Name {
    			return true
    		}
    	}
    	return false
    }
    
    // GetZones returns list of zones for all Nodes stored in FakeNodeHandler
    func GetZones(nodeHandler *FakeNodeHandler) []string {
    	nodes, _ := nodeHandler.List(context.TODO(), metav1.ListOptions{})
    	zones := sets.NewString()
    	for _, node := range nodes.Items {
    		zones.Insert(utilnode.GetZoneKey(&node))
    	}
    	return zones.List()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 15.6K bytes
    - Viewed (0)
Back to top