Packages

trait TestOffsetStore[Offset] extends AnyRef

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

Abstract Value Members

  1. abstract def allOffsets(): List[Pair[ProjectionId, Offset]]

    All offsets saved to the offset store.

  2. abstract def lastOffset(): Optional[Offset]

    The last saved offset to the offset store.

  3. abstract def readManagementState(projectionId: ProjectionId): CompletionStage[Optional[ManagementState]]
  4. abstract def readOffsets(): CompletionStage[Optional[Offset]]
  5. abstract def saveOffset(projectionId: ProjectionId, offset: Offset): CompletionStage[Done]
  6. abstract def savePaused(projectionId: ProjectionId, paused: Boolean): CompletionStage[Done]