- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 871 for mynodename (0.18 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) -
staging/src/k8s.io/apimachinery/pkg/types/nodename.go
// // To clarify the various types: // // - Node.Name is the Name field of the Node in the API. This should be stored in a NodeName. // Unfortunately, because Name is part of ObjectMeta, we can't store it as a NodeName at the API level. // // - Hostname is the hostname of the local machine (from uname -n). // However, some components allow the user to pass in a --hostname-override flag,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 2K 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/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/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/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/kubelet/cloudresource/cloud_request_manager.go
nodeAddressesErr error nodeAddresses []v1.NodeAddress nodeName types.NodeName } // NewSyncManager creates a manager responsible for collecting resources from a // cloud provider through requests that are sensitive to timeouts and hanging func NewSyncManager(cloud cloudprovider.Interface, nodeName types.NodeName, syncPeriod time.Duration) SyncManager { return &cloudResourceSyncManager{ cloud: cloud,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 05 18:29:23 UTC 2021 - 4.5K bytes - Viewed (0)