LICENSE
README.md
pyproject.toml
src/capo_firehose/__init__.py
src/capo_firehose/_async.py
src/capo_firehose/_iter.py
src/capo_firehose/_pagination.py
src/capo_firehose/py.typed
src/capo_firehose.egg-info/PKG-INFO
src/capo_firehose.egg-info/SOURCES.txt
src/capo_firehose.egg-info/dependency_links.txt
src/capo_firehose.egg-info/requires.txt
src/capo_firehose.egg-info/top_level.txt
src/capo_firehose/_auth/_identity.py
src/capo_firehose/_auth/_providers.py
src/capo_firehose/_auth/_signers.py
src/capo_firehose/_auth/_sigv4.py
src/capo_firehose/_auth/_zapros_handler.py
src/capo_firehose/_operations/firehose_20150804/create_delivery_stream.py
src/capo_firehose/_operations/firehose_20150804/delete_delivery_stream.py
src/capo_firehose/_operations/firehose_20150804/describe_delivery_stream.py
src/capo_firehose/_operations/firehose_20150804/list_delivery_streams.py
src/capo_firehose/_operations/firehose_20150804/list_tags_for_delivery_stream.py
src/capo_firehose/_operations/firehose_20150804/put_record.py
src/capo_firehose/_operations/firehose_20150804/put_record_batch.py
src/capo_firehose/_operations/firehose_20150804/start_delivery_stream_encryption.py
src/capo_firehose/_operations/firehose_20150804/stop_delivery_stream_encryption.py
src/capo_firehose/_operations/firehose_20150804/tag_delivery_stream.py
src/capo_firehose/_operations/firehose_20150804/untag_delivery_stream.py
src/capo_firehose/_operations/firehose_20150804/update_destination.py
src/capo_firehose/_protocol/__init__.py
src/capo_firehose/_protocol/errors.py
src/capo_firehose/_protocol/eventstream.py
src/capo_firehose/_protocol/serialize.py
src/capo_firehose/_protocol/xml.py
src/capo_firehose/_rule_engine/__init__.py
src/capo_firehose/_rule_engine/_aws_partition.py
src/capo_firehose/_rule_engine/_endpoint_rule_set.py
src/capo_firehose/_rule_engine/_endpoint_runtime.py
src/capo_firehose/_services/_aws_config.py
src/capo_firehose/_services/_pipeline.py
src/capo_firehose/_services/async_firehose.py
src/capo_firehose/_services/firehose.py
src/capo_firehose/errors/__init__.py
src/capo_firehose/errors/_base.py
src/capo_firehose/errors/concurrent_modification_exception.py
src/capo_firehose/errors/invalid_argument_exception.py
src/capo_firehose/errors/invalid_kms_resource_exception.py
src/capo_firehose/errors/invalid_source_exception.py
src/capo_firehose/errors/limit_exceeded_exception.py
src/capo_firehose/errors/resource_in_use_exception.py
src/capo_firehose/errors/resource_not_found_exception.py
src/capo_firehose/errors/service_unavailable_exception.py
src/capo_firehose/types/amazon_open_search_serverless_buffering_hints.py
src/capo_firehose/types/amazon_open_search_serverless_buffering_interval_in_seconds.py
src/capo_firehose/types/amazon_open_search_serverless_buffering_size_in_m_bs.py
src/capo_firehose/types/amazon_open_search_serverless_collection_endpoint.py
src/capo_firehose/types/amazon_open_search_serverless_destination_configuration.py
src/capo_firehose/types/amazon_open_search_serverless_destination_description.py
src/capo_firehose/types/amazon_open_search_serverless_destination_update.py
src/capo_firehose/types/amazon_open_search_serverless_index_name.py
src/capo_firehose/types/amazon_open_search_serverless_retry_duration_in_seconds.py
src/capo_firehose/types/amazon_open_search_serverless_retry_options.py
src/capo_firehose/types/amazon_open_search_serverless_s3_backup_mode.py
src/capo_firehose/types/amazonopensearchservice_buffering_hints.py
src/capo_firehose/types/amazonopensearchservice_buffering_interval_in_seconds.py
src/capo_firehose/types/amazonopensearchservice_buffering_size_in_m_bs.py
src/capo_firehose/types/amazonopensearchservice_cluster_endpoint.py
src/capo_firehose/types/amazonopensearchservice_destination_configuration.py
src/capo_firehose/types/amazonopensearchservice_destination_description.py
src/capo_firehose/types/amazonopensearchservice_destination_update.py
src/capo_firehose/types/amazonopensearchservice_domain_arn.py
src/capo_firehose/types/amazonopensearchservice_index_name.py
src/capo_firehose/types/amazonopensearchservice_index_rotation_period.py
src/capo_firehose/types/amazonopensearchservice_retry_duration_in_seconds.py
src/capo_firehose/types/amazonopensearchservice_retry_options.py
src/capo_firehose/types/amazonopensearchservice_s3_backup_mode.py
src/capo_firehose/types/amazonopensearchservice_type_name.py
src/capo_firehose/types/authentication_configuration.py
src/capo_firehose/types/awskms_key_arn.py
src/capo_firehose/types/block_size_bytes.py
src/capo_firehose/types/boolean_object.py
src/capo_firehose/types/bucket_arn.py
src/capo_firehose/types/buffering_hints.py
src/capo_firehose/types/catalog_configuration.py
src/capo_firehose/types/cloud_watch_logging_options.py
src/capo_firehose/types/cluster_jdbcurl.py
src/capo_firehose/types/column_to_json_key_mappings.py
src/capo_firehose/types/compression_format.py
src/capo_firehose/types/connectivity.py
src/capo_firehose/types/content_encoding.py
src/capo_firehose/types/copy_command.py
src/capo_firehose/types/copy_options.py
src/capo_firehose/types/create_delivery_stream_input.py
src/capo_firehose/types/create_delivery_stream_output.py
src/capo_firehose/types/custom_time_zone.py
src/capo_firehose/types/data.py
src/capo_firehose/types/data_format_conversion_configuration.py
src/capo_firehose/types/data_table_columns.py
src/capo_firehose/types/data_table_name.py
src/capo_firehose/types/database_column_include_or_exclude_list.py
src/capo_firehose/types/database_column_list.py
src/capo_firehose/types/database_column_name.py
src/capo_firehose/types/database_endpoint.py
src/capo_firehose/types/database_include_or_exclude_list.py
src/capo_firehose/types/database_list.py
src/capo_firehose/types/database_name.py
src/capo_firehose/types/database_port.py
src/capo_firehose/types/database_snapshot_info.py
src/capo_firehose/types/database_snapshot_info_list.py
src/capo_firehose/types/database_source_authentication_configuration.py
src/capo_firehose/types/database_source_configuration.py
src/capo_firehose/types/database_source_description.py
src/capo_firehose/types/database_source_vpc_configuration.py
src/capo_firehose/types/database_surrogate_key_list.py
src/capo_firehose/types/database_table_include_or_exclude_list.py
src/capo_firehose/types/database_table_list.py
src/capo_firehose/types/database_table_name.py
src/capo_firehose/types/database_type.py
src/capo_firehose/types/default_document_id_format.py
src/capo_firehose/types/delete_delivery_stream_input.py
src/capo_firehose/types/delete_delivery_stream_output.py
src/capo_firehose/types/delivery_start_timestamp.py
src/capo_firehose/types/delivery_stream_arn.py
src/capo_firehose/types/delivery_stream_description.py
src/capo_firehose/types/delivery_stream_encryption_configuration.py
src/capo_firehose/types/delivery_stream_encryption_configuration_input.py
src/capo_firehose/types/delivery_stream_encryption_status.py
src/capo_firehose/types/delivery_stream_failure_type.py
src/capo_firehose/types/delivery_stream_name.py
src/capo_firehose/types/delivery_stream_name_list.py
src/capo_firehose/types/delivery_stream_status.py
src/capo_firehose/types/delivery_stream_type.py
src/capo_firehose/types/delivery_stream_version_id.py
src/capo_firehose/types/describe_delivery_stream_input.py
src/capo_firehose/types/describe_delivery_stream_input_limit.py
src/capo_firehose/types/describe_delivery_stream_output.py
src/capo_firehose/types/deserializer.py
src/capo_firehose/types/destination_description.py
src/capo_firehose/types/destination_description_list.py
src/capo_firehose/types/destination_id.py
src/capo_firehose/types/destination_table_configuration.py
src/capo_firehose/types/destination_table_configuration_list.py
src/capo_firehose/types/direct_put_source_configuration.py
src/capo_firehose/types/direct_put_source_description.py
src/capo_firehose/types/document_id_options.py
src/capo_firehose/types/dynamic_partitioning_configuration.py
src/capo_firehose/types/elasticsearch_buffering_hints.py
src/capo_firehose/types/elasticsearch_buffering_interval_in_seconds.py
src/capo_firehose/types/elasticsearch_buffering_size_in_m_bs.py
src/capo_firehose/types/elasticsearch_cluster_endpoint.py
src/capo_firehose/types/elasticsearch_destination_configuration.py
src/capo_firehose/types/elasticsearch_destination_description.py
src/capo_firehose/types/elasticsearch_destination_update.py
src/capo_firehose/types/elasticsearch_domain_arn.py
src/capo_firehose/types/elasticsearch_index_name.py
src/capo_firehose/types/elasticsearch_index_rotation_period.py
src/capo_firehose/types/elasticsearch_retry_duration_in_seconds.py
src/capo_firehose/types/elasticsearch_retry_options.py
src/capo_firehose/types/elasticsearch_s3_backup_mode.py
src/capo_firehose/types/elasticsearch_type_name.py
src/capo_firehose/types/encryption_configuration.py
src/capo_firehose/types/error_code.py
src/capo_firehose/types/error_message.py
src/capo_firehose/types/error_output_prefix.py
src/capo_firehose/types/extended_s3_destination_configuration.py
src/capo_firehose/types/extended_s3_destination_description.py
src/capo_firehose/types/extended_s3_destination_update.py
src/capo_firehose/types/failure_description.py
src/capo_firehose/types/file_extension.py
src/capo_firehose/types/glue_data_catalog_arn.py
src/capo_firehose/types/hec_acknowledgment_timeout_in_seconds.py
src/capo_firehose/types/hec_endpoint.py
src/capo_firehose/types/hec_endpoint_type.py
src/capo_firehose/types/hec_token.py
src/capo_firehose/types/hive_json_ser_de.py
src/capo_firehose/types/http_endpoint_access_key.py
src/capo_firehose/types/http_endpoint_attribute_name.py
src/capo_firehose/types/http_endpoint_attribute_value.py
src/capo_firehose/types/http_endpoint_buffering_hints.py
src/capo_firehose/types/http_endpoint_buffering_interval_in_seconds.py
src/capo_firehose/types/http_endpoint_buffering_size_in_m_bs.py
src/capo_firehose/types/http_endpoint_common_attribute.py
src/capo_firehose/types/http_endpoint_common_attributes_list.py
src/capo_firehose/types/http_endpoint_configuration.py
src/capo_firehose/types/http_endpoint_description.py
src/capo_firehose/types/http_endpoint_destination_configuration.py
src/capo_firehose/types/http_endpoint_destination_description.py
src/capo_firehose/types/http_endpoint_destination_update.py
src/capo_firehose/types/http_endpoint_name.py
src/capo_firehose/types/http_endpoint_request_configuration.py
src/capo_firehose/types/http_endpoint_retry_duration_in_seconds.py
src/capo_firehose/types/http_endpoint_retry_options.py
src/capo_firehose/types/http_endpoint_s3_backup_mode.py
src/capo_firehose/types/http_endpoint_url.py
src/capo_firehose/types/iceberg_destination_configuration.py
src/capo_firehose/types/iceberg_destination_description.py
src/capo_firehose/types/iceberg_destination_update.py
src/capo_firehose/types/iceberg_s3_backup_mode.py
src/capo_firehose/types/input_format_configuration.py
src/capo_firehose/types/interval_in_seconds.py
src/capo_firehose/types/key_type.py
src/capo_firehose/types/kinesis_stream_arn.py
src/capo_firehose/types/kinesis_stream_source_configuration.py
src/capo_firehose/types/kinesis_stream_source_description.py
src/capo_firehose/types/kms_encryption_config.py
src/capo_firehose/types/list_delivery_streams_input.py
src/capo_firehose/types/list_delivery_streams_input_limit.py
src/capo_firehose/types/list_delivery_streams_output.py
src/capo_firehose/types/list_of_non_empty_strings.py
src/capo_firehose/types/list_of_non_empty_strings_without_whitespace.py
src/capo_firehose/types/list_tags_for_delivery_stream_input.py
src/capo_firehose/types/list_tags_for_delivery_stream_input_limit.py
src/capo_firehose/types/list_tags_for_delivery_stream_output.py
src/capo_firehose/types/list_tags_for_delivery_stream_output_tag_list.py
src/capo_firehose/types/log_group_name.py
src/capo_firehose/types/log_stream_name.py
src/capo_firehose/types/msk_cluster_arn.py
src/capo_firehose/types/msk_source_configuration.py
src/capo_firehose/types/msk_source_description.py
src/capo_firehose/types/no_encryption_config.py
src/capo_firehose/types/non_empty_string.py
src/capo_firehose/types/non_empty_string_without_whitespace.py
src/capo_firehose/types/non_negative_integer_object.py
src/capo_firehose/types/open_x_json_ser_de.py
src/capo_firehose/types/orc_compression.py
src/capo_firehose/types/orc_format_version.py
src/capo_firehose/types/orc_row_index_stride.py
src/capo_firehose/types/orc_ser_de.py
src/capo_firehose/types/orc_stripe_size_bytes.py
src/capo_firehose/types/output_format_configuration.py
src/capo_firehose/types/parquet_compression.py
src/capo_firehose/types/parquet_page_size_bytes.py
src/capo_firehose/types/parquet_ser_de.py
src/capo_firehose/types/parquet_writer_version.py
src/capo_firehose/types/partition_field.py
src/capo_firehose/types/partition_fields.py
src/capo_firehose/types/partition_spec.py
src/capo_firehose/types/password.py
src/capo_firehose/types/prefix.py
src/capo_firehose/types/processing_configuration.py
src/capo_firehose/types/processor.py
src/capo_firehose/types/processor_list.py
src/capo_firehose/types/processor_parameter.py
src/capo_firehose/types/processor_parameter_list.py
src/capo_firehose/types/processor_parameter_name.py
src/capo_firehose/types/processor_parameter_value.py
src/capo_firehose/types/processor_type.py
src/capo_firehose/types/proportion.py
src/capo_firehose/types/put_record_batch_input.py
src/capo_firehose/types/put_record_batch_output.py
src/capo_firehose/types/put_record_batch_request_entry_list.py
src/capo_firehose/types/put_record_batch_response_entry.py
src/capo_firehose/types/put_record_batch_response_entry_list.py
src/capo_firehose/types/put_record_input.py
src/capo_firehose/types/put_record_output.py
src/capo_firehose/types/put_response_record_id.py
src/capo_firehose/types/read_from_timestamp.py
src/capo_firehose/types/record.py
src/capo_firehose/types/redshift_destination_configuration.py
src/capo_firehose/types/redshift_destination_description.py
src/capo_firehose/types/redshift_destination_update.py
src/capo_firehose/types/redshift_retry_duration_in_seconds.py
src/capo_firehose/types/redshift_retry_options.py
src/capo_firehose/types/redshift_s3_backup_mode.py
src/capo_firehose/types/retry_duration_in_seconds.py
src/capo_firehose/types/retry_options.py
src/capo_firehose/types/role_arn.py
src/capo_firehose/types/s3_backup_mode.py
src/capo_firehose/types/s3_destination_configuration.py
src/capo_firehose/types/s3_destination_description.py
src/capo_firehose/types/s3_destination_update.py
src/capo_firehose/types/schema_configuration.py
src/capo_firehose/types/schema_evolution_configuration.py
src/capo_firehose/types/secret_arn.py
src/capo_firehose/types/secrets_manager_configuration.py
src/capo_firehose/types/security_group_id_list.py
src/capo_firehose/types/serializer.py
src/capo_firehose/types/size_in_m_bs.py
src/capo_firehose/types/snapshot_requested_by.py
src/capo_firehose/types/snapshot_status.py
src/capo_firehose/types/snowflake_account_url.py
src/capo_firehose/types/snowflake_buffering_hints.py
src/capo_firehose/types/snowflake_buffering_interval_in_seconds.py
src/capo_firehose/types/snowflake_buffering_size_in_m_bs.py
src/capo_firehose/types/snowflake_content_column_name.py
src/capo_firehose/types/snowflake_data_loading_option.py
src/capo_firehose/types/snowflake_database.py
src/capo_firehose/types/snowflake_destination_configuration.py
src/capo_firehose/types/snowflake_destination_description.py
src/capo_firehose/types/snowflake_destination_update.py
src/capo_firehose/types/snowflake_key_passphrase.py
src/capo_firehose/types/snowflake_meta_data_column_name.py
src/capo_firehose/types/snowflake_private_key.py
src/capo_firehose/types/snowflake_private_link_vpce_id.py
src/capo_firehose/types/snowflake_retry_duration_in_seconds.py
src/capo_firehose/types/snowflake_retry_options.py
src/capo_firehose/types/snowflake_role.py
src/capo_firehose/types/snowflake_role_configuration.py
src/capo_firehose/types/snowflake_s3_backup_mode.py
src/capo_firehose/types/snowflake_schema.py
src/capo_firehose/types/snowflake_table.py
src/capo_firehose/types/snowflake_user.py
src/capo_firehose/types/snowflake_vpc_configuration.py
src/capo_firehose/types/source_description.py
src/capo_firehose/types/splunk_buffering_hints.py
src/capo_firehose/types/splunk_buffering_interval_in_seconds.py
src/capo_firehose/types/splunk_buffering_size_in_m_bs.py
src/capo_firehose/types/splunk_destination_configuration.py
src/capo_firehose/types/splunk_destination_description.py
src/capo_firehose/types/splunk_destination_update.py
src/capo_firehose/types/splunk_retry_duration_in_seconds.py
src/capo_firehose/types/splunk_retry_options.py
src/capo_firehose/types/splunk_s3_backup_mode.py
src/capo_firehose/types/ssl_mode.py
src/capo_firehose/types/start_delivery_stream_encryption_input.py
src/capo_firehose/types/start_delivery_stream_encryption_output.py
src/capo_firehose/types/stop_delivery_stream_encryption_input.py
src/capo_firehose/types/stop_delivery_stream_encryption_output.py
src/capo_firehose/types/string_with_letters_digits_underscores_dots.py
src/capo_firehose/types/subnet_id_list.py
src/capo_firehose/types/table_creation_configuration.py
src/capo_firehose/types/tag.py
src/capo_firehose/types/tag_delivery_stream_input.py
src/capo_firehose/types/tag_delivery_stream_input_tag_list.py
src/capo_firehose/types/tag_delivery_stream_output.py
src/capo_firehose/types/tag_key.py
src/capo_firehose/types/tag_key_list.py
src/capo_firehose/types/tag_value.py
src/capo_firehose/types/throughput_hint_in_m_bs.py
src/capo_firehose/types/timestamp.py
src/capo_firehose/types/topic_name.py
src/capo_firehose/types/untag_delivery_stream_input.py
src/capo_firehose/types/untag_delivery_stream_output.py
src/capo_firehose/types/update_destination_input.py
src/capo_firehose/types/update_destination_output.py
src/capo_firehose/types/username.py
src/capo_firehose/types/vpc_configuration.py
src/capo_firehose/types/vpc_configuration_description.py
src/capo_firehose/types/vpc_endpoint_service_name.py
src/capo_firehose/types/warehouse_location.py
src/capo_firehose/types/_prelude/blob.py
src/capo_firehose/types/_prelude/timestamp.py
tests/test_sigv4.py