Uses of Interface
org.agrona.concurrent.EpochClock
-
Packages that use EpochClock Package Description org.agrona Data structures and utilities useful for building high-performance Java applications.org.agrona.concurrent Concurrent data structures and utilities that support both on and off Java heap usage.org.agrona.concurrent.errors A logger which provides a summary of distinct stacktrace based errors with counts and times.org.agrona.concurrent.status Counters for indicating status and telemetry which can be put in shared memory for live inspection. -
-
Uses of EpochClock in org.agrona
Methods in org.agrona with parameters of type EpochClock Modifier and Type Method Description static void
MarkFile. ensureDirectoryExists(java.io.File directory, java.lang.String filename, boolean warnIfDirectoryExists, boolean dirDeleteOnStart, int versionFieldOffset, int timestampFieldOffset, long timeoutMs, EpochClock epochClock, java.util.function.IntConsumer versionCheck, java.util.function.Consumer<java.lang.String> logger)
Ensure the directory exists, i.e.static boolean
MarkFile. isActive(java.nio.MappedByteBuffer byteBuffer, EpochClock epochClock, long timeoutMs, int versionFieldOffset, int timestampFieldOffset, java.util.function.IntConsumer versionCheck, java.util.function.Consumer<java.lang.String> logger)
Check ifMarkFile
is active, i.e.static java.nio.MappedByteBuffer
MarkFile. mapExistingMarkFile(java.io.File markFile, int versionFieldOffset, int timestampFieldOffset, long timeoutMs, EpochClock epochClock, java.util.function.IntConsumer versionCheck, java.util.function.Consumer<java.lang.String> logger)
Map existingMarkFile
.static java.nio.MappedByteBuffer
MarkFile. mapNewOrExistingMarkFile(java.io.File markFile, boolean shouldPreExist, int versionFieldOffset, int timestampFieldOffset, long totalFileLength, long timeoutMs, EpochClock epochClock, java.util.function.IntConsumer versionCheck, java.util.function.Consumer<java.lang.String> logger)
Map new of existingMarkFile
.static java.nio.MappedByteBuffer
MarkFile. waitForFileMapping(java.util.function.Consumer<java.lang.String> logger, java.io.File markFile, long deadlineMs, EpochClock epochClock)
Await the creation of theMarkFile
.Constructors in org.agrona with parameters of type EpochClock Constructor Description MarkFile(java.io.File markFile, boolean shouldPreExist, int versionFieldOffset, int timestampFieldOffset, int totalFileLength, long timeoutMs, EpochClock epochClock, java.util.function.IntConsumer versionCheck, java.util.function.Consumer<java.lang.String> logger)
Create aMarkFile
if none present.MarkFile(java.io.File directory, java.lang.String filename, boolean warnIfDirectoryExists, boolean dirDeleteOnStart, int versionFieldOffset, int timestampFieldOffset, int totalFileLength, long timeoutMs, EpochClock epochClock, java.util.function.IntConsumer versionCheck, java.util.function.Consumer<java.lang.String> logger)
Create a directory and mark file if none present.MarkFile(java.io.File directory, java.lang.String filename, int versionFieldOffset, int timestampFieldOffset, long timeoutMs, EpochClock epochClock, java.util.function.IntConsumer versionCheck, java.util.function.Consumer<java.lang.String> logger)
Map a pre-existingMarkFile
if one present and is active. -
Uses of EpochClock in org.agrona.concurrent
Classes in org.agrona.concurrent that implement EpochClock Modifier and Type Class Description class
CachedEpochClock
AnEpochClock
that caches a timestamp which can be updated withCachedEpochClock.update(long)
.class
SystemEpochClock
Implementation that callsSystem.currentTimeMillis()
.Fields in org.agrona.concurrent declared as EpochClock Modifier and Type Field Description private EpochClock
SnowflakeIdGenerator. clock
Constructors in org.agrona.concurrent with parameters of type EpochClock Constructor Description SnowflakeIdGenerator(int nodeIdBits, int sequenceBits, long nodeId, long timestampOffsetMs, EpochClock clock)
Construct a new Snowflake id generator for a given node with a provided offset andEpochClock
. -
Uses of EpochClock in org.agrona.concurrent.errors
Fields in org.agrona.concurrent.errors declared as EpochClock Modifier and Type Field Description private EpochClock
DistinctErrorLog. clock
Constructors in org.agrona.concurrent.errors with parameters of type EpochClock Constructor Description DistinctErrorLog(AtomicBuffer buffer, EpochClock clock)
Create a new error log that will be written to a providedAtomicBuffer
.DistinctErrorLog(AtomicBuffer buffer, EpochClock clock, java.nio.charset.Charset charset)
Create a new error log that will be written to a providedAtomicBuffer
. -
Uses of EpochClock in org.agrona.concurrent.status
Fields in org.agrona.concurrent.status declared as EpochClock Modifier and Type Field Description private EpochClock
CountersManager. epochClock
Constructors in org.agrona.concurrent.status with parameters of type EpochClock Constructor Description ConcurrentCountersManager(AtomicBuffer metaDataBuffer, AtomicBuffer valuesBuffer, java.nio.charset.Charset labelCharset, EpochClock epochClock, long freeToReuseTimeoutMs)
Create a new counter manager over buffers containing the values and associated metadata.CountersManager(AtomicBuffer metaDataBuffer, AtomicBuffer valuesBuffer, java.nio.charset.Charset labelCharset, EpochClock epochClock, long freeToReuseTimeoutMs)
Create a new counter manager over two buffers.
-