Type Members

1.  final class Projection extends ProjectionSerializable

   Current status of a projection.

   Current status of a projection.

   Annotations

   @ApiMayChange()

2.  trait ProjectionSerializable extends AnyRef

   INTERNAL API.

   INTERNAL API. Marker trait for projection serializers.

   Annotations

   @ApiMayChange() @InternalApi()

3.  sealed trait Started extends Status
4.  final class State extends ProjectionSerializable

   The state of a projections registry is a collection of projections with extra data indicating the name of the projection, and details about its workers.

   The state of a projections registry is a collection of projections with extra data indicating the name of the projection, and details about its workers. Note that many projections may operate over the same journal. Each worker includes information about the particular tagName it is tracking. Note that multiple workers may track the same tagName because each worker is part of a different projection. Each worker also has a key which is unique across the whole cluster. Finally, the data related to a worker that's part of the State includes a requested status and an observed status for the worker.

   Annotations

   @ApiMayChange()

5.  sealed trait Status extends ProjectionSerializable

   Super type for a worker status ADT.

   Super type for a worker status ADT. Possible values are

   Stopped

   and

   Started

   Stopped }}}

   Annotations

   @ApiMayChange()

6.  sealed trait Stopped extends Status
7.  final class Worker extends ProjectionSerializable

   Metadata of a Worker.

   Metadata of a Worker. The existence of this data doesn't mean the actual worker instance exists. This metadata identifies the tag this worker will consume, a unique identifier (aka the key) and both the requested and the observed status.

   Both the requested and observed status are eventually consistent since this metadata is being replicated across the cluster and may have been edited in other nodes when being read in the local node.

   Annotations

   @ApiMayChange()