- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 873 for NodeName (0.23 sec)
-
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) -
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/controller/volume/attachdetach/util/util.go
return } nodeName := types.NodeName(pod.Spec.NodeName) if nodeName == "" { logger.V(10).Info("Skipping processing of pod, it is not scheduled to a node", "pod", klog.KObj(pod)) return } else if !desiredStateOfWorld.NodeExists(nodeName) { // If the node the pod is scheduled to does not exist in the desired
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 12K 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) -
cmd/kubeadm/app/util/config/cluster.go
} func getAPIEndpoint(client clientset.Interface, nodeName string, apiEndpoint *kubeadmapi.APIEndpoint) error { return getAPIEndpointWithRetry(client, nodeName, apiEndpoint, constants.KubernetesAPICallRetryInterval, kubeadmapi.GetActiveTimeouts().KubernetesAPICall.Duration) } func getAPIEndpointWithRetry(client clientset.Interface, nodeName string, apiEndpoint *kubeadmapi.APIEndpoint,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 11K 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) -
pkg/scheduler/internal/cache/cache.go
} if currState.pod.Spec.NodeName != pod.Spec.NodeName { logger.Error(nil, "Pod was added to a different node than it was assumed", "podKey", key, "pod", klog.KObj(pod), "assumedNode", klog.KRef("", pod.Spec.NodeName), "currentNode", klog.KRef("", currState.pod.Spec.NodeName)) if pod.Spec.NodeName != "" { // An empty NodeName is possible when the scheduler misses a Delete
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 09:56:48 UTC 2023 - 24.9K bytes - Viewed (0) -
pkg/scheduler/internal/cache/snapshot.go
nodeNameToInfo := make(map[string]*framework.NodeInfo) for _, pod := range pods { nodeName := pod.Spec.NodeName if _, ok := nodeNameToInfo[nodeName]; !ok { nodeNameToInfo[nodeName] = framework.NewNodeInfo() } nodeNameToInfo[nodeName].AddPod(pod) } imageExistenceMap := createImageExistenceMap(nodes) for _, node := range nodes {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 01:38:03 UTC 2023 - 6.6K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher_test.go
wg.Add(1) go func(spec *volume.Spec, nodename string, fail bool) { defer wg.Done() attachID, err := csiAttacher.Attach(spec, types.NodeName(nodename)) if fail != (err != nil) { t.Errorf("expecting no failure, but got err: %v", err) } if attachID != "" { t.Errorf("expecting empty attachID, got %v", attachID) } }(tc.spec, tc.nodeName, tc.shouldFail)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0) -
pkg/kubelet/config/file.go
} type sourceFile struct { path string nodeName types.NodeName period time.Duration store cache.Store fileKeyMapping map[string]string updates chan<- interface{} watchEvents chan *watchEvent } // NewSourceFile watches a config file for changes. func NewSourceFile(path string, nodeName types.NodeName, period time.Duration, updates chan<- interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 01 07:19:44 UTC 2021 - 6.2K bytes - Viewed (0)