Type Members

1.  trait AllowSeqNrGapsMetadata extends AnyRef
2.  trait BySlicesSourceProvider extends AnyRef

   Implemented by EventSourcedProvider and DurableStateSourceProvider.

3.  sealed trait HandlerRecoveryStrategy extends AnyRef

   Error handling strategy when processing an Envelope fails.

   Error handling strategy when processing an Envelope fails. The default is defined in configuration .

4.  final case class MergeableOffset[Offset](entries: Map[String, Offset]) extends Product with Serializable
5.  sealed trait OffsetVerification extends AnyRef
6.  trait Projection[Envelope] extends AnyRef

   The core abstraction in Akka Projections.

   The core abstraction in Akka Projections.

   A projection instance may share the same name and Envelope, but must have a unique key. The key is used to achieve processing parallelism for a projection.

   For example, many projections may share the same name "user-events-projection", but can process events for different sharded entities within Akka Cluster, where key could be the Akka Cluster shardId.

   Envelope

   The envelope type of the projection.

7.  trait ProjectionContext extends AnyRef

8.  final class ProjectionId extends AnyRef
9.  sealed trait RetryRecoveryStrategy extends HandlerRecoveryStrategy
10.  abstract class StatusObserver[-Envelope] extends AnyRef

    Track status of a projection by implementing a StatusObserver and install it using Projection.withStatusObserver.

11.  sealed trait StrictRecoveryStrategy extends HandlerRecoveryStrategy