1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
/*
* Copyright 2018, OpenCensus Authors
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.opencensus.implcore.stats;
import static com.google.common.truth.Truth.assertThat;
import com.google.common.collect.ImmutableMap;
import io.opencensus.implcore.stats.MutableAggregation.MutableDistribution;
import io.opencensus.stats.Aggregation.Count;
import io.opencensus.stats.Aggregation.Distribution;
import io.opencensus.stats.Aggregation.LastValue;
import io.opencensus.stats.Aggregation.Mean;
import io.opencensus.stats.Aggregation.Sum;
import io.opencensus.stats.AggregationData.CountData;
import io.opencensus.stats.AggregationData.LastValueDataDouble;
import io.opencensus.stats.AggregationData.LastValueDataLong;
import io.opencensus.stats.AggregationData.MeanData;
import io.opencensus.stats.AggregationData.SumDataDouble;
import io.opencensus.stats.AggregationData.SumDataLong;
import io.opencensus.stats.BucketBoundaries;
import io.opencensus.stats.Measure.MeasureDouble;
import io.opencensus.stats.Measure.MeasureLong;
import io.opencensus.tags.TagKey;
import io.opencensus.tags.TagValue;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.junit.runners.JUnit4;
/** Tests for {@link RecordUtils}. */
@RunWith(JUnit4.class)
public class RecordUtilsTest {
private static final double EPSILON = 1e-7;
private static final MeasureDouble MEASURE_DOUBLE =
MeasureDouble.create("measure1", "description", "1");
private static final MeasureLong MEASURE_LONG =
MeasureLong.create("measure2", "description", "1");
private static final TagKey ORIGINATOR = TagKey.create("originator");
private static final TagKey CALLER = TagKey.create("caller");
private static final TagKey METHOD = TagKey.create("method");
private static final TagValue CALLER_V = TagValue.create("some caller");
private static final TagValue METHOD_V = TagValue.create("some method");
@Test
public void testConstants() {
assertThat(RecordUtils.UNKNOWN_TAG_VALUE).isNull();
}
@Test
public void testGetTagValues() {
List<TagKey> columns = Arrays.asList(CALLER, METHOD, ORIGINATOR);
Map<TagKey, TagValue> tags = ImmutableMap.of(CALLER, CALLER_V, METHOD, METHOD_V);
assertThat(RecordUtils.getTagValues(tags, columns))
.containsExactly(CALLER_V, METHOD_V, RecordUtils.UNKNOWN_TAG_VALUE)
.inOrder();
}
@Test
public void createMutableAggregation() {
BucketBoundaries bucketBoundaries = BucketBoundaries.create(Arrays.asList(-1.0, 0.0, 1.0));
assertThat(
RecordUtils.createMutableAggregation(Sum.create(), MEASURE_DOUBLE).toAggregationData())
.isEqualTo(SumDataDouble.create(0));
assertThat(RecordUtils.createMutableAggregation(Sum.create(), MEASURE_LONG).toAggregationData())
.isEqualTo(SumDataLong.create(0));
assertThat(
RecordUtils.createMutableAggregation(Count.create(), MEASURE_DOUBLE)
.toAggregationData())
.isEqualTo(CountData.create(0));
assertThat(
RecordUtils.createMutableAggregation(Count.create(), MEASURE_LONG).toAggregationData())
.isEqualTo(CountData.create(0));
assertThat(
RecordUtils.createMutableAggregation(Mean.create(), MEASURE_DOUBLE).toAggregationData())
.isEqualTo(MeanData.create(0, 0));
assertThat(
RecordUtils.createMutableAggregation(Mean.create(), MEASURE_LONG).toAggregationData())
.isEqualTo(MeanData.create(0, 0));
assertThat(
RecordUtils.createMutableAggregation(LastValue.create(), MEASURE_DOUBLE)
.toAggregationData())
.isEqualTo(LastValueDataDouble.create(Double.NaN));
assertThat(
RecordUtils.createMutableAggregation(LastValue.create(), MEASURE_LONG)
.toAggregationData())
.isEqualTo(LastValueDataLong.create(0));
MutableDistribution mutableDistribution =
(MutableDistribution)
RecordUtils.createMutableAggregation(
Distribution.create(bucketBoundaries), MEASURE_DOUBLE);
assertThat(mutableDistribution.getMin()).isPositiveInfinity();
assertThat(mutableDistribution.getMax()).isNegativeInfinity();
assertThat(mutableDistribution.getSumOfSquaredDeviations()).isWithin(EPSILON).of(0);
assertThat(mutableDistribution.getBucketCounts()).isEqualTo(new long[4]);
}
}
|
