- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for agg (0.19 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
staging/src/k8s.io/cli-runtime/pkg/resource/builder_test.go
t.Fatalf("unexpected error: %v", err) } if count != 3 { t.Fatalf("did not visit all infos: %d", count) } agg, ok := err.(utilerrors.Aggregate) if !ok { t.Fatalf("unexpected error: %v", err) } if len(agg.Errors()) != 2 || agg.Errors()[0] != testErr || agg.Errors()[1] != testErr { t.Fatalf("unexpected error: %v", err) } } func TestSingleItemImpliedObject(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 11:58:41 UTC 2023 - 56.1K bytes - Viewed (0)