Packages

final case class TrafficControlParameters(maxBaseTrafficAmount: Long, maxBaseTrafficAccumulationDuration: Option[Duration], readVsWriteScalingFactor: Int, setBalanceRequestSubmissionWindowSize: Option[Duration], enforceRateLimiting: Boolean, baseEventCost: Option[Long]) extends GeneratedMessage with Updatable[TrafficControlParameters] with Product with Serializable

maxBaseTrafficAmount

[doc-entry-start: TrafficControlParameters] In bytes, the maximum amount of base traffic that can be accumulated

maxBaseTrafficAccumulationDuration

Maximum duration over which the base rate can be accumulated Consequently, base_traffic_rate = max_base_traffic_amount / max_base_traffic_accumulation_duration

readVsWriteScalingFactor

Read scaling factor to compute the event cost. In parts per 10 000.

setBalanceRequestSubmissionWindowSize

Window size used to compute the max sequencing time of a submission request This impacts how quickly a submission is expected to be accepted before a retry should be attempted by the caller Default is 5 minutes

enforceRateLimiting

If true, submission requests without enough traffic credit will not be delivered

baseEventCost

In bytes, base event cost added to all sequenced events. Optional [doc-entry-end: TrafficControlParameters]

Annotations
@SerialVersionUID()
Linear Supertypes
Updatable[TrafficControlParameters], GeneratedMessage, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TrafficControlParameters
  2. Updatable
  3. GeneratedMessage
  4. Serializable
  5. Product
  6. Equals
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new TrafficControlParameters(maxBaseTrafficAmount: Long, maxBaseTrafficAccumulationDuration: Option[Duration], readVsWriteScalingFactor: Int, setBalanceRequestSubmissionWindowSize: Option[Duration], enforceRateLimiting: Boolean, baseEventCost: Option[Long])

    maxBaseTrafficAmount

    [doc-entry-start: TrafficControlParameters] In bytes, the maximum amount of base traffic that can be accumulated

    maxBaseTrafficAccumulationDuration

    Maximum duration over which the base rate can be accumulated Consequently, base_traffic_rate = max_base_traffic_amount / max_base_traffic_accumulation_duration

    readVsWriteScalingFactor

    Read scaling factor to compute the event cost. In parts per 10 000.

    setBalanceRequestSubmissionWindowSize

    Window size used to compute the max sequencing time of a submission request This impacts how quickly a submission is expected to be accepted before a retry should be attempted by the caller Default is 5 minutes

    enforceRateLimiting

    If true, submission requests without enough traffic credit will not be delivered

    baseEventCost

    In bytes, base event cost added to all sequenced events. Optional [doc-entry-end: TrafficControlParameters]

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. val baseEventCost: Option[Long]
  6. def clearBaseEventCost: TrafficControlParameters
  7. def clearMaxBaseTrafficAccumulationDuration: TrafficControlParameters
  8. def clearSetBalanceRequestSubmissionWindowSize: TrafficControlParameters
  9. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  10. def companion: TrafficControlParameters.type
    Definition Classes
    TrafficControlParameters → GeneratedMessage
  11. val enforceRateLimiting: Boolean
  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def getBaseEventCost: Long
  14. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  15. def getField(__field: FieldDescriptor): PValue
    Definition Classes
    TrafficControlParameters → GeneratedMessage
  16. def getFieldByNumber(__fieldNumber: Int): Any
    Definition Classes
    TrafficControlParameters → GeneratedMessage
  17. def getMaxBaseTrafficAccumulationDuration: Duration
  18. def getSetBalanceRequestSubmissionWindowSize: Duration
  19. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  20. val maxBaseTrafficAccumulationDuration: Option[Duration]
  21. val maxBaseTrafficAmount: Long
  22. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  23. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  24. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  25. def productElementNames: Iterator[String]
    Definition Classes
    Product
  26. val readVsWriteScalingFactor: Int
  27. def serializedSize: Int
    Definition Classes
    TrafficControlParameters → GeneratedMessage
  28. val setBalanceRequestSubmissionWindowSize: Option[Duration]
  29. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  30. final def toByteArray: Array[Byte]
    Definition Classes
    GeneratedMessage
  31. final def toByteString: ByteString
    Definition Classes
    GeneratedMessage
  32. final def toPMessage: PMessage
    Definition Classes
    GeneratedMessage
  33. def toProtoString: String
    Definition Classes
    TrafficControlParameters → GeneratedMessage
  34. def update(ms: (Lens[TrafficControlParameters, TrafficControlParameters]) => Mutation[TrafficControlParameters]*): TrafficControlParameters
    Definition Classes
    Updatable
  35. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  36. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  37. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  38. def withBaseEventCost(__v: Long): TrafficControlParameters
  39. def withEnforceRateLimiting(__v: Boolean): TrafficControlParameters
  40. def withMaxBaseTrafficAccumulationDuration(__v: Duration): TrafficControlParameters
  41. def withMaxBaseTrafficAmount(__v: Long): TrafficControlParameters
  42. def withReadVsWriteScalingFactor(__v: Int): TrafficControlParameters
  43. def withSetBalanceRequestSubmissionWindowSize(__v: Duration): TrafficControlParameters
  44. final def writeDelimitedTo(output: OutputStream): Unit
    Definition Classes
    GeneratedMessage
  45. def writeTo(_output__: CodedOutputStream): Unit
    Definition Classes
    TrafficControlParameters → GeneratedMessage
  46. final def writeTo(output: OutputStream): Unit
    Definition Classes
    GeneratedMessage

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from Updatable[TrafficControlParameters]

Inherited from GeneratedMessage

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped