Package io.opencensus.implcore.trace.export

Class InProcessSampledSpanStoreImpl.Bucket

java.lang.Object

io.opencensus.implcore.trace.export.InProcessSampledSpanStoreImpl.Bucket

Enclosing class:

InProcessSampledSpanStoreImpl

private static final class InProcessSampledSpanStoreImpl.Bucket
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
private long	lastNotSampledNanoTime
private long	lastSampledNanoTime
private com.google.common.collect.EvictingQueue<RecordEventsSpanImpl>	notSampledSpansQueue
private com.google.common.collect.EvictingQueue<RecordEventsSpanImpl>	sampledSpansQueue

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Bucket(int numSamples)

Method Summary

Modifier and Type	Method	Description
private void	considerForSampling(RecordEventsSpanImpl span)
private int	getNumSamples()
private void	getSamples(int maxSpansToReturn, java.util.List<RecordEventsSpanImpl> output)
private static void	getSamples(int maxSpansToReturn, java.util.List<RecordEventsSpanImpl> output, com.google.common.collect.EvictingQueue<RecordEventsSpanImpl> queue)
private void	getSamplesFilteredByLatency(long latencyLowerNs, long latencyUpperNs, int maxSpansToReturn, java.util.List<RecordEventsSpanImpl> output)
private static void	getSamplesFilteredByLatency(long latencyLowerNs, long latencyUpperNs, int maxSpansToReturn, java.util.List<RecordEventsSpanImpl> output, com.google.common.collect.EvictingQueue<RecordEventsSpanImpl> queue)

Methods inherited from class java.lang.Object

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

Field Detail

sampledSpansQueue

private final com.google.common.collect.EvictingQueue<RecordEventsSpanImpl> sampledSpansQueue

notSampledSpansQueue

private final com.google.common.collect.EvictingQueue<RecordEventsSpanImpl> notSampledSpansQueue

lastSampledNanoTime

private long lastSampledNanoTime

lastNotSampledNanoTime

private long lastNotSampledNanoTime

Constructor Detail

Bucket

private Bucket(int numSamples)

Method Detail

considerForSampling

private void considerForSampling(RecordEventsSpanImpl span)

getSamples

private void getSamples(int maxSpansToReturn,
                        java.util.List<RecordEventsSpanImpl> output)

getSamples

private static void getSamples(int maxSpansToReturn,
                               java.util.List<RecordEventsSpanImpl> output,
                               com.google.common.collect.EvictingQueue<RecordEventsSpanImpl> queue)

getSamplesFilteredByLatency

private void getSamplesFilteredByLatency(long latencyLowerNs,
                                         long latencyUpperNs,
                                         int maxSpansToReturn,
                                         java.util.List<RecordEventsSpanImpl> output)

getSamplesFilteredByLatency

private static void getSamplesFilteredByLatency(long latencyLowerNs,
                                                long latencyUpperNs,
                                                int maxSpansToReturn,
                                                java.util.List<RecordEventsSpanImpl> output,
                                                com.google.common.collect.EvictingQueue<RecordEventsSpanImpl> queue)

getNumSamples

private int getNumSamples()