geowatchutil.client.geowatch_client_kinesis module

class geowatchutil.client.geowatch_client_kinesis.GeoWatchClientKinesis(topic_prefix='', aws_region=None, aws_access_key_id=None, aws_secret_access_key=None)[source]

Bases: geowatchutil.client.base.GeoWatchClientTopic

check_topic_exists(topic, timeout=5, verbose=True)[source]
create_topic(topic, shards=1, timeout=5, verbose=True)[source]
delete_topic(topic, timeout=5, verbose=True)[source]
delete_topics(topics, ignore_errors=True, timeout=5, verbose=True)[source]
list_topics(limit=100, verbose=True)[source]
wait_topic(topic, verbose=False)[source]