package smaws-clients
sectionYPositions = computeSectionYPositions($el), 10)"
x-init="setTimeout(() => sectionYPositions = computeSectionYPositions($el), 10)"
>
Amazon Web Services SDK clients using EIO
Install
dune-project
Dependency
Authors
Maintainers
Sources
0.1.preview1.tar.gz
md5=18fb70dbc45e8d81a341b9bed6871bab
sha512=7607dc98acaeed5803b44c9ca32d90c88e7813d4b3e3ae4ec661a0bad16c88dc1476bc780877527ea4cd5a4b7398453c1bb600ce0db14d39afa05dc4762b5ba5
doc/smaws-clients.kinesis-analytics/Smaws_Client_KinesisAnalytics/index.html
Module Smaws_Client_KinesisAnalyticsSource
Source
type input_processing_configuration_update = {input_lambda_processor_update : input_lambda_processor_update;
}Source
type mapping_parameters = {csv_mapping_parameters : csv_mapping_parameters option;json_mapping_parameters : json_mapping_parameters option;
}Source
type record_format = {mapping_parameters : mapping_parameters option;record_format_type : record_format_type;
}Source
type input_schema_update = {record_column_updates : record_column list option;record_encoding_update : string option;record_format_update : record_format option;
}Source
type input_update = {input_parallelism_update : input_parallelism_update option;input_schema_update : input_schema_update option;kinesis_firehose_input_update : kinesis_firehose_input_update option;kinesis_streams_input_update : kinesis_streams_input_update option;input_processing_configuration_update : input_processing_configuration_update option;name_prefix_update : string option;input_id : string;
}Source
type output_update = {destination_schema_update : destination_schema option;lambda_output_update : lambda_output_update option;kinesis_firehose_output_update : kinesis_firehose_output_update option;kinesis_streams_output_update : kinesis_streams_output_update option;name_update : string option;output_id : string;
}Source
type s3_reference_data_source_update = {reference_role_arn_update : string option;file_key_update : string option;bucket_arn_update : string option;
}Source
type source_schema = {record_columns : record_column list;record_encoding : string option;record_format : record_format;
}Source
type reference_data_source_update = {reference_schema_update : source_schema option;s3_reference_data_source_update : s3_reference_data_source_update option;table_name_update : string option;reference_id : string;
}Source
type cloud_watch_logging_option_update = {role_arn_update : string option;log_stream_arn_update : string option;cloud_watch_logging_option_id : string;
}Source
type application_update = {cloud_watch_logging_option_updates : cloud_watch_logging_option_update list option;reference_data_source_updates : reference_data_source_update list option;output_updates : output_update list option;application_code_update : string option;input_updates : input_update list option;
}Source
type update_application_request = {application_update : application_update;current_application_version_id : int;application_name : string;
}Source
type unable_to_detect_schema_exception = {processed_input_records : string list option;raw_input_records : string list option;message : string option;
}Source
type input_starting_position_configuration = {input_starting_position : input_starting_position option;
}Source
type input_configuration = {input_starting_position_configuration : input_starting_position_configuration;id : string;
}Source
type start_application_request = {input_configurations : input_configuration list;application_name : string;
}Source
type reference_data_source_description = {reference_schema : source_schema option;s3_reference_data_source_description : s3_reference_data_source_description;table_name : string;reference_id : string;
}Source
type reference_data_source = {reference_schema : source_schema;s3_reference_data_source : s3_reference_data_source option;table_name : string;
}Source
type output = {destination_schema : destination_schema;lambda_output : lambda_output option;kinesis_firehose_output : kinesis_firehose_output option;kinesis_streams_output : kinesis_streams_output option;name : string;
}Source
type output_description = {destination_schema : destination_schema option;lambda_output_description : lambda_output_description option;kinesis_firehose_output_description : kinesis_firehose_output_description option;kinesis_streams_output_description : kinesis_streams_output_description option;name : string option;output_id : string option;
}Source
type application_summary = {application_status : application_status;application_ar_n : string;application_name : string;
}Source
type list_applications_response = {has_more_applications : bool;application_summaries : application_summary list;
}Source
type discover_input_schema_response = {raw_input_records : string list option;processed_input_records : string list option;parsed_input_records : string list list option;input_schema : source_schema option;
}Source
type discover_input_schema_request = {input_processing_configuration : input_processing_configuration option;s3_configuration : s3_configuration option;input_starting_position_configuration : input_starting_position_configuration option;role_ar_n : string option;resource_ar_n : string option;
}Source
type input_processing_configuration_description = {input_lambda_processor_description : input_lambda_processor_description option;
}Source
type input_description = {input_starting_position_configuration : input_starting_position_configuration option;input_parallelism : input_parallelism option;input_schema : source_schema option;kinesis_firehose_input_description : kinesis_firehose_input_description option;kinesis_streams_input_description : kinesis_streams_input_description option;input_processing_configuration_description : input_processing_configuration_description option;in_app_stream_names : string list option;name_prefix : string option;input_id : string option;
}Source
type application_detail = {application_version_id : int;application_code : string option;cloud_watch_logging_option_descriptions : cloud_watch_logging_option_description list option;reference_data_source_descriptions : reference_data_source_description list option;output_descriptions : output_description list option;input_descriptions : input_description list option;last_update_timestamp : float option;create_timestamp : float option;application_status : application_status;application_ar_n : string;application_description : string option;application_name : string;
}Source
type delete_application_cloud_watch_logging_option_request = {cloud_watch_logging_option_id : string;current_application_version_id : int;application_name : string;
}Source
type input = {input_schema : source_schema;input_parallelism : input_parallelism option;kinesis_firehose_input : kinesis_firehose_input option;kinesis_streams_input : kinesis_streams_input option;input_processing_configuration : input_processing_configuration option;name_prefix : string;
}Source
type create_application_request = {application_code : string option;cloud_watch_logging_options : cloud_watch_logging_option list option;outputs : output list option;inputs : input list option;application_description : string option;application_name : string;
}Source
type add_application_reference_data_source_request = {reference_data_source : reference_data_source;current_application_version_id : int;application_name : string;
}Source
type add_application_input_processing_configuration_request = {input_processing_configuration : input_processing_configuration;input_id : string;current_application_version_id : int;application_name : string;
}Source
type add_application_cloud_watch_logging_option_request = {cloud_watch_logging_option : cloud_watch_logging_option;current_application_version_id : int;application_name : string;
}Source
val make_input_lambda_processor_update :
?role_arn_update:string ->
?resource_arn_update:string ->
unit ->
input_lambda_processor_updateSource
val make_input_processing_configuration_update :
input_lambda_processor_update:input_lambda_processor_update ->
unit ->
input_processing_configuration_updateSource
val make_kinesis_streams_input_update :
?role_arn_update:string ->
?resource_arn_update:string ->
unit ->
kinesis_streams_input_updateSource
val make_kinesis_firehose_input_update :
?role_arn_update:string ->
?resource_arn_update:string ->
unit ->
kinesis_firehose_input_updateSource
val make_csv_mapping_parameters :
record_column_delimiter:string ->
record_row_delimiter:string ->
unit ->
csv_mapping_parametersSource
val make_mapping_parameters :
?csv_mapping_parameters:csv_mapping_parameters ->
?json_mapping_parameters:json_mapping_parameters ->
unit ->
mapping_parametersSource
val make_record_format :
?mapping_parameters:mapping_parameters ->
record_format_type:record_format_type ->
unit ->
record_formatSource
val make_record_column :
?mapping:string ->
sql_type:string ->
name:string ->
unit ->
record_columnSource
val make_input_schema_update :
?record_column_updates:record_column list ->
?record_encoding_update:string ->
?record_format_update:record_format ->
unit ->
input_schema_updateSource
val make_input_update :
?input_parallelism_update:input_parallelism_update ->
?input_schema_update:input_schema_update ->
?kinesis_firehose_input_update:kinesis_firehose_input_update ->
?kinesis_streams_input_update:kinesis_streams_input_update ->
?input_processing_configuration_update:input_processing_configuration_update ->
?name_prefix_update:string ->
input_id:string ->
unit ->
input_updateSource
val make_kinesis_streams_output_update :
?role_arn_update:string ->
?resource_arn_update:string ->
unit ->
kinesis_streams_output_updateSource
val make_kinesis_firehose_output_update :
?role_arn_update:string ->
?resource_arn_update:string ->
unit ->
kinesis_firehose_output_updateSource
val make_lambda_output_update :
?role_arn_update:string ->
?resource_arn_update:string ->
unit ->
lambda_output_updateSource
val make_destination_schema :
record_format_type:record_format_type ->
unit ->
destination_schemaSource
val make_output_update :
?destination_schema_update:destination_schema ->
?lambda_output_update:lambda_output_update ->
?kinesis_firehose_output_update:kinesis_firehose_output_update ->
?kinesis_streams_output_update:kinesis_streams_output_update ->
?name_update:string ->
output_id:string ->
unit ->
output_updateSource
val make_s3_reference_data_source_update :
?reference_role_arn_update:string ->
?file_key_update:string ->
?bucket_arn_update:string ->
unit ->
s3_reference_data_source_updateSource
val make_source_schema :
?record_encoding:string ->
record_columns:record_column list ->
record_format:record_format ->
unit ->
source_schemaSource
val make_reference_data_source_update :
?reference_schema_update:source_schema ->
?s3_reference_data_source_update:s3_reference_data_source_update ->
?table_name_update:string ->
reference_id:string ->
unit ->
reference_data_source_updateSource
val make_cloud_watch_logging_option_update :
?role_arn_update:string ->
?log_stream_arn_update:string ->
cloud_watch_logging_option_id:string ->
unit ->
cloud_watch_logging_option_updateSource
val make_application_update :
?cloud_watch_logging_option_updates:cloud_watch_logging_option_update list ->
?reference_data_source_updates:reference_data_source_update list ->
?output_updates:output_update list ->
?application_code_update:string ->
?input_updates:input_update list ->
unit ->
application_updateSource
val make_update_application_request :
application_update:application_update ->
current_application_version_id:int ->
application_name:string ->
unit ->
update_application_requestSource
val make_untag_resource_request :
tag_keys:string list ->
resource_ar_n:string ->
unit ->
untag_resource_requestSource
val make_tag_resource_request :
tags:tag list ->
resource_ar_n:string ->
unit ->
tag_resource_requestSource
val make_stop_application_request :
application_name:string ->
unit ->
stop_application_requestSource
val make_input_starting_position_configuration :
?input_starting_position:input_starting_position ->
unit ->
input_starting_position_configurationSource
val make_input_configuration :
input_starting_position_configuration:input_starting_position_configuration ->
id:string ->
unit ->
input_configurationSource
val make_start_application_request :
input_configurations:input_configuration list ->
application_name:string ->
unit ->
start_application_requestSource
val make_s3_reference_data_source_description :
reference_role_ar_n:string ->
file_key:string ->
bucket_ar_n:string ->
unit ->
s3_reference_data_source_descriptionSource
val make_s3_reference_data_source :
reference_role_ar_n:string ->
file_key:string ->
bucket_ar_n:string ->
unit ->
s3_reference_data_sourceSource
val make_s3_configuration :
file_key:string ->
bucket_ar_n:string ->
role_ar_n:string ->
unit ->
s3_configurationSource
val make_reference_data_source_description :
?reference_schema:source_schema ->
s3_reference_data_source_description:s3_reference_data_source_description ->
table_name:string ->
reference_id:string ->
unit ->
reference_data_source_descriptionSource
val make_reference_data_source :
?s3_reference_data_source:s3_reference_data_source ->
reference_schema:source_schema ->
table_name:string ->
unit ->
reference_data_sourceSource
val make_kinesis_streams_output :
role_ar_n:string ->
resource_ar_n:string ->
unit ->
kinesis_streams_outputSource
val make_kinesis_firehose_output :
role_ar_n:string ->
resource_ar_n:string ->
unit ->
kinesis_firehose_outputSource
val make_output :
?lambda_output:lambda_output ->
?kinesis_firehose_output:kinesis_firehose_output ->
?kinesis_streams_output:kinesis_streams_output ->
destination_schema:destination_schema ->
name:string ->
unit ->
outputSource
val make_kinesis_streams_output_description :
?role_ar_n:string ->
?resource_ar_n:string ->
unit ->
kinesis_streams_output_descriptionSource
val make_kinesis_firehose_output_description :
?role_ar_n:string ->
?resource_ar_n:string ->
unit ->
kinesis_firehose_output_descriptionSource
val make_lambda_output_description :
?role_ar_n:string ->
?resource_ar_n:string ->
unit ->
lambda_output_descriptionSource
val make_output_description :
?destination_schema:destination_schema ->
?lambda_output_description:lambda_output_description ->
?kinesis_firehose_output_description:kinesis_firehose_output_description ->
?kinesis_streams_output_description:kinesis_streams_output_description ->
?name:string ->
?output_id:string ->
unit ->
output_descriptionSource
val make_list_tags_for_resource_response :
?tags:tag list ->
unit ->
list_tags_for_resource_responseSource
val make_list_tags_for_resource_request :
resource_ar_n:string ->
unit ->
list_tags_for_resource_requestSource
val make_application_summary :
application_status:application_status ->
application_ar_n:string ->
application_name:string ->
unit ->
application_summarySource
val make_list_applications_response :
has_more_applications:bool ->
application_summaries:application_summary list ->
unit ->
list_applications_responseSource
val make_list_applications_request :
?exclusive_start_application_name:string ->
?limit:int ->
unit ->
list_applications_requestSource
val make_kinesis_streams_input_description :
?role_ar_n:string ->
?resource_ar_n:string ->
unit ->
kinesis_streams_input_descriptionSource
val make_kinesis_streams_input :
role_ar_n:string ->
resource_ar_n:string ->
unit ->
kinesis_streams_inputSource
val make_kinesis_firehose_input_description :
?role_ar_n:string ->
?resource_ar_n:string ->
unit ->
kinesis_firehose_input_descriptionSource
val make_kinesis_firehose_input :
role_ar_n:string ->
resource_ar_n:string ->
unit ->
kinesis_firehose_inputSource
val make_discover_input_schema_response :
?raw_input_records:string list ->
?processed_input_records:string list ->
?parsed_input_records:string list list ->
?input_schema:source_schema ->
unit ->
discover_input_schema_responseSource
val make_input_lambda_processor :
role_ar_n:string ->
resource_ar_n:string ->
unit ->
input_lambda_processorSource
val make_input_processing_configuration :
input_lambda_processor:input_lambda_processor ->
unit ->
input_processing_configurationSource
val make_discover_input_schema_request :
?input_processing_configuration:input_processing_configuration ->
?s3_configuration:s3_configuration ->
?input_starting_position_configuration:input_starting_position_configuration ->
?role_ar_n:string ->
?resource_ar_n:string ->
unit ->
discover_input_schema_requestSource
val make_input_lambda_processor_description :
?role_ar_n:string ->
?resource_ar_n:string ->
unit ->
input_lambda_processor_descriptionSource
val make_input_processing_configuration_description :
?input_lambda_processor_description:input_lambda_processor_description ->
unit ->
input_processing_configuration_descriptionSource
val make_input_description :
?input_starting_position_configuration:input_starting_position_configuration ->
?input_parallelism:input_parallelism ->
?input_schema:source_schema ->
?kinesis_firehose_input_description:kinesis_firehose_input_description ->
?kinesis_streams_input_description:kinesis_streams_input_description ->
?input_processing_configuration_description:
input_processing_configuration_description ->
?in_app_stream_names:string list ->
?name_prefix:string ->
?input_id:string ->
unit ->
input_descriptionSource
val make_cloud_watch_logging_option_description :
?cloud_watch_logging_option_id:string ->
role_ar_n:string ->
log_stream_ar_n:string ->
unit ->
cloud_watch_logging_option_descriptionSource
val make_application_detail :
?application_code:string ->
?cloud_watch_logging_option_descriptions:
cloud_watch_logging_option_description list ->
?reference_data_source_descriptions:reference_data_source_description list ->
?output_descriptions:output_description list ->
?input_descriptions:input_description list ->
?last_update_timestamp:float ->
?create_timestamp:float ->
?application_description:string ->
application_version_id:int ->
application_status:application_status ->
application_ar_n:string ->
application_name:string ->
unit ->
application_detailSource
val make_describe_application_response :
application_detail:application_detail ->
unit ->
describe_application_responseSource
val make_describe_application_request :
application_name:string ->
unit ->
describe_application_requestSource
val make_delete_application_reference_data_source_response :
unit ->
delete_application_reference_data_source_responseSource
val make_delete_application_reference_data_source_request :
reference_id:string ->
current_application_version_id:int ->
application_name:string ->
unit ->
delete_application_reference_data_source_requestSource
val make_delete_application_output_request :
output_id:string ->
current_application_version_id:int ->
application_name:string ->
unit ->
delete_application_output_requestSource
val make_delete_application_input_processing_configuration_response :
unit ->
delete_application_input_processing_configuration_responseSource
val make_delete_application_input_processing_configuration_request :
input_id:string ->
current_application_version_id:int ->
application_name:string ->
unit ->
delete_application_input_processing_configuration_requestSource
val make_delete_application_cloud_watch_logging_option_response :
unit ->
delete_application_cloud_watch_logging_option_responseSource
val make_delete_application_cloud_watch_logging_option_request :
cloud_watch_logging_option_id:string ->
current_application_version_id:int ->
application_name:string ->
unit ->
delete_application_cloud_watch_logging_option_requestSource
val make_delete_application_request :
create_timestamp:float ->
application_name:string ->
unit ->
delete_application_requestSource
val make_create_application_response :
application_summary:application_summary ->
unit ->
create_application_responseSource
val make_input :
?input_parallelism:input_parallelism ->
?kinesis_firehose_input:kinesis_firehose_input ->
?kinesis_streams_input:kinesis_streams_input ->
?input_processing_configuration:input_processing_configuration ->
input_schema:source_schema ->
name_prefix:string ->
unit ->
inputSource
val make_cloud_watch_logging_option :
role_ar_n:string ->
log_stream_ar_n:string ->
unit ->
cloud_watch_logging_optionSource
val make_create_application_request :
?tags:tag list ->
?application_code:string ->
?cloud_watch_logging_options:cloud_watch_logging_option list ->
?outputs:output list ->
?inputs:input list ->
?application_description:string ->
application_name:string ->
unit ->
create_application_requestSource
val make_add_application_reference_data_source_response :
unit ->
add_application_reference_data_source_responseSource
val make_add_application_reference_data_source_request :
reference_data_source:reference_data_source ->
current_application_version_id:int ->
application_name:string ->
unit ->
add_application_reference_data_source_requestSource
val make_add_application_output_request :
output:output ->
current_application_version_id:int ->
application_name:string ->
unit ->
add_application_output_requestSource
val make_add_application_input_processing_configuration_response :
unit ->
add_application_input_processing_configuration_responseSource
val make_add_application_input_processing_configuration_request :
input_processing_configuration:input_processing_configuration ->
input_id:string ->
current_application_version_id:int ->
application_name:string ->
unit ->
add_application_input_processing_configuration_requestSource
val make_add_application_input_request :
input:input ->
current_application_version_id:int ->
application_name:string ->
unit ->
add_application_input_requestSource
val make_add_application_cloud_watch_logging_option_response :
unit ->
add_application_cloud_watch_logging_option_responseSource
val make_add_application_cloud_watch_logging_option_request :
cloud_watch_logging_option:cloud_watch_logging_option ->
current_application_version_id:int ->
application_name:string ->
unit ->
add_application_cloud_watch_logging_option_request sectionYPositions = computeSectionYPositions($el), 10)"
x-init="setTimeout(() => sectionYPositions = computeSectionYPositions($el), 10)"
>