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
All Methods Static Methods Instance Methods Concrete Methods 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)
-
-
-
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
-
-
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()
-
-