Type Members

1.  class CleanSequencerCounterTracker extends NamedLogging

   Application handler transformer that tracks the sequencer counters for which the given application handler has successfully completed the asynchronous processing.

2.  class DiscardIgnoredEvents[Env <: Envelope[_]] extends PossiblyIgnoredApplicationHandler[Env] with NamedLogging

   Forwards only com.digitalasset.canton.store.SequencedEventStore.OrdinarySequencedEvents to the given com.digitalasset.canton.sequencing.ApplicationHandler.

   Forwards only com.digitalasset.canton.store.SequencedEventStore.OrdinarySequencedEvents to the given com.digitalasset.canton.sequencing.ApplicationHandler.

   This must only be used on code paths where there cannot be other types of events by construction. Otherwise, the application handler will not be informed about ignored event and cannot tick any of the trackers, including the com.digitalasset.canton.topology.processing.TopologyTransactionProcessor.

3.  class EnvelopeOpener[Box[+_ <: Envelope[_]]] extends AnyRef

   Opener for envelopes inside an arbitrary EnvelopeBox

4.  class EventTimestampCapture extends NamedLogging

   Capture the sequencing timestamp of the last successfully processed event (only synchronous processing).

5.  class HasReceivedEvent extends AnyRef
6.  class StoreSequencedEvent extends NamedLogging

   Transformer for com.digitalasset.canton.sequencing.OrdinaryApplicationHandler that stores all event batches in the com.digitalasset.canton.store.SequencedEventStore before passing them on to the given handler.

   Transformer for com.digitalasset.canton.sequencing.OrdinaryApplicationHandler that stores all event batches in the com.digitalasset.canton.store.SequencedEventStore before passing them on to the given handler. Complains if events have the wrong synchronizer id.

7.  class ThrottlingApplicationEventHandler extends NamedLogging
8.  class TimeLimitingApplicationEventHandler extends NamedLogging

   Monitors how long the processing of batches of sequenced events takes.

   Monitors how long the processing of batches of sequenced events takes. If the processing takes longer than the time limit on the given clock, the handler will once log an error or exit the process, depending on exitOnTimeout.