- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 728 for NodeName (0.31 sec)
-
cni/pkg/util/podutil_test.go
) func TestGetPodIPIfPodIPPresent(t *testing.T) { pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "test", Namespace: "test", }, Spec: corev1.PodSpec{ NodeName: "derp", }, Status: corev1.PodStatus{ PodIP: "11.1.1.12", }, } podIPs := GetPodIPsIfPresent(pod) assert.Equal(t, len(podIPs), 1) } func TestGetPodIPsIfPodIPPresent(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 03 19:29:42 UTC 2024 - 4.9K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/node_authorizer_test.go
attachment.Spec.NodeName = nodeName attachments = append(attachments, attachment) } nodes = append(nodes, &corev1.Node{ ObjectMeta: metav1.ObjectMeta{Name: nodeName}, Spec: corev1.NodeSpec{}, }) for p := 0; p <= opts.nodeResourceCapacitiesPerNode; p++ { name := fmt.Sprintf("slice%d-%s", p, nodeName) slice := &resourcev1alpha2.ResourceSlice{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 40.5K bytes - Viewed (0) -
pkg/proxy/nftables/proxier_test.go
Conditions: discovery.EndpointConditions{Ready: ptr.To(true)}, NodeName: ptr.To(testHostname), }, { Addresses: []string{"10.0.1.2"}, Conditions: discovery.EndpointConditions{Ready: ptr.To(true)}, NodeName: ptr.To(testHostname), }, { Addresses: []string{"10.0.1.3"}, Conditions: discovery.EndpointConditions{Ready: ptr.To(true)}, NodeName: ptr.To(testHostname),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 173.5K bytes - Viewed (0) -
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) -
pkg/scheduler/framework/plugins/registry.go
imagelocality.Name: imagelocality.New, tainttoleration.Name: runtime.FactoryAdapter(fts, tainttoleration.New), nodename.Name: nodename.New, nodeports.Name: nodeports.New, nodeaffinity.Name: nodeaffinity.New, podtopologyspread.Name: runtime.FactoryAdapter(fts, podtopologyspread.New),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 5K bytes - Viewed (0) -
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)