Packages

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

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

Instance Constructors

  1. new GrpcReadJournal(delegate: scaladsl.GrpcReadJournal)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  6. 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.

  7. def currentEventsByPersistenceIdTyped[Event](persistenceId: String, fromSequenceNr: Long, toSequenceNr: Long): Source[EventEnvelope[Event], NotUsed]
    Definition Classes
    GrpcReadJournal → CurrentEventsByPersistenceIdTypedQuery
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  10. def eventsBySlices[Event](entityType: String, minSlice: Int, maxSlice: Int, offset: Offset): Source[EventEnvelope[Event], NotUsed]
    Definition Classes
    GrpcReadJournal → EventsBySliceQuery
  11. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. def latestEventTimestamp(entityType: String, minSlice: Int, maxSlice: Int): CompletionStage[Optional[Instant]]
    Definition Classes
    GrpcReadJournal → LatestEventTimestampQuery
  15. def loadEnvelope[Event](persistenceId: String, sequenceNr: Long): CompletionStage[EventEnvelope[Event]]
    Definition Classes
    GrpcReadJournal → LoadEventQuery
  16. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  18. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  19. 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.

  20. def sliceForPersistenceId(persistenceId: String): Int
    Definition Classes
    GrpcReadJournal → EventsBySliceQuery
  21. def sliceRanges(numberOfRanges: Int): List[Pair[Integer, Integer]]
    Definition Classes
    GrpcReadJournal → EventsBySliceQuery
  22. 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.

  23. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  24. def timestampOf(persistenceId: String, sequenceNr: Long): CompletionStage[Optional[Instant]]
    Definition Classes
    GrpcReadJournal → EventTimestampQuery
  25. def toString(): String
    Definition Classes
    AnyRef → Any
  26. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  27. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  28. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from CurrentEventsByPersistenceIdTypedQuery

Inherited from LatestEventTimestampQuery

Inherited from CanTriggerReplay

Inherited from LoadEventQuery

Inherited from EventTimestampQuery

Inherited from EventsBySliceQuery

Inherited from ReadJournal

Inherited from AnyRef

Inherited from Any

Ungrouped