Class RecordUtils

java.lang.Object

io.opencensus.implcore.stats.RecordUtils

final class RecordUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	RecordUtils.AggregationDefaultFunction
private static final class	RecordUtils.CreateMutableCount
private static final class	RecordUtils.CreateMutableDistribution
private static final class	RecordUtils.CreateMutableLastValueDouble
private static final class	RecordUtils.CreateMutableLastValueLong
private static final class	RecordUtils.CreateMutableSumDouble
private static final class	RecordUtils.CreateMutableSumLong

Field Summary

Fields

Modifier and Type	Field	Description
private static final Function<Measurement.MeasurementDouble, Double>	GET_VALUE_FROM_MEASUREMENT_DOUBLE
private static final Function<Measurement.MeasurementLong, Double>	GET_VALUE_FROM_MEASUREMENT_LONG
(package private) static final TagKey	GRPC_CLIENT_METHOD
(package private) static final TagKey	GRPC_CLIENT_STATUS
(package private) static final TagKey	GRPC_SERVER_METHOD
(package private) static final TagKey	GRPC_SERVER_STATUS
(package private) static final TagKey	RPC_METHOD
(package private) static final TagKey	RPC_STATUS
private static final Map<TagKey,TagKey[]>	RPC_TAG_MAPPINGS
(package private) static final TagValue	UNKNOWN_TAG_VALUE

Constructor Summary

Constructors

Modifier	Constructor	Description
private	RecordUtils()

Method Summary

Modifier and Type	Method	Description
(package private) static <T> Map<T, AggregationData>	createAggregationMap(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 Map<TagKey, TagValueWithMetadata>	getTagMap(TagContext ctx)
private static TagValue	getTagValueForDeprecatedRpcTag(Map<? extends TagKey, TagValueWithMetadata> tags, TagKey[] newKeys)
(package private) static List<TagValue>	getTagValues(Map<? extends TagKey, TagValueWithMetadata> tags, List<? extends TagKey> columns)

Methods inherited from class Object

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

Field Details

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 Map<TagKey,TagKey[]> RPC_TAG_MAPPINGS

GET_VALUE_FROM_MEASUREMENT_DOUBLE

private static final Function<Measurement.MeasurementDouble, Double> GET_VALUE_FROM_MEASUREMENT_DOUBLE

GET_VALUE_FROM_MEASUREMENT_LONG

private static final Function<Measurement.MeasurementLong, Double> GET_VALUE_FROM_MEASUREMENT_LONG

Constructor Details

RecordUtils

private RecordUtils()

Method Details

getTagMap

static Map<TagKey, TagValueWithMetadata> getTagMap(TagContext ctx)

getTagValues

static List<TagValue> getTagValues(Map<? extends TagKey, TagValueWithMetadata> tags,
 List<? extends TagKey> columns)

getTagValueForDeprecatedRpcTag

@Nullable
private static TagValue getTagValueForDeprecatedRpcTag(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> Map<T, AggregationData> createAggregationMap(Map<T, MutableAggregation> tagValueAggregationMap,
 Measure measure)

getDoubleValueFromMeasurement

static double getDoubleValueFromMeasurement(Measurement measurement)