Package io.opencensus.implcore.stats
Class RecordUtils
- java.lang.Object
-
- io.opencensus.implcore.stats.RecordUtils
-
final class RecordUtils extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private static class
RecordUtils.AggregationDefaultFunction
private static class
RecordUtils.CreateMutableCount
private static class
RecordUtils.CreateMutableDistribution
private static class
RecordUtils.CreateMutableLastValueDouble
private static class
RecordUtils.CreateMutableLastValueLong
private static class
RecordUtils.CreateMutableSumDouble
private static class
RecordUtils.CreateMutableSumLong
-
Field Summary
Fields Modifier and Type Field Description private static Function<Measurement.MeasurementDouble,java.lang.Double>
GET_VALUE_FROM_MEASUREMENT_DOUBLE
private static Function<Measurement.MeasurementLong,java.lang.Double>
GET_VALUE_FROM_MEASUREMENT_LONG
(package private) static TagKey
GRPC_CLIENT_METHOD
(package private) static TagKey
GRPC_CLIENT_STATUS
(package private) static TagKey
GRPC_SERVER_METHOD
(package private) static TagKey
GRPC_SERVER_STATUS
(package private) static TagKey
RPC_METHOD
(package private) static TagKey
RPC_STATUS
private static java.util.Map<TagKey,TagKey[]>
RPC_TAG_MAPPINGS
(package private) static TagValue
UNKNOWN_TAG_VALUE
-
Constructor Summary
Constructors Modifier Constructor Description private
RecordUtils()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description (package private) static <T> java.util.Map<T,AggregationData>
createAggregationMap(java.util.Map<T,MutableAggregation> tagValueAggregationMap, Measure measure)
(package private) static MutableAggregation
createMutableAggregation(Aggregation aggregation, Measure measure)
Create an emptyMutableAggregation
based on the givenAggregation
.(package private) static double
getDoubleValueFromMeasurement(Measurement measurement)
(package private) static java.util.Map<TagKey,TagValueWithMetadata>
getTagMap(TagContext ctx)
private static TagValue
getTagValueForDeprecatedRpcTag(java.util.Map<? extends TagKey,TagValueWithMetadata> tags, TagKey[] newKeys)
(package private) static java.util.List<TagValue>
getTagValues(java.util.Map<? extends TagKey,TagValueWithMetadata> tags, java.util.List<? extends TagKey> columns)
-
-
-
Field Detail
-
UNKNOWN_TAG_VALUE
@Nullable static final TagValue UNKNOWN_TAG_VALUE
-
RPC_STATUS
static final TagKey RPC_STATUS
-
RPC_METHOD
static final TagKey RPC_METHOD
-
GRPC_CLIENT_STATUS
static final TagKey GRPC_CLIENT_STATUS
-
GRPC_CLIENT_METHOD
static final TagKey GRPC_CLIENT_METHOD
-
GRPC_SERVER_STATUS
static final TagKey GRPC_SERVER_STATUS
-
GRPC_SERVER_METHOD
static final TagKey GRPC_SERVER_METHOD
-
GET_VALUE_FROM_MEASUREMENT_DOUBLE
private static final Function<Measurement.MeasurementDouble,java.lang.Double> GET_VALUE_FROM_MEASUREMENT_DOUBLE
-
GET_VALUE_FROM_MEASUREMENT_LONG
private static final Function<Measurement.MeasurementLong,java.lang.Double> GET_VALUE_FROM_MEASUREMENT_LONG
-
-
Method Detail
-
getTagMap
static java.util.Map<TagKey,TagValueWithMetadata> getTagMap(TagContext ctx)
-
getTagValues
static java.util.List<TagValue> getTagValues(java.util.Map<? extends TagKey,TagValueWithMetadata> tags, java.util.List<? extends TagKey> columns)
-
getTagValueForDeprecatedRpcTag
@Nullable private static TagValue getTagValueForDeprecatedRpcTag(java.util.Map<? extends TagKey,TagValueWithMetadata> tags, TagKey[] newKeys)
-
createMutableAggregation
static MutableAggregation createMutableAggregation(Aggregation aggregation, Measure measure)
Create an emptyMutableAggregation
based on the givenAggregation
.- Parameters:
aggregation
-Aggregation
.- Returns:
- an empty
MutableAggregation
.
-
createAggregationMap
static <T> java.util.Map<T,AggregationData> createAggregationMap(java.util.Map<T,MutableAggregation> tagValueAggregationMap, Measure measure)
-
getDoubleValueFromMeasurement
static double getDoubleValueFromMeasurement(Measurement measurement)
-
-