Module Pipes.Pipe

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html

type sage_maker_pipeline_parameter = {
  1. value : string;
  2. name : string;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-sagemakerpipelineparameter.html

and batch_resource_requirement = {
  1. type_ : string;
  2. value : string;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchresourcerequirement.html

and batch_environment_variable = {
  1. value : string option;
  2. name : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchenvironmentvariable.html

and tag = {
  1. value : string;
  2. key : string;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-resource-tags.html

and ecs_environment_variable = {
  1. value : string option;
  2. name : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsenvironmentvariable.html

and ecs_resource_requirement = {
  1. type_ : string;
  2. value : string;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsresourcerequirement.html

and aws_vpc_configuration = {
  1. security_groups : string list option;
  2. subnets : string list;
  3. assign_public_ip : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-awsvpcconfiguration.html

and pipe_target_http_parameters = {
  1. path_parameter_values : string list option;
  2. header_parameters : string Stdlib__Map.Make(Stdlib.String).t option;
  3. query_string_parameters : string Stdlib__Map.Make(Stdlib.String).t option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargethttpparameters.html

and pipe_source_sqs_queue_parameters = {
  1. batch_size : int option;
  2. maximum_batching_window_in_seconds : int option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcesqsqueueparameters.html

and batch_job_dependency = {
  1. type_ : string option;
  2. job_id : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchjobdependency.html

and capacity_provider_strategy_item = {
  1. capacity_provider : string;
  2. weight : int option;
  3. base : int option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-capacityproviderstrategyitem.html

and msk_access_credentials = {
  1. client_certificate_tls_auth : string option;
  2. sasl_scram512_auth : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-mskaccesscredentials.html

and pipe_enrichment_http_parameters = {
  1. path_parameter_values : string list option;
  2. header_parameters : string Stdlib__Map.Make(Stdlib.String).t option;
  3. query_string_parameters : string Stdlib__Map.Make(Stdlib.String).t option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipeenrichmenthttpparameters.html

and cloudwatch_logs_log_destination = {
  1. log_group_arn : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-cloudwatchlogslogdestination.html

and placement_strategy = {
  1. field : string option;
  2. type_ : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-placementstrategy.html

and self_managed_kafka_access_configuration_credentials = {
  1. basic_auth : string option;
  2. sasl_scram256_auth : string option;
  3. client_certificate_tls_auth : string option;
  4. sasl_scram512_auth : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-selfmanagedkafkaaccessconfigurationcredentials.html

and batch_array_properties = {
  1. size : int option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batcharrayproperties.html

and pipe_target_lambda_function_parameters = {
  1. invocation_type : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetlambdafunctionparameters.html

and pipe_target_redshift_data_parameters = {
  1. statement_name : string option;
  2. sqls : string list;
  3. database : string;
  4. secret_manager_arn : string option;
  5. db_user : string option;
  6. with_event : bool option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetredshiftdataparameters.html

and pipe_target_event_bridge_event_bus_parameters = {
  1. detail_type : string option;
  2. endpoint_id : string option;
  3. time : string option;
  4. resources : string list option;
  5. source : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargeteventbridgeeventbusparameters.html

and ecs_environment_file = {
  1. type_ : string;
  2. value : string;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsenvironmentfile.html

and self_managed_kafka_access_configuration_vpc = {
  1. subnets : string list option;
  2. security_group : string list option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-selfmanagedkafkaaccessconfigurationvpc.html

and s3_log_destination = {
  1. bucket_name : string option;
  2. output_format : string option;
  3. prefix : string option;
  4. bucket_owner : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-s3logdestination.html

and pipe_target_state_machine_parameters = {
  1. invocation_type : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetstatemachineparameters.html

and firehose_log_destination = {
  1. delivery_stream_arn : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-firehoselogdestination.html

and pipe_target_sqs_queue_parameters = {
  1. message_group_id : string option;
  2. message_deduplication_id : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetsqsqueueparameters.html

and ecs_ephemeral_storage = {
  1. size_in_gib : int;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsephemeralstorage.html

and mq_broker_access_credentials = {
  1. basic_auth : string;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-mqbrokeraccesscredentials.html

and filter = {
  1. pattern : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-filter.html

and batch_retry_strategy = {
  1. attempts : int option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchretrystrategy.html

and placement_constraint = {
  1. type_ : string option;
  2. expression : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-placementconstraint.html

and pipe_target_kinesis_stream_parameters = {
  1. partition_key : string;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetkinesisstreamparameters.html

and ecs_inference_accelerator_override = {
  1. device_type : string option;
  2. device_name : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecsinferenceacceleratoroverride.html

and dead_letter_config = {
  1. arn : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-deadletterconfig.html

and pipe_target_cloud_watch_logs_parameters = {
  1. log_stream_name : string option;
  2. timestamp : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetcloudwatchlogsparameters.html

and pipe_source_self_managed_kafka_parameters = {
  1. starting_position : string option;
  2. batch_size : int option;
  3. consumer_group_id : string option;
  4. additional_bootstrap_servers : string list option;
  5. vpc : self_managed_kafka_access_configuration_vpc option;
  6. credentials : self_managed_kafka_access_configuration_credentials option;
  7. server_root_ca_certificate : string option;
  8. topic_name : string;
  9. maximum_batching_window_in_seconds : int option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceselfmanagedkafkaparameters.html

and batch_container_overrides = {
  1. command : string list option;
  2. environment : batch_environment_variable list option;
  3. instance_type : string option;
  4. resource_requirements : batch_resource_requirement list option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-batchcontaineroverrides.html

and pipe_enrichment_parameters = {
  1. http_parameters : pipe_enrichment_http_parameters option;
  2. input_template : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipeenrichmentparameters.html

and pipe_source_rabbit_mq_broker_parameters = {
  1. batch_size : int option;
  2. virtual_host : string option;
  3. queue_name : string;
  4. credentials : mq_broker_access_credentials;
  5. maximum_batching_window_in_seconds : int option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcerabbitmqbrokerparameters.html

and pipe_source_active_mq_broker_parameters = {
  1. batch_size : int option;
  2. queue_name : string;
  3. credentials : mq_broker_access_credentials;
  4. maximum_batching_window_in_seconds : int option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceactivemqbrokerparameters.html

and pipe_source_managed_streaming_kafka_parameters = {
  1. starting_position : string option;
  2. batch_size : int option;
  3. consumer_group_id : string option;
  4. credentials : msk_access_credentials option;
  5. topic_name : string;
  6. maximum_batching_window_in_seconds : int option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcemanagedstreamingkafkaparameters.html

and pipe_source_kinesis_stream_parameters = {
  1. starting_position : string;
  2. batch_size : int option;
  3. maximum_retry_attempts : int option;
  4. on_partial_batch_item_failure : string option;
  5. dead_letter_config : dead_letter_config option;
  6. parallelization_factor : int option;
  7. maximum_record_age_in_seconds : int option;
  8. starting_position_timestamp : string option;
  9. maximum_batching_window_in_seconds : int option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html

and pipe_target_sage_maker_pipeline_parameters = {
  1. pipeline_parameter_list : sage_maker_pipeline_parameter list option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetsagemakerpipelineparameters.html

and ecs_container_override = {
  1. memory_reservation : int option;
  2. command : string list option;
  3. memory : int option;
  4. cpu : int option;
  5. environment : ecs_environment_variable list option;
  6. resource_requirements : ecs_resource_requirement list option;
  7. environment_files : ecs_environment_file list option;
  8. name : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecscontaineroverride.html

and pipe_log_configuration = {
  1. firehose_log_destination : firehose_log_destination option;
  2. cloudwatch_logs_log_destination : cloudwatch_logs_log_destination option;
  3. include_execution_data : string list option;
  4. s3_log_destination : s3_log_destination option;
  5. level : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipelogconfiguration.html

and pipe_source_dynamo_db_stream_parameters = {
  1. starting_position : string;
  2. batch_size : int option;
  3. maximum_retry_attempts : int option;
  4. on_partial_batch_item_failure : string option;
  5. dead_letter_config : dead_letter_config option;
  6. parallelization_factor : int option;
  7. maximum_record_age_in_seconds : int option;
  8. maximum_batching_window_in_seconds : int option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcedynamodbstreamparameters.html

and network_configuration = {
  1. awsvpc_configuration : aws_vpc_configuration option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-networkconfiguration.html

and filter_criteria = {
  1. filters : filter list option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-filtercriteria.html

and pipe_source_parameters = {
  1. managed_streaming_kafka_parameters : pipe_source_managed_streaming_kafka_parameters option;
  2. dynamo_db_stream_parameters : pipe_source_dynamo_db_stream_parameters option;
  3. self_managed_kafka_parameters : pipe_source_self_managed_kafka_parameters option;
  4. rabbit_mq_broker_parameters : pipe_source_rabbit_mq_broker_parameters option;
  5. sqs_queue_parameters : pipe_source_sqs_queue_parameters option;
  6. kinesis_stream_parameters : pipe_source_kinesis_stream_parameters option;
  7. filter_criteria : filter_criteria option;
  8. active_mq_broker_parameters : pipe_source_active_mq_broker_parameters option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceparameters.html

and ecs_task_override = {
  1. execution_role_arn : string option;
  2. task_role_arn : string option;
  3. memory : string option;
  4. cpu : string option;
  5. inference_accelerator_overrides : ecs_inference_accelerator_override list option;
  6. ephemeral_storage : ecs_ephemeral_storage option;
  7. container_overrides : ecs_container_override list option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-ecstaskoverride.html

and pipe_target_batch_job_parameters = {
  1. depends_on : batch_job_dependency list option;
  2. parameters : string Stdlib__Map.Make(Stdlib.String).t option;
  3. array_properties : batch_array_properties option;
  4. job_name : string;
  5. retry_strategy : batch_retry_strategy option;
  6. job_definition : string;
  7. container_overrides : batch_container_overrides option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetbatchjobparameters.html

and pipe_target_ecs_task_parameters = {
  1. platform_version : string option;
  2. group : string option;
  3. enable_ecs_managed_tags : bool option;
  4. task_count : int option;
  5. enable_execute_command : bool option;
  6. placement_constraints : placement_constraint list option;
  7. propagate_tags : string option;
  8. placement_strategy : placement_strategy list option;
  9. launch_type : string option;
  10. capacity_provider_strategy : capacity_provider_strategy_item list option;
  11. reference_id : string option;
  12. overrides : ecs_task_override option;
  13. network_configuration : network_configuration option;
  14. tags : tag list option;
  15. task_definition_arn : string;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetecstaskparameters.html

and pipe_target_parameters = {
  1. step_function_state_machine_parameters : pipe_target_state_machine_parameters option;
  2. http_parameters : pipe_target_http_parameters option;
  3. sqs_queue_parameters : pipe_target_sqs_queue_parameters option;
  4. cloud_watch_logs_parameters : pipe_target_cloud_watch_logs_parameters option;
  5. kinesis_stream_parameters : pipe_target_kinesis_stream_parameters option;
  6. input_template : string option;
  7. sage_maker_pipeline_parameters : pipe_target_sage_maker_pipeline_parameters option;
  8. event_bridge_event_bus_parameters : pipe_target_event_bridge_event_bus_parameters option;
  9. lambda_function_parameters : pipe_target_lambda_function_parameters option;
  10. ecs_task_parameters : pipe_target_ecs_task_parameters option;
  11. batch_job_parameters : pipe_target_batch_job_parameters option;
  12. redshift_data_parameters : pipe_target_redshift_data_parameters option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html

type properties = {
  1. enrichment : string option;
  2. target : string;
  3. description : string option;
  4. desired_state : string option;
  5. target_parameters : pipe_target_parameters option;
  6. log_configuration : pipe_log_configuration option;
  7. enrichment_parameters : pipe_enrichment_parameters option;
  8. role_arn : string;
  9. source : string;
  10. source_parameters : pipe_source_parameters option;
  11. tags : string Stdlib__Map.Make(Stdlib.String).t option;
  12. name : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html;

val make_properties : ?enrichment:string -> target:string -> ?description:string -> ?desired_state:string -> ?target_parameters:pipe_target_parameters -> ?log_configuration:pipe_log_configuration -> ?enrichment_parameters:pipe_enrichment_parameters -> role_arn:string -> source:string -> ?source_parameters:pipe_source_parameters -> ?tags:string Stdlib__Map.Make(Stdlib.String).t -> ?name:string -> unit -> properties
val make_sage_maker_pipeline_parameter : value:string -> name:string -> unit -> sage_maker_pipeline_parameter
val make_batch_resource_requirement : type_:string -> value:string -> unit -> batch_resource_requirement
val make_batch_environment_variable : ?value:string -> ?name:string -> unit -> batch_environment_variable
val make_tag : value:string -> key:string -> unit -> tag
val make_ecs_environment_variable : ?value:string -> ?name:string -> unit -> ecs_environment_variable
val make_ecs_resource_requirement : type_:string -> value:string -> unit -> ecs_resource_requirement
val make_aws_vpc_configuration : ?security_groups:string list -> subnets:string list -> ?assign_public_ip:string -> unit -> aws_vpc_configuration
val make_pipe_target_http_parameters : ?path_parameter_values:string list -> ?header_parameters:string Stdlib__Map.Make(Stdlib.String).t -> ?query_string_parameters:string Stdlib__Map.Make(Stdlib.String).t -> unit -> pipe_target_http_parameters
val make_pipe_source_sqs_queue_parameters : ?batch_size:int -> ?maximum_batching_window_in_seconds:int -> unit -> pipe_source_sqs_queue_parameters
val make_batch_job_dependency : ?type_:string -> ?job_id:string -> unit -> batch_job_dependency
val make_capacity_provider_strategy_item : capacity_provider:string -> ?weight:int -> ?base:int -> unit -> capacity_provider_strategy_item
val make_msk_access_credentials : ?client_certificate_tls_auth:string -> ?sasl_scram512_auth:string -> unit -> msk_access_credentials
val make_pipe_enrichment_http_parameters : ?path_parameter_values:string list -> ?header_parameters:string Stdlib__Map.Make(Stdlib.String).t -> ?query_string_parameters:string Stdlib__Map.Make(Stdlib.String).t -> unit -> pipe_enrichment_http_parameters
val make_cloudwatch_logs_log_destination : ?log_group_arn:string -> unit -> cloudwatch_logs_log_destination
val make_placement_strategy : ?field:string -> ?type_:string -> unit -> placement_strategy
val make_self_managed_kafka_access_configuration_credentials : ?basic_auth:string -> ?sasl_scram256_auth:string -> ?client_certificate_tls_auth:string -> ?sasl_scram512_auth:string -> unit -> self_managed_kafka_access_configuration_credentials
val make_batch_array_properties : ?size:int -> unit -> batch_array_properties
val make_pipe_target_lambda_function_parameters : ?invocation_type:string -> unit -> pipe_target_lambda_function_parameters
val make_pipe_target_redshift_data_parameters : ?statement_name:string -> sqls:string list -> database:string -> ?secret_manager_arn:string -> ?db_user:string -> ?with_event:bool -> unit -> pipe_target_redshift_data_parameters
val make_pipe_target_event_bridge_event_bus_parameters : ?detail_type:string -> ?endpoint_id:string -> ?time:string -> ?resources:string list -> ?source:string -> unit -> pipe_target_event_bridge_event_bus_parameters
val make_ecs_environment_file : type_:string -> value:string -> unit -> ecs_environment_file
val make_self_managed_kafka_access_configuration_vpc : ?subnets:string list -> ?security_group:string list -> unit -> self_managed_kafka_access_configuration_vpc
val make_s3_log_destination : ?bucket_name:string -> ?output_format:string -> ?prefix:string -> ?bucket_owner:string -> unit -> s3_log_destination
val make_pipe_target_state_machine_parameters : ?invocation_type:string -> unit -> pipe_target_state_machine_parameters
val make_firehose_log_destination : ?delivery_stream_arn:string -> unit -> firehose_log_destination
val make_pipe_target_sqs_queue_parameters : ?message_group_id:string -> ?message_deduplication_id:string -> unit -> pipe_target_sqs_queue_parameters
val make_ecs_ephemeral_storage : size_in_gib:int -> unit -> ecs_ephemeral_storage
val make_mq_broker_access_credentials : basic_auth:string -> unit -> mq_broker_access_credentials
val make_filter : ?pattern:string -> unit -> filter
val make_batch_retry_strategy : ?attempts:int -> unit -> batch_retry_strategy
val make_placement_constraint : ?type_:string -> ?expression:string -> unit -> placement_constraint
val make_pipe_target_kinesis_stream_parameters : partition_key:string -> unit -> pipe_target_kinesis_stream_parameters
val make_ecs_inference_accelerator_override : ?device_type:string -> ?device_name:string -> unit -> ecs_inference_accelerator_override
val make_dead_letter_config : ?arn:string -> unit -> dead_letter_config
val make_pipe_target_cloud_watch_logs_parameters : ?log_stream_name:string -> ?timestamp:string -> unit -> pipe_target_cloud_watch_logs_parameters
val make_pipe_source_self_managed_kafka_parameters : ?starting_position:string -> ?batch_size:int -> ?consumer_group_id:string -> ?additional_bootstrap_servers:string list -> ?vpc:self_managed_kafka_access_configuration_vpc -> ?credentials:self_managed_kafka_access_configuration_credentials -> ?server_root_ca_certificate:string -> topic_name:string -> ?maximum_batching_window_in_seconds:int -> unit -> pipe_source_self_managed_kafka_parameters
val make_batch_container_overrides : ?command:string list -> ?environment:batch_environment_variable list -> ?instance_type:string -> ?resource_requirements:batch_resource_requirement list -> unit -> batch_container_overrides
val make_pipe_enrichment_parameters : ?http_parameters:pipe_enrichment_http_parameters -> ?input_template:string -> unit -> pipe_enrichment_parameters
val make_pipe_source_rabbit_mq_broker_parameters : ?batch_size:int -> ?virtual_host:string -> queue_name:string -> credentials:mq_broker_access_credentials -> ?maximum_batching_window_in_seconds:int -> unit -> pipe_source_rabbit_mq_broker_parameters
val make_pipe_source_active_mq_broker_parameters : ?batch_size:int -> queue_name:string -> credentials:mq_broker_access_credentials -> ?maximum_batching_window_in_seconds:int -> unit -> pipe_source_active_mq_broker_parameters
val make_pipe_source_managed_streaming_kafka_parameters : ?starting_position:string -> ?batch_size:int -> ?consumer_group_id:string -> ?credentials:msk_access_credentials -> topic_name:string -> ?maximum_batching_window_in_seconds:int -> unit -> pipe_source_managed_streaming_kafka_parameters
val make_pipe_source_kinesis_stream_parameters : starting_position:string -> ?batch_size:int -> ?maximum_retry_attempts:int -> ?on_partial_batch_item_failure:string -> ?dead_letter_config:dead_letter_config -> ?parallelization_factor:int -> ?maximum_record_age_in_seconds:int -> ?starting_position_timestamp:string -> ?maximum_batching_window_in_seconds:int -> unit -> pipe_source_kinesis_stream_parameters
val make_pipe_target_sage_maker_pipeline_parameters : ?pipeline_parameter_list:sage_maker_pipeline_parameter list -> unit -> pipe_target_sage_maker_pipeline_parameters
val make_ecs_container_override : ?memory_reservation:int -> ?command:string list -> ?memory:int -> ?cpu:int -> ?environment:ecs_environment_variable list -> ?resource_requirements:ecs_resource_requirement list -> ?environment_files:ecs_environment_file list -> ?name:string -> unit -> ecs_container_override
val make_pipe_log_configuration : ?firehose_log_destination:firehose_log_destination -> ?cloudwatch_logs_log_destination:cloudwatch_logs_log_destination -> ?include_execution_data:string list -> ?s3_log_destination:s3_log_destination -> ?level:string -> unit -> pipe_log_configuration
val make_pipe_source_dynamo_db_stream_parameters : starting_position:string -> ?batch_size:int -> ?maximum_retry_attempts:int -> ?on_partial_batch_item_failure:string -> ?dead_letter_config:dead_letter_config -> ?parallelization_factor:int -> ?maximum_record_age_in_seconds:int -> ?maximum_batching_window_in_seconds:int -> unit -> pipe_source_dynamo_db_stream_parameters
val make_network_configuration : ?awsvpc_configuration:aws_vpc_configuration -> unit -> network_configuration
val make_filter_criteria : ?filters:filter list -> unit -> filter_criteria
val make_pipe_source_parameters : ?managed_streaming_kafka_parameters: pipe_source_managed_streaming_kafka_parameters -> ?dynamo_db_stream_parameters:pipe_source_dynamo_db_stream_parameters -> ?self_managed_kafka_parameters:pipe_source_self_managed_kafka_parameters -> ?rabbit_mq_broker_parameters:pipe_source_rabbit_mq_broker_parameters -> ?sqs_queue_parameters:pipe_source_sqs_queue_parameters -> ?kinesis_stream_parameters:pipe_source_kinesis_stream_parameters -> ?filter_criteria:filter_criteria -> ?active_mq_broker_parameters:pipe_source_active_mq_broker_parameters -> unit -> pipe_source_parameters
val make_ecs_task_override : ?execution_role_arn:string -> ?task_role_arn:string -> ?memory:string -> ?cpu:string -> ?inference_accelerator_overrides:ecs_inference_accelerator_override list -> ?ephemeral_storage:ecs_ephemeral_storage -> ?container_overrides:ecs_container_override list -> unit -> ecs_task_override
val make_pipe_target_batch_job_parameters : ?depends_on:batch_job_dependency list -> ?parameters:string Stdlib__Map.Make(Stdlib.String).t -> ?array_properties:batch_array_properties -> job_name:string -> ?retry_strategy:batch_retry_strategy -> job_definition:string -> ?container_overrides:batch_container_overrides -> unit -> pipe_target_batch_job_parameters
val make_pipe_target_ecs_task_parameters : ?platform_version:string -> ?group:string -> ?enable_ecs_managed_tags:bool -> ?task_count:int -> ?enable_execute_command:bool -> ?placement_constraints:placement_constraint list -> ?propagate_tags:string -> ?placement_strategy:placement_strategy list -> ?launch_type:string -> ?capacity_provider_strategy:capacity_provider_strategy_item list -> ?reference_id:string -> ?overrides:ecs_task_override -> ?network_configuration:network_configuration -> ?tags:tag list -> task_definition_arn:string -> unit -> pipe_target_ecs_task_parameters
val make_pipe_target_parameters : ?step_function_state_machine_parameters:pipe_target_state_machine_parameters -> ?http_parameters:pipe_target_http_parameters -> ?sqs_queue_parameters:pipe_target_sqs_queue_parameters -> ?cloud_watch_logs_parameters:pipe_target_cloud_watch_logs_parameters -> ?kinesis_stream_parameters:pipe_target_kinesis_stream_parameters -> ?input_template:string -> ?sage_maker_pipeline_parameters:pipe_target_sage_maker_pipeline_parameters -> ?event_bridge_event_bus_parameters: pipe_target_event_bridge_event_bus_parameters -> ?lambda_function_parameters:pipe_target_lambda_function_parameters -> ?ecs_task_parameters:pipe_target_ecs_task_parameters -> ?batch_job_parameters:pipe_target_batch_job_parameters -> ?redshift_data_parameters:pipe_target_redshift_data_parameters -> unit -> pipe_target_parameters
val yojson_of_sage_maker_pipeline_parameter : sage_maker_pipeline_parameter -> Yojson.Safe.t
val yojson_of_batch_resource_requirement : batch_resource_requirement -> Yojson.Safe.t
val yojson_of_batch_environment_variable : batch_environment_variable -> Yojson.Safe.t
val yojson_of_tag : tag -> Yojson.Safe.t
val yojson_of_ecs_environment_variable : ecs_environment_variable -> Yojson.Safe.t
val yojson_of_ecs_resource_requirement : ecs_resource_requirement -> Yojson.Safe.t
val yojson_of_aws_vpc_configuration : aws_vpc_configuration -> Yojson.Safe.t
val yojson_of_pipe_target_http_parameters : pipe_target_http_parameters -> Yojson.Safe.t
val yojson_of_pipe_source_sqs_queue_parameters : pipe_source_sqs_queue_parameters -> Yojson.Safe.t
val yojson_of_batch_job_dependency : batch_job_dependency -> Yojson.Safe.t
val yojson_of_capacity_provider_strategy_item : capacity_provider_strategy_item -> Yojson.Safe.t
val yojson_of_msk_access_credentials : msk_access_credentials -> Yojson.Safe.t
val yojson_of_pipe_enrichment_http_parameters : pipe_enrichment_http_parameters -> Yojson.Safe.t
val yojson_of_cloudwatch_logs_log_destination : cloudwatch_logs_log_destination -> Yojson.Safe.t
val yojson_of_placement_strategy : placement_strategy -> Yojson.Safe.t
val yojson_of_self_managed_kafka_access_configuration_credentials : self_managed_kafka_access_configuration_credentials -> Yojson.Safe.t
val yojson_of_batch_array_properties : batch_array_properties -> Yojson.Safe.t
val yojson_of_pipe_target_lambda_function_parameters : pipe_target_lambda_function_parameters -> Yojson.Safe.t
val yojson_of_pipe_target_redshift_data_parameters : pipe_target_redshift_data_parameters -> Yojson.Safe.t
val yojson_of_pipe_target_event_bridge_event_bus_parameters : pipe_target_event_bridge_event_bus_parameters -> Yojson.Safe.t
val yojson_of_ecs_environment_file : ecs_environment_file -> Yojson.Safe.t
val yojson_of_self_managed_kafka_access_configuration_vpc : self_managed_kafka_access_configuration_vpc -> Yojson.Safe.t
val yojson_of_s3_log_destination : s3_log_destination -> Yojson.Safe.t
val yojson_of_pipe_target_state_machine_parameters : pipe_target_state_machine_parameters -> Yojson.Safe.t
val yojson_of_firehose_log_destination : firehose_log_destination -> Yojson.Safe.t
val yojson_of_pipe_target_sqs_queue_parameters : pipe_target_sqs_queue_parameters -> Yojson.Safe.t
val yojson_of_ecs_ephemeral_storage : ecs_ephemeral_storage -> Yojson.Safe.t
val yojson_of_mq_broker_access_credentials : mq_broker_access_credentials -> Yojson.Safe.t
val yojson_of_filter : filter -> Yojson.Safe.t
val yojson_of_batch_retry_strategy : batch_retry_strategy -> Yojson.Safe.t
val yojson_of_placement_constraint : placement_constraint -> Yojson.Safe.t
val yojson_of_pipe_target_kinesis_stream_parameters : pipe_target_kinesis_stream_parameters -> Yojson.Safe.t
val yojson_of_ecs_inference_accelerator_override : ecs_inference_accelerator_override -> Yojson.Safe.t
val yojson_of_dead_letter_config : dead_letter_config -> Yojson.Safe.t
val yojson_of_pipe_target_cloud_watch_logs_parameters : pipe_target_cloud_watch_logs_parameters -> Yojson.Safe.t
val yojson_of_pipe_source_self_managed_kafka_parameters : pipe_source_self_managed_kafka_parameters -> Yojson.Safe.t
val yojson_of_batch_container_overrides : batch_container_overrides -> Yojson.Safe.t
val yojson_of_pipe_enrichment_parameters : pipe_enrichment_parameters -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_pipe_source_rabbit_mq_broker_parameters : pipe_source_rabbit_mq_broker_parameters -> Yojson.Safe.t
val yojson_of_pipe_source_active_mq_broker_parameters : pipe_source_active_mq_broker_parameters -> Yojson.Safe.t
val yojson_of_pipe_source_managed_streaming_kafka_parameters : pipe_source_managed_streaming_kafka_parameters -> Yojson.Safe.t
val yojson_of_pipe_source_kinesis_stream_parameters : pipe_source_kinesis_stream_parameters -> Yojson.Safe.t
val yojson_of_pipe_target_sage_maker_pipeline_parameters : pipe_target_sage_maker_pipeline_parameters -> Yojson.Safe.t
val yojson_of_ecs_container_override : ecs_container_override -> Yojson.Safe.t
val yojson_of_pipe_log_configuration : pipe_log_configuration -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_pipe_source_dynamo_db_stream_parameters : pipe_source_dynamo_db_stream_parameters -> Yojson.Safe.t
val yojson_of_network_configuration : network_configuration -> Yojson.Safe.t
val yojson_of_filter_criteria : filter_criteria -> Yojson.Safe.t
val yojson_of_pipe_source_parameters : pipe_source_parameters -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_ecs_task_override : ecs_task_override -> Yojson.Safe.t
val yojson_of_pipe_target_batch_job_parameters : pipe_target_batch_job_parameters -> Yojson.Safe.t
val yojson_of_pipe_target_ecs_task_parameters : pipe_target_ecs_task_parameters -> Yojson.Safe.t
val yojson_of_pipe_target_parameters : pipe_target_parameters -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_properties : properties -> [> `Assoc of (string * Yojson.Safe.t) list ]
type attributes = {
  1. ref_ : string;
  2. state_reason : string;
  3. current_state : string;
  4. creation_time : string;
  5. last_modified_time : string;
  6. arn : string;
}
val create_attributes : string -> attributes
val cloudformation_type : string