com.digitalasset.canton.sequencing.handlers
DiscardIgnoredEvents
Companion object DiscardIgnoredEvents
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.
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.
- Alphabetic
- By Inheritance
- DiscardIgnoredEvents
- NamedLogging
- ApplicationHandler
- Function1
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new DiscardIgnoredEvents(handler: OrdinaryApplicationHandler[Env], loggerFactory: NamedLoggerFactory)
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
- def andThen[A](g: (HandlerResult) => A): (BoxedEnvelope[PossiblyIgnoredEnvelopeBox, Env]) => A
- Definition Classes
- Function1
- Annotations
- @unspecialized()
- def apply(tracedEvents: BoxedEnvelope[PossiblyIgnoredEnvelopeBox, Env]): HandlerResult
- Definition Classes
- DiscardIgnoredEvents → Function1
- 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()
- def combineWith[Box2[+X <: Envelope[_]] <: PossiblyIgnoredEnvelopeBox[X], Env2 <: Env](other: ApplicationHandler[Box2, Env2])(implicit ec: ExecutionContext): ApplicationHandler[Box2, Env2]
Run the
otherApplicationHandler afterthis.Run the
otherApplicationHandler afterthis.- Definition Classes
- ApplicationHandler
- def compose[A](g: (A) => BoxedEnvelope[PossiblyIgnoredEnvelopeBox, Env]): (A) => HandlerResult
- Definition Classes
- Function1
- Annotations
- @unspecialized()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- 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
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Attributes
- protected
- Definition Classes
- DiscardIgnoredEvents → NamedLogging
- def name: String
Human-readable name of the application handler for logging and debugging
Human-readable name of the application handler for logging and debugging
- Definition Classes
- DiscardIgnoredEvents → ApplicationHandler
- implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def noTracingLogger: Logger
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def replace[Box2[+_ <: Envelope[_]], Env2 <: Envelope[_]](f: (BoxedEnvelope[Box2, Env2]) => HandlerResult): ApplicationHandler[Box2, Env2]
Replaces the application handler's processing with
fand leaves the subscriptionStartsAt logic and the name the same.Replaces the application handler's processing with
fand leaves the subscriptionStartsAt logic and the name the same.- Definition Classes
- ApplicationHandler
- def subscriptionStartsAt(start: SubscriptionStart, domainTimeTracker: DomainTimeTracker)(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]
Called by the com.digitalasset.canton.sequencing.client.SequencerClient before the start of a subscription.
Called by the com.digitalasset.canton.sequencing.client.SequencerClient before the start of a subscription.
- domainTimeTracker
The domain time tracker that listens to this application handler's subscription
- Definition Classes
- DiscardIgnoredEvents → ApplicationHandler
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- Function1 → 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])