Packages

final case class SequencedEvent(previousTimestamp: Option[Long], timestamp: Long, synchronizerId: String, messageId: Option[String], batch: Option[CompressedBatch], deliverErrorReason: Option[Status], topologyTimestamp: Option[Long], trafficReceipt: Option[TrafficReceipt]) extends GeneratedMessage with Updatable[SequencedEvent] with Product with Serializable

previousTimestamp

The timestamp of the previous event of the member's event sequence. in microseconds of UTC time since Unix epoch Optional, set to None if this is the first ever event of the member's event sequence.

timestamp

The timestamp of the event. Unique and monotonically increasing. The same event has the same timestamp for all recipients. in microseconds of UTC time since Unix epoch

synchronizerId

The synchronizer on which the event has been sequenced.

messageId

The message_id of the request. Optional, but will be defined iff the request sender is the subscriber.

batch

The payload of the event. Optional, defined iff deliver_error_reason is undefined.

deliverErrorReason

Optional error, indicates why the underlying SubmissionRequest has been rejected.

topologyTimestamp

Optional timestamp of the topology snapshot used for processing the underlying request (e.g., validation, signing, resolving group addresses). If undefined, timestamp is used instead.

trafficReceipt

Traffic receipt with information about the traffic state after the cost for this event has been consumed Optional - only set on deliver receipt sent back to the sender of the event when traffic control is enabled

Annotations
@SerialVersionUID()
Linear Supertypes
Updatable[SequencedEvent], GeneratedMessage, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SequencedEvent
  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 SequencedEvent(previousTimestamp: Option[Long], timestamp: Long, synchronizerId: String, messageId: Option[String], batch: Option[CompressedBatch], deliverErrorReason: Option[Status], topologyTimestamp: Option[Long], trafficReceipt: Option[TrafficReceipt])

    previousTimestamp

    The timestamp of the previous event of the member's event sequence. in microseconds of UTC time since Unix epoch Optional, set to None if this is the first ever event of the member's event sequence.

    timestamp

    The timestamp of the event. Unique and monotonically increasing. The same event has the same timestamp for all recipients. in microseconds of UTC time since Unix epoch

    synchronizerId

    The synchronizer on which the event has been sequenced.

    messageId

    The message_id of the request. Optional, but will be defined iff the request sender is the subscriber.

    batch

    The payload of the event. Optional, defined iff deliver_error_reason is undefined.

    deliverErrorReason

    Optional error, indicates why the underlying SubmissionRequest has been rejected.

    topologyTimestamp

    Optional timestamp of the topology snapshot used for processing the underlying request (e.g., validation, signing, resolving group addresses). If undefined, timestamp is used instead.

    trafficReceipt

    Traffic receipt with information about the traffic state after the cost for this event has been consumed Optional - only set on deliver receipt sent back to the sender of the event when traffic control is enabled

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 batch: Option[CompressedBatch]
  6. def clearBatch: SequencedEvent
  7. def clearDeliverErrorReason: SequencedEvent
  8. def clearMessageId: SequencedEvent
  9. def clearPreviousTimestamp: SequencedEvent
  10. def clearTopologyTimestamp: SequencedEvent
  11. def clearTrafficReceipt: SequencedEvent
  12. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  13. def companion: SequencedEvent.type
    Definition Classes
    SequencedEvent → GeneratedMessage
  14. val deliverErrorReason: Option[Status]
  15. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. def getBatch: CompressedBatch
  17. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  18. def getDeliverErrorReason: Status
  19. def getField(__field: FieldDescriptor): PValue
    Definition Classes
    SequencedEvent → GeneratedMessage
  20. def getFieldByNumber(__fieldNumber: Int): Any
    Definition Classes
    SequencedEvent → GeneratedMessage
  21. def getMessageId: String
  22. def getPreviousTimestamp: Long
  23. def getTopologyTimestamp: Long
  24. def getTrafficReceipt: TrafficReceipt
  25. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  26. val messageId: Option[String]
  27. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  28. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  29. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  30. val previousTimestamp: Option[Long]
  31. def productElementNames: Iterator[String]
    Definition Classes
    Product
  32. def serializedSize: Int
    Definition Classes
    SequencedEvent → GeneratedMessage
  33. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  34. val synchronizerId: String
  35. val timestamp: Long
  36. final def toByteArray: Array[Byte]
    Definition Classes
    GeneratedMessage
  37. final def toByteString: ByteString
    Definition Classes
    GeneratedMessage
  38. final def toPMessage: PMessage
    Definition Classes
    GeneratedMessage
  39. def toProtoString: String
    Definition Classes
    SequencedEvent → GeneratedMessage
  40. val topologyTimestamp: Option[Long]
  41. val trafficReceipt: Option[TrafficReceipt]
  42. def update(ms: (Lens[SequencedEvent, SequencedEvent]) => Mutation[SequencedEvent]*): SequencedEvent
    Definition Classes
    Updatable
  43. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  44. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  45. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  46. def withBatch(__v: CompressedBatch): SequencedEvent
  47. def withDeliverErrorReason(__v: Status): SequencedEvent
  48. def withMessageId(__v: String): SequencedEvent
  49. def withPreviousTimestamp(__v: Long): SequencedEvent
  50. def withSynchronizerId(__v: String): SequencedEvent
  51. def withTimestamp(__v: Long): SequencedEvent
  52. def withTopologyTimestamp(__v: Long): SequencedEvent
  53. def withTrafficReceipt(__v: TrafficReceipt): SequencedEvent
  54. final def writeDelimitedTo(output: OutputStream): Unit
    Definition Classes
    GeneratedMessage
  55. def writeTo(_output__: CodedOutputStream): Unit
    Definition Classes
    SequencedEvent → GeneratedMessage
  56. 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[SequencedEvent]

Inherited from GeneratedMessage

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped