- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 871 for mynodename (0.14 sec)
-
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/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/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) -
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/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/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/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/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/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/volume/iscsi/attacher.go
return mounter.GetMountRefs(deviceMountPath) } func (attacher *iscsiAttacher) Attach(spec *volume.Spec, nodeName types.NodeName) (string, error) { return "", nil } func (attacher *iscsiAttacher) VolumesAreAttached(specs []*volume.Spec, nodeName types.NodeName) (map[*volume.Spec]bool, error) { volumesAttachedCheck := make(map[*volume.Spec]bool) for _, spec := range specs {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 04 08:51:31 UTC 2022 - 6.8K bytes - Viewed (0)