Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 24 of 24 for getNodes (0.11 sec)

  1. pkg/controller/endpointslice/endpointslice_controller.go

    	if c.topologyCache == nil {
    		return
    	}
    	nodes, err := c.nodeLister.List(labels.Everything())
    	if err != nil {
    		logger.Error(err, "Error listing Nodes")
    		return
    	}
    	c.topologyCache.SetNodes(logger, nodes)
    	serviceKeys := c.topologyCache.GetOverloadedServices()
    	for _, serviceKey := range serviceKeys {
    		logger.V(2).Info("Queuing Service after Node change due to overloading", "key", serviceKey)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  2. platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/ProblemReportingCrossProjectModelAccess.kt

                shouldNotBeUsed()
            }
    
            override fun projectPath(name: String): Path {
                shouldNotBeUsed()
            }
    
            override fun getModel(): ModelContainer<*> {
                shouldNotBeUsed()
            }
    
            override fun getBuildPath(): Path {
                shouldNotBeUsed()
            }
    
            override fun isScript(): Boolean {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:25 UTC 2024
    - 41.1K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/cluster.go

    		port := int(instance.Port.TargetPort)
    		clustersToBuild[port] = append(clustersToBuild[port], instance)
    	}
    
    	bind := actualLocalHosts[0]
    	if cb.req.Push.Mesh.GetInboundTrafficPolicy().GetMode() == meshconfig.MeshConfig_InboundTrafficPolicy_PASSTHROUGH {
    		bind = ""
    	}
    	// For each workload port, we will construct a cluster
    	for epPort, instances := range clustersToBuild {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_node_status.go

    			kl.containerRuntimeReadyExpected = true
    		}
    	}()
    
    	if timeout {
    		klog.ErrorS(nil, "Node not becoming ready in time after startup")
    		return true
    	}
    
    	originalNode, err := kl.GetNode()
    	if err != nil {
    		klog.ErrorS(err, "Error getting the current node from lister")
    		return false
    	}
    
    	readyIdx, originalNodeReady := nodeutil.GetNodeCondition(&originalNode.Status, v1.NodeReady)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
Back to top