- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for agg (0.02 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) -
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) -
pkg/controller/statefulset/stateful_set_control.go
} history.SortControllerRevisions(revisions) currentRevision, updateRevision, status, err := ssc.performUpdate(ctx, set, pods, revisions) if err != nil { errs := []error{err} if agg, ok := err.(utilerrors.Aggregate); ok { errs = agg.Errors() } return nil, utilerrors.NewAggregate(append(errs, ssc.truncateHistory(set, pods, revisions, currentRevision, updateRevision))) } // maintain the set's revision history limit
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:03:46 UTC 2024 - 30.9K bytes - Viewed (0) -
src/main/resources/fess_config.properties
page.searchlog.max.fetch.size=10000 page.searchlist.track.total.hits=true # search page paging.search.page.start=0 paging.search.page.size=10 paging.search.page.max.size=100 searchlog.agg.shard.size=-1 searchlog.request.headers= thumbnail.html.image.min.width=100 thumbnail.html.image.min.height=100 thumbnail.html.image.max.aspect.ratio=3.0 thumbnail.html.image.thumbnail.width=100
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Apr 11 02:34:53 UTC 2024 - 30.6K bytes - Viewed (0)