Uses of Class
org.agrona.concurrent.status.AtomicCounter
-
Packages that use AtomicCounter Package Description org.agrona.concurrent Concurrent data structures and utilities that support both on and off Java heap usage.org.agrona.concurrent.status 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 AtomicCounter Modifier and Type Field Description private AtomicCounter
AgentInvoker. errorCounter
private AtomicCounter
AgentRunner. errorCounter
private AtomicCounter
CountedErrorHandler. errorCounter
Constructors in org.agrona.concurrent with parameters of type AtomicCounter Constructor Description AgentInvoker(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 AtomicCounter Modifier and Type Method Description AtomicCounter
AtomicCounter. appendToLabel(java.lang.String suffix)
Append to the label for a counter constructed with aCountersManager
.AtomicCounter
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.AtomicCounter
CountersManager. newCounter(java.lang.String label)
Allocate a counter record and wrap it with a newAtomicCounter
for use with a default type ofCountersReader.DEFAULT_TYPE_ID
.AtomicCounter
CountersManager. newCounter(java.lang.String label, int typeId)
Allocate a counter record and wrap it with a newAtomicCounter
for use.AtomicCounter
CountersManager. newCounter(java.lang.String label, int typeId, java.util.function.Consumer<MutableDirectBuffer> keyFunc)
Allocate a counter record and wrap it with a newAtomicCounter
for use.
-