com.digitalasset.canton.synchronizer.sequencer.traffic
SequencerRateLimitError
Companion trait SequencerRateLimitError
object SequencerRateLimitError extends SequencerErrorGroup
- Alphabetic
- By Inheritance
- SequencerRateLimitError
- SequencerErrorGroup
- ErrorGroup
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class AboveTrafficLimit(member: Member, trafficCost: NonNegativeLong, trafficState: TrafficState) extends SequencerRateLimitError with PrettyPrinting with Product with Serializable
The event cost exceeds the available traffic.
The event cost exceeds the available traffic. Only returned during validation at submission time.
- member
sender of the event
- trafficCost
cost of the event
- trafficState
current traffic state estimated by the sequencer when processing the submission
- final case class OutdatedEventCost(member: Member, submittedEventCost: Option[NonNegativeLong], submissionTimestamp: CantonTimestamp, correctEventCost: NonNegativeLong, timestampUsedForValidation: CantonTimestamp, trafficReceipt: Option[TrafficReceipt] = None) extends SequencingCostValidationError with Product with Serializable
- sealed trait SequencingCostValidationError extends SequencerRateLimitError
Errors specifically coming from failed validation of the submission cost.
Errors specifically coming from failed validation of the submission cost. They contain the actual cost that was consumed so it can be communicated to the sender in the deliver error.
- final case class TrafficNotFound(member: Member) extends SequencerRateLimitError with PrettyPrinting with Product with Serializable
This will be raised in the case where an event's traffic is being re-processed by the SequencerRateLimitManager (for instance in case of crash-recovery), but the TrafficConsumed object corresponding to the event cannot be found.
This will be raised in the case where an event's traffic is being re-processed by the SequencerRateLimitManager (for instance in case of crash-recovery), but the TrafficConsumed object corresponding to the event cannot be found. This could indicate that events are being processed out of order (the first time), which is not supported. Or the traffic consumed store may have been pruned and the information is not available anymore.
- member
member for which traffic was requested
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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- implicit val errorClass: ErrorClass
- Definition Classes
- ErrorGroup
- val fullClassName: String
- Definition Classes
- ErrorGroup
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- 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])
- object AboveTrafficLimit extends Serializable
- object IncorrectEventCost extends AlarmErrorCode