- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 728 for NodeName (0.17 sec)
-
pkg/kubelet/kubelet_node_status.go
originalNode, err = kl.nodeLister.Get(string(kl.nodeName)) } else { opts := metav1.GetOptions{} originalNode, err = kl.heartbeatClient.CoreV1().Nodes().Get(ctx, string(kl.nodeName), opts) } if err != nil { return fmt.Errorf("error getting node %q: %v", kl.nodeName, err) } if originalNode == nil { return fmt.Errorf("nil %q node object", kl.nodeName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/scheduler/eventhandlers_test.go
func TestUpdatePodInCache(t *testing.T) { ttl := 10 * time.Second nodeName := "node" tests := []struct { name string oldObj interface{} newObj interface{} }{ { name: "pod updated with the same UID", oldObj: withPodName(podWithPort("oldUID", nodeName, 80), "pod"), newObj: withPodName(podWithPort("oldUID", nodeName, 8080), "pod"), }, { name: "pod updated with different UIDs",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 10 14:38:54 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption.go
} // Check if the returned victims are valid. for nodeName, victims := range nodeNameToVictims { if victims == nil || len(victims.Pods) == 0 { if extender.IsIgnorable() { delete(nodeNameToVictims, nodeName) logger.Info("Ignored node for which the extender didn't report victims", "node", klog.KRef("", nodeName), "extender", extender.Name()) continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 25.1K bytes - Viewed (0) -
pkg/apis/storage/validation/validation_test.go
PersistentVolumeName: &volumeName, }, NodeName: "mynode", }, }, { ObjectMeta: metav1.ObjectMeta{Name: "foo-with-inlinespec"}, Spec: storage.VolumeAttachmentSpec{ Attacher: "myattacher", Source: storage.VolumeAttachmentSource{ InlineVolumeSpec: &inlineSpec, }, NodeName: "mynode", }, }, { ObjectMeta: metav1.ObjectMeta{Name: "foo-with-status"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 69.7K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter.go
} // Save volume info in pod dir // persist volume info data for teardown nodeName := string(c.plugin.host.GetNodeName()) volData := map[string]string{ volDataKey.specVolID: c.spec.Name(), volDataKey.volHandle: volumeHandle, volDataKey.driverName: string(c.driverName), volDataKey.nodeName: nodeName, volDataKey.volumeLifecycleMode: string(c.volumeLifecycleMode),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 30 10:47:59 UTC 2024 - 21K bytes - Viewed (1) -
plugin/pkg/auth/authorizer/node/graph.go
g.deleteVertex_locked(vaVertexType, "", attachmentName) // if we have a node, establish new edges if len(nodeName) > 0 { vaVertex := g.getOrCreateVertex_locked(vaVertexType, "", attachmentName) nodeVertex := g.getOrCreateVertex_locked(nodeVertexType, "", nodeName) g.graph.SetEdge(newDestinationEdge(vaVertex, nodeVertex, nodeVertex)) } } func (g *Graph) DeleteVolumeAttachment(name string) { start := time.Now()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 17.5K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/ConfigurationDeprecatedExtensions.kt
*/ @Deprecated(deprecationMessage, replaceWith = ReplaceWith("get().addToAntBuilder(builder, nodeName, type)"), level = DeprecationLevel.HIDDEN) fun <T : Configuration> NamedDomainObjectProvider<T>.addToAntBuilder(builder: Any, nodeName: String, type: FileCollection.AntType): Unit = get().addToAntBuilder(builder, nodeName, type) /** * See [Configuration.addToAntBuilder]. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Mar 28 18:18:46 UTC 2024 - 17.5K bytes - Viewed (0) -
pkg/volume/testing/testing.go
// so as reconciler can not confirm this volume as attached. if nodeName == TimeoutAttachNode { return "", fmt.Errorf("timed out to attach volume %q to node %q", volumeName, nodeName) } if volumeNodes.Has(string(nodeName)) || volumeNodes.Has(MultiAttachNode) || nodeName == MultiAttachNode { volumeNodes.Insert(string(nodeName)) return "/dev/vdb-test", nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 53.3K bytes - Viewed (0) -
pkg/kubelet/util/util.go
// GetNodenameForKernel gets hostname value to set in the hostname field (the nodename field of struct utsname) of the pod. func GetNodenameForKernel(hostname string, hostDomainName string, setHostnameAsFQDN *bool) (string, error) { kernelHostname := hostname // FQDN has to be 64 chars to fit in the Linux nodename kernel field (specification 64 chars and the null terminating char). const fqdnMaxLen = 64
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 18:07:39 UTC 2023 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_test.go
} func makeTestPodDetails(name string, resourceVersion uint64, nodeName string, labels map[string]string) *v1.Pod { return &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Namespace: "ns", Name: name, ResourceVersion: strconv.FormatUint(resourceVersion, 10), Labels: labels, }, Spec: v1.PodSpec{ NodeName: nodeName, }, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 35.4K bytes - Viewed (0)