%% WARNING: DO NOT EDIT, AUTO-GENERATED CODE!
%% See https://github.com/aws-beam/aws-codegen for more details.

%% @doc
%% AWS Supply Chain is a cloud-based application that works with your
%% enterprise resource planning (ERP) and supply chain management systems.
%%
%% Using AWS Supply Chain, you can connect and extract your inventory,
%% supply, and demand related data from existing ERP or supply chain systems
%% into a single data model.
%%
%% The AWS Supply Chain API supports configuration data import for Supply
%% Planning.
%%
%% All AWS Supply chain API operations are Amazon-authenticated and
%% certificate-signed. They not only require the use of the AWS SDK, but also
%% allow for the exclusive use of AWS Identity and Access Management users
%% and roles to help facilitate access, trust, and permission policies.
-module(aws_supplychain).

-export([create_bill_of_materials_import_job/3,
         create_bill_of_materials_import_job/4,
         create_data_integration_flow/4,
         create_data_integration_flow/5,
         create_data_lake_dataset/5,
         create_data_lake_dataset/6,
         create_data_lake_namespace/4,
         create_data_lake_namespace/5,
         create_instance/2,
         create_instance/3,
         delete_data_integration_flow/4,
         delete_data_integration_flow/5,
         delete_data_lake_dataset/5,
         delete_data_lake_dataset/6,
         delete_data_lake_namespace/4,
         delete_data_lake_namespace/5,
         delete_instance/3,
         delete_instance/4,
         get_bill_of_materials_import_job/3,
         get_bill_of_materials_import_job/5,
         get_bill_of_materials_import_job/6,
         get_data_integration_event/3,
         get_data_integration_event/5,
         get_data_integration_event/6,
         get_data_integration_flow/3,
         get_data_integration_flow/5,
         get_data_integration_flow/6,
         get_data_integration_flow_execution/4,
         get_data_integration_flow_execution/6,
         get_data_integration_flow_execution/7,
         get_data_lake_dataset/4,
         get_data_lake_dataset/6,
         get_data_lake_dataset/7,
         get_data_lake_namespace/3,
         get_data_lake_namespace/5,
         get_data_lake_namespace/6,
         get_instance/2,
         get_instance/4,
         get_instance/5,
         list_data_integration_events/2,
         list_data_integration_events/4,
         list_data_integration_events/5,
         list_data_integration_flow_executions/3,
         list_data_integration_flow_executions/5,
         list_data_integration_flow_executions/6,
         list_data_integration_flows/2,
         list_data_integration_flows/4,
         list_data_integration_flows/5,
         list_data_lake_datasets/3,
         list_data_lake_datasets/5,
         list_data_lake_datasets/6,
         list_data_lake_namespaces/2,
         list_data_lake_namespaces/4,
         list_data_lake_namespaces/5,
         list_instances/1,
         list_instances/3,
         list_instances/4,
         list_tags_for_resource/2,
         list_tags_for_resource/4,
         list_tags_for_resource/5,
         send_data_integration_event/3,
         send_data_integration_event/4,
         tag_resource/3,
         tag_resource/4,
         untag_resource/3,
         untag_resource/4,
         update_data_integration_flow/4,
         update_data_integration_flow/5,
         update_data_lake_dataset/5,
         update_data_lake_dataset/6,
         update_data_lake_namespace/4,
         update_data_lake_namespace/5,
         update_instance/3,
         update_instance/4]).

-include_lib("hackney/include/hackney_lib.hrl").



%% Example:
%% data_integration_flow_source() :: #{
%%   <<"datasetSource">> => data_integration_flow_dataset_source_configuration(),
%%   <<"s3Source">> => data_integration_flow_s3_source_configuration(),
%%   <<"sourceName">> => string(),
%%   <<"sourceType">> => list(any())
%% }
-type data_integration_flow_source() :: #{binary() => any()}.

%% Example:
%% delete_data_lake_dataset_request() :: #{}
-type delete_data_lake_dataset_request() :: #{}.


%% Example:
%% tag_resource_request() :: #{
%%   <<"tags">> := map()
%% }
-type tag_resource_request() :: #{binary() => any()}.


%% Example:
%% delete_data_lake_namespace_response() :: #{
%%   <<"instanceId">> => string(),
%%   <<"name">> => string()
%% }
-type delete_data_lake_namespace_response() :: #{binary() => any()}.

%% Example:
%% get_data_integration_flow_execution_request() :: #{}
-type get_data_integration_flow_execution_request() :: #{}.


%% Example:
%% list_data_lake_namespaces_response() :: #{
%%   <<"namespaces">> => list(data_lake_namespace()),
%%   <<"nextToken">> => string()
%% }
-type list_data_lake_namespaces_response() :: #{binary() => any()}.

%% Example:
%% delete_data_lake_namespace_request() :: #{}
-type delete_data_lake_namespace_request() :: #{}.


%% Example:
%% data_integration_event_dataset_target_configuration() :: #{
%%   <<"datasetIdentifier">> => string(),
%%   <<"operationType">> => list(any())
%% }
-type data_integration_event_dataset_target_configuration() :: #{binary() => any()}.

%% Example:
%% untag_resource_response() :: #{}
-type untag_resource_response() :: #{}.


%% Example:
%% data_integration_flow_s3_target_configuration() :: #{
%%   <<"bucketName">> => string(),
%%   <<"options">> => data_integration_flow_s3_options(),
%%   <<"prefix">> => string()
%% }
-type data_integration_flow_s3_target_configuration() :: #{binary() => any()}.


%% Example:
%% data_integration_flow_execution_source_info() :: #{
%%   <<"datasetSource">> => data_integration_flow_dataset_source(),
%%   <<"s3Source">> => data_integration_flow_s3_source(),
%%   <<"sourceType">> => list(any())
%% }
-type data_integration_flow_execution_source_info() :: #{binary() => any()}.


%% Example:
%% data_integration_flow_s3_options() :: #{
%%   <<"fileType">> => list(any())
%% }
-type data_integration_flow_s3_options() :: #{binary() => any()}.


%% Example:
%% list_data_integration_flow_executions_request() :: #{
%%   <<"maxResults">> => integer(),
%%   <<"nextToken">> => string()
%% }
-type list_data_integration_flow_executions_request() :: #{binary() => any()}.


%% Example:
%% get_data_lake_dataset_response() :: #{
%%   <<"dataset">> => data_lake_dataset()
%% }
-type get_data_lake_dataset_response() :: #{binary() => any()}.


%% Example:
%% list_data_lake_datasets_request() :: #{
%%   <<"maxResults">> => integer(),
%%   <<"nextToken">> => string()
%% }
-type list_data_lake_datasets_request() :: #{binary() => any()}.


%% Example:
%% data_lake_dataset_partition_field() :: #{
%%   <<"name">> => string(),
%%   <<"transform">> => data_lake_dataset_partition_field_transform()
%% }
-type data_lake_dataset_partition_field() :: #{binary() => any()}.

%% Example:
%% delete_data_integration_flow_request() :: #{}
-type delete_data_integration_flow_request() :: #{}.


%% Example:
%% update_data_lake_dataset_request() :: #{
%%   <<"description">> => string()
%% }
-type update_data_lake_dataset_request() :: #{binary() => any()}.


%% Example:
%% create_data_lake_dataset_request() :: #{
%%   <<"description">> => string(),
%%   <<"partitionSpec">> => data_lake_dataset_partition_spec(),
%%   <<"schema">> => data_lake_dataset_schema(),
%%   <<"tags">> => map()
%% }
-type create_data_lake_dataset_request() :: #{binary() => any()}.


%% Example:
%% create_instance_response() :: #{
%%   <<"instance">> => instance()
%% }
-type create_instance_response() :: #{binary() => any()}.


%% Example:
%% delete_data_integration_flow_response() :: #{
%%   <<"instanceId">> => string(),
%%   <<"name">> => string()
%% }
-type delete_data_integration_flow_response() :: #{binary() => any()}.


%% Example:
%% data_integration_flow_dedupe_strategy() :: #{
%%   <<"fieldPriority">> => data_integration_flow_field_priority_dedupe_strategy_configuration(),
%%   <<"type">> => list(any())
%% }
-type data_integration_flow_dedupe_strategy() :: #{binary() => any()}.


%% Example:
%% data_lake_dataset_primary_key_field() :: #{
%%   <<"name">> => string()
%% }
-type data_lake_dataset_primary_key_field() :: #{binary() => any()}.


%% Example:
%% untag_resource_request() :: #{
%%   <<"tagKeys">> := list(string())
%% }
-type untag_resource_request() :: #{binary() => any()}.


%% Example:
%% create_data_integration_flow_request() :: #{
%%   <<"sources">> := list(data_integration_flow_source()),
%%   <<"tags">> => map(),
%%   <<"target">> := data_integration_flow_target(),
%%   <<"transformation">> := data_integration_flow_transformation()
%% }
-type create_data_integration_flow_request() :: #{binary() => any()}.


%% Example:
%% create_data_lake_namespace_request() :: #{
%%   <<"description">> => string(),
%%   <<"tags">> => map()
%% }
-type create_data_lake_namespace_request() :: #{binary() => any()}.


%% Example:
%% data_integration_flow_field_priority_dedupe_field() :: #{
%%   <<"name">> => string(),
%%   <<"sortOrder">> => list(any())
%% }
-type data_integration_flow_field_priority_dedupe_field() :: #{binary() => any()}.


%% Example:
%% data_integration_flow() :: #{
%%   <<"createdTime">> => [non_neg_integer()],
%%   <<"instanceId">> => string(),
%%   <<"lastModifiedTime">> => [non_neg_integer()],
%%   <<"name">> => string(),
%%   <<"sources">> => list(data_integration_flow_source()),
%%   <<"target">> => data_integration_flow_target(),
%%   <<"transformation">> => data_integration_flow_transformation()
%% }
-type data_integration_flow() :: #{binary() => any()}.


%% Example:
%% update_data_integration_flow_response() :: #{
%%   <<"flow">> => data_integration_flow()
%% }
-type update_data_integration_flow_response() :: #{binary() => any()}.

