SynchronousWriteReplaySupport

Type Members

type Receive = PartialFunction[Any, Unit]

Definition Classes
Actor

Abstract Value Members

abstract def executeBatchReplayInMsgs(cmds: Seq[ReplayInMsgs], p: (Message, ActorRef) ⇒ Unit): Unit

Instructs a journal provider to batch-replay input messages.
Instructs a journal provider to batch-replay input messages.
cmds
command batch to be executed by the journal provider.
p
function to be called by the provider for every replayed input message. The acks field of a replayed input message must contain the channel ids of all acknowledgements for that input message. The replay target of the currently processed org.eligosource.eventsourced.core.JournalProtocol.ReplayInMsgs command must be passed as second argument.

See also
org.eligosource.eventsourced.core.EventsourcingExtension
org.eligosource.eventsourced.core.JournalProtocol.WriteAck
abstract def executeDeleteOutMsg(cmd: DeleteOutMsg): Unit

Instructs a journal provider to delete an output message.
Instructs a journal provider to delete an output message.
cmd
command to be executed by the journal provider.

See also
org.eligosource.eventsourced.core.ReliableChannel
org.eligosource.eventsourced.core.JournalProtocol.DeleteOutMsg
abstract def executeReplayInMsgs(cmd: ReplayInMsgs, p: (Message) ⇒ Unit): Unit

Instructs a journal provider to replay input messages.
Instructs a journal provider to replay input messages.
cmd
command to be executed by the journal provider.
p
function to be called by the provider for each replayed input message. The acks field of a replayed input message must contain the channel ids of all acknowledgements for that input message.

See also
org.eligosource.eventsourced.core.EventsourcingExtension
org.eligosource.eventsourced.core.JournalProtocol.WriteAck
abstract def executeReplayOutMsgs(cmd: ReplayOutMsgs, p: (Message) ⇒ Unit): Unit

Instructs a journal provider to replay output messages.
Instructs a journal provider to replay output messages.
cmd
command to be executed by the journal provider.
p
function to be called by the provider for each replayed output message.

See also
org.eligosource.eventsourced.core.EventsourcingExtension
abstract def executeWriteAck(cmd: WriteAck): Unit

Instructs a journal provider to write an acknowledgement.
Instructs a journal provider to write an acknowledgement.
cmd
command to be executed by the journal provider.

See also
org.eligosource.eventsourced.core.ReliableChannel
org.eligosource.eventsourced.core.DefaultChannel
org.eligosource.eventsourced.core.JournalProtocol.WriteAck
abstract def executeWriteInMsg(cmd: WriteInMsg): Unit

Instructs a journal provider to write an input message.
Instructs a journal provider to write an input message.
cmd
command to be executed by the journal provider.

See also
org.eligosource.eventsourced.core.JournalProtocol.WriteInMsg
abstract def executeWriteOutMsg(cmd: WriteOutMsg): Unit

Instructs a journal provider to write an output message, optionally together with an acknowledgement.
Instructs a journal provider to write an output message, optionally together with an acknowledgement.
cmd
command to be executed by the journal provider.

See also
org.eligosource.eventsourced.core.JournalProtocol.WriteInMsg
abstract def loadSnapshotSync(processorId: Int, snapshotFilter: (SnapshotMetadata) ⇒ Boolean): Option[Snapshot]

Loads the latest snapshot for specified processor whose metadata match predicate p.
Loads the latest snapshot for specified processor whose metadata match predicate p.
processorId
processor id of the snapshot.
snapshotFilter
predicate for selecting saved snapshots.
returns
youngest snapshots of those selected by p, if any.
abstract def saveSnapshot(snapshot: Snapshot): Future[SnapshotSaved]

Saves a snapshot asynchronously.
Saves a snapshot asynchronously.
snapshot
a snapshot.
returns
a future that is completed when the snapshot has been successfully saved.
abstract def snapshotSaved(metadata: SnapshotMetadata): Unit

Called when a snapshot has been successfully saved.
Called when a snapshot has been successfully saved.
metadata
snapshot metadata.
abstract def storedCounter: Long

Returns the last stored counter value.
Returns the last stored counter value.

Attributes
protected

Concrete Value Members

final def !=(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def !=(arg0: Any): Boolean

Definition Classes
Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def ==(arg0: Any): Boolean

Definition Classes
Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
implicit val context: ActorContext

Definition Classes
Actor
def counter: Long

Returns the current counter value.
Returns the current counter value.

Attributes
protected
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
def initialCounter: Long

Returns the initial counter value after journal start.
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def postRestart(reason: Throwable): Unit

Definition Classes
Actor
Annotations
@throws( classOf[java.lang.Exception] )
def postStop(): Unit

Calls stop().
Calls stop().

Definition Classes
SynchronousWriteReplaySupport → Actor
def preRestart(reason: Throwable, message: Option[Any]): Unit

Definition Classes
Actor
Annotations
@throws( classOf[java.lang.Exception] )
def preStart(): Unit

Initializes the counter from the last stored counter value and calls start().
Initializes the counter from the last stored counter value and calls start().

Definition Classes
SynchronousWriteReplaySupport → Actor
def receive: PartialFunction[Any, Unit]

Definition Classes
SynchronousWriteReplaySupport → Actor
implicit final val self: ActorRef

Definition Classes
Actor
final def sender: ActorRef

Definition Classes
Actor
def start(): Unit

Start callback.
Start callback. Empty default implementation.

Attributes
protected
def stop(): Unit

Stop callback.
Stop callback. Empty default implementation.

Attributes
protected
def supervisorStrategy: SupervisorStrategy

Definition Classes
Actor
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
def unhandled(message: Any): Unit

Definition Classes
Actor
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

trait SynchronousWriteReplaySupport extends Actor

Type Members

type Receive = PartialFunction[Any, Unit]

Abstract Value Members

abstract def executeBatchReplayInMsgs(cmds: Seq[ReplayInMsgs], p: (Message, ActorRef) ⇒ Unit): Unit

abstract def executeDeleteOutMsg(cmd: DeleteOutMsg): Unit

abstract def executeReplayInMsgs(cmd: ReplayInMsgs, p: (Message) ⇒ Unit): Unit

abstract def executeReplayOutMsgs(cmd: ReplayOutMsgs, p: (Message) ⇒ Unit): Unit

abstract def executeWriteAck(cmd: WriteAck): Unit

abstract def executeWriteInMsg(cmd: WriteInMsg): Unit

abstract def executeWriteOutMsg(cmd: WriteOutMsg): Unit

abstract def loadSnapshotSync(processorId: Int, snapshotFilter: (SnapshotMetadata) ⇒ Boolean): Option[Snapshot]

abstract def saveSnapshot(snapshot: Snapshot): Future[SnapshotSaved]

abstract def snapshotSaved(metadata: SnapshotMetadata): Unit

abstract def storedCounter: Long

Concrete Value Members

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def clone(): AnyRef

implicit val context: ActorContext

def counter: Long

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

def initialCounter: Long

final def isInstanceOf[T0]: Boolean

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def postRestart(reason: Throwable): Unit

def postStop(): Unit

def preRestart(reason: Throwable, message: Option[Any]): Unit

def preStart(): Unit

def receive: PartialFunction[Any, Unit]

implicit final val self: ActorRef

final def sender: ActorRef

def start(): Unit

def stop(): Unit

def supervisorStrategy: SupervisorStrategy

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

def unhandled(message: Any): Unit

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

Inherited from Actor

Inherited from AnyRef

Inherited from Any

Ungrouped