Type Members

1.  final case class Event(persistenceId: String = "", seqNr: Long = 0L, slice: Int = 0, offset: Option[Offset] = _root_.scala.None, payload: Option[Any] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[Event] with Product with Serializable

   Annotations

   @SerialVersionUID()

2.  trait EventProducerService extends AnyRef

   Annotations

   @AkkaGrpcGenerated()

3.  trait EventProducerServiceClient extends EventProducerService with EventProducerServiceClientPowerApi with AkkaGrpcClient

   Annotations

   @AkkaGrpcGenerated()

4.  trait EventProducerServiceClientPowerApi extends AnyRef

   Annotations

   @AkkaGrpcGenerated()

5.  trait EventProducerServicePowerApi extends AnyRef

   Annotations

   @AkkaGrpcGenerated()

6.  final case class EventTimestampRequest(streamId: String = "", persistenceId: String = "", seqNr: Long = 0L, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[EventTimestampRequest] with Product with Serializable

   Annotations

   @SerialVersionUID()

7.  final case class EventTimestampResponse(timestamp: Option[Timestamp] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[EventTimestampResponse] with Product with Serializable

   Annotations

   @SerialVersionUID()

8.  final case class FilteredEvent(persistenceId: String = "", seqNr: Long = 0L, slice: Int = 0, offset: Option[Offset] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[FilteredEvent] with Product with Serializable

   Events that are filtered out are represented by this placeholder to be able to track sequence numbers without holes.

   Events that are filtered out are represented by this placeholder to be able to track sequence numbers without holes.

   Annotations

   @SerialVersionUID()

9.  final case class InitReq(streamId: String = "", sliceMin: Int = 0, sliceMax: Int = 0, offset: Option[Offset] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[InitReq] with Product with Serializable
   streamId

   the logical stream identifier, mapped to a specific internal entity type by the producer settings

   sliceMin

   entities are partitioned by a deterministic slice (0-1023), a consumer would handle a slice range from slice_min to slice_max

   Annotations

   @SerialVersionUID()

10.  final case class LoadEventRequest(streamId: String = "", persistenceId: String = "", seqNr: Long = 0L, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[LoadEventRequest] with Product with Serializable
    streamId

    the logical stream identifier, mapped to a specific internal entity type by the producer settings

    Annotations

    @SerialVersionUID()

11.  final case class LoadEventResponse(message: Message = akka.projection.grpc.internal.proto.LoadEventResponse.Message.Empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[LoadEventResponse] with Product with Serializable

    Annotations

    @SerialVersionUID()

12.  final case class Offset(timestamp: Option[Timestamp] = _root_.scala.None, seen: Seq[PersistenceIdSeqNr] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[Offset] with Product with Serializable
    seen

    events with these sequence numbers for this timestamp have already been processed and doesn't have to be emitted again

    Annotations

    @SerialVersionUID()

13.  final case class PersistenceIdSeqNr(persistenceId: String = "", seqNr: Long = 0L, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[PersistenceIdSeqNr] with Product with Serializable

    Annotations

    @SerialVersionUID()

14.  final case class StreamIn(message: Message = akka.projection.grpc.internal.proto.StreamIn.Message.Empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[StreamIn] with Product with Serializable

    Annotations

    @SerialVersionUID()

15.  final case class StreamOut(message: Message = akka.projection.grpc.internal.proto.StreamOut.Message.Empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[StreamOut] with Product with Serializable

    Annotations

    @SerialVersionUID()