t

akka.projection.scaladsl

AtLeastOnceFlowProjection

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

Self Type
AtLeastOnceFlowProjection[Offset, Envelope] with InternalProjection
Annotations
@DoNotInherit()
Source
Projections.scala
Linear Supertypes
Projection[Envelope], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AtLeastOnceFlowProjection
  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 withRestartBackoff(minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double, maxRestarts: Int): AtLeastOnceFlowProjection[Offset, Envelope]
    Definition Classes
    AtLeastOnceFlowProjection → Projection
  4. abstract def withRestartBackoff(minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double): AtLeastOnceFlowProjection[Offset, Envelope]
    Definition Classes
    AtLeastOnceFlowProjection → Projection
  5. abstract def withRestartBackoff(minBackoff: Duration, maxBackoff: Duration, randomFactor: Double, maxRestarts: Int): Projection[Envelope]

    Java API

    Java API

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

    Java API

    Java API

    Definition Classes
    Projection
  7. abstract def withSaveOffset(afterEnvelopes: Int, afterDuration: FiniteDuration): AtLeastOnceFlowProjection[Offset, Envelope]
  8. abstract def withStatusObserver(observer: StatusObserver[Envelope]): AtLeastOnceFlowProjection[Offset, Envelope]
    Definition Classes
    AtLeastOnceFlowProjection → Projection