org.opendaylight.controller.akka.segjournal

Class SegmentedFileJournal

java.lang.Object

akka.persistence.journal.japi.AsyncRecovery

akka.persistence.journal.japi.AsyncWriteJournal

org.opendaylight.controller.akka.segjournal.SegmentedFileJournal

All Implemented Interfaces:

akka.actor.Actor, akka.persistence.journal.AsyncRecovery, akka.persistence.journal.AsyncWriteJournal, akka.persistence.journal.WriteJournalBase

public class SegmentedFileJournal
extends akka.persistence.journal.japi.AsyncWriteJournal

An Akka persistence journal implementation on top of SegmentedJournal. This actor represents aggregation of multiple journals and performs a receptionist job between Akka and invidual per-persistenceId actors. See SegmentedJournalActor for details on how the persistence works.

Author:

Robert Varga

Nested Class Summary

Nested classes/interfaces inherited from interface akka.persistence.journal.AsyncWriteJournal

akka.persistence.journal.AsyncWriteJournal.Desequenced, akka.persistence.journal.AsyncWriteJournal.Desequenced$, akka.persistence.journal.AsyncWriteJournal.Resequencer

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

Field Summary

Fields

Modifier and Type	Field and Description
static String	STORAGE_MAX_ENTRY_SIZE
static int	STORAGE_MAX_ENTRY_SIZE_DEFAULT
static String	STORAGE_MAX_SEGMENT_SIZE
static int	STORAGE_MAX_SEGMENT_SIZE_DEFAULT
static String	STORAGE_MEMORY_MAPPED
static String	STORAGE_ROOT_DIRECTORY

Constructor Summary

Constructors

Constructor and Description
SegmentedFileJournal(com.typesafe.config.Config config)

Method Summary

Modifier and Type	Method and Description
scala.concurrent.Future<Void>	doAsyncDeleteMessagesTo(String persistenceId, long toSequenceNr)
scala.concurrent.Future<Long>	doAsyncReadHighestSequenceNr(String persistenceId, long fromSequenceNr)
scala.concurrent.Future<Void>	doAsyncReplayMessages(String persistenceId, long fromSequenceNr, long toSequenceNr, long max, Consumer<akka.persistence.PersistentRepr> replayCallback)
scala.concurrent.Future<Iterable<Optional<Exception>>>	doAsyncWriteMessages(Iterable<akka.persistence.AtomicWrite> messages)

Methods inherited from class akka.persistence.journal.japi.AsyncWriteJournal

adaptFromJournal, adaptToJournal, akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$breaker_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$config_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$extension_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$publish_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterMaxOldWriters_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterMode_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterWindowSize_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$resequencer_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$receiveWriteJournal_$eq, akka$persistence$journal$AsyncWriteJournal$$breaker, akka$persistence$journal$AsyncWriteJournal$$config, akka$persistence$journal$AsyncWriteJournal$$extension, akka$persistence$journal$AsyncWriteJournal$$publish, akka$persistence$journal$AsyncWriteJournal$$replayFilterMaxOldWriters, akka$persistence$journal$AsyncWriteJournal$$replayFilterMode, akka$persistence$journal$AsyncWriteJournal$$replayFilterWindowSize, akka$persistence$journal$AsyncWriteJournal$$resequencer, akka$persistence$journal$AsyncWriteJournal$$resequencerCounter_$eq, akka$persistence$journal$AsyncWriteJournal$$resequencerCounter, akka$persistence$journal$WriteJournalBase$_setter_$akka$persistence$journal$WriteJournalBase$$eventAdapters_$eq, akka$persistence$journal$WriteJournalBase$_setter_$persistence_$eq, akka$persistence$journal$WriteJournalBase$$eventAdapters, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, asyncDeleteMessagesTo, asyncWriteMessages, context, persistence, postRestart, postStop, preparePersistentBatch, preRestart, preStart, receive, receivePluginInternal, receiveWriteJournal, self, sender, supervisorStrategy, unhandled

Methods inherited from class akka.persistence.journal.japi.AsyncRecovery

asyncReadHighestSequenceNr, asyncReplayMessages

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.persistence.journal.AsyncWriteJournal

$init$, akka$persistence$journal$AsyncWriteJournal$$isReplayFilterEnabled, successUnit

Methods inherited from interface akka.actor.Actor

$init$, noSender

Methods inherited from interface akka.persistence.journal.WriteJournalBase

$init$

Methods inherited from interface akka.persistence.journal.AsyncRecovery

asyncReadHighestSequenceNr, asyncReplayMessages

Field Detail

STORAGE_ROOT_DIRECTORY

public static final String STORAGE_ROOT_DIRECTORY

See Also:

Constant Field Values

STORAGE_MAX_ENTRY_SIZE

public static final String STORAGE_MAX_ENTRY_SIZE

See Also:

Constant Field Values

STORAGE_MAX_ENTRY_SIZE_DEFAULT

public static final int STORAGE_MAX_ENTRY_SIZE_DEFAULT

See Also:

Constant Field Values

STORAGE_MAX_SEGMENT_SIZE

public static final String STORAGE_MAX_SEGMENT_SIZE

See Also:

Constant Field Values

STORAGE_MAX_SEGMENT_SIZE_DEFAULT

public static final int STORAGE_MAX_SEGMENT_SIZE_DEFAULT

See Also:

Constant Field Values

STORAGE_MEMORY_MAPPED

public static final String STORAGE_MEMORY_MAPPED

See Also:

Constant Field Values

Constructor Detail

SegmentedFileJournal

public SegmentedFileJournal(com.typesafe.config.Config config)

Method Detail

doAsyncWriteMessages

public scala.concurrent.Future<Iterable<Optional<Exception>>> doAsyncWriteMessages(Iterable<akka.persistence.AtomicWrite> messages)

doAsyncDeleteMessagesTo

public scala.concurrent.Future<Void> doAsyncDeleteMessagesTo(String persistenceId,
                                                             long toSequenceNr)

doAsyncReplayMessages

public scala.concurrent.Future<Void> doAsyncReplayMessages(String persistenceId,
                                                           long fromSequenceNr,
                                                           long toSequenceNr,
                                                           long max,
                                                           Consumer<akka.persistence.PersistentRepr> replayCallback)

doAsyncReadHighestSequenceNr

public scala.concurrent.Future<Long> doAsyncReadHighestSequenceNr(String persistenceId,
                                                                  long fromSequenceNr)