final class GrpcReadJournal extends ReadJournal with EventsBySliceQuery with EventTimestampQuery with LoadEventQuery with CanTriggerReplay
- Source
- GrpcReadJournal.scala
- Alphabetic
- By Inheritance
- GrpcReadJournal
- CanTriggerReplay
- LoadEventQuery
- EventTimestampQuery
- EventsBySliceQuery
- ReadJournal
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new GrpcReadJournal(delegate: scaladsl.GrpcReadJournal)
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def close(): CompletionStage[Done]
Close the gRPC client.
Close the gRPC client. It will be automatically closed when the
ActorSystemis terminated, so invoking this is only needed when there is a need to close the resource before that. After closing theGrpcReadJournalinstance cannot be used again. - final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def eventsBySlices[Event](entityType: String, minSlice: Int, maxSlice: Int, offset: Offset): Source[EventEnvelope[Event], NotUsed]
- Definition Classes
- GrpcReadJournal → EventsBySliceQuery
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def loadEnvelope[Event](persistenceId: String, sequenceNr: Long): CompletionStage[EventEnvelope[Event]]
- Definition Classes
- GrpcReadJournal → LoadEventQuery
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- 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
eventsBySlicesqueries with the samestreamIdrunning from this instance of theGrpcReadJournal. Create separate instances of theGrpcReadJournalto have separation between replay requests for the samestreamId. - def sliceForPersistenceId(persistenceId: String): Int
- Definition Classes
- GrpcReadJournal → EventsBySliceQuery
- def sliceRanges(numberOfRanges: Int): List[Pair[Integer, Integer]]
- Definition Classes
- GrpcReadJournal → EventsBySliceQuery
- 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.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def timestampOf(persistenceId: String, sequenceNr: Long): CompletionStage[Optional[Instant]]
- Definition Classes
- GrpcReadJournal → EventTimestampQuery
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])