Packages

final class GrpcReadJournal extends ReadJournal with EventsBySliceQuery with EventTimestampQuery with LoadEventQuery with CanTriggerReplay

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. GrpcReadJournal
  2. CanTriggerReplay
  3. LoadEventQuery
  4. EventTimestampQuery
  5. EventsBySliceQuery
  6. ReadJournal
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new GrpcReadJournal(delegate: scaladsl.GrpcReadJournal)

Value Members

  1. def close(): CompletionStage[Done]

    Close the gRPC client.

    Close the gRPC client. It will be automatically closed when the ActorSystem is terminated, so invoking this is only needed when there is a need to close the resource before that. After closing the GrpcReadJournal instance cannot be used again.

  2. def eventsBySlices[Event](entityType: String, minSlice: Int, maxSlice: Int, offset: Offset): Source[EventEnvelope[Event], NotUsed]
    Definition Classes
    GrpcReadJournal → EventsBySliceQuery
  3. def loadEnvelope[Event](persistenceId: String, sequenceNr: Long): CompletionStage[EventEnvelope[Event]]
    Definition Classes
    GrpcReadJournal → LoadEventQuery
  4. val replayCorrelationId: UUID

    Correlation id to be used with ConsumerFilter.ReplayWithFilter.

    Correlation id to be used with ConsumerFilter.ReplayWithFilter. Such replay request will trigger replay in all eventsBySlices queries with the same streamId running from this instance of the GrpcReadJournal. Create separate instances of the GrpcReadJournal to have separation between replay requests for the same streamId.

  5. def sliceForPersistenceId(persistenceId: String): Int
    Definition Classes
    GrpcReadJournal → EventsBySliceQuery
  6. def sliceRanges(numberOfRanges: Int): List[Pair[Integer, Integer]]
    Definition Classes
    GrpcReadJournal → EventsBySliceQuery
  7. def streamId(): String

    The identifier of the stream to consume, which is exposed by the producing/publishing side.

    The identifier of the stream to consume, which is exposed by the producing/publishing side. It is defined in the GrpcQuerySettings.

  8. def timestampOf(persistenceId: String, sequenceNr: Long): CompletionStage[Optional[Instant]]
    Definition Classes
    GrpcReadJournal → EventTimestampQuery