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

%% @doc Welcome to the Entity Resolution API Reference.
%%
%% Entity Resolution is an Amazon Web Services service that provides
%% pre-configured entity
%% resolution capabilities that enable developers and analysts at advertising
%% and marketing
%% companies to build an accurate and complete view of their consumers.
%%
%% With Entity Resolution, you can match source records containing consumer
%% identifiers,
%% such as name, email address, and phone number. This is true even when
%% these records have
%% incomplete or conflicting identifiers. For example, Entity Resolution can
%% effectively match
%% a source record from a customer relationship management (CRM) system with
%% a source record
%% from a marketing system containing campaign information.
%%
%% To learn more about Entity Resolution concepts, procedures, and best
%% practices, see the
%% Entity Resolution User Guide:
%% https://docs.aws.amazon.com/entityresolution/latest/userguide/what-is-service.html.
-module(aws_entityresolution).

-export([add_policy_statement/4,
         add_policy_statement/5,
         batch_delete_unique_id/3,
         batch_delete_unique_id/4,
         create_id_mapping_workflow/2,
         create_id_mapping_workflow/3,
         create_id_namespace/2,
         create_id_namespace/3,
         create_matching_workflow/2,
         create_matching_workflow/3,
         create_schema_mapping/2,
         create_schema_mapping/3,
         delete_id_mapping_workflow/3,
         delete_id_mapping_workflow/4,
         delete_id_namespace/3,
         delete_id_namespace/4,
         delete_matching_workflow/3,
         delete_matching_workflow/4,
         delete_policy_statement/4,
         delete_policy_statement/5,
         delete_schema_mapping/3,
         delete_schema_mapping/4,
         get_id_mapping_job/3,
         get_id_mapping_job/5,
         get_id_mapping_job/6,
         get_id_mapping_workflow/2,
         get_id_mapping_workflow/4,
         get_id_mapping_workflow/5,
         get_id_namespace/2,
         get_id_namespace/4,
         get_id_namespace/5,
         get_match_id/3,
         get_match_id/4,
         get_matching_job/3,
         get_matching_job/5,
         get_matching_job/6,
         get_matching_workflow/2,
         get_matching_workflow/4,
         get_matching_workflow/5,
         get_policy/2,
         get_policy/4,
         get_policy/5,
         get_provider_service/3,
         get_provider_service/5,
         get_provider_service/6,
         get_schema_mapping/2,
         get_schema_mapping/4,
         get_schema_mapping/5,
         list_id_mapping_jobs/2,
         list_id_mapping_jobs/4,
         list_id_mapping_jobs/5,
         list_id_mapping_workflows/1,
         list_id_mapping_workflows/3,
         list_id_mapping_workflows/4,
         list_id_namespaces/1,
         list_id_namespaces/3,
         list_id_namespaces/4,
         list_matching_jobs/2,
         list_matching_jobs/4,
         list_matching_jobs/5,
         list_matching_workflows/1,
         list_matching_workflows/3,
         list_matching_workflows/4,
         list_provider_services/1,
         list_provider_services/3,
         list_provider_services/4,
         list_schema_mappings/1,
         list_schema_mappings/3,
         list_schema_mappings/4,
         list_tags_for_resource/2,
         list_tags_for_resource/4,
         list_tags_for_resource/5,
         put_policy/3,
         put_policy/4,
         start_id_mapping_job/3,
         start_id_mapping_job/4,
         start_matching_job/3,
         start_matching_job/4,
         tag_resource/3,
         tag_resource/4,
         untag_resource/3,
         untag_resource/4,
         update_id_mapping_workflow/3,
         update_id_mapping_workflow/4,
         update_id_namespace/3,
         update_id_namespace/4,
         update_matching_workflow/3,
         update_matching_workflow/4,
         update_schema_mapping/3,
         update_schema_mapping/4]).

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


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


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

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


%% Example:
%% id_mapping_techniques() :: #{
%%   <<"idMappingType">> => list(any()),
%%   <<"providerProperties">> => provider_properties(),
%%   <<"ruleBasedProperties">> => id_mapping_rule_based_properties()
%% }
-type id_mapping_techniques() :: #{binary() => any()}.


%% Example:
%% input_source() :: #{
%%   <<"applyNormalization">> => [boolean()],
%%   <<"inputSourceARN">> => [string()],
%%   <<"schemaName">> => string()
%% }
-type input_source() :: #{binary() => any()}.

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


%% Example:
%% get_match_id_output() :: #{
%%   <<"matchId">> => [string()],
%%   <<"matchRule">> => [string()]
%% }
-type get_match_id_output() :: #{binary() => any()}.


%% Example:
%% resolution_techniques() :: #{
%%   <<"providerProperties">> => provider_properties(),
%%   <<"resolutionType">> => list(any()),
%%   <<"ruleBasedProperties">> => rule_based_properties()
%% }
-type resolution_techniques() :: #{binary() => any()}.


%% Example:
%% update_schema_mapping_output() :: #{
%%   <<"description">> => string(),
%%   <<"mappedInputFields">> => list(schema_input_attribute()()),
%%   <<"schemaArn">> => string(),
%%   <<"schemaName">> => string()
%% }
-type update_schema_mapping_output() :: #{binary() => any()}.


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


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


%% Example:
%% add_policy_statement_input() :: #{
%%   <<"action">> := list(string()()),
%%   <<"condition">> => string(),
%%   <<"effect">> := list(any()),
%%   <<"principal">> := list(string()())
%% }
-type add_policy_statement_input() :: #{binary() => any()}.


%% Example:
%% update_schema_mapping_input() :: #{
%%   <<"description">> => string(),
%%   <<"mappedInputFields">> := list(schema_input_attribute()())
%% }
-type update_schema_mapping_input() :: #{binary() => any()}.

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


%% Example:
%% update_matching_workflow_input() :: #{
%%   <<"description">> => string(),
%%   <<"incrementalRunConfig">> => incremental_run_config(),
%%   <<"inputSourceConfig">> := list(input_source()()),
%%   <<"outputSourceConfig">> := list(output_source()()),
%%   <<"resolutionTechniques">> := resolution_techniques(),
%%   <<"roleArn">> := [string()]
%% }
-type update_matching_workflow_input() :: #{binary() => any()}.


%% Example:
%% provider_service_summary() :: #{
%%   <<"providerName">> => string(),
%%   <<"providerServiceArn">> => string(),
%%   <<"providerServiceDisplayName">> => string(),
%%   <<"providerServiceName">> => string(),
%%   <<"providerServiceType">> => list(any())
%% }
-type provider_service_summary() :: #{binary() => any()}.


%% Example:
%% list_schema_mappings_output() :: #{
%%   <<"nextToken">> => string(),
%%   <<"schemaList">> => list(schema_mapping_summary()())
%% }
-type list_schema_mappings_output() :: #{binary() => any()}.


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


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


%% Example:
%% exceeds_limit_exception() :: #{
%%   <<"message">> => string(),
%%   <<"quotaName">> => [string()],
%%   <<"quotaValue">> => [integer()]
%% }
-type exceeds_limit_exception() :: #{binary() => any()}.

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


%% Example:
%% put_policy_input() :: #{
%%   <<"policy">> := string(),
%%   <<"token">> => string()
%% }
-type put_policy_input() :: #{binary() => any()}.


%% Example:
%% put_policy_output() :: #{
%%   <<"arn">> => string(),
%%   <<"policy">> => string(),
%%   <<"token">> => string()
%% }
-type put_policy_output() :: #{binary() => any()}.


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

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


%% Example:
%% list_id_namespaces_output() :: #{
%%   <<"idNamespaceSummaries">> => list(id_namespace_summary()()),
%%   <<"nextToken">> => string()
%% }
-type list_id_namespaces_output() :: #{binary() => any()}.


%% Example:
%% id_namespace_id_mapping_workflow_properties() :: #{
%%   <<"idMappingType">> => list(any()),
%%   <<"providerProperties">> => namespace_provider_properties(),
%%   <<"ruleBasedProperties">> => namespace_rule_based_properties()
%% }
-type id_namespace_id_mapping_workflow_properties() :: #{binary() => any()}.


%% Example:
%% create_schema_mapping_output() :: #{
%%   <<"description">> => string(),
%%   <<"mappedInputFields">> => list(schema_input_attribute()()),
%%   <<"schemaArn">> => string(),
%%   <<"schemaName">> => string()
%% }
-type create_schema_mapping_output() :: #{binary() => any()}.


