kinesis

Example usage 

@mock_kinesis
def test_kinesis_behaviour:
    boto3.client("kinesis")
    ...

Implemented features for this service

  • [X] add_tags_to_stream

  • [X] create_stream

  • [X] decrease_stream_retention_period

  • [X] delete_stream

  • [X] deregister_stream_consumer

  • [ ] describe_limits

  • [X] describe_stream

  • [X] describe_stream_consumer

  • [X] describe_stream_summary

  • [X] disable_enhanced_monitoring

  • [X] enable_enhanced_monitoring

  • [X] get_records

  • [X] get_shard_iterator

  • [X] increase_stream_retention_period

  • [X] list_shards

  • [X] list_stream_consumers

    Pagination is not yet implemented

  • [X] list_streams

  • [X] list_tags_for_stream

  • [X] merge_shards

  • [X] put_record

  • [X] put_records

  • [X] register_stream_consumer

  • [X] remove_tags_from_stream

  • [X] split_shard

  • [X] start_stream_encryption

  • [X] stop_stream_encryption

  • [ ] subscribe_to_shard

  • [X] update_shard_count

  • [X] update_stream_mode