- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 728 for NodeName (0.16 sec)
-
pkg/controller/volume/attachdetach/util/util_test.go
migratedVolume = "migrated-volume-name" nonMigratedVolume = "non-migrated-volume-name" testNodeName = "test-node-name" ) var ( dirOrCreate = v1.HostPathType(v1.HostPathDirectoryOrCreate) nodeName = kubetypes.NodeName(testNodeName) hostPath = &v1.HostPathVolumeSource{ Path: socketPath, Type: &dirOrCreate, } migratedObjectReference = v1.ObjectReference{Namespace: "default", Name: "migrated-pvc"}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 12 05:42:38 UTC 2023 - 10.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpoint_builder.go
ClusterID: c.Cluster(), }, tlsMode: model.GetTLSModeFromEndpointLabels(proxy.Labels), nodeName: proxy.GetNodeName(), } var networkID network.ID if len(proxy.IPAddresses) > 0 { networkID = out.endpointNetwork(proxy.IPAddresses[0]) } out.labels = labelutil.AugmentLabels(proxy.Labels, c.Cluster(), locality, out.nodeName, networkID) return out } func (b *EndpointBuilder) buildIstioEndpoint(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4.8K bytes - Viewed (0) -
pkg/apis/resource/validation/validation_resourceslice_test.go
"k8s.io/kubernetes/pkg/apis/resource" "k8s.io/utils/ptr" ) func testResourceSlice(name, nodeName, driverName string) *resource.ResourceSlice { return &resource.ResourceSlice{ ObjectMeta: metav1.ObjectMeta{ Name: name, }, NodeName: nodeName, DriverName: driverName, ResourceModel: resource.ResourceModel{ NamedResources: &resource.NamedResourcesResources{}, }, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 14 17:07:36 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller.go
item, quit := gcc.nodeQueue.Get() if quit { return nil, true } nodeName := item if !existingNodeNames.Has(nodeName) { exists, err := gcc.checkIfNodeExists(ctx, nodeName) switch { case err != nil: klog.FromContext(ctx).Error(err, "Error while getting node", "node", klog.KRef("", nodeName)) // Node will be added back to the queue in the subsequent loop if still needed case !exists:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/controller/controller_utils_test.go
Spec: v1.PodSpec{NodeName: "foo"}, Status: v1.PodStatus{Phase: v1.PodUnknown}, }, { ObjectMeta: metav1.ObjectMeta{Name: "runningButNotReady"}, Spec: v1.PodSpec{NodeName: "foo"}, Status: v1.PodStatus{Phase: v1.PodRunning}, }, { ObjectMeta: metav1.ObjectMeta{Name: "runningNoLastTransitionTime"}, Spec: v1.PodSpec{NodeName: "foo"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 39.4K bytes - Viewed (0) -
platforms/core-configuration/file-collections/src/main/java/org/gradle/api/internal/file/AbstractFileCollection.java
new AntFileCollectionMatchingTaskBuilder(getAsFileTrees()).addToAntBuilder(builder, nodeName); } protected void addAsFileSet(Object builder, String nodeName) { new AntFileSetBuilder(getAsFileTrees()).addToAntBuilder(builder, nodeName); } protected void addAsResourceCollection(Object builder, String nodeName) { new AntFileCollectionBuilder(this).addToAntBuilder(builder, nodeName);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 23 07:32:50 UTC 2024 - 13.5K 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) -
cmd/kubeadm/app/util/apiclient/wait.go
} // getStaticPodSingleHash computes hashes for a single Static Pod resource func getStaticPodSingleHash(client clientset.Interface, nodeName string, component string) (string, error) { staticPodName := fmt.Sprintf("%s-%s", component, nodeName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/kubeadm/app/phases/etcd/local.go
func CreateLocalEtcdStaticPodManifestFile(manifestDir, patchesDir string, nodeName string, cfg *kubeadmapi.ClusterConfiguration, endpoint *kubeadmapi.APIEndpoint, isDryRun bool) error { if cfg.Etcd.External != nil { return errors.New("etcd static pod manifest cannot be generated for cluster using external etcd") } if err := prepareAndWriteEtcdStaticPod(manifestDir, patchesDir, cfg, endpoint, nodeName, []etcdutil.Member{}, isDryRun); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 14:07:27 UTC 2024 - 13.8K bytes - Viewed (1) -
cmd/kubeadm/app/phases/kubelet/flags_test.go
}, } for _, tc := range testCases { t.Run(tc.name, func(t *testing.T) { nodeName, hostname, err := GetNodeNameAndHostname(tc.opts.nodeRegOpts) if err != nil { t.Errorf("unexpected error: %v", err) } if nodeName != tc.expectedNodeName { t.Errorf("expected nodeName: %v, got %v", tc.expectedNodeName, nodeName) } if hostname != tc.expectedHostName {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 07:02:51 UTC 2024 - 4.9K bytes - Viewed (0)