Module akka_projection_rs::consumer

Akka projections

In Akka Projections you process a stream of event envelopes from a source to a projected model or external system. Each envelope is associated with an offset representing the position in the stream. This offset is used for resuming the stream from that position when the projection is restarted.

Functions

• run
  Provides at-least-once projections with storage for projection offsets, meaning, for multiple runs of a projection, it is possible for events to repeat from previous runs.