Module Smaws_Client_DynamoDBStreams

DynamoDB Streams client library built on EIO.

Types

module Types : sig ... end

Builders

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