- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for agg (0.03 sec)
-
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) -
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) -
cmd/kubelet/app/options/options.go
fs.DurationVar(&c.VolumeStatsAggPeriod.Duration, "volume-stats-agg-period", c.VolumeStatsAggPeriod.Duration, "Specifies interval for kubelet to calculate and cache the volume disk usage for all pods and volumes. To disable volume calculations, set to a negative number.")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:05 UTC 2024 - 41.6K bytes - Viewed (0)