%% Example:
%% update_matching_workflow_output() :: #{
%%   <<"description">> => string(),
%%   <<"incrementalRunConfig">> => incremental_run_config(),
%%   <<"inputSourceConfig">> => list(input_source()()),
%%   <<"outputSourceConfig">> => list(output_source()()),
%%   <<"resolutionTechniques">> => resolution_techniques(),
%%   <<"roleArn">> => [string()],
%%   <<"workflowName">> => string()
%% }
-type update_matching_workflow_output() :: #{binary() => any()}.


%% Example:
%% list_id_mapping_jobs_output() :: #{
%%   <<"jobs">> => list(job_summary()()),
%%   <<"nextToken">> => string()
%% }
-type list_id_mapping_jobs_output() :: #{binary() => any()}.


%% Example:
%% job_metrics() :: #{
%%   <<"inputRecords">> => [integer()],
%%   <<"matchIDs">> => [integer()],
%%   <<"recordsNotProcessed">> => [integer()],
%%   <<"totalRecordsProcessed">> => [integer()]
%% }
-type job_metrics() :: #{binary() => any()}.


%% Example:
%% get_id_mapping_workflow_output() :: #{
%%   <<"createdAt">> => [non_neg_integer()],
%%   <<"description">> => string(),
%%   <<"idMappingTechniques">> => id_mapping_techniques(),
%%   <<"inputSourceConfig">> => list(id_mapping_workflow_input_source()()),
%%   <<"outputSourceConfig">> => list(id_mapping_workflow_output_source()()),
%%   <<"roleArn">> => string(),
%%   <<"tags">> => map(),
%%   <<"updatedAt">> => [non_neg_integer()],
%%   <<"workflowArn">> => string(),
%%   <<"workflowName">> => string()
%% }
-type get_id_mapping_workflow_output() :: #{binary() => any()}.


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


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


%% Example:
%% get_schema_mapping_output() :: #{
%%   <<"createdAt">> => [non_neg_integer()],
%%   <<"description">> => string(),
%%   <<"hasWorkflows">> => [boolean()],
%%   <<"mappedInputFields">> => list(schema_input_attribute()()),
%%   <<"schemaArn">> => string(),
%%   <<"schemaName">> => string(),
%%   <<"tags">> => map(),
%%   <<"updatedAt">> => [non_neg_integer()]
%% }
-type get_schema_mapping_output() :: #{binary() => any()}.


%% Example:
%% namespace_rule_based_properties() :: #{
%%   <<"attributeMatchingModel">> => list(any()),
%%   <<"recordMatchingModels">> => list(list(any())()),
%%   <<"ruleDefinitionTypes">> => list(list(any())()),
%%   <<"rules">> => list(rule()())
%% }
-type namespace_rule_based_properties() :: #{binary() => any()}.


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


%% Example:
%% id_mapping_workflow_output_source() :: #{
%%   <<"KMSArn">> => string(),
%%   <<"outputS3Path">> => string()
%% }
-type id_mapping_workflow_output_source() :: #{binary() => any()}.


%% Example:
%% create_matching_workflow_output() :: #{
%%   <<"description">> => string(),
%%   <<"incrementalRunConfig">> => incremental_run_config(),
%%   <<"inputSourceConfig">> => list(input_source()()),
%%   <<"outputSourceConfig">> => list(output_source()()),
%%   <<"resolutionTechniques">> => resolution_techniques(),
%%   <<"roleArn">> => [string()],
%%   <<"workflowArn">> => string(),
%%   <<"workflowName">> => string()
%% }
-type create_matching_workflow_output() :: #{binary() => any()}.


%% Example:
%% job_summary() :: #{
%%   <<"endTime">> => [non_neg_integer()],
%%   <<"jobId">> => string(),
%%   <<"startTime">> => [non_neg_integer()],
%%   <<"status">> => list(any())
%% }
-type job_summary() :: #{binary() => any()}.


%% Example:
%% namespace_provider_properties() :: #{
%%   <<"providerConfiguration">> => [any()],
%%   <<"providerServiceArn">> => string()
%% }
-type namespace_provider_properties() :: #{binary() => any()}.


%% Example:
%% batch_delete_unique_id_output() :: #{
%%   <<"deleted">> => list(deleted_unique_id()()),
%%   <<"disconnectedUniqueIds">> => list(string()()),
%%   <<"errors">> => list(delete_unique_id_error()()),
%%   <<"status">> => list(any())
%% }
-type batch_delete_unique_id_output() :: #{binary() => any()}.

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


%% Example:
%% job_output_source() :: #{
%%   <<"KMSArn">> => string(),
%%   <<"outputS3Path">> => string(),
%%   <<"roleArn">> => string()
%% }
-type job_output_source() :: #{binary() => any()}.


%% Example:
%% provider_id_name_space_configuration() :: #{
%%   <<"description">> => [string()],
%%   <<"providerSourceConfigurationDefinition">> => [any()],
%%   <<"providerTargetConfigurationDefinition">> => [any()]
%% }
-type provider_id_name_space_configuration() :: #{binary() => any()}.


%% Example:
%% batch_delete_unique_id_input() :: #{
%%   <<"inputSource">> => [string()],
%%   <<"uniqueIds">> := list(string()())
%% }
-type batch_delete_unique_id_input() :: #{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:
%% intermediate_source_configuration() :: #{
%%   <<"intermediateS3Path">> => string()
%% }
-type intermediate_source_configuration() :: #{binary() => any()}.

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


%% Example:
%% list_id_mapping_workflows_output() :: #{
%%   <<"nextToken">> => string(),
%%   <<"workflowSummaries">> => list(id_mapping_workflow_summary()())
%% }
-type list_id_mapping_workflows_output() :: #{binary() => any()}.


%% Example:
%% id_mapping_job_metrics() :: #{
%%   <<"inputRecords">> => [integer()],
%%   <<"recordsNotProcessed">> => [integer()],
%%   <<"totalMappedRecords">> => [integer()],
%%   <<"totalMappedSourceRecords">> => [integer()],
%%   <<"totalMappedTargetRecords">> => [integer()],
%%   <<"totalRecordsProcessed">> => [integer()]
%% }
-type id_mapping_job_metrics() :: #{binary() => any()}.


%% Example:
%% create_id_mapping_workflow_input() :: #{
%%   <<"description">> => string(),
%%   <<"idMappingTechniques">> := id_mapping_techniques(),
%%   <<"inputSourceConfig">> := list(id_mapping_workflow_input_source()()),
%%   <<"outputSourceConfig">> => list(id_mapping_workflow_output_source()()),
%%   <<"roleArn">> => string(),
%%   <<"tags">> => map(),
%%   <<"workflowName">> := string()
%% }
-type create_id_mapping_workflow_input() :: #{binary() => any()}.


%% Example:
%% list_matching_workflows_output() :: #{
%%   <<"nextToken">> => string(),
%%   <<"workflowSummaries">> => list(matching_workflow_summary()())
%% }
-type list_matching_workflows_output() :: #{binary() => any()}.


%% Example:
%% create_matching_workflow_input() :: #{
%%   <<"description">> => string(),
%%   <<"incrementalRunConfig">> => incremental_run_config(),
%%   <<"inputSourceConfig">> := list(input_source()()),
%%   <<"outputSourceConfig">> := list(output_source()()),
%%   <<"resolutionTechniques">> := resolution_techniques(),
%%   <<"roleArn">> := [string()],
%%   <<"tags">> => map(),
%%   <<"workflowName">> := string()
%% }
-type create_matching_workflow_input() :: #{binary() => any()}.


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


%% Example:
%% matching_workflow_summary() :: #{
%%   <<"createdAt">> => [non_neg_integer()],
%%   <<"resolutionType">> => list(any()),
%%   <<"updatedAt">> => [non_neg_integer()],
%%   <<"workflowArn">> => string(),
%%   <<"workflowName">> => string()
%% }
-type matching_workflow_summary() :: #{binary() => any()}.


%% Example:
%% get_id_mapping_job_output() :: #{
%%   <<"endTime">> => [non_neg_integer()],
%%   <<"errorDetails">> => error_details(),
%%   <<"jobId">> => string(),
%%   <<"metrics">> => id_mapping_job_metrics(),
%%   <<"outputSourceConfig">> => list(id_mapping_job_output_source()()),
%%   <<"startTime">> => [non_neg_integer()],
%%   <<"status">> => list(any())
%% }
-type get_id_mapping_job_output() :: #{binary() => any()}.


%% Example:
%% provider_schema_attribute() :: #{
%%   <<"fieldName">> => string(),
%%   <<"hashing">> => [boolean()],
%%   <<"subType">> => string(),
%%   <<"type">> => list(any())
%% }
-type provider_schema_attribute() :: #{binary() => any()}.


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