%% Example:
%% get_instance_request() :: #{}
-type get_instance_request() :: #{}.


%% Example:
%% create_bill_of_materials_import_job_response() :: #{
%%   <<"jobId">> => string()
%% }
-type create_bill_of_materials_import_job_response() :: #{binary() => any()}.


%% Example:
%% update_data_lake_namespace_request() :: #{
%%   <<"description">> => string()
%% }
-type update_data_lake_namespace_request() :: #{binary() => any()}.


%% Example:
%% data_lake_dataset_schema_field() :: #{
%%   <<"isRequired">> => [boolean()],
%%   <<"name">> => string(),
%%   <<"type">> => list(any())
%% }
-type data_lake_dataset_schema_field() :: #{binary() => any()}.


%% Example:
%% get_bill_of_materials_import_job_response() :: #{
%%   <<"job">> => bill_of_materials_import_job()
%% }
-type get_bill_of_materials_import_job_response() :: #{binary() => any()}.


%% Example:
%% data_integration_flow_s_q_l_transformation_configuration() :: #{
%%   <<"query">> => string()
%% }
-type data_integration_flow_s_q_l_transformation_configuration() :: #{binary() => any()}.


%% Example:
%% create_data_integration_flow_response() :: #{
%%   <<"instanceId">> => string(),
%%   <<"name">> => string()
%% }
-type create_data_integration_flow_response() :: #{binary() => any()}.


%% Example:
%% list_data_lake_datasets_response() :: #{
%%   <<"datasets">> => list(data_lake_dataset()),
%%   <<"nextToken">> => string()
%% }
-type list_data_lake_datasets_response() :: #{binary() => any()}.


%% Example:
%% conflict_exception() :: #{
%%   <<"message">> => [string()]
%% }
-type conflict_exception() :: #{binary() => any()}.


%% Example:
%% resource_not_found_exception() :: #{
%%   <<"message">> => [string()]
%% }
-type resource_not_found_exception() :: #{binary() => any()}.


%% Example:
%% update_data_lake_namespace_response() :: #{
%%   <<"namespace">> => data_lake_namespace()
%% }
-type update_data_lake_namespace_response() :: #{binary() => any()}.

%% Example:
%% get_bill_of_materials_import_job_request() :: #{}
-type get_bill_of_materials_import_job_request() :: #{}.


%% Example:
%% service_quota_exceeded_exception() :: #{
%%   <<"message">> => [string()]
%% }
-type service_quota_exceeded_exception() :: #{binary() => any()}.


%% Example:
%% data_integration_flow_dataset_options() :: #{
%%   <<"dedupeRecords">> => [boolean()],
%%   <<"dedupeStrategy">> => data_integration_flow_dedupe_strategy(),
%%   <<"loadType">> => list(any())
%% }
-type data_integration_flow_dataset_options() :: #{binary() => any()}.

%% Example:
%% get_data_integration_flow_request() :: #{}
-type get_data_integration_flow_request() :: #{}.


%% Example:
%% data_integration_event_dataset_load_execution_details() :: #{
%%   <<"message">> => [string()],
%%   <<"status">> => list(any())
%% }
-type data_integration_event_dataset_load_execution_details() :: #{binary() => any()}.


%% Example:
%% update_instance_request() :: #{
%%   <<"instanceDescription">> => string(),
%%   <<"instanceName">> => string()
%% }
-type update_instance_request() :: #{binary() => any()}.


%% Example:
%% list_data_integration_flow_executions_response() :: #{
%%   <<"flowExecutions">> => list(data_integration_flow_execution()),
%%   <<"nextToken">> => string()
%% }
-type list_data_integration_flow_executions_response() :: #{binary() => any()}.


%% Example:
%% data_integration_event_dataset_target_details() :: #{
%%   <<"datasetIdentifier">> => string(),
%%   <<"datasetLoadExecution">> => data_integration_event_dataset_load_execution_details(),
%%   <<"operationType">> => list(any())
%% }
-type data_integration_event_dataset_target_details() :: #{binary() => any()}.


%% Example:
%% get_instance_response() :: #{
%%   <<"instance">> => instance()
%% }
-type get_instance_response() :: #{binary() => any()}.


%% Example:
%% data_lake_dataset_schema() :: #{
%%   <<"fields">> => list(data_lake_dataset_schema_field()),
%%   <<"name">> => string(),
%%   <<"primaryKeys">> => list(data_lake_dataset_primary_key_field())
%% }
-type data_lake_dataset_schema() :: #{binary() => any()}.


%% Example:
%% list_data_integration_events_request() :: #{
%%   <<"eventType">> => list(any()),
%%   <<"maxResults">> => integer(),
%%   <<"nextToken">> => string()
%% }
-type list_data_integration_events_request() :: #{binary() => any()}.


%% Example:
%% list_tags_for_resource_response() :: #{
%%   <<"tags">> => map()
%% }
-type list_tags_for_resource_response() :: #{binary() => any()}.


%% Example:
%% data_lake_dataset_partition_field_transform() :: #{
%%   <<"type">> => list(any())
%% }
-type data_lake_dataset_partition_field_transform() :: #{binary() => any()}.


%% Example:
%% data_integration_flow_dataset_target_configuration() :: #{
%%   <<"datasetIdentifier">> => string(),
%%   <<"options">> => data_integration_flow_dataset_options()
%% }
-type data_integration_flow_dataset_target_configuration() :: #{binary() => any()}.


%% Example:
%% create_bill_of_materials_import_job_request() :: #{
%%   <<"clientToken">> => string(),
%%   <<"s3uri">> := string()
%% }
-type create_bill_of_materials_import_job_request() :: #{binary() => any()}.


%% Example:
%% list_instances_request() :: #{
%%   <<"instanceNameFilter">> => list(string()),
%%   <<"instanceStateFilter">> => list(list(any())()),
%%   <<"maxResults">> => integer(),
%%   <<"nextToken">> => string()
%% }
-type list_instances_request() :: #{binary() => any()}.


%% Example:
%% create_data_lake_dataset_response() :: #{
%%   <<"dataset">> => data_lake_dataset()
%% }
-type create_data_lake_dataset_response() :: #{binary() => any()}.


%% Example:
%% list_instances_response() :: #{
%%   <<"instances">> => list(instance()),
%%   <<"nextToken">> => string()
%% }
-type list_instances_response() :: #{binary() => any()}.


%% Example:
%% internal_server_exception() :: #{
%%   <<"message">> => [string()]
%% }
-type internal_server_exception() :: #{binary() => any()}.


%% Example:
%% data_integration_flow_transformation() :: #{
%%   <<"sqlTransformation">> => data_integration_flow_s_q_l_transformation_configuration(),
%%   <<"transformationType">> => list(any())
%% }
-type data_integration_flow_transformation() :: #{binary() => any()}.


%% Example:
%% get_data_integration_flow_execution_response() :: #{
%%   <<"flowExecution">> => data_integration_flow_execution()
%% }
-type get_data_integration_flow_execution_response() :: #{binary() => any()}.


%% Example:
%% data_integration_flow_dataset_source() :: #{
%%   <<"datasetIdentifier">> => string()
%% }
-type data_integration_flow_dataset_source() :: #{binary() => any()}.


%% Example:
%% data_integration_flow_execution_output_metadata() :: #{
%%   <<"diagnosticReportsRootS3URI">> => string()
%% }
-type data_integration_flow_execution_output_metadata() :: #{binary() => any()}.


%% Example:
%% get_data_integration_event_response() :: #{
%%   <<"event">> => data_integration_event()
%% }
-type get_data_integration_event_response() :: #{binary() => any()}.


%% Example:
%% get_data_integration_flow_response() :: #{
%%   <<"flow">> => data_integration_flow()
%% }
-type get_data_integration_flow_response() :: #{binary() => any()}.


%% Example:
%% create_instance_request() :: #{
%%   <<"clientToken">> => string(),
%%   <<"instanceDescription">> => string(),
%%   <<"instanceName">> => string(),
%%   <<"kmsKeyArn">> => string(),
%%   <<"tags">> => map(),
%%   <<"webAppDnsDomain">> => string()
%% }
-type create_instance_request() :: #{binary() => any()}.


%% Example:
%% instance() :: #{
%%   <<"awsAccountId">> => string(),
%%   <<"createdTime">> => [non_neg_integer()],
%%   <<"errorMessage">> => [string()],
%%   <<"instanceDescription">> => string(),
%%   <<"instanceId">> => string(),
%%   <<"instanceName">> => string(),
%%   <<"kmsKeyArn">> => string(),
%%   <<"lastModifiedTime">> => [non_neg_integer()],
%%   <<"state">> => list(any()),
%%   <<"versionNumber">> => [float()],
%%   <<"webAppDnsDomain">> => string()
%% }
-type instance() :: #{binary() => any()}.

%% Example:
%% get_data_lake_namespace_request() :: #{}
-type get_data_lake_namespace_request() :: #{}.


%% Example:
%% access_denied_exception() :: #{
%%   <<"message">> => [string()]
%% }
-type access_denied_exception() :: #{binary() => any()}.

%% Example:
%% tag_resource_response() :: #{}
-type tag_resource_response() :: #{}.


%% Example:
%% list_data_integration_events_response() :: #{
%%   <<"events">> => list(data_integration_event()),
%%   <<"nextToken">> => string()
%% }
-type list_data_integration_events_response() :: #{binary() => any()}.


%% Example:
%% get_data_lake_namespace_response() :: #{
%%   <<"namespace">> => data_lake_namespace()
%% }
-type get_data_lake_namespace_response() :: #{binary() => any()}.


%% Example:
%% delete_instance_response() :: #{
%%   <<"instance">> => instance()
%% }
-type delete_instance_response() :: #{binary() => any()}.


%% Example:
%% send_data_integration_event_response() :: #{
%%   <<"eventId">> => string()
%% }
-type send_data_integration_event_response() :: #{binary() => any()}.


%% Example:
%% validation_exception() :: #{
%%   <<"message">> => [string()]
%% }
-type validation_exception() :: #{binary() => any()}.

