- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 871 for mynodename (0.17 sec)
-
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) -
pkg/controller/tainteviction/taint_eviction.go
podName := "" podNamespace := "" nodeName := "" oldTolerations := []v1.Toleration{} if oldPod != nil { podName = oldPod.Name podNamespace = oldPod.Namespace nodeName = oldPod.Spec.NodeName oldTolerations = oldPod.Spec.Tolerations } newTolerations := []v1.Toleration{} if newPod != nil { podName = newPod.Name podNamespace = newPod.Namespace nodeName = newPod.Spec.NodeName
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/statusupdater/node_status_updater.go
needsUpdate, attachedVolumes := nsu.actualStateOfWorld.GetVolumesToReportAttachedForNode(logger, nodeName) if !needsUpdate { return nil } return nsu.processNodeVolumes(logger, nodeName, attachedVolumes) } func (nsu *nodeStatusUpdater) processNodeVolumes(logger klog.Logger, nodeName types.NodeName, attachedVolumes []v1.AttachedVolume) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/volume/util/nestedpendingoperations/nestedpendingoperations.go
podNameExactMatch := previousOp.key.podName == key.podName nodeNameMatch := previousOp.key.nodeName == EmptyNodeName || key.nodeName == EmptyNodeName || previousOp.key.nodeName == key.nodeName nodeNameExactMatch := previousOp.key.nodeName == key.nodeName if volumeNameMatch && podNameMatch && nodeNameMatch { // nonExactMatch pending first if previousOp.operationPending {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 12.6K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/testing/testvolumespec.go
nodeNamePrefix := "mynode" for i := 0; i < 5; i++ { var nodeName string if i != 0 { nodeName = fmt.Sprintf("%s-%d", nodeNamePrefix, i) } else { // We want also the "mynode" node since all the testing pods live there nodeName = nodeNamePrefix } csiNode := storagev1.CSINode{ ObjectMeta: metav1.ObjectMeta{ Name: nodeName, }, } obj.Items = append(obj.Items, csiNode) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 17 08:48:30 UTC 2023 - 16.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodename/node_name.go
limitations under the License. */ package nodename import ( "context" v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/runtime" "k8s.io/kubernetes/pkg/scheduler/framework" "k8s.io/kubernetes/pkg/scheduler/framework/plugins/names" ) // NodeName is a plugin that checks if a pod spec node name matches the current node. type NodeName struct{} var _ framework.FilterPlugin = &NodeName{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 20 09:49:54 UTC 2023 - 2.3K bytes - Viewed (0) -
pkg/apis/discovery/v1beta1/conversion_test.go
Zone: utilpointer.String("zone1"), }, }, { desc: "nodeName and topology[hostname] are populated with different values", external: v1beta1.Endpoint{ NodeName: utilpointer.String("node-1"), Topology: map[string]string{ corev1.LabelHostname: "node-2", }, }, internal: discovery.Endpoint{ NodeName: utilpointer.String("node-1"), DeprecatedTopology: map[string]string{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 05 10:48:05 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/interpodaffinity/scoring_test.go
pod: &v1.Pod{Spec: v1.PodSpec{NodeName: "", Affinity: stayWithS1InRegion}, ObjectMeta: metav1.ObjectMeta{Labels: podLabelSecurityS1}}, pods: []*v1.Pod{ {Spec: v1.PodSpec{NodeName: "node1"}, ObjectMeta: metav1.ObjectMeta{Labels: podLabelSecurityS1}}, {Spec: v1.PodSpec{NodeName: "node2"}, ObjectMeta: metav1.ObjectMeta{Labels: podLabelSecurityS2}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 44.8K bytes - Viewed (0) -
plugin/pkg/admission/noderestriction/admission.go
if existingPod.Spec.NodeName != nodeName { return admission.NewForbidden(a, fmt.Errorf("node %q can only delete pods with spec.nodeName set to itself", nodeName)) } return nil default: return admission.NewForbidden(a, fmt.Errorf("unexpected operation %q, node %q can only create and delete mirror pods", a.GetOperation(), nodeName)) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 23.6K bytes - Viewed (0)