Smaws_Client_KeyspacesStreams (smaws-clients.Smaws_Client

Types

module Types : sig ... end

Builders

val make_stream : 
  stream_label:Smaws_Lib.Smithy_api.Types.string_ ->
  table_name:Types.table_name ->
  keyspace_name:Types.keyspace_name ->
  stream_arn:Types.stream_arn ->
  unit ->
  Types.stream

val make_shard_filter : 
  ?shard_id:Types.shard_id ->
  ?type_:Types.shard_filter_type ->
  unit ->
  Types.shard_filter

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_ids:Types.shard_id_list ->
  ?sequence_number_range:Types.sequence_number_range ->
  ?shard_id:Types.shard_id ->
  unit ->
  Types.shard

val make_keyspaces_metadata : 
  ?write_time:Smaws_Lib.Smithy_api.Types.string_ ->
  ?expiration_time:Smaws_Lib.Smithy_api.Types.string_ ->
  unit ->
  Types.keyspaces_metadata

val make_keyspaces_cell : 
  ?metadata:Types.keyspaces_metadata ->
  ?value:Types.keyspaces_cell_value ->
  unit ->
  Types.keyspaces_cell

val make_keyspaces_cell_map_definition : 
  ?metadata:Types.keyspaces_metadata ->
  ?value:Types.keyspaces_cell_value ->
  ?key:Types.keyspaces_cell_value ->
  unit ->
  Types.keyspaces_cell_map_definition

val make_keyspaces_row : 
  ?row_metadata:Types.keyspaces_metadata ->
  ?static_cells:Types.keyspaces_cells ->
  ?value_cells:Types.keyspaces_cells ->
  unit ->
  Types.keyspaces_row

val make_record : 
  ?sequence_number:Types.sequence_number ->
  ?old_image:Types.keyspaces_row ->
  ?new_image:Types.keyspaces_row ->
  ?clustering_keys:Types.keyspaces_keys_map ->
  ?partition_keys:Types.keyspaces_keys_map ->
  ?origin:Types.origin_type ->
  ?created_at:Types.date ->
  ?event_version:Smaws_Lib.Smithy_api.Types.string_ ->
  unit ->
  Types.record

val make_list_streams_output : 
  ?next_token:Types.stream_arn_token ->
  ?streams:Types.stream_list ->
  unit ->
  Types.list_streams_output

val make_list_streams_input : 
  ?next_token:Types.stream_arn_token ->
  ?max_results:Smaws_Lib.Smithy_api.Types.integer ->
  ?table_name:Types.table_name ->
  ?keyspace_name:Types.keyspace_name ->
  unit ->
  Types.list_streams_input

val make_get_stream_output : 
  ?next_token:Types.shard_id_token ->
  ?shards:Types.shard_description_list ->
  table_name:Types.table_name ->
  keyspace_name:Types.keyspace_name ->
  creation_request_date_time:Types.date ->
  stream_view_type:Types.stream_view_type ->
  stream_status:Types.stream_status ->
  stream_label:Smaws_Lib.Smithy_api.Types.string_ ->
  stream_arn:Types.stream_arn ->
  unit ->
  Types.get_stream_output

val make_get_stream_input : 
  ?next_token:Types.shard_id_token ->
  ?shard_filter:Types.shard_filter ->
  ?max_results:Smaws_Lib.Smithy_api.Types.integer ->
  stream_arn:Types.stream_arn ->
  unit ->
  Types.get_stream_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_iterator_description : 
  ?iterator_position:Types.iterator_position ->
  unit ->
  Types.iterator_description

val make_get_records_output : 
  ?iterator_description:Types.iterator_description ->
  ?next_shard_iterator:Types.shard_iterator ->
  ?change_records:Types.record_list ->
  unit ->
  Types.get_records_output

val make_get_records_input : 
  ?max_results:Smaws_Lib.Smithy_api.Types.integer ->
  shard_iterator:Types.shard_iterator ->
  unit ->
  Types.get_records_input

Operations

module GetRecords : sig ... end

Retrieves data records from a specified shard in an Amazon Keyspaces data stream. This operation returns a collection of data records from the shard, including the primary key columns and information about modifications made to the captured table data. Each record represents a single data modification in the Amazon Keyspaces table and includes metadata about when the change occurred.

module GetShardIterator : sig ... end

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.

module GetStream : sig ... end

Returns detailed information about a specific data capture stream for an Amazon Keyspaces table. The information includes the stream's Amazon Resource Name (ARN), creation time, current status, retention period, shard composition, and associated table details. This operation helps you monitor and manage the configuration of your Amazon Keyspaces data streams.

module ListStreams : sig ... end

module Json_serializers : sig ... end

module Json_deserializers : sig ... end