package proto

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

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

    The event payload may be serialized as Protobuf message when the type_url prefix is type.googleapis.com/ or with Akka serialization when the type_url prefix ser.akka.io/. For Akka serialization, the serializer id and manifest are encoded into a custom type_url schema. Note that the payload is empty for backtracking events, see source.

    source

    "" for ordinary events. "BT" for backtracking events. "PS" for PubSub events.

    Annotations
    @SerialVersionUID()
  4. trait EventProducerService extends AnyRef

    EventProducerService runs on the producer side and implements the producer side of the EventsBySlices query, which can be used with Akka Projection over gRPC.

    EventProducerService runs on the producer side and implements the producer side of the EventsBySlices query, which can be used with Akka Projection over gRPC.

    1. Events are stored in the event journal on the producer side. 2. Consumer side starts an Akka Projection which locally reads its offset from the Projection offset store. 3. Consumer side establishes a replication stream from the producer service by sending the InitReq with the offset to start from. 4. Events are read from the journal on the producer side and emitted to the replication stream. 5. Consumer side processes the events in a Projection handler. 6. Offset is stored on the consumer side by the Projection offset store. 7. Producer continues to read new events from the journal and emit to the stream. The consumer can define event filters with the FilterCriteria, which can be included in the InitReq and also changed in runtime by sending FilterReq.
    Annotations
    @AkkaGrpcGenerated()
  5. trait EventProducerServiceClient extends EventProducerService with EventProducerServiceClientPowerApi with AkkaGrpcClient
    Annotations
    @AkkaGrpcGenerated()
  6. trait EventProducerServiceClientPowerApi extends AnyRef
    Annotations
    @AkkaGrpcGenerated()
  7. trait EventProducerServicePowerApi extends AnyRef
    Annotations
    @AkkaGrpcGenerated()
  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

    Retrieve the timestamp of a specific event.

    Retrieve the timestamp of a specific event.

    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

    Response to EventTimestampRequest.

    Response to EventTimestampRequest.

    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

    Exclude events for entities with the given entity ids, unless there is a matching include filter that overrides the exclude.

    Exclude events for entities with the given entity ids, unless there is a matching include filter that overrides the exclude.

    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

    Exclude events for entities with entity ids matching the given regular expressions, unless there is a matching include filter that overrides the exclude.

    Exclude events for entities with entity ids matching the given regular expressions, unless there is a matching include filter that overrides the exclude.

    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

    Exclude events with any of the given tags, unless there is a matching include filter that overrides the exclude.

    Exclude events with any of the given tags, unless there is a matching include filter that overrides the exclude.

    Annotations
    @SerialVersionUID()
  13. final case class FilterCriteria(message: Message = akka.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

    Include events for entities with the given entity ids.

    Include events for entities with the given entity ids. A matching include overrides a matching exclude.

    For the given entity ids a seq_nr can be defined to replay all events for the entity from the sequence number (inclusive). If seq_nr is 0 events will not be replayed.

    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

    Include events for entities with entity ids matching the given regular expressions.

    Include events for entities with entity ids matching the given regular expressions. A matching include overrides a matching exclude.

    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

    Include events with any of the given tags.

    Include events with any of the given tags. A matching include overrides a matching exclude.

    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

    offset

    start from this offset

    filter

    consumer defined event filters

    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

    Lazy loading of a specific event.

    Lazy loading of a specific event. Used when payload for a backtracking event is needed.

    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 = akka.projection.grpc.internal.proto.LoadEventResponse.Message.Empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[LoadEventResponse] with Product with Serializable

    Response to LoadEventRequest.

    Response to LoadEventRequest.

    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

    Remove a previously added ExcludeEntityIds.

    Remove a previously added ExcludeEntityIds.

    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

    Remove a previously added ExcludeRegexEntityIds.

    Remove a previously added ExcludeRegexEntityIds.

    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

    Remove a previously added ExcludeTags.

    Remove a previously added ExcludeTags.

    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

    Remove a previously added IncludeEntityIds.

    Remove a previously added IncludeEntityIds.

    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

    Remove a previously added IncludeRegexEntityIds.

    Remove a previously added IncludeRegexEntityIds.

    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

    Remove a previously added IncludeTags.

    Remove a previously added IncludeTags.

    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 = 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()
  33. 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()

Value Members

  1. object ConsumerFilterStoreState extends GeneratedMessageCompanion[ConsumerFilterStoreState]
  2. object ConsumerProto extends GeneratedFileObject
  3. object EntityIdOffset extends GeneratedMessageCompanion[EntityIdOffset]
  4. object Event extends GeneratedMessageCompanion[Event]
  5. object EventProducerProto extends GeneratedFileObject
  6. object EventProducerService extends ServiceDescription
    Annotations
    @AkkaGrpcGenerated()
  7. object EventProducerServiceClient
    Annotations
    @AkkaGrpcGenerated()
  8. object EventProducerServiceHandler
    Annotations
    @ApiMayChange() @AkkaGrpcGenerated()
  9. object EventProducerServicePowerApiHandler
    Annotations
    @ApiMayChange() @AkkaGrpcGenerated()
  10. object EventTimestampRequest extends GeneratedMessageCompanion[EventTimestampRequest]
  11. object EventTimestampResponse extends GeneratedMessageCompanion[EventTimestampResponse]
  12. object ExcludeEntityIds extends GeneratedMessageCompanion[ExcludeEntityIds]
  13. object ExcludeRegexEntityIds extends GeneratedMessageCompanion[ExcludeRegexEntityIds]
  14. object ExcludeTags extends GeneratedMessageCompanion[ExcludeTags]
  15. object FilterCriteria extends GeneratedMessageCompanion[FilterCriteria]
  16. object FilterReq extends GeneratedMessageCompanion[FilterReq]
  17. object FilteredEvent extends GeneratedMessageCompanion[FilteredEvent]
  18. object IncludeEntityIds extends GeneratedMessageCompanion[IncludeEntityIds]
  19. object IncludeRegexEntityIds extends GeneratedMessageCompanion[IncludeRegexEntityIds]
  20. object IncludeTags extends GeneratedMessageCompanion[IncludeTags]
  21. object InitReq extends GeneratedMessageCompanion[InitReq]
  22. object LoadEventRequest extends GeneratedMessageCompanion[LoadEventRequest]
  23. object LoadEventResponse extends GeneratedMessageCompanion[LoadEventResponse]
  24. object Offset extends GeneratedMessageCompanion[Offset]
  25. object PersistenceIdSeqNr extends GeneratedMessageCompanion[PersistenceIdSeqNr]
  26. object RemoveExcludeEntityIds extends GeneratedMessageCompanion[RemoveExcludeEntityIds]
  27. object RemoveExcludeRegexEntityIds extends GeneratedMessageCompanion[RemoveExcludeRegexEntityIds]
  28. object RemoveExcludeTags extends GeneratedMessageCompanion[RemoveExcludeTags]
  29. object RemoveIncludeEntityIds extends GeneratedMessageCompanion[RemoveIncludeEntityIds]
  30. object RemoveIncludeRegexEntityIds extends GeneratedMessageCompanion[RemoveIncludeRegexEntityIds]
  31. object RemoveIncludeTags extends GeneratedMessageCompanion[RemoveIncludeTags]
  32. object ReplayReq extends GeneratedMessageCompanion[ReplayReq]
  33. object SeqNrMap extends GeneratedMessageCompanion[SeqNrMap]
  34. object StreamIn extends GeneratedMessageCompanion[StreamIn]
  35. object StreamOut extends GeneratedMessageCompanion[StreamOut]

Ungrouped