Module Smaws_Client_DynamoDBStreamsSource

Sourcetype trimmed_data_access_exception = {
  1. message : string option;
}
Sourcetype stream_view_type =
  1. | KEYS_ONLY
  2. | NEW_AND_OLD_IMAGES
  3. | OLD_IMAGE
  4. | NEW_IMAGE
Sourcetype stream_status =
  1. | DISABLED
  2. | DISABLING
  3. | ENABLED
  4. | ENABLING
Sourcetype attribute_value =
  1. | BOOL of bool
  2. | NULL of bool
  3. | L of attribute_value list
  4. | M of (string * attribute_value) list
  5. | BS of bytes list
  6. | NS of string list
  7. | SS of string list
  8. | B of bytes
  9. | N of string
  10. | S of string
Sourcetype stream_record = {
  1. stream_view_type : stream_view_type option;
  2. size_bytes : int option;
  3. sequence_number : string option;
  4. old_image : (string * attribute_value) list option;
  5. new_image : (string * attribute_value) list option;
  6. keys : (string * attribute_value) list option;
  7. approximate_creation_date_time : float option;
}
Sourcetype stream = {
  1. stream_label : string option;
  2. table_name : string option;
  3. stream_arn : string option;
}
Sourcetype key_type =
  1. | RANGE
  2. | HASH
Sourcetype key_schema_element = {
  1. key_type : key_type;
  2. attribute_name : string;
}
Sourcetype sequence_number_range = {
  1. ending_sequence_number : string option;
  2. starting_sequence_number : string option;
}
Sourcetype shard = {
  1. parent_shard_id : string option;
  2. sequence_number_range : sequence_number_range option;
  3. shard_id : string option;
}
Sourcetype stream_description = {
  1. last_evaluated_shard_id : string option;
  2. shards : shard list option;
  3. key_schema : key_schema_element list option;
  4. table_name : string option;
  5. creation_request_date_time : float option;
  6. stream_view_type : stream_view_type option;
  7. stream_status : stream_status option;
  8. stream_label : string option;
  9. stream_arn : string option;
}
Sourcetype shard_iterator_type =
  1. | AFTER_SEQUENCE_NUMBER
  2. | AT_SEQUENCE_NUMBER
  3. | LATEST
  4. | TRIM_HORIZON
Sourcetype resource_not_found_exception = {
  1. message : string option;
}
Sourcetype operation_type =
  1. | REMOVE
  2. | MODIFY
  3. | INSERT
Sourcetype identity = {
  1. type_ : string option;
  2. principal_id : string option;
}
Sourcetype record = {
  1. user_identity : identity option;
  2. dynamodb : stream_record option;
  3. aws_region : string option;
  4. event_source : string option;
  5. event_version : string option;
  6. event_name : operation_type option;
  7. event_i_d : string option;
}
Sourcetype list_streams_output = {
  1. last_evaluated_stream_arn : string option;
  2. streams : stream list option;
}
Sourcetype list_streams_input = {
  1. exclusive_start_stream_arn : string option;
  2. limit : int option;
  3. table_name : string option;
}
Sourcetype internal_server_error = {
  1. message : string option;
}
Sourcetype limit_exceeded_exception = {
  1. message : string option;
}
Sourcetype get_shard_iterator_output = {
  1. shard_iterator : string option;
}
Sourcetype get_shard_iterator_input = {
  1. sequence_number : string option;
  2. shard_iterator_type : shard_iterator_type;
  3. shard_id : string;
  4. stream_arn : string;
}
Sourcetype get_records_output = {
  1. next_shard_iterator : string option;
  2. records : record list option;
}
Sourcetype get_records_input = {
  1. limit : int option;
  2. shard_iterator : string;
}
Sourcetype expired_iterator_exception = {
  1. message : string option;
}
Sourcetype describe_stream_output = {
  1. stream_description : stream_description option;
}
Sourcetype describe_stream_input = {
  1. exclusive_start_shard_id : string option;
  2. limit : int option;
  3. stream_arn : string;
}
Sourcetype base_document = Smaws_Lib.Json.t
Sourceval make_stream_record : ?stream_view_type:stream_view_type -> ?size_bytes:int -> ?sequence_number:string -> ?old_image:(string * attribute_value) list -> ?new_image:(string * attribute_value) list -> ?keys:(string * attribute_value) list -> ?approximate_creation_date_time:float -> unit -> stream_record
Sourceval make_stream : ?stream_label:string -> ?table_name:string -> ?stream_arn:string -> unit -> stream
Sourceval make_key_schema_element : key_type:key_type -> attribute_name:string -> unit -> key_schema_element
Sourceval make_sequence_number_range : ?ending_sequence_number:string -> ?starting_sequence_number:string -> unit -> sequence_number_range
Sourceval make_shard : ?parent_shard_id:string -> ?sequence_number_range:sequence_number_range -> ?shard_id:string -> unit -> shard
Sourceval make_stream_description : ?last_evaluated_shard_id:string -> ?shards:shard list -> ?key_schema:key_schema_element list -> ?table_name:string -> ?creation_request_date_time:float -> ?stream_view_type:stream_view_type -> ?stream_status:stream_status -> ?stream_label:string -> ?stream_arn:string -> unit -> stream_description
Sourceval make_identity : ?type_:string -> ?principal_id:string -> unit -> identity
Sourceval make_record : ?user_identity:identity -> ?dynamodb:stream_record -> ?aws_region:string -> ?event_source:string -> ?event_version:string -> ?event_name:operation_type -> ?event_i_d:string -> unit -> record
Sourceval make_list_streams_output : ?last_evaluated_stream_arn:string -> ?streams:stream list -> unit -> list_streams_output
Sourceval make_list_streams_input : ?exclusive_start_stream_arn:string -> ?limit:int -> ?table_name:string -> unit -> list_streams_input
Sourceval make_get_shard_iterator_output : ?shard_iterator:string -> unit -> get_shard_iterator_output
Sourceval make_get_shard_iterator_input : ?sequence_number:string -> shard_iterator_type:shard_iterator_type -> shard_id:string -> stream_arn:string -> unit -> get_shard_iterator_input
Sourceval make_get_records_output : ?next_shard_iterator:string -> ?records:record list -> unit -> get_records_output
Sourceval make_get_records_input : ?limit:int -> shard_iterator:string -> unit -> get_records_input
Sourceval make_describe_stream_output : ?stream_description:stream_description -> unit -> describe_stream_output
Sourceval make_describe_stream_input : ?exclusive_start_shard_id:string -> ?limit:int -> stream_arn:string -> unit -> describe_stream_input
Sourcemodule ListStreams : sig ... end
Sourcemodule GetShardIterator : sig ... end
Sourcemodule GetRecords : sig ... end
Sourcemodule DescribeStream : sig ... end