Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 134 for getNodes (0.21 sec)

  1. pkg/serviceaccount/claims_test.go

    	if f.secret == nil {
    		return nil, apierrors.NewNotFound(schema.GroupResource{Group: "", Resource: "secrets"}, name)
    	}
    	return f.secret, nil
    }
    func (f fakeGetter) GetNode(name string) (*v1.Node, error) {
    	if f.node == nil {
    		return nil, apierrors.NewNotFound(schema.GroupResource{Group: "", Resource: "nodes"}, name)
    	}
    	return f.node, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  2. pkg/kubelet/server/server_test.go

    	return fk.machineInfoFunc()
    }
    
    func (*fakeKubelet) GetVersionInfo() (*cadvisorapi.VersionInfo, error) {
    	return &cadvisorapi.VersionInfo{}, nil
    }
    
    func (fk *fakeKubelet) GetPods() []*v1.Pod {
    	return fk.podsFunc()
    }
    
    func (fk *fakeKubelet) GetRunningPods(ctx context.Context) ([]*v1.Pod, error) {
    	return fk.runningPodsFunc(ctx)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.5K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/cluster_traffic_policy.go

    func shouldH2Upgrade(clusterName string, port *model.Port, mesh *meshconfig.MeshConfig,
    	connectionPool *networking.ConnectionPoolSettings,
    ) bool {
    	// TODO (mjog)
    	// Upgrade if tls.GetMode() == networking.TLSSettings_ISTIO_MUTUAL
    	if connectionPool != nil && connectionPool.Http != nil {
    		override := connectionPool.Http.H2UpgradePolicy
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 23 05:38:57 UTC 2024
    - 20K bytes
    - Viewed (0)
  4. pkg/kubelet/pleg/generic.go

    	}
    
    	timestamp := g.clock.Now()
    	defer func() {
    		metrics.PLEGRelistDuration.Observe(metrics.SinceInSeconds(timestamp))
    	}()
    
    	// Get all the pods.
    	podList, err := g.runtime.GetPods(ctx, true)
    	if err != nil {
    		klog.ErrorS(err, "GenericPLEG: Unable to retrieve pods")
    		return
    	}
    
    	g.updateRelistTime(timestamp)
    
    	pods := kubecontainer.Pods(podList)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.3K bytes
    - Viewed (0)
  5. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/transform/DefaultTransform.java

                return isolateParameters(inputFingerprinter);
            }
    
            private IsolatedParameters isolateParameters(InputFingerprinter inputFingerprinter) {
                ModelContainer<?> model = owner.getModel();
                if (!model.hasMutableState()) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 18 08:26:19 UTC 2024
    - 34.8K bytes
    - Viewed (0)
  6. docs/fr/docs/index.md

    Vous faites cela avec les types Python standard modernes.
    
    Vous n'avez pas à apprendre une nouvelle syntaxe, les méthodes ou les classes d'une bibliothèque spécifique, etc.
    
    Juste du **Python** standard.
    
    Par exemple, pour un `int`:
    
    ```Python
    item_id: int
    ```
    
    ou pour un modèle `Item` plus complexe :
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Mon Apr 29 05:18:04 UTC 2024
    - 22K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. pkg/kube/inject/inject.go

    		imageType = it
    	}
    
    	return imageURL(global.GetHub(), imageName, tag, imageType)
    }
    
    func InboundTrafficPolicyMode(meshConfig *meshconfig.MeshConfig) string {
    	switch meshConfig.GetInboundTrafficPolicy().GetMode() {
    	case meshconfig.MeshConfig_InboundTrafficPolicy_LOCALHOST:
    		return "localhost"
    	case meshconfig.MeshConfig_InboundTrafficPolicy_PASSTHROUGH:
    		return "passthrough"
    	}
    	return "passthrough"
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 20:35:11 UTC 2024
    - 28.8K bytes
    - Viewed (0)
  10. pkg/workloadapi/workload.pb.go

    }
    
    func (x *LoadBalancing) GetRoutingPreference() []LoadBalancing_Scope {
    	if x != nil {
    		return x.RoutingPreference
    	}
    	return nil
    }
    
    func (x *LoadBalancing) GetMode() LoadBalancing_Mode {
    	if x != nil {
    		return x.Mode
    	}
    	return LoadBalancing_UNSPECIFIED_MODE
    }
    
    // Workload represents a workload - an endpoint (or collection behind a hostname).
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 18:02:35 UTC 2024
    - 65.9K bytes
    - Viewed (0)
Back to top