%% Example:
%% list_tags_for_resource_request() :: #{}
-type list_tags_for_resource_request() :: #{}.


%% Example:
%% throttling_exception() :: #{
%%   <<"message">> => [string()]
%% }
-type throttling_exception() :: #{binary() => any()}.

%% Example:
%% delete_instance_request() :: #{}
-type delete_instance_request() :: #{}.

%% Example:
%% get_data_integration_event_request() :: #{}
-type get_data_integration_event_request() :: #{}.


%% Example:
%% list_data_integration_flows_response() :: #{
%%   <<"flows">> => list(data_integration_flow()),
%%   <<"nextToken">> => string()
%% }
-type list_data_integration_flows_response() :: #{binary() => any()}.


%% Example:
%% list_data_lake_namespaces_request() :: #{
%%   <<"maxResults">> => integer(),
%%   <<"nextToken">> => string()
%% }
-type list_data_lake_namespaces_request() :: #{binary() => any()}.


%% Example:
%% data_integration_flow_field_priority_dedupe_strategy_configuration() :: #{
%%   <<"fields">> => list(data_integration_flow_field_priority_dedupe_field())
%% }
-type data_integration_flow_field_priority_dedupe_strategy_configuration() :: #{binary() => any()}.


%% Example:
%% data_integration_flow_s3_source() :: #{
%%   <<"bucketName">> => string(),
%%   <<"key">> => string()
%% }
-type data_integration_flow_s3_source() :: #{binary() => any()}.


%% Example:
%% send_data_integration_event_request() :: #{
%%   <<"clientToken">> => string(),
%%   <<"data">> := string(),
%%   <<"datasetTarget">> => data_integration_event_dataset_target_configuration(),
%%   <<"eventGroupId">> := string(),
%%   <<"eventTimestamp">> => [non_neg_integer()],
%%   <<"eventType">> := list(any())
%% }
-type send_data_integration_event_request() :: #{binary() => any()}.


%% Example:
%% data_integration_flow_execution() :: #{
%%   <<"endTime">> => [non_neg_integer()],
%%   <<"executionId">> => string(),
%%   <<"flowName">> => string(),
%%   <<"instanceId">> => string(),
%%   <<"message">> => [string()],
%%   <<"outputMetadata">> => data_integration_flow_execution_output_metadata(),
%%   <<"sourceInfo">> => data_integration_flow_execution_source_info(),
%%   <<"startTime">> => [non_neg_integer()],
%%   <<"status">> => list(any())
%% }
-type data_integration_flow_execution() :: #{binary() => any()}.


%% Example:
%% data_integration_flow_s3_source_configuration() :: #{
%%   <<"bucketName">> => string(),
%%   <<"options">> => data_integration_flow_s3_options(),
%%   <<"prefix">> => string()
%% }
-type data_integration_flow_s3_source_configuration() :: #{binary() => any()}.

%% Example:
%% get_data_lake_dataset_request() :: #{}
-type get_data_lake_dataset_request() :: #{}.


%% Example:
%% data_integration_flow_target() :: #{
%%   <<"datasetTarget">> => data_integration_flow_dataset_target_configuration(),
%%   <<"s3Target">> => data_integration_flow_s3_target_configuration(),
%%   <<"targetType">> => list(any())
%% }
-type data_integration_flow_target() :: #{binary() => any()}.


%% Example:
%% data_lake_dataset_partition_spec() :: #{
%%   <<"fields">> => list(data_lake_dataset_partition_field())
%% }
-type data_lake_dataset_partition_spec() :: #{binary() => any()}.


%% Example:
%% data_lake_namespace() :: #{
%%   <<"arn">> => string(),
%%   <<"createdTime">> => [non_neg_integer()],
%%   <<"description">> => string(),
%%   <<"instanceId">> => string(),
%%   <<"lastModifiedTime">> => [non_neg_integer()],
%%   <<"name">> => string()
%% }
-type data_lake_namespace() :: #{binary() => any()}.


%% Example:
%% list_data_integration_flows_request() :: #{
%%   <<"maxResults">> => integer(),
%%   <<"nextToken">> => string()
%% }
-type list_data_integration_flows_request() :: #{binary() => any()}.


%% Example:
%% data_integration_event() :: #{
%%   <<"datasetTargetDetails">> => data_integration_event_dataset_target_details(),
%%   <<"eventGroupId">> => string(),
%%   <<"eventId">> => string(),
%%   <<"eventTimestamp">> => [non_neg_integer()],
%%   <<"eventType">> => list(any()),
%%   <<"instanceId">> => string()
%% }
-type data_integration_event() :: #{binary() => any()}.


%% Example:
%% update_instance_response() :: #{
%%   <<"instance">> => instance()
%% }
-type update_instance_response() :: #{binary() => any()}.


%% Example:
%% update_data_integration_flow_request() :: #{
%%   <<"sources">> => list(data_integration_flow_source()),
%%   <<"target">> => data_integration_flow_target(),
%%   <<"transformation">> => data_integration_flow_transformation()
%% }
-type update_data_integration_flow_request() :: #{binary() => any()}.


%% Example:
%% data_integration_flow_dataset_source_configuration() :: #{
%%   <<"datasetIdentifier">> => string(),
%%   <<"options">> => data_integration_flow_dataset_options()
%% }
-type data_integration_flow_dataset_source_configuration() :: #{binary() => any()}.


%% Example:
%% bill_of_materials_import_job() :: #{
%%   <<"instanceId">> => string(),
%%   <<"jobId">> => string(),
%%   <<"message">> => [string()],
%%   <<"s3uri">> => string(),
%%   <<"status">> => list(any())
%% }
-type bill_of_materials_import_job() :: #{binary() => any()}.


%% Example:
%% create_data_lake_namespace_response() :: #{
%%   <<"namespace">> => data_lake_namespace()
%% }
-type create_data_lake_namespace_response() :: #{binary() => any()}.


%% Example:
%% data_lake_dataset() :: #{
%%   <<"arn">> => string(),
%%   <<"createdTime">> => [non_neg_integer()],
%%   <<"description">> => string(),
%%   <<"instanceId">> => string(),
%%   <<"lastModifiedTime">> => [non_neg_integer()],
%%   <<"name">> => string(),
%%   <<"namespace">> => string(),
%%   <<"partitionSpec">> => data_lake_dataset_partition_spec(),
%%   <<"schema">> => data_lake_dataset_schema()
%% }
-type data_lake_dataset() :: #{binary() => any()}.


%% Example:
%% delete_data_lake_dataset_response() :: #{
%%   <<"instanceId">> => string(),
%%   <<"name">> => string(),
%%   <<"namespace">> => string()
%% }
-type delete_data_lake_dataset_response() :: #{binary() => any()}.


%% Example:
%% update_data_lake_dataset_response() :: #{
%%   <<"dataset">> => data_lake_dataset()
%% }
-type update_data_lake_dataset_response() :: #{binary() => any()}.

-type create_bill_of_materials_import_job_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    service_quota_exceeded_exception() | 
    conflict_exception().

-type create_data_integration_flow_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    service_quota_exceeded_exception() | 
    conflict_exception().

-type create_data_lake_dataset_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    service_quota_exceeded_exception() | 
    resource_not_found_exception() | 
    conflict_exception().

-type create_data_lake_namespace_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    service_quota_exceeded_exception() | 
    conflict_exception().

-type create_instance_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    service_quota_exceeded_exception() | 
    conflict_exception().

-type delete_data_integration_flow_errors() ::
    throttling_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type delete_data_lake_dataset_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type delete_data_lake_namespace_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type delete_instance_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type get_bill_of_materials_import_job_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type get_data_integration_event_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type get_data_integration_flow_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type get_data_integration_flow_execution_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type get_data_lake_dataset_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type get_data_lake_namespace_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type get_instance_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type list_data_integration_events_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception().

-type list_data_integration_flow_executions_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type list_data_integration_flows_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception().

-type list_data_lake_datasets_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type list_data_lake_namespaces_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception().

-type list_instances_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception().

-type list_tags_for_resource_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type send_data_integration_event_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    service_quota_exceeded_exception() | 
    resource_not_found_exception() | 
    conflict_exception().

-type tag_resource_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type untag_resource_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type update_data_integration_flow_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type update_data_lake_dataset_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type update_data_lake_namespace_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type update_instance_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

%%====================================================================
%% API
%%====================================================================

%% @doc CreateBillOfMaterialsImportJob creates an import job for the Product
%% Bill Of Materials (BOM) entity.
%%
%% For information on the product_bom entity, see the AWS Supply Chain User
%% Guide.
%%
%% The CSV file must be located in an Amazon S3 location accessible to AWS
%% Supply Chain. It is recommended to use the same Amazon S3 bucket created
%% during your AWS Supply Chain instance creation.
-spec create_bill_of_materials_import_job(aws_client:aws_client(), binary() | list(), create_bill_of_materials_import_job_request()) ->
    {ok, create_bill_of_materials_import_job_response(), tuple()} |
    {error, any()} |
    {error, create_bill_of_materials_import_job_errors(), tuple()}.
create_bill_of_materials_import_job(Client, InstanceId, Input) ->
    create_bill_of_materials_import_job(Client, InstanceId, Input, []).

-spec create_bill_of_materials_import_job(aws_client:aws_client(), binary() | list(), create_bill_of_materials_import_job_request(), proplists:proplist()) ->
    {ok, create_bill_of_materials_import_job_response(), tuple()} |
    {error, any()} |
    {error, create_bill_of_materials_import_job_errors(), tuple()}.
create_bill_of_materials_import_job(Client, InstanceId, Input0, Options0) ->
    Method = post,
    Path = ["/api/configuration/instances/", aws_util:encode_uri(InstanceId), "/bill-of-materials-import-jobs"],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary},
               {append_sha256_content_hash, false}
               | Options2],

    Headers = [],
    Input1 = Input0,

    CustomHeaders = [],
    Input2 = Input1,

    Query_ = [],
    Input = Input2,

    request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode).

