Uses of Class
org.agrona.concurrent.status.AtomicCounter
Packages that use AtomicCounter
Package
Description
Concurrent data structures and utilities that support both on and off Java heap usage.
Counters for indicating status and telemetry which can be put in shared memory for live inspection.
-
Uses of AtomicCounter in org.agrona.concurrent
Fields in org.agrona.concurrent declared as AtomicCounterModifier and TypeFieldDescriptionprivate final AtomicCounter
AgentInvoker.errorCounter
private final AtomicCounter
AgentRunner.errorCounter
private final AtomicCounter
CountedErrorHandler.errorCounter
Constructors in org.agrona.concurrent with parameters of type AtomicCounterModifierConstructorDescriptionAgentInvoker
(ErrorHandler errorHandler, AtomicCounter errorCounter, Agent agent) Create an agent and initialise it.AgentRunner
(IdleStrategy idleStrategy, ErrorHandler errorHandler, AtomicCounter errorCounter, Agent agent) Create an agent runner and initialise it.CountedErrorHandler
(ErrorHandler errorHandler, AtomicCounter errorCounter) Construct a counted error handler with a delegate and counter. -
Uses of AtomicCounter in org.agrona.concurrent.status
Methods in org.agrona.concurrent.status that return AtomicCounterModifier and TypeMethodDescriptionAtomicCounter.appendToLabel
(String suffix) Append to the label for a counter constructed with aCountersManager
.CountersManager.newCounter
(int typeId, DirectBuffer keyBuffer, int keyOffset, int keyLength, DirectBuffer labelBuffer, int labelOffset, int labelLength) Allocate a counter record and wrap it with a newAtomicCounter
for use.CountersManager.newCounter
(String label) Allocate a counter record and wrap it with a newAtomicCounter
for use with a default type ofCountersReader.DEFAULT_TYPE_ID
.CountersManager.newCounter
(String label, int typeId) Allocate a counter record and wrap it with a newAtomicCounter
for use.CountersManager.newCounter
(String label, int typeId, Consumer<MutableDirectBuffer> keyFunc) Allocate a counter record and wrap it with a newAtomicCounter
for use.