Type Members

1.  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 .

   Annotations

   @ApiMayChange()

2.  final case class MergeableOffset[Offset](entries: Map[String, Offset]) extends Product with Serializable

   Annotations

   @ApiMayChange()

3.  sealed trait OffsetVerification extends AnyRef
4.  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.

   Annotations

   @ApiMayChange()

5.  trait ProjectionContext extends AnyRef

6.  final class ProjectionId extends AnyRef

   Annotations

   @ApiMayChange()

7.  sealed trait RetryRecoveryStrategy extends HandlerRecoveryStrategy
8.  abstract class StatusObserver[-Envelope] extends AnyRef

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

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

   Annotations

   @ApiMayChange()

9.  sealed trait StrictRecoveryStrategy extends HandlerRecoveryStrategy