%% @doc Enables you to programmatically create a data pipeline to ingest data
%% from source systems such as Amazon S3 buckets, to a predefined Amazon Web
%% Services Supply Chain dataset (product, inbound_order) or a temporary
%% dataset along with the data transformation query provided with the API.
-spec create_data_integration_flow(aws_client:aws_client(), binary() | list(), binary() | list(), create_data_integration_flow_request()) ->
    {ok, create_data_integration_flow_response(), tuple()} |
    {error, any()} |
    {error, create_data_integration_flow_errors(), tuple()}.
create_data_integration_flow(Client, InstanceId, Name, Input) ->
    create_data_integration_flow(Client, InstanceId, Name, Input, []).

-spec create_data_integration_flow(aws_client:aws_client(), binary() | list(), binary() | list(), create_data_integration_flow_request(), proplists:proplist()) ->
    {ok, create_data_integration_flow_response(), tuple()} |
    {error, any()} |
    {error, create_data_integration_flow_errors(), tuple()}.
create_data_integration_flow(Client, InstanceId, Name, Input0, Options0) ->
    Method = put,
    Path = ["/api/data-integration/instance/", aws_util:encode_uri(InstanceId), "/data-integration-flows/", aws_util:encode_uri(Name), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary},
               {append_sha256_content_hash, false}
               | Options2],

    Headers = [],
    Input1 = Input0,

    CustomHeaders = [],
    Input2 = Input1,

    Query_ = [],
    Input = Input2,

    request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode).

%% @doc Enables you to programmatically create an Amazon Web Services Supply
%% Chain data lake dataset.
%%
%% Developers can create the datasets using their pre-defined or custom
%% schema for a given instance ID, namespace, and dataset name.
-spec create_data_lake_dataset(aws_client:aws_client(), binary() | list(), binary() | list(), binary() | list(), create_data_lake_dataset_request()) ->
    {ok, create_data_lake_dataset_response(), tuple()} |
    {error, any()} |
    {error, create_data_lake_dataset_errors(), tuple()}.
create_data_lake_dataset(Client, InstanceId, Name, Namespace, Input) ->
    create_data_lake_dataset(Client, InstanceId, Name, Namespace, Input, []).

-spec create_data_lake_dataset(aws_client:aws_client(), binary() | list(), binary() | list(), binary() | list(), create_data_lake_dataset_request(), proplists:proplist()) ->
    {ok, create_data_lake_dataset_response(), tuple()} |
    {error, any()} |
    {error, create_data_lake_dataset_errors(), tuple()}.
create_data_lake_dataset(Client, InstanceId, Name, Namespace, Input0, Options0) ->
    Method = put,
    Path = ["/api/datalake/instance/", aws_util:encode_uri(InstanceId), "/namespaces/", aws_util:encode_uri(Namespace), "/datasets/", aws_util:encode_uri(Name), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary},
               {append_sha256_content_hash, false}
               | Options2],

    Headers = [],
    Input1 = Input0,

    CustomHeaders = [],
    Input2 = Input1,

    Query_ = [],
    Input = Input2,

    request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode).

%% @doc Enables you to programmatically create an Amazon Web Services Supply
%% Chain data lake namespace.
%%
%% Developers can create the namespaces for a given instance ID.
-spec create_data_lake_namespace(aws_client:aws_client(), binary() | list(), binary() | list(), create_data_lake_namespace_request()) ->
    {ok, create_data_lake_namespace_response(), tuple()} |
    {error, any()} |
    {error, create_data_lake_namespace_errors(), tuple()}.
create_data_lake_namespace(Client, InstanceId, Name, Input) ->
    create_data_lake_namespace(Client, InstanceId, Name, Input, []).

-spec create_data_lake_namespace(aws_client:aws_client(), binary() | list(), binary() | list(), create_data_lake_namespace_request(), proplists:proplist()) ->
    {ok, create_data_lake_namespace_response(), tuple()} |
    {error, any()} |
    {error, create_data_lake_namespace_errors(), tuple()}.
create_data_lake_namespace(Client, InstanceId, Name, Input0, Options0) ->
    Method = put,
    Path = ["/api/datalake/instance/", aws_util:encode_uri(InstanceId), "/namespaces/", aws_util:encode_uri(Name), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary},
               {append_sha256_content_hash, false}
               | Options2],

    Headers = [],
    Input1 = Input0,

    CustomHeaders = [],
    Input2 = Input1,

    Query_ = [],
    Input = Input2,

    request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode).

%% @doc Enables you to programmatically create an Amazon Web Services Supply
%% Chain instance by applying KMS keys and relevant information associated
%% with the API without using the Amazon Web Services console.
%%
%% This is an asynchronous operation. Upon receiving a CreateInstance
%% request, Amazon Web Services Supply Chain immediately returns the instance
%% resource, instance ID, and the initializing state while simultaneously
%% creating all required Amazon Web Services resources for an instance
%% creation. You can use GetInstance to check the status of the instance. If
%% the instance results in an unhealthy state, you need to check the error
%% message, delete the current instance, and recreate a new one based on the
%% mitigation from the error message.
-spec create_instance(aws_client:aws_client(), create_instance_request()) ->
    {ok, create_instance_response(), tuple()} |
    {error, any()} |
    {error, create_instance_errors(), tuple()}.
create_instance(Client, Input) ->
    create_instance(Client, Input, []).

-spec create_instance(aws_client:aws_client(), create_instance_request(), proplists:proplist()) ->
    {ok, create_instance_response(), tuple()} |
    {error, any()} |
    {error, create_instance_errors(), tuple()}.
create_instance(Client, Input0, Options0) ->
    Method = post,
    Path = ["/api/instance"],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary},
               {append_sha256_content_hash, false}
               | Options2],

    Headers = [],
    Input1 = Input0,

    CustomHeaders = [],
    Input2 = Input1,

    Query_ = [],
    Input = Input2,

    request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode).

%% @doc Enable you to programmatically delete an existing data pipeline for
%% the provided Amazon Web Services Supply Chain instance and
%% DataIntegrationFlow name.
-spec delete_data_integration_flow(aws_client:aws_client(), binary() | list(), binary() | list(), delete_data_integration_flow_request()) ->
    {ok, delete_data_integration_flow_response(), tuple()} |
    {error, any()} |
    {error, delete_data_integration_flow_errors(), tuple()}.
delete_data_integration_flow(Client, InstanceId, Name, Input) ->
    delete_data_integration_flow(Client, InstanceId, Name, Input, []).

-spec delete_data_integration_flow(aws_client:aws_client(), binary() | list(), binary() | list(), delete_data_integration_flow_request(), proplists:proplist()) ->
    {ok, delete_data_integration_flow_response(), tuple()} |
    {error, any()} |
    {error, delete_data_integration_flow_errors(), tuple()}.
delete_data_integration_flow(Client, InstanceId, Name, Input0, Options0) ->
    Method = delete,
    Path = ["/api/data-integration/instance/", aws_util:encode_uri(InstanceId), "/data-integration-flows/", aws_util:encode_uri(Name), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary},
               {append_sha256_content_hash, false}
               | Options2],

    Headers = [],
    Input1 = Input0,

    CustomHeaders = [],
    Input2 = Input1,

    Query_ = [],
    Input = Input2,

    request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode).

%% @doc Enables you to programmatically delete an Amazon Web Services Supply
%% Chain data lake dataset.
%%
%% Developers can delete the existing datasets for a given instance ID,
%% namespace, and instance name.
-spec delete_data_lake_dataset(aws_client:aws_client(), binary() | list(), binary() | list(), binary() | list(), delete_data_lake_dataset_request()) ->
    {ok, delete_data_lake_dataset_response(), tuple()} |
    {error, any()} |
    {error, delete_data_lake_dataset_errors(), tuple()}.
delete_data_lake_dataset(Client, InstanceId, Name, Namespace, Input) ->
    delete_data_lake_dataset(Client, InstanceId, Name, Namespace, Input, []).

-spec delete_data_lake_dataset(aws_client:aws_client(), binary() | list(), binary() | list(), binary() | list(), delete_data_lake_dataset_request(), proplists:proplist()) ->
    {ok, delete_data_lake_dataset_response(), tuple()} |
    {error, any()} |
    {error, delete_data_lake_dataset_errors(), tuple()}.
delete_data_lake_dataset(Client, InstanceId, Name, Namespace, Input0, Options0) ->
    Method = delete,
    Path = ["/api/datalake/instance/", aws_util:encode_uri(InstanceId), "/namespaces/", aws_util:encode_uri(Namespace), "/datasets/", aws_util:encode_uri(Name), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary},
               {append_sha256_content_hash, false}
               | Options2],

    Headers = [],
    Input1 = Input0,

    CustomHeaders = [],
    Input2 = Input1,

    Query_ = [],
    Input = Input2,

    request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode).

%% @doc Enables you to programmatically delete an Amazon Web Services Supply
%% Chain data lake namespace and its underling datasets.
%%
%% Developers can delete the existing namespaces for a given instance ID and
%% namespace name.
-spec delete_data_lake_namespace(aws_client:aws_client(), binary() | list(), binary() | list(), delete_data_lake_namespace_request()) ->
    {ok, delete_data_lake_namespace_response(), tuple()} |
    {error, any()} |
    {error, delete_data_lake_namespace_errors(), tuple()}.
delete_data_lake_namespace(Client, InstanceId, Name, Input) ->
    delete_data_lake_namespace(Client, InstanceId, Name, Input, []).

-spec delete_data_lake_namespace(aws_client:aws_client(), binary() | list(), binary() | list(), delete_data_lake_namespace_request(), proplists:proplist()) ->
    {ok, delete_data_lake_namespace_response(), tuple()} |
    {error, any()} |
    {error, delete_data_lake_namespace_errors(), tuple()}.
delete_data_lake_namespace(Client, InstanceId, Name, Input0, Options0) ->
    Method = delete,
    Path = ["/api/datalake/instance/", aws_util:encode_uri(InstanceId), "/namespaces/", aws_util:encode_uri(Name), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary},
               {append_sha256_content_hash, false}
               | Options2],

    Headers = [],
    Input1 = Input0,

    CustomHeaders = [],
    Input2 = Input1,

    Query_ = [],
    Input = Input2,

    request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode).

