Type Members

1.  trait BySlicesSourceProvider extends AnyRef

   Implemented by EventSourcedProvider and DurableStateSourceProvider.

2.  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()

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

   Annotations

   @ApiMayChange()

4.  sealed trait OffsetVerification extends AnyRef
5.  trait Projection[Envelope] extends AnyRef

   The core abstraction in Pekko Projections.

   The core abstraction in Pekko 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 Pekko Cluster, where key could be the Pekko Cluster shardId.

   Envelope

   The envelope type of the projection.

   Annotations

   @ApiMayChange()

6.  trait ProjectionContext extends AnyRef

7.  final class ProjectionId extends AnyRef

   Annotations

   @ApiMayChange()

8.  sealed trait RetryRecoveryStrategy extends HandlerRecoveryStrategy
9.  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()

10.  sealed trait StrictRecoveryStrategy extends HandlerRecoveryStrategy