t

akka.projection.scaladsl

GroupedProjection

trait GroupedProjection[Offset, Envelope] extends Projection[Envelope]

Self Type
GroupedProjection[Offset, Envelope] with InternalProjection
Annotations
@DoNotInherit()
Source
Projections.scala
Linear Supertypes
Projection[Envelope], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. GroupedProjection
  2. Projection
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def projectionId: ProjectionId
    Definition Classes
    Projection
  2. abstract def statusObserver: StatusObserver[Envelope]
    Definition Classes
    Projection
  3. abstract def withGroup(groupAfterEnvelopes: Int, groupAfterDuration: FiniteDuration): GroupedProjection[Offset, Envelope]
  4. abstract def withRecoveryStrategy(recoveryStrategy: HandlerRecoveryStrategy): GroupedProjection[Offset, Envelope]
  5. abstract def withRestartBackoff(minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double, maxRestarts: Int): GroupedProjection[Offset, Envelope]
    Definition Classes
    GroupedProjection → Projection
  6. abstract def withRestartBackoff(minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double): GroupedProjection[Offset, Envelope]
    Definition Classes
    GroupedProjection → Projection
  7. abstract def withRestartBackoff(minBackoff: Duration, maxBackoff: Duration, randomFactor: Double, maxRestarts: Int): Projection[Envelope]

    Java API

    Java API

    Definition Classes
    Projection
  8. abstract def withRestartBackoff(minBackoff: Duration, maxBackoff: Duration, randomFactor: Double): Projection[Envelope]

    Java API

    Java API

    Definition Classes
    Projection
  9. abstract def withStatusObserver(observer: StatusObserver[Envelope]): GroupedProjection[Offset, Envelope]
    Definition Classes
    GroupedProjection → Projection