t

akka.projection.javadsl

VerifiableSourceProvider

trait VerifiableSourceProvider[Offset, Envelope] extends SourceProvider[Offset, Envelope]

Source
SourceProvider.scala
Linear Supertypes
SourceProvider[Offset, Envelope], AnyRef, Any
Known Subclasses
TestSourceProvider
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. VerifiableSourceProvider
  2. SourceProvider
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def extractCreationTime(envelope: Envelope): Long

    Timestamp (in millis-since-epoch) of the instant when the envelope was created.

    Timestamp (in millis-since-epoch) of the instant when the envelope was created. The meaning of "when the envelope was created" is implementation specific and could be an instant on the producer machine, or the instant when the database persisted the envelope, or other.

    Definition Classes
    SourceProvider
  2. abstract def extractOffset(envelope: Envelope): Offset
    Definition Classes
    SourceProvider
  3. abstract def source(offset: Supplier[CompletionStage[Optional[Offset]]]): CompletionStage[Source[Envelope, NotUsed]]
    Definition Classes
    SourceProvider
  4. abstract def verifyOffset(offset: Offset): OffsetVerification