Type Members

1.  final case class ConsumerFilterStoreState(excludeTags: ByteString = _root_.com.google.protobuf.ByteString.EMPTY, includeTags: ByteString = _root_.com.google.protobuf.ByteString.EMPTY, excludeRegexEntityIds: ByteString = _root_.com.google.protobuf.ByteString.EMPTY, includeRegexEntityIds: ByteString = _root_.com.google.protobuf.ByteString.EMPTY, excludeEntityIds: ByteString = _root_.com.google.protobuf.ByteString.EMPTY, includeEntityOffsets: Option[SeqNrMap] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ConsumerFilterStoreState] with Product with Serializable
   excludeTags

   ORSet serialized with Akka's ReplicatedDataSerializer

   includeTags

   ORSet serialized with Akka's ReplicatedDataSerializer

   excludeRegexEntityIds

   ORSet serialized with Akka's ReplicatedDataSerializer

   includeRegexEntityIds

   ORSet serialized with Akka's ReplicatedDataSerializer

   excludeEntityIds

   ORSet serialized with Akka's ReplicatedDataSerializer

   Annotations

   @SerialVersionUID()

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

   If this is defined (> 0) events are replayed from the given sequence number (inclusive).

   Annotations

   @SerialVersionUID()

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

   Actual payload and metadata serialization is deferred to Pekko serialization, the serializer id and manifest are encoded into a custom type_url schema

   Annotations

   @SerialVersionUID()

4.  trait EventProducerService extends AnyRef

   Annotations

   @PekkoGrpcGenerated()

5.  trait EventProducerServiceClient extends EventProducerService with EventProducerServiceClientPowerApi with PekkoGrpcClient

   Annotations

   @PekkoGrpcGenerated()

6.  trait EventProducerServiceClientPowerApi extends AnyRef

   Annotations

   @PekkoGrpcGenerated()

7.  trait EventProducerServicePowerApi extends AnyRef

   Annotations

   @PekkoGrpcGenerated()

8.  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()

9.  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()

10.  final case class ExcludeEntityIds(entityIds: Seq[String] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ExcludeEntityIds] with Product with Serializable

    Annotations

    @SerialVersionUID()

11.  final case class ExcludeRegexEntityIds(matching: Seq[String] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ExcludeRegexEntityIds] with Product with Serializable

    Annotations

    @SerialVersionUID()

12.  final case class ExcludeTags(tags: Seq[String] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ExcludeTags] with Product with Serializable

    Annotations

    @SerialVersionUID()

13.  final case class FilterCriteria(message: Message = org.apache.pekko.projection.grpc.internal.proto.FilterCriteria.Message.Empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[FilterCriteria] with Product with Serializable

    Annotations

    @SerialVersionUID()

14.  final case class FilterReq(criteria: Seq[FilterCriteria] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[FilterReq] with Product with Serializable

    Add filter criteria to exclude and include events for matching entities.

    Add filter criteria to exclude and include events for matching entities.

    Annotations

    @SerialVersionUID()

15.  final case class FilteredEvent(persistenceId: String = "", seqNr: Long = 0L, slice: Int = 0, offset: Option[Offset] = _root_.scala.None, source: String = "", 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()

16.  final case class IncludeEntityIds(entityIdOffset: Seq[EntityIdOffset] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[IncludeEntityIds] with Product with Serializable

    Annotations

    @SerialVersionUID()

17.  final case class IncludeRegexEntityIds(matching: Seq[String] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[IncludeRegexEntityIds] with Product with Serializable

    Annotations

    @SerialVersionUID()

18.  final case class IncludeTags(tags: Seq[String] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[IncludeTags] with Product with Serializable

    Annotations

    @SerialVersionUID()

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

    The first message must always be this InitReq to setup the stream.

    The first message must always be this InitReq to setup the stream. It can only be used as the first message.

    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()

20.  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()

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

    Annotations

    @SerialVersionUID()

22.  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()

23.  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()

24.  final case class RemoveExcludeEntityIds(entityIds: Seq[String] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[RemoveExcludeEntityIds] with Product with Serializable

    Annotations

    @SerialVersionUID()

25.  final case class RemoveExcludeRegexEntityIds(matching: Seq[String] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[RemoveExcludeRegexEntityIds] with Product with Serializable

    Annotations

    @SerialVersionUID()

26.  final case class RemoveExcludeTags(tags: Seq[String] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[RemoveExcludeTags] with Product with Serializable

    Annotations

    @SerialVersionUID()

27.  final case class RemoveIncludeEntityIds(entityIds: Seq[String] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[RemoveIncludeEntityIds] with Product with Serializable

    Annotations

    @SerialVersionUID()

28.  final case class RemoveIncludeRegexEntityIds(matching: Seq[String] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[RemoveIncludeRegexEntityIds] with Product with Serializable

    Annotations

    @SerialVersionUID()

29.  final case class RemoveIncludeTags(tags: Seq[String] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[RemoveIncludeTags] with Product with Serializable

    Annotations

    @SerialVersionUID()

30.  final case class ReplayReq(persistenceIdOffset: Seq[PersistenceIdSeqNr] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReplayReq] with Product with Serializable

    Replay events for given entities.

    Replay events for given entities.

    Annotations

    @SerialVersionUID()

31.  final case class SeqNrMap(orsetKeys: ByteString = _root_.com.google.protobuf.ByteString.EMPTY, entries: Seq[Entry] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[SeqNrMap] with Product with Serializable
    orsetKeys

    ORSet serialized with Akka's ReplicatedDataSerializer

    Annotations

    @SerialVersionUID()

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

    Annotations

    @SerialVersionUID()

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

    Annotations

    @SerialVersionUID()