Home
last modified time | relevance | path

Searched refs:Aggregation (Results 1 – 25 of 44) sorted by relevance

12

/external/opencensus-java/api/src/main/java/io/opencensus/stats/
DAggregation.java43 public abstract class Aggregation { class
45 private Aggregation() {} in Aggregation() method in Aggregation
57 Function<? super Aggregation, T> defaultFunction); in match() argument
66 public abstract static class Sum extends Aggregation {
88 Function<? super Aggregation, T> defaultFunction) { in match() argument
100 public abstract static class Count extends Aggregation {
122 Function<? super Aggregation, T> defaultFunction) { in match() argument
137 public abstract static class Mean extends Aggregation {
159 Function<? super Aggregation, T> defaultFunction) { in match() argument
172 public abstract static class Distribution extends Aggregation {
[all …]
DViewData.java24 import io.opencensus.stats.Aggregation.Count;
25 import io.opencensus.stats.Aggregation.Distribution;
26 import io.opencensus.stats.Aggregation.LastValue;
27 import io.opencensus.stats.Aggregation.Sum;
245 final Aggregation aggregation, final AggregationData aggregationData, final Measure measure) {
313 new Function<Aggregation, Void>() {
315 public Void apply(Aggregation arg) {
319 if (arg instanceof Aggregation.Mean) {
332 boolean isValid, Aggregation aggregation, AggregationData aggregationData) {
340 Aggregation aggregation, AggregationData aggregationData) {
DView.java83 public abstract Aggregation getAggregation(); in getAggregation()
124 Aggregation aggregation, in create()
152 Aggregation aggregation, in create()
/external/tcpdump/tests/
Dlacp-ev.out4 State Flags [Activity, Aggregation, Expired]
7 State Flags [Timeout, Aggregation, Collecting, Distributing]
14 State Flags [Activity, Aggregation, Expired]
17 State Flags [Timeout, Aggregation, Collecting, Distributing]
24 State Flags [Activity, Aggregation, Expired]
27 State Flags [Timeout, Aggregation, Collecting, Distributing]
34 State Flags [Activity, Aggregation, Synchronization, Default]
44 State Flags [Activity, Aggregation, Synchronization, Collecting, Distributing, Default]
54 State Flags [Activity, Aggregation, Synchronization, Collecting, Distributing, Default]
64 State Flags [Activity, Aggregation, Synchronization, Collecting, Distributing, Default]
[all …]
/external/opencensus-java/exporters/stats/signalfx/src/test/java/io/opencensus/exporter/stats/signalfx/
DSignalFxSessionAdaptorTest.java33 import io.opencensus.stats.Aggregation;
87 Aggregation.Mean.create(), AggregationWindow.Cumulative.create())); in checkMetricTypeFromAggregation()
91 Aggregation.Mean.create(), AggregationWindow.Interval.create(ONE_SECOND))); in checkMetricTypeFromAggregation()
95 Aggregation.Count.create(), AggregationWindow.Cumulative.create())); in checkMetricTypeFromAggregation()
99 Aggregation.Sum.create(), AggregationWindow.Cumulative.create())); in checkMetricTypeFromAggregation()
101 SignalFxSessionAdaptor.getMetricTypeForAggregation(Aggregation.Count.create(), null)); in checkMetricTypeFromAggregation()
102 assertNull(SignalFxSessionAdaptor.getMetricTypeForAggregation(Aggregation.Sum.create(), null)); in checkMetricTypeFromAggregation()
105 Aggregation.Count.create(), AggregationWindow.Interval.create(ONE_SECOND))); in checkMetricTypeFromAggregation()
108 Aggregation.Sum.create(), AggregationWindow.Interval.create(ONE_SECOND))); in checkMetricTypeFromAggregation()
111 Aggregation.Distribution.create(BucketBoundaries.create(ImmutableList.of(3.15d))), in checkMetricTypeFromAggregation()
[all …]
/external/grpc-grpc/src/cpp/ext/filters/census/
Dviews.cc30 using ::opencensus::stats::Aggregation;
40 Aggregation BytesDistributionAggregation() { in BytesDistributionAggregation()
41 return Aggregation::Distribution(BucketBoundaries::Explicit( in BytesDistributionAggregation()
46 Aggregation MillisDistributionAggregation() { in MillisDistributionAggregation()
47 return Aggregation::Distribution(BucketBoundaries::Explicit( in MillisDistributionAggregation()
54 Aggregation CountDistributionAggregation() { in CountDistributionAggregation()
55 return Aggregation::Distribution(BucketBoundaries::Exponential(17, 1.0, 2.0)); in CountDistributionAggregation()
135 .set_aggregation(Aggregation::Count()) in ClientCompletedRpcsCumulative()
197 .set_aggregation(Aggregation::Count()) in ServerCompletedRpcsCumulative()
269 .set_aggregation(Aggregation::Count()) in ClientCompletedRpcsMinute()
[all …]
/external/opencensus-java/api/src/test/java/io/opencensus/stats/
DAggregationTest.java23 import io.opencensus.stats.Aggregation.Count;
24 import io.opencensus.stats.Aggregation.Distribution;
25 import io.opencensus.stats.Aggregation.LastValue;
26 import io.opencensus.stats.Aggregation.Mean;
27 import io.opencensus.stats.Aggregation.Sum;
75 List<Aggregation> aggregations = in testMatch()
84 for (Aggregation aggregation : aggregations) { in testMatch()
DViewDataTest.java28 import io.opencensus.stats.Aggregation.Count;
29 import io.opencensus.stats.Aggregation.Distribution;
30 import io.opencensus.stats.Aggregation.LastValue;
31 import io.opencensus.stats.Aggregation.Mean;
32 import io.opencensus.stats.Aggregation.Sum;
242 private static View createView(Aggregation aggregation) { in createView()
246 private static View createView(Aggregation aggregation, Measure measure) { in createView()
254 Aggregation aggregation = view.getAggregation(); in aggregationAndAggregationDataMismatch()
283 private static final Aggregation DISTRIBUTION = Distribution.create(BUCKET_BOUNDARIES);
/external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/stats/
DRecordUtils.java31 import io.opencensus.stats.Aggregation;
32 import io.opencensus.stats.Aggregation.Count;
33 import io.opencensus.stats.Aggregation.Distribution;
34 import io.opencensus.stats.Aggregation.LastValue;
35 import io.opencensus.stats.Aggregation.Sum;
103 Aggregation aggregation, final Measure measure) { in createMutableAggregation()
198 implements Function<Aggregation, MutableAggregation> {
200 public MutableAggregation apply(Aggregation arg) {
201 if (arg instanceof Aggregation.Mean) {
DMetricUtils.java26 import io.opencensus.stats.Aggregation;
63 static Type getType(Measure measure, Aggregation aggregation) { in getType()
106 private static final Function<Aggregation, Type> AGGREGATION_TYPE_DEFAULT_FUNCTION =
107 new Function<Aggregation, Type>() {
109 public Type apply(Aggregation arg) {
110 if (arg instanceof Aggregation.Mean) {
DIntervalBucket.java25 import io.opencensus.stats.Aggregation;
42 private final Aggregation aggregation;
47 IntervalBucket(Timestamp start, Duration duration, Aggregation aggregation, Measure measure) { in IntervalBucket()
DMutableViewData.java41 import io.opencensus.stats.Aggregation;
354 Aggregation aggregation = super.view.getAggregation(); in combineBucketsAndGetAggregationMap()
367 Aggregation aggregation, in putBucketsIntoMultiMap()
400 Aggregation aggregation, in putFractionalMutableAggregationsToMultiMap()
414 Multimap<T, MutableAggregation> multimap, Aggregation aggregation, Measure measure) { in aggregateOnEachTagValueList()
/external/opencensus-java/contrib/http_util/src/main/java/io/opencensus/contrib/http/util/
DHttpViewConstants.java33 import io.opencensus.stats.Aggregation;
34 import io.opencensus.stats.Aggregation.Count;
35 import io.opencensus.stats.Aggregation.Distribution;
53 @VisibleForTesting static final Aggregation COUNT = Count.create();
56 static final Aggregation SIZE_DISTRIBUTION =
77 static final Aggregation LATENCY_DISTRIBUTION =
/external/opencensus-java/exporters/stats/stackdriver/src/main/java/io/opencensus/exporter/stats/stackdriver/
DStackdriverExportUtils.java47 import io.opencensus.stats.Aggregation;
48 import io.opencensus.stats.Aggregation.LastValue;
104 private static final Function<Aggregation, MetricDescriptor.ValueType> valueTypeMeanFunction =
105 new Function<Aggregation, MetricDescriptor.ValueType>() {
107 public MetricDescriptor.ValueType apply(Aggregation arg) {
111 if (arg instanceof Aggregation.Mean) {
258 static MetricKind createMetricKind(View.AggregationWindow window, Aggregation aggregation) { in createMetricKind()
271 static String createUnit(Aggregation aggregation, final Measure measure) { in createUnit()
272 if (aggregation instanceof Aggregation.Count) { in createUnit()
281 Aggregation aggregation, final Measure measure) { in createValueType()
[all …]
/external/opencensus-java/exporters/stats/prometheus/src/main/java/io/opencensus/exporter/stats/prometheus/
DPrometheusExportUtils.java26 import io.opencensus.stats.Aggregation;
27 import io.opencensus.stats.Aggregation.Count;
28 import io.opencensus.stats.Aggregation.Distribution;
29 import io.opencensus.stats.Aggregation.Sum;
132 static Type getType(Aggregation aggregation, View.AggregationWindow window) { in getType()
141 new Function<Aggregation, Type>() { in getType()
143 public Type apply(Aggregation arg) { in getType()
144 if (arg instanceof Aggregation.Mean) { in getType()
160 final Aggregation aggregation) {
/external/opencensus-java/exporters/stats/signalfx/src/main/java/io/opencensus/exporter/stats/signalfx/
DSignalFxSessionAdaptor.java27 import io.opencensus.stats.Aggregation;
91 Aggregation aggregation, View.AggregationWindow window) { in getMetricTypeForAggregation()
92 if (aggregation instanceof Aggregation.Mean || aggregation instanceof Aggregation.LastValue) { in getMetricTypeForAggregation()
94 } else if (aggregation instanceof Aggregation.Count || aggregation instanceof Aggregation.Sum) { in getMetricTypeForAggregation()
/external/opencensus-java/impl_core/src/test/java/io/opencensus/implcore/stats/
DRecordUtilsTest.java23 import io.opencensus.stats.Aggregation.Count;
24 import io.opencensus.stats.Aggregation.Distribution;
25 import io.opencensus.stats.Aggregation.LastValue;
26 import io.opencensus.stats.Aggregation.Mean;
27 import io.opencensus.stats.Aggregation.Sum;
DMetricUtilsTest.java27 import io.opencensus.stats.Aggregation.Count;
28 import io.opencensus.stats.Aggregation.Distribution;
29 import io.opencensus.stats.Aggregation.LastValue;
30 import io.opencensus.stats.Aggregation.Mean;
31 import io.opencensus.stats.Aggregation.Sum;
/external/opencensus-java/contrib/zpages/src/main/java/io/opencensus/contrib/zpages/
DStatszZPageHandler.java31 import io.opencensus.stats.Aggregation;
32 import io.opencensus.stats.Aggregation.Count;
33 import io.opencensus.stats.Aggregation.Distribution;
34 import io.opencensus.stats.Aggregation.LastValue;
35 import io.opencensus.stats.Aggregation.Sum;
331 new Function<Aggregation, String>() { in emitViewInfo()
333 public String apply(Aggregation arg) { in emitViewInfo()
339 if (arg instanceof Aggregation.Mean) { in emitViewInfo()
426 new Function<Aggregation, Void>() { in emitViewDataTableHeader()
428 public Void apply(Aggregation arg) { in emitViewDataTableHeader()
[all …]
/external/opencensus-java/contrib/grpc_metrics/src/main/java/io/opencensus/contrib/grpc/metrics/
DRpcViewConstants.java63 import io.opencensus.stats.Aggregation;
64 import io.opencensus.stats.Aggregation.Count;
65 import io.opencensus.stats.Aggregation.Distribution;
126 @VisibleForTesting static final Aggregation MEAN = Aggregation.Mean.create();
127 @VisibleForTesting static final Aggregation COUNT = Count.create();
130 static final Aggregation AGGREGATION_WITH_BYTES_HISTOGRAM =
134 static final Aggregation AGGREGATION_WITH_MILLIS_HISTOGRAM =
137 static final Aggregation AGGREGATION_WITH_MILLIS_HISTOGRAM_DEPRECATED =
141 static final Aggregation AGGREGATION_WITH_COUNT_HISTOGRAM =
/external/grpc-grpc/src/cpp/server/load_reporter/
Dload_reporter.cc52 .set_aggregation(::opencensus::stats::Aggregation::Sum()) in CensusViewProvider()
71 .set_aggregation(::opencensus::stats::Aggregation::Sum()) in CensusViewProvider()
86 .set_aggregation(::opencensus::stats::Aggregation::Sum()) in CensusViewProvider()
101 .set_aggregation(::opencensus::stats::Aggregation::Sum()) in CensusViewProvider()
116 .set_aggregation(::opencensus::stats::Aggregation::Sum()) in CensusViewProvider()
132 .set_aggregation(::opencensus::stats::Aggregation::Count()) in CensusViewProvider()
147 .set_aggregation(::opencensus::stats::Aggregation::Sum()) in CensusViewProvider()
/external/opencensus-java/contrib/zpages/src/test/java/io/opencensus/contrib/zpages/
DStatszZPageHandlerTest.java37 import io.opencensus.stats.Aggregation;
38 import io.opencensus.stats.Aggregation.Sum;
228 new Function<Aggregation, String>() { in assertContainsViewData()
230 public String apply(Aggregation arg) { in assertContainsViewData()
231 if (arg instanceof Aggregation.Mean) { in assertContainsViewData()
/external/grpc-grpc/test/cpp/ext/filters/census/
Dstats_plugin_end2end_test.cc38 using ::opencensus::stats::Aggregation;
105 .set_aggregation(Aggregation::Count()) in TEST_F()
112 .set_aggregation(Aggregation::Count()) in TEST_F()
120 .set_aggregation(Aggregation::Count()) in TEST_F()
127 .set_aggregation(Aggregation::Count()) in TEST_F()
/external/opencensus-java/exporters/stats/prometheus/src/test/java/io/opencensus/exporter/stats/prometheus/
DPrometheusExportUtilsTest.java29 import io.opencensus.stats.Aggregation.Count;
30 import io.opencensus.stats.Aggregation.Distribution;
31 import io.opencensus.stats.Aggregation.LastValue;
32 import io.opencensus.stats.Aggregation.Mean;
33 import io.opencensus.stats.Aggregation.Sum;
/external/opencensus-java/contrib/grpc_metrics/src/test/java/io/opencensus/contrib/grpc/metrics/
DRpcViewConstantsTest.java22 import io.opencensus.stats.Aggregation.Count;
23 import io.opencensus.stats.Aggregation.Distribution;
24 import io.opencensus.stats.Aggregation.Mean;

12