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 CounterAndTimestamp(lastCounter: SequencerCounter, lastTimestamp: CantonTimestamp) extends Product with Serializable
  4. final case class IgnoredSequencedEvent[+Env <: Envelope[_]](timestamp: CantonTimestamp, counter: SequencerCounter, underlying: Option[SignedContent[SequencedEvent[Env]]], previousTimestamp: Option[CantonTimestamp] = 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. Holds a counter and timestamp in the event stream, to be used for repairs of event history.

    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.

    TODO(#25162): Consider returning the support for "future" ignored events: 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.

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

    Finds the event with the highest timestamp before or at inclusive

  6. final case class OrdinarySequencedEvent[+Env <: Envelope[_]](counter: SequencerCounter, signedEvent: SignedContent[SequencedEvent[Env]])(traceContext: TraceContext) extends PossiblyIgnoredSequencedEvent[Env] with Product with Serializable

    Encapsulates an event received by the sequencer client that has been validated and stored.

    Encapsulates an event received by the sequencer client that has been validated and stored. Has a counter assigned by this store and contains a trace context.

  7. sealed trait PossiblyIgnoredSequencedEvent[+Env <: Envelope[_]] extends ProcessingSequencedEvent[Env]

    Encapsulates an event stored in the SequencedEventStore (has a counter assigned), and the event could have been marked as "ignored".

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

    Base type for wrapping all not yet stored (no counter) and stored events (have counter)

  9. sealed trait RangeCriterion extends Product with Serializable with PrettyPrinting

    Finds a sequence of events within a range

  10. sealed trait SearchCriterion extends Product with Serializable
  11. final case class SequencedEventWithTraceContext[+Env <: Envelope[_]](signedEvent: SignedContent[SequencedEvent[Env]])(traceContext: TraceContext) extends ProcessingSequencedEvent[Env] with Product with Serializable

    A wrapper for not yet stored events (no counter) with an additional trace context.

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, indexedSynchronizer: IndexedSynchronizer, 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]) @IntrinsicCandidate() @native()
  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
    @IntrinsicCandidate() @native()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  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
    @IntrinsicCandidate() @native()
  14. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  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 CounterAndTimestamp extends Serializable
  21. object IgnoredSequencedEvent extends Serializable
  22. object OrdinarySequencedEvent extends Serializable
  23. object PossiblyIgnoredSequencedEvent extends Serializable
  24. object SearchCriterion extends Serializable

Deprecated Value Members

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

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped