Module Smaws_Client_Firehose

Firehose client library built on EIO.

Types

module Types : sig ... end

Builders

val make_vpc_configuration_description : vpc_id:Types.non_empty_string_without_whitespace -> security_group_ids:Types.security_group_id_list -> role_ar_n:Types.role_ar_n -> subnet_ids:Types.subnet_id_list -> unit -> Types.vpc_configuration_description
val make_vpc_configuration : security_group_ids:Types.security_group_id_list -> role_ar_n:Types.role_ar_n -> subnet_ids:Types.subnet_id_list -> unit -> Types.vpc_configuration
val make_update_destination_output : unit -> unit
val make_buffering_hints : ?interval_in_seconds:Types.interval_in_seconds -> ?size_in_m_bs:Types.size_in_m_bs -> unit -> Types.buffering_hints
val make_kms_encryption_config : awskms_key_ar_n:Types.awskms_key_ar_n -> unit -> Types.kms_encryption_config
val make_encryption_configuration : ?kms_encryption_config:Types.kms_encryption_config -> ?no_encryption_config:Types.no_encryption_config -> unit -> Types.encryption_configuration
val make_cloud_watch_logging_options : ?log_stream_name:Types.log_stream_name -> ?log_group_name:Types.log_group_name -> ?enabled:Types.boolean_object -> unit -> Types.cloud_watch_logging_options
val make_s3_destination_update : ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?encryption_configuration:Types.encryption_configuration -> ?compression_format:Types.compression_format -> ?buffering_hints:Types.buffering_hints -> ?error_output_prefix:Types.error_output_prefix -> ?prefix:Types.prefix -> ?bucket_ar_n:Types.bucket_ar_n -> ?role_ar_n:Types.role_ar_n -> unit -> Types.s3_destination_update
val make_processor_parameter : parameter_value:Types.processor_parameter_value -> parameter_name:Types.processor_parameter_name -> unit -> Types.processor_parameter
val make_processor : ?parameters:Types.processor_parameter_list -> type_:Types.processor_type -> unit -> Types.processor
val make_processing_configuration : ?processors:Types.processor_list -> ?enabled:Types.boolean_object -> unit -> Types.processing_configuration
val make_open_x_json_ser_de : ?column_to_json_key_mappings:Types.column_to_json_key_mappings -> ?case_insensitive:Types.boolean_object -> ?convert_dots_in_json_keys_to_underscores:Types.boolean_object -> unit -> Types.open_x_json_ser_de
val make_hive_json_ser_de : ?timestamp_formats:Types.list_of_non_empty_strings -> unit -> Types.hive_json_ser_de
val make_deserializer : ?hive_json_ser_de:Types.hive_json_ser_de -> ?open_x_json_ser_de:Types.open_x_json_ser_de -> unit -> Types.deserializer
val make_input_format_configuration : ?deserializer:Types.deserializer -> unit -> Types.input_format_configuration
val make_parquet_ser_de : ?writer_version:Types.parquet_writer_version -> ?max_padding_bytes:Types.non_negative_integer_object -> ?enable_dictionary_compression:Types.boolean_object -> ?compression:Types.parquet_compression -> ?page_size_bytes:Types.parquet_page_size_bytes -> ?block_size_bytes:Types.block_size_bytes -> unit -> Types.parquet_ser_de
val make_orc_ser_de : ?format_version:Types.orc_format_version -> ?dictionary_key_threshold:Types.proportion -> ?bloom_filter_false_positive_probability:Types.proportion -> ?bloom_filter_columns:Types.list_of_non_empty_strings_without_whitespace -> ?compression:Types.orc_compression -> ?padding_tolerance:Types.proportion -> ?enable_padding:Types.boolean_object -> ?row_index_stride:Types.orc_row_index_stride -> ?block_size_bytes:Types.block_size_bytes -> ?stripe_size_bytes:Types.orc_stripe_size_bytes -> unit -> Types.orc_ser_de
val make_serializer : ?orc_ser_de:Types.orc_ser_de -> ?parquet_ser_de:Types.parquet_ser_de -> unit -> Types.serializer
val make_output_format_configuration : ?serializer:Types.serializer -> unit -> Types.output_format_configuration
val make_data_format_conversion_configuration : ?enabled:Types.boolean_object -> ?output_format_configuration:Types.output_format_configuration -> ?input_format_configuration:Types.input_format_configuration -> ?schema_configuration:Types.schema_configuration -> unit -> Types.data_format_conversion_configuration
val make_retry_options : ?duration_in_seconds:Types.retry_duration_in_seconds -> unit -> Types.retry_options
val make_dynamic_partitioning_configuration : ?enabled:Types.boolean_object -> ?retry_options:Types.retry_options -> unit -> Types.dynamic_partitioning_configuration
val make_extended_s3_destination_update : ?custom_time_zone:Types.custom_time_zone -> ?file_extension:Types.file_extension -> ?dynamic_partitioning_configuration:Types.dynamic_partitioning_configuration -> ?data_format_conversion_configuration: Types.data_format_conversion_configuration -> ?s3_backup_update:Types.s3_destination_update -> ?s3_backup_mode:Types.s3_backup_mode -> ?processing_configuration:Types.processing_configuration -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?encryption_configuration:Types.encryption_configuration -> ?compression_format:Types.compression_format -> ?buffering_hints:Types.buffering_hints -> ?error_output_prefix:Types.error_output_prefix -> ?prefix:Types.prefix -> ?bucket_ar_n:Types.bucket_ar_n -> ?role_ar_n:Types.role_ar_n -> unit -> Types.extended_s3_destination_update
val make_copy_command : ?copy_options:Types.copy_options -> ?data_table_columns:Types.data_table_columns -> data_table_name:Types.data_table_name -> unit -> Types.copy_command
val make_redshift_retry_options : ?duration_in_seconds:Types.redshift_retry_duration_in_seconds -> unit -> Types.redshift_retry_options
val make_secrets_manager_configuration : ?role_ar_n:Types.role_ar_n -> ?secret_ar_n:Types.secret_ar_n -> enabled:Types.boolean_object -> unit -> Types.secrets_manager_configuration
val make_redshift_destination_update : ?secrets_manager_configuration:Types.secrets_manager_configuration -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?s3_backup_update:Types.s3_destination_update -> ?s3_backup_mode:Types.redshift_s3_backup_mode -> ?processing_configuration:Types.processing_configuration -> ?s3_update:Types.s3_destination_update -> ?retry_options:Types.redshift_retry_options -> ?password:Types.password -> ?username:Types.username -> ?copy_command:Types.copy_command -> ?cluster_jdbcur_l:Types.cluster_jdbcur_l -> ?role_ar_n:Types.role_ar_n -> unit -> Types.redshift_destination_update
val make_elasticsearch_buffering_hints : ?size_in_m_bs:Types.elasticsearch_buffering_size_in_m_bs -> ?interval_in_seconds:Types.elasticsearch_buffering_interval_in_seconds -> unit -> Types.elasticsearch_buffering_hints
val make_elasticsearch_retry_options : ?duration_in_seconds:Types.elasticsearch_retry_duration_in_seconds -> unit -> Types.elasticsearch_retry_options
val make_document_id_options : default_document_id_format:Types.default_document_id_format -> unit -> Types.document_id_options
val make_elasticsearch_destination_update : ?document_id_options:Types.document_id_options -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?processing_configuration:Types.processing_configuration -> ?s3_update:Types.s3_destination_update -> ?retry_options:Types.elasticsearch_retry_options -> ?buffering_hints:Types.elasticsearch_buffering_hints -> ?index_rotation_period:Types.elasticsearch_index_rotation_period -> ?type_name:Types.elasticsearch_type_name -> ?index_name:Types.elasticsearch_index_name -> ?cluster_endpoint:Types.elasticsearch_cluster_endpoint -> ?domain_ar_n:Types.elasticsearch_domain_ar_n -> ?role_ar_n:Types.role_ar_n -> unit -> Types.elasticsearch_destination_update
val make_amazonopensearchservice_retry_options : ?duration_in_seconds:Types.amazonopensearchservice_retry_duration_in_seconds -> unit -> Types.amazonopensearchservice_retry_options
val make_splunk_retry_options : ?duration_in_seconds:Types.splunk_retry_duration_in_seconds -> unit -> Types.splunk_retry_options
val make_splunk_buffering_hints : ?size_in_m_bs:Types.splunk_buffering_size_in_m_bs -> ?interval_in_seconds:Types.splunk_buffering_interval_in_seconds -> unit -> Types.splunk_buffering_hints
val make_splunk_destination_update : ?secrets_manager_configuration:Types.secrets_manager_configuration -> ?buffering_hints:Types.splunk_buffering_hints -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?processing_configuration:Types.processing_configuration -> ?s3_update:Types.s3_destination_update -> ?s3_backup_mode:Types.splunk_s3_backup_mode -> ?retry_options:Types.splunk_retry_options -> ?hec_acknowledgment_timeout_in_seconds: Types.hec_acknowledgment_timeout_in_seconds -> ?hec_token:Types.hec_token -> ?hec_endpoint_type:Types.hec_endpoint_type -> ?hec_endpoint:Types.hec_endpoint -> unit -> Types.splunk_destination_update
val make_http_endpoint_configuration : ?access_key:Types.http_endpoint_access_key -> ?name:Types.http_endpoint_name -> url:Types.http_endpoint_url -> unit -> Types.http_endpoint_configuration
val make_http_endpoint_buffering_hints : ?interval_in_seconds:Types.http_endpoint_buffering_interval_in_seconds -> ?size_in_m_bs:Types.http_endpoint_buffering_size_in_m_bs -> unit -> Types.http_endpoint_buffering_hints
val make_http_endpoint_common_attribute : attribute_value:Types.http_endpoint_attribute_value -> attribute_name:Types.http_endpoint_attribute_name -> unit -> Types.http_endpoint_common_attribute
val make_http_endpoint_request_configuration : ?common_attributes:Types.http_endpoint_common_attributes_list -> ?content_encoding:Types.content_encoding -> unit -> Types.http_endpoint_request_configuration
val make_http_endpoint_retry_options : ?duration_in_seconds:Types.http_endpoint_retry_duration_in_seconds -> unit -> Types.http_endpoint_retry_options
val make_http_endpoint_destination_update : ?secrets_manager_configuration:Types.secrets_manager_configuration -> ?s3_update:Types.s3_destination_update -> ?s3_backup_mode:Types.http_endpoint_s3_backup_mode -> ?retry_options:Types.http_endpoint_retry_options -> ?role_ar_n:Types.role_ar_n -> ?processing_configuration:Types.processing_configuration -> ?request_configuration:Types.http_endpoint_request_configuration -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?buffering_hints:Types.http_endpoint_buffering_hints -> ?endpoint_configuration:Types.http_endpoint_configuration -> unit -> Types.http_endpoint_destination_update
val make_amazon_open_search_serverless_retry_options : ?duration_in_seconds: Types.amazon_open_search_serverless_retry_duration_in_seconds -> unit -> Types.amazon_open_search_serverless_retry_options
val make_amazon_open_search_serverless_destination_update : ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?processing_configuration:Types.processing_configuration -> ?s3_update:Types.s3_destination_update -> ?retry_options:Types.amazon_open_search_serverless_retry_options -> ?buffering_hints:Types.amazon_open_search_serverless_buffering_hints -> ?index_name:Types.amazon_open_search_serverless_index_name -> ?collection_endpoint:Types.amazon_open_search_serverless_collection_endpoint -> ?role_ar_n:Types.role_ar_n -> unit -> Types.amazon_open_search_serverless_destination_update
val make_snowflake_role_configuration : ?snowflake_role:Types.snowflake_role -> ?enabled:Types.boolean_object -> unit -> Types.snowflake_role_configuration
val make_snowflake_retry_options : ?duration_in_seconds:Types.snowflake_retry_duration_in_seconds -> unit -> Types.snowflake_retry_options
val make_snowflake_buffering_hints : ?interval_in_seconds:Types.snowflake_buffering_interval_in_seconds -> ?size_in_m_bs:Types.snowflake_buffering_size_in_m_bs -> unit -> Types.snowflake_buffering_hints
val make_snowflake_destination_update : ?buffering_hints:Types.snowflake_buffering_hints -> ?secrets_manager_configuration:Types.secrets_manager_configuration -> ?s3_update:Types.s3_destination_update -> ?s3_backup_mode:Types.snowflake_s3_backup_mode -> ?retry_options:Types.snowflake_retry_options -> ?role_ar_n:Types.role_ar_n -> ?processing_configuration:Types.processing_configuration -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?content_column_name:Types.snowflake_content_column_name -> ?meta_data_column_name:Types.snowflake_meta_data_column_name -> ?data_loading_option:Types.snowflake_data_loading_option -> ?snowflake_role_configuration:Types.snowflake_role_configuration -> ?table:Types.snowflake_table -> ?schema:Types.snowflake_schema -> ?database:Types.snowflake_database -> ?user:Types.snowflake_user -> ?key_passphrase:Types.snowflake_key_passphrase -> ?private_key:Types.snowflake_private_key -> ?account_url:Types.snowflake_account_url -> unit -> Types.snowflake_destination_update
val make_partition_field : source_name:Types.non_empty_string_without_whitespace -> unit -> Types.partition_field
val make_partition_spec : ?identity:Types.partition_fields -> unit -> Types.partition_spec
val make_destination_table_configuration : ?s3_error_output_prefix:Types.error_output_prefix -> ?partition_spec:Types.partition_spec -> ?unique_keys:Types.list_of_non_empty_strings_without_whitespace -> destination_database_name:Types.string_with_letters_digits_underscores_dots -> destination_table_name:Types.string_with_letters_digits_underscores_dots -> unit -> Types.destination_table_configuration
val make_schema_evolution_configuration : enabled:Types.boolean_object -> unit -> Types.schema_evolution_configuration
val make_table_creation_configuration : enabled:Types.boolean_object -> unit -> Types.table_creation_configuration
val make_catalog_configuration : ?warehouse_location:Types.warehouse_location -> ?catalog_ar_n:Types.glue_data_catalog_ar_n -> unit -> Types.catalog_configuration
val make_s3_destination_configuration : ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?encryption_configuration:Types.encryption_configuration -> ?compression_format:Types.compression_format -> ?buffering_hints:Types.buffering_hints -> ?error_output_prefix:Types.error_output_prefix -> ?prefix:Types.prefix -> bucket_ar_n:Types.bucket_ar_n -> role_ar_n:Types.role_ar_n -> unit -> Types.s3_destination_configuration
val make_iceberg_destination_update : ?s3_configuration:Types.s3_destination_configuration -> ?catalog_configuration:Types.catalog_configuration -> ?append_only:Types.boolean_object -> ?role_ar_n:Types.role_ar_n -> ?retry_options:Types.retry_options -> ?s3_backup_mode:Types.iceberg_s3_backup_mode -> ?processing_configuration:Types.processing_configuration -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?buffering_hints:Types.buffering_hints -> ?table_creation_configuration:Types.table_creation_configuration -> ?schema_evolution_configuration:Types.schema_evolution_configuration -> ?destination_table_configuration_list: Types.destination_table_configuration_list -> unit -> Types.iceberg_destination_update
val make_update_destination_input : ?iceberg_destination_update:Types.iceberg_destination_update -> ?snowflake_destination_update:Types.snowflake_destination_update -> ?amazon_open_search_serverless_destination_update: Types.amazon_open_search_serverless_destination_update -> ?http_endpoint_destination_update:Types.http_endpoint_destination_update -> ?splunk_destination_update:Types.splunk_destination_update -> ?amazonopensearchservice_destination_update: Types.amazonopensearchservice_destination_update -> ?elasticsearch_destination_update:Types.elasticsearch_destination_update -> ?redshift_destination_update:Types.redshift_destination_update -> ?extended_s3_destination_update:Types.extended_s3_destination_update -> ?s3_destination_update:Types.s3_destination_update -> destination_id:Types.destination_id -> current_delivery_stream_version_id:Types.delivery_stream_version_id -> delivery_stream_name:Types.delivery_stream_name -> unit -> Types.update_destination_input
val make_untag_delivery_stream_output : unit -> unit
val make_untag_delivery_stream_input : tag_keys:Types.tag_key_list -> delivery_stream_name:Types.delivery_stream_name -> unit -> Types.untag_delivery_stream_input
val make_tag_delivery_stream_output : unit -> unit
val make_tag : ?value:Types.tag_value -> key:Types.tag_key -> unit -> Types.tag
val make_tag_delivery_stream_input : tags:Types.tag_delivery_stream_input_tag_list -> delivery_stream_name:Types.delivery_stream_name -> unit -> Types.tag_delivery_stream_input
val make_stop_delivery_stream_encryption_output : unit -> unit
val make_stop_delivery_stream_encryption_input : delivery_stream_name:Types.delivery_stream_name -> unit -> Types.stop_delivery_stream_encryption_input
val make_start_delivery_stream_encryption_output : unit -> unit
val make_delivery_stream_encryption_configuration_input : ?key_ar_n:Types.awskms_key_arn_for_ss_e -> key_type:Types.key_type -> unit -> Types.delivery_stream_encryption_configuration_input
val make_start_delivery_stream_encryption_input : ?delivery_stream_encryption_configuration_input: Types.delivery_stream_encryption_configuration_input -> delivery_stream_name:Types.delivery_stream_name -> unit -> Types.start_delivery_stream_encryption_input
val make_s3_destination_description : ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?error_output_prefix:Types.error_output_prefix -> ?prefix:Types.prefix -> encryption_configuration:Types.encryption_configuration -> compression_format:Types.compression_format -> buffering_hints:Types.buffering_hints -> bucket_ar_n:Types.bucket_ar_n -> role_ar_n:Types.role_ar_n -> unit -> Types.s3_destination_description
val make_splunk_destination_description : ?secrets_manager_configuration:Types.secrets_manager_configuration -> ?buffering_hints:Types.splunk_buffering_hints -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?processing_configuration:Types.processing_configuration -> ?s3_destination_description:Types.s3_destination_description -> ?s3_backup_mode:Types.splunk_s3_backup_mode -> ?retry_options:Types.splunk_retry_options -> ?hec_acknowledgment_timeout_in_seconds: Types.hec_acknowledgment_timeout_in_seconds -> ?hec_token:Types.hec_token -> ?hec_endpoint_type:Types.hec_endpoint_type -> ?hec_endpoint:Types.hec_endpoint -> unit -> Types.splunk_destination_description
val make_splunk_destination_configuration : ?secrets_manager_configuration:Types.secrets_manager_configuration -> ?buffering_hints:Types.splunk_buffering_hints -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?processing_configuration:Types.processing_configuration -> ?s3_backup_mode:Types.splunk_s3_backup_mode -> ?retry_options:Types.splunk_retry_options -> ?hec_acknowledgment_timeout_in_seconds: Types.hec_acknowledgment_timeout_in_seconds -> ?hec_token:Types.hec_token -> s3_configuration:Types.s3_destination_configuration -> hec_endpoint_type:Types.hec_endpoint_type -> hec_endpoint:Types.hec_endpoint -> unit -> Types.splunk_destination_configuration
val make_direct_put_source_description : ?throughput_hint_in_m_bs:Types.throughput_hint_in_m_bs -> unit -> Types.direct_put_source_description
val make_kinesis_stream_source_description : ?delivery_start_timestamp:Types.delivery_start_timestamp -> ?role_ar_n:Types.role_ar_n -> ?kinesis_stream_ar_n:Types.kinesis_stream_ar_n -> unit -> Types.kinesis_stream_source_description
val make_authentication_configuration : connectivity:Types.connectivity -> role_ar_n:Types.role_ar_n -> unit -> Types.authentication_configuration
val make_msk_source_description : ?read_from_timestamp:Types.read_from_timestamp -> ?delivery_start_timestamp:Types.delivery_start_timestamp -> ?authentication_configuration:Types.authentication_configuration -> ?topic_name:Types.topic_name -> ?msk_cluster_ar_n:Types.msk_cluster_ar_n -> unit -> Types.msk_source_description
val make_failure_description : details:Types.non_empty_string -> type_:Types.delivery_stream_failure_type -> unit -> Types.failure_description
val make_database_snapshot_info : ?failure_description:Types.failure_description -> status:Types.snapshot_status -> requested_by:Types.snapshot_requested_by -> request_timestamp:Types.timestamp -> table:Types.database_table_name -> id:Types.non_empty_string_without_whitespace -> unit -> Types.database_snapshot_info
val make_database_source_authentication_configuration : secrets_manager_configuration:Types.secrets_manager_configuration -> unit -> Types.database_source_authentication_configuration
val make_database_source_vpc_configuration : vpc_endpoint_service_name:Types.vpc_endpoint_service_name -> unit -> Types.database_source_vpc_configuration
val make_database_source_description : ?database_source_vpc_configuration:Types.database_source_vpc_configuration -> ?database_source_authentication_configuration: Types.database_source_authentication_configuration -> ?snapshot_info:Types.database_snapshot_info_list -> ?snapshot_watermark_table:Types.database_table_name -> ?surrogate_keys:Types.database_column_include_or_exclude_list -> ?columns:Types.database_column_list -> ?tables:Types.database_table_list -> ?databases:Types.database_list -> ?ssl_mode:Types.ssl_mode -> ?port:Types.database_port -> ?endpoint:Types.database_endpoint -> ?type_:Types.database_type -> unit -> Types.database_source_description
val make_source_description : ?database_source_description:Types.database_source_description -> ?msk_source_description:Types.msk_source_description -> ?kinesis_stream_source_description:Types.kinesis_stream_source_description -> ?direct_put_source_description:Types.direct_put_source_description -> unit -> Types.source_description
val make_snowflake_vpc_configuration : private_link_vpce_id:Types.snowflake_private_link_vpce_id -> unit -> Types.snowflake_vpc_configuration
val make_snowflake_destination_description : ?buffering_hints:Types.snowflake_buffering_hints -> ?secrets_manager_configuration:Types.secrets_manager_configuration -> ?s3_destination_description:Types.s3_destination_description -> ?s3_backup_mode:Types.snowflake_s3_backup_mode -> ?retry_options:Types.snowflake_retry_options -> ?role_ar_n:Types.role_ar_n -> ?processing_configuration:Types.processing_configuration -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?snowflake_vpc_configuration:Types.snowflake_vpc_configuration -> ?content_column_name:Types.snowflake_content_column_name -> ?meta_data_column_name:Types.snowflake_meta_data_column_name -> ?data_loading_option:Types.snowflake_data_loading_option -> ?snowflake_role_configuration:Types.snowflake_role_configuration -> ?table:Types.snowflake_table -> ?schema:Types.snowflake_schema -> ?database:Types.snowflake_database -> ?user:Types.snowflake_user -> ?account_url:Types.snowflake_account_url -> unit -> Types.snowflake_destination_description
val make_snowflake_destination_configuration : ?buffering_hints:Types.snowflake_buffering_hints -> ?secrets_manager_configuration:Types.secrets_manager_configuration -> ?s3_backup_mode:Types.snowflake_s3_backup_mode -> ?retry_options:Types.snowflake_retry_options -> ?processing_configuration:Types.processing_configuration -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?snowflake_vpc_configuration:Types.snowflake_vpc_configuration -> ?content_column_name:Types.snowflake_content_column_name -> ?meta_data_column_name:Types.snowflake_meta_data_column_name -> ?data_loading_option:Types.snowflake_data_loading_option -> ?snowflake_role_configuration:Types.snowflake_role_configuration -> ?user:Types.snowflake_user -> ?key_passphrase:Types.snowflake_key_passphrase -> ?private_key:Types.snowflake_private_key -> s3_configuration:Types.s3_destination_configuration -> role_ar_n:Types.role_ar_n -> table:Types.snowflake_table -> schema:Types.snowflake_schema -> database:Types.snowflake_database -> account_url:Types.snowflake_account_url -> unit -> Types.snowflake_destination_configuration
val make_redshift_destination_description : ?secrets_manager_configuration:Types.secrets_manager_configuration -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?s3_backup_description:Types.s3_destination_description -> ?s3_backup_mode:Types.redshift_s3_backup_mode -> ?processing_configuration:Types.processing_configuration -> ?retry_options:Types.redshift_retry_options -> ?username:Types.username -> s3_destination_description:Types.s3_destination_description -> copy_command:Types.copy_command -> cluster_jdbcur_l:Types.cluster_jdbcur_l -> role_ar_n:Types.role_ar_n -> unit -> Types.redshift_destination_description
val make_redshift_destination_configuration : ?secrets_manager_configuration:Types.secrets_manager_configuration -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?s3_backup_configuration:Types.s3_destination_configuration -> ?s3_backup_mode:Types.redshift_s3_backup_mode -> ?processing_configuration:Types.processing_configuration -> ?retry_options:Types.redshift_retry_options -> ?password:Types.password -> ?username:Types.username -> s3_configuration:Types.s3_destination_configuration -> copy_command:Types.copy_command -> cluster_jdbcur_l:Types.cluster_jdbcur_l -> role_ar_n:Types.role_ar_n -> unit -> Types.redshift_destination_configuration
val make_record : data:Types.data -> unit -> Types.record
val make_put_record_output : ?encrypted:Types.boolean_object -> record_id:Types.put_response_record_id -> unit -> Types.put_record_output
val make_put_record_input : record:Types.record -> delivery_stream_name:Types.delivery_stream_name -> unit -> Types.put_record_input
val make_put_record_batch_response_entry : ?error_message:Types.error_message -> ?error_code:Types.error_code -> ?record_id:Types.put_response_record_id -> unit -> Types.put_record_batch_response_entry
val make_put_record_batch_output : ?encrypted:Types.boolean_object -> request_responses:Types.put_record_batch_response_entry_list -> failed_put_count:Types.non_negative_integer_object -> unit -> Types.put_record_batch_output
val make_put_record_batch_input : records:Types.put_record_batch_request_entry_list -> delivery_stream_name:Types.delivery_stream_name -> unit -> Types.put_record_batch_input
val make_msk_source_configuration : ?read_from_timestamp:Types.read_from_timestamp -> authentication_configuration:Types.authentication_configuration -> topic_name:Types.topic_name -> msk_cluster_ar_n:Types.msk_cluster_ar_n -> unit -> Types.msk_source_configuration
val make_list_tags_for_delivery_stream_output : has_more_tags:Types.boolean_object -> tags:Types.list_tags_for_delivery_stream_output_tag_list -> unit -> Types.list_tags_for_delivery_stream_output
val make_list_tags_for_delivery_stream_input : ?limit:Types.list_tags_for_delivery_stream_input_limit -> ?exclusive_start_tag_key:Types.tag_key -> delivery_stream_name:Types.delivery_stream_name -> unit -> Types.list_tags_for_delivery_stream_input
val make_list_delivery_streams_output : has_more_delivery_streams:Types.boolean_object -> delivery_stream_names:Types.delivery_stream_name_list -> unit -> Types.list_delivery_streams_output
val make_list_delivery_streams_input : ?exclusive_start_delivery_stream_name:Types.delivery_stream_name -> ?delivery_stream_type:Types.delivery_stream_type -> ?limit:Types.list_delivery_streams_input_limit -> unit -> Types.list_delivery_streams_input
val make_kinesis_stream_source_configuration : role_ar_n:Types.role_ar_n -> kinesis_stream_ar_n:Types.kinesis_stream_ar_n -> unit -> Types.kinesis_stream_source_configuration
val make_iceberg_destination_description : ?s3_destination_description:Types.s3_destination_description -> ?catalog_configuration:Types.catalog_configuration -> ?append_only:Types.boolean_object -> ?role_ar_n:Types.role_ar_n -> ?retry_options:Types.retry_options -> ?s3_backup_mode:Types.iceberg_s3_backup_mode -> ?processing_configuration:Types.processing_configuration -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?buffering_hints:Types.buffering_hints -> ?table_creation_configuration:Types.table_creation_configuration -> ?schema_evolution_configuration:Types.schema_evolution_configuration -> ?destination_table_configuration_list: Types.destination_table_configuration_list -> unit -> Types.iceberg_destination_description
val make_iceberg_destination_configuration : ?append_only:Types.boolean_object -> ?retry_options:Types.retry_options -> ?s3_backup_mode:Types.iceberg_s3_backup_mode -> ?processing_configuration:Types.processing_configuration -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?buffering_hints:Types.buffering_hints -> ?table_creation_configuration:Types.table_creation_configuration -> ?schema_evolution_configuration:Types.schema_evolution_configuration -> ?destination_table_configuration_list: Types.destination_table_configuration_list -> s3_configuration:Types.s3_destination_configuration -> catalog_configuration:Types.catalog_configuration -> role_ar_n:Types.role_ar_n -> unit -> Types.iceberg_destination_configuration
val make_http_endpoint_description : ?name:Types.http_endpoint_name -> ?url:Types.http_endpoint_url -> unit -> Types.http_endpoint_description
val make_http_endpoint_destination_description : ?secrets_manager_configuration:Types.secrets_manager_configuration -> ?s3_destination_description:Types.s3_destination_description -> ?s3_backup_mode:Types.http_endpoint_s3_backup_mode -> ?retry_options:Types.http_endpoint_retry_options -> ?role_ar_n:Types.role_ar_n -> ?processing_configuration:Types.processing_configuration -> ?request_configuration:Types.http_endpoint_request_configuration -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?buffering_hints:Types.http_endpoint_buffering_hints -> ?endpoint_configuration:Types.http_endpoint_description -> unit -> Types.http_endpoint_destination_description
val make_http_endpoint_destination_configuration : ?secrets_manager_configuration:Types.secrets_manager_configuration -> ?s3_backup_mode:Types.http_endpoint_s3_backup_mode -> ?retry_options:Types.http_endpoint_retry_options -> ?role_ar_n:Types.role_ar_n -> ?processing_configuration:Types.processing_configuration -> ?request_configuration:Types.http_endpoint_request_configuration -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?buffering_hints:Types.http_endpoint_buffering_hints -> s3_configuration:Types.s3_destination_configuration -> endpoint_configuration:Types.http_endpoint_configuration -> unit -> Types.http_endpoint_destination_configuration
val make_delivery_stream_encryption_configuration : ?failure_description:Types.failure_description -> ?status:Types.delivery_stream_encryption_status -> ?key_type:Types.key_type -> ?key_ar_n:Types.awskms_key_arn_for_ss_e -> unit -> Types.delivery_stream_encryption_configuration
val make_extended_s3_destination_description : ?custom_time_zone:Types.custom_time_zone -> ?file_extension:Types.file_extension -> ?dynamic_partitioning_configuration:Types.dynamic_partitioning_configuration -> ?data_format_conversion_configuration: Types.data_format_conversion_configuration -> ?s3_backup_description:Types.s3_destination_description -> ?s3_backup_mode:Types.s3_backup_mode -> ?processing_configuration:Types.processing_configuration -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?error_output_prefix:Types.error_output_prefix -> ?prefix:Types.prefix -> encryption_configuration:Types.encryption_configuration -> compression_format:Types.compression_format -> buffering_hints:Types.buffering_hints -> bucket_ar_n:Types.bucket_ar_n -> role_ar_n:Types.role_ar_n -> unit -> Types.extended_s3_destination_description
val make_elasticsearch_destination_description : ?document_id_options:Types.document_id_options -> ?vpc_configuration_description:Types.vpc_configuration_description -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?processing_configuration:Types.processing_configuration -> ?s3_destination_description:Types.s3_destination_description -> ?s3_backup_mode:Types.elasticsearch_s3_backup_mode -> ?retry_options:Types.elasticsearch_retry_options -> ?buffering_hints:Types.elasticsearch_buffering_hints -> ?index_rotation_period:Types.elasticsearch_index_rotation_period -> ?type_name:Types.elasticsearch_type_name -> ?index_name:Types.elasticsearch_index_name -> ?cluster_endpoint:Types.elasticsearch_cluster_endpoint -> ?domain_ar_n:Types.elasticsearch_domain_ar_n -> ?role_ar_n:Types.role_ar_n -> unit -> Types.elasticsearch_destination_description
val make_amazonopensearchservice_destination_description : ?document_id_options:Types.document_id_options -> ?vpc_configuration_description:Types.vpc_configuration_description -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?processing_configuration:Types.processing_configuration -> ?s3_destination_description:Types.s3_destination_description -> ?s3_backup_mode:Types.amazonopensearchservice_s3_backup_mode -> ?retry_options:Types.amazonopensearchservice_retry_options -> ?buffering_hints:Types.amazonopensearchservice_buffering_hints -> ?index_rotation_period:Types.amazonopensearchservice_index_rotation_period -> ?type_name:Types.amazonopensearchservice_type_name -> ?index_name:Types.amazonopensearchservice_index_name -> ?cluster_endpoint:Types.amazonopensearchservice_cluster_endpoint -> ?domain_ar_n:Types.amazonopensearchservice_domain_ar_n -> ?role_ar_n:Types.role_ar_n -> unit -> Types.amazonopensearchservice_destination_description
val make_amazon_open_search_serverless_destination_description : ?vpc_configuration_description:Types.vpc_configuration_description -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?processing_configuration:Types.processing_configuration -> ?s3_destination_description:Types.s3_destination_description -> ?s3_backup_mode:Types.amazon_open_search_serverless_s3_backup_mode -> ?retry_options:Types.amazon_open_search_serverless_retry_options -> ?buffering_hints:Types.amazon_open_search_serverless_buffering_hints -> ?index_name:Types.amazon_open_search_serverless_index_name -> ?collection_endpoint:Types.amazon_open_search_serverless_collection_endpoint -> ?role_ar_n:Types.role_ar_n -> unit -> Types.amazon_open_search_serverless_destination_description
val make_destination_description : ?iceberg_destination_description:Types.iceberg_destination_description -> ?amazon_open_search_serverless_destination_description: Types.amazon_open_search_serverless_destination_description -> ?snowflake_destination_description:Types.snowflake_destination_description -> ?http_endpoint_destination_description: Types.http_endpoint_destination_description -> ?splunk_destination_description:Types.splunk_destination_description -> ?amazonopensearchservice_destination_description: Types.amazonopensearchservice_destination_description -> ?elasticsearch_destination_description: Types.elasticsearch_destination_description -> ?redshift_destination_description:Types.redshift_destination_description -> ?extended_s3_destination_description: Types.extended_s3_destination_description -> ?s3_destination_description:Types.s3_destination_description -> destination_id:Types.destination_id -> unit -> Types.destination_description
val make_delivery_stream_description : ?source:Types.source_description -> ?last_update_timestamp:Types.timestamp -> ?create_timestamp:Types.timestamp -> ?delivery_stream_encryption_configuration: Types.delivery_stream_encryption_configuration -> ?failure_description:Types.failure_description -> has_more_destinations:Types.boolean_object -> destinations:Types.destination_description_list -> version_id:Types.delivery_stream_version_id -> delivery_stream_type:Types.delivery_stream_type -> delivery_stream_status:Types.delivery_stream_status -> delivery_stream_ar_n:Types.delivery_stream_ar_n -> delivery_stream_name:Types.delivery_stream_name -> unit -> Types.delivery_stream_description
val make_describe_delivery_stream_output : delivery_stream_description:Types.delivery_stream_description -> unit -> Types.describe_delivery_stream_output
val make_describe_delivery_stream_input : ?exclusive_start_destination_id:Types.destination_id -> ?limit:Types.describe_delivery_stream_input_limit -> delivery_stream_name:Types.delivery_stream_name -> unit -> Types.describe_delivery_stream_input
val make_delete_delivery_stream_output : unit -> unit
val make_delete_delivery_stream_input : ?allow_force_delete:Types.boolean_object -> delivery_stream_name:Types.delivery_stream_name -> unit -> Types.delete_delivery_stream_input
val make_create_delivery_stream_output : ?delivery_stream_ar_n:Types.delivery_stream_ar_n -> unit -> Types.create_delivery_stream_output
val make_direct_put_source_configuration : throughput_hint_in_m_bs:Types.throughput_hint_in_m_bs -> unit -> Types.direct_put_source_configuration
val make_extended_s3_destination_configuration : ?custom_time_zone:Types.custom_time_zone -> ?file_extension:Types.file_extension -> ?dynamic_partitioning_configuration:Types.dynamic_partitioning_configuration -> ?data_format_conversion_configuration: Types.data_format_conversion_configuration -> ?s3_backup_configuration:Types.s3_destination_configuration -> ?s3_backup_mode:Types.s3_backup_mode -> ?processing_configuration:Types.processing_configuration -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?encryption_configuration:Types.encryption_configuration -> ?compression_format:Types.compression_format -> ?buffering_hints:Types.buffering_hints -> ?error_output_prefix:Types.error_output_prefix -> ?prefix:Types.prefix -> bucket_ar_n:Types.bucket_ar_n -> role_ar_n:Types.role_ar_n -> unit -> Types.extended_s3_destination_configuration
val make_elasticsearch_destination_configuration : ?document_id_options:Types.document_id_options -> ?vpc_configuration:Types.vpc_configuration -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?processing_configuration:Types.processing_configuration -> ?s3_backup_mode:Types.elasticsearch_s3_backup_mode -> ?retry_options:Types.elasticsearch_retry_options -> ?buffering_hints:Types.elasticsearch_buffering_hints -> ?index_rotation_period:Types.elasticsearch_index_rotation_period -> ?type_name:Types.elasticsearch_type_name -> ?cluster_endpoint:Types.elasticsearch_cluster_endpoint -> ?domain_ar_n:Types.elasticsearch_domain_ar_n -> s3_configuration:Types.s3_destination_configuration -> index_name:Types.elasticsearch_index_name -> role_ar_n:Types.role_ar_n -> unit -> Types.elasticsearch_destination_configuration
val make_database_source_configuration : ?surrogate_keys:Types.database_surrogate_key_list -> ?columns:Types.database_column_list -> ?ssl_mode:Types.ssl_mode -> database_source_vpc_configuration:Types.database_source_vpc_configuration -> database_source_authentication_configuration: Types.database_source_authentication_configuration -> snapshot_watermark_table:Types.database_table_name -> tables:Types.database_table_list -> databases:Types.database_list -> port:Types.database_port -> endpoint:Types.database_endpoint -> type_:Types.database_type -> unit -> Types.database_source_configuration
val make_create_delivery_stream_input : ?database_source_configuration:Types.database_source_configuration -> ?iceberg_destination_configuration:Types.iceberg_destination_configuration -> ?snowflake_destination_configuration: Types.snowflake_destination_configuration -> ?msk_source_configuration:Types.msk_source_configuration -> ?amazon_open_search_serverless_destination_configuration: Types.amazon_open_search_serverless_destination_configuration -> ?tags:Types.tag_delivery_stream_input_tag_list -> ?http_endpoint_destination_configuration: Types.http_endpoint_destination_configuration -> ?splunk_destination_configuration:Types.splunk_destination_configuration -> ?amazonopensearchservice_destination_configuration: Types.amazonopensearchservice_destination_configuration -> ?elasticsearch_destination_configuration: Types.elasticsearch_destination_configuration -> ?redshift_destination_configuration:Types.redshift_destination_configuration -> ?extended_s3_destination_configuration: Types.extended_s3_destination_configuration -> ?s3_destination_configuration:Types.s3_destination_configuration -> ?delivery_stream_encryption_configuration_input: Types.delivery_stream_encryption_configuration_input -> ?kinesis_stream_source_configuration: Types.kinesis_stream_source_configuration -> ?direct_put_source_configuration:Types.direct_put_source_configuration -> ?delivery_stream_type:Types.delivery_stream_type -> delivery_stream_name:Types.delivery_stream_name -> unit -> Types.create_delivery_stream_input

Operations

module CreateDeliveryStream : sig ... end

Creates a Firehose stream.

module DeleteDeliveryStream : sig ... end

Deletes a Firehose stream and its data.

module DescribeDeliveryStream : sig ... end

Describes the specified Firehose stream and its status. For example, after your Firehose stream is created, call DescribeDeliveryStream to see whether the Firehose stream is ACTIVE and therefore ready for data to be sent to it.

module ListDeliveryStreams : sig ... end

Lists your Firehose streams in alphabetical order of their names.

module ListTagsForDeliveryStream : sig ... end

Lists the tags for the specified Firehose stream. This operation has a limit of five transactions per second per account.

module PutRecord : sig ... end

Writes a single data record into an Firehose stream. To write multiple data records into a Firehose stream, use PutRecordBatch. Applications using these operations are referred to as producers.

module PutRecordBatch : sig ... end

Writes multiple data records into a Firehose stream in a single call, which can achieve higher throughput per producer than when writing single records. To write single data records into a Firehose stream, use PutRecord. Applications using these operations are referred to as producers.

module StartDeliveryStreamEncryption : sig ... end

Enables server-side encryption (SSE) for the Firehose stream.

module StopDeliveryStreamEncryption : sig ... end

Disables server-side encryption (SSE) for the Firehose stream.

module TagDeliveryStream : sig ... end

Adds or updates tags for the specified Firehose stream. A tag is a key-value pair that you can define and assign to Amazon Web Services resources. If you specify a tag that already exists, the tag value is replaced with the value that you specify in the request. Tags are metadata. For example, you can add friendly names and descriptions or other types of information that can help you distinguish the Firehose stream. For more information about tags, see Using Cost Allocation Tags in the Amazon Web Services Billing and Cost Management User Guide.

module UntagDeliveryStream : sig ... end

Removes tags from the specified Firehose stream. Removed tags are deleted, and you can't recover them after this operation successfully completes.

module UpdateDestination : sig ... end
module Json_serializers : sig ... end
module Json_deserializers : sig ... end