| D | layer1.py | 71 def add_tags_to_stream(self, stream_name, tags): argument
91 def create_stream(self, stream_name, shard_count): argument
165 def delete_stream(self, stream_name): argument
199 def describe_stream(self, stream_name, limit=None, argument
337 def get_shard_iterator(self, stream_name, shard_id, shard_iterator_type, argument
463 def list_tags_for_stream(self, stream_name, exclusive_start_tag_key=None, argument
491 def merge_shards(self, stream_name, shard_to_merge, argument
559 def put_record(self, stream_name, data, partition_key, argument
662 def put_records(self, records, stream_name, b64_encode=True): argument
750 def remove_tags_from_stream(self, stream_name, tag_keys): argument
[all …]
|