Instance Constructors

1.  new InitReq(streamId: String = "", sliceMin: Int = 0, sliceMax: Int = 0, offset: Seq[Offset] = _root_.scala.Seq.empty, filter: Seq[FilterCriteria] = _root_.scala.Seq.empty, replicaInfo: Option[ReplicaInfo] = _root_.scala.None, correlationId: Option[String] = _root_.scala.None, keepAliveIntervalMillis: Long = 0L, keepAliveTimeoutMillis: Long = 0L, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty)
   streamId

   the logical stream identifier, mapped to a specific internal entity type by the producer settings

   sliceMin

   entities are partitioned by a deterministic slice (0-1023), a consumer would handle a slice range from slice_min to slice_max

   offset

   start from this offset if empty, then NoOffset if single and no slice defined, then TimestampOffset if any and slice defined, then TimestampOffsetBySlice

   filter

   consumer defined event filters

   keepAliveIntervalMillis

   if greater than 0 the producer will emit StreamOut.keep_alive messages when no events have been emitted for this many milliseconds, to keep the connection alive end-to-end through proxies and load balancers. The producer clamps the interval to between 1 second and 1 hour, and emits one keep alive right away when the stream starts.

   keepAliveTimeoutMillis

   if greater than 0 the producer fails the stream when no StreamIn.keep_alive has arrived from the consumer for this many milliseconds, counted once the consumer has sent its first one. At least twice the interval.