- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 728 for mynodename (0.15 sec)
-
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
// waitForAttachTimeout is the maximum amount of time a // operationexecutor.Mount call will wait for a volume to be attached. waitForAttachTimeout = 1 * time.Second nodeName = k8stypes.NodeName("mynodename") kubeletPodsDir = "fake-dir" testOperationBackOffDuration = 100 * time.Millisecond reconcilerSyncWaitDuration = 10 * time.Second ) func hasAddedPods() bool { return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
} } } pods, err := adc.podLister.List(labels.Everything()) if err != nil { t.Fatalf("Run failed with error. Expected: <no error> Actual: %v", err) } for _, pod := range pods { uniqueName := fmt.Sprintf("%s/%s", controllervolumetesting.TestPluginName, pod.Spec.Volumes[0].Name) nodeName := types.NodeName(pod.Spec.NodeName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/actual_state_of_world.go
return err } func (asw *actualStateOfWorld) MarkVolumeAsDetached( volumeName v1.UniqueVolumeName, nodeName types.NodeName) { asw.DeleteVolumeNode(volumeName, nodeName) } func (asw *actualStateOfWorld) RemoveVolumeFromReportAsAttached( volumeName v1.UniqueVolumeName, nodeName types.NodeName) error { asw.Lock() defer asw.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 07:35:17 UTC 2024 - 28.7K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/node_authorizer.go
case resourceClaimResource: return r.authorizeGet(nodeName, resourceClaimVertexType, attrs) case vaResource: return r.authorizeGet(nodeName, vaVertexType, attrs) case svcAcctResource: return r.authorizeCreateToken(nodeName, serviceAccountVertexType, attrs) case leaseResource: return r.authorizeLease(nodeName, attrs) case csiNodeResource: return r.authorizeCSINode(nodeName, attrs)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 16K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/actual_state_of_world_test.go
volumeName := v1.UniqueVolumeName("volume-name") nodeName := types.NodeName("node-name") // Act asw.DeleteVolumeNode(volumeName, nodeName) // Assert volumeNodeComboState := asw.GetAttachState(volumeName, nodeName) if volumeNodeComboState != AttachStateDetached { t.Fatalf("%q/%q volume/node combo is marked %q, expected 'Detached'.", volumeName, nodeName, volumeNodeComboState) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 07:35:17 UTC 2024 - 66.1K bytes - Viewed (0) -
pkg/registry/discovery/endpointslice/strategy_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 27.3K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go
dsw := NewDesiredStateOfWorld(volumePluginMgr) nodeName := k8stypes.NodeName("node-name") // Act dsw.AddNode(nodeName) // Assert nodeExists := dsw.NodeExists(nodeName) if !nodeExists { t.Fatalf("Added node %q does not exist, it should.", nodeName) } // Act dsw.AddNode(nodeName) // Assert nodeExists = dsw.NodeExists(nodeName) if !nodeExists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 35.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world.go
// pod object contains the api object of pod podObj *v1.Pod } func (dsw *desiredStateOfWorld) AddNode(nodeName k8stypes.NodeName) { dsw.Lock() defer dsw.Unlock() if _, nodeExists := dsw.nodesManaged[nodeName]; !nodeExists { dsw.nodesManaged[nodeName] = nodeManaged{ nodeName: nodeName, volumesToAttach: make(map[v1.UniqueVolumeName]volumeToAttach), } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator_test.go
dswp.desiredStateOfWorld.AddNode(k8stypes.NodeName(pod.Spec.NodeName)) logger, _ := ktesting.NewTestContext(t) dswp.findAndAddActivePods(logger) expectedVolumeName := v1.UniqueVolumeName(generatedVolumeName) //check if the given volume referenced by the pod is added to dsw volumeExists := dswp.desiredStateOfWorld.VolumeExists(expectedVolumeName, k8stypes.NodeName(pod.Spec.NodeName)) if !volumeExists { t.Fatalf(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 7.3K bytes - Viewed (0) -
cmd/kubeadm/app/util/config/cluster_test.go
name string nodeName string staticPod *testresources.FakeStaticPod expectedEndpoint *kubeadmapi.APIEndpoint expectedErr bool }{ { name: "no pod annotations", nodeName: nodeName, expectedErr: true, }, { name: "valid ipv4 endpoint in pod annotation", nodeName: nodeName, staticPod: &testresources.FakeStaticPod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 26.7K bytes - Viewed (0)