Class PersistentQueueKt
-
- All Implemented Interfaces:
public final class PersistentQueueKt
-
-
Field Summary
Fields Modifier and Type Field Description private final static Topic<String>ACTIVE_EVENT_LOG_FILE_NAME_TOPICprivate final static Topic<Pair<Long, Integer>>LOGS_FILE_METRICS_CALCULATED_TOPICprivate final static Topic<DeletedInformation>LOGS_FILE_DELETED
-
Method Summary
Modifier and Type Method Description final Topic<String>getACTIVE_EVENT_LOG_FILE_NAME_TOPIC()Publish the filename each time a new event log file is created for a persistent queue. final Topic<Pair<Long, Integer>>getLOGS_FILE_METRICS_CALCULATED_TOPIC()Topic for publishing metrics about file roll-over statistics. final Topic<DeletedInformation>getLOGS_FILE_DELETED()Topic used for publishing information about files removed from the logs storage. final static <E extends Any> PersistentQueue<E>persistentQueue(MessageBus messageBus, FileStorage fileStorage, FusJsonSerializer jsonSerializer, FusLoggerFactory loggerFactory, Duration defaultDelay, EventLogBuildType buildType, Long maxFileBytes, Duration maxFileAge)-
-
Method Detail
-
getACTIVE_EVENT_LOG_FILE_NAME_TOPIC
final Topic<String> getACTIVE_EVENT_LOG_FILE_NAME_TOPIC()
Publish the filename each time a new event log file is created for a persistent queue.
-
getLOGS_FILE_METRICS_CALCULATED_TOPIC
final Topic<Pair<Long, Integer>> getLOGS_FILE_METRICS_CALCULATED_TOPIC()
Topic for publishing metrics about file roll-over statistics.
The metrics are a pair of integers: first is the file size at rollover, and the second is the number of events in the latest file.
-
getLOGS_FILE_DELETED
final Topic<DeletedInformation> getLOGS_FILE_DELETED()
Topic used for publishing information about files removed from the logs storage.
This topic communicates events of type DeletedInformation, which provide metadata about deleted log files including their age in milliseconds, the time spent in the queue before deletion, the file size in bytes, and the associated build type that generated the logs.
-
persistentQueue
final static <E extends Any> PersistentQueue<E> persistentQueue(MessageBus messageBus, FileStorage fileStorage, FusJsonSerializer jsonSerializer, FusLoggerFactory loggerFactory, Duration defaultDelay, EventLogBuildType buildType, Long maxFileBytes, Duration maxFileAge)
-
-
-
-