%% @doc Enables you to programmatically delete an Amazon Web Services Supply
%% Chain instance by deleting the KMS keys and relevant information
%% associated with the API without using the Amazon Web Services console.
%%
%% This is an asynchronous operation. Upon receiving a DeleteInstance
%% request, Amazon Web Services Supply Chain immediately returns a response
%% with the instance resource, delete state while cleaning up all Amazon Web
%% Services resources created during the instance creation process. You can
%% use the GetInstance action to check the instance status.
-spec delete_instance(aws_client:aws_client(), binary() | list(), delete_instance_request()) ->
    {ok, delete_instance_response(), tuple()} |
    {error, any()} |
    {error, delete_instance_errors(), tuple()}.
delete_instance(Client, InstanceId, Input) ->
    delete_instance(Client, InstanceId, Input, []).

-spec delete_instance(aws_client:aws_client(), binary() | list(), delete_instance_request(), proplists:proplist()) ->
    {ok, delete_instance_response(), tuple()} |
    {error, any()} |
    {error, delete_instance_errors(), tuple()}.
delete_instance(Client, InstanceId, Input0, Options0) ->
    Method = delete,
    Path = ["/api/instance/", aws_util:encode_uri(InstanceId), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary},
               {append_sha256_content_hash, false}
               | Options2],

    Headers = [],
    Input1 = Input0,

    CustomHeaders = [],
    Input2 = Input1,

    Query_ = [],
    Input = Input2,

    request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode).

%% @doc Get status and details of a BillOfMaterialsImportJob.
-spec get_bill_of_materials_import_job(aws_client:aws_client(), binary() | list(), binary() | list()) ->
    {ok, get_bill_of_materials_import_job_response(), tuple()} |
    {error, any()} |
    {error, get_bill_of_materials_import_job_errors(), tuple()}.
