ExAws.DynamoStreams v2.0.0 ExAws.DynamoStreams View Source
Operations on DynamoDB Streams
http://docs.aws.amazon.com/dynamodbstreams/latest/APIReference/API_Operations.html
NOTE: When Mix.env in [:test, :dev] dynamo clients will run by default against Dynamodb local.
Enabling/Disabling streams on a table is performed through the Dynamo.update_table
operation.
The stream arn can then be retrieved with Dynamo.describe_table
in the LatestStreamArn
key.
Link to this section Summary
Functions
Describe Stream
Get stream records
Get a shard iterator
Lists all of the streams associated with an account. If you have multiple streams on a table (created by disabling/enabling the stream) you may have difficulty identifying the active stream from this operation
Link to this section Types
describe_stream_opts() :: [limit: pos_integer(), exclusive_start_shard_id: binary()]
get_shard_iterator_opts() :: [{:sequence_number, binary()}]
list_stream_opts() :: [limit: pos_integer(), exclusive_start_stream_arn: binary(), table_name: binary()]
shard_iterator_types() :: :at_sequence_number | :after_sequence_number | :trim_horizon | :latest
Link to this section Functions
describe_stream(stream_arn :: stream_arn(), opts :: describe_stream_opts()) :: ExAws.Operation.JSON.t()
Describe Stream
get_records(shard_iterator :: binary(), opts :: get_records_opts()) :: ExAws.Operation.JSON.t()
Get stream records
get_shard_iterator(stream_arn :: stream_arn(), shard_id :: binary(), shard_iterator_type :: shard_iterator_types(), opts :: get_shard_iterator_opts()) :: ExAws.Operation.JSON.t()
Get a shard iterator
list_streams(opts :: list_stream_opts()) :: ExAws.Operation.JSON.t()
Lists all of the streams associated with an account. If you have multiple streams on a table (created by disabling/enabling the stream) you may have difficulty identifying the active stream from this operation.