- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 873 for NodeName (0.28 sec)
-
pkg/kubelet/volumemanager/reconciler/reconciler_common.go
func NewReconciler( kubeClient clientset.Interface, controllerAttachDetachEnabled bool, loopSleepDuration time.Duration, waitForAttachTimeout time.Duration, nodeName types.NodeName, desiredStateOfWorld cache.DesiredStateOfWorld, actualStateOfWorld cache.ActualStateOfWorld, populatorHasAddedPods func() bool, operationExecutor operationexecutor.OperationExecutor, mounter mount.Interface,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go
logger, _ := ktesting.NewTestContext(t) err = asw.MarkVolumeAsAttached(logger, emptyVolumeName, volumeSpec, "" /* nodeName */, devicePath) if err != nil { t.Fatalf("MarkVolumeAsAttached failed. Expected: <no error> Actual: <%v>", err) } // Act err = asw.MarkVolumeAsAttached(logger, emptyVolumeName, volumeSpec, "" /* nodeName */, devicePath) // Assert if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/metrics/metrics_test.go
nodeName := k8stypes.NodeName("node-name") dsw.AddNode(nodeName) _, err := dsw.AddPod(types.UniquePodName(podName), controllervolumetesting.NewPod(podName, podName), volumeSpec, nodeName) if err != nil { t.Fatalf("Expected no error, got %v", err) } logger, _ := ktesting.NewTestContext(t) asw.AddVolumeNode(logger, volumeName, volumeSpec, nodeName, "", true)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/registry/core/serviceaccount/storage/token.go
if nodeName := pod.Spec.NodeName; nodeName != "" { newCtx := newContext(ctx, "nodes", nodeName, "", api.SchemeGroupVersion.WithKind("Node")) // set ResourceVersion=0 to allow this to be read/served from the apiservers watch cache nodeObj, err := r.nodes.Get(newCtx, nodeName, &metav1.GetOptions{ResourceVersion: "0"}) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 05 10:24:31 UTC 2024 - 10K bytes - Viewed (0) -
cmd/kubeadm/app/phases/markcontrolplane/markcontrolplane_test.go
}, } for _, tc := range tests { t.Run(tc.name, func(t *testing.T) { nodename := "node01" controlPlaneNode := &v1.Node{ ObjectMeta: metav1.ObjectMeta{ Name: nodename, Labels: map[string]string{ v1.LabelHostname: nodename, }, }, } for _, label := range tc.existingLabels { controlPlaneNode.ObjectMeta.Labels[label] = ""
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 25 14:22:20 UTC 2022 - 5K bytes - Viewed (0) -
pkg/controller/daemon/util/daemonset_util_test.go
"k8s.io/utils/pointer" ) func newPod(podName string, nodeName string, label map[string]string) *v1.Pod { pod := &v1.Pod{ TypeMeta: metav1.TypeMeta{APIVersion: "v1"}, ObjectMeta: metav1.ObjectMeta{ Labels: label, Namespace: metav1.NamespaceDefault, }, Spec: v1.PodSpec{ NodeName: nodeName, Containers: []v1.Container{ { Image: "foo/bar", }, }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 14.5K bytes - Viewed (0) -
pkg/auth/nodeidentifier/default_test.go
expectNodeName: "foo", expectIsNode: true, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { nodeName, isNode := NewDefaultNodeIdentifier().NodeIdentity(tt.user) if nodeName != tt.expectNodeName { t.Errorf("DefaultNodeIdentifier.NodeIdentity() got = %v, want %v", nodeName, tt.expectNodeName) } if isNode != tt.expectIsNode {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 19 15:35:04 UTC 2019 - 1.9K bytes - Viewed (0) -
cmd/kubelet/app/server_bootstrap_test.go
UserAgent: "FirstClient", Host: s.URL, } config2 := &restclient.Config{ UserAgent: "SecondClient", Host: s.URL, } nodeName := types.NodeName("test") m, err := buildClientCertificateManager(config1, config2, testDir, nodeName) if err != nil { t.Fatal(err) } defer m.Stop() r := m.(rotater) // get an expired CSR (simulating historical output) server.backdate = 2 * time.Hour
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 01 05:59:41 UTC 2022 - 10.5K bytes - Viewed (0) -
pkg/registry/core/pod/strategy.go
container, err = validateContainer(container, pod) if err != nil { return nil, nil, err } nodeName := types.NodeName(pod.Spec.NodeName) if len(nodeName) == 0 { // If pod has not been assigned a host, return an empty location return nil, nil, nil } nodeInfo, err := connInfo.GetConnectionInfo(ctx, nodeName) if err != nil { return nil, nil, err } params := url.Values{} if opts.Follow {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 17:51:48 UTC 2024 - 29.8K bytes - Viewed (0) -
pkg/volume/csi/csi_block_test.go
t.Fatalf("Failed to make a new Mapper: %v", err) } pvName := pv.GetName() nodeName := string(plug.host.GetNodeName()) csiMapper.csiClient = setupClient(t, true) attachID := getAttachmentName(csiMapper.volumeID, string(csiMapper.driverName), string(nodeName)) attachment := makeTestAttachment(attachID, nodeName, pvName) attachment.Status.Attached = true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 06:07:40 UTC 2023 - 26.5K bytes - Viewed (0)