Packages

class JdbcOffsetStore[S <: JdbcSession] extends AnyRef

INTERNAL API

Annotations
@InternalApi()
Source
JdbcOffsetStore.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. JdbcOffsetStore
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new JdbcOffsetStore(system: ActorSystem[_], settings: JdbcSettings, jdbcSessionFactory: () => S)
  2. new JdbcOffsetStore(system: ActorSystem[_], settings: JdbcSettings, jdbcSessionFactory: () => S, clock: Clock)

Value Members

  1. def clearOffset(projectionId: ProjectionId): Future[Done]
  2. def createIfNotExists(): Future[Done]
  3. def dropIfExists(): Future[Done]
  4. def readManagementState(projectionId: ProjectionId): Future[Option[ManagementState]]
  5. def readOffset[Offset](projectionId: ProjectionId): Future[Option[Offset]]
  6. def saveOffset[Offset](projectionId: ProjectionId, offset: Offset): Future[Done]

    Like saveOffset, but async.

    Like saveOffset, but async. Useful for resetting an offset

  7. def saveOffsetBlocking[Offset](conn: Connection, projectionId: ProjectionId, offset: Offset): Done

    This method is explicitly made non-async because it's used together with the users' handler code and run inside the same Future

  8. def savePaused(projectionId: ProjectionId, paused: Boolean): Future[Done]