final case class ConsumerEventInit(originId: String = "", streamId: String = "", fillSequenceNumberGaps: Boolean = false, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ConsumerEventInit] with Product with Serializable

must be the first event from the connecting producer, the producer must then not start emitting events until it sees a ConsumerEventStart

originId

unique producer identifier showing where the events came from/was produced

streamId

the stream id of the type of entity the producer wants to push

fillSequenceNumberGaps

if gaps in sequence numbers may exist and should be filled in

Annotations
@SerialVersionUID()
Source
ConsumerEventInit.scala
Linear Supertypes
Updatable[ConsumerEventInit], GeneratedMessage, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ConsumerEventInit
  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 ConsumerEventInit(originId: String = "", streamId: String = "", fillSequenceNumberGaps: Boolean = false, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty)

    originId

    unique producer identifier showing where the events came from/was produced

    streamId

    the stream id of the type of entity the producer wants to push

    fillSequenceNumberGaps

    if gaps in sequence numbers may exist and should be filled in

Value Members

  1. def companion: ConsumerEventInit.type
    Definition Classes
    ConsumerEventInit → GeneratedMessage
  2. def discardUnknownFields: ConsumerEventInit
  3. val fillSequenceNumberGaps: Boolean
  4. def getField(__field: FieldDescriptor): PValue
    Definition Classes
    ConsumerEventInit → GeneratedMessage
  5. def getFieldByNumber(__fieldNumber: Int): Any
    Definition Classes
    ConsumerEventInit → GeneratedMessage
  6. val originId: String
  7. def productElementNames: Iterator[String]
    Definition Classes
    Product
  8. def serializedSize: Int
    Definition Classes
    ConsumerEventInit → GeneratedMessage
  9. val streamId: String
  10. final def toByteArray: Array[Byte]
    Definition Classes
    GeneratedMessage
  11. final def toByteString: ByteString
    Definition Classes
    GeneratedMessage
  12. final def toPMessage: PMessage
    Definition Classes
    GeneratedMessage
  13. def toProtoString: String
    Definition Classes
    ConsumerEventInit → GeneratedMessage
  14. val unknownFields: UnknownFieldSet
  15. def update(ms: (Lens[ConsumerEventInit, ConsumerEventInit]) => Mutation[ConsumerEventInit]*): ConsumerEventInit
    Definition Classes
    Updatable
  16. def withFillSequenceNumberGaps(__v: Boolean): ConsumerEventInit
  17. def withOriginId(__v: String): ConsumerEventInit
  18. def withStreamId(__v: String): ConsumerEventInit
  19. def withUnknownFields(__v: UnknownFieldSet): ConsumerEventInit
  20. final def writeDelimitedTo(output: OutputStream): Unit
    Definition Classes
    GeneratedMessage
  21. def writeTo(_output__: CodedOutputStream): Unit
    Definition Classes
    ConsumerEventInit → GeneratedMessage
  22. final def writeTo(output: OutputStream): Unit
    Definition Classes
    GeneratedMessage