Uses of Interface
org.agrona.concurrent.EpochClock
Packages that use EpochClock
Package
Description
Data structures and utilities useful for building high-performance Java applications.
Concurrent data structures and utilities that support both on and off Java heap usage.
A logger which provides a summary of distinct stacktrace based errors with counts and times.
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 EpochClockModifier and TypeMethodDescriptionstatic void
MarkFile.ensureDirectoryExists
(File directory, String filename, boolean warnIfDirectoryExists, boolean dirDeleteOnStart, int versionFieldOffset, int timestampFieldOffset, long timeoutMs, EpochClock epochClock, IntConsumer versionCheck, Consumer<String> logger) Ensure the directory exists, i.e.static boolean
MarkFile.isActive
(MappedByteBuffer byteBuffer, EpochClock epochClock, long timeoutMs, int versionFieldOffset, int timestampFieldOffset, IntConsumer versionCheck, Consumer<String> logger) Check ifMarkFile
is active, i.e.static MappedByteBuffer
MarkFile.mapExistingMarkFile
(File markFile, int versionFieldOffset, int timestampFieldOffset, long timeoutMs, EpochClock epochClock, IntConsumer versionCheck, Consumer<String> logger) Map existingMarkFile
.static MappedByteBuffer
MarkFile.mapNewOrExistingMarkFile
(File markFile, boolean shouldPreExist, int versionFieldOffset, int timestampFieldOffset, long totalFileLength, long timeoutMs, EpochClock epochClock, IntConsumer versionCheck, Consumer<String> logger) Map new of existingMarkFile
.static MappedByteBuffer
MarkFile.waitForFileMapping
(Consumer<String> logger, File markFile, long deadlineMs, EpochClock epochClock) Await the creation of theMarkFile
.Constructors in org.agrona with parameters of type EpochClockModifierConstructorDescriptionMarkFile
(File markFile, boolean shouldPreExist, int versionFieldOffset, int timestampFieldOffset, int totalFileLength, long timeoutMs, EpochClock epochClock, IntConsumer versionCheck, Consumer<String> logger) Create aMarkFile
if none present.MarkFile
(File directory, String filename, boolean warnIfDirectoryExists, boolean dirDeleteOnStart, int versionFieldOffset, int timestampFieldOffset, int totalFileLength, long timeoutMs, EpochClock epochClock, IntConsumer versionCheck, Consumer<String> logger) Create a directory and mark file if none present.MarkFile
(File directory, String filename, int versionFieldOffset, int timestampFieldOffset, long timeoutMs, EpochClock epochClock, IntConsumer versionCheck, Consumer<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 EpochClockModifier and TypeClassDescriptionclass
AnEpochClock
that caches a timestamp which can be updated withCachedEpochClock.update(long)
.class
Implementation that callsSystem.currentTimeMillis()
.Fields in org.agrona.concurrent declared as EpochClockConstructors in org.agrona.concurrent with parameters of type EpochClockModifierConstructorDescriptionSnowflakeIdGenerator
(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 EpochClockConstructors in org.agrona.concurrent.errors with parameters of type EpochClockModifierConstructorDescriptionDistinctErrorLog
(AtomicBuffer buffer, EpochClock clock) Create a new error log that will be written to a providedAtomicBuffer
.DistinctErrorLog
(AtomicBuffer buffer, EpochClock clock, 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 EpochClockConstructors in org.agrona.concurrent.status with parameters of type EpochClockModifierConstructorDescriptionConcurrentCountersManager
(AtomicBuffer metaDataBuffer, AtomicBuffer valuesBuffer, Charset labelCharset, EpochClock epochClock, long freeToReuseTimeoutMs) Create a new counter manager over buffers containing the values and associated metadata.CountersManager
(AtomicBuffer metaDataBuffer, AtomicBuffer valuesBuffer, Charset labelCharset, EpochClock epochClock, long freeToReuseTimeoutMs) Create a new counter manager over two buffers.