Module Values.GetShardIteratorInputSource

Returns a shard iterator that serves as a bookmark for reading data from a specific position in an Amazon Keyspaces data stream's shard. The shard iterator specifies the shard position from which to start reading data records sequentially. You can specify whether to begin reading at the latest record, the oldest record, or at a particular sequence number within the shard.

Sourcetype nonrec t = {
  1. streamArn : StreamArn.t;
    (*

    The Amazon Resource Name (ARN) of the stream for which to get the shard iterator. The ARN uniquely identifies the stream within Amazon Keyspaces.

    *)
  2. shardId : ShardId.t;
    (*

    The identifier of the shard within the stream. The shard ID uniquely identifies a subset of the stream's data records that you want to access.

    *)
  3. shardIteratorType : ShardIteratorType.t;
    (*

    Determines how the shard iterator is positioned. Must be one of the following: TRIM_HORIZON - Start reading at the last untrimmed record in the shard, which is the oldest data record in the shard. AT_SEQUENCE_NUMBER - Start reading exactly from the specified sequence number. AFTER_SEQUENCE_NUMBER - Start reading right after the specified sequence number. LATEST - Start reading just after the most recent record in the shard, so that you always read the most recent data.

    *)
  4. sequenceNumber : SequenceNumber.t option;
    (*

    The sequence number of the data record in the shard from which to start reading. Required if ShardIteratorType is AT_SEQUENCE_NUMBER or AFTER_SEQUENCE_NUMBER. This parameter is ignored for other iterator types.

    *)
}
Sourceval context_ : string
Sourceval make : ?sequenceNumber:??? -> streamArn:StreamArn.t -> shardId:ShardId.t -> shardIteratorType:ShardIteratorType.t -> unit -> t
Sourceval to_value : t -> [> `Structure of (string * [> `Enum of string | `String of StreamArn.t ]) list ]
Sourceval to_query : t -> Awso.Client.Query.t
Sourceval of_xml : Awso.Xml.t -> t
Sourceval of_string : string -> t
Sourceval of_json : Yojson.Safe.t -> t
Sourceval to_json : t -> Yojson.Safe.t