Packages

  • package root
    Definition Classes
    root
  • package com
    Definition Classes
    root
  • package digitalasset
    Definition Classes
    com
  • package canton
    Definition Classes
    digitalasset
  • package sequencing
    Definition Classes
    canton
  • package client
    Definition Classes
    sequencing
  • package transports
    Definition Classes
    client
  • package replay
    Definition Classes
    transports
  • class ReplayingSendsSequencerClientTransport extends SequencerClientTransport with NamedLogging with NoTracing with FlagCloseableAsync

    Replays previously recorded sends against the configured sequencer and using a real sequencer client transport.

    Replays previously recorded sends against the configured sequencer and using a real sequencer client transport. Records the latencies/rates to complete the send itself, and latencies/rates for an event that was caused by the send to be witnessed. These metrics are currently printed to stdout. Sequencers are able to drop sends so to know when all sends have likely been sequenced we simply wait for a period where no events are received for a configurable duration. This isn't perfect as technically a sequencer could stall, however the inflight gauge will report a number greater than 0 indicating that these sends have gone missing. Clients are responsible for interacting with the transport to initiate a replay and wait for observed events to be idle. A reference can be obtained to this transport component by waiting on the future provided in ReplayAction.SequencerSends. This testing transport is very stateful and the metrics will only make sense for a single replay, however currently multiple or even concurrent calls are not prevented (just don't).

    Definition Classes
    replay
  • EventsReceivedReport
  • SendReplayReport

case class EventsReceivedReport(elapsedDuration: FiniteDuration, totalEventsReceived: Int, finishedAtCounter: SequencerCounter) extends Product with Serializable

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. EventsReceivedReport
  2. Serializable
  3. Product
  4. Equals
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new EventsReceivedReport(elapsedDuration: FiniteDuration, totalEventsReceived: Int, finishedAtCounter: SequencerCounter)

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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  6. val elapsedDuration: FiniteDuration
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. val finishedAtCounter: SequencerCounter
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  13. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  14. def productElementNames: Iterator[String]
    Definition Classes
    Product
  15. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  16. def toString(): String
    Definition Classes
    EventsReceivedReport → AnyRef → Any
  17. val totalEventsReceived: Int
  18. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  19. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  20. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

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

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped