object SubscriptionStart extends Serializable
- Alphabetic
- By Inheritance
- SubscriptionStart
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class CleanHeadResubscriptionStart(cleanPrehead: CantonTimestamp) extends ResubscriptionStart with Product with Serializable
The first processed event is at some timestamp after the
cleanPrehead.The first processed event is at some timestamp after the
cleanPrehead. All events up tocleanPreheadinclusive have previously been processed completely. The application handler has never been called with an event with a higher timestamp. - type FreshSubscription = FreshSubscription.type
- final case class ReplayResubscriptionStart(firstReplayed: CantonTimestamp, cleanPreheadO: Option[CantonTimestamp]) extends ResubscriptionStart with Product with Serializable
The first processed event will be
firstReplayed.The first processed event will be
firstReplayed.- cleanPreheadO
The timestamp of the last event known to be clean. If set, this may be before, at, or after
firstReplayed. If it is beforefirstReplayed, thenfirstReplayedis the timestamp of the first event aftercleanPreheadO.
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
- 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()
- 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
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- 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])
- case object FreshSubscription extends SubscriptionStart with Product with Serializable
The subscription is created for the first time.
The subscription is created for the first time. The application handler has never been called with an event.