Current section

Files

Jump to
erlcloud include erlcloud_ddb_streams.hrl
Raw

include/erlcloud_ddb_streams.hrl

-record(ddb_streams_stream,
{stream_arn :: erlcloud_ddb_streams:stream_arn(),
stream_label :: erlcloud_ddb_streams:stream_label(),
table_name :: erlcloud_ddb_streams:table_name()
}).
-record(ddb_streams_shard,
{parent_shard_id :: erlcloud_ddb_streams:shard_id(),
sequence_number_range :: erlcloud_ddb_streams:sequence_number_range(),
shard_id :: erlcloud_ddb_streams:shard_id()
}).
-record(ddb_streams_stream_description,
{creation_request_date_time :: number(),
key_schema :: erlcloud_ddb_streams:key_schema(),
last_evaluated_shard_id :: erlcloud_ddb_streams:shard_id(),
shards :: [#ddb_streams_shard{}],
stream_arn :: erlcloud_ddb_streams:stream_arn(),
stream_label :: erlcloud_ddb_streams:stream_label(),
stream_status :: erlcloud_ddb_streams:stream_status(),
stream_view_type :: erlcloud_ddb_streams:stream_view_type(),
table_name :: erlcloud_ddb_streams:table_name()
}).
-record(ddb_streams_stream_record,
{keys :: erlcloud_ddb_streams:key(),
new_image :: erlcloud_ddb_streams:item(),
old_image :: erlcloud_ddb_streams:item(),
sequence_number :: erlcloud_ddb_streams:sequence_number(),
size_bytes :: pos_integer(),
stream_view_type :: erlcloud_ddb_streams:stream_view_type()}).
-record(ddb_streams_record,
{aws_region :: erlcloud_ddb_streams:aws_region(),
dynamodb :: #ddb_streams_stream_record{},
event_id :: erlcloud_ddb_streams:event_id(),
event_name :: erlcloud_ddb_streams:event_name(),
event_source :: erlcloud_ddb_streams:event_source(),
event_version :: erlcloud_ddb_streams:event_version()
}).
-record(ddb_streams_describe_stream,
{stream_description :: #ddb_streams_stream_description{}
}).
-record(ddb_streams_get_records,
{next_shard_iterator :: erlcloud_ddb_streams:shard_iterator(),
records :: [#ddb_streams_record{}]
}).
-record(ddb_streams_get_shard_iterator,
{shard_iterator :: erlcloud_ddb_streams:shard_iterator()
}).
-record(ddb_streams_list_streams,
{last_evaluated_stream_arn :: erlcloud_ddb_streams:stream_arn(),
streams :: [#ddb_streams_stream{}]
}).