%% Example:
%% update_id_mapping_workflow_output() :: #{
%%   <<"description">> => string(),
%%   <<"idMappingTechniques">> => id_mapping_techniques(),
%%   <<"inputSourceConfig">> => list(id_mapping_workflow_input_source()()),
%%   <<"outputSourceConfig">> => list(id_mapping_workflow_output_source()()),
%%   <<"roleArn">> => string(),
%%   <<"workflowArn">> => string(),
%%   <<"workflowName">> => string()
%% }
-type update_id_mapping_workflow_output() :: #{binary() => any()}.

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


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


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


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

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

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


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


%% Example:
%% delete_policy_statement_output() :: #{
%%   <<"arn">> => string(),
%%   <<"policy">> => string(),
%%   <<"token">> => string()
%% }
-type delete_policy_statement_output() :: #{binary() => any()}.


%% Example:
%% rule() :: #{
%%   <<"matchingKeys">> => list(string()()),
%%   <<"ruleName">> => [string()]
%% }
-type rule() :: #{binary() => any()}.


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

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


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


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


%% Example:
%% create_id_mapping_workflow_output() :: #{
%%   <<"description">> => string(),
%%   <<"idMappingTechniques">> => id_mapping_techniques(),
%%   <<"inputSourceConfig">> => list(id_mapping_workflow_input_source()()),
%%   <<"outputSourceConfig">> => list(id_mapping_workflow_output_source()()),
%%   <<"roleArn">> => string(),
%%   <<"workflowArn">> => string(),
%%   <<"workflowName">> => string()
%% }
-type create_id_mapping_workflow_output() :: #{binary() => any()}.


%% Example:
%% update_id_mapping_workflow_input() :: #{
%%   <<"description">> => string(),
%%   <<"idMappingTechniques">> := id_mapping_techniques(),
%%   <<"inputSourceConfig">> := list(id_mapping_workflow_input_source()()),
%%   <<"outputSourceConfig">> => list(id_mapping_workflow_output_source()()),
%%   <<"roleArn">> => string()
%% }
-type update_id_mapping_workflow_input() :: #{binary() => any()}.


%% Example:
%% schema_mapping_summary() :: #{
%%   <<"createdAt">> => [non_neg_integer()],
%%   <<"hasWorkflows">> => [boolean()],
%%   <<"schemaArn">> => string(),
%%   <<"schemaName">> => string(),
%%   <<"updatedAt">> => [non_neg_integer()]
%% }
-type schema_mapping_summary() :: #{binary() => any()}.


%% Example:
%% get_id_namespace_output() :: #{
%%   <<"createdAt">> => [non_neg_integer()],
%%   <<"description">> => string(),
%%   <<"idMappingWorkflowProperties">> => list(id_namespace_id_mapping_workflow_properties()()),
%%   <<"idNamespaceArn">> => string(),
%%   <<"idNamespaceName">> => string(),
%%   <<"inputSourceConfig">> => list(id_namespace_input_source()()),
%%   <<"roleArn">> => string(),
%%   <<"tags">> => map(),
%%   <<"type">> => list(any()),
%%   <<"updatedAt">> => [non_neg_integer()]
%% }
-type get_id_namespace_output() :: #{binary() => any()}.


%% Example:
%% create_schema_mapping_input() :: #{
%%   <<"description">> => string(),
%%   <<"mappedInputFields">> := list(schema_input_attribute()()),
%%   <<"schemaName">> := string(),
%%   <<"tags">> => map()
%% }
-type create_schema_mapping_input() :: #{binary() => any()}.


%% Example:
%% create_id_namespace_input() :: #{
%%   <<"description">> => string(),
%%   <<"idMappingWorkflowProperties">> => list(id_namespace_id_mapping_workflow_properties()()),
%%   <<"idNamespaceName">> := string(),
%%   <<"inputSourceConfig">> => list(id_namespace_input_source()()),
%%   <<"roleArn">> => string(),
%%   <<"tags">> => map(),
%%   <<"type">> := list(any())
%% }
-type create_id_namespace_input() :: #{binary() => any()}.


%% Example:
%% provider_intermediate_data_access_configuration() :: #{
%%   <<"awsAccountIds">> => list(string()()),
%%   <<"requiredBucketActions">> => list([string()]())
%% }
-type provider_intermediate_data_access_configuration() :: #{binary() => any()}.


%% Example:
%% delete_unique_id_error() :: #{
%%   <<"errorType">> => list(any()),
%%   <<"uniqueId">> => string()
%% }
-type delete_unique_id_error() :: #{binary() => any()}.


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


%% Example:
%% update_id_namespace_input() :: #{
%%   <<"description">> => string(),
%%   <<"idMappingWorkflowProperties">> => list(id_namespace_id_mapping_workflow_properties()()),
%%   <<"inputSourceConfig">> => list(id_namespace_input_source()()),
%%   <<"roleArn">> => string()
%% }
-type update_id_namespace_input() :: #{binary() => any()}.


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

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

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


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


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

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


%% Example:
%% get_provider_service_output() :: #{
%%   <<"anonymizedOutput">> => [boolean()],
%%   <<"providerComponentSchema">> => provider_component_schema(),
%%   <<"providerConfigurationDefinition">> => [any()],
%%   <<"providerEndpointConfiguration">> => list(),
%%   <<"providerEntityOutputDefinition">> => [any()],
%%   <<"providerIdNameSpaceConfiguration">> => provider_id_name_space_configuration(),
%%   <<"providerIntermediateDataAccessConfiguration">> => provider_intermediate_data_access_configuration(),
%%   <<"providerJobConfiguration">> => [any()],
%%   <<"providerName">> => string(),
%%   <<"providerServiceArn">> => string(),
%%   <<"providerServiceDisplayName">> => string(),
%%   <<"providerServiceName">> => string(),
%%   <<"providerServiceType">> => list(any())
%% }
-type get_provider_service_output() :: #{binary() => any()}.

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


%% Example:
%% add_policy_statement_output() :: #{
%%   <<"arn">> => string(),
%%   <<"policy">> => string(),
%%   <<"token">> => string()
%% }
-type add_policy_statement_output() :: #{binary() => any()}.


%% Example:
%% id_mapping_workflow_summary() :: #{
%%   <<"createdAt">> => [non_neg_integer()],
%%   <<"updatedAt">> => [non_neg_integer()],
%%   <<"workflowArn">> => string(),
%%   <<"workflowName">> => string()
%% }
-type id_mapping_workflow_summary() :: #{binary() => any()}.


%% Example:
%% output_source() :: #{
%%   <<"KMSArn">> => string(),
%%   <<"applyNormalization">> => [boolean()],
%%   <<"output">> => list(output_attribute()()),
%%   <<"outputS3Path">> => string()
%% }
-type output_source() :: #{binary() => any()}.


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


%% Example:
%% provider_properties() :: #{
%%   <<"intermediateSourceConfiguration">> => intermediate_source_configuration(),
%%   <<"providerConfiguration">> => [any()],
%%   <<"providerServiceArn">> => string()
%% }
-type provider_properties() :: #{binary() => any()}.


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


%% Example:
%% provider_component_schema() :: #{
%%   <<"providerSchemaAttributes">> => list(provider_schema_attribute()()),
%%   <<"schemas">> => list(list([string()]())())
%% }
-type provider_component_schema() :: #{binary() => any()}.


%% Example:
%% id_mapping_job_output_source() :: #{
%%   <<"KMSArn">> => string(),
%%   <<"outputS3Path">> => string(),
%%   <<"roleArn">> => string()
%% }
-type id_mapping_job_output_source() :: #{binary() => any()}.


%% Example:
%% id_namespace_summary() :: #{
%%   <<"createdAt">> => [non_neg_integer()],
%%   <<"description">> => string(),
%%   <<"idMappingWorkflowProperties">> => list(id_namespace_id_mapping_workflow_metadata()()),
%%   <<"idNamespaceArn">> => string(),
%%   <<"idNamespaceName">> => string(),
%%   <<"type">> => list(any()),
%%   <<"updatedAt">> => [non_neg_integer()]
%% }
-type id_namespace_summary() :: #{binary() => any()}.


%% Example:
%% start_id_mapping_job_output() :: #{
%%   <<"jobId">> => string(),
%%   <<"outputSourceConfig">> => list(id_mapping_job_output_source()())
%% }
-type start_id_mapping_job_output() :: #{binary() => any()}.


