OffsetSeq¶

Creating Instance¶

OffsetSeq takes the following to be created:

• Offsets (Seq[Option[OffsetV2]])
• OffsetSeqMetadata

OffsetSeq is created when:

• OffsetSeq is requested to fill
• StreamProgress is requested to toOffsetSeq

fill¶

fill(
  offsets: Offset*): OffsetSeq // (1)!
fill(
  metadata: Option[String],
  offsets: Offset*): OffsetSeq

1. Uses no metadata

fill...FIXME

fill is used when:

• OffsetSeqLog is requested to deserialize an OffsetSeq
• ContinuousExecution is requested to getStartOffsets, addOffset