Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for crdNames (0.11 sec)

  1. operator/pkg/helmreconciler/wait.go

    	var crdNames []string
    	for _, o := range object.KindObjects(objects, name.CRDStr) {
    		crdNames = append(crdNames, o.Name)
    	}
    	if len(crdNames) == 0 {
    		return nil
    	}
    
    	errPoll := wait.PollUntilContextTimeout(context.Background(), cRDPollInterval, cRDPollTimeout, false, func(context.Context) (bool, error) {
    	descriptor:
    		for _, crdName := range crdNames {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Dec 08 03:13:12 UTC 2023
    - 13.1K bytes
    - Viewed (0)
  2. tests/integration/security/sds_ingress/util/util.go

    					GatewayLabel:   inst.Settings().IngressGatewayIstioLabel,
    				})
    				credNames = append(credNames, cred)
    			}
    			SetupConfig(ctx, ns.Get(), tests...)
    			return nil
    		}).
    		To(echotest.SimplePodServiceAndAllSpecial(1)).
    		RunFromClusters(func(ctx framework.TestContext, fromCluster cluster.Cluster, to echo.Target) {
    			for _, cn := range credNames {
    				CreateIngressKubeSecret(ctx, cn, Mtls, IngressCredentialA, false)
    			}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jul 25 05:12:36 UTC 2023
    - 20.2K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/conversion/metrics.go

    }
    
    var _ crConverterInterface = &converterMetric{}
    
    type converterMetric struct {
    	delegate  crConverterInterface
    	latencies *metrics.HistogramVec
    	crdName   string
    }
    
    func (c *converterMetricFactory) addMetrics(crdName string, converter crConverterInterface) (crConverterInterface, error) {
    	c.factoryLock.Lock()
    	defer c.factoryLock.Unlock()
    	metric, exists := c.durations["webhook"]
    	if !exists {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 07 19:34:33 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  4. tests/integration/pilot/mcs/common/common.go

    		if err != nil {
    			return err
    		}
    
    		// Make sure the CRD exists in each cluster.
    		for _, c := range t.Clusters() {
    			crdName := fmt.Sprintf("%ss.%s", kind, params.Group)
    			if isCRDInstalled(c, crdName, params.Version) {
    				// It's already installed on this cluster - nothing to do.
    				continue
    			}
    
    			// Add/Update the CRD in this cluster...
    			if t.Settings().NoCleanup {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 27 17:09:00 UTC 2022
    - 3.7K bytes
    - Viewed (0)
  5. pilot/pkg/xds/debug.go

    	var cmdNames []string
    	for k := range s.debugHandlers {
    		key := strings.Replace(k, "/debug/", "", -1)
    		// exclude current list command
    		if key == "list" {
    			continue
    		}
    		// can not support pprof commands
    		if strings.Contains(key, "pprof") {
    			continue
    		}
    		cmdNames = append(cmdNames, key)
    	}
    	sort.Strings(cmdNames)
    	writeJSON(w, cmdNames, req)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go

    		if len(pathParts) == 2 {
    			r.groupDiscoveryHandler.ServeHTTP(w, req)
    			return
    		}
    
    		r.delegate.ServeHTTP(w, req)
    		return
    	}
    
    	crdName := requestInfo.Resource + "." + requestInfo.APIGroup
    	crd, err := r.crdLister.Get(crdName)
    	if apierrors.IsNotFound(err) {
    		r.delegate.ServeHTTP(w, req)
    		return
    	}
    	if err != nil {
    		utilruntime.HandleError(err)
    		responsewriters.ErrorNegotiated(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 52.9K bytes
    - Viewed (0)
Back to top