Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for agg (0.02 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/errors/errors_test.go

    	var slice []error
    	var agg Aggregate
    	var err error
    
    	agg = NewAggregate(slice)
    	if agg != nil {
    		t.Errorf("expected nil, got %#v", agg)
    	}
    	err = NewAggregate(slice)
    	if err != nil {
    		t.Errorf("expected nil, got %#v", err)
    	}
    
    	// This is not normally possible, but pedantry demands I test it.
    	agg = aggregate(slice) // empty aggregate
    	if s := agg.Error(); s != "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jul 24 13:16:21 UTC 2022
    - 12.7K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. src/main/java/org/codelibs/fess/app/service/SearchLogService.java

                        }
                    }, null);
                });
                final Terms agg = list.getAggregations().get(SearchLogPager.LOG_TYPE_CLICK_COUNT);
                final List<? extends Terms.Bucket> buckets = agg.getBuckets();
                updatePagerByAgg(pager, buckets.size());
                return buckets.stream().map(e -> {
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  8. src/runtime/metrics.go

    	samples := *(*[]metricSample)(unsafe.Pointer(&sl))
    
    	// Clear agg defensively.
    	agg = statAggregate{}
    
    	// Sample.
    	for i := range samples {
    		sample := &samples[i]
    		data, ok := metrics[sample.name]
    		if !ok {
    			sample.value.kind = metricKindBad
    			continue
    		}
    		// Ensure we have all the stats we need.
    		// agg is populated lazily.
    		agg.ensure(&data.deps)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 08 21:03:13 UTC 2024
    - 26K bytes
    - Viewed (0)
  9. cmd/kubeadm/app/phases/certs/certs_test.go

    			// executes create func
    			ret, err := SharedCertificateExists(cfg)
    			switch {
    			case err != nil:
    				if agg, ok := err.(utilerrors.Aggregate); ok && len(agg.Errors()) != test.expectedErrors {
    					t.Errorf("SharedCertificateExists didn't fail with the expected number of errors, expected: %v, got: %v", test.expectedErrors, len(agg.Errors()))
    				}
    			case err == nil && test.expectedErrors != 0:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 31 21:49:21 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apimachinery/pkg/util/validation/field/errors.go

    		if errorMsgs.Has(msg) {
    			continue
    		}
    		errorMsgs.Insert(msg)
    		errs = append(errs, err)
    	}
    	return utilerrors.NewAggregate(errs)
    }
    
    func fromAggregate(agg utilerrors.Aggregate) ErrorList {
    	errs := agg.Errors()
    	list := make(ErrorList, len(errs))
    	for i := range errs {
    		list[i] = errs[i].(*Error)
    	}
    	return list
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Oct 28 07:31:28 UTC 2023
    - 11.1K bytes
    - Viewed (0)
Back to top