Class MutableViewData.IntervalMutableViewData

java.lang.Object

io.opencensus.implcore.stats.MutableViewData

io.opencensus.implcore.stats.MutableViewData.IntervalMutableViewData

Enclosing class:

MutableViewData

private static final class MutableViewData.IntervalMutableViewData
extends MutableViewData

Field Summary

Fields

Modifier and Type	Field	Description
private final Duration	bucketDuration
private final ArrayDeque<IntervalBucket>	buckets
private static final int	N
private final Duration	totalDuration

Fields inherited from class MutableViewData

ZERO_TIMESTAMP

Constructor Summary

Constructors

Modifier	Constructor	Description
private	IntervalMutableViewData(View view, Timestamp start)

Method Summary

Modifier and Type	Method	Description
private static <T> Map<T, MutableAggregation>	aggregateOnEachTagValueList(com.google.common.collect.Multimap<T, MutableAggregation> multimap, Aggregation aggregation, Measure measure)
(package private) void	clearStats()
private Map<List<TagValue>, AggregationData>	combineBucketsAndGetAggregationMap(Timestamp now)
private static void	putBucketsIntoMultiMap(ArrayDeque<IntervalBucket> buckets, com.google.common.collect.Multimap<List<TagValue>, MutableAggregation> multimap, Aggregation aggregation, Measure measure, Timestamp now)
private static <T> void	putFractionalMutableAggregationsToMultiMap(Map<T, MutableAggregation> mutableAggrMap, com.google.common.collect.Multimap<T, MutableAggregation> multimap, Aggregation aggregation, Measure measure, double fraction)
(package private) void	record(TagContext context, double value, Timestamp timestamp, Map<String, AttachmentValue> attachments)	Record stats with the given tags.
private void	refreshBucketList(Timestamp now)
(package private) void	resumeStatsCollection(Timestamp now)
private void	shiftBucketList(long numOfPadBuckets, Timestamp now)
private static Timestamp	subtractDuration(Timestamp timestamp, Duration duration)
(package private) Metric	toMetric(Timestamp now, CurrentState.State state)
(package private) ViewData	toViewData(Timestamp now, CurrentState.State state)	Convert this MutableViewData to ViewData.

Methods inherited from class MutableViewData

create, getView

Methods inherited from class Object

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

Field Details

N

private static final int N

See Also:

• Constant Field Values

buckets

private final ArrayDeque<IntervalBucket> buckets

totalDuration

private final Duration totalDuration

bucketDuration

private final Duration bucketDuration

Constructor Details

IntervalMutableViewData

private IntervalMutableViewData(View view,
 Timestamp start)

Method Details

toMetric

@Nullable
Metric toMetric(Timestamp now,
 CurrentState.State state)

Specified by:

toMetric in class MutableViewData

record

void record(TagContext context,
 double value,
 Timestamp timestamp,
 Map<String, AttachmentValue> attachments)

Description copied from class: MutableViewData

Record stats with the given tags.

Specified by:

record in class MutableViewData

toViewData

ViewData toViewData(Timestamp now,
 CurrentState.State state)

Description copied from class: MutableViewData

Convert this MutableViewData to ViewData.

Specified by:

toViewData in class MutableViewData

clearStats

void clearStats()

Specified by:

clearStats in class MutableViewData

resumeStatsCollection

void resumeStatsCollection(Timestamp now)

Specified by:

resumeStatsCollection in class MutableViewData

refreshBucketList

private void refreshBucketList(Timestamp now)

shiftBucketList

private void shiftBucketList(long numOfPadBuckets,
 Timestamp now)

combineBucketsAndGetAggregationMap

private Map<List<TagValue>, AggregationData> combineBucketsAndGetAggregationMap(Timestamp now)

putBucketsIntoMultiMap

private static void putBucketsIntoMultiMap(ArrayDeque<IntervalBucket> buckets,
 com.google.common.collect.Multimap<List<TagValue>, MutableAggregation> multimap,
 Aggregation aggregation,
 Measure measure,
 Timestamp now)

putFractionalMutableAggregationsToMultiMap

private static <T> void putFractionalMutableAggregationsToMultiMap(Map<T, MutableAggregation> mutableAggrMap,
 com.google.common.collect.Multimap<T, MutableAggregation> multimap,
 Aggregation aggregation,
 Measure measure,
 double fraction)

aggregateOnEachTagValueList

private static <T> Map<T, MutableAggregation> aggregateOnEachTagValueList(com.google.common.collect.Multimap<T, MutableAggregation> multimap,
 Aggregation aggregation,
 Measure measure)

subtractDuration

private static Timestamp subtractDuration(Timestamp timestamp,
 Duration duration)