class InMemorySequencerCounterTrackerStore extends SequencerCounterTrackerStore with NamedLogging
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- InMemorySequencerCounterTrackerStore
- NamedLogging
- SequencerCounterTrackerStore
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new InMemorySequencerCounterTrackerStore(loggerFactory: NamedLoggerFactory)
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
- def advancePreheadSequencerCounterTo(sequencerCounter: CursorPrehead[SequencerCounter])(implicit traceContext: TraceContext): Future[Unit]
Sets the prehead clean sequencer counter to
sequencerCounterunless it has previously been set to a higher value.Sets the prehead clean sequencer counter to
sequencerCounterunless it has previously been set to a higher value.- Definition Classes
- SequencerCounterTrackerStore
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- val cursorStore: InMemoryCursorPreheadStore[SequencerCounter]
- Attributes
- protected[store]
- Definition Classes
- InMemorySequencerCounterTrackerStore → SequencerCounterTrackerStore
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Definition Classes
- InMemorySequencerCounterTrackerStore → NamedLogging
- implicit def loggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def noTracingLogger: Logger
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def preheadSequencerCounter(implicit traceContext: TraceContext): Future[Option[CursorPrehead[SequencerCounter]]]
Gets the prehead clean sequencer counter.
Gets the prehead clean sequencer counter. All sequencer counters below are assumed to be clean.
- Definition Classes
- SequencerCounterTrackerStore
- def rewindPreheadSequencerCounter(newPreheadO: Option[CursorPrehead[SequencerCounter]])(implicit traceContext: TraceContext): Future[Unit]
Rewinds the prehead clean sequencer counter to
newPreheadunless the prehead is already at or before the newpreHead.Rewinds the prehead clean sequencer counter to
newPreheadunless the prehead is already at or before the newpreHead.- Definition Classes
- SequencerCounterTrackerStore
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- 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])