Smaws_Client_DynamoDBStreams (smaws-clients.Smaws_Client

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_shard_filter : 
  ?shard_id:Types.shard_id ->
  ?type_:Types.shard_filter_type ->
  unit ->
  Types.shard_filter

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 : 
  ?shard_filter:Types.shard_filter ->
  ?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

module Json_serializers : sig ... end

module Json_deserializers : sig ... end