get_bill_of_materials_import_job(Client, InstanceId, JobId)
  when is_map(Client) ->
    get_bill_of_materials_import_job(Client, InstanceId, JobId, #{}, #{}).

-spec get_bill_of_materials_import_job(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map()) ->
    {ok, get_bill_of_materials_import_job_response(), tuple()} |
    {error, any()} |
    {error, get_bill_of_materials_import_job_errors(), tuple()}.
get_bill_of_materials_import_job(Client, InstanceId, JobId, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    get_bill_of_materials_import_job(Client, InstanceId, JobId, QueryMap, HeadersMap, []).

-spec get_bill_of_materials_import_job(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, get_bill_of_materials_import_job_response(), tuple()} |
    {error, any()} |
    {error, get_bill_of_materials_import_job_errors(), tuple()}.
get_bill_of_materials_import_job(Client, InstanceId, JobId, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/api/configuration/instances/", aws_util:encode_uri(InstanceId), "/bill-of-materials-import-jobs/", aws_util:encode_uri(JobId), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary}
               | Options2],

    Headers = [],

    Query_ = [],

    request(Client, get, Path, Query_, Headers, undefined, Options, SuccessStatusCode).

%% @doc Enables you to programmatically view an Amazon Web Services Supply
%% Chain Data Integration Event.
%%
%% Developers can view the eventType, eventGroupId, eventTimestamp,
%% datasetTarget, datasetLoadExecution.
-spec get_data_integration_event(aws_client:aws_client(), binary() | list(), binary() | list()) ->
    {ok, get_data_integration_event_response(), tuple()} |
    {error, any()} |
    {error, get_data_integration_event_errors(), tuple()}.
get_data_integration_event(Client, EventId, InstanceId)
  when is_map(Client) ->
    get_data_integration_event(Client, EventId, InstanceId, #{}, #{}).

-spec get_data_integration_event(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map()) ->
    {ok, get_data_integration_event_response(), tuple()} |
    {error, any()} |
    {error, get_data_integration_event_errors(), tuple()}.
get_data_integration_event(Client, EventId, InstanceId, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    get_data_integration_event(Client, EventId, InstanceId, QueryMap, HeadersMap, []).

-spec get_data_integration_event(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, get_data_integration_event_response(), tuple()} |
    {error, any()} |
    {error, get_data_integration_event_errors(), tuple()}.
get_data_integration_event(Client, EventId, InstanceId, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/api-data/data-integration/instance/", aws_util:encode_uri(InstanceId), "/data-integration-events/", aws_util:encode_uri(EventId), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary}
               | Options2],

    Headers = [],

    Query_ = [],

    request(Client, get, Path, Query_, Headers, undefined, Options, SuccessStatusCode).

%% @doc Enables you to programmatically view a specific data pipeline for the
%% provided Amazon Web Services Supply Chain instance and DataIntegrationFlow
%% name.
-spec get_data_integration_flow(aws_client:aws_client(), binary() | list(), binary() | list()) ->
    {ok, get_data_integration_flow_response(), tuple()} |
    {error, any()} |
    {error, get_data_integration_flow_errors(), tuple()}.
get_data_integration_flow(Client, InstanceId, Name)
  when is_map(Client) ->
    get_data_integration_flow(Client, InstanceId, Name, #{}, #{}).

-spec get_data_integration_flow(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map()) ->
    {ok, get_data_integration_flow_response(), tuple()} |
    {error, any()} |
    {error, get_data_integration_flow_errors(), tuple()}.
get_data_integration_flow(Client, InstanceId, Name, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    get_data_integration_flow(Client, InstanceId, Name, QueryMap, HeadersMap, []).

-spec get_data_integration_flow(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, get_data_integration_flow_response(), tuple()} |
    {error, any()} |
    {error, get_data_integration_flow_errors(), tuple()}.
get_data_integration_flow(Client, InstanceId, Name, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/api/data-integration/instance/", aws_util:encode_uri(InstanceId), "/data-integration-flows/", aws_util:encode_uri(Name), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary}
               | Options2],

    Headers = [],

    Query_ = [],

    request(Client, get, Path, Query_, Headers, undefined, Options, SuccessStatusCode).

%% @doc Get the flow execution.
-spec get_data_integration_flow_execution(aws_client:aws_client(), binary() | list(), binary() | list(), binary() | list()) ->
    {ok, get_data_integration_flow_execution_response(), tuple()} |
    {error, any()} |
    {error, get_data_integration_flow_execution_errors(), tuple()}.
get_data_integration_flow_execution(Client, ExecutionId, FlowName, InstanceId)
  when is_map(Client) ->
    get_data_integration_flow_execution(Client, ExecutionId, FlowName, InstanceId, #{}, #{}).

-spec get_data_integration_flow_execution(aws_client:aws_client(), binary() | list(), binary() | list(), binary() | list(), map(), map()) ->
    {ok, get_data_integration_flow_execution_response(), tuple()} |
    {error, any()} |
    {error, get_data_integration_flow_execution_errors(), tuple()}.
get_data_integration_flow_execution(Client, ExecutionId, FlowName, InstanceId, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    get_data_integration_flow_execution(Client, ExecutionId, FlowName, InstanceId, QueryMap, HeadersMap, []).

-spec get_data_integration_flow_execution(aws_client:aws_client(), binary() | list(), binary() | list(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, get_data_integration_flow_execution_response(), tuple()} |
    {error, any()} |
    {error, get_data_integration_flow_execution_errors(), tuple()}.
get_data_integration_flow_execution(Client, ExecutionId, FlowName, InstanceId, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/api-data/data-integration/instance/", aws_util:encode_uri(InstanceId), "/data-integration-flows/", aws_util:encode_uri(FlowName), "/executions/", aws_util:encode_uri(ExecutionId), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary}
               | Options2],

    Headers = [],

    Query_ = [],

    request(Client, get, Path, Query_, Headers, undefined, Options, SuccessStatusCode).

%% @doc Enables you to programmatically view an Amazon Web Services Supply
%% Chain data lake dataset.
%%
%% Developers can view the data lake dataset information such as namespace,
%% schema, and so on for a given instance ID, namespace, and dataset name.
-spec get_data_lake_dataset(aws_client:aws_client(), binary() | list(), binary() | list(), binary() | list()) ->
    {ok, get_data_lake_dataset_response(), tuple()} |
    {error, any()} |
    {error, get_data_lake_dataset_errors(), tuple()}.
get_data_lake_dataset(Client, InstanceId, Name, Namespace)
  when is_map(Client) ->
    get_data_lake_dataset(Client, InstanceId, Name, Namespace, #{}, #{}).

-spec get_data_lake_dataset(aws_client:aws_client(), binary() | list(), binary() | list(), binary() | list(), map(), map()) ->
    {ok, get_data_lake_dataset_response(), tuple()} |
    {error, any()} |
    {error, get_data_lake_dataset_errors(), tuple()}.
get_data_lake_dataset(Client, InstanceId, Name, Namespace, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    get_data_lake_dataset(Client, InstanceId, Name, Namespace, QueryMap, HeadersMap, []).

-spec get_data_lake_dataset(aws_client:aws_client(), binary() | list(), binary() | list(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, get_data_lake_dataset_response(), tuple()} |
    {error, any()} |
    {error, get_data_lake_dataset_errors(), tuple()}.
get_data_lake_dataset(Client, InstanceId, Name, Namespace, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/api/datalake/instance/", aws_util:encode_uri(InstanceId), "/namespaces/", aws_util:encode_uri(Namespace), "/datasets/", aws_util:encode_uri(Name), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary}
               | Options2],

    Headers = [],

    Query_ = [],

    request(Client, get, Path, Query_, Headers, undefined, Options, SuccessStatusCode).

%% @doc Enables you to programmatically view an Amazon Web Services Supply
%% Chain data lake namespace.
%%
%% Developers can view the data lake namespace information such as
%% description for a given instance ID and namespace name.
-spec get_data_lake_namespace(aws_client:aws_client(), binary() | list(), binary() | list()) ->
    {ok, get_data_lake_namespace_response(), tuple()} |
    {error, any()} |
    {error, get_data_lake_namespace_errors(), tuple()}.
get_data_lake_namespace(Client, InstanceId, Name)
  when is_map(Client) ->
    get_data_lake_namespace(Client, InstanceId, Name, #{}, #{}).

-spec get_data_lake_namespace(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map()) ->
    {ok, get_data_lake_namespace_response(), tuple()} |
    {error, any()} |
    {error, get_data_lake_namespace_errors(), tuple()}.
get_data_lake_namespace(Client, InstanceId, Name, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    get_data_lake_namespace(Client, InstanceId, Name, QueryMap, HeadersMap, []).

-spec get_data_lake_namespace(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, get_data_lake_namespace_response(), tuple()} |
    {error, any()} |
    {error, get_data_lake_namespace_errors(), tuple()}.
get_data_lake_namespace(Client, InstanceId, Name, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/api/datalake/instance/", aws_util:encode_uri(InstanceId), "/namespaces/", aws_util:encode_uri(Name), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary}
               | Options2],

    Headers = [],

    Query_ = [],

    request(Client, get, Path, Query_, Headers, undefined, Options, SuccessStatusCode).

%% @doc Enables you to programmatically retrieve the information related to
%% an Amazon Web Services Supply Chain instance ID.
-spec get_instance(aws_client:aws_client(), binary() | list()) ->
    {ok, get_instance_response(), tuple()} |
    {error, any()} |
    {error, get_instance_errors(), tuple()}.
get_instance(Client, InstanceId)
  when is_map(Client) ->
    get_instance(Client, InstanceId, #{}, #{}).

-spec get_instance(aws_client:aws_client(), binary() | list(), map(), map()) ->
    {ok, get_instance_response(), tuple()} |
    {error, any()} |
    {error, get_instance_errors(), tuple()}.
get_instance(Client, InstanceId, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    get_instance(Client, InstanceId, QueryMap, HeadersMap, []).

-spec get_instance(aws_client:aws_client(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, get_instance_response(), tuple()} |
    {error, any()} |
    {error, get_instance_errors(), tuple()}.
get_instance(Client, InstanceId, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/api/instance/", aws_util:encode_uri(InstanceId), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary}
               | Options2],

    Headers = [],

    Query_ = [],

    request(Client, get, Path, Query_, Headers, undefined, Options, SuccessStatusCode).

%% @doc Enables you to programmatically list all data integration events for
%% the provided Amazon Web Services Supply Chain instance.
-spec list_data_integration_events(aws_client:aws_client(), binary() | list()) ->
    {ok, list_data_integration_events_response(), tuple()} |
    {error, any()} |
    {error, list_data_integration_events_errors(), tuple()}.
list_data_integration_events(Client, InstanceId)
  when is_map(Client) ->
    list_data_integration_events(Client, InstanceId, #{}, #{}).

-spec list_data_integration_events(aws_client:aws_client(), binary() | list(), map(), map()) ->
    {ok, list_data_integration_events_response(), tuple()} |
    {error, any()} |
    {error, list_data_integration_events_errors(), tuple()}.
list_data_integration_events(Client, InstanceId, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    list_data_integration_events(Client, InstanceId, QueryMap, HeadersMap, []).

-spec list_data_integration_events(aws_client:aws_client(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, list_data_integration_events_response(), tuple()} |
    {error, any()} |
    {error, list_data_integration_events_errors(), tuple()}.
list_data_integration_events(Client, InstanceId, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/api-data/data-integration/instance/", aws_util:encode_uri(InstanceId), "/data-integration-events"],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary}
               | Options2],

    Headers = [],

    Query0_ =
      [
        {<<"eventType">>, maps:get(<<"eventType">>, QueryMap, undefined)},
        {<<"maxResults">>, maps:get(<<"maxResults">>, QueryMap, undefined)},
        {<<"nextToken">>, maps:get(<<"nextToken">>, QueryMap, undefined)}
      ],
    Query_ = [H || {_, V} = H <- Query0_, V =/= undefined],

    request(Client, get, Path, Query_, Headers, undefined, Options, SuccessStatusCode).

%% @doc List flow executions.
-spec list_data_integration_flow_executions(aws_client:aws_client(), binary() | list(), binary() | list()) ->
    {ok, list_data_integration_flow_executions_response(), tuple()} |
    {error, any()} |
    {error, list_data_integration_flow_executions_errors(), tuple()}.
list_data_integration_flow_executions(Client, FlowName, InstanceId)
  when is_map(Client) ->
    list_data_integration_flow_executions(Client, FlowName, InstanceId, #{}, #{}).

-spec list_data_integration_flow_executions(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map()) ->
    {ok, list_data_integration_flow_executions_response(), tuple()} |
    {error, any()} |
    {error, list_data_integration_flow_executions_errors(), tuple()}.
list_data_integration_flow_executions(Client, FlowName, InstanceId, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    list_data_integration_flow_executions(Client, FlowName, InstanceId, QueryMap, HeadersMap, []).

-spec list_data_integration_flow_executions(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, list_data_integration_flow_executions_response(), tuple()} |
    {error, any()} |
    {error, list_data_integration_flow_executions_errors(), tuple()}.
list_data_integration_flow_executions(Client, FlowName, InstanceId, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/api-data/data-integration/instance/", aws_util:encode_uri(InstanceId), "/data-integration-flows/", aws_util:encode_uri(FlowName), "/executions"],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary}
               | Options2],

    Headers = [],

    Query0_ =
      [
        {<<"maxResults">>, maps:get(<<"maxResults">>, QueryMap, undefined)},
        {<<"nextToken">>, maps:get(<<"nextToken">>, QueryMap, undefined)}
      ],
    Query_ = [H || {_, V} = H <- Query0_, V =/= undefined],

    request(Client, get, Path, Query_, Headers, undefined, Options, SuccessStatusCode).

%% @doc Enables you to programmatically list all data pipelines for the
%% provided Amazon Web Services Supply Chain instance.
-spec list_data_integration_flows(aws_client:aws_client(), binary() | list()) ->
    {ok, list_data_integration_flows_response(), tuple()} |
    {error, any()} |
    {error, list_data_integration_flows_errors(), tuple()}.
list_data_integration_flows(Client, InstanceId)
  when is_map(Client) ->
    list_data_integration_flows(Client, InstanceId, #{}, #{}).

-spec list_data_integration_flows(aws_client:aws_client(), binary() | list(), map(), map()) ->
    {ok, list_data_integration_flows_response(), tuple()} |
    {error, any()} |
    {error, list_data_integration_flows_errors(), tuple()}.
list_data_integration_flows(Client, InstanceId, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    list_data_integration_flows(Client, InstanceId, QueryMap, HeadersMap, []).

-spec list_data_integration_flows(aws_client:aws_client(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, list_data_integration_flows_response(), tuple()} |
    {error, any()} |
    {error, list_data_integration_flows_errors(), tuple()}.
list_data_integration_flows(Client, InstanceId, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/api/data-integration/instance/", aws_util:encode_uri(InstanceId), "/data-integration-flows"],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary}
               | Options2],

    Headers = [],

    Query0_ =
      [
        {<<"maxResults">>, maps:get(<<"maxResults">>, QueryMap, undefined)},
        {<<"nextToken">>, maps:get(<<"nextToken">>, QueryMap, undefined)}
      ],
    Query_ = [H || {_, V} = H <- Query0_, V =/= undefined],

    request(Client, get, Path, Query_, Headers, undefined, Options, SuccessStatusCode).

%% @doc Enables you to programmatically view the list of Amazon Web Services
%% Supply Chain data lake datasets.
%%
%% Developers can view the datasets and the corresponding information such as
%% namespace, schema, and so on for a given instance ID and namespace.
-spec list_data_lake_datasets(aws_client:aws_client(), binary() | list(), binary() | list()) ->
    {ok, list_data_lake_datasets_response(), tuple()} |
    {error, any()} |
    {error, list_data_lake_datasets_errors(), tuple()}.
list_data_lake_datasets(Client, InstanceId, Namespace)
  when is_map(Client) ->
    list_data_lake_datasets(Client, InstanceId, Namespace, #{}, #{}).

-spec list_data_lake_datasets(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map()) ->
    {ok, list_data_lake_datasets_response(), tuple()} |
    {error, any()} |
    {error, list_data_lake_datasets_errors(), tuple()}.
list_data_lake_datasets(Client, InstanceId, Namespace, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    list_data_lake_datasets(Client, InstanceId, Namespace, QueryMap, HeadersMap, []).

-spec list_data_lake_datasets(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, list_data_lake_datasets_response(), tuple()} |
    {error, any()} |
    {error, list_data_lake_datasets_errors(), tuple()}.
list_data_lake_datasets(Client, InstanceId, Namespace, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/api/datalake/instance/", aws_util:encode_uri(InstanceId), "/namespaces/", aws_util:encode_uri(Namespace), "/datasets"],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary}
               | Options2],

    Headers = [],

    Query0_ =
      [
        {<<"maxResults">>, maps:get(<<"maxResults">>, QueryMap, undefined)},
        {<<"nextToken">>, maps:get(<<"nextToken">>, QueryMap, undefined)}
      ],
    Query_ = [H || {_, V} = H <- Query0_, V =/= undefined],

    request(Client, get, Path, Query_, Headers, undefined, Options, SuccessStatusCode).

%% @doc Enables you to programmatically view the list of Amazon Web Services
%% Supply Chain data lake namespaces.
%%
%% Developers can view the namespaces and the corresponding information such
%% as description for a given instance ID. Note that this API only return
%% custom namespaces, instance pre-defined namespaces are not included.
-spec list_data_lake_namespaces(aws_client:aws_client(), binary() | list()) ->
    {ok, list_data_lake_namespaces_response(), tuple()} |
    {error, any()} |
    {error, list_data_lake_namespaces_errors(), tuple()}.
list_data_lake_namespaces(Client, InstanceId)
  when is_map(Client) ->
    list_data_lake_namespaces(Client, InstanceId, #{}, #{}).

-spec list_data_lake_namespaces(aws_client:aws_client(), binary() | list(), map(), map()) ->
    {ok, list_data_lake_namespaces_response(), tuple()} |
    {error, any()} |
    {error, list_data_lake_namespaces_errors(), tuple()}.
list_data_lake_namespaces(Client, InstanceId, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    list_data_lake_namespaces(Client, InstanceId, QueryMap, HeadersMap, []).

-spec list_data_lake_namespaces(aws_client:aws_client(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, list_data_lake_namespaces_response(), tuple()} |
    {error, any()} |
    {error, list_data_lake_namespaces_errors(), tuple()}.
list_data_lake_namespaces(Client, InstanceId, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/api/datalake/instance/", aws_util:encode_uri(InstanceId), "/namespaces"],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary}
               | Options2],

    Headers = [],

    Query0_ =
      [
        {<<"maxResults">>, maps:get(<<"maxResults">>, QueryMap, undefined)},
        {<<"nextToken">>, maps:get(<<"nextToken">>, QueryMap, undefined)}
      ],
    Query_ = [H || {_, V} = H <- Query0_, V =/= undefined],

    request(Client, get, Path, Query_, Headers, undefined, Options, SuccessStatusCode).

%% @doc List all Amazon Web Services Supply Chain instances for a specific
%% account.
%%
%% Enables you to programmatically list all Amazon Web Services Supply Chain
%% instances based on their account ID, instance name, and state of the
%% instance (active or delete).
-spec list_instances(aws_client:aws_client()) ->
    {ok, list_instances_response(), tuple()} |
    {error, any()} |
    {error, list_instances_errors(), tuple()}.
list_instances(Client)
  when is_map(Client) ->
    list_instances(Client, #{}, #{}).

-spec list_instances(aws_client:aws_client(), map(), map()) ->
    {ok, list_instances_response(), tuple()} |
    {error, any()} |
    {error, list_instances_errors(), tuple()}.
list_instances(Client, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    list_instances(Client, QueryMap, HeadersMap, []).

-spec list_instances(aws_client:aws_client(), map(), map(), proplists:proplist()) ->
    {ok, list_instances_response(), tuple()} |
    {error, any()} |
    {error, list_instances_errors(), tuple()}.
list_instances(Client, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/api/instance"],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary}
               | Options2],

    Headers = [],

    Query0_ =
      [
        {<<"instanceNameFilter">>, maps:get(<<"instanceNameFilter">>, QueryMap, undefined)},
        {<<"instanceStateFilter">>, maps:get(<<"instanceStateFilter">>, QueryMap, undefined)},
        {<<"maxResults">>, maps:get(<<"maxResults">>, QueryMap, undefined)},
        {<<"nextToken">>, maps:get(<<"nextToken">>, QueryMap, undefined)}
      ],
    Query_ = [H || {_, V} = H <- Query0_, V =/= undefined],

    request(Client, get, Path, Query_, Headers, undefined, Options, SuccessStatusCode).

%% @doc List all the tags for an Amazon Web ServicesSupply Chain resource.
%%
%% You can list all the tags added to a resource. By listing the tags,
%% developers can view the tag level information on a resource and perform
%% actions such as, deleting a resource associated with a particular tag.
-spec list_tags_for_resource(aws_client:aws_client(), binary() | list()) ->
    {ok, list_tags_for_resource_response(), tuple()} |
    {error, any()} |
    {error, list_tags_for_resource_errors(), tuple()}.
list_tags_for_resource(Client, ResourceArn)
  when is_map(Client) ->
    list_tags_for_resource(Client, ResourceArn, #{}, #{}).

-spec list_tags_for_resource(aws_client:aws_client(), binary() | list(), map(), map()) ->
    {ok, list_tags_for_resource_response(), tuple()} |
    {error, any()} |
    {error, list_tags_for_resource_errors(), tuple()}.
list_tags_for_resource(Client, ResourceArn, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    list_tags_for_resource(Client, ResourceArn, QueryMap, HeadersMap, []).

-spec list_tags_for_resource(aws_client:aws_client(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, list_tags_for_resource_response(), tuple()} |
    {error, any()} |
    {error, list_tags_for_resource_errors(), tuple()}.
list_tags_for_resource(Client, ResourceArn, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/api/tags/", aws_util:encode_uri(ResourceArn), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary}
               | Options2],

    Headers = [],

    Query_ = [],

    request(Client, get, Path, Query_, Headers, undefined, Options, SuccessStatusCode).

%% @doc Send the data payload for the event with real-time data for analysis
%% or monitoring.
%%
%% The real-time data events are stored in an Amazon Web Services service
%% before being processed and stored in data lake.
-spec send_data_integration_event(aws_client:aws_client(), binary() | list(), send_data_integration_event_request()) ->
    {ok, send_data_integration_event_response(), tuple()} |
    {error, any()} |
    {error, send_data_integration_event_errors(), tuple()}.
send_data_integration_event(Client, InstanceId, Input) ->
    send_data_integration_event(Client, InstanceId, Input, []).

-spec send_data_integration_event(aws_client:aws_client(), binary() | list(), send_data_integration_event_request(), proplists:proplist()) ->
    {ok, send_data_integration_event_response(), tuple()} |
    {error, any()} |
    {error, send_data_integration_event_errors(), tuple()}.
send_data_integration_event(Client, InstanceId, Input0, Options0) ->
    Method = post,
    Path = ["/api-data/data-integration/instance/", aws_util:encode_uri(InstanceId), "/data-integration-events"],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary},
               {append_sha256_content_hash, false}
               | Options2],

    Headers = [],
    Input1 = Input0,

    CustomHeaders = [],
    Input2 = Input1,

    Query_ = [],
    Input = Input2,

    request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode).

%% @doc You can create tags during or after creating a resource such as
%% instance, data flow, or dataset in AWS Supply chain.
%%
%% During the data ingestion process, you can add tags such as dev, test, or
%% prod to data flows created during the data ingestion process in the AWS
%% Supply Chain datasets. You can use these tags to identify a group of
%% resources or a single resource used by the developer.
-spec tag_resource(aws_client:aws_client(), binary() | list(), tag_resource_request()) ->
    {ok, tag_resource_response(), tuple()} |
    {error, any()} |
    {error, tag_resource_errors(), tuple()}.
tag_resource(Client, ResourceArn, Input) ->
    tag_resource(Client, ResourceArn, Input, []).

-spec tag_resource(aws_client:aws_client(), binary() | list(), tag_resource_request(), proplists:proplist()) ->
    {ok, tag_resource_response(), tuple()} |
    {error, any()} |
    {error, tag_resource_errors(), tuple()}.
tag_resource(Client, ResourceArn, Input0, Options0) ->
    Method = post,
    Path = ["/api/tags/", aws_util:encode_uri(ResourceArn), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary},
               {append_sha256_content_hash, false}
               | Options2],

    Headers = [],
    Input1 = Input0,

    CustomHeaders = [],
    Input2 = Input1,

    Query_ = [],
    Input = Input2,

    request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode).

%% @doc You can delete tags for an Amazon Web Services Supply chain resource
%% such as instance, data flow, or dataset in AWS Supply Chain.
%%
%% During the data ingestion process, you can delete tags such as dev, test,
%% or prod to data flows created during the data ingestion process in the AWS
%% Supply Chain datasets.
-spec untag_resource(aws_client:aws_client(), binary() | list(), untag_resource_request()) ->
    {ok, untag_resource_response(), tuple()} |
    {error, any()} |
    {error, untag_resource_errors(), tuple()}.
untag_resource(Client, ResourceArn, Input) ->
    untag_resource(Client, ResourceArn, Input, []).

-spec untag_resource(aws_client:aws_client(), binary() | list(), untag_resource_request(), proplists:proplist()) ->
    {ok, untag_resource_response(), tuple()} |
    {error, any()} |
    {error, untag_resource_errors(), tuple()}.
untag_resource(Client, ResourceArn, Input0, Options0) ->
    Method = delete,
    Path = ["/api/tags/", aws_util:encode_uri(ResourceArn), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary},
               {append_sha256_content_hash, false}
               | Options2],

    Headers = [],
    Input1 = Input0,

    CustomHeaders = [],
    Input2 = Input1,

    QueryMapping = [
                     {<<"tagKeys">>, <<"tagKeys">>}
                   ],
    {Query_, Input} = aws_request:build_headers(QueryMapping, Input2),
    request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode).

%% @doc Enables you to programmatically update an existing data pipeline to
%% ingest data from the source systems such as, Amazon S3 buckets, to a
%% predefined Amazon Web Services Supply Chain dataset (product,
%% inbound_order) or a temporary dataset along with the data transformation
%% query provided with the API.
-spec update_data_integration_flow(aws_client:aws_client(), binary() | list(), binary() | list(), update_data_integration_flow_request()) ->
    {ok, update_data_integration_flow_response(), tuple()} |
    {error, any()} |
    {error, update_data_integration_flow_errors(), tuple()}.
update_data_integration_flow(Client, InstanceId, Name, Input) ->
    update_data_integration_flow(Client, InstanceId, Name, Input, []).

-spec update_data_integration_flow(aws_client:aws_client(), binary() | list(), binary() | list(), update_data_integration_flow_request(), proplists:proplist()) ->
    {ok, update_data_integration_flow_response(), tuple()} |
    {error, any()} |
    {error, update_data_integration_flow_errors(), tuple()}.
update_data_integration_flow(Client, InstanceId, Name, Input0, Options0) ->
    Method = patch,
    Path = ["/api/data-integration/instance/", aws_util:encode_uri(InstanceId), "/data-integration-flows/", aws_util:encode_uri(Name), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary},
               {append_sha256_content_hash, false}
               | Options2],

    Headers = [],
    Input1 = Input0,

    CustomHeaders = [],
    Input2 = Input1,

    Query_ = [],
    Input = Input2,

    request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode).

%% @doc Enables you to programmatically update an Amazon Web Services Supply
%% Chain data lake dataset.
%%
%% Developers can update the description of a data lake dataset for a given
%% instance ID, namespace, and dataset name.
-spec update_data_lake_dataset(aws_client:aws_client(), binary() | list(), binary() | list(), binary() | list(), update_data_lake_dataset_request()) ->
    {ok, update_data_lake_dataset_response(), tuple()} |
    {error, any()} |
    {error, update_data_lake_dataset_errors(), tuple()}.
update_data_lake_dataset(Client, InstanceId, Name, Namespace, Input) ->
    update_data_lake_dataset(Client, InstanceId, Name, Namespace, Input, []).

-spec update_data_lake_dataset(aws_client:aws_client(), binary() | list(), binary() | list(), binary() | list(), update_data_lake_dataset_request(), proplists:proplist()) ->
    {ok, update_data_lake_dataset_response(), tuple()} |
    {error, any()} |
    {error, update_data_lake_dataset_errors(), tuple()}.
update_data_lake_dataset(Client, InstanceId, Name, Namespace, Input0, Options0) ->
    Method = patch,
    Path = ["/api/datalake/instance/", aws_util:encode_uri(InstanceId), "/namespaces/", aws_util:encode_uri(Namespace), "/datasets/", aws_util:encode_uri(Name), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary},
               {append_sha256_content_hash, false}
               | Options2],

    Headers = [],
    Input1 = Input0,

    CustomHeaders = [],
    Input2 = Input1,

    Query_ = [],
    Input = Input2,

    request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode).

%% @doc Enables you to programmatically update an Amazon Web Services Supply
%% Chain data lake namespace.
%%
%% Developers can update the description of a data lake namespace for a given
%% instance ID and namespace name.
-spec update_data_lake_namespace(aws_client:aws_client(), binary() | list(), binary() | list(), update_data_lake_namespace_request()) ->
    {ok, update_data_lake_namespace_response(), tuple()} |
    {error, any()} |
    {error, update_data_lake_namespace_errors(), tuple()}.
update_data_lake_namespace(Client, InstanceId, Name, Input) ->
    update_data_lake_namespace(Client, InstanceId, Name, Input, []).

-spec update_data_lake_namespace(aws_client:aws_client(), binary() | list(), binary() | list(), update_data_lake_namespace_request(), proplists:proplist()) ->
    {ok, update_data_lake_namespace_response(), tuple()} |
    {error, any()} |
    {error, update_data_lake_namespace_errors(), tuple()}.
update_data_lake_namespace(Client, InstanceId, Name, Input0, Options0) ->
    Method = patch,
    Path = ["/api/datalake/instance/", aws_util:encode_uri(InstanceId), "/namespaces/", aws_util:encode_uri(Name), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary},
               {append_sha256_content_hash, false}
               | Options2],

    Headers = [],
    Input1 = Input0,

    CustomHeaders = [],
    Input2 = Input1,

    Query_ = [],
    Input = Input2,

    request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode).

%% @doc Enables you to programmatically update an Amazon Web Services Supply
%% Chain instance description by providing all the relevant information such
%% as account ID, instance ID and so on without using the AWS console.
-spec update_instance(aws_client:aws_client(), binary() | list(), update_instance_request()) ->
    {ok, update_instance_response(), tuple()} |
    {error, any()} |
    {error, update_instance_errors(), tuple()}.
update_instance(Client, InstanceId, Input) ->
    update_instance(Client, InstanceId, Input, []).

-spec update_instance(aws_client:aws_client(), binary() | list(), update_instance_request(), proplists:proplist()) ->
    {ok, update_instance_response(), tuple()} |
    {error, any()} |
    {error, update_instance_errors(), tuple()}.
update_instance(Client, InstanceId, Input0, Options0) ->
    Method = patch,
    Path = ["/api/instance/", aws_util:encode_uri(InstanceId), ""],
    SuccessStatusCode = 200,
    {SendBodyAsBinary, Options1} = proplists_take(send_body_as_binary, Options0, false),
    {ReceiveBodyAsBinary, Options2} = proplists_take(receive_body_as_binary, Options1, false),
    Options = [{send_body_as_binary, SendBodyAsBinary},
               {receive_body_as_binary, ReceiveBodyAsBinary},
               {append_sha256_content_hash, false}
               | Options2],

    Headers = [],
    Input1 = Input0,

    CustomHeaders = [],
    Input2 = Input1,

    Query_ = [],
    Input = Input2,

    request(Client, Method, Path, Query_, CustomHeaders ++ Headers, Input, Options, SuccessStatusCode).

%%====================================================================
%% Internal functions
%%====================================================================

-spec proplists_take(any(), proplists:proplist(), any()) -> {any(), proplists:proplist()}.
proplists_take(Key, Proplist, Default) ->
  Value = proplists:get_value(Key, Proplist, Default),
  {Value, proplists:delete(Key, Proplist)}.

-spec request(aws_client:aws_client(), atom(), iolist(), list(),
              list(), map() | undefined, list(), pos_integer() | undefined) ->
    {ok, {integer(), list()}} |
    {ok, Result, {integer(), list(), hackney:client()}} |
    {error, Error, {integer(), list(), hackney:client()}} |
    {error, term()} when
    Result :: map(),
    Error :: map().
request(Client, Method, Path, Query, Headers0, Input, Options, SuccessStatusCode) ->
  RequestFun = fun() -> do_request(Client, Method, Path, Query, Headers0, Input, Options, SuccessStatusCode) end,
  aws_request:request(RequestFun, Options).

do_request(Client, Method, Path, Query, Headers0, Input, Options, SuccessStatusCode) ->
    Client1 = Client#{service => <<"scn">>},
    DefaultHost = build_host(<<"scn">>, Client1),
    URL0 = build_url(DefaultHost, Path, Client1),
    PathBin = erlang:iolist_to_binary(Path),
    {URL1, Host} = aws_util:apply_endpoint_url_override(URL0, DefaultHost, PathBin, <<"AWS_ENDPOINT_URL_SUPPLYCHAIN">>),
    URL = aws_request:add_query(URL1, Query),
    AdditionalHeaders1 = [ {<<"Host">>, Host}
                         , {<<"Content-Type">>, <<"application/x-amz-json-1.1">>}
                         ],
    Payload =
      case proplists:get_value(send_body_as_binary, Options) of
         true when is_list(Input) ->
           proplists:get_value(<<"Body">>, Input, <<"">>);
         true when Input =:= undefined ->
           <<"">>;
         true ->
           maps:get(<<"Body">>, Input, <<"">>);
        false ->
          encode_payload(Input)
      end,
    AdditionalHeaders = case proplists:get_value(append_sha256_content_hash, Options, false) of
                          true ->
                            add_checksum_hash_header(AdditionalHeaders1, Payload);
                          false ->
                            AdditionalHeaders1
                        end,
    Headers1 = aws_request:add_headers(AdditionalHeaders, Headers0),

    MethodBin = aws_request:method_to_binary(Method),
    SignedHeaders = aws_request:sign_request(Client1, MethodBin, URL, Headers1, Payload),
    Response = hackney:request(Method, URL, SignedHeaders, Payload, Options),
    DecodeBody = not proplists:get_value(receive_body_as_binary, Options),
    handle_response(Response, SuccessStatusCode, DecodeBody).

add_checksum_hash_header(Headers, Body) ->
  [ {<<"X-Amz-CheckSum-SHA256">>, base64:encode(crypto:hash(sha256, Body))}
  | Headers
  ].

handle_response({ok, StatusCode, ResponseHeaders}, SuccessStatusCode, _DecodeBody)
  when StatusCode =:= 200;
       StatusCode =:= 202;
       StatusCode =:= 204;
       StatusCode =:= 206;
       StatusCode =:= SuccessStatusCode ->
    {ok, {StatusCode, ResponseHeaders}};
handle_response({ok, StatusCode, ResponseHeaders}, _, _DecodeBody) ->
    {error, {StatusCode, ResponseHeaders}};
handle_response({ok, StatusCode, ResponseHeaders, Client}, SuccessStatusCode, DecodeBody)
  when StatusCode =:= 200;
       StatusCode =:= 202;
       StatusCode =:= 204;
       StatusCode =:= 206;
       StatusCode =:= SuccessStatusCode ->
    case hackney:body(Client) of
        {ok, <<>>} when StatusCode =:= 200;
                        StatusCode =:= SuccessStatusCode ->
            {ok, #{}, {StatusCode, ResponseHeaders, Client}};
        {ok, Body} ->
            Result = case DecodeBody of
                       true ->
                         try
                           jsx:decode(Body)
                         catch
                           Error:Reason:Stack ->
                             erlang:raise(error, {body_decode_failed, Error, Reason, StatusCode, Body}, Stack)
                         end;
                       false -> #{<<"Body">> => Body}
                     end,
            {ok, Result, {StatusCode, ResponseHeaders, Client}}
    end;
handle_response({ok, StatusCode, _ResponseHeaders, _Client}, _, _DecodeBody)
  when StatusCode =:= 503 ->
  %% Retriable error if retries are enabled
  {error, service_unavailable};
handle_response({ok, StatusCode, ResponseHeaders, Client}, _, _DecodeBody) ->
    {ok, Body} = hackney:body(Client),
    try
      DecodedError = jsx:decode(Body),
      {error, DecodedError, {StatusCode, ResponseHeaders, Client}}
    catch
      Error:Reason:Stack ->
        erlang:raise(error, {body_decode_failed, Error, Reason, StatusCode, Body}, Stack)
    end;
handle_response({error, Reason}, _, _DecodeBody) ->
  {error, Reason}.

build_host(_EndpointPrefix, #{region := <<"local">>, endpoint := Endpoint}) ->
    Endpoint;
build_host(_EndpointPrefix, #{region := <<"local">>}) ->
    <<"localhost">>;
build_host(EndpointPrefix, #{region := Region, endpoint := Endpoint}) ->
    aws_util:binary_join([EndpointPrefix, Region, Endpoint], <<".">>).

build_url(Host, Path0, Client) ->
    Proto = aws_client:proto(Client),
    Path = erlang:iolist_to_binary(Path0),
    Port = aws_client:port(Client),
    aws_util:binary_join([Proto, <<"://">>, Host, <<":">>, Port, Path], <<"">>).

-spec encode_payload(undefined | map()) -> binary().
encode_payload(undefined) ->
  <<>>;
encode_payload(Input) ->
  jsx:encode(Input).