- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for currentNode (0.24 sec)
-
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/cel/compilation.go
// provide size estimates when that happens return nil } currentNode := c.root // cut off "self" from path, since we always start there for _, name := range element.Path()[1:] { switch name { case "@items", "@values": if currentNode.ElemType == nil { return nil } currentNode = currentNode.ElemType case "@keys": if currentNode.KeyType == nil { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 20:13:14 UTC 2024 - 13.8K bytes - Viewed (0) -
operator/pkg/translate/translate.go
} patchObj := make(map[string]any) var currentNode, nextNode any nextNode = patchObj for i, pe := range path { currentNode = nextNode // last path element if i == length-1 { currentNode, ok := currentNode.(map[string]any) if !ok { return nil, fmt.Errorf("path %s has an unexpected non KV element %s", path, pe) } currentNode[pe] = node break }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 12 19:43:09 UTC 2024 - 36.3K bytes - Viewed (0) -
pkg/kubelet/cloudresource/cloud_request_manager.go
// TODO(roberthbailey): Can we do this without having credentials to talk to // the cloud provider? // TODO(justinsb): We can if CurrentNodeName() was actually CurrentNode() and // returned an interface. // TODO: If IP addresses couldn't be fetched from the cloud provider, should // kubelet fallback on the other methods for getting the IP below? instances, ok := m.cloud.Instances()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 05 18:29:23 UTC 2021 - 4.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/DetermineExecutionPlanAction.java
if (previousTaskNode.getShouldSuccessors().contains(node)) { walkedShouldRunAfterEdges.push(new GraphEdge(previous, node)); } } private void onOrderingCycle(Node successor, Node currentNode) { List<Set<Node>> cycles = findCycles(successor); if (cycles.isEmpty()) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 17.7K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache.go
// The pod was added to a different node than it was assumed to. logger.Info("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)) return nil } case !ok: // Pod was expired. We should add it back. if err = cache.addPod(logger, pod, false); err != nil {
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/proxy/nftables/proxier.go
func (proxier *Proxier) OnNodeAdd(node *v1.Node) { if node.Name != proxier.hostname { proxier.logger.Error(nil, "Received a watch event for a node that doesn't match the current node", "eventNode", node.Name, "currentNode", proxier.hostname) return } if reflect.DeepEqual(proxier.nodeLabels, node.Labels) { return } proxier.mu.Lock() proxier.nodeLabels = map[string]string{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
func (proxier *Proxier) OnNodeAdd(node *v1.Node) { if node.Name != proxier.hostname { proxier.logger.Error(nil, "Received a watch event for a node that doesn't match the current node", "eventNode", node.Name, "currentNode", proxier.hostname) return } if reflect.DeepEqual(proxier.nodeLabels, node.Labels) { return } proxier.mu.Lock() proxier.nodeLabels = map[string]string{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
c.Lock() // check if the node exists as this add event could be due to controller resync // if the stored object changes, then fire an update event. Otherwise, ignore this event. currentNode, exists := c.nodeInfoMap[node.Name] if !exists || !nodeEquals(currentNode, k8sNode) { c.nodeInfoMap[node.Name] = k8sNode updatedNeeded = true } c.Unlock() } // update all related services
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
// is observed. func (proxier *Proxier) OnNodeAdd(node *v1.Node) { if node.Name != proxier.hostname { proxier.logger.Error(nil, "Received a watch event for a node that doesn't match the current node", "eventNode", node.Name, "currentNode", proxier.hostname) return } if reflect.DeepEqual(proxier.nodeLabels, node.Labels) { return } proxier.mu.Lock() proxier.nodeLabels = map[string]string{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
src/internal/trace/traceviewer/static/webcomponents.min.js
l),function(e){"use strict";function t(e){r(e,this)}var n=e.registerWrapper,r=e.setWrapper,o=e.unsafeUnwrap,i=e.unwrapIfNeeded,a=e.wrap,s=window.TreeWalker;t.prototype={get root(){return a(o(this).root)},get currentNode(){return a(o(this).currentNode)},set currentNode(e){o(this).currentNode=i(e)},get filter(){return o(this).filter},parentNode:function(){return a(o(this).parentNode())},firstChild:function(){return a(o(this).firstChild())},lastChild:function(){return a(o(this).lastChild())},previo...
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 20:45:06 UTC 2023 - 115.6K bytes - Viewed (0)