Packages

p

org.apache.pekko

projection

package projection

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package cassandra
  2. package eventsourced
  3. package internal
  4. package javadsl
  5. package jdbc
  6. package kafka
  7. package scaladsl
  8. package slick
  9. package state
  10. package testkit

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

Value Members

  1. object HandlerRecoveryStrategy
    Annotations
    @ApiMayChange()
  2. object OffsetVerification
    Annotations
    @ApiMayChange()
  3. object ProjectionBehavior
    Annotations
    @ApiMayChange()
  4. object ProjectionId
    Annotations
    @ApiMayChange()

Ungrouped