object SequencedEventStore

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SequencedEventStore
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. final case class ByTimestamp(timestamp: CantonTimestamp) extends SearchCriterion with Product with Serializable

    Find the event with the given timestamp

  2. final case class ByTimestampRange(lowerInclusive: CantonTimestamp, upperInclusive: CantonTimestamp) extends RangeCriterion with Product with Serializable

    Finds all events with timestamps within the given range.

    Finds all events with timestamps within the given range.

    lowerInclusive

    The lower bound, inclusive. Must not be after upperInclusive

    upperInclusive

    The upper bound, inclusive. Must not be before lowerInclusive

    Exceptions thrown

    java.lang.IllegalArgumentException if lowerInclusive is after upperInclusive

  3. final case class IgnoredSequencedEvent[+Env <: Envelope[_]](timestamp: CantonTimestamp, counter: SequencerCounter, underlying: Option[SignedContent[SequencedEvent[Env]]], trafficState: Option[SequencedEventTrafficState] = None)(traceContext: TraceContext) extends PossiblyIgnoredSequencedEvent[Env] with Product with Serializable

    Encapsulates an ignored event, i.e., an event that should not be processed.

    Encapsulates an ignored event, i.e., an event that should not be processed.

    If an ordinary sequenced event oe is later converted to an ignored event ie, the actual event oe.signedEvent is retained as ie.underlying so that no information gets discarded by ignoring events. If an ignored event ie is inserted as a placeholder for an event that has not been received, the underlying event ie.underlying is left empty.

  4. final case class LatestUpto(inclusive: CantonTimestamp) extends SearchCriterion with Product with Serializable

    Finds the event with the highest timestamp before or at inclusive

  5. final case class OrdinarySequencedEvent[+Env <: Envelope[_]](signedEvent: SignedContent[SequencedEvent[Env]], trafficState: Option[SequencedEventTrafficState])(traceContext: TraceContext) extends PossiblyIgnoredSequencedEvent[Env] with Product with Serializable

    Encapsulates an event received by the sequencer.

    Encapsulates an event received by the sequencer. It has been signed by the sequencer and contains a trace context.

  6. sealed trait PossiblyIgnoredSequencedEvent[+Env <: Envelope[_]] extends HasTraceContext with PrettyPrinting with Product with Serializable

    Encapsulates an event stored in the SequencedEventStore.

  7. sealed trait RangeCriterion extends Product with Serializable with PrettyPrinting

    Finds a sequence of events within a range

  8. sealed trait SearchCriterion extends Product with Serializable

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def apply[Env <: Envelope[_]](storage: Storage, member: SequencerClientDiscriminator, protocolVersion: ProtocolVersion, timeouts: ProcessingTimeout, loggerFactory: NamedLoggerFactory)(implicit executionContext: ExecutionContext): SequencedEventStore
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  14. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  15. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  16. def toString(): String
    Definition Classes
    AnyRef → Any
  17. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  18. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  19. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  20. object IgnoredSequencedEvent extends Serializable
  21. object OrdinarySequencedEvent extends Serializable
  22. object PossiblyIgnoredSequencedEvent extends Serializable

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated @Deprecated
    Deprecated

Inherited from AnyRef

Inherited from Any

Ungrouped