Type Members

1.  sealed trait SequencerRateLimitError extends AnyRef
2.  trait SequencerRateLimitManager extends AutoCloseable

   Holds the traffic control state and control rate limiting logic of members of a sequencer

3.  final case class SequencerTrafficConfig(trafficPurchasedCacheSizePerMember: PositiveInt = PositiveInt.tryCreate(3), maximumTrafficPurchasedCacheSize: PositiveInt = PositiveInt.tryCreate(1000), batchAggregatorConfig: BatchAggregatorConfig = BatchAggregatorConfig.Batching(), pruningRetentionWindow: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofHours(2L), trafficConsumedCacheTTL: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofHours(2L), maximumTrafficConsumedCacheSize: PositiveInt = PositiveInt.tryCreate(1000), submissionTimestampInFutureTolerance: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofSeconds(5)) extends UniformCantonConfigValidation with Product with Serializable

   Configuration for the traffic purchased entry manager.

   Configuration for the traffic purchased entry manager.

   trafficPurchasedCacheSizePerMember

   How many traffic purchased entries to keep in memory for each member.

   maximumTrafficPurchasedCacheSize

   The maximum number of entries (= members) to keep in the cache.

   batchAggregatorConfig

   configures how balances are batched before being written to the store.

   pruningRetentionWindow

   the duration for which balances are kept in the cache and the store. Balances older than this duration will be pruned at regular intervals.

   trafficConsumedCacheTTL

   the duration for which consumed traffic entries are kept in the cache after the last time they've been accessed.

   maximumTrafficConsumedCacheSize

   Maximum number of entries (members) to keep in the traffic consumed cache.

   submissionTimestampInFutureTolerance

   the tolerance window that should be added to future dated submission timestamp that can still be accepted by this sequencer.

4.  final case class SequencerTrafficStatus(trafficStatesOrErrors: Map[Member, Either[String, TrafficState]]) extends Product with Serializable