Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for IsPrimary (0.13 sec)

  1. pkg/test/framework/components/cluster/clusters.go

    		}
    	}
    	return out
    }
    
    // Primaries returns the subset that are primary clusters.
    func (c Clusters) Primaries(excluded ...Cluster) Clusters {
    	return c.filterClusters(func(cc Cluster) bool {
    		return cc.IsPrimary()
    	}, exclude(excluded...))
    }
    
    // Exclude returns all clusters not given as input.
    func (c Clusters) Exclude(excluded ...Cluster) Clusters {
    	return c.filterClusters(func(cc Cluster) bool {
    		return true
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. pkg/test/framework/suite.go

    	return s.RequireMinClusters(1).RequireMaxClusters(1)
    }
    
    func (s *suiteImpl) RequireMultiPrimary() Suite {
    	fn := func(ctx resource.Context) error {
    		for _, c := range ctx.Clusters() {
    			if !c.IsPrimary() {
    				s.Skip(fmt.Sprintf("Cluster %s is not using a local control plane",
    					c.Name()))
    			}
    		}
    		return nil
    	}
    
    	s.requireFns = append(s.requireFns, fn)
    	return s
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  3. tests/integration/telemetry/api/dashboard_test.go

    			go setupDashboardTest(c.Done())
    			for _, d := range dashboards {
    				d := d
    				t.NewSubTest(d.name).Run(func(t framework.TestContext) {
    					for _, cl := range t.Clusters() {
    						if !cl.IsPrimary() && d.requirePrimary {
    							// Skip verification of dashboards that won't be present on non primary(remote) clusters.
    							continue
    						}
    						t.Logf("Verifying %s for cluster %s", d.name, cl.Name())
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 20:46:28 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  4. pkg/test/framework/test.go

    					t.goTest.Name(), c.Name(), t.minKubernetesMinorVersion)
    				return
    			}
    		}
    	}
    
    	if t.requireLocalIstiod {
    		for _, c := range ctx.Clusters() {
    			if !c.IsPrimary() {
    				t.goTest.Skipf(fmt.Sprintf("Skipping %q: cluster %s is not using a local control plane",
    					t.goTest.Name(), c.Name()))
    				return
    			}
    		}
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  5. tests/integration/telemetry/api/wasmplugin_test.go

    			util.PromDiff(t, promInst, c, q)
    			return err
    		}
    		return nil
    	}, retry.Delay(1*time.Second), retry.Timeout(80*time.Second))
    
    	if ecdsShouldReject && t.Clusters().Default().IsPrimary() { // Only check istiod if running locally (i.e., not an external control plane)
    		// Verify that istiod has a stats about rejected ECDS update
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  6. analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/symbols/descriptorBased/base/Kt1DescUtils.kt

        }
    
        return KaFe10DescConstructorSymbol(this, analysisContext)
    }
    
    internal val CallableMemberDescriptor.ktHasStableParameterNames: Boolean
        get() = when {
            this is ConstructorDescriptor && isPrimary && constructedClass.kind == ClassKind.ANNOTATION_CLASS -> true
            isExpect -> false
            else -> when (this) {
                is JavaCallableMemberDescriptor -> false
                else -> hasStableParameterNames()
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Tue Jun 11 15:45:42 UTC 2024
    - 33.4K bytes
    - Viewed (0)
Back to top