Values.SubscribeToShardEventSourceAfter you call SubscribeToShard, Kinesis Data Streams sends events of this type over an HTTP/2 connection to your consumer.
type nonrec t = {records : RecordList.t option;continuationSequenceNumber : SequenceNumber.t option;Use this as SequenceNumber in the next call to SubscribeToShard, with StartingPosition set to AT_SEQUENCE_NUMBER or AFTER_SEQUENCE_NUMBER. Use ContinuationSequenceNumber for checkpointing because it captures your shard progress even when no data is written to the shard.
*)millisBehindLatest : MillisBehindLatest.t option;The number of milliseconds the read records are from the tip of the stream, indicating how far behind current time the consumer is. A value of zero indicates that record processing is caught up, and there are no new records to process at this moment.
*)childShards : ChildShardList.t option;The list of the child shards of the current shard, returned only at the end of the current shard.
*)}val to_value :
t ->
[> `Structure of
(string
* [> `List of
[> `Structure of
(string
* [> `Blob of Data.t
| `Enum of string
| `List of [> `String of ShardId.t ] list
| `String of SequenceNumber.t
| `Structure of
(string * [> `String of HashKey.t ]) list
| `Timestamp of Timestamp.t ])
list ]
list
| `Long of MillisBehindLatest.t
| `String of SequenceNumber.t ])
list ]