t

akka.projection.scaladsl

SourceProvider

trait SourceProvider[Offset, Envelope] extends AnyRef

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SourceProvider
  2. AnyRef
  3. 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.

  2. abstract def extractOffset(envelope: Envelope): Offset
  3. abstract def source(offset: () => Future[Option[Offset]]): Future[Source[Envelope, NotUsed]]