- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for crdNames (0.11 sec)
-
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) -
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) -
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) -
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) -
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) -
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)