- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 131 for mynodename (0.16 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/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/scheduler/internal/cache/cache_test.go
func TestExpirePod(t *testing.T) { nodeName := "node" testPods := []*v1.Pod{ makeBasePod(t, nodeName, "test-1", "100m", "500", "", []v1.ContainerPort{{HostIP: "127.0.0.1", HostPort: 80, Protocol: "TCP"}}), makeBasePod(t, nodeName, "test-2", "200m", "1Ki", "", []v1.ContainerPort{{HostIP: "127.0.0.1", HostPort: 8080, Protocol: "TCP"}}),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 01:38:03 UTC 2023 - 63.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
volumeSpec := controllervolumetesting.GetTestVolumeSpec(string(volumeName), volumeName) nodeName := k8stypes.NodeName("node-name") dsw.AddNode(nodeName) volumeExists := dsw.VolumeExists(volumeName, nodeName) if volumeExists { t.Fatalf( "Volume %q/node %q should not exist, but it does.", volumeName, nodeName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher_test.go
wg.Add(1) go func(spec *volume.Spec, nodename string, fail bool) { defer wg.Done() attachID, err := csiAttacher.Attach(spec, types.NodeName(nodename)) if fail != (err != nil) { t.Errorf("expecting no failure, but got err: %v", err) } if attachID != "" { t.Errorf("expecting empty attachID, got %v", attachID) } }(tc.spec, tc.nodeName, tc.shouldFail)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
return nil, fields.Set{ "spec.nodeName": pod.Spec.NodeName, "metadata.name": pod.ObjectMeta.Name, "metadata.namespace": pod.ObjectMeta.Namespace, }, nil } func clusterScopedNodeNameAttrFunc(obj runtime.Object) (labels.Set, fields.Set, error) { pod := obj.(*example.Pod) return nil, fields.Set{ "spec.nodeName": pod.Spec.NodeName, "metadata.name": pod.ObjectMeta.Name, }, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
} f.runPostBindPlugin(ctx, pl, state, pod, nodeName) } } func (f *frameworkImpl) runPostBindPlugin(ctx context.Context, pl framework.PostBindPlugin, state *framework.CycleState, pod *v1.Pod, nodeName string) { if !state.ShouldRecordPluginMetrics() { pl.PostBind(ctx, state, pod, nodeName) return } startTime := time.Now() pl.PostBind(ctx, state, pod, nodeName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
if err := nc.reconcileNodeLabels(ctx, nodeName); err != nil { logger.Error(err, "Failed to reconcile labels for node, requeue it", "node", klog.KRef("", nodeName)) // TODO(yujuhong): Add nodeName back to the queue } nc.nodeUpdateQueue.Done(nodeName) } } func (nc *Controller) doNoScheduleTaintingPass(ctx context.Context, nodeName string) error { node, err := nc.nodeLister.Get(nodeName) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
if utilnet.IsIPv6String(epa.IP) != (tc.expectedEndpointFamily == ipv6) { t.Fatalf("IP: expected %s, got: %s", tc.expectedEndpointFamily, epa.IP) } if *(epa.NodeName) != pod.Spec.NodeName { t.Fatalf("NodeName: expected: %s, got: %s", pod.Spec.NodeName, *(epa.NodeName)) } if epa.TargetRef.Kind != "Pod" { t.Fatalf("TargetRef.Kind: expected: %s, got: %s", "Pod", epa.TargetRef.Kind) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
cmd/kubelet/app/server.go
func makeEventRecorder(ctx context.Context, kubeDeps *kubelet.Dependencies, nodeName types.NodeName) { if kubeDeps.Recorder != nil { return } eventBroadcaster := record.NewBroadcaster(record.WithContext(ctx)) kubeDeps.Recorder = eventBroadcaster.NewRecorder(legacyscheme.Scheme, v1.EventSource{Component: componentKubelet, Host: string(nodeName)}) eventBroadcaster.StartStructuredLogging(3) if kubeDeps.EventClient != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:34 UTC 2024 - 53.9K bytes - Viewed (0)