%% Example:
%% get_matching_workflow_output() :: #{
%%   <<"createdAt">> => [non_neg_integer()],
%%   <<"description">> => string(),
%%   <<"incrementalRunConfig">> => incremental_run_config(),
%%   <<"inputSourceConfig">> => list(input_source()()),
%%   <<"outputSourceConfig">> => list(output_source()()),
%%   <<"resolutionTechniques">> => resolution_techniques(),
%%   <<"roleArn">> => [string()],
%%   <<"tags">> => map(),
%%   <<"updatedAt">> => [non_neg_integer()],
%%   <<"workflowArn">> => string(),
%%   <<"workflowName">> => string()
%% }
-type get_matching_workflow_output() :: #{binary() => any()}.


%% Example:
%% schema_input_attribute() :: #{
%%   <<"fieldName">> => string(),
%%   <<"groupName">> => string(),
%%   <<"hashed">> => [boolean()],
%%   <<"matchKey">> => string(),
%%   <<"subType">> => string(),
%%   <<"type">> => list(any())
%% }
-type schema_input_attribute() :: #{binary() => any()}.


%% Example:
%% id_namespace_input_source() :: #{
%%   <<"inputSourceARN">> => [string()],
%%   <<"schemaName">> => string()
%% }
-type id_namespace_input_source() :: #{binary() => any()}.


%% Example:
%% provider_marketplace_configuration() :: #{
%%   <<"assetId">> => [string()],
%%   <<"dataSetId">> => [string()],
%%   <<"listingId">> => [string()],
%%   <<"revisionId">> => [string()]
%% }
-type provider_marketplace_configuration() :: #{binary() => any()}.


%% Example:
%% get_matching_job_output() :: #{
%%   <<"endTime">> => [non_neg_integer()],
%%   <<"errorDetails">> => error_details(),
%%   <<"jobId">> => string(),
%%   <<"metrics">> => job_metrics(),
%%   <<"outputSourceConfig">> => list(job_output_source()()),
%%   <<"startTime">> => [non_neg_integer()],
%%   <<"status">> => list(any())
%% }
-type get_matching_job_output() :: #{binary() => any()}.


%% Example:
%% rule_based_properties() :: #{
%%   <<"attributeMatchingModel">> => list(any()),
%%   <<"matchPurpose">> => list(any()),
%%   <<"rules">> => list(rule()())
%% }
-type rule_based_properties() :: #{binary() => any()}.


%% Example:
%% create_id_namespace_output() :: #{
%%   <<"createdAt">> => [non_neg_integer()],
%%   <<"description">> => string(),
%%   <<"idMappingWorkflowProperties">> => list(id_namespace_id_mapping_workflow_properties()()),
%%   <<"idNamespaceArn">> => string(),
%%   <<"idNamespaceName">> => string(),
%%   <<"inputSourceConfig">> => list(id_namespace_input_source()()),
%%   <<"roleArn">> => string(),
%%   <<"tags">> => map(),
%%   <<"type">> => list(any()),
%%   <<"updatedAt">> => [non_neg_integer()]
%% }
-type create_id_namespace_output() :: #{binary() => any()}.


%% Example:
%% id_mapping_rule_based_properties() :: #{
%%   <<"attributeMatchingModel">> => list(any()),
%%   <<"recordMatchingModel">> => list(any()),
%%   <<"ruleDefinitionType">> => list(any()),
%%   <<"rules">> => list(rule()())
%% }
-type id_mapping_rule_based_properties() :: #{binary() => any()}.


%% Example:
%% update_id_namespace_output() :: #{
%%   <<"createdAt">> => [non_neg_integer()],
%%   <<"description">> => string(),
%%   <<"idMappingWorkflowProperties">> => list(id_namespace_id_mapping_workflow_properties()()),
%%   <<"idNamespaceArn">> => string(),
%%   <<"idNamespaceName">> => string(),
%%   <<"inputSourceConfig">> => list(id_namespace_input_source()()),
%%   <<"roleArn">> => string(),
%%   <<"type">> => list(any()),
%%   <<"updatedAt">> => [non_neg_integer()]
%% }
-type update_id_namespace_output() :: #{binary() => any()}.


%% Example:
%% id_mapping_workflow_input_source() :: #{
%%   <<"inputSourceARN">> => [string()],
%%   <<"schemaName">> => string(),
%%   <<"type">> => list(any())
%% }
-type id_mapping_workflow_input_source() :: #{binary() => any()}.


%% Example:
%% get_match_id_input() :: #{
%%   <<"applyNormalization">> => [boolean()],
%%   <<"record">> := map()
%% }
-type get_match_id_input() :: #{binary() => any()}.


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

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


%% Example:
%% list_matching_jobs_output() :: #{
%%   <<"jobs">> => list(job_summary()()),
%%   <<"nextToken">> => string()
%% }
-type list_matching_jobs_output() :: #{binary() => any()}.


%% Example:
%% list_provider_services_output() :: #{
%%   <<"nextToken">> => string(),
%%   <<"providerServiceSummaries">> => list(provider_service_summary()())
%% }
-type list_provider_services_output() :: #{binary() => any()}.


%% Example:
%% get_policy_output() :: #{
%%   <<"arn">> => string(),
%%   <<"policy">> => string(),
%%   <<"token">> => string()
%% }
-type get_policy_output() :: #{binary() => any()}.

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

-type batch_delete_unique_id_errors() ::
    validation_exception() | 
    internal_server_exception() | 
    resource_not_found_exception().

-type create_id_mapping_workflow_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    conflict_exception() | 
    exceeds_limit_exception().

-type create_id_namespace_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    conflict_exception() | 
    exceeds_limit_exception().

-type create_matching_workflow_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    conflict_exception() | 
    exceeds_limit_exception().

-type create_schema_mapping_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    conflict_exception() | 
    exceeds_limit_exception().

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

-type start_id_mapping_job_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception() | 
    conflict_exception() | 
    exceeds_limit_exception().

-type start_matching_job_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    internal_server_exception() | 
    resource_not_found_exception() | 
    conflict_exception() | 
    exceeds_limit_exception().

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

-type untag_resource_errors() ::
    internal_server_exception() | 
    resource_not_found_exception().

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

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

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

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

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

%% @doc Adds a policy statement object.
%%
%% To retrieve a list of existing policy statements, use
%% the `GetPolicy' API.
-spec add_policy_statement(aws_client:aws_client(), binary() | list(), binary() | list(), add_policy_statement_input()) ->
    {ok, add_policy_statement_output(), tuple()} |
    {error, any()} |
    {error, add_policy_statement_errors(), tuple()}.
add_policy_statement(Client, Arn, StatementId, Input) ->
    add_policy_statement(Client, Arn, StatementId, Input, []).

-spec add_policy_statement(aws_client:aws_client(), binary() | list(), binary() | list(), add_policy_statement_input(), proplists:proplist()) ->
    {ok, add_policy_statement_output(), tuple()} |
    {error, any()} |
    {error, add_policy_statement_errors(), tuple()}.
add_policy_statement(Client, Arn, StatementId, Input0, Options0) ->
    Method = post,
    Path = ["/policies/", aws_util:encode_uri(Arn), "/", aws_util:encode_uri(StatementId), ""],
    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 Deletes multiple unique IDs in a matching workflow.
-spec batch_delete_unique_id(aws_client:aws_client(), binary() | list(), batch_delete_unique_id_input()) ->
    {ok, batch_delete_unique_id_output(), tuple()} |
    {error, any()} |
    {error, batch_delete_unique_id_errors(), tuple()}.
batch_delete_unique_id(Client, WorkflowName, Input) ->
    batch_delete_unique_id(Client, WorkflowName, Input, []).

-spec batch_delete_unique_id(aws_client:aws_client(), binary() | list(), batch_delete_unique_id_input(), proplists:proplist()) ->
    {ok, batch_delete_unique_id_output(), tuple()} |
    {error, any()} |
    {error, batch_delete_unique_id_errors(), tuple()}.
batch_delete_unique_id(Client, WorkflowName, Input0, Options0) ->
    Method = delete,
    Path = ["/matchingworkflows/", aws_util:encode_uri(WorkflowName), "/uniqueids"],
    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],

    HeadersMapping = [
                       {<<"inputSource">>, <<"inputSource">>},
                       {<<"uniqueIds">>, <<"uniqueIds">>}
                     ],
    {Headers, Input1} = aws_request:build_headers(HeadersMapping, Input0),

    CustomHeaders = [],
    Input2 = Input1,

    Query_ = [],
    Input = Input2,

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

%% @doc Creates an `IdMappingWorkflow' object which stores the
%% configuration of the
%% data processing job to be run.
%%
%% Each `IdMappingWorkflow' must have a unique
%% workflow name. To modify an existing workflow, use the
%% `UpdateIdMappingWorkflow'
%% API.
-spec create_id_mapping_workflow(aws_client:aws_client(), create_id_mapping_workflow_input()) ->
    {ok, create_id_mapping_workflow_output(), tuple()} |
    {error, any()} |
    {error, create_id_mapping_workflow_errors(), tuple()}.
