- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 176 for newobj (0.2 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/versioncheck.go
} // Update implements Manager. func (f *versionCheckManager) Update(liveObj, newObj runtime.Object, managed Managed, manager string) (runtime.Object, Managed, error) { // Nothing to do for updates, this is checked in many other places. return f.fieldManager.Update(liveObj, newObj, managed, manager) } // Apply implements Manager.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 16 20:03:48 UTC 2023 - 1.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 2K bytes - Viewed (0) -
pkg/scheduler/eventhandlers_test.go
name string oldObj interface{} newObj interface{} }{ { name: "pod updated with the same UID", oldObj: withPodName(podWithPort("oldUID", nodeName, 80), "pod"), newObj: withPodName(podWithPort("oldUID", nodeName, 8080), "pod"), }, { name: "pod updated with different UIDs", oldObj: withPodName(podWithPort("oldUID", nodeName, 80), "pod"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 10 14:38:54 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeaffinity/node_affinity_test.go
args *config.NodeAffinityArgs pod *v1.Pod oldObj, newObj interface{} expectedHint framework.QueueingHint expectedErr bool }{ "backoff-wrong-new-object": { args: &config.NodeAffinityArgs{}, pod: podWithNodeAffinity.Obj(), newObj: "not-a-node", expectedHint: framework.Queue, expectedErr: true, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Dec 18 12:00:10 UTC 2023 - 38.7K bytes - Viewed (0) -
pkg/kube/kclient/index.go
addObj(obj) idx.mu.Unlock() if delegate != nil { delegate.OnAdd(obj, initialList) } }, UpdateFunc: func(oldObj, newObj any) { idx.mu.Lock() deleteObj(oldObj) addObj(newObj) idx.mu.Unlock() if delegate != nil { delegate.OnUpdate(oldObj, newObj) } }, DeleteFunc: func(obj any) { idx.mu.Lock() deleteObj(obj) idx.mu.Unlock() if delegate != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 04 03:49:30 UTC 2023 - 3.5K bytes - Viewed (0) -
pkg/controller/ttl/ttl_controller.go
} }() ttlc.enqueueNode(logger, node) } func (ttlc *Controller) updateNode(logger klog.Logger, _, newObj interface{}) { node, ok := newObj.(*v1.Node) if !ok { utilruntime.HandleError(fmt.Errorf("unexpected object type: %v", newObj)) return } // Processing all updates of nodes guarantees that we will update // the ttl annotation, when cluster size changes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/scheduler/util/utils.go
// object stored in it will be converted instead. func As[T any](oldObj, newobj interface{}) (T, T, error) { var oldTyped T var newTyped T var ok bool if newobj != nil { newTyped, ok = newobj.(T) if !ok { return oldTyped, newTyped, fmt.Errorf("expected %T, but got %T", newTyped, newobj) } } if oldObj != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 6.2K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/storageversionmigrator.go
} _, _ = svmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { svmController.addSVM(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { svmController.updateSVM(logger, oldObj, newObj) }, }) return svmController } func (svmc *SVMController) Name() string { return svmc.controllerName }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/fit_test.go
if tc.expectedErr { require.Error(t, err) return } require.NoError(t, err) require.Equal(t, tc.expectedHint, actualHint) }) } } func Test_isSchedulableAfterNodeChange(t *testing.T) { testcases := map[string]struct { pod *v1.Pod oldObj, newObj interface{} expectedHint framework.QueueingHint
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 57.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/tainttoleration/taint_toleration.go
// pod schedulable. func (pl *TaintToleration) isSchedulableAfterNodeChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { originalNode, modifiedNode, err := util.As[*v1.Node](oldObj, newObj) if err != nil { return framework.Queue, err } wasUntolerated := true if originalNode != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 9.2K bytes - Viewed (0)