Dependencies
Declarations
-
org
-
terracotta
-
context
-
AbstractTreeNode
- children: CopyOnWriteArraySet<AbstractTreeNode>
- addChild(AbstractTreeNode): boolean
- removeChild(AbstractTreeNode): boolean
- getChildren(): Set<AbstractTreeNode>
- getPath(): List<TreeNode>
- toTreeString(): String
- dumpSubtree(int, TreeNode): String
- addedParent(AbstractTreeNode): void
- removedParent(AbstractTreeNode): void
- getAncestors(): Set<AbstractTreeNode>
- getListeners(): Collection<ContextListener>
- clean(): void
- ContextAwareTreeNode
- ContextCreationListener
- ContextElement
- ContextListener
-
ContextManager
- LOGGER: Logger
- CONTEXT_OBJECTS: WeakIdentityHashMap<Object, MutableTreeNode>
- contextCreationListeners: Collection<ContextCreationListener>
- root: RootNode
- associate(Object): Association
- dissociate(Object): Dissociation
- nodeFor(Object): TreeNode
- registerContextCreationListener(ContextCreationListener): void
- deregisterContextCreationListener(ContextCreationListener): void
- associate(Object, Object): void
- dissociate(Object, Object): void
- getTreeNode(Object): MutableTreeNode
- getOrCreateTreeNode(Object): MutableTreeNode
- discoverAssociations(Object): void
- contextCreated(Object): void
- root(Object): void
- uproot(Object): void
- query(Query): Set<TreeNode>
- queryForSingleton(Query): TreeNode
- registerContextListener(ContextListener): void
- deregisterContextListener(ContextListener): void
- Association
- Dissociation
-
MutableTreeNode
- parents: CopyOnWriteArraySet<AbstractTreeNode>
- context: ContextElement
- MutableTreeNode(ContextElement): void
- getContext(): ContextElement
- toString(): String
- getAncestors(): Set<AbstractTreeNode>
- getListeners(): Collection<ContextListener>
- addedParent(AbstractTreeNode): void
- removedParent(AbstractTreeNode): void
- getPaths(): Collection<List<TreeNode>>
-
RootNode
- listeners: Collection<ContextListener>
- addedParent(AbstractTreeNode): void
- removedParent(AbstractTreeNode): void
- getAncestors(): Set<AbstractTreeNode>
- getListeners(): Collection<ContextListener>
- addListener(ContextListener): void
- removeListener(ContextListener): void
- getContext(): ContextElement
- getPaths(): Collection<List<TreeNode>>
- TreeNode
- WeakIdentityHashMap
- annotations
-
extractor
- AttributeGetter
- DirectAttributeGetter
- FieldAttributeGetter
- LazyContextElement
- MethodAttributeGetter
-
ObjectContextExtractor
- ObjectContextExtractor(): void
- extract(Object): ContextElement
- extractInstanceAttribute(Object): Map<String, AttributeGetter>
- extractMethodAttributes(Object): Map<String, AttributeGetter<Object>>
- extractFieldAttributes(Object): Map<String, AttributeGetter<Object>>
- createFieldAttributeGetter(Object, Field): AttributeGetter<Object>
- WeakAttributeGetter
- WeakFieldAttributeGetter
- WeakMethodAttributeGetter
-
query
- ChainedQuery
- Children
- Descendants
- EmptyQuery
- EnsureUnique
- Filter
- Matcher
-
Matchers
- Matchers(): void
- context(Matcher<ContextElement>): Matcher<TreeNode>
- attributes(Matcher<Map<String, Object>>): Matcher<ContextElement>
- identifier(Matcher<Class<Object>>): Matcher<ContextElement>
- subclassOf(Class<Object>): Matcher<Class<Object>>
- hasAttribute(String, Object): Matcher<Map<String, Object>>
- hasAttribute(String, Matcher<Object>): Matcher<Map<String, Object>>
- anyOf(Matcher[]): Matcher<Object>
- allOf(Matcher[]): Matcher<Object>
- not(Matcher<Object>): Matcher<Object>
- NullQuery
- Parent
- Queries
- Query
- QueryBuilder
-
AbstractTreeNode
-
statistics
- AbstractOperationStatistic
- AbstractSourceStatistic
- ConstantValueStatistic
- GeneralOperationStatistic
-
MappedOperationStatistic
- name: String
- tags: Set<String>
- properties: Map<String, Object>
- outcomeType: Class<Enum>
- mapper: StatisticMapper<Enum, Enum>
- MappedOperationStatistic(Object, Map<Enum, Set<Enum>>, String, int, String, String): void
- type(): Class<Enum>
- statistic(Enum): ValueStatistic<Long>
- statistic(Set<Enum>): ValueStatistic<Long>
- count(Enum): long
- sum(Set<Enum>): long
- sum(): long
- addDerivedStatistic(ChainedOperationObserver<Enum>): void
- removeDerivedStatistic(ChainedOperationObserver<Enum>): void
- getDerivedStatistics(): Collection<ChainedOperationObserver<Enum>>
- begin(): void
- end(Enum): void
- findOperationStat(Object, Class<Enum>, String): OperationStatistic<Enum>
- MemoizingValueStatistic
- OperationStatistic
-
PassThroughStatistic
- BINDING: WeakIdentityHashMap<Object, Collection<PassThroughStatistic<Serializable>>>
- bindStatistic(PassThroughStatistic<Serializable>, Object): void
- removeStatistics(Object): void
- hasStatisticsFor(Object): boolean
- name: String
- tags: Set<String>
- properties: Map<String, Object>
- type: StatisticType
- source: ValueStatistic<Serializable>
- PassThroughStatistic(Object, String, Set<String>, Map<String, Object>, ValueStatistic<Serializable>): void
- value(): Serializable
- type(): StatisticType
- Sample
- SampledStatistic
-
SampledStatisticAdapter
- timeSource: LongSupplier
- statistic: ValueStatistic<Serializable>
- SampledStatisticAdapter(ValueStatistic<Serializable>, LongSupplier): void
- value(): Serializable
- history(): List<Sample<Serializable>>
- history(long): List<Sample<Serializable>>
- type(): StatisticType
- sample(ValueStatistic<Serializable>, LongSupplier): SampledStatistic<Serializable>
- SourceStatistic
- Statistic
- StatisticBuilder
-
StatisticMapper
- targetType: Class<Enum>
- sourceType: Class<Enum>
- statistic: OperationStatistic<Enum>
- translation: Map<Enum, Set<Enum>>
- reverseTranslation: Map<Enum, Enum>
- derivedStats: ConcurrentMap<ChainedOperationObserver<Enum>, ChainedOperationObserver<Enum>>
- StatisticMapper(Map<Enum, Set<Enum>>, OperationStatistic<Enum>): void
- reverse(Map<Enum, Set<Enum>>): Map<Enum, Enum>
- type(): Class<Enum>
- statistic(Enum): ValueStatistic<Long>
- statistic(Set<Enum>): ValueStatistic<Long>
- count(Enum): long
- sum(Set<Enum>): long
- sum(): long
- addDerivedStatistic(ChainedOperationObserver<Enum>): void
- removeDerivedStatistic(ChainedOperationObserver<Enum>): void
- getDerivedStatistics(): Collection<ChainedOperationObserver<Enum>>
- begin(): void
- end(Enum): void
- StatisticType
-
StatisticsManager
- EQ: String
- static class initializer
- createOperationStatistic(Object, String, Set<String>, Class<Enum>): OperationObserver<Enum>
- createOperationStatistic(Object, String, Set<String>, Map<String, Object>, Class<Enum>): OperationObserver<Enum>
- createOperationStatistic(String, Set<String>, Map<String, Object>, Class<Enum>): OperationStatistic<Enum>
- getOperationStatisticFor(OperationObserver<Enum>): OperationStatistic<Enum>
- createPassThroughStatistic(Object, String, Set<String>, StatisticType, Supplier<Serializable>): void
- createPassThroughStatistic(Object, String, Set<String>, ValueStatistic<Serializable>): void
- createPassThroughStatistic(Object, String, Set<String>, Map<String, Object>, StatisticType, Supplier<Serializable>): void
- createPassThroughStatistic(Object, String, Set<String>, Map<String, Object>, ValueStatistic<Serializable>): void
- removePassThroughStatistics(Object): void
- tags(String[]): Set<String>
- parseStatisticAnnotations(Object): void
- properties(String[]): Map<String, String>
- ReflectionSupplier
- SuppliedValueStatistic
-
Table
- serialVersionUID: long
- newBuilder(String[]): Builder
- Table(String[]): void
- Builder
- RowBuilder
-
TableSkeleton
- serialVersionUID: long
- statistics: Map<String, ValueStatistic[]>
- innerStatisticNames: String[]
- TableSkeleton(String[]): void
- isEmpty(): boolean
- getRowCount(): int
- getRowLabels(): Collection<String>
- getStatisticNames(): String[]
- getStatisticCount(): int
- getStatistics(String): ValueStatistic[]
- getStatistics(): Map<String, ValueStatistic[]>
- getStatistic(String, String): Optional<ValueStatistic<Serializable>>
- toString(): String
- insert(String, String, StatisticType, Serializable): void
- insert(String, String, ValueStatistic<Serializable>): void
-
TableValueStatistic
- serialVersionUID: long
- newBuilder(String[]): Builder
- TableValueStatistic(String[]): void
- type(): StatisticType
- value(): Table
- Builder
- RowBuilder
- Time
- ValueStatistic
-
ValueStatistics
- nullValue(StatisticType): ConstantValueStatistic<Serializable>
- constant(StatisticType, Serializable): ConstantValueStatistic<Serializable>
- supply(StatisticType, Supplier<Serializable>): ValueStatistic<Serializable>
- gauge(Supplier<Number>): ValueStatistic<Number>
- counter(Supplier<Number>): ValueStatistic<Number>
- rate(Supplier<Number>): ValueStatistic<Number>
- ratio(Supplier<Number>): ValueStatistic<Number>
- table(Supplier<Table>): ValueStatistic<Table>
- memoize(long, TimeUnit, ValueStatistic<Serializable>): ValueStatistic<Serializable>
-
ZeroOperationStatistic
- INSTANCE: OperationStatistic<Enum>
- get(): OperationStatistic<Enum>
- type(): Class<Enum>
- count(Enum): long
- sum(Set<Enum>): long
- sum(): long
- addDerivedStatistic(ChainedOperationObserver<Enum>): void
- removeDerivedStatistic(ChainedOperationObserver<Enum>): void
- getDerivedStatistics(): Collection<ChainedOperationObserver<Enum>>
- begin(): void
- end(Enum): void
-
archive
- CircularBuffer
-
StatisticArchive
- TIMESTAMPED_COMPARATOR: Comparator<Sample<Serializable>>
- overspill: Consumer<Object>
- size: int
- buffer: CircularBuffer<Sample<Serializable>>
- StatisticArchive(int): void
- StatisticArchive(int, Consumer<Object>): void
- setCapacity(int): void
- add(Sample<Serializable>): void
- clear(): void
- getArchive(): List<Sample<Serializable>>
- getArchive(long): List<Sample<Serializable>>
-
StatisticSampler
- exclusiveExecutor: boolean
- executor: ScheduledExecutorService
- task: SamplingTask<Serializable>
- currentExecution: ScheduledFuture<Object>
- period: long
- StatisticSampler(long, TimeUnit, ValueStatistic<Serializable>, Consumer<Sample<Serializable>>, LongSupplier): void
- StatisticSampler(ScheduledExecutorService, long, TimeUnit, ValueStatistic<Serializable>, Consumer<Sample<Serializable>>, LongSupplier): void
- setPeriod(long, TimeUnit): void
- start(): void
- stop(): void
- shutdown(): void
- SamplingTask
- SamplerThreadFactory
-
derived
-
EventRateSimpleMovingAverage
- PARTITION_COUNT: int
- archive: Queue<CounterPartition>
- activePartition: AtomicReference<CounterPartition>
- windowSize: long
- partitionSize: long
- EventRateSimpleMovingAverage(long, TimeUnit): void
- setWindow(long, TimeUnit): void
- value(): Double
- type(): StatisticType
- rateUsingSeconds(): Double
- rate(TimeUnit): Double
- event(long, long): void
- archive(CounterPartition): void
- CounterPartition
- OperationResultFilter
- OperationResultSampler
-
histogram
-
BarSplittingBiasedHistogram
- DEFAULT_MAX_COEFFICIENT: double
- DEFAULT_PHI: double
- DEFAULT_EXPANSION_FACTOR: int
- DEFAULT_EXP_HISTOGRAM_EPSILON: double
- barCount: int
- bucketCount: int
- barEpsilon: double
- window: long
- phi: double
- alphaPhi: double
- ratio: double
- bars: List<Bar>
- maxSizeTable: double[]
- size: long
- BarSplittingBiasedHistogram(double, double, int, int, double, long): void
- BarSplittingBiasedHistogram(int, long): void
- BarSplittingBiasedHistogram(double, int, long): void
- event(double, long): void
- expire(long): void
- toString(): String
- getBuckets(): List<Bucket>
- nextUpIfEqual(double, double): double
- getMinimum(): double
- getMaximum(): double
- getQuantileBounds(double): double[]
- evaluateQuantileFromMax(double): double[]
- evaluateQuantileFromMin(double): double[]
- maxBarSize(int): double
- split(Bar, int): void
- mergeBars(): int
- getBarIndex(double): int
- size(): long
- bars(): List<Bar>
- alphaPhi(): double
- phi(): double
- bucketCount(): int
- Bar
-
ExponentialHistogram
- EMPTY_LONG_ARRAY: long[]
- epsilon: double
- mergeThreshold: int
- window: long
- boxes: long[]
- insert: int[]
- total: long
- last: long
- ExponentialHistogram(double, long): void
- ExponentialHistogram(double, int, long, int): void
- merge(ExponentialHistogram): void
- merge(long[], long): void
- insert(long, long): void
- makeBoxes(long, long): long[]
- tailedLCanonical(int, long): int[]
- lCanonical(int, long): int[]
- merge(long[], long[], int, int, long[]): long[]
- insert(long): void
- expire(long): long
- min_l(int): int
- max_l(int): int
- count(): long
- split(double): ExponentialHistogram
- transfer(long[], long[], int, int): void
- pull(long[], int, int): long[]
- doubleUp(long[]): long[]
- toString(): String
- reverseSort(long[]): int
- reverseSort(long[], int, int): int
- ensureCapacity(int): void
- initializeArrays(int): void
- epsilon(): double
- Histogram
- ImmutableBucket
-
Striped
- NCPU: int
- threadHash: ThreadLocal<Integer>
- Cell
- stripeGuard: AtomicInteger
- constructor: Supplier<Object>
- base: Cell<Object>
- cells: Cell[]
- advanceProbe(int): int
- Striped(Supplier<Object>): void
- stream(): Stream<Object>
- process(Consumer<Object>): void
- processWithContention(int, Consumer<Object>, boolean): void
- toString(): String
-
CellSpliterator
- array: Cell[]
- index: int
- limit: int
- CellSpliterator(Cell[]): void
- CellSpliterator(Cell[], int, int): void
- trySplit(): Spliterator<Cell<Object>>
- forEachRemaining(Consumer<Object>): void
- tryAdvance(Consumer<Object>): boolean
- visitCell(Cell<Object>, Consumer<Object>): void
- estimateSize(): long
- characteristics(): int
-
StripedHistogram
- StripedHistogram(double, double, int, int, double, long): void
- StripedHistogram(int, long): void
- StripedHistogram(double, int, long): void
- getBuckets(): List<Bucket>
- mergeBars(List<double[]>): void
- flatten(double[], double[]): List<double[]>
- getQuantileBounds(double): double[]
- evaluateQuantileFromMax(double): double[]
- evaluateQuantileFromMin(double): double[]
- size(): long
- event(double, long): void
- expire(long): void
-
BarSplittingBiasedHistogram
-
latency
-
DefaultLatencyHistogramStatistic
- histogram: BarSplittingBiasedHistogram
- timeSupplier: LongSupplier
- pruningDelay: long
- query: LatencyHistogramQuery
- nextPruning: long
- DefaultLatencyHistogramStatistic(double, int, Duration, LongSupplier): void
- DefaultLatencyHistogramStatistic(double, int, Duration): void
- buckets(): List<Bucket>
- count(): long
- minimum(): Long
- maximum(): Long
- percentile(double): Long
- percentileBounds(double): long[]
- event(long, long): void
- query(Function<LatencyHistogramQuery, Object>): Object
- toString(): String
- tryExpire(boolean, LongSupplier): void
- nullOrVal(double): Long
- Jsr107LatencyMonitor
-
LatencyAccumulator
- DEFAULT_MIN: long
- DEFAULT_MAX: long
- count: LongAdder
- total: LongAdder
- minimum: LongAccumulator
- maximum: LongAccumulator
- LatencyAccumulator(long[]): void
- accumulate(long): void
- accumulate(LatencyAccumulator): void
- count(): long
- total(): long
- isEmpty(): boolean
- event(long, long): void
- maximum(): Long
- minimum(): Long
- average(): double
- toString(): String
- accumulator(long[]): LatencyAccumulator
- empty(): LatencyAccumulator
- LatencyHistogramQuery
- LatencyHistogramStatistic
-
LatencyPeriodAccumulator
- accumulator: LatencyAccumulator
- start: long
- end: long
- LatencyPeriodAccumulator(long, long, long[]): void
- isBefore(long): boolean
- isAfter(long): boolean
- start(): long
- end(): long
- accumulator(): LatencyAccumulator
- tryAccumulate(long, long): boolean
- event(long, long): void
- minimum(): Long
- maximum(): Long
- average(): double
- toString(): String
-
LatencySimpleMovingAverage
- PARTITION_COUNT: int
- archive: Queue<LatencyPeriodAccumulator>
- activePartition: AtomicReference<LatencyPeriodAccumulator>
- windowSize: long
- partitionSize: long
- LatencySimpleMovingAverage(long, TimeUnit): void
- LatencySimpleMovingAverage(long, TimeUnit, int): void
- average(): double
- maximum(): Long
- minimum(): Long
- event(long, long): void
- archive(LatencyPeriodAccumulator): void
- LatencyStatistic
-
MaximumLatencyHistory
- timeSupplier: LongSupplier
- latestAccumulator: AtomicReference<LatencyPeriodAccumulator>
- archive: Queue<LatencyPeriodAccumulator>
- windowSizeNs: long
- sink: Consumer<LatencyPeriodAccumulator>
- drift: long
- MaximumLatencyHistory(int, long, TimeUnit, LongSupplier): void
- MaximumLatencyHistory(int, long, TimeUnit, LongSupplier, Consumer<LatencyPeriodAccumulator>): void
- event(long, long): void
- value(): Long
- type(): StatisticType
- history(): List<Sample<Long>>
- history(long): List<Sample<Long>>
- insert(LatencyPeriodAccumulator): void
-
DefaultLatencyHistogramStatistic
-
EventRateSimpleMovingAverage
- observer
-
registry
-
OperationStatisticDescriptor
- observerName: String
- tags: Set<String>
- type: Class<Enum>
- OperationStatisticDescriptor(String, Set<String>, Class<Enum>): void
- getObserverName(): String
- getTags(): Set<String>
- getType(): Class<Enum>
- descriptor(String, Set<String>, Class<Enum>): OperationStatisticDescriptor<Enum>
- descriptor(String, Class<Enum>, String[]): OperationStatisticDescriptor<Enum>
-
Statistic
- serialVersionUID: long
- type: StatisticType
- samples: List<Sample<Serializable>>
- Statistic(StatisticType): void
- Statistic(StatisticType, Sample<Serializable>): void
- Statistic(StatisticType, List<Sample<Serializable>>): void
- getType(): StatisticType
- isEmpty(): boolean
- getSamples(): List<Sample<Serializable>>
- getLatestSampleValue(): Optional<Serializable>
- getLatestSample(): Optional<Sample<Serializable>>
- toString(): String
- extract(ValueStatistic<Serializable>, long, long): Statistic<Serializable>
- accepted(Serializable): boolean
-
StatisticRegistry
- contextObject: Object
- timeSource: LongSupplier
- statistics: Map<String, ValueStatistic<Serializable>>
- StatisticRegistry(Object, LongSupplier): void
- getStatistics(): Map<String, ValueStatistic<Serializable>>
- queryStatistic(String): Optional<Statistic<Serializable>>
- queryStatistic(String, long): Optional<Statistic<Serializable>>
- queryStatistics(): Map<String, Statistic<Serializable>>
- queryStatistics(long): Map<String, Statistic<Serializable>>
- registerStatistic(String, StatisticType, Supplier<Serializable>): void
- registerStatistic(String, ValueStatistic<Serializable>): void
- registerTable(String, Supplier<Table>): void
- registerGauge(String, Supplier<Number>): void
- registerCounter(String, Supplier<Number>): void
- registerStatistic(String, ValueStatisticDescriptor): boolean
- registerStatistic(String, OperationStatisticDescriptor<Enum>, EnumSet<Enum>): boolean
- hasTags(Collection<String>): Matcher<Map<String, Object>>
- ValueStatisticDescriptor
-
OperationStatisticDescriptor
-
context
-
terracotta