create_id_mapping_workflow(Client, Input) ->
    create_id_mapping_workflow(Client, Input, []).

-spec create_id_mapping_workflow(aws_client:aws_client(), create_id_mapping_workflow_input(), proplists:proplist()) ->
    {ok, create_id_mapping_workflow_output(), tuple()} |
    {error, any()} |
    {error, create_id_mapping_workflow_errors(), tuple()}.
create_id_mapping_workflow(Client, Input0, Options0) ->
    Method = post,
    Path = ["/idmappingworkflows"],
    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 Creates an ID namespace object which will help customers provide
%% metadata explaining
%% their dataset and how to use it.
%%
%% Each ID namespace must have a unique name. To modify an
%% existing ID namespace, use the `UpdateIdNamespace' API.
-spec create_id_namespace(aws_client:aws_client(), create_id_namespace_input()) ->
    {ok, create_id_namespace_output(), tuple()} |
    {error, any()} |
    {error, create_id_namespace_errors(), tuple()}.
create_id_namespace(Client, Input) ->
    create_id_namespace(Client, Input, []).

-spec create_id_namespace(aws_client:aws_client(), create_id_namespace_input(), proplists:proplist()) ->
    {ok, create_id_namespace_output(), tuple()} |
    {error, any()} |
    {error, create_id_namespace_errors(), tuple()}.
create_id_namespace(Client, Input0, Options0) ->
    Method = post,
    Path = ["/idnamespaces"],
    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 Creates a `MatchingWorkflow' object which stores the
%% configuration of the
%% data processing job to be run.
%%
%% It is important to note that there should not be a
%% pre-existing `MatchingWorkflow' with the same name. To modify an
%% existing
%% workflow, utilize the `UpdateMatchingWorkflow' API.
-spec create_matching_workflow(aws_client:aws_client(), create_matching_workflow_input()) ->
    {ok, create_matching_workflow_output(), tuple()} |
    {error, any()} |
    {error, create_matching_workflow_errors(), tuple()}.
create_matching_workflow(Client, Input) ->
    create_matching_workflow(Client, Input, []).

-spec create_matching_workflow(aws_client:aws_client(), create_matching_workflow_input(), proplists:proplist()) ->
    {ok, create_matching_workflow_output(), tuple()} |
    {error, any()} |
    {error, create_matching_workflow_errors(), tuple()}.
create_matching_workflow(Client, Input0, Options0) ->
    Method = post,
    Path = ["/matchingworkflows"],
    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 Creates a schema mapping, which defines the schema of the input
%% customer records table.
%%
%% The `SchemaMapping' also provides Entity Resolution with some metadata
%% about the
%% table, such as the attribute types of the columns and which columns to
%% match on.
-spec create_schema_mapping(aws_client:aws_client(), create_schema_mapping_input()) ->
    {ok, create_schema_mapping_output(), tuple()} |
    {error, any()} |
    {error, create_schema_mapping_errors(), tuple()}.
create_schema_mapping(Client, Input) ->
    create_schema_mapping(Client, Input, []).

-spec create_schema_mapping(aws_client:aws_client(), create_schema_mapping_input(), proplists:proplist()) ->
    {ok, create_schema_mapping_output(), tuple()} |
    {error, any()} |
    {error, create_schema_mapping_errors(), tuple()}.
create_schema_mapping(Client, Input0, Options0) ->
    Method = post,
    Path = ["/schemas"],
    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 Deletes the `IdMappingWorkflow' with a given name.
%%
%% This operation will
%% succeed even if a workflow with the given name does not exist.
-spec delete_id_mapping_workflow(aws_client:aws_client(), binary() | list(), delete_id_mapping_workflow_input()) ->
    {ok, delete_id_mapping_workflow_output(), tuple()} |
    {error, any()} |
    {error, delete_id_mapping_workflow_errors(), tuple()}.
delete_id_mapping_workflow(Client, WorkflowName, Input) ->
    delete_id_mapping_workflow(Client, WorkflowName, Input, []).

-spec delete_id_mapping_workflow(aws_client:aws_client(), binary() | list(), delete_id_mapping_workflow_input(), proplists:proplist()) ->
    {ok, delete_id_mapping_workflow_output(), tuple()} |
    {error, any()} |
    {error, delete_id_mapping_workflow_errors(), tuple()}.
delete_id_mapping_workflow(Client, WorkflowName, Input0, Options0) ->
    Method = delete,
    Path = ["/idmappingworkflows/", aws_util:encode_uri(WorkflowName), ""],
    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 Deletes the `IdNamespace' with a given name.
-spec delete_id_namespace(aws_client:aws_client(), binary() | list(), delete_id_namespace_input()) ->
    {ok, delete_id_namespace_output(), tuple()} |
    {error, any()} |
    {error, delete_id_namespace_errors(), tuple()}.
delete_id_namespace(Client, IdNamespaceName, Input) ->
    delete_id_namespace(Client, IdNamespaceName, Input, []).

-spec delete_id_namespace(aws_client:aws_client(), binary() | list(), delete_id_namespace_input(), proplists:proplist()) ->
    {ok, delete_id_namespace_output(), tuple()} |
    {error, any()} |
    {error, delete_id_namespace_errors(), tuple()}.
delete_id_namespace(Client, IdNamespaceName, Input0, Options0) ->
    Method = delete,
    Path = ["/idnamespaces/", aws_util:encode_uri(IdNamespaceName), ""],
    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 Deletes the `MatchingWorkflow' with a given name.
%%
%% This operation will succeed
%% even if a workflow with the given name does not exist.
-spec delete_matching_workflow(aws_client:aws_client(), binary() | list(), delete_matching_workflow_input()) ->
    {ok, delete_matching_workflow_output(), tuple()} |
    {error, any()} |
    {error, delete_matching_workflow_errors(), tuple()}.
delete_matching_workflow(Client, WorkflowName, Input) ->
    delete_matching_workflow(Client, WorkflowName, Input, []).

-spec delete_matching_workflow(aws_client:aws_client(), binary() | list(), delete_matching_workflow_input(), proplists:proplist()) ->
    {ok, delete_matching_workflow_output(), tuple()} |
    {error, any()} |
    {error, delete_matching_workflow_errors(), tuple()}.
delete_matching_workflow(Client, WorkflowName, Input0, Options0) ->
    Method = delete,
    Path = ["/matchingworkflows/", aws_util:encode_uri(WorkflowName), ""],
    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 Deletes the policy statement.
-spec delete_policy_statement(aws_client:aws_client(), binary() | list(), binary() | list(), delete_policy_statement_input()) ->
    {ok, delete_policy_statement_output(), tuple()} |
    {error, any()} |
    {error, delete_policy_statement_errors(), tuple()}.
delete_policy_statement(Client, Arn, StatementId, Input) ->
    delete_policy_statement(Client, Arn, StatementId, Input, []).

-spec delete_policy_statement(aws_client:aws_client(), binary() | list(), binary() | list(), delete_policy_statement_input(), proplists:proplist()) ->
    {ok, delete_policy_statement_output(), tuple()} |
    {error, any()} |
    {error, delete_policy_statement_errors(), tuple()}.
delete_policy_statement(Client, Arn, StatementId, Input0, Options0) ->
    Method = delete,
    Path = ["/policies/", aws_util:encode_uri(Arn), "/", aws_util:encode_uri(StatementId), ""],
    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 Deletes the `SchemaMapping' with a given name.
%%
%% This operation will succeed
%% even if a schema with the given name does not exist. This operation will
%% fail if there is a
%% `MatchingWorkflow' object that references the `SchemaMapping' in
%% the workflow's `InputSourceConfig'.
-spec delete_schema_mapping(aws_client:aws_client(), binary() | list(), delete_schema_mapping_input()) ->
    {ok, delete_schema_mapping_output(), tuple()} |
    {error, any()} |
    {error, delete_schema_mapping_errors(), tuple()}.
delete_schema_mapping(Client, SchemaName, Input) ->
    delete_schema_mapping(Client, SchemaName, Input, []).

-spec delete_schema_mapping(aws_client:aws_client(), binary() | list(), delete_schema_mapping_input(), proplists:proplist()) ->
    {ok, delete_schema_mapping_output(), tuple()} |
    {error, any()} |
    {error, delete_schema_mapping_errors(), tuple()}.
