- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 871 for mynodename (0.49 sec)
-
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) -
cmd/kubeadm/app/phases/patchnode/patchnode_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 12 15:15:45 UTC 2022 - 3.7K bytes - Viewed (0) -
pkg/volume/util/nestedpendingoperations/nestedpendingoperations_test.go
nodeName1 types.NodeName, volumeName2 v1.UniqueVolumeName, podName2 volumetypes.UniquePodName, nodeName2 types.NodeName) { // Arrange grm := NewNestedPendingOperations(false /* exponentialBackOffOnError */) operation1DoneCh := make(chan interface{}) operation1 := generateWaitFunc(operation1DoneCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 36.1K bytes - Viewed (0) -
cmd/kubeadm/app/phases/patchnode/patchnode.go
// AnnotateCRISocket annotates the node with the given crisocket func AnnotateCRISocket(client clientset.Interface, nodeName string, criSocket string) error { klog.V(1).Infof("[patchnode] Uploading the CRI Socket information %q to the Node API object %q as an annotation\n", criSocket, nodeName) return apiclient.PatchNode(client, nodeName, func(n *v1.Node) { annotateNodeWithCRISocket(n, criSocket) }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 17 14:40:46 UTC 2021 - 1.4K 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) -
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/kubelet/pod/mirror_client.go
apiserverClient clientset.Interface nodeGetter nodeGetter nodeName string } // NewBasicMirrorClient returns a new MirrorClient. func NewBasicMirrorClient(apiserverClient clientset.Interface, nodeName string, nodeGetter nodeGetter) MirrorClient { return &basicMirrorClient{ apiserverClient: apiserverClient, nodeName: nodeName, nodeGetter: nodeGetter, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 21 11:38:40 UTC 2021 - 5.5K bytes - Viewed (0) -
cni/pkg/repair/repair_test_helpers.go
Namespace: "default", Labels: args.Labels, Annotations: args.Annotations, }, Spec: corev1.PodSpec{ NodeName: args.NodeName, Volumes: nil, InitContainers: []corev1.Container{ { Name: args.InitContainerName, }, }, Containers: []corev1.Container{ { Name: "payload-container", }, }, }, Status: corev1.PodStatus{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 12 17:39:53 UTC 2023 - 4.7K 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)