- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 284 for NodeName (0.15 sec)
-
pkg/scheduler/testing/framework/fake_extender.go
func (pl *node2PrioritizerPlugin) Name() string { return "Node2Prioritizer" } // Score return score 100 if the given nodeName is "node2"; otherwise return score 10. func (pl *node2PrioritizerPlugin) Score(_ context.Context, _ *framework.CycleState, _ *v1.Pod, nodeName string) (int64, *framework.Status) { score := 10 if nodeName == "node2" { score = 100 } return int64(score), nil } // ScoreExtensions returns nil.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.9K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/join/kubelet.go
klog.V(1).Infof("[kubelet-start] Checking for an existing Node in the cluster with name %q and status %q", nodeName, v1.NodeReady) node, err := bootstrapClient.CoreV1().Nodes().Get(context.TODO(), nodeName, metav1.GetOptions{}) if err != nil && !apierrors.IsNotFound(err) { return errors.Wrapf(err, "cannot get Node %q", nodeName) } for _, cond := range node.Status.Conditions {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/volume/volume.go
// node. Attach(spec *Spec, nodeName types.NodeName) (string, error) // VolumesAreAttached checks whether the list of volumes still attached to the specified // node. It returns a map which maps from the volume spec to the checking result. // If an error is occurred during checking, the error will be returned VolumesAreAttached(specs []*Spec, nodeName types.NodeName) (map[*Spec]bool, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 11.8K bytes - Viewed (0) -
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/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) -
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)