delete_schema_mapping(Client, SchemaName, Input0, Options0) ->
    Method = delete,
    Path = ["/schemas/", aws_util:encode_uri(SchemaName), ""],
    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 Gets the status, metrics, and errors (if there are any) that are
%% associated with a
%% job.
-spec get_id_mapping_job(aws_client:aws_client(), binary() | list(), binary() | list()) ->
    {ok, get_id_mapping_job_output(), tuple()} |
    {error, any()} |
    {error, get_id_mapping_job_errors(), tuple()}.
get_id_mapping_job(Client, JobId, WorkflowName)
  when is_map(Client) ->
    get_id_mapping_job(Client, JobId, WorkflowName, #{}, #{}).

-spec get_id_mapping_job(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map()) ->
    {ok, get_id_mapping_job_output(), tuple()} |
    {error, any()} |
    {error, get_id_mapping_job_errors(), tuple()}.
get_id_mapping_job(Client, JobId, WorkflowName, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    get_id_mapping_job(Client, JobId, WorkflowName, QueryMap, HeadersMap, []).

-spec get_id_mapping_job(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, get_id_mapping_job_output(), tuple()} |
    {error, any()} |
    {error, get_id_mapping_job_errors(), tuple()}.
get_id_mapping_job(Client, JobId, WorkflowName, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/idmappingworkflows/", aws_util:encode_uri(WorkflowName), "/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 Returns the `IdMappingWorkflow' with a given name, if it exists.
-spec get_id_mapping_workflow(aws_client:aws_client(), binary() | list()) ->
    {ok, get_id_mapping_workflow_output(), tuple()} |
    {error, any()} |
    {error, get_id_mapping_workflow_errors(), tuple()}.
get_id_mapping_workflow(Client, WorkflowName)
  when is_map(Client) ->
    get_id_mapping_workflow(Client, WorkflowName, #{}, #{}).

-spec get_id_mapping_workflow(aws_client:aws_client(), binary() | list(), map(), map()) ->
    {ok, get_id_mapping_workflow_output(), tuple()} |
    {error, any()} |
    {error, get_id_mapping_workflow_errors(), tuple()}.
get_id_mapping_workflow(Client, WorkflowName, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    get_id_mapping_workflow(Client, WorkflowName, QueryMap, HeadersMap, []).

-spec get_id_mapping_workflow(aws_client:aws_client(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, get_id_mapping_workflow_output(), tuple()} |
    {error, any()} |
    {error, get_id_mapping_workflow_errors(), tuple()}.
get_id_mapping_workflow(Client, WorkflowName, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/idmappingworkflows/", aws_util:encode_uri(WorkflowName), ""],
    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 Returns the `IdNamespace' with a given name, if it exists.
-spec get_id_namespace(aws_client:aws_client(), binary() | list()) ->
    {ok, get_id_namespace_output(), tuple()} |
    {error, any()} |
    {error, get_id_namespace_errors(), tuple()}.
get_id_namespace(Client, IdNamespaceName)
  when is_map(Client) ->
    get_id_namespace(Client, IdNamespaceName, #{}, #{}).

-spec get_id_namespace(aws_client:aws_client(), binary() | list(), map(), map()) ->
    {ok, get_id_namespace_output(), tuple()} |
    {error, any()} |
    {error, get_id_namespace_errors(), tuple()}.
get_id_namespace(Client, IdNamespaceName, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    get_id_namespace(Client, IdNamespaceName, QueryMap, HeadersMap, []).

-spec get_id_namespace(aws_client:aws_client(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, get_id_namespace_output(), tuple()} |
    {error, any()} |
    {error, get_id_namespace_errors(), tuple()}.
get_id_namespace(Client, IdNamespaceName, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/idnamespaces/", aws_util:encode_uri(IdNamespaceName), ""],
    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 Returns the corresponding Match ID of a customer record if the record
%% has been
%% processed.
-spec get_match_id(aws_client:aws_client(), binary() | list(), get_match_id_input()) ->
    {ok, get_match_id_output(), tuple()} |
    {error, any()} |
    {error, get_match_id_errors(), tuple()}.
get_match_id(Client, WorkflowName, Input) ->
    get_match_id(Client, WorkflowName, Input, []).

-spec get_match_id(aws_client:aws_client(), binary() | list(), get_match_id_input(), proplists:proplist()) ->
    {ok, get_match_id_output(), tuple()} |
    {error, any()} |
    {error, get_match_id_errors(), tuple()}.
get_match_id(Client, WorkflowName, Input0, Options0) ->
    Method = post,
    Path = ["/matchingworkflows/", aws_util:encode_uri(WorkflowName), "/matches"],
    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 Gets the status, metrics, and errors (if there are any) that are
%% associated with a
%% job.
-spec get_matching_job(aws_client:aws_client(), binary() | list(), binary() | list()) ->
    {ok, get_matching_job_output(), tuple()} |
    {error, any()} |
    {error, get_matching_job_errors(), tuple()}.
get_matching_job(Client, JobId, WorkflowName)
  when is_map(Client) ->
    get_matching_job(Client, JobId, WorkflowName, #{}, #{}).

-spec get_matching_job(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map()) ->
    {ok, get_matching_job_output(), tuple()} |
    {error, any()} |
    {error, get_matching_job_errors(), tuple()}.
get_matching_job(Client, JobId, WorkflowName, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    get_matching_job(Client, JobId, WorkflowName, QueryMap, HeadersMap, []).

-spec get_matching_job(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, get_matching_job_output(), tuple()} |
    {error, any()} |
    {error, get_matching_job_errors(), tuple()}.
get_matching_job(Client, JobId, WorkflowName, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/matchingworkflows/", aws_util:encode_uri(WorkflowName), "/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 Returns the `MatchingWorkflow' with a given name, if it exists.
-spec get_matching_workflow(aws_client:aws_client(), binary() | list()) ->
    {ok, get_matching_workflow_output(), tuple()} |
    {error, any()} |
    {error, get_matching_workflow_errors(), tuple()}.
get_matching_workflow(Client, WorkflowName)
  when is_map(Client) ->
    get_matching_workflow(Client, WorkflowName, #{}, #{}).

-spec get_matching_workflow(aws_client:aws_client(), binary() | list(), map(), map()) ->
    {ok, get_matching_workflow_output(), tuple()} |
    {error, any()} |
    {error, get_matching_workflow_errors(), tuple()}.
get_matching_workflow(Client, WorkflowName, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    get_matching_workflow(Client, WorkflowName, QueryMap, HeadersMap, []).

-spec get_matching_workflow(aws_client:aws_client(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, get_matching_workflow_output(), tuple()} |
    {error, any()} |
    {error, get_matching_workflow_errors(), tuple()}.
get_matching_workflow(Client, WorkflowName, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/matchingworkflows/", aws_util:encode_uri(WorkflowName), ""],
    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 Returns the resource-based policy.
-spec get_policy(aws_client:aws_client(), binary() | list()) ->
    {ok, get_policy_output(), tuple()} |
    {error, any()} |
    {error, get_policy_errors(), tuple()}.
get_policy(Client, Arn)
  when is_map(Client) ->
    get_policy(Client, Arn, #{}, #{}).

-spec get_policy(aws_client:aws_client(), binary() | list(), map(), map()) ->
    {ok, get_policy_output(), tuple()} |
    {error, any()} |
    {error, get_policy_errors(), tuple()}.
get_policy(Client, Arn, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    get_policy(Client, Arn, QueryMap, HeadersMap, []).

-spec get_policy(aws_client:aws_client(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, get_policy_output(), tuple()} |
    {error, any()} |
    {error, get_policy_errors(), tuple()}.
get_policy(Client, Arn, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/policies/", aws_util:encode_uri(Arn), ""],
    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 Returns the `ProviderService' of a given name.
-spec get_provider_service(aws_client:aws_client(), binary() | list(), binary() | list()) ->
    {ok, get_provider_service_output(), tuple()} |
    {error, any()} |
    {error, get_provider_service_errors(), tuple()}.
get_provider_service(Client, ProviderName, ProviderServiceName)
  when is_map(Client) ->
    get_provider_service(Client, ProviderName, ProviderServiceName, #{}, #{}).

-spec get_provider_service(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map()) ->
    {ok, get_provider_service_output(), tuple()} |
    {error, any()} |
    {error, get_provider_service_errors(), tuple()}.
get_provider_service(Client, ProviderName, ProviderServiceName, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    get_provider_service(Client, ProviderName, ProviderServiceName, QueryMap, HeadersMap, []).

-spec get_provider_service(aws_client:aws_client(), binary() | list(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, get_provider_service_output(), tuple()} |
    {error, any()} |
    {error, get_provider_service_errors(), tuple()}.
get_provider_service(Client, ProviderName, ProviderServiceName, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/providerservices/", aws_util:encode_uri(ProviderName), "/", aws_util:encode_uri(ProviderServiceName), ""],
    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 Returns the SchemaMapping of a given name.
-spec get_schema_mapping(aws_client:aws_client(), binary() | list()) ->
    {ok, get_schema_mapping_output(), tuple()} |
    {error, any()} |
    {error, get_schema_mapping_errors(), tuple()}.
get_schema_mapping(Client, SchemaName)
  when is_map(Client) ->
    get_schema_mapping(Client, SchemaName, #{}, #{}).

-spec get_schema_mapping(aws_client:aws_client(), binary() | list(), map(), map()) ->
    {ok, get_schema_mapping_output(), tuple()} |
    {error, any()} |
    {error, get_schema_mapping_errors(), tuple()}.
get_schema_mapping(Client, SchemaName, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    get_schema_mapping(Client, SchemaName, QueryMap, HeadersMap, []).

-spec get_schema_mapping(aws_client:aws_client(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, get_schema_mapping_output(), tuple()} |
    {error, any()} |
    {error, get_schema_mapping_errors(), tuple()}.
get_schema_mapping(Client, SchemaName, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/schemas/", aws_util:encode_uri(SchemaName), ""],
    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 Lists all ID mapping jobs for a given workflow.
-spec list_id_mapping_jobs(aws_client:aws_client(), binary() | list()) ->
    {ok, list_id_mapping_jobs_output(), tuple()} |
    {error, any()} |
    {error, list_id_mapping_jobs_errors(), tuple()}.
list_id_mapping_jobs(Client, WorkflowName)
  when is_map(Client) ->
    list_id_mapping_jobs(Client, WorkflowName, #{}, #{}).

-spec list_id_mapping_jobs(aws_client:aws_client(), binary() | list(), map(), map()) ->
    {ok, list_id_mapping_jobs_output(), tuple()} |
    {error, any()} |
    {error, list_id_mapping_jobs_errors(), tuple()}.
list_id_mapping_jobs(Client, WorkflowName, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    list_id_mapping_jobs(Client, WorkflowName, QueryMap, HeadersMap, []).

-spec list_id_mapping_jobs(aws_client:aws_client(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, list_id_mapping_jobs_output(), tuple()} |
    {error, any()} |
    {error, list_id_mapping_jobs_errors(), tuple()}.
list_id_mapping_jobs(Client, WorkflowName, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/idmappingworkflows/", aws_util:encode_uri(WorkflowName), "/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}
               | 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 Returns a list of all the `IdMappingWorkflows' that have been
%% created for an
%% Amazon Web Services account.
-spec list_id_mapping_workflows(aws_client:aws_client()) ->
    {ok, list_id_mapping_workflows_output(), tuple()} |
    {error, any()} |
    {error, list_id_mapping_workflows_errors(), tuple()}.
list_id_mapping_workflows(Client)
  when is_map(Client) ->
    list_id_mapping_workflows(Client, #{}, #{}).

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

-spec list_id_mapping_workflows(aws_client:aws_client(), map(), map(), proplists:proplist()) ->
    {ok, list_id_mapping_workflows_output(), tuple()} |
    {error, any()} |
    {error, list_id_mapping_workflows_errors(), tuple()}.
list_id_mapping_workflows(Client, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/idmappingworkflows"],
    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 Returns a list of all ID namespaces.
-spec list_id_namespaces(aws_client:aws_client()) ->
    {ok, list_id_namespaces_output(), tuple()} |
    {error, any()} |
    {error, list_id_namespaces_errors(), tuple()}.
list_id_namespaces(Client)
  when is_map(Client) ->
    list_id_namespaces(Client, #{}, #{}).

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

-spec list_id_namespaces(aws_client:aws_client(), map(), map(), proplists:proplist()) ->
    {ok, list_id_namespaces_output(), tuple()} |
    {error, any()} |
    {error, list_id_namespaces_errors(), tuple()}.
list_id_namespaces(Client, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/idnamespaces"],
    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 Lists all jobs for a given workflow.
-spec list_matching_jobs(aws_client:aws_client(), binary() | list()) ->
    {ok, list_matching_jobs_output(), tuple()} |
    {error, any()} |
    {error, list_matching_jobs_errors(), tuple()}.
list_matching_jobs(Client, WorkflowName)
  when is_map(Client) ->
    list_matching_jobs(Client, WorkflowName, #{}, #{}).

-spec list_matching_jobs(aws_client:aws_client(), binary() | list(), map(), map()) ->
    {ok, list_matching_jobs_output(), tuple()} |
    {error, any()} |
    {error, list_matching_jobs_errors(), tuple()}.
list_matching_jobs(Client, WorkflowName, QueryMap, HeadersMap)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap) ->
    list_matching_jobs(Client, WorkflowName, QueryMap, HeadersMap, []).

-spec list_matching_jobs(aws_client:aws_client(), binary() | list(), map(), map(), proplists:proplist()) ->
    {ok, list_matching_jobs_output(), tuple()} |
    {error, any()} |
    {error, list_matching_jobs_errors(), tuple()}.
list_matching_jobs(Client, WorkflowName, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/matchingworkflows/", aws_util:encode_uri(WorkflowName), "/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}
               | 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 Returns a list of all the `MatchingWorkflows' that have been
%% created for an
%% Amazon Web Services account.
-spec list_matching_workflows(aws_client:aws_client()) ->
    {ok, list_matching_workflows_output(), tuple()} |
    {error, any()} |
    {error, list_matching_workflows_errors(), tuple()}.
list_matching_workflows(Client)
  when is_map(Client) ->
    list_matching_workflows(Client, #{}, #{}).

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

-spec list_matching_workflows(aws_client:aws_client(), map(), map(), proplists:proplist()) ->
    {ok, list_matching_workflows_output(), tuple()} |
    {error, any()} |
    {error, list_matching_workflows_errors(), tuple()}.
list_matching_workflows(Client, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/matchingworkflows"],
    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 Returns a list of all the `ProviderServices' that are available
%% in this
%% Amazon Web Services Region.
-spec list_provider_services(aws_client:aws_client()) ->
    {ok, list_provider_services_output(), tuple()} |
    {error, any()} |
    {error, list_provider_services_errors(), tuple()}.
list_provider_services(Client)
  when is_map(Client) ->
    list_provider_services(Client, #{}, #{}).

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

-spec list_provider_services(aws_client:aws_client(), map(), map(), proplists:proplist()) ->
    {ok, list_provider_services_output(), tuple()} |
    {error, any()} |
    {error, list_provider_services_errors(), tuple()}.
list_provider_services(Client, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/providerservices"],
    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)},
        {<<"providerName">>, maps:get(<<"providerName">>, QueryMap, undefined)}
      ],
    Query_ = [H || {_, V} = H <- Query0_, V =/= undefined],

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

%% @doc Returns a list of all the `SchemaMappings' that have been created
%% for an
%% Amazon Web Services account.
-spec list_schema_mappings(aws_client:aws_client()) ->
    {ok, list_schema_mappings_output(), tuple()} |
    {error, any()} |
    {error, list_schema_mappings_errors(), tuple()}.
list_schema_mappings(Client)
  when is_map(Client) ->
    list_schema_mappings(Client, #{}, #{}).

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

-spec list_schema_mappings(aws_client:aws_client(), map(), map(), proplists:proplist()) ->
    {ok, list_schema_mappings_output(), tuple()} |
    {error, any()} |
    {error, list_schema_mappings_errors(), tuple()}.
list_schema_mappings(Client, QueryMap, HeadersMap, Options0)
  when is_map(Client), is_map(QueryMap), is_map(HeadersMap), is_list(Options0) ->
    Path = ["/schemas"],
    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 Displays the tags associated with an Entity Resolution resource.
%%
%% In Entity Resolution,
%% `SchemaMapping', and `MatchingWorkflow' can be tagged.
-spec list_tags_for_resource(aws_client:aws_client(), binary() | list()) ->
    {ok, list_tags_for_resource_output(), 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_output(), 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_output(), 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 = ["/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 Updates the resource-based policy.
-spec put_policy(aws_client:aws_client(), binary() | list(), put_policy_input()) ->
    {ok, put_policy_output(), tuple()} |
    {error, any()} |
    {error, put_policy_errors(), tuple()}.
put_policy(Client, Arn, Input) ->
    put_policy(Client, Arn, Input, []).

-spec put_policy(aws_client:aws_client(), binary() | list(), put_policy_input(), proplists:proplist()) ->
    {ok, put_policy_output(), tuple()} |
    {error, any()} |
    {error, put_policy_errors(), tuple()}.
put_policy(Client, Arn, Input0, Options0) ->
    Method = put,
    Path = ["/policies/", aws_util:encode_uri(Arn), ""],
    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 Starts the `IdMappingJob' of a workflow.
%%
%% The workflow must have previously
%% been created using the `CreateIdMappingWorkflow' endpoint.
-spec start_id_mapping_job(aws_client:aws_client(), binary() | list(), start_id_mapping_job_input()) ->
    {ok, start_id_mapping_job_output(), tuple()} |
    {error, any()} |
    {error, start_id_mapping_job_errors(), tuple()}.
start_id_mapping_job(Client, WorkflowName, Input) ->
    start_id_mapping_job(Client, WorkflowName, Input, []).

-spec start_id_mapping_job(aws_client:aws_client(), binary() | list(), start_id_mapping_job_input(), proplists:proplist()) ->
    {ok, start_id_mapping_job_output(), tuple()} |
    {error, any()} |
    {error, start_id_mapping_job_errors(), tuple()}.
start_id_mapping_job(Client, WorkflowName, Input0, Options0) ->
    Method = post,
    Path = ["/idmappingworkflows/", aws_util:encode_uri(WorkflowName), "/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 Starts the `MatchingJob' of a workflow.
%%
%% The workflow must have previously
%% been created using the `CreateMatchingWorkflow' endpoint.
-spec start_matching_job(aws_client:aws_client(), binary() | list(), start_matching_job_input()) ->
    {ok, start_matching_job_output(), tuple()} |
    {error, any()} |
    {error, start_matching_job_errors(), tuple()}.
start_matching_job(Client, WorkflowName, Input) ->
    start_matching_job(Client, WorkflowName, Input, []).

-spec start_matching_job(aws_client:aws_client(), binary() | list(), start_matching_job_input(), proplists:proplist()) ->
    {ok, start_matching_job_output(), tuple()} |
    {error, any()} |
    {error, start_matching_job_errors(), tuple()}.
start_matching_job(Client, WorkflowName, Input0, Options0) ->
    Method = post,
    Path = ["/matchingworkflows/", aws_util:encode_uri(WorkflowName), "/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 Assigns one or more tags (key-value pairs) to the specified Entity
%% Resolution resource.
%%
%% Tags can help you organize and categorize your resources. You can also use
%% them to scope
%% user permissions by granting a user permission to access or change only
%% resources with
%% certain tag values. In Entity Resolution, `SchemaMapping' and
%% `MatchingWorkflow' can be tagged. Tags don't have any semantic
%% meaning to
%% Amazon Web Services and are interpreted strictly as strings of characters.
%% You can use
%% the `TagResource' action with a resource that already has tags. If you
%% specify a
%% new tag key, this tag is appended to the list of tags associated with the
%% resource. If you
%% specify a tag key that is already associated with the resource, the new
%% tag value that you
%% specify replaces the previous value for that tag.
-spec tag_resource(aws_client:aws_client(), binary() | list(), tag_resource_input()) ->
    {ok, tag_resource_output(), 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_input(), proplists:proplist()) ->
    {ok, tag_resource_output(), tuple()} |
    {error, any()} |
    {error, tag_resource_errors(), tuple()}.
tag_resource(Client, ResourceArn, Input0, Options0) ->
    Method = post,
    Path = ["/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 Removes one or more tags from the specified Entity Resolution
%% resource.
%%
%% In Entity Resolution, `SchemaMapping', and `MatchingWorkflow' can
%% be
%% tagged.
-spec untag_resource(aws_client:aws_client(), binary() | list(), untag_resource_input()) ->
    {ok, untag_resource_output(), 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_input(), proplists:proplist()) ->
    {ok, untag_resource_output(), tuple()} |
    {error, any()} |
    {error, untag_resource_errors(), tuple()}.
untag_resource(Client, ResourceArn, Input0, Options0) ->
    Method = delete,
    Path = ["/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 Updates an existing `IdMappingWorkflow'.
%%
%% This method is identical to
%% `CreateIdMappingWorkflow', except it uses an HTTP `PUT' request
%% instead of a `POST' request, and the `IdMappingWorkflow' must
%% already
%% exist for the method to succeed.
-spec update_id_mapping_workflow(aws_client:aws_client(), binary() | list(), update_id_mapping_workflow_input()) ->
    {ok, update_id_mapping_workflow_output(), tuple()} |
    {error, any()} |
    {error, update_id_mapping_workflow_errors(), tuple()}.
update_id_mapping_workflow(Client, WorkflowName, Input) ->
    update_id_mapping_workflow(Client, WorkflowName, Input, []).

-spec update_id_mapping_workflow(aws_client:aws_client(), binary() | list(), update_id_mapping_workflow_input(), proplists:proplist()) ->
    {ok, update_id_mapping_workflow_output(), tuple()} |
    {error, any()} |
    {error, update_id_mapping_workflow_errors(), tuple()}.
update_id_mapping_workflow(Client, WorkflowName, Input0, Options0) ->
    Method = put,
    Path = ["/idmappingworkflows/", aws_util:encode_uri(WorkflowName), ""],
    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 Updates an existing ID namespace.
-spec update_id_namespace(aws_client:aws_client(), binary() | list(), update_id_namespace_input()) ->
    {ok, update_id_namespace_output(), tuple()} |
    {error, any()} |
    {error, update_id_namespace_errors(), tuple()}.
update_id_namespace(Client, IdNamespaceName, Input) ->
    update_id_namespace(Client, IdNamespaceName, Input, []).

-spec update_id_namespace(aws_client:aws_client(), binary() | list(), update_id_namespace_input(), proplists:proplist()) ->
    {ok, update_id_namespace_output(), tuple()} |
    {error, any()} |
    {error, update_id_namespace_errors(), tuple()}.
update_id_namespace(Client, IdNamespaceName, Input0, Options0) ->
    Method = put,
    Path = ["/idnamespaces/", aws_util:encode_uri(IdNamespaceName), ""],
    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 Updates an existing `MatchingWorkflow'.
%%
%% This method is identical to
%% `CreateMatchingWorkflow', except it uses an HTTP `PUT' request
%% instead of a `POST' request, and the `MatchingWorkflow' must
%% already
%% exist for the method to succeed.
-spec update_matching_workflow(aws_client:aws_client(), binary() | list(), update_matching_workflow_input()) ->
    {ok, update_matching_workflow_output(), tuple()} |
    {error, any()} |
    {error, update_matching_workflow_errors(), tuple()}.
update_matching_workflow(Client, WorkflowName, Input) ->
    update_matching_workflow(Client, WorkflowName, Input, []).

-spec update_matching_workflow(aws_client:aws_client(), binary() | list(), update_matching_workflow_input(), proplists:proplist()) ->
    {ok, update_matching_workflow_output(), tuple()} |
    {error, any()} |
    {error, update_matching_workflow_errors(), tuple()}.
update_matching_workflow(Client, WorkflowName, Input0, Options0) ->
    Method = put,
    Path = ["/matchingworkflows/", aws_util:encode_uri(WorkflowName), ""],
    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 Updates a schema mapping.
%%
%% A schema is immutable if it is being used by a workflow. Therefore, you
%% can't update
%% a schema mapping if it's associated with a workflow.
-spec update_schema_mapping(aws_client:aws_client(), binary() | list(), update_schema_mapping_input()) ->
    {ok, update_schema_mapping_output(), tuple()} |
    {error, any()} |
    {error, update_schema_mapping_errors(), tuple()}.
update_schema_mapping(Client, SchemaName, Input) ->
    update_schema_mapping(Client, SchemaName, Input, []).

-spec update_schema_mapping(aws_client:aws_client(), binary() | list(), update_schema_mapping_input(), proplists:proplist()) ->
    {ok, update_schema_mapping_output(), tuple()} |
    {error, any()} |
    {error, update_schema_mapping_errors(), tuple()}.
update_schema_mapping(Client, SchemaName, Input0, Options0) ->
    Method = put,
    Path = ["/schemas/", aws_util:encode_uri(SchemaName), ""],
    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 => <<"entityresolution">>},
    Host = build_host(<<"entityresolution">>, Client1),
    URL0 = build_url(Host, Path, Client1),
    URL = aws_request:add_query(URL0, Query),
    AdditionalHeaders1 = [ {<<"Host">>, Host}
                         , {<<"Content-Type">>, <<"application/x-amz-json-1.1">>}
                         ],
    Payload =
      case proplists:get_value(send_body_as_binary, Options) of
        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).