c

com.digitalasset.canton.sequencing.client

SequencedEventValidator

class SequencedEventValidator extends ValidateSequencedEvent with NamedLogging

Validate whether a received event is valid for processing.

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SequencedEventValidator
  2. NamedLogging
  3. ValidateSequencedEvent
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new SequencedEventValidator(initialPriorEventMetadata: Option[SequencedEventMetadata], unauthenticated: Boolean, optimistic: Boolean, skipValidation: Boolean, domainId: DomainId, sequencerId: SequencerId, syncCryptoApi: SyncCryptoClient, timely: FutureSupervisor, loggerFactory: NamedLoggerFactory)(implicit executionContext: ExecutionContext)

    initialPriorEventMetadata

    the preceding event of the first event to be validated (can be none on a new connection)

    unauthenticated

    if true, then the connection is unauthenticated. in such cases, we have to skip some validations.

    optimistic

    if true, we'll try to be optimistic and validate the event possibly with some stale data. this means that during sequencer key rolling, a message might have been signed by a key that was just revoked. the security impact is very marginal (and an adverse scenario only possible in the async ms of this node validating a few inflight transactions). therefore, this parameter should be set to true due to performance reasons.

    skipValidation

    if this flag is set to true, then the sequenced event validation will be skipped entirely. only use it in case of a programming error and the need to unblock a deployment.

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. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  9. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. def logger: TracedLogger
    Attributes
    protected
    Definition Classes
    NamedLogging
  12. val loggerFactory: NamedLoggerFactory
    Attributes
    protected
    Definition Classes
    SequencedEventValidatorNamedLogging
  13. implicit def loggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. def noTracingLogger: Logger
    Attributes
    protected
    Definition Classes
    NamedLogging
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  18. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  19. def toString(): String
    Definition Classes
    AnyRef → Any
  20. def validate(event: OrdinarySerializedEvent): EitherT[Future, SequencedEventValidationError, Unit]

    Validates that the supplied event is suitable for processing from the prior event.

    Validates that the supplied event is suitable for processing from the prior event. Currently the signature not being valid is not considered an error but its validity is returned to the caller to allow them to choose what to do with the event. If the event is successfully validated (regardless of the signature check) it becomes the event that the event in a following call will be validated against. We currently assume this is safe to do as if the event fails to be handled by the application then the sequencer client will halt and will need recreating to restart event processing. This method should not be called concurrently as it will corrupt the prior event state.

    Definition Classes
    SequencedEventValidatorValidateSequencedEvent
  21. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  22. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  23. 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 NamedLogging

Inherited from ValidateSequencedEvent

Inherited from AnyRef

Inherited from Any

Ungrouped