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

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 empty MutableAggregation based on the given Aggregation.
(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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

RPC_TAG_MAPPINGS

private static final java.util.Map<TagKey,TagKey[]> RPC_TAG_MAPPINGS

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

Constructor Detail

RecordUtils

private RecordUtils()

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 empty MutableAggregation based on the given Aggregation.

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)