Smaws_Client_DynamoDBStreams
DynamoDB Streams client library built on EIO.
module Types : sig ... end
val make_stream_record :
?stream_view_type:Types.stream_view_type ->
?size_bytes:Types.positive_long_object ->
?sequence_number:Types.sequence_number ->
?old_image:Types.attribute_map ->
?new_image:Types.attribute_map ->
?keys:Types.attribute_map ->
?approximate_creation_date_time:Types.date ->
unit ->
Types.stream_record
val make_stream :
?stream_label:Types.string_ ->
?table_name:Types.table_name ->
?stream_arn:Types.stream_arn ->
unit ->
Types.stream
val make_key_schema_element :
key_type:Types.key_type ->
attribute_name:Types.key_schema_attribute_name ->
unit ->
Types.key_schema_element
val make_sequence_number_range :
?ending_sequence_number:Types.sequence_number ->
?starting_sequence_number:Types.sequence_number ->
unit ->
Types.sequence_number_range
val make_shard :
?parent_shard_id:Types.shard_id ->
?sequence_number_range:Types.sequence_number_range ->
?shard_id:Types.shard_id ->
unit ->
Types.shard
val make_stream_description :
?last_evaluated_shard_id:Types.shard_id ->
?shards:Types.shard_description_list ->
?key_schema:Types.key_schema ->
?table_name:Types.table_name ->
?creation_request_date_time:Types.date ->
?stream_view_type:Types.stream_view_type ->
?stream_status:Types.stream_status ->
?stream_label:Types.string_ ->
?stream_arn:Types.stream_arn ->
unit ->
Types.stream_description
val make_identity :
?type_:Types.string_ ->
?principal_id:Types.string_ ->
unit ->
Types.identity
val make_record :
?user_identity:Types.identity ->
?dynamodb:Types.stream_record ->
?aws_region:Types.string_ ->
?event_source:Types.string_ ->
?event_version:Types.string_ ->
?event_name:Types.operation_type ->
?event_i_d:Types.string_ ->
unit ->
Types.record
val make_list_streams_output :
?last_evaluated_stream_arn:Types.stream_arn ->
?streams:Types.stream_list ->
unit ->
Types.list_streams_output
val make_list_streams_input :
?exclusive_start_stream_arn:Types.stream_arn ->
?limit:Types.positive_integer_object ->
?table_name:Types.table_name ->
unit ->
Types.list_streams_input
val make_get_shard_iterator_output :
?shard_iterator:Types.shard_iterator ->
unit ->
Types.get_shard_iterator_output
val make_get_shard_iterator_input :
?sequence_number:Types.sequence_number ->
shard_iterator_type:Types.shard_iterator_type ->
shard_id:Types.shard_id ->
stream_arn:Types.stream_arn ->
unit ->
Types.get_shard_iterator_input
val make_get_records_output :
?next_shard_iterator:Types.shard_iterator ->
?records:Types.record_list ->
unit ->
Types.get_records_output
val make_get_records_input :
?limit:Types.positive_integer_object ->
shard_iterator:Types.shard_iterator ->
unit ->
Types.get_records_input
val make_describe_stream_output :
?stream_description:Types.stream_description ->
unit ->
Types.describe_stream_output
val make_describe_stream_input :
?exclusive_start_shard_id:Types.shard_id ->
?limit:Types.positive_integer_object ->
stream_arn:Types.stream_arn ->
unit ->
Types.describe_stream_input
Operations
module DescribeStream : sig ... end
Returns information about a stream, including the current status of the stream, its Amazon Resource Name (ARN), the composition of its shards, and its corresponding DynamoDB table.
module GetRecords : sig ... end
Retrieves the stream records from a given shard.
module GetShardIterator : sig ... end
Returns a shard iterator. A shard iterator provides information about how to retrieve the stream records from within a shard. Use the shard iterator in a subsequent GetRecords
request to read the stream records from the shard.
module ListStreams : sig ... end
Returns an array of stream ARNs associated with the current account and endpoint. If the TableName
parameter is present, then ListStreams
will return only the streams ARNs for that table.
module Json_serializers : sig ... end
module Json_deserializers : sig ... end