- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 549 for NodeName (0.16 sec)
-
pkg/kubelet/runonce_test.go
kb.resourceAnalyzer = stats.NewResourceAnalyzer(kb, volumeStatsAggPeriod, kb.recorder) nodeRef := &v1.ObjectReference{ Kind: "Node", Name: string(kb.nodeName), UID: types.UID(kb.nodeName), Namespace: "", } fakeKillPodFunc := func(pod *v1.Pod, evict bool, gracePeriodOverride *int64, fn func(*v1.PodStatus)) error { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 06:59:54 UTC 2024 - 6.5K 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/controller/endpointslice/endpointslice_controller_test.go
nodeInformer := informerFactory.Core().V1().Nodes() indexer := nodeInformer.Informer().GetIndexer() for _, nodeName := range nodeNames { indexer.Add(&v1.Node{ObjectMeta: metav1.ObjectMeta{Name: nodeName}}) } esInformer := informerFactory.Discovery().V1().EndpointSlices() esIndexer := esInformer.Informer().GetIndexer()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
plugin/pkg/admission/noderestriction/admission_test.go
nodename := "mynode" mynode := &user.DefaultInfo{Name: "system:node:" + nodename, Groups: []string{"system:nodes"}} err := "can only create ResourceSlice with the same NodeName as the requesting node" sliceNode := &resourceapi.ResourceSlice{ ObjectMeta: metav1.ObjectMeta{ Name: "something", }, NodeName: nodename, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 73.2K 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/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) -
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)