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

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

Link to this type describe_stream_opts() View Source
describe_stream_opts() :: [limit: pos_integer(), exclusive_start_shard_id: binary()]
Link to this type get_records_opts() View Source
get_records_opts() :: [{:limit, pos_integer()}]
Link to this type get_shard_iterator_opts() View Source
get_shard_iterator_opts() :: [{:sequence_number, binary()}]
Link to this type list_stream_opts() View Source
list_stream_opts() :: [limit: pos_integer(), exclusive_start_stream_arn: binary(), table_name: binary()]
Link to this type shard_iterator_types() View Source
shard_iterator_types() ::
  :at_sequence_number |
  :after_sequence_number |
  :trim_horizon |
  :latest
Link to this type stream_arn() View Source
stream_arn() :: binary()

Link to this section Functions

Link to this function describe_stream(stream_arn, opts \\ []) View Source
describe_stream(stream_arn :: stream_arn(), opts :: describe_stream_opts()) :: ExAws.Operation.JSON.t()

Describe Stream

Link to this function get_records(shard_iterator, opts \\ []) View Source
get_records(shard_iterator :: binary(), opts :: get_records_opts()) :: ExAws.Operation.JSON.t()

Get stream records

Link to this function get_shard_iterator(stream_arn, shard_id, shard_iterator_type, opts \\ []) View Source
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

Link to this function list_streams(opts \\ []) View Source
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.