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]¶