ExAws.Kinesis

Summary

add_tags_to_stream(adapter, name, tags)
create_stream(adapter, name, shard_count)
delete_stream(adapter, name)
describe_stream(adapter, name, opts)
get_records(adapter, shard_iterator, opts)
get_shard_iterator(adapter, name, shard_id, shard_iterator_type, opts)
list_streams(adapter)
list_tags_for_stream(adapter, name, opts)
merge_shards(adapter, name, adjacent_shard, shard)
put_record(adapter, stream_name, partition_key, data, opts)
put_records(adapter, stream_name, records)
remove_tags_for_stream(adapter, name, tag_keys)
request(data, action, adapter)
split_shard(adapter, name, shard, new_starting_hash_key)

Functions

add_tags_to_stream(adapter, name, tags)
create_stream(adapter, name, shard_count)
delete_stream(adapter, name)
describe_stream(adapter, name, opts)
get_records(adapter, shard_iterator, opts)
get_shard_iterator(adapter, name, shard_id, shard_iterator_type, opts)
list_streams(adapter)
list_tags_for_stream(adapter, name, opts)
merge_shards(adapter, name, adjacent_shard, shard)
put_record(adapter, stream_name, partition_key, data, opts)
put_records(adapter, stream_name, records)
remove_tags_for_stream(adapter, name, tag_keys)
request(data, action, adapter)
split_shard(adapter, name, shard, new_starting_hash_key)