- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 345 for NodeName (0.15 sec)
-
pkg/apis/discovery/v1beta1/conversion.go
} // Remove hostname from the topology map ONLY IF it is the same value as // nodeName. This preserves the (rather odd) ability to have different // values for topology[hostname] and nodename in v1beta1, without showing // duplicate values in v1. if node, ok := in.Topology[corev1.LabelHostname]; ok { if out.NodeName != nil && node == *out.NodeName { delete(out.DeprecatedTopology, corev1.LabelHostname) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 05 20:02:41 UTC 2021 - 3K bytes - Viewed (0) -
cmd/kubeadm/app/phases/kubelet/flags.go
hostname, err := nodeutil.GetHostname("") nodeName := hostname if cfg.Name != "" { nodeName = cfg.Name } if name, idx := kubeadmapi.GetArgValue(cfg.KubeletExtraArgs, "hostname-override", -1); idx > -1 { nodeName = name } return nodeName, hostname, err } // WriteKubeletDynamicEnvFile writes an environment file with dynamic flags to the kubelet.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 10:27:05 UTC 2023 - 5K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph_populator.go
func (g *graphPopulator) updatePod(oldObj, obj interface{}) { pod := obj.(*corev1.Pod) if len(pod.Spec.NodeName) == 0 { // No node assigned klog.V(5).Infof("updatePod %s/%s, no node", pod.Namespace, pod.Name) return } if oldPod, ok := oldObj.(*corev1.Pod); ok && oldPod != nil { if (pod.Spec.NodeName == oldPod.Spec.NodeName) && (pod.UID == oldPod.UID) &&
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 6.5K bytes - Viewed (0) -
src/syscall/mksysctl_openbsd.pl
# Top level. $node = \%mib; } else { # Node. my $nodename = lc($2); if ($header =~ /^netinet\//) { $ctlname = "net.inet.$nodename"; } elsif ($header =~ /^netinet6\//) { $ctlname = "net.inet6.$nodename"; } elsif ($header =~ /^net\//) { $ctlname = "net.$nodename"; } else { $ctlname = "$nodename"; $ctlname =~ s/^(fs|net|kern)_/$1\./; }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 14 13:21:46 UTC 2018 - 5K bytes - Viewed (0) -
cmd/admin-server-info.go
} nodeName := endpoint.Host if nodeName == "" { nodeName = addr } if endpoint.IsLocal { // Only proceed for local endpoints network[nodeName] = string(madmin.ItemOnline) continue } _, present := network[nodeName] if !present { if err := isServerResolvable(endpoint, 5*time.Second); err == nil { network[nodeName] = string(madmin.ItemOnline) } else {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.9K bytes - Viewed (0) -
cmd/consolelogger.go
func (sys *HTTPConsoleLoggerSys) Send(ctx context.Context, entry interface{}) error { var lg log.Info switch e := entry.(type) { case log.Entry: lg = log.Info{Entry: e, NodeName: sys.nodeName} case string: lg = log.Info{ConsoleMsg: e, NodeName: sys.nodeName} } atomic.AddInt64(&sys.totalMessages, 1) sys.pubsub.Publish(lg) sys.Lock() // add log to ring buffer sys.logBuf.Value = lg
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
cmd/kubeadm/test/resources/pods.go
}, map[string]v1.Volume{}, p.Annotations, ) if len(suffix) > 0 { pod.ObjectMeta.Name = fmt.Sprintf("%s-%s-%s", p.Component, p.NodeName, suffix) } else { pod.ObjectMeta.Name = fmt.Sprintf("%s-%s", p.Component, p.NodeName) } pod.Spec.NodeName = p.NodeName return &pod } // Create creates a fake static pod using the provided client func (p *FakeStaticPod) Create(client clientset.Interface) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 17 14:40:46 UTC 2021 - 1.9K bytes - Viewed (0) -
pkg/kubelet/config/common.go
maxConfigLength = 10 * 1 << 20 // 10MB ) // Generate a pod name that is unique among nodes by appending the nodeName. func generatePodName(name string, nodeName types.NodeName) string { return fmt.Sprintf("%s-%s", name, strings.ToLower(string(nodeName))) } func applyDefaults(pod *api.Pod, source string, isFile bool, nodeName types.NodeName) error { if len(pod.UID) == 0 { hasher := md5.New() hash.DeepHashObject(hasher, pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 5.8K bytes - Viewed (0) -
pkg/kubelet/server/auth.go
// NewNodeAuthorizerAttributesGetter creates a new authorizer.RequestAttributesGetter for the node. func NewNodeAuthorizerAttributesGetter(nodeName types.NodeName) authorizer.RequestAttributesGetter { return nodeAuthorizerAttributesGetter{nodeName: nodeName} } type nodeAuthorizerAttributesGetter struct { nodeName types.NodeName } func isSubpath(subpath, path string) bool { path = strings.TrimSuffix(path, "/")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 19 18:09:38 UTC 2024 - 4K bytes - Viewed (0) -
pkg/registry/resource/resourceslice/strategy.go
"nodeName": nodeNameTriggerFunc, } func nodeNameTriggerFunc(obj runtime.Object) string { return obj.(*resource.ResourceSlice).NodeName } // Indexers returns the indexers for ResourceSlice. func Indexers() *cache.Indexers { return &cache.Indexers{ storage.FieldIndex("nodeName"): nodeNameIndexFunc, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 4.4K bytes - Viewed (0)