Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for agg (0.01 sec)

  1. platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/expiry/AnyDaemonExpirationStrategyTest.groovy

            given:
            AnyDaemonExpirationStrategy agg = new AnyDaemonExpirationStrategy([c1, c2])
    
            when:
            1 * c1.checkExpiration() >> { new DaemonExpirationResult(c1Status, "r1") }
            1 * c2.checkExpiration() >> { new DaemonExpirationResult(c2Status, "r2") }
    
            then:
            DaemonExpirationResult result = agg.checkExpiration()
            result.status == anyStatus
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/errors/errors.go

    type aggregate []error
    
    // Error is part of the error interface.
    func (agg aggregate) Error() string {
    	if len(agg) == 0 {
    		// This should never happen, really.
    		return ""
    	}
    	if len(agg) == 1 {
    		return agg[0].Error()
    	}
    	seenerrs := sets.NewString()
    	result := ""
    	agg.visit(func(err error) bool {
    		msg := err.Error()
    		if seenerrs.Has(msg) {
    			return false
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 29 09:44:02 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  3. platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/expiry/AllDaemonExpirationStrategyTest.groovy

            when:
            AllDaemonExpirationStrategy agg = new AllDaemonExpirationStrategy(Collections.emptyList())
    
            then:
            DaemonExpirationResult result = agg.checkExpiration()
            result.status == DO_NOT_EXPIRE
            result.reason == null
        }
    
        def "doesn't concatenate a null reason"() {
            given:
            AllDaemonExpirationStrategy agg = new AllDaemonExpirationStrategy([c1, c2])
    
            when:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  4. pilot/pkg/credentials/kube/multicluster.go

    		// Authorization will always use the proxy cluster.
    		agg.controllers = append(agg.controllers, *cc)
    	}
    	if cc := m.component.ForCluster(m.configCluster); cc != nil {
    		agg.controllers = append(agg.controllers, *cc)
    	}
    	return agg, nil
    }
    
    func (m *Multicluster) AddSecretHandler(h func(name string, namespace string)) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 23 19:18:21 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/util/validation/field/errors_test.go

    	}
    	for i, tc := range testCases.ErrList {
    		agg := tc.ToAggregate()
    		numErrs := 0
    
    		if agg != nil {
    			numErrs = len(agg.Errors())
    		}
    		if numErrs != testCases.NumExpectedErrs[i] {
    			t.Errorf("[%d] Expected %d, got %d", i, testCases.NumExpectedErrs[i], numErrs)
    		}
    
    		if len(tc) == 0 {
    			if agg != nil {
    				t.Errorf("[%d] Expected nil, got %#v", i, agg)
    			}
    		} else if agg == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Oct 28 07:31:28 UTC 2023
    - 4.2K bytes
    - Viewed (0)
Back to top