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

%% @doc You can use Amazon CloudWatch Logs to monitor, store, and access your
%% log files from
%% EC2 instances, CloudTrail, and other sources.
%%
%% You can then retrieve the associated
%% log data from CloudWatch Logs using the CloudWatch console. Alternatively,
%% you can use
%% CloudWatch Logs commands in the Amazon Web Services CLI, CloudWatch Logs
%% API, or CloudWatch
%% Logs SDK.
%%
%% You can use CloudWatch Logs to:
%%
%% Monitor logs from EC2 instances in real time: You
%% can use CloudWatch Logs to monitor applications and systems using log
%% data. For example,
%% CloudWatch Logs can track the number of errors that occur in your
%% application logs. Then,
%% it can send you a notification whenever the rate of errors exceeds a
%% threshold that you
%% specify. CloudWatch Logs uses your log data for monitoring so no code
%% changes are
%% required. For example, you can monitor application logs for specific
%% literal terms (such
%% as "NullReferenceException"). You can also count the number of
%% occurrences of a literal
%% term at a particular position in log data (such as "404" status
%% codes in an Apache access
%% log). When the term you are searching for is found, CloudWatch Logs
%% reports the data to a
%% CloudWatch metric that you specify.
%%
%% Monitor CloudTrail logged events: You
%% can create alarms in CloudWatch and receive notifications of particular
%% API activity as
%% captured by CloudTrail. You can use the notification to perform
%% troubleshooting.
%%
%% Archive log data: You can use CloudWatch Logs to
%% store your log data in highly durable storage. You can change the log
%% retention setting so
%% that any log events earlier than this setting are automatically deleted.
%% The CloudWatch
%% Logs agent helps to quickly send both rotated and non-rotated log data off
%% of a host and
%% into the log service. You can then access the raw log data when you need
%% it.
-module(aws_cloudwatch_logs).

-export([associate_kms_key/2,
         associate_kms_key/3,
         associate_source_to_s3_table_integration/2,
         associate_source_to_s3_table_integration/3,
         cancel_export_task/2,
         cancel_export_task/3,
         cancel_import_task/2,
         cancel_import_task/3,
         create_delivery/2,
         create_delivery/3,
         create_export_task/2,
         create_export_task/3,
         create_import_task/2,
         create_import_task/3,
         create_log_anomaly_detector/2,
         create_log_anomaly_detector/3,
         create_log_group/2,
         create_log_group/3,
         create_log_stream/2,
         create_log_stream/3,
         create_lookup_table/2,
         create_lookup_table/3,
         create_scheduled_query/2,
         create_scheduled_query/3,
         delete_account_policy/2,
         delete_account_policy/3,
         delete_data_protection_policy/2,
         delete_data_protection_policy/3,
         delete_delivery/2,
         delete_delivery/3,
         delete_delivery_destination/2,
         delete_delivery_destination/3,
         delete_delivery_destination_policy/2,
         delete_delivery_destination_policy/3,
         delete_delivery_source/2,
         delete_delivery_source/3,
         delete_destination/2,
         delete_destination/3,
         delete_index_policy/2,
         delete_index_policy/3,
         delete_integration/2,
         delete_integration/3,
         delete_log_anomaly_detector/2,
         delete_log_anomaly_detector/3,
         delete_log_group/2,
         delete_log_group/3,
         delete_log_stream/2,
         delete_log_stream/3,
         delete_lookup_table/2,
         delete_lookup_table/3,
         delete_metric_filter/2,
         delete_metric_filter/3,
         delete_query_definition/2,
         delete_query_definition/3,
         delete_resource_policy/2,
         delete_resource_policy/3,
         delete_retention_policy/2,
         delete_retention_policy/3,
         delete_scheduled_query/2,
         delete_scheduled_query/3,
         delete_subscription_filter/2,
         delete_subscription_filter/3,
         delete_transformer/2,
         delete_transformer/3,
         describe_account_policies/2,
         describe_account_policies/3,
         describe_configuration_templates/2,
         describe_configuration_templates/3,
         describe_deliveries/2,
         describe_deliveries/3,
         describe_delivery_destinations/2,
         describe_delivery_destinations/3,
         describe_delivery_sources/2,
         describe_delivery_sources/3,
         describe_destinations/2,
         describe_destinations/3,
         describe_export_tasks/2,
         describe_export_tasks/3,
         describe_field_indexes/2,
         describe_field_indexes/3,
         describe_import_task_batches/2,
         describe_import_task_batches/3,
         describe_import_tasks/2,
         describe_import_tasks/3,
         describe_index_policies/2,
         describe_index_policies/3,
         describe_log_groups/2,
         describe_log_groups/3,
         describe_log_streams/2,
         describe_log_streams/3,
         describe_lookup_tables/2,
         describe_lookup_tables/3,
         describe_metric_filters/2,
         describe_metric_filters/3,
         describe_queries/2,
         describe_queries/3,
         describe_query_definitions/2,
         describe_query_definitions/3,
         describe_resource_policies/2,
         describe_resource_policies/3,
         describe_subscription_filters/2,
         describe_subscription_filters/3,
         disassociate_kms_key/2,
         disassociate_kms_key/3,
         disassociate_source_from_s3_table_integration/2,
         disassociate_source_from_s3_table_integration/3,
         filter_log_events/2,
         filter_log_events/3,
         get_data_protection_policy/2,
         get_data_protection_policy/3,
         get_delivery/2,
         get_delivery/3,
         get_delivery_destination/2,
         get_delivery_destination/3,
         get_delivery_destination_policy/2,
         get_delivery_destination_policy/3,
         get_delivery_source/2,
         get_delivery_source/3,
         get_integration/2,
         get_integration/3,
         get_log_anomaly_detector/2,
         get_log_anomaly_detector/3,
         get_log_events/2,
         get_log_events/3,
         get_log_fields/2,
         get_log_fields/3,
         get_log_group_fields/2,
         get_log_group_fields/3,
         get_log_object/2,
         get_log_object/3,
         get_log_record/2,
         get_log_record/3,
         get_lookup_table/2,
         get_lookup_table/3,
         get_query_results/2,
         get_query_results/3,
         get_scheduled_query/2,
         get_scheduled_query/3,
         get_scheduled_query_history/2,
         get_scheduled_query_history/3,
         get_transformer/2,
         get_transformer/3,
         list_aggregate_log_group_summaries/2,
         list_aggregate_log_group_summaries/3,
         list_anomalies/2,
         list_anomalies/3,
         list_integrations/2,
         list_integrations/3,
         list_log_anomaly_detectors/2,
         list_log_anomaly_detectors/3,
         list_log_groups/2,
         list_log_groups/3,
         list_log_groups_for_query/2,
         list_log_groups_for_query/3,
         list_scheduled_queries/2,
         list_scheduled_queries/3,
         list_sources_for_s3_table_integration/2,
         list_sources_for_s3_table_integration/3,
         list_tags_for_resource/2,
         list_tags_for_resource/3,
         list_tags_log_group/2,
         list_tags_log_group/3,
         put_account_policy/2,
         put_account_policy/3,
         put_bearer_token_authentication/2,
         put_bearer_token_authentication/3,
         put_data_protection_policy/2,
         put_data_protection_policy/3,
         put_delivery_destination/2,
         put_delivery_destination/3,
         put_delivery_destination_policy/2,
         put_delivery_destination_policy/3,
         put_delivery_source/2,
         put_delivery_source/3,
         put_destination/2,
         put_destination/3,
         put_destination_policy/2,
         put_destination_policy/3,
         put_index_policy/2,
         put_index_policy/3,
         put_integration/2,
         put_integration/3,
         put_log_events/2,
         put_log_events/3,
         put_log_group_deletion_protection/2,
         put_log_group_deletion_protection/3,
         put_metric_filter/2,
         put_metric_filter/3,
         put_query_definition/2,
         put_query_definition/3,
         put_resource_policy/2,
         put_resource_policy/3,
         put_retention_policy/2,
         put_retention_policy/3,
         put_subscription_filter/2,
         put_subscription_filter/3,
         put_transformer/2,
         put_transformer/3,
         start_live_tail/2,
         start_live_tail/3,
         start_query/2,
         start_query/3,
         stop_query/2,
         stop_query/3,
         tag_log_group/2,
         tag_log_group/3,
         tag_resource/2,
         tag_resource/3,
         test_metric_filter/2,
         test_metric_filter/3,
         test_transformer/2,
         test_transformer/3,
         untag_log_group/2,
         untag_log_group/3,
         untag_resource/2,
         untag_resource/3,
         update_anomaly/2,
         update_anomaly/3,
         update_delivery_configuration/2,
         update_delivery_configuration/3,
         update_log_anomaly_detector/2,
         update_log_anomaly_detector/3,
         update_lookup_table/2,
         update_lookup_table/3,
         update_scheduled_query/2,
         update_scheduled_query/3]).

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


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

%% Example:
%% list_anomalies_response() :: #{
%%   <<"anomalies">> => list(anomaly()),
%%   <<"nextToken">> => string()
%% }
-type list_anomalies_response() :: #{binary() => any()}.

%% Example:
%% add_key_entry() :: #{
%%   <<"key">> => string(),
%%   <<"overwriteIfExists">> => boolean(),
%%   <<"value">> => string()
%% }
-type add_key_entry() :: #{binary() => any()}.

%% Example:
%% update_scheduled_query_response() :: #{
%%   <<"creationTime">> => float(),
%%   <<"description">> => string(),
%%   <<"destinationConfiguration">> => destination_configuration(),
%%   <<"executionRoleArn">> => string(),
%%   <<"lastExecutionStatus">> => list(any()),
%%   <<"lastTriggeredTime">> => float(),
%%   <<"lastUpdatedTime">> => float(),
%%   <<"logGroupIdentifiers">> => list(string()),
%%   <<"name">> => string(),
%%   <<"queryLanguage">> => list(any()),
%%   <<"queryString">> => string(),
%%   <<"scheduleEndTime">> => float(),
%%   <<"scheduleExpression">> => string(),
%%   <<"scheduleStartTime">> => float(),
%%   <<"scheduledQueryArn">> => string(),
%%   <<"startTimeOffset">> => float(),
%%   <<"state">> => list(any()),
%%   <<"timezone">> => string()
%% }
-type update_scheduled_query_response() :: #{binary() => any()}.

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

%% Example:
%% describe_resource_policies_request() :: #{
%%   <<"limit">> => integer(),
%%   <<"nextToken">> => string(),
%%   <<"policyScope">> => list(any()),
%%   <<"resourceArn">> => string()
%% }
-type describe_resource_policies_request() :: #{binary() => any()}.

%% Example:
%% associate_source_to_s3_table_integration_request() :: #{
%%   <<"dataSource">> := data_source(),
%%   <<"integrationArn">> := string()
%% }
-type associate_source_to_s3_table_integration_request() :: #{binary() => any()}.

%% Example:
%% delivery() :: #{
%%   <<"arn">> => string(),
%%   <<"deliveryDestinationArn">> => string(),
%%   <<"deliveryDestinationType">> => list(any()),
%%   <<"deliverySourceName">> => string(),
%%   <<"fieldDelimiter">> => string(),
%%   <<"id">> => string(),
%%   <<"recordFields">> => list(string()),
%%   <<"s3DeliveryConfiguration">> => s3_delivery_configuration(),
%%   <<"tags">> => map()
%% }
-type delivery() :: #{binary() => any()}.

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

%% Example:
%% delete_integration_response() :: #{

%% }
-type delete_integration_response() :: #{binary() => any()}.

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

%% Example:
%% describe_log_groups_request() :: #{
%%   <<"accountIdentifiers">> => list(string()),
%%   <<"includeLinkedAccounts">> => boolean(),
%%   <<"limit">> => integer(),
%%   <<"logGroupClass">> => list(any()),
%%   <<"logGroupIdentifiers">> => list(string()),
%%   <<"logGroupNamePattern">> => string(),
%%   <<"logGroupNamePrefix">> => string(),
%%   <<"nextToken">> => string()
%% }
-type describe_log_groups_request() :: #{binary() => any()}.

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

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

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

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

%% Example:
%% trigger_history_record() :: #{
%%   <<"destinations">> => list(scheduled_query_destination()),
%%   <<"errorMessage">> => string(),
%%   <<"executionStatus">> => list(any()),
%%   <<"queryId">> => string(),
%%   <<"triggeredTimestamp">> => float()
%% }
-type trigger_history_record() :: #{binary() => any()}.

%% Example:
%% put_bearer_token_authentication_request() :: #{
%%   <<"bearerTokenAuthenticationEnabled">> := boolean(),
%%   <<"logGroupIdentifier">> := string()
%% }
-type put_bearer_token_authentication_request() :: #{binary() => any()}.

%% Example:
%% put_delivery_destination_policy_request() :: #{
%%   <<"deliveryDestinationName">> := string(),
%%   <<"deliveryDestinationPolicy">> := string()
%% }
-type put_delivery_destination_policy_request() :: #{binary() => any()}.

%% Example:
%% account_policy() :: #{
%%   <<"accountId">> => string(),
%%   <<"lastUpdatedTime">> => float(),
%%   <<"policyDocument">> => string(),
%%   <<"policyName">> => string(),
%%   <<"policyType">> => list(any()),
%%   <<"scope">> => list(any()),
%%   <<"selectionCriteria">> => string()
%% }
-type account_policy() :: #{binary() => any()}.

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

%% Example:
%% open_search_data_source() :: #{
%%   <<"dataSourceName">> => string(),
%%   <<"status">> => open_search_resource_status()
%% }
-type open_search_data_source() :: #{binary() => any()}.

%% Example:
%% delete_index_policy_response() :: #{

%% }
-type delete_index_policy_response() :: #{binary() => any()}.

%% Example:
%% create_export_task_request() :: #{
%%   <<"destination">> := string(),
%%   <<"destinationPrefix">> => string(),
%%   <<"from">> := float(),
%%   <<"logGroupName">> := string(),
%%   <<"logStreamNamePrefix">> => string(),
%%   <<"taskName">> => string(),
%%   <<"to">> := float()
%% }
-type create_export_task_request() :: #{binary() => any()}.

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

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

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

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

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

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

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

%% Example:
%% filter_log_events_response() :: #{
%%   <<"events">> => list(filtered_log_event()),
%%   <<"nextToken">> => string(),
%%   <<"searchedLogStreams">> => list(searched_log_stream())
%% }
-type filter_log_events_response() :: #{binary() => any()}.

%% Example:
%% open_search_resource_config() :: #{
%%   <<"applicationArn">> => string(),
%%   <<"dashboardViewerPrincipals">> => list(string()),
%%   <<"dataSourceRoleArn">> => string(),
%%   <<"kmsKeyArn">> => string(),
%%   <<"retentionDays">> => integer()
%% }
-type open_search_resource_config() :: #{binary() => any()}.

%% Example:
%% put_destination_request() :: #{
%%   <<"destinationName">> := string(),
%%   <<"roleArn">> := string(),
%%   <<"tags">> => map(),
%%   <<"targetArn">> := string()
%% }
-type put_destination_request() :: #{binary() => any()}.

%% Example:
%% log_field_type() :: #{
%%   <<"element">> => log_field_type(),
%%   <<"fields">> => list(log_fields_list_item()),
%%   <<"type">> => string()
%% }
-type log_field_type() :: #{binary() => any()}.

%% Example:
%% get_query_results_response() :: #{
%%   <<"encryptionKey">> => string(),
%%   <<"nextToken">> => string(),
%%   <<"queryLanguage">> => list(any()),
%%   <<"results">> => list(list(result_field())()),
%%   <<"statistics">> => query_statistics(),
%%   <<"status">> => list(any())
%% }
-type get_query_results_response() :: #{binary() => any()}.

%% Example:
%% describe_queries_request() :: #{
%%   <<"logGroupName">> => string(),
%%   <<"maxResults">> => integer(),
%%   <<"nextToken">> => string(),
%%   <<"queryLanguage">> => list(any()),
%%   <<"status">> => list(any())
%% }
-type describe_queries_request() :: #{binary() => any()}.

%% Example:
%% put_account_policy_response() :: #{
%%   <<"accountPolicy">> => account_policy()
%% }
-type put_account_policy_response() :: #{binary() => any()}.

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

%% Example:
%% entity() :: #{
%%   <<"attributes">> => map(),
%%   <<"keyAttributes">> => map()
%% }
-type entity() :: #{binary() => any()}.

%% Example:
%% substitute_string_entry() :: #{
%%   <<"from">> => string(),
%%   <<"source">> => string(),
%%   <<"to">> => string()
%% }
-type substitute_string_entry() :: #{binary() => any()}.

%% Example:
%% list_sources_for_s3_table_integration_response() :: #{
%%   <<"nextToken">> => string(),
%%   <<"sources">> => list(s3_table_integration_source())
%% }
-type list_sources_for_s3_table_integration_response() :: #{binary() => any()}.

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

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

%% Example:
%% split_string_entry() :: #{
%%   <<"delimiter">> => string(),
%%   <<"source">> => string()
%% }
-type split_string_entry() :: #{binary() => any()}.

%% Example:
%% copy_value_entry() :: #{
%%   <<"overwriteIfExists">> => boolean(),
%%   <<"source">> => string(),
%%   <<"target">> => string()
%% }
-type copy_value_entry() :: #{binary() => any()}.

%% Example:
%% list_aggregate_log_group_summaries_request() :: #{
%%   <<"accountIdentifiers">> => list(string()),
%%   <<"dataSources">> => list(data_source_filter()),
%%   <<"groupBy">> := list(any()),
%%   <<"includeLinkedAccounts">> => boolean(),
%%   <<"limit">> => integer(),
%%   <<"logGroupClass">> => list(any()),
%%   <<"logGroupNamePattern">> => string(),
%%   <<"nextToken">> => string()
%% }
-type list_aggregate_log_group_summaries_request() :: #{binary() => any()}.

%% Example:
%% describe_queries_response() :: #{
%%   <<"nextToken">> => string(),
%%   <<"queries">> => list(query_info())
%% }
-type describe_queries_response() :: #{binary() => any()}.

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

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

%% Example:
%% put_log_events_request() :: #{
%%   <<"entity">> => entity(),
%%   <<"logEvents">> := list(input_log_event()),
%%   <<"logGroupName">> := string(),
%%   <<"logStreamName">> := string(),
%%   <<"sequenceToken">> => string()
%% }
-type put_log_events_request() :: #{binary() => any()}.

%% Example:
%% put_account_policy_request() :: #{
%%   <<"policyDocument">> := string(),
%%   <<"policyName">> := string(),
%%   <<"policyType">> := list(any()),
%%   <<"scope">> => list(any()),
%%   <<"selectionCriteria">> => string()
%% }
-type put_account_policy_request() :: #{binary() => any()}.

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

%% Example:
%% describe_lookup_tables_response() :: #{
%%   <<"lookupTables">> => list(lookup_table()),
%%   <<"nextToken">> => string()
%% }
-type describe_lookup_tables_response() :: #{binary() => any()}.

%% Example:
%% create_scheduled_query_response() :: #{
%%   <<"scheduledQueryArn">> => string(),
%%   <<"state">> => list(any())
%% }
-type create_scheduled_query_response() :: #{binary() => any()}.

%% Example:
%% export_task_execution_info() :: #{
%%   <<"completionTime">> => float(),
%%   <<"creationTime">> => float()
%% }
-type export_task_execution_info() :: #{binary() => any()}.

%% Example:
%% put_data_protection_policy_request() :: #{
%%   <<"logGroupIdentifier">> := string(),
%%   <<"policyDocument">> := string()
%% }
-type put_data_protection_policy_request() :: #{binary() => any()}.

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

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

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

%% Example:
%% delete_scheduled_query_response() :: #{

%% }
-type delete_scheduled_query_response() :: #{binary() => any()}.

%% Example:
%% live_tail_session_metadata() :: #{
%%   <<"sampled">> => boolean()
%% }
-type live_tail_session_metadata() :: #{binary() => any()}.

%% Example:
%% create_log_group_request() :: #{
%%   <<"deletionProtectionEnabled">> => boolean(),
%%   <<"kmsKeyId">> => string(),
%%   <<"logGroupClass">> => list(any()),
%%   <<"logGroupName">> := string(),
%%   <<"tags">> => map()
%% }
-type create_log_group_request() :: #{binary() => any()}.

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

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

%% Example:
%% scheduled_query_destination() :: #{
%%   <<"destinationIdentifier">> => string(),
%%   <<"destinationType">> => list(any()),
%%   <<"errorMessage">> => string(),
%%   <<"processedIdentifier">> => string(),
%%   <<"status">> => list(any())
%% }
-type scheduled_query_destination() :: #{binary() => any()}.

%% Example:
%% open_search_encryption_policy() :: #{
%%   <<"policyName">> => string(),
%%   <<"status">> => open_search_resource_status()
%% }
-type open_search_encryption_policy() :: #{binary() => any()}.

%% Example:
%% put_delivery_destination_request() :: #{
%%   <<"deliveryDestinationConfiguration">> => delivery_destination_configuration(),
%%   <<"deliveryDestinationType">> => list(any()),
%%   <<"name">> := string(),
%%   <<"outputFormat">> => list(any()),
%%   <<"tags">> => map()
%% }
-type put_delivery_destination_request() :: #{binary() => any()}.

%% Example:
%% get_delivery_source_response() :: #{
%%   <<"deliverySource">> => delivery_source()
%% }
-type get_delivery_source_response() :: #{binary() => any()}.

%% Example:
%% subscription_filter() :: #{
%%   <<"applyOnTransformedLogs">> => boolean(),
%%   <<"creationTime">> => float(),
%%   <<"destinationArn">> => string(),
%%   <<"distribution">> => list(any()),
%%   <<"emitSystemFields">> => list(string()),
%%   <<"fieldSelectionCriteria">> => string(),
%%   <<"filterName">> => string(),
%%   <<"filterPattern">> => string(),
%%   <<"logGroupName">> => string(),
%%   <<"roleArn">> => string()
%% }
-type subscription_filter() :: #{binary() => any()}.

%% Example:
%% describe_export_tasks_response() :: #{
%%   <<"exportTasks">> => list(export_task()),
%%   <<"nextToken">> => string()
%% }
-type describe_export_tasks_response() :: #{binary() => any()}.

%% Example:
%% live_tail_session_start() :: #{
%%   <<"logEventFilterPattern">> => string(),
%%   <<"logGroupIdentifiers">> => list(string()),
%%   <<"logStreamNamePrefixes">> => list(string()),
%%   <<"logStreamNames">> => list(string()),
%%   <<"requestId">> => string(),
%%   <<"sessionId">> => string()
%% }
-type live_tail_session_start() :: #{binary() => any()}.

%% Example:
%% create_log_stream_request() :: #{
%%   <<"logGroupName">> := string(),
%%   <<"logStreamName">> := string()
%% }
-type create_log_stream_request() :: #{binary() => any()}.

%% Example:
%% describe_import_task_batches_response() :: #{
%%   <<"importBatches">> => list(import_batch()),
%%   <<"importId">> => string(),
%%   <<"importSourceArn">> => string(),
%%   <<"nextToken">> => string()
%% }
-type describe_import_task_batches_response() :: #{binary() => any()}.

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

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

%% Example:
%% list_log_groups_response() :: #{
%%   <<"logGroups">> => list(log_group_summary()),
%%   <<"nextToken">> => string()
%% }
-type list_log_groups_response() :: #{binary() => any()}.

%% Example:
%% put_integration_request() :: #{
%%   <<"integrationName">> := string(),
%%   <<"integrationType">> := list(any()),
%%   <<"resourceConfig">> := list()
%% }
-type put_integration_request() :: #{binary() => any()}.

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

%% Example:
%% describe_account_policies_response() :: #{
%%   <<"accountPolicies">> => list(account_policy()),
%%   <<"nextToken">> => string()
%% }
-type describe_account_policies_response() :: #{binary() => any()}.

%% Example:
%% update_delivery_configuration_response() :: #{

%% }
-type update_delivery_configuration_response() :: #{binary() => any()}.

%% Example:
%% put_log_group_deletion_protection_request() :: #{
%%   <<"deletionProtectionEnabled">> := boolean(),
%%   <<"logGroupIdentifier">> := string()
%% }
-type put_log_group_deletion_protection_request() :: #{binary() => any()}.

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

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

%% Example:
%% update_anomaly_request() :: #{
%%   <<"anomalyDetectorArn">> := string(),
%%   <<"anomalyId">> => string(),
%%   <<"baseline">> => boolean(),
%%   <<"patternId">> => string(),
%%   <<"suppressionPeriod">> => suppression_period(),
%%   <<"suppressionType">> => list(any())
%% }
-type update_anomaly_request() :: #{binary() => any()}.

%% Example:
%% create_scheduled_query_request() :: #{
%%   <<"description">> => string(),
%%   <<"destinationConfiguration">> => destination_configuration(),
%%   <<"executionRoleArn">> := string(),
%%   <<"logGroupIdentifiers">> => list(string()),
%%   <<"name">> := string(),
%%   <<"queryLanguage">> := list(any()),
%%   <<"queryString">> := string(),
%%   <<"scheduleEndTime">> => float(),
%%   <<"scheduleExpression">> := string(),
%%   <<"scheduleStartTime">> => float(),
%%   <<"startTimeOffset">> => float(),
%%   <<"state">> => list(any()),
%%   <<"tags">> => map(),
%%   <<"timezone">> => string()
%% }
-type create_scheduled_query_request() :: #{binary() => any()}.

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

%% Example:
%% put_retention_policy_request() :: #{
%%   <<"logGroupName">> := string(),
%%   <<"retentionInDays">> := integer()
%% }
-type put_retention_policy_request() :: #{binary() => any()}.

%% Example:
%% start_query_request() :: #{
%%   <<"endTime">> := float(),
%%   <<"limit">> => integer(),
%%   <<"logGroupIdentifiers">> => list(string()),
%%   <<"logGroupName">> => string(),
%%   <<"logGroupNames">> => list(string()),
%%   <<"queryLanguage">> => list(any()),
%%   <<"queryString">> := string(),
%%   <<"startTime">> := float()
%% }
-type start_query_request() :: #{binary() => any()}.

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

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

%% Example:
%% import_statistics() :: #{
%%   <<"bytesImported">> => float()
%% }
-type import_statistics() :: #{binary() => any()}.

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

%% Example:
%% update_log_anomaly_detector_request() :: #{
%%   <<"anomalyDetectorArn">> := string(),
%%   <<"anomalyVisibilityTime">> => float(),
%%   <<"enabled">> := boolean(),
%%   <<"evaluationFrequency">> => list(any()),
%%   <<"filterPattern">> => string()
%% }
-type update_log_anomaly_detector_request() :: #{binary() => any()}.

%% Example:
%% describe_metric_filters_request() :: #{
%%   <<"filterNamePrefix">> => string(),
%%   <<"limit">> => integer(),
%%   <<"logGroupName">> => string(),
%%   <<"metricName">> => string(),
%%   <<"metricNamespace">> => string(),
%%   <<"nextToken">> => string()
%% }
-type describe_metric_filters_request() :: #{binary() => any()}.

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

%% Example:
%% put_data_protection_policy_response() :: #{
%%   <<"lastUpdatedTime">> => float(),
%%   <<"logGroupIdentifier">> => string(),
%%   <<"policyDocument">> => string()
%% }
-type put_data_protection_policy_response() :: #{binary() => any()}.

%% Example:
%% integration_summary() :: #{
%%   <<"integrationName">> => string(),
%%   <<"integrationStatus">> => list(any()),
%%   <<"integrationType">> => list(any())
%% }
-type integration_summary() :: #{binary() => any()}.

%% Example:
%% field_index() :: #{
%%   <<"fieldIndexName">> => string(),
%%   <<"firstEventTime">> => float(),
%%   <<"lastEventTime">> => float(),
%%   <<"lastScanTime">> => float(),
%%   <<"logGroupIdentifier">> => string(),
%%   <<"type">> => list(any())
%% }
-type field_index() :: #{binary() => any()}.

%% Example:
%% processor() :: #{
%%   <<"addKeys">> => add_keys(),
%%   <<"copyValue">> => copy_value(),
%%   <<"csv">> => csv(),
%%   <<"dateTimeConverter">> => date_time_converter(),
%%   <<"deleteKeys">> => delete_keys(),
%%   <<"grok">> => grok(),
%%   <<"listToMap">> => list_to_map(),
%%   <<"lowerCaseString">> => lower_case_string(),
%%   <<"moveKeys">> => move_keys(),
%%   <<"parseCloudfront">> => parse_cloudfront(),
%%   <<"parseJSON">> => parse_json(),
%%   <<"parseKeyValue">> => parse_key_value(),
%%   <<"parsePostgres">> => parse_postgres(),
%%   <<"parseRoute53">> => parse_route53(),
%%   <<"parseToOCSF">> => parse_to_o_c_s_f(),
%%   <<"parseVPC">> => parse_vpc(),
%%   <<"parseWAF">> => parse_w_a_f(),
%%   <<"renameKeys">> => rename_keys(),
%%   <<"splitString">> => split_string(),
%%   <<"substituteString">> => substitute_string(),
%%   <<"trimString">> => trim_string(),
%%   <<"typeConverter">> => type_converter(),
%%   <<"upperCaseString">> => upper_case_string()
%% }
-type processor() :: #{binary() => any()}.

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

%% Example:
%% put_index_policy_response() :: #{
%%   <<"indexPolicy">> => index_policy()
%% }
-type put_index_policy_response() :: #{binary() => any()}.

%% Example:
%% configuration_template() :: #{
%%   <<"allowedActionForAllowVendedLogsDeliveryForResource">> => string(),
%%   <<"allowedFieldDelimiters">> => list(string()),
%%   <<"allowedFields">> => list(record_field()),
%%   <<"allowedOutputFormats">> => list(list(any())()),
%%   <<"allowedSuffixPathFields">> => list(string()),
%%   <<"defaultDeliveryConfigValues">> => configuration_template_delivery_config_values(),
%%   <<"deliveryDestinationType">> => list(any()),
%%   <<"deliverySourceConfiguration">> => list(delivery_source_configuration_schema()),
%%   <<"logType">> => string(),
%%   <<"resourceType">> => string(),
%%   <<"s3TablesIntegration">> => s3_tables_integration(),
%%   <<"service">> => string()
%% }
-type configuration_template() :: #{binary() => any()}.

%% Example:
%% put_integration_response() :: #{
%%   <<"integrationName">> => string(),
%%   <<"integrationStatus">> => list(any())
%% }
-type put_integration_response() :: #{binary() => any()}.

%% Example:
%% describe_destinations_response() :: #{
%%   <<"destinations">> => list(destination()),
%%   <<"nextToken">> => string()
%% }
-type describe_destinations_response() :: #{binary() => any()}.

%% Example:
%% live_tail_session_update() :: #{
%%   <<"sessionMetadata">> => live_tail_session_metadata(),
%%   <<"sessionResults">> => list(live_tail_session_log_event())
%% }
-type live_tail_session_update() :: #{binary() => any()}.

%% Example:
%% get_transformer_response() :: #{
%%   <<"creationTime">> => float(),
%%   <<"lastModifiedTime">> => float(),
%%   <<"logGroupIdentifier">> => string(),
%%   <<"transformerConfig">> => list(processor())
%% }
-type get_transformer_response() :: #{binary() => any()}.

%% Example:
%% transformed_log_record() :: #{
%%   <<"eventMessage">> => string(),
%%   <<"eventNumber">> => float(),
%%   <<"transformedEventMessage">> => string()
%% }
-type transformed_log_record() :: #{binary() => any()}.

%% Example:
%% query_compile_error_location() :: #{
%%   <<"endCharOffset">> => integer(),
%%   <<"startCharOffset">> => integer()
%% }
-type query_compile_error_location() :: #{binary() => any()}.

%% Example:
%% list_log_groups_request() :: #{
%%   <<"accountIdentifiers">> => list(string()),
%%   <<"dataSources">> => list(data_source_filter()),
%%   <<"fieldIndexNames">> => list(string()),
%%   <<"includeLinkedAccounts">> => boolean(),
%%   <<"limit">> => integer(),
%%   <<"logGroupClass">> => list(any()),
%%   <<"logGroupNamePattern">> => string(),
%%   <<"logGroupTags">> => list(tag_filter()),
%%   <<"nextToken">> => string()
%% }
-type list_log_groups_request() :: #{binary() => any()}.

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

%% Example:
%% list_integrations_request() :: #{
%%   <<"integrationNamePrefix">> => string(),
%%   <<"integrationStatus">> => list(any()),
%%   <<"integrationType">> => list(any())
%% }
-type list_integrations_request() :: #{binary() => any()}.

%% Example:
%% create_import_task_response() :: #{
%%   <<"creationTime">> => float(),
%%   <<"importDestinationArn">> => string(),
%%   <<"importId">> => string()
%% }
-type create_import_task_response() :: #{binary() => any()}.

%% Example:
%% delivery_source_configuration_schema() :: #{
%%   <<"defaultValue">> => string(),
%%   <<"keyName">> => string(),
%%   <<"maxValue">> => float(),
%%   <<"minValue">> => float(),
%%   <<"supportedValues">> => list(string()),
%%   <<"valueType">> => list(any())
%% }
-type delivery_source_configuration_schema() :: #{binary() => any()}.

%% Example:
%% describe_query_definitions_response() :: #{
%%   <<"nextToken">> => string(),
%%   <<"queryDefinitions">> => list(query_definition())
%% }
-type describe_query_definitions_response() :: #{binary() => any()}.

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

%% Example:
%% get_log_fields_request() :: #{
%%   <<"dataSourceName">> := string(),
%%   <<"dataSourceType">> := string()
%% }
-type get_log_fields_request() :: #{binary() => any()}.

%% Example:
%% describe_subscription_filters_request() :: #{
%%   <<"filterNamePrefix">> => string(),
%%   <<"limit">> => integer(),
%%   <<"logGroupName">> := string(),
%%   <<"nextToken">> => string()
%% }
-type describe_subscription_filters_request() :: #{binary() => any()}.

%% Example:
%% put_destination_policy_request() :: #{
%%   <<"accessPolicy">> := string(),
%%   <<"destinationName">> := string(),
%%   <<"forceUpdate">> => boolean()
%% }
-type put_destination_policy_request() :: #{binary() => any()}.

%% Example:
%% get_integration_response() :: #{
%%   <<"integrationDetails">> => list(),
%%   <<"integrationName">> => string(),
%%   <<"integrationStatus">> => list(any()),
%%   <<"integrationType">> => list(any())
%% }
-type get_integration_response() :: #{binary() => any()}.

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

%% Example:
%% input_log_event() :: #{
%%   <<"message">> => string(),
%%   <<"timestamp">> => float()
%% }
-type input_log_event() :: #{binary() => any()}.

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

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

%% Example:
%% malformed_query_exception() :: #{
%%   <<"message">> => string(),
%%   <<"queryCompileError">> => query_compile_error()
%% }
-type malformed_query_exception() :: #{binary() => any()}.

%% Example:
%% live_tail_session_log_event() :: #{
%%   <<"ingestionTime">> => float(),
%%   <<"logGroupIdentifier">> => string(),
%%   <<"logStreamName">> => string(),
%%   <<"message">> => string(),
%%   <<"timestamp">> => float()
%% }
-type live_tail_session_log_event() :: #{binary() => any()}.

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

%% Example:
%% aggregate_log_group_summary() :: #{
%%   <<"groupingIdentifiers">> => list(grouping_identifier()),
%%   <<"logGroupCount">> => integer()
%% }
-type aggregate_log_group_summary() :: #{binary() => any()}.

%% Example:
%% list_aggregate_log_group_summaries_response() :: #{
%%   <<"aggregateLogGroupSummaries">> => list(aggregate_log_group_summary()),
%%   <<"nextToken">> => string()
%% }
-type list_aggregate_log_group_summaries_response() :: #{binary() => any()}.

%% Example:
%% s3_delivery_configuration() :: #{
%%   <<"enableHiveCompatiblePath">> => boolean(),
%%   <<"suffixPath">> => string()
%% }
-type s3_delivery_configuration() :: #{binary() => any()}.

%% Example:
%% get_delivery_destination_request() :: #{
%%   <<"name">> := string()
%% }
-type get_delivery_destination_request() :: #{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:
%% delete_integration_request() :: #{
%%   <<"force">> => boolean(),
%%   <<"integrationName">> := string()
%% }
-type delete_integration_request() :: #{binary() => any()}.

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

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

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

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

%% Example:
%% disassociate_kms_key_request() :: #{
%%   <<"logGroupName">> => string(),
%%   <<"resourceIdentifier">> => string()
%% }
-type disassociate_kms_key_request() :: #{binary() => any()}.

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

%% Example:
%% describe_export_tasks_request() :: #{
%%   <<"limit">> => integer(),
%%   <<"nextToken">> => string(),
%%   <<"statusCode">> => list(any()),
%%   <<"taskId">> => string()
%% }
-type describe_export_tasks_request() :: #{binary() => any()}.

%% Example:
%% open_search_collection() :: #{
%%   <<"collectionArn">> => string(),
%%   <<"collectionEndpoint">> => string(),
%%   <<"status">> => open_search_resource_status()
%% }
-type open_search_collection() :: #{binary() => any()}.

%% Example:
%% get_log_anomaly_detector_response() :: #{
%%   <<"anomalyDetectorStatus">> => list(any()),
%%   <<"anomalyVisibilityTime">> => float(),
%%   <<"creationTimeStamp">> => float(),
%%   <<"detectorName">> => string(),
%%   <<"evaluationFrequency">> => list(any()),
%%   <<"filterPattern">> => string(),
%%   <<"kmsKeyId">> => string(),
%%   <<"lastModifiedTimeStamp">> => float(),
%%   <<"logGroupArnList">> => list(string())
%% }
-type get_log_anomaly_detector_response() :: #{binary() => any()}.

%% Example:
%% delete_query_definition_response() :: #{
%%   <<"success">> => boolean()
%% }
-type delete_query_definition_response() :: #{binary() => any()}.

%% Example:
%% describe_log_streams_response() :: #{
%%   <<"logStreams">> => list(log_stream()),
%%   <<"nextToken">> => string()
%% }
-type describe_log_streams_response() :: #{binary() => any()}.

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

%% Example:
%% export_task_status() :: #{
%%   <<"code">> => list(any()),
%%   <<"message">> => string()
%% }
-type export_task_status() :: #{binary() => any()}.

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

%% Example:
%% lookup_table() :: #{
%%   <<"description">> => string(),
%%   <<"kmsKeyId">> => string(),
%%   <<"lastUpdatedTime">> => float(),
%%   <<"lookupTableArn">> => string(),
%%   <<"lookupTableName">> => string(),
%%   <<"recordsCount">> => float(),
%%   <<"sizeBytes">> => float(),
%%   <<"tableFields">> => list(string())
%% }
-type lookup_table() :: #{binary() => any()}.

%% Example:
%% suppression_period() :: #{
%%   <<"suppressionUnit">> => list(any()),
%%   <<"value">> => integer()
%% }
-type suppression_period() :: #{binary() => any()}.

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

%% Example:
%% pattern_token() :: #{
%%   <<"dynamicTokenPosition">> => integer(),
%%   <<"enumerations">> => map(),
%%   <<"inferredTokenName">> => string(),
%%   <<"isDynamic">> => boolean(),
%%   <<"tokenString">> => string()
%% }
-type pattern_token() :: #{binary() => any()}.

%% Example:
%% delete_log_stream_request() :: #{
%%   <<"logGroupName">> := string(),
%%   <<"logStreamName">> := string()
%% }
-type delete_log_stream_request() :: #{binary() => any()}.

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

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

%% Example:
%% open_search_data_access_policy() :: #{
%%   <<"policyName">> => string(),
%%   <<"status">> => open_search_resource_status()
%% }
-type open_search_data_access_policy() :: #{binary() => any()}.

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

%% Example:
%% describe_delivery_destinations_response() :: #{
%%   <<"deliveryDestinations">> => list(delivery_destination()),
%%   <<"nextToken">> => string()
%% }
-type describe_delivery_destinations_response() :: #{binary() => any()}.

%% Example:
%% csv() :: #{
%%   <<"columns">> => list(string()),
%%   <<"delimiter">> => string(),
%%   <<"destination">> => string(),
%%   <<"quoteCharacter">> => string(),
%%   <<"source">> => string()
%% }
-type csv() :: #{binary() => any()}.

%% Example:
%% rename_key_entry() :: #{
%%   <<"key">> => string(),
%%   <<"overwriteIfExists">> => boolean(),
%%   <<"renameTo">> => string()
%% }
-type rename_key_entry() :: #{binary() => any()}.

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

%% Example:
%% associate_kms_key_request() :: #{
%%   <<"kmsKeyId">> := string(),
%%   <<"logGroupName">> => string(),
%%   <<"resourceIdentifier">> => string()
%% }
-type associate_kms_key_request() :: #{binary() => any()}.

%% Example:
%% get_log_record_request() :: #{
%%   <<"logRecordPointer">> := string(),
%%   <<"unmask">> => boolean()
%% }
-type get_log_record_request() :: #{binary() => any()}.

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

%% Example:
%% metric_filter_match_record() :: #{
%%   <<"eventMessage">> => string(),
%%   <<"eventNumber">> => float(),
%%   <<"extractedValues">> => map()
%% }
-type metric_filter_match_record() :: #{binary() => any()}.

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

%% Example:
%% open_search_workspace() :: #{
%%   <<"status">> => open_search_resource_status(),
%%   <<"workspaceId">> => string()
%% }
-type open_search_workspace() :: #{binary() => any()}.

%% Example:
%% stop_query_response() :: #{
%%   <<"success">> => boolean()
%% }
-type stop_query_response() :: #{binary() => any()}.

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

%% Example:
%% put_delivery_source_request() :: #{
%%   <<"deliverySourceConfiguration">> => map(),
%%   <<"logType">> := string(),
%%   <<"name">> := string(),
%%   <<"resourceArn">> := string(),
%%   <<"tags">> => map()
%% }
-type put_delivery_source_request() :: #{binary() => any()}.

%% Example:
%% get_scheduled_query_response() :: #{
%%   <<"creationTime">> => float(),
%%   <<"description">> => string(),
%%   <<"destinationConfiguration">> => destination_configuration(),
%%   <<"executionRoleArn">> => string(),
%%   <<"lastExecutionStatus">> => list(any()),
%%   <<"lastTriggeredTime">> => float(),
%%   <<"lastUpdatedTime">> => float(),
%%   <<"logGroupIdentifiers">> => list(string()),
%%   <<"name">> => string(),
%%   <<"queryLanguage">> => list(any()),
%%   <<"queryString">> => string(),
%%   <<"scheduleEndTime">> => float(),
%%   <<"scheduleExpression">> => string(),
%%   <<"scheduleStartTime">> => float(),
%%   <<"scheduledQueryArn">> => string(),
%%   <<"startTimeOffset">> => float(),
%%   <<"state">> => list(any()),
%%   <<"timezone">> => string()
%% }
-type get_scheduled_query_response() :: #{binary() => any()}.

%% Example:
%% describe_field_indexes_response() :: #{
%%   <<"fieldIndexes">> => list(field_index()),
%%   <<"nextToken">> => string()
%% }
-type describe_field_indexes_response() :: #{binary() => any()}.

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

%% Example:
%% open_search_network_policy() :: #{
%%   <<"policyName">> => string(),
%%   <<"status">> => open_search_resource_status()
%% }
-type open_search_network_policy() :: #{binary() => any()}.

%% Example:
%% put_transformer_request() :: #{
%%   <<"logGroupIdentifier">> := string(),
%%   <<"transformerConfig">> := list(processor())
%% }
-type put_transformer_request() :: #{binary() => any()}.

%% Example:
%% log_stream() :: #{
%%   <<"arn">> => string(),
%%   <<"creationTime">> => float(),
%%   <<"firstEventTimestamp">> => float(),
%%   <<"lastEventTimestamp">> => float(),
%%   <<"lastIngestionTime">> => float(),
%%   <<"logStreamName">> => string(),
%%   <<"storedBytes">> => float(),
%%   <<"uploadSequenceToken">> => string()
%% }
-type log_stream() :: #{binary() => any()}.

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

%% Example:
%% put_metric_filter_request() :: #{
%%   <<"applyOnTransformedLogs">> => boolean(),
%%   <<"emitSystemFieldDimensions">> => list(string()),
%%   <<"fieldSelectionCriteria">> => string(),
%%   <<"filterName">> := string(),
%%   <<"filterPattern">> := string(),
%%   <<"logGroupName">> := string(),
%%   <<"metricTransformations">> := list(metric_transformation())
%% }
-type put_metric_filter_request() :: #{binary() => any()}.

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

%% Example:
%% describe_index_policies_response() :: #{
%%   <<"indexPolicies">> => list(index_policy()),
%%   <<"nextToken">> => string()
%% }
-type describe_index_policies_response() :: #{binary() => any()}.

%% Example:
%% cancel_import_task_response() :: #{
%%   <<"creationTime">> => float(),
%%   <<"importId">> => string(),
%%   <<"importStatistics">> => import_statistics(),
%%   <<"importStatus">> => list(any()),
%%   <<"lastUpdatedTime">> => float()
%% }
-type cancel_import_task_response() :: #{binary() => any()}.

%% Example:
%% filter_log_events_request() :: #{
%%   <<"endTime">> => float(),
%%   <<"filterPattern">> => string(),
%%   <<"interleaved">> => boolean(),
%%   <<"limit">> => integer(),
%%   <<"logGroupIdentifier">> => string(),
%%   <<"logGroupName">> => string(),
%%   <<"logStreamNamePrefix">> => string(),
%%   <<"logStreamNames">> => list(string()),
%%   <<"nextToken">> => string(),
%%   <<"startTime">> => float(),
%%   <<"unmask">> => boolean()
%% }
-type filter_log_events_request() :: #{binary() => any()}.

%% Example:
%% describe_deliveries_response() :: #{
%%   <<"deliveries">> => list(delivery()),
%%   <<"nextToken">> => string()
%% }
-type describe_deliveries_response() :: #{binary() => any()}.

%% Example:
%% grok() :: #{
%%   <<"match">> => string(),
%%   <<"source">> => string()
%% }
-type grok() :: #{binary() => any()}.

%% Example:
%% log_group_summary() :: #{
%%   <<"logGroupArn">> => string(),
%%   <<"logGroupClass">> => list(any()),
%%   <<"logGroupName">> => string()
%% }
-type log_group_summary() :: #{binary() => any()}.

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

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

%% Example:
%% parse_key_value() :: #{
%%   <<"destination">> => string(),
%%   <<"fieldDelimiter">> => string(),
%%   <<"keyPrefix">> => string(),
%%   <<"keyValueDelimiter">> => string(),
%%   <<"nonMatchValue">> => string(),
%%   <<"overwriteIfExists">> => boolean(),
%%   <<"source">> => string()
%% }
-type parse_key_value() :: #{binary() => any()}.

%% Example:
%% log_fields_list_item() :: #{
%%   <<"logFieldName">> => string(),
%%   <<"logFieldType">> => log_field_type()
%% }
-type log_fields_list_item() :: #{binary() => any()}.

%% Example:
%% delete_account_policy_request() :: #{
%%   <<"policyName">> := string(),
%%   <<"policyType">> := list(any())
%% }
-type delete_account_policy_request() :: #{binary() => any()}.

%% Example:
%% get_lookup_table_response() :: #{
%%   <<"description">> => string(),
%%   <<"kmsKeyId">> => string(),
%%   <<"lastUpdatedTime">> => float(),
%%   <<"lookupTableArn">> => string(),
%%   <<"lookupTableName">> => string(),
%%   <<"sizeBytes">> => float(),
%%   <<"tableBody">> => string()
%% }
-type get_lookup_table_response() :: #{binary() => any()}.

%% Example:
%% describe_log_groups_response() :: #{
%%   <<"logGroups">> => list(log_group()),
%%   <<"nextToken">> => string()
%% }
-type describe_log_groups_response() :: #{binary() => any()}.

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

%% Example:
%% untag_log_group_request() :: #{
%%   <<"logGroupName">> := string(),
%%   <<"tags">> := list(string())
%% }
-type untag_log_group_request() :: #{binary() => any()}.

%% Example:
%% put_subscription_filter_request() :: #{
%%   <<"applyOnTransformedLogs">> => boolean(),
%%   <<"destinationArn">> := string(),
%%   <<"distribution">> => list(any()),
%%   <<"emitSystemFields">> => list(string()),
%%   <<"fieldSelectionCriteria">> => string(),
%%   <<"filterName">> := string(),
%%   <<"filterPattern">> := string(),
%%   <<"logGroupName">> := string(),
%%   <<"roleArn">> => string()
%% }
-type put_subscription_filter_request() :: #{binary() => any()}.

%% Example:
%% describe_delivery_sources_response() :: #{
%%   <<"deliverySources">> => list(delivery_source()),
%%   <<"nextToken">> => string()
%% }
-type describe_delivery_sources_response() :: #{binary() => any()}.

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

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

%% Example:
%% scheduled_query_summary() :: #{
%%   <<"creationTime">> => float(),
%%   <<"destinationConfiguration">> => destination_configuration(),
%%   <<"lastExecutionStatus">> => list(any()),
%%   <<"lastTriggeredTime">> => float(),
%%   <<"lastUpdatedTime">> => float(),
%%   <<"name">> => string(),
%%   <<"scheduleExpression">> => string(),
%%   <<"scheduledQueryArn">> => string(),
%%   <<"state">> => list(any()),
%%   <<"timezone">> => string()
%% }
-type scheduled_query_summary() :: #{binary() => any()}.

%% Example:
%% open_search_lifecycle_policy() :: #{
%%   <<"policyName">> => string(),
%%   <<"status">> => open_search_resource_status()
%% }
-type open_search_lifecycle_policy() :: #{binary() => any()}.

%% Example:
%% delivery_destination() :: #{
%%   <<"arn">> => string(),
%%   <<"deliveryDestinationConfiguration">> => delivery_destination_configuration(),
%%   <<"deliveryDestinationType">> => list(any()),
%%   <<"name">> => string(),
%%   <<"outputFormat">> => list(any()),
%%   <<"tags">> => map()
%% }
-type delivery_destination() :: #{binary() => any()}.

%% Example:
%% list_to_map() :: #{
%%   <<"flatten">> => boolean(),
%%   <<"flattenedElement">> => list(any()),
%%   <<"key">> => string(),
%%   <<"source">> => string(),
%%   <<"target">> => string(),
%%   <<"valueKey">> => string()
%% }
-type list_to_map() :: #{binary() => any()}.

%% Example:
%% query_compile_error() :: #{
%%   <<"location">> => query_compile_error_location(),
%%   <<"message">> => string()
%% }
-type query_compile_error() :: #{binary() => any()}.

%% Example:
%% get_delivery_destination_response() :: #{
%%   <<"deliveryDestination">> => delivery_destination()
%% }
-type get_delivery_destination_response() :: #{binary() => any()}.

%% Example:
%% create_log_anomaly_detector_request() :: #{
%%   <<"anomalyVisibilityTime">> => float(),
%%   <<"detectorName">> => string(),
%%   <<"evaluationFrequency">> => list(any()),
%%   <<"filterPattern">> => string(),
%%   <<"kmsKeyId">> => string(),
%%   <<"logGroupArnList">> := list(string()),
%%   <<"tags">> => map()
%% }
-type create_log_anomaly_detector_request() :: #{binary() => any()}.

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

%% Example:
%% describe_import_task_batches_request() :: #{
%%   <<"batchImportStatus">> => list(list(any())()),
%%   <<"importId">> := string(),
%%   <<"limit">> => integer(),
%%   <<"nextToken">> => string()
%% }
-type describe_import_task_batches_request() :: #{binary() => any()}.

%% Example:
%% get_scheduled_query_history_request() :: #{
%%   <<"endTime">> := float(),
%%   <<"executionStatuses">> => list(list(any())()),
%%   <<"identifier">> := string(),
%%   <<"maxResults">> => integer(),
%%   <<"nextToken">> => string(),
%%   <<"startTime">> := float()
%% }
-type get_scheduled_query_history_request() :: #{binary() => any()}.

%% Example:
%% update_delivery_configuration_request() :: #{
%%   <<"fieldDelimiter">> => string(),
%%   <<"id">> := string(),
%%   <<"recordFields">> => list(string()),
%%   <<"s3DeliveryConfiguration">> => s3_delivery_configuration()
%% }
-type update_delivery_configuration_request() :: #{binary() => any()}.

%% Example:
%% get_log_group_fields_request() :: #{
%%   <<"logGroupIdentifier">> => string(),
%%   <<"logGroupName">> => string(),
%%   <<"time">> => float()
%% }
-type get_log_group_fields_request() :: #{binary() => any()}.

%% Example:
%% put_query_definition_request() :: #{
%%   <<"clientToken">> => string(),
%%   <<"logGroupNames">> => list(string()),
%%   <<"name">> := string(),
%%   <<"parameters">> => list(query_parameter()),
%%   <<"queryDefinitionId">> => string(),
%%   <<"queryLanguage">> => list(any()),
%%   <<"queryString">> := string()
%% }
-type put_query_definition_request() :: #{binary() => any()}.

%% Example:
%% export_task() :: #{
%%   <<"destination">> => string(),
%%   <<"destinationPrefix">> => string(),
%%   <<"executionInfo">> => export_task_execution_info(),
%%   <<"from">> => float(),
%%   <<"logGroupName">> => string(),
%%   <<"status">> => export_task_status(),
%%   <<"taskId">> => string(),
%%   <<"taskName">> => string(),
%%   <<"to">> => float()
%% }
-type export_task() :: #{binary() => any()}.

%% Example:
%% create_lookup_table_response() :: #{
%%   <<"createdAt">> => float(),
%%   <<"lookupTableArn">> => string()
%% }
-type create_lookup_table_response() :: #{binary() => any()}.

%% Example:
%% metric_transformation() :: #{
%%   <<"defaultValue">> => float(),
%%   <<"dimensions">> => map(),
%%   <<"metricName">> => string(),
%%   <<"metricNamespace">> => string(),
%%   <<"metricValue">> => string(),
%%   <<"unit">> => list(any())
%% }
-type metric_transformation() :: #{binary() => any()}.

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

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

%% Example:
%% resource_policy() :: #{
%%   <<"lastUpdatedTime">> => float(),
%%   <<"policyDocument">> => string(),
%%   <<"policyName">> => string(),
%%   <<"policyScope">> => list(any()),
%%   <<"resourceArn">> => string(),
%%   <<"revisionId">> => string()
%% }
-type resource_policy() :: #{binary() => any()}.

%% Example:
%% anomaly() :: #{
%%   <<"active">> => boolean(),
%%   <<"anomalyDetectorArn">> => string(),
%%   <<"anomalyId">> => string(),
%%   <<"description">> => string(),
%%   <<"firstSeen">> => float(),
%%   <<"histogram">> => map(),
%%   <<"isPatternLevelSuppression">> => boolean(),
%%   <<"lastSeen">> => float(),
%%   <<"logGroupArnList">> => list(string()),
%%   <<"logSamples">> => list(log_event()),
%%   <<"patternId">> => string(),
%%   <<"patternRegex">> => string(),
%%   <<"patternString">> => string(),
%%   <<"patternTokens">> => list(pattern_token()),
%%   <<"priority">> => string(),
%%   <<"state">> => list(any()),
%%   <<"suppressed">> => boolean(),
%%   <<"suppressedDate">> => float(),
%%   <<"suppressedUntil">> => float()
%% }
-type anomaly() :: #{binary() => any()}.

%% Example:
%% list_anomalies_request() :: #{
%%   <<"anomalyDetectorArn">> => string(),
%%   <<"limit">> => integer(),
%%   <<"nextToken">> => string(),
%%   <<"suppressionState">> => list(any())
%% }
-type list_anomalies_request() :: #{binary() => any()}.

%% Example:
%% put_delivery_destination_response() :: #{
%%   <<"deliveryDestination">> => delivery_destination()
%% }
-type put_delivery_destination_response() :: #{binary() => any()}.

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

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

%% Example:
%% create_import_task_request() :: #{
%%   <<"importFilter">> => import_filter(),
%%   <<"importRoleArn">> := string(),
%%   <<"importSourceArn">> := string()
%% }
-type create_import_task_request() :: #{binary() => any()}.

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

%% Example:
%% update_lookup_table_response() :: #{
%%   <<"lastUpdatedTime">> => float(),
%%   <<"lookupTableArn">> => string()
%% }
-type update_lookup_table_response() :: #{binary() => any()}.

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

%% Example:
%% start_live_tail_request() :: #{
%%   <<"logEventFilterPattern">> => string(),
%%   <<"logGroupIdentifiers">> := list(string()),
%%   <<"logStreamNamePrefixes">> => list(string()),
%%   <<"logStreamNames">> => list(string())
%% }
-type start_live_tail_request() :: #{binary() => any()}.

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

%% Example:
%% filtered_log_event() :: #{
%%   <<"eventId">> => string(),
%%   <<"ingestionTime">> => float(),
%%   <<"logStreamName">> => string(),
%%   <<"message">> => string(),
%%   <<"timestamp">> => float()
%% }
-type filtered_log_event() :: #{binary() => any()}.

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

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

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

%% Example:
%% put_resource_policy_request() :: #{
%%   <<"expectedRevisionId">> => string(),
%%   <<"policyDocument">> => string(),
%%   <<"policyName">> => string(),
%%   <<"resourceArn">> => string()
%% }
-type put_resource_policy_request() :: #{binary() => any()}.

%% Example:
%% update_scheduled_query_request() :: #{
%%   <<"description">> => string(),
%%   <<"destinationConfiguration">> => destination_configuration(),
%%   <<"executionRoleArn">> := string(),
%%   <<"identifier">> := string(),
%%   <<"logGroupIdentifiers">> => list(string()),
%%   <<"queryLanguage">> := list(any()),
%%   <<"queryString">> := string(),
%%   <<"scheduleEndTime">> => float(),
%%   <<"scheduleExpression">> := string(),
%%   <<"scheduleStartTime">> => float(),
%%   <<"startTimeOffset">> => float(),
%%   <<"state">> => list(any()),
%%   <<"timezone">> => string()
%% }
-type update_scheduled_query_request() :: #{binary() => any()}.

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

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

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

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

%% Example:
%% import_filter() :: #{
%%   <<"endEventTime">> => float(),
%%   <<"startEventTime">> => float()
%% }
-type import_filter() :: #{binary() => any()}.

%% Example:
%% open_search_integration_details() :: #{
%%   <<"accessPolicy">> => open_search_data_access_policy(),
%%   <<"application">> => open_search_application(),
%%   <<"collection">> => open_search_collection(),
%%   <<"dataSource">> => open_search_data_source(),
%%   <<"encryptionPolicy">> => open_search_encryption_policy(),
%%   <<"lifecyclePolicy">> => open_search_lifecycle_policy(),
%%   <<"networkPolicy">> => open_search_network_policy(),
%%   <<"workspace">> => open_search_workspace()
%% }
-type open_search_integration_details() :: #{binary() => any()}.

%% Example:
%% move_key_entry() :: #{
%%   <<"overwriteIfExists">> => boolean(),
%%   <<"source">> => string(),
%%   <<"target">> => string()
%% }
-type move_key_entry() :: #{binary() => any()}.

%% Example:
%% get_log_events_request() :: #{
%%   <<"endTime">> => float(),
%%   <<"limit">> => integer(),
%%   <<"logGroupIdentifier">> => string(),
%%   <<"logGroupName">> => string(),
%%   <<"logStreamName">> := string(),
%%   <<"nextToken">> => string(),
%%   <<"startFromHead">> => boolean(),
%%   <<"startTime">> => float(),
%%   <<"unmask">> => boolean()
%% }
-type get_log_events_request() :: #{binary() => any()}.

%% Example:
%% parse_to_o_c_s_f() :: #{
%%   <<"eventSource">> => list(any()),
%%   <<"mappingVersion">> => string(),
%%   <<"ocsfVersion">> => list(any()),
%%   <<"source">> => string()
%% }
-type parse_to_o_c_s_f() :: #{binary() => any()}.

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

%% Example:
%% rejected_log_events_info() :: #{
%%   <<"expiredLogEventEndIndex">> => integer(),
%%   <<"tooNewLogEventStartIndex">> => integer(),
%%   <<"tooOldLogEventEndIndex">> => integer()
%% }
-type rejected_log_events_info() :: #{binary() => any()}.

%% Example:
%% list_scheduled_queries_response() :: #{
%%   <<"nextToken">> => string(),
%%   <<"scheduledQueries">> => list(scheduled_query_summary())
%% }
-type list_scheduled_queries_response() :: #{binary() => any()}.

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

%% Example:
%% s3_table_integration_source() :: #{
%%   <<"createdTimeStamp">> => float(),
%%   <<"dataSource">> => data_source(),
%%   <<"identifier">> => string(),
%%   <<"parentSourceIdentifier">> => string(),
%%   <<"status">> => list(any()),
%%   <<"statusReason">> => string()
%% }
-type s3_table_integration_source() :: #{binary() => any()}.

%% Example:
%% get_log_events_response() :: #{
%%   <<"events">> => list(output_log_event()),
%%   <<"nextBackwardToken">> => string(),
%%   <<"nextForwardToken">> => string()
%% }
-type get_log_events_response() :: #{binary() => any()}.

%% Example:
%% output_log_event() :: #{
%%   <<"ingestionTime">> => float(),
%%   <<"message">> => string(),
%%   <<"timestamp">> => float()
%% }
-type output_log_event() :: #{binary() => any()}.

%% Example:
%% searched_log_stream() :: #{
%%   <<"logStreamName">> => string(),
%%   <<"searchedCompletely">> => boolean()
%% }
-type searched_log_stream() :: #{binary() => any()}.

%% Example:
%% describe_account_policies_request() :: #{
%%   <<"accountIdentifiers">> => list(string()),
%%   <<"nextToken">> => string(),
%%   <<"policyName">> => string(),
%%   <<"policyType">> := list(any())
%% }
-type describe_account_policies_request() :: #{binary() => any()}.

%% Example:
%% metric_filter() :: #{
%%   <<"applyOnTransformedLogs">> => boolean(),
%%   <<"creationTime">> => float(),
%%   <<"emitSystemFieldDimensions">> => list(string()),
%%   <<"fieldSelectionCriteria">> => string(),
%%   <<"filterName">> => string(),
%%   <<"filterPattern">> => string(),
%%   <<"logGroupName">> => string(),
%%   <<"metricTransformations">> => list(metric_transformation())
%% }
-type metric_filter() :: #{binary() => any()}.

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

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

%% Example:
%% destination() :: #{
%%   <<"accessPolicy">> => string(),
%%   <<"arn">> => string(),
%%   <<"creationTime">> => float(),
%%   <<"destinationName">> => string(),
%%   <<"roleArn">> => string(),
%%   <<"targetArn">> => string()
%% }
-type destination() :: #{binary() => any()}.

%% Example:
%% put_log_events_response() :: #{
%%   <<"nextSequenceToken">> => string(),
%%   <<"rejectedEntityInfo">> => rejected_entity_info(),
%%   <<"rejectedLogEventsInfo">> => rejected_log_events_info()
%% }
-type put_log_events_response() :: #{binary() => any()}.

%% Example:
%% put_delivery_source_response() :: #{
%%   <<"deliverySource">> => delivery_source()
%% }
-type put_delivery_source_response() :: #{binary() => any()}.

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

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

%% Example:
%% log_group() :: #{
%%   <<"arn">> => string(),
%%   <<"bearerTokenAuthenticationEnabled">> => boolean(),
%%   <<"creationTime">> => float(),
%%   <<"dataProtectionStatus">> => list(any()),
%%   <<"deletionProtectionEnabled">> => boolean(),
%%   <<"inheritedProperties">> => list(list(any())()),
%%   <<"kmsKeyId">> => string(),
%%   <<"logGroupArn">> => string(),
%%   <<"logGroupClass">> => list(any()),
%%   <<"logGroupName">> => string(),
%%   <<"metricFilterCount">> => integer(),
%%   <<"retentionInDays">> => integer(),
%%   <<"storedBytes">> => float()
%% }
-type log_group() :: #{binary() => any()}.

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

%% Example:
%% describe_log_streams_request() :: #{
%%   <<"descending">> => boolean(),
%%   <<"limit">> => integer(),
%%   <<"logGroupIdentifier">> => string(),
%%   <<"logGroupName">> => string(),
%%   <<"logStreamNamePrefix">> => string(),
%%   <<"nextToken">> => string(),
%%   <<"orderBy">> => list(any())
%% }
-type describe_log_streams_request() :: #{binary() => any()}.

%% Example:
%% s3_configuration() :: #{
%%   <<"destinationIdentifier">> => string(),
%%   <<"kmsKeyId">> => string(),
%%   <<"ownerAccountId">> => string(),
%%   <<"roleArn">> => string()
%% }
-type s3_configuration() :: #{binary() => any()}.

%% Example:
%% update_lookup_table_request() :: #{
%%   <<"description">> => string(),
%%   <<"kmsKeyId">> => string(),
%%   <<"lookupTableArn">> := string(),
%%   <<"tableBody">> := string()
%% }
-type update_lookup_table_request() :: #{binary() => any()}.

%% Example:
%% result_field() :: #{
%%   <<"field">> => string(),
%%   <<"value">> => string()
%% }
-type result_field() :: #{binary() => any()}.

%% Example:
%% s3_tables_integration() :: #{
%%   <<"datasourceName">> => string(),
%%   <<"datasourceType">> => string()
%% }
-type s3_tables_integration() :: #{binary() => any()}.

%% Example:
%% put_resource_policy_response() :: #{
%%   <<"resourcePolicy">> => resource_policy(),
%%   <<"revisionId">> => string()
%% }
-type put_resource_policy_response() :: #{binary() => any()}.

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

%% Example:
%% date_time_converter() :: #{
%%   <<"locale">> => string(),
%%   <<"matchPatterns">> => list(string()),
%%   <<"source">> => string(),
%%   <<"sourceTimezone">> => string(),
%%   <<"target">> => string(),
%%   <<"targetFormat">> => string(),
%%   <<"targetTimezone">> => string()
%% }
-type date_time_converter() :: #{binary() => any()}.

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

%% Example:
%% delete_metric_filter_request() :: #{
%%   <<"filterName">> := string(),
%%   <<"logGroupName">> := string()
%% }
-type delete_metric_filter_request() :: #{binary() => any()}.

%% Example:
%% describe_resource_policies_response() :: #{
%%   <<"nextToken">> => string(),
%%   <<"resourcePolicies">> => list(resource_policy())
%% }
-type describe_resource_policies_response() :: #{binary() => any()}.

%% Example:
%% describe_subscription_filters_response() :: #{
%%   <<"nextToken">> => string(),
%%   <<"subscriptionFilters">> => list(subscription_filter())
%% }
-type describe_subscription_filters_response() :: #{binary() => any()}.

%% Example:
%% query_statistics() :: #{
%%   <<"bytesScanned">> => float(),
%%   <<"estimatedBytesSkipped">> => float(),
%%   <<"estimatedRecordsSkipped">> => float(),
%%   <<"logGroupsScanned">> => float(),
%%   <<"recordsMatched">> => float(),
%%   <<"recordsScanned">> => float()
%% }
-type query_statistics() :: #{binary() => any()}.

%% Example:
%% get_data_protection_policy_response() :: #{
%%   <<"lastUpdatedTime">> => float(),
%%   <<"logGroupIdentifier">> => string(),
%%   <<"policyDocument">> => string()
%% }
-type get_data_protection_policy_response() :: #{binary() => any()}.

%% Example:
%% open_search_resource_status() :: #{
%%   <<"status">> => list(any()),
%%   <<"statusMessage">> => string()
%% }
-type open_search_resource_status() :: #{binary() => any()}.

%% Example:
%% delivery_source() :: #{
%%   <<"arn">> => string(),
%%   <<"deliverySourceConfiguration">> => map(),
%%   <<"logType">> => string(),
%%   <<"name">> => string(),
%%   <<"resourceArns">> => list(string()),
%%   <<"service">> => string(),
%%   <<"status">> => list(any()),
%%   <<"statusReason">> => list(any()),
%%   <<"tags">> => map()
%% }
-type delivery_source() :: #{binary() => any()}.

%% Example:
%% delete_resource_policy_request() :: #{
%%   <<"expectedRevisionId">> => string(),
%%   <<"policyName">> => string(),
%%   <<"resourceArn">> => string()
%% }
-type delete_resource_policy_request() :: #{binary() => any()}.

%% Example:
%% get_log_object_request() :: #{
%%   <<"logObjectPointer">> := string(),
%%   <<"unmask">> => boolean()
%% }
-type get_log_object_request() :: #{binary() => any()}.

%% Example:
%% anomaly_detector() :: #{
%%   <<"anomalyDetectorArn">> => string(),
%%   <<"anomalyDetectorStatus">> => list(any()),
%%   <<"anomalyVisibilityTime">> => float(),
%%   <<"creationTimeStamp">> => float(),
%%   <<"detectorName">> => string(),
%%   <<"evaluationFrequency">> => list(any()),
%%   <<"filterPattern">> => string(),
%%   <<"kmsKeyId">> => string(),
%%   <<"lastModifiedTimeStamp">> => float(),
%%   <<"logGroupArnList">> => list(string())
%% }
-type anomaly_detector() :: #{binary() => any()}.

%% Example:
%% test_transformer_request() :: #{
%%   <<"logEventMessages">> := list(string()),
%%   <<"transformerConfig">> := list(processor())
%% }
-type test_transformer_request() :: #{binary() => any()}.

%% Example:
%% list_log_anomaly_detectors_response() :: #{
%%   <<"anomalyDetectors">> => list(anomaly_detector()),
%%   <<"nextToken">> => string()
%% }
-type list_log_anomaly_detectors_response() :: #{binary() => any()}.

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

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

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

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

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

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

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

%% Example:
%% describe_configuration_templates_response() :: #{
%%   <<"configurationTemplates">> => list(configuration_template()),
%%   <<"nextToken">> => string()
%% }
-type describe_configuration_templates_response() :: #{binary() => any()}.

%% Example:
%% describe_import_tasks_request() :: #{
%%   <<"importId">> => string(),
%%   <<"importSourceArn">> => string(),
%%   <<"importStatus">> => list(any()),
%%   <<"limit">> => integer(),
%%   <<"nextToken">> => string()
%% }
-type describe_import_tasks_request() :: #{binary() => any()}.

%% Example:
%% delete_subscription_filter_request() :: #{
%%   <<"filterName">> := string(),
%%   <<"logGroupName">> := string()
%% }
-type delete_subscription_filter_request() :: #{binary() => any()}.

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

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

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

%% Example:
%% parse_json() :: #{
%%   <<"destination">> => string(),
%%   <<"source">> => string()
%% }
-type parse_json() :: #{binary() => any()}.

%% Example:
%% open_search_application() :: #{
%%   <<"applicationArn">> => string(),
%%   <<"applicationEndpoint">> => string(),
%%   <<"applicationId">> => string(),
%%   <<"status">> => open_search_resource_status()
%% }
-type open_search_application() :: #{binary() => any()}.

%% Example:
%% query_definition() :: #{
%%   <<"lastModified">> => float(),
%%   <<"logGroupNames">> => list(string()),
%%   <<"name">> => string(),
%%   <<"parameters">> => list(query_parameter()),
%%   <<"queryDefinitionId">> => string(),
%%   <<"queryLanguage">> => list(any()),
%%   <<"queryString">> => string()
%% }
-type query_definition() :: #{binary() => any()}.

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

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

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

%% Example:
%% import() :: #{
%%   <<"creationTime">> => float(),
%%   <<"errorMessage">> => string(),
%%   <<"importDestinationArn">> => string(),
%%   <<"importFilter">> => import_filter(),
%%   <<"importId">> => string(),
%%   <<"importSourceArn">> => string(),
%%   <<"importStatistics">> => import_statistics(),
%%   <<"importStatus">> => list(any()),
%%   <<"lastUpdatedTime">> => float()
%% }
-type import() :: #{binary() => any()}.

%% Example:
%% create_delivery_request() :: #{
%%   <<"deliveryDestinationArn">> := string(),
%%   <<"deliverySourceName">> := string(),
%%   <<"fieldDelimiter">> => string(),
%%   <<"recordFields">> => list(string()),
%%   <<"s3DeliveryConfiguration">> => s3_delivery_configuration(),
%%   <<"tags">> => map()
%% }
-type create_delivery_request() :: #{binary() => any()}.

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

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

%% Example:
%% test_metric_filter_request() :: #{
%%   <<"filterPattern">> := string(),
%%   <<"logEventMessages">> := list(string())
%% }
-type test_metric_filter_request() :: #{binary() => any()}.

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

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

%% Example:
%% query_info() :: #{
%%   <<"bytesScanned">> => float(),
%%   <<"createTime">> => float(),
%%   <<"logGroupName">> => string(),
%%   <<"queryDuration">> => float(),
%%   <<"queryId">> => string(),
%%   <<"queryLanguage">> => list(any()),
%%   <<"queryString">> => string(),
%%   <<"status">> => list(any()),
%%   <<"userIdentity">> => string()
%% }
-type query_info() :: #{binary() => any()}.

%% Example:
%% configuration_template_delivery_config_values() :: #{
%%   <<"fieldDelimiter">> => string(),
%%   <<"recordFields">> => list(string()),
%%   <<"s3DeliveryConfiguration">> => s3_delivery_configuration()
%% }
-type configuration_template_delivery_config_values() :: #{binary() => any()}.

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

%% Example:
%% put_index_policy_request() :: #{
%%   <<"logGroupIdentifier">> := string(),
%%   <<"policyDocument">> := string()
%% }
-type put_index_policy_request() :: #{binary() => any()}.

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

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

%% Example:
%% get_scheduled_query_history_response() :: #{
%%   <<"name">> => string(),
%%   <<"nextToken">> => string(),
%%   <<"scheduledQueryArn">> => string(),
%%   <<"triggerHistory">> => list(trigger_history_record())
%% }
-type get_scheduled_query_history_response() :: #{binary() => any()}.

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

%% Example:
%% import_batch() :: #{
%%   <<"batchId">> => string(),
%%   <<"errorMessage">> => string(),
%%   <<"status">> => list(any())
%% }
-type import_batch() :: #{binary() => any()}.

%% Example:
%% describe_import_tasks_response() :: #{
%%   <<"imports">> => list(import()),
%%   <<"nextToken">> => string()
%% }
-type describe_import_tasks_response() :: #{binary() => any()}.

%% Example:
%% destination_configuration() :: #{
%%   <<"s3Configuration">> => s3_configuration()
%% }
-type destination_configuration() :: #{binary() => any()}.

%% Example:
%% describe_configuration_templates_request() :: #{
%%   <<"deliveryDestinationTypes">> => list(list(any())()),
%%   <<"limit">> => integer(),
%%   <<"logTypes">> => list(string()),
%%   <<"nextToken">> => string(),
%%   <<"resourceTypes">> => list(string()),
%%   <<"service">> => string()
%% }
-type describe_configuration_templates_request() :: #{binary() => any()}.

%% Example:
%% describe_metric_filters_response() :: #{
%%   <<"metricFilters">> => list(metric_filter()),
%%   <<"nextToken">> => string()
%% }
-type describe_metric_filters_response() :: #{binary() => any()}.

%% Example:
%% index_policy() :: #{
%%   <<"lastUpdateTime">> => float(),
%%   <<"logGroupIdentifier">> => string(),
%%   <<"policyDocument">> => string(),
%%   <<"policyName">> => string(),
%%   <<"source">> => list(any())
%% }
-type index_policy() :: #{binary() => any()}.

%% Example:
%% log_event() :: #{
%%   <<"message">> => string(),
%%   <<"timestamp">> => float()
%% }
-type log_event() :: #{binary() => any()}.

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

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

-type associate_kms_key_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

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

-type cancel_export_task_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    invalid_operation_exception().

-type cancel_import_task_errors() ::
    throttling_exception() | 
    invalid_parameter_exception() | 
    access_denied_exception() | 
    resource_not_found_exception() | 
    invalid_operation_exception().

-type create_delivery_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    service_unavailable_exception() | 
    service_quota_exceeded_exception() | 
    resource_not_found_exception() | 
    conflict_exception().

-type create_export_task_errors() ::
    resource_already_exists_exception() | 
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type create_import_task_errors() ::
    throttling_exception() | 
    validation_exception() | 
    invalid_parameter_exception() | 
    access_denied_exception() | 
    resource_not_found_exception() | 
    conflict_exception() | 
    invalid_operation_exception().

-type create_log_anomaly_detector_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type create_log_group_errors() ::
    resource_already_exists_exception() | 
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    operation_aborted_exception().

-type create_log_stream_errors() ::
    resource_already_exists_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type create_lookup_table_errors() ::
    resource_already_exists_exception() | 
    limit_exceeded_exception() | 
    validation_exception() | 
    invalid_parameter_exception() | 
    access_denied_exception() | 
    service_unavailable_exception().

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

-type delete_account_policy_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type delete_data_protection_policy_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type delete_delivery_errors() ::
    throttling_exception() | 
    validation_exception() | 
    service_unavailable_exception() | 
    service_quota_exceeded_exception() | 
    resource_not_found_exception() | 
    conflict_exception().

-type delete_delivery_destination_errors() ::
    throttling_exception() | 
    validation_exception() | 
    service_unavailable_exception() | 
    service_quota_exceeded_exception() | 
    resource_not_found_exception() | 
    conflict_exception().

-type delete_delivery_destination_policy_errors() ::
    validation_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    conflict_exception().

-type delete_delivery_source_errors() ::
    throttling_exception() | 
    validation_exception() | 
    service_unavailable_exception() | 
    service_quota_exceeded_exception() | 
    resource_not_found_exception() | 
    conflict_exception().

-type delete_destination_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type delete_index_policy_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type delete_integration_errors() ::
    validation_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type delete_log_anomaly_detector_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type delete_log_group_errors() ::
    validation_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type delete_log_stream_errors() ::
    validation_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type delete_lookup_table_errors() ::
    invalid_parameter_exception() | 
    access_denied_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type delete_metric_filter_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type delete_query_definition_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type delete_resource_policy_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type delete_retention_policy_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

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

-type delete_subscription_filter_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type delete_transformer_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception() | 
    invalid_operation_exception().

-type describe_account_policies_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type describe_configuration_templates_errors() ::
    throttling_exception() | 
    validation_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type describe_deliveries_errors() ::
    throttling_exception() | 
    validation_exception() | 
    service_unavailable_exception() | 
    service_quota_exceeded_exception().

-type describe_delivery_destinations_errors() ::
    throttling_exception() | 
    validation_exception() | 
    service_unavailable_exception() | 
    service_quota_exceeded_exception().

-type describe_delivery_sources_errors() ::
    throttling_exception() | 
    validation_exception() | 
    service_unavailable_exception() | 
    service_quota_exceeded_exception().

-type describe_destinations_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception().

-type describe_export_tasks_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception().

-type describe_field_indexes_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type describe_import_task_batches_errors() ::
    throttling_exception() | 
    invalid_parameter_exception() | 
    access_denied_exception() | 
    resource_not_found_exception() | 
    invalid_operation_exception().

-type describe_import_tasks_errors() ::
    throttling_exception() | 
    invalid_parameter_exception() | 
    access_denied_exception() | 
    resource_not_found_exception() | 
    invalid_operation_exception().

-type describe_index_policies_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type describe_log_groups_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception().

-type describe_log_streams_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type describe_lookup_tables_errors() ::
    invalid_parameter_exception() | 
    access_denied_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type describe_metric_filters_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type describe_queries_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type describe_query_definitions_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception().

-type describe_resource_policies_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception().

-type describe_subscription_filters_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type disassociate_kms_key_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

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

-type filter_log_events_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type get_data_protection_policy_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type get_delivery_errors() ::
    throttling_exception() | 
    validation_exception() | 
    service_unavailable_exception() | 
    service_quota_exceeded_exception() | 
    resource_not_found_exception().

-type get_delivery_destination_errors() ::
    throttling_exception() | 
    validation_exception() | 
    service_unavailable_exception() | 
    service_quota_exceeded_exception() | 
    resource_not_found_exception().

-type get_delivery_destination_policy_errors() ::
    validation_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type get_delivery_source_errors() ::
    throttling_exception() | 
    validation_exception() | 
    service_unavailable_exception() | 
    service_quota_exceeded_exception() | 
    resource_not_found_exception().

-type get_integration_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type get_log_anomaly_detector_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type get_log_events_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type get_log_fields_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type get_log_group_fields_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type get_log_object_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    access_denied_exception() | 
    resource_not_found_exception() | 
    invalid_operation_exception().

-type get_log_record_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type get_lookup_table_errors() ::
    invalid_parameter_exception() | 
    access_denied_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type get_query_results_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

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

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

-type get_transformer_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    invalid_operation_exception().

-type list_aggregate_log_group_summaries_errors() ::
    validation_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception().

-type list_anomalies_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type list_integrations_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception().

-type list_log_anomaly_detectors_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type list_log_groups_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception().

-type list_log_groups_for_query_errors() ::
    invalid_parameter_exception() | 
    access_denied_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

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

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

-type list_tags_for_resource_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type list_tags_log_group_errors() ::
    service_unavailable_exception() | 
    resource_not_found_exception().

-type put_account_policy_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    operation_aborted_exception().

-type put_bearer_token_authentication_errors() ::
    invalid_parameter_exception() | 
    access_denied_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception() | 
    invalid_operation_exception().

-type put_data_protection_policy_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type put_delivery_destination_errors() ::
    throttling_exception() | 
    validation_exception() | 
    service_unavailable_exception() | 
    service_quota_exceeded_exception() | 
    resource_not_found_exception() | 
    conflict_exception().

-type put_delivery_destination_policy_errors() ::
    validation_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    conflict_exception().

-type put_delivery_source_errors() ::
    throttling_exception() | 
    validation_exception() | 
    service_unavailable_exception() | 
    service_quota_exceeded_exception() | 
    resource_not_found_exception() | 
    conflict_exception().

-type put_destination_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    operation_aborted_exception().

-type put_destination_policy_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    operation_aborted_exception().

-type put_index_policy_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type put_integration_errors() ::
    limit_exceeded_exception() | 
    validation_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception().

-type put_log_events_errors() ::
    unrecognized_client_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    data_already_accepted_exception() | 
    invalid_sequence_token_exception().

-type put_log_group_deletion_protection_errors() ::
    invalid_parameter_exception() | 
    access_denied_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception() | 
    invalid_operation_exception().

-type put_metric_filter_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception() | 
    invalid_operation_exception().

-type put_query_definition_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type put_resource_policy_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type put_retention_policy_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type put_subscription_filter_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception() | 
    invalid_operation_exception().

-type put_transformer_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception() | 
    invalid_operation_exception().

-type start_live_tail_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    access_denied_exception() | 
    resource_not_found_exception() | 
    invalid_operation_exception().

-type start_query_errors() ::
    limit_exceeded_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    malformed_query_exception().

-type stop_query_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type tag_log_group_errors() ::
    invalid_parameter_exception() | 
    resource_not_found_exception().

-type tag_resource_errors() ::
    too_many_tags_exception() | 
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type test_metric_filter_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception().

-type test_transformer_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    invalid_operation_exception().

-type untag_log_group_errors() ::
    resource_not_found_exception().

-type untag_resource_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

-type update_anomaly_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type update_delivery_configuration_errors() ::
    throttling_exception() | 
    validation_exception() | 
    access_denied_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    conflict_exception().

-type update_log_anomaly_detector_errors() ::
    invalid_parameter_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception() | 
    operation_aborted_exception().

-type update_lookup_table_errors() ::
    validation_exception() | 
    invalid_parameter_exception() | 
    access_denied_exception() | 
    service_unavailable_exception() | 
    resource_not_found_exception().

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

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

%% @doc Associates the specified KMS key with either one log group in the
%% account, or with all stored CloudWatch Logs query insights results in the
%% account.
%%
%% When you use `AssociateKmsKey', you specify either the
%% `logGroupName' parameter or the `resourceIdentifier' parameter.
%% You
%% can't specify both of those parameters in the same operation.
%%
%% Specify the `logGroupName' parameter to cause log events ingested into
%% that
%% log group to be encrypted with that key. Only the log events ingested
%% after the key is
%% associated are encrypted with that key.
%%
%% Associating a KMS key with a log group overrides any existing
%% associations between the log group and a KMS key. After a KMS key is
%% associated with a log group, all newly ingested data for the log group
%% is encrypted using the KMS key. This association is stored as long as the
%% data encrypted with the KMS key is still within CloudWatch Logs. This
%% enables CloudWatch Logs to decrypt this data whenever it is requested.
%%
%% Associating a key with a log group does not cause the results of queries
%% of that log
%% group to be encrypted with that key. To have query results encrypted with
%% a KMS key, you must use an `AssociateKmsKey' operation with the
%% `resourceIdentifier' parameter that specifies a `query-result'
%% resource.
%%
%% Specify the `resourceIdentifier' parameter with a `query-result'
%% resource, to use that key to encrypt the stored results of all future
%% StartQuery:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_StartQuery.html
%% operations in the account. The response from a GetQueryResults:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_GetQueryResults.html
%% operation will still return the query results in plain
%% text.
%%
%% Even if you have not associated a key with your query results, the query
%% results are
%% encrypted when stored, using the default CloudWatch Logs method.
%%
%% If you run a query from a monitoring account that queries logs in a source
%% account,
%% the query results key from the monitoring account, if any, is used.
%%
%% If you delete the key that is used to encrypt log events or log group
%% query results,
%% then all the associated stored log events or query results that were
%% encrypted with that key
%% will be unencryptable and unusable.
%%
%% CloudWatch Logs supports only symmetric KMS keys. Do not associate an
%% asymmetric KMS key with your log group or query results. For more
%% information, see Using Symmetric and Asymmetric
%% Keys:
%% https://docs.aws.amazon.com/kms/latest/developerguide/symmetric-asymmetric.html.
%%
%% It can take up to 5 minutes for this operation to take effect.
%%
%% If you attempt to associate a KMS key with a log group but the KMS key
%% does not exist or the KMS key is disabled, you receive an
%% `InvalidParameterException' error.
-spec associate_kms_key(aws_client:aws_client(), associate_kms_key_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, associate_kms_key_errors(), tuple()}.
associate_kms_key(Client, Input)
  when is_map(Client), is_map(Input) ->
    associate_kms_key(Client, Input, []).

-spec associate_kms_key(aws_client:aws_client(), associate_kms_key_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, associate_kms_key_errors(), tuple()}.
associate_kms_key(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"AssociateKmsKey">>, Input, Options).

%% @doc Associates a data source with an S3 Table Integration for query
%% access in the 'logs'
%% namespace.
%%
%% This enables querying log data using analytics engines that support
%% Iceberg such as
%% Amazon Athena, Amazon Redshift, and Apache Spark.
-spec associate_source_to_s3_table_integration(aws_client:aws_client(), associate_source_to_s3_table_integration_request()) ->
    {ok, associate_source_to_s3_table_integration_response(), tuple()} |
    {error, any()} |
    {error, associate_source_to_s3_table_integration_errors(), tuple()}.
associate_source_to_s3_table_integration(Client, Input)
  when is_map(Client), is_map(Input) ->
    associate_source_to_s3_table_integration(Client, Input, []).

-spec associate_source_to_s3_table_integration(aws_client:aws_client(), associate_source_to_s3_table_integration_request(), proplists:proplist()) ->
    {ok, associate_source_to_s3_table_integration_response(), tuple()} |
    {error, any()} |
    {error, associate_source_to_s3_table_integration_errors(), tuple()}.
associate_source_to_s3_table_integration(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"AssociateSourceToS3TableIntegration">>, Input, Options).

%% @doc Cancels the specified export task.
%%
%% The task must be in the `PENDING' or `RUNNING' state.
-spec cancel_export_task(aws_client:aws_client(), cancel_export_task_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, cancel_export_task_errors(), tuple()}.
cancel_export_task(Client, Input)
  when is_map(Client), is_map(Input) ->
    cancel_export_task(Client, Input, []).

-spec cancel_export_task(aws_client:aws_client(), cancel_export_task_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, cancel_export_task_errors(), tuple()}.
cancel_export_task(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"CancelExportTask">>, Input, Options).

%% @doc Cancels an active import task and stops importing data from the
%% CloudTrail Lake Event Data Store.
-spec cancel_import_task(aws_client:aws_client(), cancel_import_task_request()) ->
    {ok, cancel_import_task_response(), tuple()} |
    {error, any()} |
    {error, cancel_import_task_errors(), tuple()}.
cancel_import_task(Client, Input)
  when is_map(Client), is_map(Input) ->
    cancel_import_task(Client, Input, []).

-spec cancel_import_task(aws_client:aws_client(), cancel_import_task_request(), proplists:proplist()) ->
    {ok, cancel_import_task_response(), tuple()} |
    {error, any()} |
    {error, cancel_import_task_errors(), tuple()}.
cancel_import_task(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"CancelImportTask">>, Input, Options).

%% @doc Creates a delivery.
%%
%% A delivery is a connection between a logical
%% delivery source and a logical delivery destination
%% that you have already created.
%%
%% Only some Amazon Web Services services support being configured as a
%% delivery source using
%% this operation. These services are listed as Supported [V2
%% Permissions] in the table at Enabling logging from
%% Amazon Web Services services.:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/AWS-logs-and-resource-policy.html
%%
%% A delivery destination can represent a log group in CloudWatch Logs, an
%% Amazon S3 bucket, a delivery stream in Firehose, or X-Ray.
%%
%% To configure logs delivery between a supported Amazon Web Services service
%% and a
%% destination, you must do the following:
%%
%% Create a delivery source, which is a logical object that represents the
%% resource that
%% is actually sending the logs. For more information, see PutDeliverySource:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDeliverySource.html.
%%
%% Create a delivery destination, which is a logical object that
%% represents the actual delivery destination. For more information, see
%% PutDeliveryDestination:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDeliveryDestination.html.
%%
%% If you are delivering logs cross-account, you must use
%% PutDeliveryDestinationPolicy:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDeliveryDestinationPolicy.html
%% in the destination account to assign an IAM policy to the destination.
%% This policy allows delivery to that destination.
%%
%% Use `CreateDelivery' to create a delivery by pairing
%% exactly one delivery source and one delivery destination.
%%
%% You can configure a single delivery source to send logs to multiple
%% destinations by
%% creating multiple deliveries. You can also create multiple deliveries to
%% configure multiple
%% delivery sources to send logs to the same delivery destination.
%%
%% To update an existing delivery configuration, use
%% UpdateDeliveryConfiguration:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_UpdateDeliveryConfiguration.html.
-spec create_delivery(aws_client:aws_client(), create_delivery_request()) ->
    {ok, create_delivery_response(), tuple()} |
    {error, any()} |
    {error, create_delivery_errors(), tuple()}.
create_delivery(Client, Input)
  when is_map(Client), is_map(Input) ->
    create_delivery(Client, Input, []).

-spec create_delivery(aws_client:aws_client(), create_delivery_request(), proplists:proplist()) ->
    {ok, create_delivery_response(), tuple()} |
    {error, any()} |
    {error, create_delivery_errors(), tuple()}.
create_delivery(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"CreateDelivery">>, Input, Options).

%% @doc Creates an export task so that you can efficiently export data from a
%% log group to an
%% Amazon S3 bucket.
%%
%% When you perform a `CreateExportTask' operation, you must use
%% credentials that have permission to write to the S3 bucket that you
%% specify as the
%% destination.
%%
%% Exporting log data to S3 buckets that are encrypted by KMS is supported.
%% Exporting log data to Amazon S3 buckets that have S3 Object Lock enabled
%% with a
%% retention period is also supported.
%%
%% Exporting to S3 buckets that are encrypted with AES-256 is supported.
%%
%% This is an asynchronous call. If all the required information is provided,
%% this
%% operation initiates an export task and responds with the ID of the task.
%% After the task has
%% started, you can use DescribeExportTasks:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_DescribeExportTasks.html
%% to get the status of the export task. Each account can only
%% have one active (`RUNNING' or `PENDING') export task at a time. To
%% cancel an export task, use CancelExportTask:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_CancelExportTask.html.
%%
%% You can export logs from multiple log groups or multiple time ranges to
%% the same S3
%% bucket. To separate log data for each export task, specify a prefix to be
%% used as the Amazon
%% S3 key prefix for all exported objects.
%%
%% We recommend that you don't regularly export to Amazon S3 as a way to
%% continuously archive your logs. For that use case, we instead recommend
%% that you use
%% subscriptions. For more information about subscriptions, see Real-time
%% processing of log data
%% with subscriptions:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/Subscriptions.html.
%%
%% Time-based sorting on chunks of log data inside an exported file is not
%% guaranteed. You
%% can sort the exported log field data by using Linux utilities.
-spec create_export_task(aws_client:aws_client(), create_export_task_request()) ->
    {ok, create_export_task_response(), tuple()} |
    {error, any()} |
    {error, create_export_task_errors(), tuple()}.
create_export_task(Client, Input)
  when is_map(Client), is_map(Input) ->
    create_export_task(Client, Input, []).

-spec create_export_task(aws_client:aws_client(), create_export_task_request(), proplists:proplist()) ->
    {ok, create_export_task_response(), tuple()} |
    {error, any()} |
    {error, create_export_task_errors(), tuple()}.
create_export_task(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"CreateExportTask">>, Input, Options).

%% @doc Starts an import from a data source to CloudWatch Log and creates a
%% managed log group as the destination for the imported data.
%%
%% Currently, CloudTrail Event Data Store:
%% https://docs.aws.amazon.com/awscloudtrail/latest/userguide/query-event-data-store.html
%% is the only supported data source.
%%
%% The import task must satisfy the following constraints:
%%
%% The specified source must be in an ACTIVE state.
%%
%% The API caller must have permissions to access the data in the provided
%% source and to perform iam:PassRole on the
%% provided import role which has the same permissions, as described below.
%%
%% The provided IAM role must trust the &quot;cloudtrail.amazonaws.com&quot;
%% principal and have the following permissions:
%%
%% cloudtrail:GetEventDataStoreData
%%
%% logs:CreateLogGroup
%%
%% logs:CreateLogStream
%%
%% logs:PutResourcePolicy
%%
%% (If source has an associated Amazon Web Services KMS Key) kms:Decrypt
%%
%% (If source has an associated Amazon Web Services KMS Key)
%% kms:GenerateDataKey
%%
%% Example IAM policy for provided import role:
%%
%% `[ { &quot;Effect&quot;: &quot;Allow&quot;, &quot;Action&quot;:
%% &quot;iam:PassRole&quot;, &quot;Resource&quot;:
%% &quot;arn:aws:iam::123456789012:role/apiCallerCredentials&quot;,
%% &quot;Condition&quot;: { &quot;StringLike&quot;: {
%% &quot;iam:AssociatedResourceARN&quot;:
%% &quot;arn:aws:logs:us-east-1:123456789012:log-group:aws/cloudtrail/f1d45bff-d0e3-4868-b5d9-2eb678aa32fb:*&quot;
%% } } }, { &quot;Effect&quot;: &quot;Allow&quot;, &quot;Action&quot;: [
%% &quot;cloudtrail:GetEventDataStoreData&quot; ], &quot;Resource&quot;: [
%% &quot;arn:aws:cloudtrail:us-east-1:123456789012:eventdatastore/f1d45bff-d0e3-4868-b5d9-2eb678aa32fb&quot;
%% ] }, { &quot;Effect&quot;: &quot;Allow&quot;, &quot;Action&quot;: [
%% &quot;logs:CreateImportTask&quot;, &quot;logs:CreateLogGroup&quot;,
%% &quot;logs:CreateLogStream&quot;, &quot;logs:PutResourcePolicy&quot; ],
%% &quot;Resource&quot;: [
%% &quot;arn:aws:logs:us-east-1:123456789012:log-group:/aws/cloudtrail/*&quot;
%% ] }, { &quot;Effect&quot;: &quot;Allow&quot;, &quot;Action&quot;: [
%% &quot;kms:Decrypt&quot;, &quot;kms:GenerateDataKey&quot; ],
%% &quot;Resource&quot;: [
%% &quot;arn:aws:kms:us-east-1:123456789012:key/12345678-1234-1234-1234-123456789012&quot;
%% ] } ]'
%%
%% If the import source has a customer managed key, the
%% &quot;cloudtrail.amazonaws.com&quot; principal needs permissions to
%% perform kms:Decrypt and kms:GenerateDataKey.
%%
%% There can be no more than 3 active imports per account at a given time.
%%
%% The startEventTime must be less than or equal to endEventTime.
%%
%% The data being imported must be within the specified source's
%% retention period.
-spec create_import_task(aws_client:aws_client(), create_import_task_request()) ->
    {ok, create_import_task_response(), tuple()} |
    {error, any()} |
    {error, create_import_task_errors(), tuple()}.
create_import_task(Client, Input)
  when is_map(Client), is_map(Input) ->
    create_import_task(Client, Input, []).

-spec create_import_task(aws_client:aws_client(), create_import_task_request(), proplists:proplist()) ->
    {ok, create_import_task_response(), tuple()} |
    {error, any()} |
    {error, create_import_task_errors(), tuple()}.
create_import_task(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"CreateImportTask">>, Input, Options).

%% @doc Creates an anomaly detector that regularly scans one or more log
%% groups and look for patterns and anomalies in the logs.
%%
%% An anomaly detector can help surface issues by automatically discovering
%% anomalies in your
%% log event traffic. An anomaly detector uses machine learning algorithms to
%% scan log events and
%% find patterns. A pattern is a shared text structure that recurs among
%% your log fields. Patterns provide a useful tool for analyzing large sets
%% of logs because a
%% large number of log events can often be compressed into a few patterns.
%%
%% The anomaly detector uses pattern recognition to find `anomalies',
%% which are
%% unusual log events. It uses the `evaluationFrequency' to compare
%% current log events
%% and patterns with trained baselines.
%%
%% Fields within a pattern are called tokens. Fields that vary within a
%% pattern, such as a request ID or timestamp, are referred to as dynamic
%% tokens and represented by `&lt;*&gt;'.
%%
%% The following is an example of a pattern:
%%
%% `[INFO] Request time: &lt;*&gt; ms'
%%
%% This pattern represents log events like `[INFO] Request time: 327 ms'
%% and other
%% similar log events that differ only by the number, in this csse 327. When
%% the pattern is
%% displayed, the different numbers are replaced by `&lt;*&gt;'
%%
%% Any parts of log events that are masked as sensitive data are not scanned
%% for anomalies.
%% For more information about masking sensitive data, see Help protect
%% sensitive log
%% data with masking:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/mask-sensitive-log-data.html.
-spec create_log_anomaly_detector(aws_client:aws_client(), create_log_anomaly_detector_request()) ->
    {ok, create_log_anomaly_detector_response(), tuple()} |
    {error, any()} |
    {error, create_log_anomaly_detector_errors(), tuple()}.
create_log_anomaly_detector(Client, Input)
  when is_map(Client), is_map(Input) ->
    create_log_anomaly_detector(Client, Input, []).

-spec create_log_anomaly_detector(aws_client:aws_client(), create_log_anomaly_detector_request(), proplists:proplist()) ->
    {ok, create_log_anomaly_detector_response(), tuple()} |
    {error, any()} |
    {error, create_log_anomaly_detector_errors(), tuple()}.
create_log_anomaly_detector(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"CreateLogAnomalyDetector">>, Input, Options).

%% @doc Creates a log group with the specified name.
%%
%% You can create up to 1,000,000 log groups
%% per Region per account.
%%
%% You must use the following guidelines when naming a log group:
%%
%% Log group names must be unique within a Region for an Amazon Web Services
%% account.
%%
%% Log group names can be between 1 and 512 characters long.
%%
%% Log group names consist of the following characters: a-z, A-Z, 0-9,
%% '_'
%% (underscore), '-' (hyphen), '/' (forward slash),
%% '.' (period), and '#' (number
%% sign)
%%
%% Log group names can't start with the string `aws/'
%%
%% When you create a log group, by default the log events in the log group do
%% not expire.
%% To set a retention policy so that events expire and are deleted after a
%% specified time, use
%% PutRetentionPolicy:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutRetentionPolicy.html.
%%
%% If you associate an KMS key with the log group, ingested data is
%% encrypted using the KMS key. This association is stored as long as the
%% data
%% encrypted with the KMS key is still within CloudWatch Logs. This enables
%% CloudWatch Logs to decrypt this data whenever it is requested.
%%
%% If you attempt to associate a KMS key with the log group but the KMS key
%% does not exist or the KMS key is disabled, you receive an
%% `InvalidParameterException' error.
%%
%% CloudWatch Logs supports only symmetric KMS keys. Do not associate an
%% asymmetric KMS key with your log group. For more information, see Using
%% Symmetric and Asymmetric Keys:
%% https://docs.aws.amazon.com/kms/latest/developerguide/symmetric-asymmetric.html.
-spec create_log_group(aws_client:aws_client(), create_log_group_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, create_log_group_errors(), tuple()}.
create_log_group(Client, Input)
  when is_map(Client), is_map(Input) ->
    create_log_group(Client, Input, []).

-spec create_log_group(aws_client:aws_client(), create_log_group_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, create_log_group_errors(), tuple()}.
create_log_group(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"CreateLogGroup">>, Input, Options).

%% @doc Creates a log stream for the specified log group.
%%
%% A log stream is a sequence of log
%% events that originate from a single source, such as an application
%% instance or a resource that
%% is being monitored.
%%
%% There is no limit on the number of log streams that you can create for a
%% log group.
%% There is a limit of 50 TPS on `CreateLogStream' operations, after
%% which
%% transactions are throttled.
%%
%% You must use the following guidelines when naming a log stream:
%%
%% Log stream names must be unique within the log group.
%%
%% Log stream names can be between 1 and 512 characters long.
%%
%% Don't use ':' (colon) or '*' (asterisk) characters.
-spec create_log_stream(aws_client:aws_client(), create_log_stream_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, create_log_stream_errors(), tuple()}.
create_log_stream(Client, Input)
  when is_map(Client), is_map(Input) ->
    create_log_stream(Client, Input, []).

-spec create_log_stream(aws_client:aws_client(), create_log_stream_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, create_log_stream_errors(), tuple()}.
create_log_stream(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"CreateLogStream">>, Input, Options).

%% @doc Creates a lookup table by uploading CSV data.
%%
%% You can use lookup tables to enrich log
%% data in CloudWatch Logs Insights queries with reference data such as user
%% details, application
%% names, or error descriptions.
%%
%% The table name must be unique within your account and Region. The CSV
%% content must include
%% a header row with column names, use UTF-8 encoding, and not exceed 10 MB.
-spec create_lookup_table(aws_client:aws_client(), create_lookup_table_request()) ->
    {ok, create_lookup_table_response(), tuple()} |
    {error, any()} |
    {error, create_lookup_table_errors(), tuple()}.
create_lookup_table(Client, Input)
  when is_map(Client), is_map(Input) ->
    create_lookup_table(Client, Input, []).

-spec create_lookup_table(aws_client:aws_client(), create_lookup_table_request(), proplists:proplist()) ->
    {ok, create_lookup_table_response(), tuple()} |
    {error, any()} |
    {error, create_lookup_table_errors(), tuple()}.
create_lookup_table(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"CreateLookupTable">>, Input, Options).

%% @doc Creates a scheduled query that runs CloudWatch Logs Insights queries
%% at regular intervals.
%%
%% Scheduled queries enable proactive monitoring by automatically executing
%% queries to detect
%% patterns and anomalies in your log data. Query results can be delivered to
%% Amazon S3 for analysis
%% or further processing.
-spec create_scheduled_query(aws_client:aws_client(), create_scheduled_query_request()) ->
    {ok, create_scheduled_query_response(), tuple()} |
    {error, any()} |
    {error, create_scheduled_query_errors(), tuple()}.
create_scheduled_query(Client, Input)
  when is_map(Client), is_map(Input) ->
    create_scheduled_query(Client, Input, []).

-spec create_scheduled_query(aws_client:aws_client(), create_scheduled_query_request(), proplists:proplist()) ->
    {ok, create_scheduled_query_response(), tuple()} |
    {error, any()} |
    {error, create_scheduled_query_errors(), tuple()}.
create_scheduled_query(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"CreateScheduledQuery">>, Input, Options).

%% @doc Deletes a CloudWatch Logs account policy.
%%
%% This stops the account-wide policy from
%% applying to log groups or data sources in the account. If you delete a
%% data protection policy
%% or subscription filter policy, any log-group level policies of those types
%% remain in effect.
%% This operation supports deletion of data source-based field index
%% policies, including facet
%% configurations, in addition to log group-based policies.
%%
%% To use this operation, you must be signed on with the correct permissions
%% depending on the
%% type of policy that you are deleting.
%%
%% To delete a data protection policy, you must have the
%% `logs:DeleteDataProtectionPolicy' and `logs:DeleteAccountPolicy'
%% permissions.
%%
%% To delete a subscription filter policy, you must have the
%% `logs:DeleteSubscriptionFilter' and `logs:DeleteAccountPolicy'
%% permissions.
%%
%% To delete a transformer policy, you must have the
%% `logs:DeleteTransformer'
%% and `logs:DeleteAccountPolicy' permissions.
%%
%% To delete a field index policy, you must have the
%% `logs:DeleteIndexPolicy'
%% and `logs:DeleteAccountPolicy' permissions.
%%
%% If you delete a field index policy that included facet configurations,
%% those facets
%% will no longer be available for interactive exploration in the CloudWatch
%% Logs Insights
%% console. However, facet data is retained for up to 30 days.
%%
%% If you delete a field index policy, the indexing of the log events that
%% happened before
%% you deleted the policy will still be used for up to 30 days to improve
%% CloudWatch Logs
%% Insights queries.
-spec delete_account_policy(aws_client:aws_client(), delete_account_policy_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_account_policy_errors(), tuple()}.
delete_account_policy(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_account_policy(Client, Input, []).

-spec delete_account_policy(aws_client:aws_client(), delete_account_policy_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_account_policy_errors(), tuple()}.
delete_account_policy(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteAccountPolicy">>, Input, Options).

%% @doc Deletes the data protection policy from the specified log group.
%%
%% For more information about data protection policies, see
%% PutDataProtectionPolicy:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDataProtectionPolicy.html.
-spec delete_data_protection_policy(aws_client:aws_client(), delete_data_protection_policy_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_data_protection_policy_errors(), tuple()}.
delete_data_protection_policy(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_data_protection_policy(Client, Input, []).

-spec delete_data_protection_policy(aws_client:aws_client(), delete_data_protection_policy_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_data_protection_policy_errors(), tuple()}.
delete_data_protection_policy(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteDataProtectionPolicy">>, Input, Options).

%% @doc Deletes a delivery.
%%
%% A delivery is a connection between a logical
%% delivery source and a logical delivery
%% destination. Deleting a delivery only deletes the connection between the
%% delivery
%% source and delivery destination. It does not delete the delivery
%% destination or the delivery
%% source.
-spec delete_delivery(aws_client:aws_client(), delete_delivery_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_delivery_errors(), tuple()}.
delete_delivery(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_delivery(Client, Input, []).

-spec delete_delivery(aws_client:aws_client(), delete_delivery_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_delivery_errors(), tuple()}.
delete_delivery(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteDelivery">>, Input, Options).

%% @doc Deletes a delivery destination.
%%
%% A delivery is a connection between a
%% logical delivery source and a logical delivery
%% destination.
%%
%% You can't delete a delivery destination if any current deliveries are
%% associated with it.
%% To find whether any deliveries are associated with this delivery
%% destination, use the DescribeDeliveries:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_DescribeDeliveries.html
%% operation and check the `deliveryDestinationArn'
%% field in the results.
-spec delete_delivery_destination(aws_client:aws_client(), delete_delivery_destination_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_delivery_destination_errors(), tuple()}.
delete_delivery_destination(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_delivery_destination(Client, Input, []).

-spec delete_delivery_destination(aws_client:aws_client(), delete_delivery_destination_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_delivery_destination_errors(), tuple()}.
delete_delivery_destination(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteDeliveryDestination">>, Input, Options).

%% @doc Deletes a delivery destination policy.
%%
%% For more information about these policies, see
%% PutDeliveryDestinationPolicy:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDeliveryDestinationPolicy.html.
-spec delete_delivery_destination_policy(aws_client:aws_client(), delete_delivery_destination_policy_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_delivery_destination_policy_errors(), tuple()}.
delete_delivery_destination_policy(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_delivery_destination_policy(Client, Input, []).

-spec delete_delivery_destination_policy(aws_client:aws_client(), delete_delivery_destination_policy_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_delivery_destination_policy_errors(), tuple()}.
delete_delivery_destination_policy(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteDeliveryDestinationPolicy">>, Input, Options).

%% @doc Deletes a delivery source.
%%
%% A delivery is a connection between a
%% logical delivery source and a logical delivery
%% destination.
%%
%% You can't delete a delivery source if any current deliveries are
%% associated with it. To
%% find whether any deliveries are associated with this delivery source, use
%% the DescribeDeliveries:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_DescribeDeliveries.html
%% operation and check the `deliverySourceName' field in
%% the results.
-spec delete_delivery_source(aws_client:aws_client(), delete_delivery_source_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_delivery_source_errors(), tuple()}.
delete_delivery_source(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_delivery_source(Client, Input, []).

-spec delete_delivery_source(aws_client:aws_client(), delete_delivery_source_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_delivery_source_errors(), tuple()}.
delete_delivery_source(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteDeliverySource">>, Input, Options).

%% @doc Deletes the specified destination, and eventually disables all the
%% subscription filters
%% that publish to it.
%%
%% This operation does not delete the physical resource encapsulated by the
%% destination.
-spec delete_destination(aws_client:aws_client(), delete_destination_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_destination_errors(), tuple()}.
delete_destination(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_destination(Client, Input, []).

-spec delete_destination(aws_client:aws_client(), delete_destination_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_destination_errors(), tuple()}.
delete_destination(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteDestination">>, Input, Options).

%% @doc Deletes a log-group level field index policy that was applied to a
%% single log group.
%%
%% The
%% indexing of the log events that happened before you delete the policy will
%% still be used for
%% as many as 30 days to improve CloudWatch Logs Insights queries.
%%
%% If the deleted policy included facet configurations, those facets will no
%% longer be
%% available for interactive exploration in the CloudWatch Logs Insights
%% console for this log
%% group. However, facet data is retained for up to 30 days.
%%
%% You can't use this operation to delete an account-level index policy.
%% Instead, use DeleteAccountPolicy:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_DeleteAccountPolicy.html.
%%
%% If you delete a log-group level field index policy and there is an
%% account-level field
%% index policy, in a few minutes the log group begins using that
%% account-wide policy to index
%% new incoming log events. This operation only affects log group-level
%% policies, including any
%% facet configurations, and preserves any data source-based account policies
%% that may apply to
%% the log group.
-spec delete_index_policy(aws_client:aws_client(), delete_index_policy_request()) ->
    {ok, delete_index_policy_response(), tuple()} |
    {error, any()} |
    {error, delete_index_policy_errors(), tuple()}.
delete_index_policy(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_index_policy(Client, Input, []).

-spec delete_index_policy(aws_client:aws_client(), delete_index_policy_request(), proplists:proplist()) ->
    {ok, delete_index_policy_response(), tuple()} |
    {error, any()} |
    {error, delete_index_policy_errors(), tuple()}.
delete_index_policy(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteIndexPolicy">>, Input, Options).

%% @doc Deletes the integration between CloudWatch Logs and OpenSearch
%% Service.
%%
%% If your
%% integration has active vended logs dashboards, you must specify `true'
%% for the
%% `force' parameter, otherwise the operation will fail. If you delete
%% the
%% integration by setting `force' to `true', all your vended logs
%% dashboards powered by OpenSearch Service will be deleted and the data that
%% was on them will no
%% longer be accessible.
-spec delete_integration(aws_client:aws_client(), delete_integration_request()) ->
    {ok, delete_integration_response(), tuple()} |
    {error, any()} |
    {error, delete_integration_errors(), tuple()}.
delete_integration(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_integration(Client, Input, []).

-spec delete_integration(aws_client:aws_client(), delete_integration_request(), proplists:proplist()) ->
    {ok, delete_integration_response(), tuple()} |
    {error, any()} |
    {error, delete_integration_errors(), tuple()}.
delete_integration(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteIntegration">>, Input, Options).

%% @doc Deletes the specified CloudWatch Logs anomaly detector.
-spec delete_log_anomaly_detector(aws_client:aws_client(), delete_log_anomaly_detector_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_log_anomaly_detector_errors(), tuple()}.
delete_log_anomaly_detector(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_log_anomaly_detector(Client, Input, []).

-spec delete_log_anomaly_detector(aws_client:aws_client(), delete_log_anomaly_detector_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_log_anomaly_detector_errors(), tuple()}.
delete_log_anomaly_detector(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteLogAnomalyDetector">>, Input, Options).

%% @doc Deletes the specified log group and permanently deletes all the
%% archived log events
%% associated with the log group.
-spec delete_log_group(aws_client:aws_client(), delete_log_group_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_log_group_errors(), tuple()}.
delete_log_group(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_log_group(Client, Input, []).

-spec delete_log_group(aws_client:aws_client(), delete_log_group_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_log_group_errors(), tuple()}.
delete_log_group(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteLogGroup">>, Input, Options).

%% @doc Deletes the specified log stream and permanently deletes all the
%% archived log events
%% associated with the log stream.
-spec delete_log_stream(aws_client:aws_client(), delete_log_stream_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_log_stream_errors(), tuple()}.
delete_log_stream(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_log_stream(Client, Input, []).

-spec delete_log_stream(aws_client:aws_client(), delete_log_stream_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_log_stream_errors(), tuple()}.
delete_log_stream(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteLogStream">>, Input, Options).

%% @doc Deletes a lookup table permanently.
%%
%% This operation cannot be undone.
%%
%% Queries that reference a deleted table will return an error. Before
%% deleting a lookup
%% table, review any saved queries or dashboards that may reference it.
-spec delete_lookup_table(aws_client:aws_client(), delete_lookup_table_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_lookup_table_errors(), tuple()}.
delete_lookup_table(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_lookup_table(Client, Input, []).

-spec delete_lookup_table(aws_client:aws_client(), delete_lookup_table_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_lookup_table_errors(), tuple()}.
delete_lookup_table(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteLookupTable">>, Input, Options).

%% @doc Deletes the specified metric filter.
-spec delete_metric_filter(aws_client:aws_client(), delete_metric_filter_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_metric_filter_errors(), tuple()}.
delete_metric_filter(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_metric_filter(Client, Input, []).

-spec delete_metric_filter(aws_client:aws_client(), delete_metric_filter_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_metric_filter_errors(), tuple()}.
delete_metric_filter(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteMetricFilter">>, Input, Options).

%% @doc Deletes a saved CloudWatch Logs Insights query definition.
%%
%% A query definition contains
%% details about a saved CloudWatch Logs Insights query.
%%
%% Each `DeleteQueryDefinition' operation can delete one query
%% definition.
%%
%% You must have the `logs:DeleteQueryDefinition' permission to be able
%% to perform
%% this operation.
-spec delete_query_definition(aws_client:aws_client(), delete_query_definition_request()) ->
    {ok, delete_query_definition_response(), tuple()} |
    {error, any()} |
    {error, delete_query_definition_errors(), tuple()}.
delete_query_definition(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_query_definition(Client, Input, []).

-spec delete_query_definition(aws_client:aws_client(), delete_query_definition_request(), proplists:proplist()) ->
    {ok, delete_query_definition_response(), tuple()} |
    {error, any()} |
    {error, delete_query_definition_errors(), tuple()}.
delete_query_definition(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteQueryDefinition">>, Input, Options).

%% @doc Deletes a resource policy from this account.
%%
%% This revokes the access of the identities
%% in that policy to put log events to this account.
-spec delete_resource_policy(aws_client:aws_client(), delete_resource_policy_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_resource_policy_errors(), tuple()}.
delete_resource_policy(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_resource_policy(Client, Input, []).

-spec delete_resource_policy(aws_client:aws_client(), delete_resource_policy_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_resource_policy_errors(), tuple()}.
delete_resource_policy(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteResourcePolicy">>, Input, Options).

%% @doc Deletes the specified retention policy.
%%
%% Log events do not expire if they belong to log groups without a retention
%% policy.
-spec delete_retention_policy(aws_client:aws_client(), delete_retention_policy_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_retention_policy_errors(), tuple()}.
delete_retention_policy(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_retention_policy(Client, Input, []).

-spec delete_retention_policy(aws_client:aws_client(), delete_retention_policy_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_retention_policy_errors(), tuple()}.
delete_retention_policy(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteRetentionPolicy">>, Input, Options).

%% @doc Deletes a scheduled query and stops all future executions.
%%
%% This operation also removes any
%% configured actions and associated resources.
-spec delete_scheduled_query(aws_client:aws_client(), delete_scheduled_query_request()) ->
    {ok, delete_scheduled_query_response(), tuple()} |
    {error, any()} |
    {error, delete_scheduled_query_errors(), tuple()}.
delete_scheduled_query(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_scheduled_query(Client, Input, []).

-spec delete_scheduled_query(aws_client:aws_client(), delete_scheduled_query_request(), proplists:proplist()) ->
    {ok, delete_scheduled_query_response(), tuple()} |
    {error, any()} |
    {error, delete_scheduled_query_errors(), tuple()}.
delete_scheduled_query(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteScheduledQuery">>, Input, Options).

%% @doc Deletes the specified subscription filter.
-spec delete_subscription_filter(aws_client:aws_client(), delete_subscription_filter_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_subscription_filter_errors(), tuple()}.
delete_subscription_filter(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_subscription_filter(Client, Input, []).

-spec delete_subscription_filter(aws_client:aws_client(), delete_subscription_filter_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_subscription_filter_errors(), tuple()}.
delete_subscription_filter(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteSubscriptionFilter">>, Input, Options).

%% @doc Deletes the log transformer for the specified log group.
%%
%% As soon as you do this, the
%% transformation of incoming log events according to that transformer stops.
%% If this account has
%% an account-level transformer that applies to this log group, the log group
%% begins using that
%% account-level transformer when this log-group level transformer is
%% deleted.
%%
%% After you delete a transformer, be sure to edit any metric filters or
%% subscription filters
%% that relied on the transformed versions of the log events.
-spec delete_transformer(aws_client:aws_client(), delete_transformer_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_transformer_errors(), tuple()}.
delete_transformer(Client, Input)
  when is_map(Client), is_map(Input) ->
    delete_transformer(Client, Input, []).

-spec delete_transformer(aws_client:aws_client(), delete_transformer_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, delete_transformer_errors(), tuple()}.
delete_transformer(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DeleteTransformer">>, Input, Options).

%% @doc Returns a list of all CloudWatch Logs account policies in the
%% account.
%%
%% To use this operation, you must be signed on with the correct permissions
%% depending on the
%% type of policy that you are retrieving information for.
%%
%% To see data protection policies, you must have the
%% `logs:GetDataProtectionPolicy' and `logs:DescribeAccountPolicies'
%% permissions.
%%
%% To see subscription filter policies, you must have the
%% `logs:DescribeSubscriptionFilters' and
%% `logs:DescribeAccountPolicies' permissions.
%%
%% To see transformer policies, you must have the `logs:GetTransformer'
%% and
%% `logs:DescribeAccountPolicies' permissions.
%%
%% To see field index policies, you must have the
%% `logs:DescribeIndexPolicies'
%% and `logs:DescribeAccountPolicies' permissions.
-spec describe_account_policies(aws_client:aws_client(), describe_account_policies_request()) ->
    {ok, describe_account_policies_response(), tuple()} |
    {error, any()} |
    {error, describe_account_policies_errors(), tuple()}.
describe_account_policies(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_account_policies(Client, Input, []).

-spec describe_account_policies(aws_client:aws_client(), describe_account_policies_request(), proplists:proplist()) ->
    {ok, describe_account_policies_response(), tuple()} |
    {error, any()} |
    {error, describe_account_policies_errors(), tuple()}.
describe_account_policies(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeAccountPolicies">>, Input, Options).

%% @doc Use this operation to return the valid and default values that are
%% used when creating
%% delivery sources, delivery destinations, and deliveries.
%%
%% For more information about
%% deliveries, see CreateDelivery:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_CreateDelivery.html.
-spec describe_configuration_templates(aws_client:aws_client(), describe_configuration_templates_request()) ->
    {ok, describe_configuration_templates_response(), tuple()} |
    {error, any()} |
    {error, describe_configuration_templates_errors(), tuple()}.
describe_configuration_templates(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_configuration_templates(Client, Input, []).

-spec describe_configuration_templates(aws_client:aws_client(), describe_configuration_templates_request(), proplists:proplist()) ->
    {ok, describe_configuration_templates_response(), tuple()} |
    {error, any()} |
    {error, describe_configuration_templates_errors(), tuple()}.
describe_configuration_templates(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeConfigurationTemplates">>, Input, Options).

%% @doc Retrieves a list of the deliveries that have been created in the
%% account.
%%
%% A delivery is a connection between a
%% delivery
%% source
%% :
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDeliverySource.html
%% and a
%% delivery destination
%% :
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDeliveryDestination.html.
%%
%% A delivery source represents an Amazon Web Services resource that sends
%% logs to an logs
%% delivery destination. The destination can be CloudWatch Logs, Amazon S3,
%% Firehose or X-Ray. Only some Amazon Web Services services support being
%% configured as a delivery source. These services are listed in Enable
%% logging from
%% Amazon Web Services services.:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/AWS-logs-and-resource-policy.html
-spec describe_deliveries(aws_client:aws_client(), describe_deliveries_request()) ->
    {ok, describe_deliveries_response(), tuple()} |
    {error, any()} |
    {error, describe_deliveries_errors(), tuple()}.
describe_deliveries(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_deliveries(Client, Input, []).

-spec describe_deliveries(aws_client:aws_client(), describe_deliveries_request(), proplists:proplist()) ->
    {ok, describe_deliveries_response(), tuple()} |
    {error, any()} |
    {error, describe_deliveries_errors(), tuple()}.
describe_deliveries(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeDeliveries">>, Input, Options).

%% @doc Retrieves a list of the delivery destinations that have been created
%% in the
%% account.
-spec describe_delivery_destinations(aws_client:aws_client(), describe_delivery_destinations_request()) ->
    {ok, describe_delivery_destinations_response(), tuple()} |
    {error, any()} |
    {error, describe_delivery_destinations_errors(), tuple()}.
describe_delivery_destinations(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_delivery_destinations(Client, Input, []).

-spec describe_delivery_destinations(aws_client:aws_client(), describe_delivery_destinations_request(), proplists:proplist()) ->
    {ok, describe_delivery_destinations_response(), tuple()} |
    {error, any()} |
    {error, describe_delivery_destinations_errors(), tuple()}.
describe_delivery_destinations(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeDeliveryDestinations">>, Input, Options).

%% @doc Retrieves a list of the delivery sources that have been created in
%% the account.
-spec describe_delivery_sources(aws_client:aws_client(), describe_delivery_sources_request()) ->
    {ok, describe_delivery_sources_response(), tuple()} |
    {error, any()} |
    {error, describe_delivery_sources_errors(), tuple()}.
describe_delivery_sources(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_delivery_sources(Client, Input, []).

-spec describe_delivery_sources(aws_client:aws_client(), describe_delivery_sources_request(), proplists:proplist()) ->
    {ok, describe_delivery_sources_response(), tuple()} |
    {error, any()} |
    {error, describe_delivery_sources_errors(), tuple()}.
describe_delivery_sources(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeDeliverySources">>, Input, Options).

%% @doc Lists all your destinations.
%%
%% The results are ASCII-sorted by destination
%% name.
-spec describe_destinations(aws_client:aws_client(), describe_destinations_request()) ->
    {ok, describe_destinations_response(), tuple()} |
    {error, any()} |
    {error, describe_destinations_errors(), tuple()}.
describe_destinations(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_destinations(Client, Input, []).

-spec describe_destinations(aws_client:aws_client(), describe_destinations_request(), proplists:proplist()) ->
    {ok, describe_destinations_response(), tuple()} |
    {error, any()} |
    {error, describe_destinations_errors(), tuple()}.
describe_destinations(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeDestinations">>, Input, Options).

%% @doc Lists the specified export tasks.
%%
%% You can list all your export tasks or filter the
%% results based on task ID or task status.
-spec describe_export_tasks(aws_client:aws_client(), describe_export_tasks_request()) ->
    {ok, describe_export_tasks_response(), tuple()} |
    {error, any()} |
    {error, describe_export_tasks_errors(), tuple()}.
describe_export_tasks(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_export_tasks(Client, Input, []).

-spec describe_export_tasks(aws_client:aws_client(), describe_export_tasks_request(), proplists:proplist()) ->
    {ok, describe_export_tasks_response(), tuple()} |
    {error, any()} |
    {error, describe_export_tasks_errors(), tuple()}.
describe_export_tasks(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeExportTasks">>, Input, Options).

%% @doc Returns a list of custom and default field indexes which are
%% discovered in log data.
%%
%% For
%% more information about field index policies, see PutIndexPolicy:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutIndexPolicy.html.
-spec describe_field_indexes(aws_client:aws_client(), describe_field_indexes_request()) ->
    {ok, describe_field_indexes_response(), tuple()} |
    {error, any()} |
    {error, describe_field_indexes_errors(), tuple()}.
describe_field_indexes(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_field_indexes(Client, Input, []).

-spec describe_field_indexes(aws_client:aws_client(), describe_field_indexes_request(), proplists:proplist()) ->
    {ok, describe_field_indexes_response(), tuple()} |
    {error, any()} |
    {error, describe_field_indexes_errors(), tuple()}.
describe_field_indexes(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeFieldIndexes">>, Input, Options).

%% @doc Gets detailed information about the individual batches within an
%% import task, including their status and any error messages.
%%
%% For CloudTrail Event Data Store sources, a batch refers to a subset of
%% stored events grouped by their eventTime.
-spec describe_import_task_batches(aws_client:aws_client(), describe_import_task_batches_request()) ->
    {ok, describe_import_task_batches_response(), tuple()} |
    {error, any()} |
    {error, describe_import_task_batches_errors(), tuple()}.
describe_import_task_batches(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_import_task_batches(Client, Input, []).

-spec describe_import_task_batches(aws_client:aws_client(), describe_import_task_batches_request(), proplists:proplist()) ->
    {ok, describe_import_task_batches_response(), tuple()} |
    {error, any()} |
    {error, describe_import_task_batches_errors(), tuple()}.
describe_import_task_batches(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeImportTaskBatches">>, Input, Options).

%% @doc Lists and describes import tasks, with optional filtering by import
%% status and source ARN.
-spec describe_import_tasks(aws_client:aws_client(), describe_import_tasks_request()) ->
    {ok, describe_import_tasks_response(), tuple()} |
    {error, any()} |
    {error, describe_import_tasks_errors(), tuple()}.
describe_import_tasks(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_import_tasks(Client, Input, []).

-spec describe_import_tasks(aws_client:aws_client(), describe_import_tasks_request(), proplists:proplist()) ->
    {ok, describe_import_tasks_response(), tuple()} |
    {error, any()} |
    {error, describe_import_tasks_errors(), tuple()}.
describe_import_tasks(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeImportTasks">>, Input, Options).

%% @doc Returns the field index policies of the specified log group.
%%
%% For more information about
%% field index policies, see PutIndexPolicy:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutIndexPolicy.html.
%%
%% If a specified log group has a log-group level index policy, that policy
%% is returned by
%% this operation.
%%
%% If a specified log group doesn't have a log-group level index policy,
%% but an account-wide
%% index policy applies to it, that account-wide policy is returned by this
%% operation.
%%
%% To find information about only account-level policies, use
%% DescribeAccountPolicies:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_DescribeAccountPolicies.html
%% instead.
-spec describe_index_policies(aws_client:aws_client(), describe_index_policies_request()) ->
    {ok, describe_index_policies_response(), tuple()} |
    {error, any()} |
    {error, describe_index_policies_errors(), tuple()}.
describe_index_policies(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_index_policies(Client, Input, []).

-spec describe_index_policies(aws_client:aws_client(), describe_index_policies_request(), proplists:proplist()) ->
    {ok, describe_index_policies_response(), tuple()} |
    {error, any()} |
    {error, describe_index_policies_errors(), tuple()}.
describe_index_policies(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeIndexPolicies">>, Input, Options).

%% @doc Returns information about log groups, including data sources that
%% ingest into each log
%% group.
%%
%% You can return all your log groups or filter the results by prefix. The
%% results are
%% ASCII-sorted by log group name.
%%
%% CloudWatch Logs doesn't support IAM policies that control access to
%% the
%% `DescribeLogGroups' action by using the
%%
%% ```
%% aws:ResourceTag/key-name ''' condition key. Other CloudWatch
%% Logs actions do support the use of the
%%
%% ```
%% aws:ResourceTag/key-name ''' condition key to control access.
%% For more information about using tags to control access, see Controlling
%% access to Amazon Web Services
%% resources using tags:
%% https://docs.aws.amazon.com/IAM/latest/UserGuide/access_tags.html.
%%
%% If you are using CloudWatch cross-account observability, you can use this
%% operation
%% in a monitoring account and view data from the linked source accounts. For
%% more information,
%% see CloudWatch cross-account observability:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/CloudWatch-Unified-Cross-Account.html.
-spec describe_log_groups(aws_client:aws_client(), describe_log_groups_request()) ->
    {ok, describe_log_groups_response(), tuple()} |
    {error, any()} |
    {error, describe_log_groups_errors(), tuple()}.
describe_log_groups(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_log_groups(Client, Input, []).

-spec describe_log_groups(aws_client:aws_client(), describe_log_groups_request(), proplists:proplist()) ->
    {ok, describe_log_groups_response(), tuple()} |
    {error, any()} |
    {error, describe_log_groups_errors(), tuple()}.
describe_log_groups(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeLogGroups">>, Input, Options).

%% @doc Lists the log streams for the specified log group.
%%
%% You can list all the log streams or
%% filter the results by prefix. You can also control how the results are
%% ordered.
%%
%% You can specify the log group to search by using either
%% `logGroupIdentifier' or
%% `logGroupName'. You must include one of these two parameters, but you
%% can't
%% include both.
%%
%% This operation has a limit of 25 transactions per second, after which
%% transactions are
%% throttled.
%%
%% If you are using CloudWatch cross-account observability, you can use this
%% operation
%% in a monitoring account and view data from the linked source accounts. For
%% more information,
%% see CloudWatch cross-account observability:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/CloudWatch-Unified-Cross-Account.html.
-spec describe_log_streams(aws_client:aws_client(), describe_log_streams_request()) ->
    {ok, describe_log_streams_response(), tuple()} |
    {error, any()} |
    {error, describe_log_streams_errors(), tuple()}.
describe_log_streams(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_log_streams(Client, Input, []).

-spec describe_log_streams(aws_client:aws_client(), describe_log_streams_request(), proplists:proplist()) ->
    {ok, describe_log_streams_response(), tuple()} |
    {error, any()} |
    {error, describe_log_streams_errors(), tuple()}.
describe_log_streams(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeLogStreams">>, Input, Options).

%% @doc Retrieves metadata about lookup tables in your account.
%%
%% You can optionally filter the
%% results by table name prefix. Results are sorted by table name in
%% ascending order.
-spec describe_lookup_tables(aws_client:aws_client(), describe_lookup_tables_request()) ->
    {ok, describe_lookup_tables_response(), tuple()} |
    {error, any()} |
    {error, describe_lookup_tables_errors(), tuple()}.
describe_lookup_tables(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_lookup_tables(Client, Input, []).

-spec describe_lookup_tables(aws_client:aws_client(), describe_lookup_tables_request(), proplists:proplist()) ->
    {ok, describe_lookup_tables_response(), tuple()} |
    {error, any()} |
    {error, describe_lookup_tables_errors(), tuple()}.
describe_lookup_tables(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeLookupTables">>, Input, Options).

%% @doc Lists the specified metric filters.
%%
%% You can list all of the metric filters or filter
%% the results by log name, prefix, metric name, or metric namespace. The
%% results are
%% ASCII-sorted by filter name.
-spec describe_metric_filters(aws_client:aws_client(), describe_metric_filters_request()) ->
    {ok, describe_metric_filters_response(), tuple()} |
    {error, any()} |
    {error, describe_metric_filters_errors(), tuple()}.
describe_metric_filters(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_metric_filters(Client, Input, []).

-spec describe_metric_filters(aws_client:aws_client(), describe_metric_filters_request(), proplists:proplist()) ->
    {ok, describe_metric_filters_response(), tuple()} |
    {error, any()} |
    {error, describe_metric_filters_errors(), tuple()}.
describe_metric_filters(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeMetricFilters">>, Input, Options).

%% @doc Returns a list of CloudWatch Logs Insights queries that are
%% scheduled, running, or have
%% been run recently in this account.
%%
%% You can request all queries or limit it to queries of a
%% specific log group or queries with a certain status.
%%
%% This operation includes both interactive queries started directly by users
%% and automated
%% queries executed by scheduled query configurations. Scheduled query
%% executions appear in the
%% results alongside manually initiated queries, providing visibility into
%% all query activity in
%% your account.
-spec describe_queries(aws_client:aws_client(), describe_queries_request()) ->
    {ok, describe_queries_response(), tuple()} |
    {error, any()} |
    {error, describe_queries_errors(), tuple()}.
describe_queries(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_queries(Client, Input, []).

-spec describe_queries(aws_client:aws_client(), describe_queries_request(), proplists:proplist()) ->
    {ok, describe_queries_response(), tuple()} |
    {error, any()} |
    {error, describe_queries_errors(), tuple()}.
describe_queries(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeQueries">>, Input, Options).

%% @doc This operation returns a paginated list of your saved CloudWatch Logs
%% Insights query
%% definitions.
%%
%% You can retrieve query definitions from the current account or from a
%% source
%% account that is linked to the current account.
%%
%% You can use the `queryDefinitionNamePrefix' parameter to limit the
%% results to
%% only the query definitions that have names that start with a certain
%% string.
-spec describe_query_definitions(aws_client:aws_client(), describe_query_definitions_request()) ->
    {ok, describe_query_definitions_response(), tuple()} |
    {error, any()} |
    {error, describe_query_definitions_errors(), tuple()}.
describe_query_definitions(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_query_definitions(Client, Input, []).

-spec describe_query_definitions(aws_client:aws_client(), describe_query_definitions_request(), proplists:proplist()) ->
    {ok, describe_query_definitions_response(), tuple()} |
    {error, any()} |
    {error, describe_query_definitions_errors(), tuple()}.
describe_query_definitions(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeQueryDefinitions">>, Input, Options).

%% @doc Lists the resource policies in this account.
-spec describe_resource_policies(aws_client:aws_client(), describe_resource_policies_request()) ->
    {ok, describe_resource_policies_response(), tuple()} |
    {error, any()} |
    {error, describe_resource_policies_errors(), tuple()}.
describe_resource_policies(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_resource_policies(Client, Input, []).

-spec describe_resource_policies(aws_client:aws_client(), describe_resource_policies_request(), proplists:proplist()) ->
    {ok, describe_resource_policies_response(), tuple()} |
    {error, any()} |
    {error, describe_resource_policies_errors(), tuple()}.
describe_resource_policies(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeResourcePolicies">>, Input, Options).

%% @doc Lists the subscription filters for the specified log group.
%%
%% You can list all the
%% subscription filters or filter the results by prefix. The results are
%% ASCII-sorted by filter
%% name.
-spec describe_subscription_filters(aws_client:aws_client(), describe_subscription_filters_request()) ->
    {ok, describe_subscription_filters_response(), tuple()} |
    {error, any()} |
    {error, describe_subscription_filters_errors(), tuple()}.
describe_subscription_filters(Client, Input)
  when is_map(Client), is_map(Input) ->
    describe_subscription_filters(Client, Input, []).

-spec describe_subscription_filters(aws_client:aws_client(), describe_subscription_filters_request(), proplists:proplist()) ->
    {ok, describe_subscription_filters_response(), tuple()} |
    {error, any()} |
    {error, describe_subscription_filters_errors(), tuple()}.
describe_subscription_filters(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DescribeSubscriptionFilters">>, Input, Options).

%% @doc Disassociates the specified KMS key from the specified log group or
%% from all CloudWatch Logs Insights query results in the account.
%%
%% When you use `DisassociateKmsKey', you specify either the
%% `logGroupName' parameter or the `resourceIdentifier' parameter.
%% You
%% can't specify both of those parameters in the same operation.
%%
%% Specify the `logGroupName' parameter to stop using the KMS key to
%% encrypt future log events ingested and stored in the log group.
%% Instead, they will be encrypted with the default CloudWatch Logs method.
%% The log events
%% that were ingested while the key was associated with the log group are
%% still encrypted
%% with that key. Therefore, CloudWatch Logs will need permissions for the
%% key whenever
%% that data is accessed.
%%
%% Specify the `resourceIdentifier' parameter with the
%% `query-result' resource to stop using the KMS key to
%% encrypt the results of all future StartQuery:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_StartQuery.html
%% operations in the account. They will instead be encrypted with the default
%% CloudWatch Logs method. The results from queries that ran while the key
%% was associated with
%% the account are still encrypted with that key. Therefore, CloudWatch Logs
%% will need
%% permissions for the key whenever that data is accessed.
%%
%% It can take up to 5 minutes for this operation to take effect.
-spec disassociate_kms_key(aws_client:aws_client(), disassociate_kms_key_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, disassociate_kms_key_errors(), tuple()}.
disassociate_kms_key(Client, Input)
  when is_map(Client), is_map(Input) ->
    disassociate_kms_key(Client, Input, []).

-spec disassociate_kms_key(aws_client:aws_client(), disassociate_kms_key_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, disassociate_kms_key_errors(), tuple()}.
disassociate_kms_key(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DisassociateKmsKey">>, Input, Options).

%% @doc Disassociates a data source from an S3 Table Integration, removing
%% query access and
%% deleting all associated data from the integration.
-spec disassociate_source_from_s3_table_integration(aws_client:aws_client(), disassociate_source_from_s3_table_integration_request()) ->
    {ok, disassociate_source_from_s3_table_integration_response(), tuple()} |
    {error, any()} |
    {error, disassociate_source_from_s3_table_integration_errors(), tuple()}.
disassociate_source_from_s3_table_integration(Client, Input)
  when is_map(Client), is_map(Input) ->
    disassociate_source_from_s3_table_integration(Client, Input, []).

-spec disassociate_source_from_s3_table_integration(aws_client:aws_client(), disassociate_source_from_s3_table_integration_request(), proplists:proplist()) ->
    {ok, disassociate_source_from_s3_table_integration_response(), tuple()} |
    {error, any()} |
    {error, disassociate_source_from_s3_table_integration_errors(), tuple()}.
disassociate_source_from_s3_table_integration(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"DisassociateSourceFromS3TableIntegration">>, Input, Options).

%% @doc Lists log events from the specified log group.
%%
%% You can list all the log events or
%% filter the results using one or more of the following:
%%
%% A filter pattern
%%
%% A time range
%%
%% The log stream name, or a log stream name prefix that matches multiple log
%% streams
%%
%% You must have the `logs:FilterLogEvents' permission to perform this
%% operation.
%%
%% You can specify the log group to search by using either
%% `logGroupIdentifier' or
%% `logGroupName'. You must include one of these two parameters, but you
%% can't
%% include both.
%%
%% `FilterLogEvents' is a paginated operation. Each page returned can
%% contain up
%% to 1 MB of log events or up to 10,000 log events. A returned page might
%% only be partially
%% full, or even empty. For example, if the result of a query would return
%% 15,000 log events, the
%% first page isn't guaranteed to have 10,000 log events even if they all
%% fit into 1 MB.
%%
%% Partially full or empty pages don't necessarily mean that pagination
%% is finished. If the
%% results include a `nextToken', there might be more log events
%% available. You can
%% return these additional log events by providing the nextToken in a
%% subsequent
%% `FilterLogEvents' operation. If the results don't include a
%% `nextToken', then pagination is finished.
%%
%% Specifying the `limit' parameter only guarantees that a single page
%% doesn't
%% return more log events than the specified limit, but it might return fewer
%% events than the
%% limit. This is the expected API behavior.
%%
%% The returned log events are sorted by event timestamp, the timestamp when
%% the event was
%% ingested by CloudWatch Logs, and the ID of the `PutLogEvents' request.
%%
%% If you are using CloudWatch cross-account observability, you can use this
%% operation
%% in a monitoring account and view data from the linked source accounts. For
%% more information,
%% see CloudWatch cross-account observability:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/CloudWatch-Unified-Cross-Account.html.
%%
%% If you are using log
%% transformation:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CloudWatch-Logs-Transformation.html,
%% the `FilterLogEvents' operation returns only the
%% original versions of log events, before they were transformed. To view the
%% transformed
%% versions, you must use a CloudWatch Logs
%% query.:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/AnalyzingLogData.html
-spec filter_log_events(aws_client:aws_client(), filter_log_events_request()) ->
    {ok, filter_log_events_response(), tuple()} |
    {error, any()} |
    {error, filter_log_events_errors(), tuple()}.
filter_log_events(Client, Input)
  when is_map(Client), is_map(Input) ->
    filter_log_events(Client, Input, []).

-spec filter_log_events(aws_client:aws_client(), filter_log_events_request(), proplists:proplist()) ->
    {ok, filter_log_events_response(), tuple()} |
    {error, any()} |
    {error, filter_log_events_errors(), tuple()}.
filter_log_events(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"FilterLogEvents">>, Input, Options).

%% @doc Returns information about a log group data protection policy.
-spec get_data_protection_policy(aws_client:aws_client(), get_data_protection_policy_request()) ->
    {ok, get_data_protection_policy_response(), tuple()} |
    {error, any()} |
    {error, get_data_protection_policy_errors(), tuple()}.
get_data_protection_policy(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_data_protection_policy(Client, Input, []).

-spec get_data_protection_policy(aws_client:aws_client(), get_data_protection_policy_request(), proplists:proplist()) ->
    {ok, get_data_protection_policy_response(), tuple()} |
    {error, any()} |
    {error, get_data_protection_policy_errors(), tuple()}.
get_data_protection_policy(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetDataProtectionPolicy">>, Input, Options).

%% @doc Returns complete information about one logical delivery.
%%
%% A delivery
%% is a connection between a
%% delivery
%% source
%% :
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDeliverySource.html
%% and a
%% delivery destination
%% :
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDeliveryDestination.html.
%%
%% A delivery source represents an Amazon Web Services resource that sends
%% logs to an logs
%% delivery destination. The destination can be CloudWatch Logs, Amazon S3,
%% or Firehose. Only some Amazon Web Services services support being
%% configured as a delivery
%% source. These services are listed in Enable logging from
%% Amazon Web Services services.:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/AWS-logs-and-resource-policy.html
%%
%% You need to specify the delivery `id' in this operation. You can find
%% the IDs
%% of the deliveries in your account with the DescribeDeliveries:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_DescribeDeliveries.html
%% operation.
-spec get_delivery(aws_client:aws_client(), get_delivery_request()) ->
    {ok, get_delivery_response(), tuple()} |
    {error, any()} |
    {error, get_delivery_errors(), tuple()}.
get_delivery(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_delivery(Client, Input, []).

-spec get_delivery(aws_client:aws_client(), get_delivery_request(), proplists:proplist()) ->
    {ok, get_delivery_response(), tuple()} |
    {error, any()} |
    {error, get_delivery_errors(), tuple()}.
get_delivery(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetDelivery">>, Input, Options).

%% @doc Retrieves complete information about one delivery destination.
-spec get_delivery_destination(aws_client:aws_client(), get_delivery_destination_request()) ->
    {ok, get_delivery_destination_response(), tuple()} |
    {error, any()} |
    {error, get_delivery_destination_errors(), tuple()}.
get_delivery_destination(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_delivery_destination(Client, Input, []).

-spec get_delivery_destination(aws_client:aws_client(), get_delivery_destination_request(), proplists:proplist()) ->
    {ok, get_delivery_destination_response(), tuple()} |
    {error, any()} |
    {error, get_delivery_destination_errors(), tuple()}.
get_delivery_destination(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetDeliveryDestination">>, Input, Options).

%% @doc Retrieves the delivery destination policy assigned to the delivery
%% destination that you
%% specify.
%%
%% For more information about delivery destinations and their policies, see
%% PutDeliveryDestinationPolicy:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDeliveryDestinationPolicy.html.
-spec get_delivery_destination_policy(aws_client:aws_client(), get_delivery_destination_policy_request()) ->
    {ok, get_delivery_destination_policy_response(), tuple()} |
    {error, any()} |
    {error, get_delivery_destination_policy_errors(), tuple()}.
get_delivery_destination_policy(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_delivery_destination_policy(Client, Input, []).

-spec get_delivery_destination_policy(aws_client:aws_client(), get_delivery_destination_policy_request(), proplists:proplist()) ->
    {ok, get_delivery_destination_policy_response(), tuple()} |
    {error, any()} |
    {error, get_delivery_destination_policy_errors(), tuple()}.
get_delivery_destination_policy(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetDeliveryDestinationPolicy">>, Input, Options).

%% @doc Retrieves complete information about one delivery source.
-spec get_delivery_source(aws_client:aws_client(), get_delivery_source_request()) ->
    {ok, get_delivery_source_response(), tuple()} |
    {error, any()} |
    {error, get_delivery_source_errors(), tuple()}.
get_delivery_source(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_delivery_source(Client, Input, []).

-spec get_delivery_source(aws_client:aws_client(), get_delivery_source_request(), proplists:proplist()) ->
    {ok, get_delivery_source_response(), tuple()} |
    {error, any()} |
    {error, get_delivery_source_errors(), tuple()}.
get_delivery_source(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetDeliverySource">>, Input, Options).

%% @doc Returns information about one integration between CloudWatch Logs and
%% OpenSearch Service.
-spec get_integration(aws_client:aws_client(), get_integration_request()) ->
    {ok, get_integration_response(), tuple()} |
    {error, any()} |
    {error, get_integration_errors(), tuple()}.
get_integration(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_integration(Client, Input, []).

-spec get_integration(aws_client:aws_client(), get_integration_request(), proplists:proplist()) ->
    {ok, get_integration_response(), tuple()} |
    {error, any()} |
    {error, get_integration_errors(), tuple()}.
get_integration(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetIntegration">>, Input, Options).

%% @doc Retrieves information about the log anomaly detector that you
%% specify.
%%
%% The KMS key ARN detected is valid.
-spec get_log_anomaly_detector(aws_client:aws_client(), get_log_anomaly_detector_request()) ->
    {ok, get_log_anomaly_detector_response(), tuple()} |
    {error, any()} |
    {error, get_log_anomaly_detector_errors(), tuple()}.
get_log_anomaly_detector(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_log_anomaly_detector(Client, Input, []).

-spec get_log_anomaly_detector(aws_client:aws_client(), get_log_anomaly_detector_request(), proplists:proplist()) ->
    {ok, get_log_anomaly_detector_response(), tuple()} |
    {error, any()} |
    {error, get_log_anomaly_detector_errors(), tuple()}.
get_log_anomaly_detector(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetLogAnomalyDetector">>, Input, Options).

%% @doc Lists log events from the specified log stream.
%%
%% You can list all of the log events or
%% filter using a time range.
%%
%% `GetLogEvents' is a paginated operation. Each page returned can
%% contain up to 1
%% MB of log events or up to 10,000 log events. A returned page might only be
%% partially full, or
%% even empty. For example, if the result of a query would return 15,000 log
%% events, the first
%% page isn't guaranteed to have 10,000 log events even if they all fit
%% into 1 MB.
%%
%% Partially full or empty pages don't necessarily mean that pagination
%% is finished. As long
%% as the `nextBackwardToken' or `nextForwardToken' returned is NOT
%% equal
%% to the `nextToken' that you passed into the API call, there might be
%% more log
%% events available. The token that you use depends on the direction you want
%% to move in along
%% the log stream. The returned tokens are never null.
%%
%% If you set `startFromHead' to `true' and you don’t include
%% `endTime' in your request, you can end up in a situation where the
%% pagination
%% doesn't terminate. This can happen when the new log events are being
%% added to the target log
%% streams faster than they are being read. This situation is a good use case
%% for the CloudWatch Logs
%% Live Tail:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CloudWatchLogs_LiveTail.html
%% feature.
%%
%% If you are using CloudWatch cross-account observability, you can use this
%% operation
%% in a monitoring account and view data from the linked source accounts. For
%% more information,
%% see CloudWatch cross-account observability:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/CloudWatch-Unified-Cross-Account.html.
%%
%% You can specify the log group to search by using either
%% `logGroupIdentifier' or
%% `logGroupName'. You must include one of these two parameters, but you
%% can't
%% include both.
%%
%% If you are using log
%% transformation:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CloudWatch-Logs-Transformation.html,
%% the `GetLogEvents' operation returns only the original
%% versions of log events, before they were transformed. To view the
%% transformed versions, you
%% must use a CloudWatch Logs
%% query.:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/AnalyzingLogData.html
-spec get_log_events(aws_client:aws_client(), get_log_events_request()) ->
    {ok, get_log_events_response(), tuple()} |
    {error, any()} |
    {error, get_log_events_errors(), tuple()}.
get_log_events(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_log_events(Client, Input, []).

-spec get_log_events(aws_client:aws_client(), get_log_events_request(), proplists:proplist()) ->
    {ok, get_log_events_response(), tuple()} |
    {error, any()} |
    {error, get_log_events_errors(), tuple()}.
get_log_events(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetLogEvents">>, Input, Options).

%% @doc Discovers available fields for a specific data source and type.
%%
%% The response includes any
%% field modifications introduced through pipelines, such as new fields or
%% changed field types.
-spec get_log_fields(aws_client:aws_client(), get_log_fields_request()) ->
    {ok, get_log_fields_response(), tuple()} |
    {error, any()} |
    {error, get_log_fields_errors(), tuple()}.
get_log_fields(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_log_fields(Client, Input, []).

-spec get_log_fields(aws_client:aws_client(), get_log_fields_request(), proplists:proplist()) ->
    {ok, get_log_fields_response(), tuple()} |
    {error, any()} |
    {error, get_log_fields_errors(), tuple()}.
get_log_fields(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetLogFields">>, Input, Options).

%% @doc Returns a list of the fields that are included in log events in the
%% specified log group.
%%
%% Includes the percentage of log events that contain each field. The search
%% is limited to a time
%% period that you specify.
%%
%% This operation is used for discovering fields within log group events. For
%% discovering
%% fields across data sources, use the GetLogFields operation.
%%
%% You can specify the log group to search by using either
%% `logGroupIdentifier' or
%% `logGroupName'. You must specify one of these parameters, but you
%% can't specify
%% both.
%%
%% In the results, fields that start with `@' are fields generated by
%% CloudWatch
%% Logs. For example, `@timestamp' is the timestamp of each log event.
%% For more
%% information about the fields that are generated by CloudWatch logs, see
%% Supported
%% Logs and Discovered Fields:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CWL_AnalyzeLogData-discoverable-fields.html.
%%
%% The response results are sorted by the frequency percentage, starting with
%% the highest
%% percentage.
%%
%% If you are using CloudWatch cross-account observability, you can use this
%% operation
%% in a monitoring account and view data from the linked source accounts. For
%% more information,
%% see CloudWatch cross-account observability:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/CloudWatch-Unified-Cross-Account.html.
-spec get_log_group_fields(aws_client:aws_client(), get_log_group_fields_request()) ->
    {ok, get_log_group_fields_response(), tuple()} |
    {error, any()} |
    {error, get_log_group_fields_errors(), tuple()}.
get_log_group_fields(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_log_group_fields(Client, Input, []).

-spec get_log_group_fields(aws_client:aws_client(), get_log_group_fields_request(), proplists:proplist()) ->
    {ok, get_log_group_fields_response(), tuple()} |
    {error, any()} |
    {error, get_log_group_fields_errors(), tuple()}.
get_log_group_fields(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetLogGroupFields">>, Input, Options).

%% @doc Retrieves a large logging object (LLO) and streams it back.
%%
%% This API is used to fetch the
%% content of large portions of log events that have been ingested through
%% the
%% PutOpenTelemetryLogs API. When log events contain fields that would cause
%% the total event size
%% to exceed 1MB, CloudWatch Logs automatically processes up to 10 fields,
%% starting with the
%% largest fields. Each field is truncated as needed to keep the total event
%% size as close to 1MB
%% as possible. The excess portions are stored as Large Log Objects (LLOs)
%% and these fields are
%% processed separately and LLO reference system fields (in the format
%% `@ptr.$[path.to.field]') are added. The path in the reference field
%% reflects the
%% original JSON structure where the large field was located. For example,
%% this could be
%% `@ptr.$['input']['message']',
%% `@ptr.$['AAA']['BBB']['CCC']['DDD']',
%% `@ptr.$['AAA']', or any other path matching your log
%% structure.
%%
%% The `GetLogObject' API routes requests using SDK host prefix
%% injection. SDK versions released before April 1, 2026 route to
%% `streaming-logs.Region.amazonaws.com', which does not support VPC
%% endpoints. SDK versions released on or after April 1, 2026 route to
%% `stream-logs.Region.amazonaws.com', which supports VPC endpoints. To
%% set up a VPC endpoint for this API, see Creating a VPC endpoint for
%% CloudWatch Logs
%% :
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/cloudwatch-logs-and-interface-VPC.html#create-VPC-endpoint-for-CloudWatchLogs.
-spec get_log_object(aws_client:aws_client(), get_log_object_request()) ->
    {ok, get_log_object_response(), tuple()} |
    {error, any()} |
    {error, get_log_object_errors(), tuple()}.
get_log_object(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_log_object(Client, Input, []).

-spec get_log_object(aws_client:aws_client(), get_log_object_request(), proplists:proplist()) ->
    {ok, get_log_object_response(), tuple()} |
    {error, any()} |
    {error, get_log_object_errors(), tuple()}.
get_log_object(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetLogObject">>, Input, Options).

%% @doc Retrieves all of the fields and values of a single log event.
%%
%% All fields are retrieved,
%% even if the original query that produced the `logRecordPointer'
%% retrieved only a
%% subset of fields. Fields are returned as field name/field value pairs.
%%
%% The full unparsed log event is returned within `@message'.
-spec get_log_record(aws_client:aws_client(), get_log_record_request()) ->
    {ok, get_log_record_response(), tuple()} |
    {error, any()} |
    {error, get_log_record_errors(), tuple()}.
get_log_record(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_log_record(Client, Input, []).

-spec get_log_record(aws_client:aws_client(), get_log_record_request(), proplists:proplist()) ->
    {ok, get_log_record_response(), tuple()} |
    {error, any()} |
    {error, get_log_record_errors(), tuple()}.
get_log_record(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetLogRecord">>, Input, Options).

%% @doc Retrieves the full content of a lookup table, including the CSV data.
-spec get_lookup_table(aws_client:aws_client(), get_lookup_table_request()) ->
    {ok, get_lookup_table_response(), tuple()} |
    {error, any()} |
    {error, get_lookup_table_errors(), tuple()}.
get_lookup_table(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_lookup_table(Client, Input, []).

-spec get_lookup_table(aws_client:aws_client(), get_lookup_table_request(), proplists:proplist()) ->
    {ok, get_lookup_table_response(), tuple()} |
    {error, any()} |
    {error, get_lookup_table_errors(), tuple()}.
get_lookup_table(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetLookupTable">>, Input, Options).

%% @doc Returns the results from the specified query.
%%
%% Only the fields requested in the query are returned, along with a
%% `@ptr' field,
%% which is the identifier for the log record. You can use the value of
%% `@ptr' in a
%% GetLogRecord:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_GetLogRecord.html
%% operation to get the full log record.
%%
%% `GetQueryResults' does not start running a query. To run a query, use
%% StartQuery:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_StartQuery.html.
%% For more information about how long results of previous queries are
%% available, see CloudWatch Logs
%% quotas:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/cloudwatch_limits_cwl.html.
%%
%% If the value of the `Status' field in the output is `Running',
%% this
%% operation returns only partial results. If you see a value of
%% `Scheduled' or
%% `Running' for the status, you can retry the operation later to see the
%% final
%% results.
%%
%% This operation is used both for retrieving results from interactive
%% queries and from
%% automated scheduled query executions. Scheduled queries use
%% `GetQueryResults'
%% internally to retrieve query results for processing and delivery to
%% configured
%% destinations.
%%
%% You can retrieve up to 100,000 log event results from a query, if
%% available, by using
%% pagination. Use the `nextToken' returned in the response to request
%% additional
%% pages of results, with each page returning up to 10,000 log events.
%%
%% If you are using CloudWatch cross-account observability, you can use this
%% operation
%% in a monitoring account to start queries in linked source accounts. For
%% more information, see
%% CloudWatch cross-account observability:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/CloudWatch-Unified-Cross-Account.html.
-spec get_query_results(aws_client:aws_client(), get_query_results_request()) ->
    {ok, get_query_results_response(), tuple()} |
    {error, any()} |
    {error, get_query_results_errors(), tuple()}.
get_query_results(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_query_results(Client, Input, []).

-spec get_query_results(aws_client:aws_client(), get_query_results_request(), proplists:proplist()) ->
    {ok, get_query_results_response(), tuple()} |
    {error, any()} |
    {error, get_query_results_errors(), tuple()}.
get_query_results(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetQueryResults">>, Input, Options).

%% @doc Retrieves details about a specific scheduled query, including its
%% configuration, execution
%% status, and metadata.
-spec get_scheduled_query(aws_client:aws_client(), get_scheduled_query_request()) ->
    {ok, get_scheduled_query_response(), tuple()} |
    {error, any()} |
    {error, get_scheduled_query_errors(), tuple()}.
get_scheduled_query(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_scheduled_query(Client, Input, []).

-spec get_scheduled_query(aws_client:aws_client(), get_scheduled_query_request(), proplists:proplist()) ->
    {ok, get_scheduled_query_response(), tuple()} |
    {error, any()} |
    {error, get_scheduled_query_errors(), tuple()}.
get_scheduled_query(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetScheduledQuery">>, Input, Options).

%% @doc Retrieves the execution history of a scheduled query within a
%% specified time range,
%% including query results and destination processing status.
-spec get_scheduled_query_history(aws_client:aws_client(), get_scheduled_query_history_request()) ->
    {ok, get_scheduled_query_history_response(), tuple()} |
    {error, any()} |
    {error, get_scheduled_query_history_errors(), tuple()}.
get_scheduled_query_history(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_scheduled_query_history(Client, Input, []).

-spec get_scheduled_query_history(aws_client:aws_client(), get_scheduled_query_history_request(), proplists:proplist()) ->
    {ok, get_scheduled_query_history_response(), tuple()} |
    {error, any()} |
    {error, get_scheduled_query_history_errors(), tuple()}.
get_scheduled_query_history(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetScheduledQueryHistory">>, Input, Options).

%% @doc Returns the information about the log transformer associated with
%% this log group.
%%
%% This operation returns data only for transformers created at the log group
%% level. To get
%% information for an account-level transformer, use DescribeAccountPolicies:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_DescribeAccountPolicies.html.
-spec get_transformer(aws_client:aws_client(), get_transformer_request()) ->
    {ok, get_transformer_response(), tuple()} |
    {error, any()} |
    {error, get_transformer_errors(), tuple()}.
get_transformer(Client, Input)
  when is_map(Client), is_map(Input) ->
    get_transformer(Client, Input, []).

-spec get_transformer(aws_client:aws_client(), get_transformer_request(), proplists:proplist()) ->
    {ok, get_transformer_response(), tuple()} |
    {error, any()} |
    {error, get_transformer_errors(), tuple()}.
get_transformer(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"GetTransformer">>, Input, Options).

%% @doc Returns an aggregate summary of all log groups in the Region grouped
%% by specified data
%% source characteristics.
%%
%% Supports optional filtering by log group class, name patterns, and
%% data sources. If you perform this action in a monitoring account, you can
%% also return
%% aggregated summaries of log groups from source accounts that are linked to
%% the monitoring
%% account. For more information about using cross-account observability to
%% set up monitoring
%% accounts and source accounts, see CloudWatch
%% cross-account observability:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/CloudWatch-Unified-Cross-Account.html.
%%
%% The operation aggregates log groups by data source name and type and
%% optionally format,
%% providing counts of log groups that share these characteristics. The
%% operation paginates
%% results. By default, it returns up to 50 results and includes a token to
%% retrieve more
%% results.
-spec list_aggregate_log_group_summaries(aws_client:aws_client(), list_aggregate_log_group_summaries_request()) ->
    {ok, list_aggregate_log_group_summaries_response(), tuple()} |
    {error, any()} |
    {error, list_aggregate_log_group_summaries_errors(), tuple()}.
list_aggregate_log_group_summaries(Client, Input)
  when is_map(Client), is_map(Input) ->
    list_aggregate_log_group_summaries(Client, Input, []).

-spec list_aggregate_log_group_summaries(aws_client:aws_client(), list_aggregate_log_group_summaries_request(), proplists:proplist()) ->
    {ok, list_aggregate_log_group_summaries_response(), tuple()} |
    {error, any()} |
    {error, list_aggregate_log_group_summaries_errors(), tuple()}.
list_aggregate_log_group_summaries(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"ListAggregateLogGroupSummaries">>, Input, Options).

%% @doc Returns a list of anomalies that log anomaly detectors have found.
%%
%% For details about the
%% structure format of each anomaly object that is returned, see the example
%% in this
%% section.
-spec list_anomalies(aws_client:aws_client(), list_anomalies_request()) ->
    {ok, list_anomalies_response(), tuple()} |
    {error, any()} |
    {error, list_anomalies_errors(), tuple()}.
list_anomalies(Client, Input)
  when is_map(Client), is_map(Input) ->
    list_anomalies(Client, Input, []).

-spec list_anomalies(aws_client:aws_client(), list_anomalies_request(), proplists:proplist()) ->
    {ok, list_anomalies_response(), tuple()} |
    {error, any()} |
    {error, list_anomalies_errors(), tuple()}.
list_anomalies(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"ListAnomalies">>, Input, Options).

%% @doc Returns a list of integrations between CloudWatch Logs and other
%% services in this
%% account.
%%
%% Currently, only one integration can be created in an account, and this
%% integration
%% must be with OpenSearch Service.
-spec list_integrations(aws_client:aws_client(), list_integrations_request()) ->
    {ok, list_integrations_response(), tuple()} |
    {error, any()} |
    {error, list_integrations_errors(), tuple()}.
list_integrations(Client, Input)
  when is_map(Client), is_map(Input) ->
    list_integrations(Client, Input, []).

-spec list_integrations(aws_client:aws_client(), list_integrations_request(), proplists:proplist()) ->
    {ok, list_integrations_response(), tuple()} |
    {error, any()} |
    {error, list_integrations_errors(), tuple()}.
list_integrations(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"ListIntegrations">>, Input, Options).

%% @doc Retrieves a list of the log anomaly detectors in the account.
-spec list_log_anomaly_detectors(aws_client:aws_client(), list_log_anomaly_detectors_request()) ->
    {ok, list_log_anomaly_detectors_response(), tuple()} |
    {error, any()} |
    {error, list_log_anomaly_detectors_errors(), tuple()}.
list_log_anomaly_detectors(Client, Input)
  when is_map(Client), is_map(Input) ->
    list_log_anomaly_detectors(Client, Input, []).

-spec list_log_anomaly_detectors(aws_client:aws_client(), list_log_anomaly_detectors_request(), proplists:proplist()) ->
    {ok, list_log_anomaly_detectors_response(), tuple()} |
    {error, any()} |
    {error, list_log_anomaly_detectors_errors(), tuple()}.
list_log_anomaly_detectors(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"ListLogAnomalyDetectors">>, Input, Options).

%% @doc Returns a list of log groups in the Region in your account.
%%
%% If you are performing this
%% action in a monitoring account, you can choose to also return log groups
%% from source accounts
%% that are linked to the monitoring account. For more information about
%% using cross-account
%% observability to set up monitoring accounts and source accounts, see
%% CloudWatch cross-account observability:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/CloudWatch-Unified-Cross-Account.html.
%%
%% You can optionally filter the results by log group class, log group name
%% pattern,
%% field indexes, data sources, field index names, or log group tags. If you
%% specify more than
%% one filter type, the results include log groups that satisfy all filters.
%%
%% This operation is paginated. By default, your first use of this operation
%% returns 50
%% results, and includes a token to use in a subsequent operation to return
%% more results.
-spec list_log_groups(aws_client:aws_client(), list_log_groups_request()) ->
    {ok, list_log_groups_response(), tuple()} |
    {error, any()} |
    {error, list_log_groups_errors(), tuple()}.
list_log_groups(Client, Input)
  when is_map(Client), is_map(Input) ->
    list_log_groups(Client, Input, []).

-spec list_log_groups(aws_client:aws_client(), list_log_groups_request(), proplists:proplist()) ->
    {ok, list_log_groups_response(), tuple()} |
    {error, any()} |
    {error, list_log_groups_errors(), tuple()}.
list_log_groups(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"ListLogGroups">>, Input, Options).

%% @doc Returns a list of the log groups that were analyzed during a single
%% CloudWatch Logs
%% Insights query.
%%
%% This can be useful for queries that use log group name prefixes or the
%% `filterIndex' command, because the log groups are dynamically selected
%% in these
%% cases.
%%
%% For more information about field indexes, see Create field indexes
%% to improve query performance and reduce costs:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CloudWatchLogs-Field-Indexing.html.
-spec list_log_groups_for_query(aws_client:aws_client(), list_log_groups_for_query_request()) ->
    {ok, list_log_groups_for_query_response(), tuple()} |
    {error, any()} |
    {error, list_log_groups_for_query_errors(), tuple()}.
list_log_groups_for_query(Client, Input)
  when is_map(Client), is_map(Input) ->
    list_log_groups_for_query(Client, Input, []).

-spec list_log_groups_for_query(aws_client:aws_client(), list_log_groups_for_query_request(), proplists:proplist()) ->
    {ok, list_log_groups_for_query_response(), tuple()} |
    {error, any()} |
    {error, list_log_groups_for_query_errors(), tuple()}.
list_log_groups_for_query(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"ListLogGroupsForQuery">>, Input, Options).

%% @doc Lists all scheduled queries in your account and region.
%%
%% You can filter results by state to
%% show only enabled or disabled queries.
-spec list_scheduled_queries(aws_client:aws_client(), list_scheduled_queries_request()) ->
    {ok, list_scheduled_queries_response(), tuple()} |
    {error, any()} |
    {error, list_scheduled_queries_errors(), tuple()}.
list_scheduled_queries(Client, Input)
  when is_map(Client), is_map(Input) ->
    list_scheduled_queries(Client, Input, []).

-spec list_scheduled_queries(aws_client:aws_client(), list_scheduled_queries_request(), proplists:proplist()) ->
    {ok, list_scheduled_queries_response(), tuple()} |
    {error, any()} |
    {error, list_scheduled_queries_errors(), tuple()}.
list_scheduled_queries(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"ListScheduledQueries">>, Input, Options).

%% @doc Returns a list of data source associations for a specified S3 Table
%% Integration, showing
%% which data sources are currently associated for query access.
-spec list_sources_for_s3_table_integration(aws_client:aws_client(), list_sources_for_s3_table_integration_request()) ->
    {ok, list_sources_for_s3_table_integration_response(), tuple()} |
    {error, any()} |
    {error, list_sources_for_s3_table_integration_errors(), tuple()}.
list_sources_for_s3_table_integration(Client, Input)
  when is_map(Client), is_map(Input) ->
    list_sources_for_s3_table_integration(Client, Input, []).

-spec list_sources_for_s3_table_integration(aws_client:aws_client(), list_sources_for_s3_table_integration_request(), proplists:proplist()) ->
    {ok, list_sources_for_s3_table_integration_response(), tuple()} |
    {error, any()} |
    {error, list_sources_for_s3_table_integration_errors(), tuple()}.
list_sources_for_s3_table_integration(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"ListSourcesForS3TableIntegration">>, Input, Options).

%% @doc Displays the tags associated with a CloudWatch Logs resource.
%%
%% Currently, log groups and
%% destinations support tagging.
-spec list_tags_for_resource(aws_client:aws_client(), list_tags_for_resource_request()) ->
    {ok, list_tags_for_resource_response(), tuple()} |
    {error, any()} |
    {error, list_tags_for_resource_errors(), tuple()}.
list_tags_for_resource(Client, Input)
  when is_map(Client), is_map(Input) ->
    list_tags_for_resource(Client, Input, []).

-spec list_tags_for_resource(aws_client:aws_client(), list_tags_for_resource_request(), proplists:proplist()) ->
    {ok, list_tags_for_resource_response(), tuple()} |
    {error, any()} |
    {error, list_tags_for_resource_errors(), tuple()}.
list_tags_for_resource(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"ListTagsForResource">>, Input, Options).

%% @doc
%% The ListTagsLogGroup operation is on the path to deprecation.
%%
%% We recommend that you use
%% ListTagsForResource:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_ListTagsForResource.html
%% instead.
%%
%% Lists the tags for the specified log group.
-spec list_tags_log_group(aws_client:aws_client(), list_tags_log_group_request()) ->
    {ok, list_tags_log_group_response(), tuple()} |
    {error, any()} |
    {error, list_tags_log_group_errors(), tuple()}.
list_tags_log_group(Client, Input)
  when is_map(Client), is_map(Input) ->
    list_tags_log_group(Client, Input, []).

-spec list_tags_log_group(aws_client:aws_client(), list_tags_log_group_request(), proplists:proplist()) ->
    {ok, list_tags_log_group_response(), tuple()} |
    {error, any()} |
    {error, list_tags_log_group_errors(), tuple()}.
list_tags_log_group(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"ListTagsLogGroup">>, Input, Options).

%% @doc Creates an account-level data protection policy, subscription filter
%% policy, field index
%% policy, transformer policy, or metric extraction policy that applies to
%% all log groups, a
%% subset of log groups, or a data source name and type combination in the
%% account.
%%
%% For field index policies, you can configure indexed fields as facets
%% to enable interactive exploration of your logs. Facets provide value
%% distributions and counts
%% for indexed fields in the CloudWatch Logs Insights console without
%% requiring query
%% execution. For more information, see Use facets to group and
%% explore logs:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CloudWatchLogs-Facets.html.
%%
%% To use this operation, you must be signed on with the correct permissions
%% depending on the
%% type of policy that you are creating.
%%
%% To create a data protection policy, you must have the
%% `logs:PutDataProtectionPolicy' and `logs:PutAccountPolicy'
%% permissions.
%%
%% To create a subscription filter policy, you must have the
%% `logs:PutSubscriptionFilter' and `logs:PutAccountPolicy'
%% permissions.
%%
%% To create a transformer policy, you must have the
%% `logs:PutTransformer' and
%% `logs:PutAccountPolicy' permissions.
%%
%% To create a field index policy, you must have the
%% `logs:PutIndexPolicy' and
%% `logs:PutAccountPolicy' permissions.
%%
%% To configure facets for field index policies, you must have the
%% `logs:PutIndexPolicy' and `logs:PutAccountPolicy'
%% permissions.
%%
%% To create a metric extraction policy, you must have the
%% `logs:PutMetricExtractionPolicy' and `logs:PutAccountPolicy'
%% permissions.
%%
%% Data protection policy
%%
%% A data protection policy can help safeguard sensitive data that's
%% ingested by your log
%% groups by auditing and masking the sensitive log data. Each account can
%% have only one
%% account-level data protection policy.
%%
%% Sensitive data is detected and masked when it is ingested into a log
%% group. When you set
%% a data protection policy, log events ingested into the log groups before
%% that time are not
%% masked.
%%
%% If you use `PutAccountPolicy' to create a data protection policy for
%% your whole
%% account, it applies to both existing log groups and all log groups that
%% are created later in
%% this account. The account-level policy is applied to existing log groups
%% with eventual
%% consistency. It might take up to 5 minutes before sensitive data in
%% existing log groups begins
%% to be masked.
%%
%% By default, when a user views a log event that includes masked data, the
%% sensitive data is
%% replaced by asterisks. A user who has the `logs:Unmask' permission can
%% use a GetLogEvents:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_GetLogEvents.html
%% or FilterLogEvents:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_FilterLogEvents.html
%% operation with the `unmask' parameter set to
%% `true' to view the unmasked log events. Users with the
%% `logs:Unmask'
%% can also view unmasked data in the CloudWatch Logs console by running a
%% CloudWatch Logs
%% Insights query with the `unmask' query command.
%%
%% For more information, including a list of types of data that can be
%% audited and masked,
%% see Protect sensitive log data
%% with masking:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/mask-sensitive-log-data.html.
%%
%% To use the `PutAccountPolicy' operation for a data protection policy,
%% you must
%% be signed on with the `logs:PutDataProtectionPolicy' and
%% `logs:PutAccountPolicy' permissions.
%%
%% The `PutAccountPolicy' operation applies to all log groups in the
%% account. You
%% can use PutDataProtectionPolicy:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDataProtectionPolicy.html
%% to create a data protection policy that applies to just one
%% log group. If a log group has its own data protection policy and the
%% account also has an
%% account-level data protection policy, then the two policies are
%% cumulative. Any sensitive term
%% specified in either policy is masked.
%%
%% Subscription filter policy
%%
%% A subscription filter policy sets up a real-time feed of log events from
%% CloudWatch Logs to other Amazon Web Services services. Account-level
%% subscription filter policies apply to
%% both existing log groups and log groups that are created later in this
%% account. Supported
%% destinations are Kinesis Data Streams, Firehose, and Lambda. When log
%% events are sent to the receiving service, they are Base64 encoded and
%% compressed with the GZIP
%% format.
%%
%% The following destinations are supported for subscription filters:
%%
%% An Kinesis Data Streams data stream in the same account as the
%% subscription policy, for
%% same-account delivery.
%%
%% An Firehose data stream in the same account as the subscription policy,
%% for
%% same-account delivery.
%%
%% A Lambda function in the same account as the subscription policy, for
%% same-account delivery.
%%
%% A logical destination in a different account created with PutDestination:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDestination.html,
%% for cross-account delivery. Kinesis Data Streams and Firehose are
%% supported as logical destinations.
%%
%% Each account can have one account-level subscription filter policy per
%% Region. If you are
%% updating an existing filter, you must specify the correct name in
%% `PolicyName'. To
%% perform a `PutAccountPolicy' subscription filter operation for any
%% destination
%% except a Lambda function, you must also have the `iam:PassRole'
%% permission.
%%
%% Transformer policy
%%
%% Creates or updates a log transformer policy for your account. You use
%% log transformers to transform log events into a different format, making
%% them easier for you
%% to process and analyze. You can also transform logs from different sources
%% into standardized
%% formats that contain relevant, source-specific information. After you have
%% created a
%% transformer, CloudWatch Logs performs this transformation at the time of
%% log ingestion. You
%% can then refer to the transformed versions of the logs during operations
%% such as querying with
%% CloudWatch Logs Insights or creating metric filters or subscription
%% filters.
%%
%% You can also use a transformer to copy metadata from metadata keys into
%% the log events
%% themselves. This metadata can include log group name, log stream name,
%% account ID and
%% Region.
%%
%% A transformer for a log group is a series of processors, where each
%% processor applies one
%% type of transformation to the log events ingested into this log group. For
%% more information
%% about the available processors to use in a transformer, see Processors
%% that you can use:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CloudWatch-Logs-Transformation.html#CloudWatch-Logs-Transformation-Processors.
%%
%% Having log events in standardized format enables visibility across your
%% applications for
%% your log analysis, reporting, and alarming needs. CloudWatch Logs provides
%% transformation
%% for common log types with out-of-the-box transformation templates for
%% major Amazon Web Services
%% log sources such as VPC flow logs, Lambda, and Amazon RDS. You can use
%% pre-built transformation templates or create custom transformation
%% policies.
%%
%% You can create transformers only for the log groups in the Standard log
%% class.
%%
%% You can have one account-level transformer policy that applies to all log
%% groups in the
%% account. Or you can create as many as 20 account-level transformer
%% policies that are each
%% scoped to a subset of log groups with the `selectionCriteria'
%% parameter. If you
%% have multiple account-level transformer policies with selection criteria,
%% no two of them can
%% use the same or overlapping log group name prefixes. For example, if you
%% have one policy
%% filtered to log groups that start with `my-log', you can't have
%% another transformer
%% policy filtered to `my-logpprod' or `my-logging'.
%%
%% You can also set up a transformer at the log-group level. For more
%% information, see PutTransformer:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutTransformer.html.
%% If there is both a log-group level transformer created with
%% `PutTransformer' and an account-level transformer that could apply to
%% the same
%% log group, the log group uses only the log-group level transformer. It
%% ignores the
%% account-level transformer.
%%
%% Field index policy
%%
%% You can use field index policies to create indexes on fields found in log
%% events for a log
%% group or data source name and type combination. Creating field indexes can
%% help lower the scan
%% volume for CloudWatch Logs Insights queries that reference those fields,
%% because these
%% queries attempt to skip the processing of log events that are known to not
%% match the indexed
%% field. Good fields to index are fields that you often need to query for
%% and fields or values
%% that match only a small fraction of the total log events. Common examples
%% of indexes include
%% request ID, session ID, user IDs, or instance IDs. For more information,
%% see Create field indexes to improve query performance and reduce costs:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CloudWatchLogs-Field-Indexing.html
%%
%% To find the fields that are in your log group events, use the
%% GetLogGroupFields:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_GetLogGroupFields.html
%% operation. To find the fields for a data source use the GetLogFields:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_GetLogFields.html
%% operation.
%%
%% For example, suppose you have created a field index for `requestId'.
%% Then, any
%% CloudWatch Logs Insights query on that log group that includes
%% ```
%% requestId = value ''' or
%% ```
%% requestId in [value, value, ...]''' will attempt to process
%% only the log events where
%% the indexed field matches the specified value.
%%
%% Matches of log events to the names of indexed fields are case-sensitive.
%% For example, an
%% indexed field of `RequestId' won't match a log event containing
%% `requestId'.
%%
%% You can have one account-level field index policy that applies to all log
%% groups in the
%% account. Or you can create as many as 20 account-level field index
%% policies that are each
%% scoped to a subset of log groups using `LogGroupNamePrefix' with the
%% `selectionCriteria' parameter. You can have another 20 account-level
%% field index
%% policies using `DataSourceName' and `DataSourceType' for the
%% `selectionCriteria' parameter. If you have multiple account-level
%% index policies
%% with `LogGroupNamePrefix' selection criteria, no two of them can use
%% the same or
%% overlapping log group name prefixes. For example, if you have one policy
%% filtered to log
%% groups that start with my-log, you can't have another field index
%% policy
%% filtered to my-logpprod or my-logging. Similarly, if
%% you have multiple account-level index policies with `DataSourceName'
%% and
%% `DataSourceType' selection criteria, no two of them can use the same
%% data source
%% name and type combination. For example, if you have one policy filtered to
%% the data source
%% name `amazon_vpc' and data source type `flow' you cannot create
%% another
%% policy with this combination.
%%
%% If you create an account-level field index policy in a monitoring account
%% in cross-account
%% observability, the policy is applied only to the monitoring account and
%% not to any source
%% accounts.
%%
%% CloudWatch Logs provides default field indexes for all log groups in the
%% Standard log
%% class. Default field indexes are automatically available for the following
%% fields:
%%
%% `@logStream'
%%
%% `@aws.region'
%%
%% `@aws.account'
%%
%% `@source.log'
%%
%% `@data_source_name'
%%
%% `@data_source_type'
%%
%% `@data_format'
%%
%% `traceId'
%%
%% `severityText'
%%
%% `attributes.session.id'
%%
%% CloudWatch Logs provides default field indexes for certain data source
%% name and type
%% combinations as well. Default field indexes are automatically available
%% for the following data
%% source name and type combinations as identified in the following list:
%%
%% `amazon_vpc.flow'
%%
%% `action'
%%
%% `logStatus'
%%
%% `region'
%%
%% `flowDirection'
%%
%% `type'
%%
%% `amazon_route53.resolver_query'
%%
%% `transport'
%%
%% `rcode'
%%
%% `aws_waf.access'
%%
%% `action'
%%
%% `httpRequest.country'
%%
%% `aws_cloudtrail.data', `aws_cloudtrail.management'
%%
%% `eventSource'
%%
%% `eventName'
%%
%% `awsRegion'
%%
%% `userAgent'
%%
%% `errorCode'
%%
%% `eventType'
%%
%% `managementEvent'
%%
%% `readOnly'
%%
%% `eventCategory'
%%
%% `requestId'
%%
%% Default field indexes are in addition to any custom field indexes you
%% define within your
%% policy. Default field indexes are not counted towards your field index
%% quota:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CloudWatchLogs-Field-Indexing-Syntax.
%%
%% If you want to create a field index policy for a single log group, you can
%% use PutIndexPolicy:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutIndexPolicy.html
%% instead of `PutAccountPolicy'. If you do so, that log
%% group will use that log-group level policy and any account-level policies
%% that match at the
%% data source level; any account-level policy that matches at the log group
%% level (for example,
%% no selection criteria or log group name prefix selection criteria) will be
%% ignored.
%%
%% Metric extraction policy
%%
%% A metric extraction policy controls whether CloudWatch Metrics can be
%% created through the
%% Embedded Metrics Format (EMF) for log groups in your account. By default,
%% EMF metric creation
%% is enabled for all log groups. You can use metric extraction policies to
%% disable EMF metric
%% creation for your entire account or specific log groups.
%%
%% When a policy disables EMF metric creation for a log group, log events in
%% the EMF format
%% are still ingested, but no CloudWatch Metrics are created from them.
%%
%% Creating a policy disables metrics for Amazon Web Services features that
%% use EMF to create metrics, such
%% as CloudWatch Container Insights and CloudWatch Application Signals. To
%% prevent turning off
%% those features by accident, we recommend that you exclude the underlying
%% log-groups through
%% a selection-criteria such as
%% ```
%% LogGroupNamePrefix NOT IN [&quot;/aws/containerinsights&quot;,
%% &quot;/aws/ecs/containerinsights&quot;,
%% &quot;/aws/application-signals/data&quot;]'''.
%%
%% Each account can have either one account-level metric extraction policy
%% that applies to
%% all log groups, or up to 5 policies that are each scoped to a subset of
%% log groups with the
%% `selectionCriteria' parameter. The selection criteria supports
%% filtering by
%% `LogGroupName' and `LogGroupNamePrefix' using the operators
%% `IN' and `NOT IN'. You can specify up to 50 values in each
%% `IN' or `NOT IN' list.
%%
%% The selection criteria can be specified in these formats:
%%
%% `LogGroupName IN [&quot;log-group-1&quot;, &quot;log-group-2&quot;]'
%%
%% `LogGroupNamePrefix NOT IN [&quot;/aws/prefix1&quot;,
%% &quot;/aws/prefix2&quot;]'
%%
%% If you have multiple account-level metric extraction policies with
%% selection criteria, no
%% two of them can have overlapping criteria. For example, if you have one
%% policy with selection
%% criteria `LogGroupNamePrefix IN [&quot;my-log&quot;]', you can't
%% have another metric
%% extraction policy with selection criteria `LogGroupNamePrefix IN
%% [&quot;/my-log-prod&quot;]'
%% or `LogGroupNamePrefix IN [&quot;/my-logging&quot;]', as the set of
%% log groups matching these
%% prefixes would be a subset of the log groups matching the first
%% policy's prefix, creating an
%% overlap.
%%
%% When using `NOT IN', only one policy with this operator is allowed per
%% account.
%%
%% When combining policies with `IN' and `NOT IN' operators, the
%% overlap check ensures that policies don't have conflicting effects.
%% Two policies with
%% `IN' and `NOT IN' operators do not overlap if and only if every
%% value
%% in the `IN 'policy is completely contained within some value in the
%% ```
%% NOT IN''' policy. For example:
%%
%% If you have a `NOT IN' policy for prefix
%% `&quot;/aws/lambda&quot;', you
%% can create an `IN' policy for the exact log group name
%% `&quot;/aws/lambda/function1&quot;' because the set of log groups
%% matching
%% `&quot;/aws/lambda/function1&quot;' is a subset of the log groups
%% matching
%% `&quot;/aws/lambda&quot;'.
%%
%% If you have a `NOT IN' policy for prefix
%% `&quot;/aws/lambda&quot;', you
%% cannot create an `IN' policy for prefix `&quot;/aws&quot;' because
%% the set of
%% log groups matching `&quot;/aws&quot;' is not a subset of the log
%% groups matching
%% `&quot;/aws/lambda&quot;'.
-spec put_account_policy(aws_client:aws_client(), put_account_policy_request()) ->
    {ok, put_account_policy_response(), tuple()} |
    {error, any()} |
    {error, put_account_policy_errors(), tuple()}.
put_account_policy(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_account_policy(Client, Input, []).

-spec put_account_policy(aws_client:aws_client(), put_account_policy_request(), proplists:proplist()) ->
    {ok, put_account_policy_response(), tuple()} |
    {error, any()} |
    {error, put_account_policy_errors(), tuple()}.
put_account_policy(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutAccountPolicy">>, Input, Options).

%% @doc Enables or disables bearer token authentication for the specified log
%% group.
%%
%% When enabled on a
%% log group, bearer token authentication is enabled on operations until it
%% is explicitly
%% disabled.
%%
%% For information about the parameters that are common to all actions, see
%% Common Parameters:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/CommonParameters.html.
-spec put_bearer_token_authentication(aws_client:aws_client(), put_bearer_token_authentication_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, put_bearer_token_authentication_errors(), tuple()}.
put_bearer_token_authentication(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_bearer_token_authentication(Client, Input, []).

-spec put_bearer_token_authentication(aws_client:aws_client(), put_bearer_token_authentication_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, put_bearer_token_authentication_errors(), tuple()}.
put_bearer_token_authentication(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutBearerTokenAuthentication">>, Input, Options).

%% @doc Creates a data protection policy for the specified log group.
%%
%% A data protection policy can
%% help safeguard sensitive data that's ingested by the log group by
%% auditing and masking the
%% sensitive log data.
%%
%% Sensitive data is detected and masked when it is ingested into the log
%% group. When you
%% set a data protection policy, log events ingested into the log group
%% before that time are
%% not masked.
%%
%% By default, when a user views a log event that includes masked data, the
%% sensitive data is
%% replaced by asterisks. A user who has the `logs:Unmask' permission can
%% use a GetLogEvents:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_GetLogEvents.html
%% or FilterLogEvents:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_FilterLogEvents.html
%% operation with the `unmask' parameter set to
%% `true' to view the unmasked log events. Users with the
%% `logs:Unmask'
%% can also view unmasked data in the CloudWatch Logs console by running a
%% CloudWatch Logs
%% Insights query with the `unmask' query command.
%%
%% For more information, including a list of types of data that can be
%% audited and masked,
%% see Protect sensitive log data
%% with masking:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/mask-sensitive-log-data.html.
%%
%% The `PutDataProtectionPolicy' operation applies to only the specified
%% log
%% group. You can also use PutAccountPolicy:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutAccountPolicy.html
%% to create an account-level data protection policy that applies to
%% all log groups in the account, including both existing log groups and log
%% groups that are
%% created level. If a log group has its own data protection policy and the
%% account also has an
%% account-level data protection policy, then the two policies are
%% cumulative. Any sensitive term
%% specified in either policy is masked.
-spec put_data_protection_policy(aws_client:aws_client(), put_data_protection_policy_request()) ->
    {ok, put_data_protection_policy_response(), tuple()} |
    {error, any()} |
    {error, put_data_protection_policy_errors(), tuple()}.
put_data_protection_policy(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_data_protection_policy(Client, Input, []).

-spec put_data_protection_policy(aws_client:aws_client(), put_data_protection_policy_request(), proplists:proplist()) ->
    {ok, put_data_protection_policy_response(), tuple()} |
    {error, any()} |
    {error, put_data_protection_policy_errors(), tuple()}.
put_data_protection_policy(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutDataProtectionPolicy">>, Input, Options).

%% @doc Creates or updates a logical delivery destination.
%%
%% A delivery
%% destination is an Amazon Web Services resource that represents an Amazon
%% Web Services service
%% that logs can be sent to. CloudWatch Logs, Amazon S3, and Firehose are
%% supported as logs delivery destinations and X-Ray as the trace delivery
%% destination.
%%
%% To configure logs delivery between a supported Amazon Web Services service
%% and a
%% destination, you must do the following:
%%
%% Create a delivery source, which is a logical object that represents the
%% resource that
%% is actually sending the logs. For more information, see PutDeliverySource:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDeliverySource.html.
%%
%% Use `PutDeliveryDestination' to create a delivery
%% destination in the same account of the actual delivery destination. The
%% delivery destination that you create is a logical object that represents
%% the actual
%% delivery destination.
%%
%% If you are delivering logs cross-account, you must use
%% PutDeliveryDestinationPolicy:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDeliveryDestinationPolicy.html
%% in the destination account to assign an IAM policy to the destination.
%% This policy allows delivery to that destination.
%%
%% Use `CreateDelivery' to create a delivery by pairing
%% exactly one delivery source and one delivery destination. For more
%% information, see CreateDelivery:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_CreateDelivery.html.
%%
%% You can configure a single delivery source to send logs to multiple
%% destinations by
%% creating multiple deliveries. You can also create multiple deliveries to
%% configure multiple
%% delivery sources to send logs to the same delivery destination.
%%
%% Only some Amazon Web Services services support being configured as a
%% delivery source. These
%% services are listed as Supported [V2 Permissions] in the
%% table at Enabling logging from
%% Amazon Web Services services.:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/AWS-logs-and-resource-policy.html
%%
%% If you use this operation to update an existing delivery destination, all
%% the current
%% delivery destination parameters are overwritten with the new parameter
%% values that you
%% specify.
-spec put_delivery_destination(aws_client:aws_client(), put_delivery_destination_request()) ->
    {ok, put_delivery_destination_response(), tuple()} |
    {error, any()} |
    {error, put_delivery_destination_errors(), tuple()}.
put_delivery_destination(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_delivery_destination(Client, Input, []).

-spec put_delivery_destination(aws_client:aws_client(), put_delivery_destination_request(), proplists:proplist()) ->
    {ok, put_delivery_destination_response(), tuple()} |
    {error, any()} |
    {error, put_delivery_destination_errors(), tuple()}.
put_delivery_destination(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutDeliveryDestination">>, Input, Options).

%% @doc Creates and assigns an IAM policy that grants permissions to
%% CloudWatch Logs to deliver logs cross-account to a specified destination
%% in this account.
%%
%% To
%% configure the delivery of logs from an Amazon Web Services service in
%% another account to a logs
%% delivery destination in the current account, you must do the following:
%%
%% Create a delivery source, which is a logical object that represents the
%% resource that
%% is actually sending the logs. For more information, see PutDeliverySource:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDeliverySource.html.
%%
%% Create a delivery destination, which is a logical object that
%% represents the actual delivery destination. For more information, see
%% PutDeliveryDestination:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDeliveryDestination.html.
%%
%% Use this operation in the destination account to assign an IAM policy
%% to the destination. This policy allows delivery to that destination.
%%
%% Create a delivery by pairing exactly one delivery source and one
%% delivery destination. For more information, see CreateDelivery:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_CreateDelivery.html.
%%
%% Only some Amazon Web Services services support being configured as a
%% delivery source. These
%% services are listed as Supported [V2 Permissions] in the
%% table at Enabling logging from
%% Amazon Web Services services.:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/AWS-logs-and-resource-policy.html
%%
%% The contents of the policy must include two statements. One statement
%% enables general logs
%% delivery, and the other allows delivery to the chosen destination. See the
%% examples for the
%% needed policies.
-spec put_delivery_destination_policy(aws_client:aws_client(), put_delivery_destination_policy_request()) ->
    {ok, put_delivery_destination_policy_response(), tuple()} |
    {error, any()} |
    {error, put_delivery_destination_policy_errors(), tuple()}.
put_delivery_destination_policy(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_delivery_destination_policy(Client, Input, []).

-spec put_delivery_destination_policy(aws_client:aws_client(), put_delivery_destination_policy_request(), proplists:proplist()) ->
    {ok, put_delivery_destination_policy_response(), tuple()} |
    {error, any()} |
    {error, put_delivery_destination_policy_errors(), tuple()}.
put_delivery_destination_policy(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutDeliveryDestinationPolicy">>, Input, Options).

%% @doc Creates or updates a logical delivery source.
%%
%% A delivery source
%% represents an Amazon Web Services resource that sends logs to an logs
%% delivery destination. The
%% destination can be CloudWatch Logs, Amazon S3, Firehose or X-Ray for
%% sending traces.
%%
%% To configure logs delivery between a delivery destination and an Amazon
%% Web Services
%% service that is supported as a delivery source, you must do the following:
%%
%% Use `PutDeliverySource' to create a delivery source, which is a
%% logical
%% object that represents the resource that is actually sending the logs.
%%
%% Use `PutDeliveryDestination' to create a delivery
%% destination, which is a logical object that represents the actual delivery
%% destination. For more information, see PutDeliveryDestination:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDeliveryDestination.html.
%%
%% If you are delivering logs cross-account, you must use
%% PutDeliveryDestinationPolicy:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDeliveryDestinationPolicy.html
%% in the destination account to assign an IAM policy to the destination.
%% This policy allows delivery to that destination.
%%
%% Use `CreateDelivery' to create a delivery by pairing
%% exactly one delivery source and one delivery destination. For more
%% information, see CreateDelivery:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_CreateDelivery.html.
%%
%% You can configure a single delivery source to send logs to multiple
%% destinations by
%% creating multiple deliveries. You can also create multiple deliveries to
%% configure multiple
%% delivery sources to send logs to the same delivery destination.
%%
%% Only some Amazon Web Services services support being configured as a
%% delivery source. These
%% services are listed as Supported [V2 Permissions] in the
%% table at Enabling logging from
%% Amazon Web Services services.:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/AWS-logs-and-resource-policy.html
%%
%% If you use this operation to update an existing delivery source, all the
%% current delivery
%% source parameters are overwritten with the new parameter values that you
%% specify.
-spec put_delivery_source(aws_client:aws_client(), put_delivery_source_request()) ->
    {ok, put_delivery_source_response(), tuple()} |
    {error, any()} |
    {error, put_delivery_source_errors(), tuple()}.
put_delivery_source(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_delivery_source(Client, Input, []).

-spec put_delivery_source(aws_client:aws_client(), put_delivery_source_request(), proplists:proplist()) ->
    {ok, put_delivery_source_response(), tuple()} |
    {error, any()} |
    {error, put_delivery_source_errors(), tuple()}.
put_delivery_source(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutDeliverySource">>, Input, Options).

%% @doc Creates or updates a destination.
%%
%% This operation is used only to create destinations
%% for cross-account subscriptions.
%%
%% A destination encapsulates a physical resource (such as an Amazon Kinesis
%% stream). With
%% a destination, you can subscribe to a real-time stream of log events for a
%% different account,
%% ingested using PutLogEvents:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutLogEvents.html.
%%
%% Through an access policy, a destination controls what is written to it. By
%% default,
%% `PutDestination' does not set any access policy with the destination,
%% which means
%% a cross-account user cannot call PutSubscriptionFilter:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutSubscriptionFilter.html
%% against this destination. To enable this, the destination
%% owner must call PutDestinationPolicy:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDestinationPolicy.html
%% after `PutDestination'.
%%
%% To perform a `PutDestination' operation, you must also have the
%% `iam:PassRole' permission.
-spec put_destination(aws_client:aws_client(), put_destination_request()) ->
    {ok, put_destination_response(), tuple()} |
    {error, any()} |
    {error, put_destination_errors(), tuple()}.
put_destination(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_destination(Client, Input, []).

-spec put_destination(aws_client:aws_client(), put_destination_request(), proplists:proplist()) ->
    {ok, put_destination_response(), tuple()} |
    {error, any()} |
    {error, put_destination_errors(), tuple()}.
put_destination(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutDestination">>, Input, Options).

%% @doc Creates or updates an access policy associated with an existing
%% destination.
%%
%% An access
%% policy is an IAM
%% policy document:
%% https://docs.aws.amazon.com/IAM/latest/UserGuide/policies_overview.html
%% that is used to authorize claims to register a subscription filter
%% against a given destination.
-spec put_destination_policy(aws_client:aws_client(), put_destination_policy_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, put_destination_policy_errors(), tuple()}.
put_destination_policy(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_destination_policy(Client, Input, []).

-spec put_destination_policy(aws_client:aws_client(), put_destination_policy_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, put_destination_policy_errors(), tuple()}.
put_destination_policy(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutDestinationPolicy">>, Input, Options).

%% @doc Creates or updates a field index policy for the specified log group.
%%
%% Only log groups in the Standard log class support field index policies.
%% For more information
%% about log classes, see Log
%% classes:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CloudWatch_Logs_Log_Classes.html.
%%
%% You can use field index policies to create field indexes on fields
%% found in log events in the log group. Creating field indexes speeds up and
%% lowers the costs
%% for CloudWatch Logs Insights queries that reference those field indexes,
%% because these
%% queries attempt to skip the processing of log events that are known to not
%% match the indexed
%% field. Good fields to index are fields that you often need to query for
%% and fields or values
%% that match only a small fraction of the total log events. Common examples
%% of indexes include
%% request ID, session ID, userID, and instance IDs. For more information,
%% see Create field indexes to improve query performance and reduce costs:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CloudWatchLogs-Field-Indexing.html.
%%
%% You can configure indexed fields as facets to enable interactive
%% exploration and filtering of your logs in the CloudWatch Logs Insights
%% console. Facets
%% allow you to view value distributions and counts for indexed fields
%% without running queries.
%% When you create a field index, you can optionally set it as a facet to
%% enable this interactive
%% analysis capability. For more information, see Use facets to group and
%% explore logs:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CloudWatchLogs-Facets.html.
%%
%% To find the fields that are in your log group events, use the
%% GetLogGroupFields:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_GetLogGroupFields.html
%% operation.
%%
%% For example, suppose you have created a field index for `requestId'.
%% Then, any
%% CloudWatch Logs Insights query on that log group that includes
%% ```
%% requestId = value ''' or
%% ```
%% requestId IN [value, value, ...]''' will process fewer log
%% events to reduce costs, and
%% have improved performance.
%%
%% CloudWatch Logs provides default field indexes for all log groups in the
%% Standard log
%% class. Default field indexes are automatically available for the following
%% fields:
%%
%% `@logStream'
%%
%% `@aws.region'
%%
%% `@aws.account'
%%
%% `@source.log'
%%
%% `traceId'
%%
%% Default field indexes are in addition to any custom field indexes you
%% define within your
%% policy. Default field indexes are not counted towards your field index
%% quota.
%%
%% Each index policy has the following quotas and restrictions:
%%
%% As many as 20 fields can be included in the policy.
%%
%% Each field name can include as many as 100 characters.
%%
%% Matches of log events to the names of indexed fields are case-sensitive.
%% For example, a
%% field index of `RequestId' won't match a log event containing
%% `requestId'.
%%
%% Log group-level field index policies created with `PutIndexPolicy'
%% override
%% account-level field index policies created with PutAccountPolicy:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutAccountPolicy.html
%% that apply to log groups. If you use `PutIndexPolicy'
%% to create a field index policy for a log group, that log group uses only
%% that policy for log
%% group-level indexing, including any facet configurations. The log group
%% ignores any
%% account-wide field index policy that applies to log groups, but data
%% source-based account
%% policies may still apply.
-spec put_index_policy(aws_client:aws_client(), put_index_policy_request()) ->
    {ok, put_index_policy_response(), tuple()} |
    {error, any()} |
    {error, put_index_policy_errors(), tuple()}.
put_index_policy(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_index_policy(Client, Input, []).

-spec put_index_policy(aws_client:aws_client(), put_index_policy_request(), proplists:proplist()) ->
    {ok, put_index_policy_response(), tuple()} |
    {error, any()} |
    {error, put_index_policy_errors(), tuple()}.
put_index_policy(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutIndexPolicy">>, Input, Options).

%% @doc Creates an integration between CloudWatch Logs and another service in
%% this account.
%%
%% Currently, only integrations with OpenSearch Service are supported, and
%% currently you can have
%% only one integration in your account.
%%
%% Integrating with OpenSearch Service makes it possible for you to create
%% curated vended
%% logs dashboards, powered by OpenSearch Service analytics. For more
%% information, see Vended log
%% dashboards powered by Amazon OpenSearch Service:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CloudWatchLogs-OpenSearch-Dashboards.html.
%%
%% You can use this operation only to create a new integration. You can't
%% modify an existing
%% integration.
-spec put_integration(aws_client:aws_client(), put_integration_request()) ->
    {ok, put_integration_response(), tuple()} |
    {error, any()} |
    {error, put_integration_errors(), tuple()}.
put_integration(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_integration(Client, Input, []).

-spec put_integration(aws_client:aws_client(), put_integration_request(), proplists:proplist()) ->
    {ok, put_integration_response(), tuple()} |
    {error, any()} |
    {error, put_integration_errors(), tuple()}.
put_integration(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutIntegration">>, Input, Options).

%% @doc Uploads a batch of log events to the specified log stream.
%%
%% The sequence token is now ignored in `PutLogEvents' actions.
%% `PutLogEvents' actions are always accepted and never return
%% `InvalidSequenceTokenException' or `DataAlreadyAcceptedException'
%% even if the sequence token is not valid. You can use parallel
%% `PutLogEvents'
%% actions on the same log stream.
%%
%% The batch of events must satisfy the following constraints:
%%
%% The maximum batch size is 1,048,576 bytes. This size is calculated as the
%% sum of
%% all event messages in UTF-8, plus 26 bytes for each log event.
%%
%% Events more than 2 hours in the future are rejected while processing
%% remaining
%% valid events.
%%
%% Events older than 14 days or preceding the log group's retention
%% period are
%% rejected while processing remaining valid events.
%%
%% The log events in the batch must be in chronological order by their
%% timestamp. The
%% timestamp is the time that the event occurred, expressed as the number of
%% milliseconds
%% after `Jan 1, 1970 00:00:00 UTC'. (In Amazon Web Services Tools for
%% PowerShell
%% and the Amazon Web Services SDK for .NET, the timestamp is specified in
%% .NET format:
%% `yyyy-mm-ddThh:mm:ss'. For example, `2017-09-15T13:45:30'.)
%%
%% A batch of log events in a single request must be in a chronological
%% order.
%% Otherwise, the operation fails.
%%
%% Each log event can be no larger than 1 MB.
%%
%% The maximum number of log events in a batch is 10,000.
%%
%% For valid events (within 14 days in the past to 2 hours in future), the
%% time span
%% in a single batch cannot exceed 24 hours. Otherwise, the operation fails.
%%
%% The quota of five requests per second per log stream has been removed.
%% Instead,
%% `PutLogEvents' actions are throttled based on a per-second per-account
%% quota.
%% You can request an increase to the per-second throttling quota by using
%% the Service Quotas service.
%%
%% If a call to `PutLogEvents' returns
%% &quot;UnrecognizedClientException&quot; the most
%% likely cause is a non-valid Amazon Web Services access key ID or secret
%% key.
-spec put_log_events(aws_client:aws_client(), put_log_events_request()) ->
    {ok, put_log_events_response(), tuple()} |
    {error, any()} |
    {error, put_log_events_errors(), tuple()}.
put_log_events(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_log_events(Client, Input, []).

-spec put_log_events(aws_client:aws_client(), put_log_events_request(), proplists:proplist()) ->
    {ok, put_log_events_response(), tuple()} |
    {error, any()} |
    {error, put_log_events_errors(), tuple()}.
put_log_events(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutLogEvents">>, Input, Options).

%% @doc Enables or disables deletion protection for the specified log group.
%%
%% When enabled on a
%% log group, deletion protection blocks all deletion operations until it is
%% explicitly
%% disabled.
%%
%% For information about the parameters that are common to all actions, see
%% Common Parameters:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/CommonParameters.html.
-spec put_log_group_deletion_protection(aws_client:aws_client(), put_log_group_deletion_protection_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, put_log_group_deletion_protection_errors(), tuple()}.
put_log_group_deletion_protection(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_log_group_deletion_protection(Client, Input, []).

-spec put_log_group_deletion_protection(aws_client:aws_client(), put_log_group_deletion_protection_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, put_log_group_deletion_protection_errors(), tuple()}.
put_log_group_deletion_protection(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutLogGroupDeletionProtection">>, Input, Options).

%% @doc Creates or updates a metric filter and associates it with the
%% specified log group.
%%
%% With
%% metric filters, you can configure rules to extract metric data from log
%% events ingested
%% through PutLogEvents:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutLogEvents.html.
%%
%% The maximum number of metric filters that can be associated with a log
%% group is
%% 100.
%%
%% Using regular expressions in filter patterns is supported. For these
%% filters, there is a
%% quota of two regular expression patterns within a single filter pattern.
%% There is also a quota
%% of five regular expression patterns per log group. For more information
%% about using regular
%% expressions in filter patterns, see Filter pattern syntax for
%% metric filters, subscription filters, filter log events, and Live Tail:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/FilterAndPatternSyntax.html.
%%
%% When you create a metric filter, you can also optionally assign a unit and
%% dimensions to
%% the metric that is created.
%%
%% Metrics extracted from log events are charged as custom metrics. To
%% prevent unexpected
%% high charges, do not specify high-cardinality fields such as
%% `IPAddress' or
%% `requestID' as dimensions. Each different value found for a dimension
%% is
%% treated as a separate metric and accrues charges as a separate custom
%% metric.
%%
%% CloudWatch Logs might disable a metric filter if it generates 1,000
%% different
%% name/value pairs for your specified dimensions within one hour.
%%
%% You can also set up a billing alarm to alert you if your charges are
%% higher than
%% expected. For more information, see
%% Creating a Billing Alarm to Monitor Your Estimated Amazon Web Services
%% Charges:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/monitor_estimated_charges_with_cloudwatch.html.
-spec put_metric_filter(aws_client:aws_client(), put_metric_filter_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, put_metric_filter_errors(), tuple()}.
put_metric_filter(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_metric_filter(Client, Input, []).

-spec put_metric_filter(aws_client:aws_client(), put_metric_filter_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, put_metric_filter_errors(), tuple()}.
put_metric_filter(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutMetricFilter">>, Input, Options).

%% @doc Creates or updates a query definition for CloudWatch Logs Insights.
%%
%% For more information,
%% see Analyzing Log Data with CloudWatch Logs Insights:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/AnalyzingLogData.html.
%%
%% To update a query definition, specify its `queryDefinitionId' in your
%% request.
%% The values of `name', `queryString', and `logGroupNames' are
%% changed to the values that you specify in your update operation. No
%% current values are
%% retained from the current query definition. For example, imagine updating
%% a current query
%% definition that includes log groups. If you don't specify the
%% `logGroupNames'
%% parameter in your update operation, the query definition changes to
%% contain no log
%% groups.
%%
%% You must have the `logs:PutQueryDefinition' permission to be able to
%% perform
%% this operation.
-spec put_query_definition(aws_client:aws_client(), put_query_definition_request()) ->
    {ok, put_query_definition_response(), tuple()} |
    {error, any()} |
    {error, put_query_definition_errors(), tuple()}.
put_query_definition(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_query_definition(Client, Input, []).

-spec put_query_definition(aws_client:aws_client(), put_query_definition_request(), proplists:proplist()) ->
    {ok, put_query_definition_response(), tuple()} |
    {error, any()} |
    {error, put_query_definition_errors(), tuple()}.
put_query_definition(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutQueryDefinition">>, Input, Options).

%% @doc Creates or updates a resource policy allowing other Amazon Web
%% Services services to put
%% log events to this account, such as Amazon Route 53.
%%
%% This API has the following
%% restrictions:
%%
%% Supported actions - Policy only supports
%% `logs:PutLogEvents' and `logs:CreateLogStream ' actions
%%
%% Supported principals - Policy only applies when
%% operations are invoked by Amazon Web Services service principals (not IAM
%% users, roles, or cross-account principals
%%
%% Policy limits - An account can have a maximum of 10
%% policies without resourceARN and one per LogGroup resourceARN
%%
%% Resource policies with actions invoked by non-Amazon Web Services service
%% principals
%% (such as IAM users, roles, or other Amazon Web Services accounts) will not
%% be
%% enforced. For access control involving these principals, use the IAM
%% policies.
-spec put_resource_policy(aws_client:aws_client(), put_resource_policy_request()) ->
    {ok, put_resource_policy_response(), tuple()} |
    {error, any()} |
    {error, put_resource_policy_errors(), tuple()}.
put_resource_policy(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_resource_policy(Client, Input, []).

-spec put_resource_policy(aws_client:aws_client(), put_resource_policy_request(), proplists:proplist()) ->
    {ok, put_resource_policy_response(), tuple()} |
    {error, any()} |
    {error, put_resource_policy_errors(), tuple()}.
put_resource_policy(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutResourcePolicy">>, Input, Options).

%% @doc Sets the retention of the specified log group.
%%
%% With a retention policy, you can
%% configure the number of days for which to retain log events in the
%% specified log
%% group.
%%
%% CloudWatch Logs doesn't immediately delete log events when they reach
%% their retention
%% setting. It typically takes up to 72 hours after that before log events
%% are deleted, but in
%% rare situations might take longer.
%%
%% To illustrate, imagine that you change a log group to have a longer
%% retention setting
%% when it contains log events that are past the expiration date, but
%% haven't been deleted.
%% Those log events will take up to 72 hours to be deleted after the new
%% retention date is
%% reached. To make sure that log data is deleted permanently, keep a log
%% group at its lower
%% retention setting until 72 hours after the previous retention period ends.
%% Alternatively,
%% wait to change the retention setting until you confirm that the earlier
%% log events are
%% deleted.
%%
%% When log events reach their retention setting they are marked for
%% deletion. After they
%% are marked for deletion, they do not add to your archival storage costs
%% anymore, even if
%% they are not actually deleted until later. These log events marked for
%% deletion are also not
%% included when you use an API to retrieve the `storedBytes' value to
%% see how many
%% bytes a log group is storing.
-spec put_retention_policy(aws_client:aws_client(), put_retention_policy_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, put_retention_policy_errors(), tuple()}.
put_retention_policy(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_retention_policy(Client, Input, []).

-spec put_retention_policy(aws_client:aws_client(), put_retention_policy_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, put_retention_policy_errors(), tuple()}.
put_retention_policy(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutRetentionPolicy">>, Input, Options).

%% @doc Creates or updates a subscription filter and associates it with the
%% specified log
%% group.
%%
%% With subscription filters, you can subscribe to a real-time stream of log
%% events
%% ingested through PutLogEvents:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutLogEvents.html
%% and have them delivered to a specific destination. When log events are
%% sent to the receiving
%% service, they are Base64 encoded and compressed with the GZIP format.
%%
%% The following destinations are supported for subscription filters:
%%
%% An Amazon Kinesis data stream belonging to the same account as the
%% subscription
%% filter, for same-account delivery.
%%
%% A logical destination created with PutDestination:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutDestination.html
%% that belongs to a different account, for cross-account delivery.
%% We currently support Kinesis Data Streams and Firehose as logical
%% destinations.
%%
%% An Amazon Kinesis Data Firehose delivery stream that belongs to the same
%% account as
%% the subscription filter, for same-account delivery.
%%
%% An Lambda function that belongs to the same account as the
%% subscription filter, for same-account delivery.
%%
%% Each log group can have up to two subscription filters associated with it.
%% If you are
%% updating an existing filter, you must specify the correct name in
%% `filterName'.
%%
%% Using regular expressions in filter patterns is supported. For these
%% filters, there is a
%% quotas of quota of two regular expression patterns within a single filter
%% pattern. There is
%% also a quota of five regular expression patterns per log group. For more
%% information about
%% using regular expressions in filter patterns, see Filter pattern syntax
%% for
%% metric filters, subscription filters, filter log events, and Live Tail:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/FilterAndPatternSyntax.html.
%%
%% To perform a `PutSubscriptionFilter' operation for any destination
%% except a
%% Lambda function, you must also have the `iam:PassRole'
%% permission.
-spec put_subscription_filter(aws_client:aws_client(), put_subscription_filter_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, put_subscription_filter_errors(), tuple()}.
put_subscription_filter(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_subscription_filter(Client, Input, []).

-spec put_subscription_filter(aws_client:aws_client(), put_subscription_filter_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, put_subscription_filter_errors(), tuple()}.
put_subscription_filter(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutSubscriptionFilter">>, Input, Options).

%% @doc Creates or updates a log transformer for a single log group.
%%
%% You use
%% log transformers to transform log events into a different format, making
%% them easier for you
%% to process and analyze. You can also transform logs from different sources
%% into standardized
%% formats that contains relevant, source-specific information.
%%
%% After you have created a transformer, CloudWatch Logs performs the
%% transformations at
%% the time of log ingestion. You can then refer to the transformed versions
%% of the logs during
%% operations such as querying with CloudWatch Logs Insights or creating
%% metric filters or
%% subscription filers.
%%
%% You can also use a transformer to copy metadata from metadata keys into
%% the log events
%% themselves. This metadata can include log group name, log stream name,
%% account ID and
%% Region.
%%
%% A transformer for a log group is a series of processors, where each
%% processor applies one
%% type of transformation to the log events ingested into this log group. The
%% processors work one
%% after another, in the order that you list them, like a pipeline. For more
%% information about
%% the available processors to use in a transformer, see Processors that you
%% can use:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CloudWatch-Logs-Transformation.html#CloudWatch-Logs-Transformation-Processors.
%%
%% Having log events in standardized format enables visibility across your
%% applications for
%% your log analysis, reporting, and alarming needs. CloudWatch Logs provides
%% transformation
%% for common log types with out-of-the-box transformation templates for
%% major Amazon Web Services
%% log sources such as VPC flow logs, Lambda, and Amazon RDS. You can use
%% pre-built transformation templates or create custom transformation
%% policies.
%%
%% You can create transformers only for the log groups in the Standard log
%% class.
%%
%% You can also set up a transformer at the account level. For more
%% information, see PutAccountPolicy:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutAccountPolicy.html.
%% If there is both a log-group level transformer created with
%% `PutTransformer' and an account-level transformer that could apply to
%% the same
%% log group, the log group uses only the log-group level transformer. It
%% ignores the
%% account-level transformer.
-spec put_transformer(aws_client:aws_client(), put_transformer_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, put_transformer_errors(), tuple()}.
put_transformer(Client, Input)
  when is_map(Client), is_map(Input) ->
    put_transformer(Client, Input, []).

-spec put_transformer(aws_client:aws_client(), put_transformer_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, put_transformer_errors(), tuple()}.
put_transformer(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"PutTransformer">>, Input, Options).

%% @doc Starts a Live Tail streaming session for one or more log groups.
%%
%% A Live Tail session
%% returns a stream of log events that have been recently ingested in the log
%% groups. For more
%% information, see Use Live Tail to view logs
%% in near real time:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CloudWatchLogs_LiveTail.html.
%%
%% The response to this operation is a response stream, over which the server
%% sends live log
%% events and the client receives them.
%%
%% The following objects are sent over the stream:
%%
%% A single LiveTailSessionStart:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_LiveTailSessionStart.html
%% object is sent at the start of the session.
%%
%% Every second, a LiveTailSessionUpdate:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_LiveTailSessionUpdate.html
%% object is sent. Each of these objects contains an array
%% of the actual log events.
%%
%% If no new log events were ingested in the past second, the
%% `LiveTailSessionUpdate' object will contain an empty array.
%%
%% The array of log events contained in a `LiveTailSessionUpdate' can
%% include
%% as many as 500 log events. If the number of log events matching the
%% request exceeds 500
%% per second, the log events are sampled down to 500 log events to be
%% included in each
%% `LiveTailSessionUpdate' object.
%%
%% If your client consumes the log events slower than the server produces
%% them, CloudWatch Logs buffers up to 10 `LiveTailSessionUpdate' events
%% or 5000 log
%% events, after which it starts dropping the oldest events.
%%
%% A SessionStreamingException:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_StartLiveTailResponseStream.html#CWL-Type-StartLiveTailResponseStream-SessionStreamingException
%% object is returned if an unknown error occurs on the
%% server side.
%%
%% A SessionTimeoutException:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_StartLiveTailResponseStream.html#CWL-Type-StartLiveTailResponseStream-SessionTimeoutException
%% object is returned when the session times out, after it
%% has been kept open for three hours.
%%
%% The `StartLiveTail' API routes requests using SDK host prefix
%% injection. SDK versions released before April 1, 2026 route to
%% `streaming-logs.Region.amazonaws.com', which does not support VPC
%% endpoints. SDK versions released on or after April 1, 2026 route to
%% `stream-logs.Region.amazonaws.com', which supports VPC endpoints. To
%% set up a VPC endpoint for this API, see Creating a VPC endpoint for
%% CloudWatch Logs
%% :
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/cloudwatch-logs-and-interface-VPC.html#create-VPC-endpoint-for-CloudWatchLogs.
%%
%% You can end a session before it times out by closing the session stream or
%% by closing
%% the client that is receiving the stream. The session also ends if the
%% established connection
%% between the client and the server breaks.
%%
%% For examples of using an SDK to start a Live Tail session, see Start
%% a Live Tail session using an Amazon Web Services SDK:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/example_cloudwatch-logs_StartLiveTail_section.html.
-spec start_live_tail(aws_client:aws_client(), start_live_tail_request()) ->
    {ok, start_live_tail_response(), tuple()} |
    {error, any()} |
    {error, start_live_tail_errors(), tuple()}.
start_live_tail(Client, Input)
  when is_map(Client), is_map(Input) ->
    start_live_tail(Client, Input, []).

-spec start_live_tail(aws_client:aws_client(), start_live_tail_request(), proplists:proplist()) ->
    {ok, start_live_tail_response(), tuple()} |
    {error, any()} |
    {error, start_live_tail_errors(), tuple()}.
start_live_tail(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"StartLiveTail">>, Input, Options).

%% @doc Starts a query of one or more log groups or data sources using
%% CloudWatch Logs
%% Insights.
%%
%% You specify the log groups or data sources and time range to query and the
%% query
%% string to use. You can query up to 10 data sources in a single query.
%%
%% For more information, see CloudWatch Logs Insights Query
%% Syntax:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CWL_QuerySyntax.html.
%%
%% After you run a query using `StartQuery', the query results are stored
%% by
%% CloudWatch Logs. You can use GetQueryResults:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_GetQueryResults.html
%% to retrieve the results of a query, using the `queryId'
%% that `StartQuery' returns.
%%
%% Interactive queries started with `StartQuery' share concurrency limits
%% with
%% automated scheduled query executions. Both types of queries count toward
%% the same regional
%% concurrent query quota, so high scheduled query activity may affect the
%% availability of
%% concurrent slots for interactive queries.
%%
%% To specify the log groups to query, a `StartQuery' operation must
%% include one
%% of the following:
%%
%% Either exactly one of the following parameters: `logGroupName',
%% `logGroupNames', or `logGroupIdentifiers'
%%
%% Or the `queryString' must include a `SOURCE' command to select
%% log groups for the query. The `SOURCE' command can select log groups
%% based on
%% log group name prefix, account ID, and log class, or select data sources
%% using
%% dataSource syntax in LogsQL, PPL, and SQL. In LogsQL, the `SOURCE'
%% command
%% also supports filtering by log group tags.
%%
%% For more information about the `SOURCE' command, see SOURCE:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/CWL_QuerySyntax-Source.html.
%%
%% If you have associated a KMS key with the query results in this
%% account, then StartQuery:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_StartQuery.html
%% uses
%% that key to encrypt the results when it stores them. If no key is
%% associated with query
%% results, the query results are encrypted with the default CloudWatch Logs
%% encryption
%% method.
%%
%% Queries time out after 60 minutes of runtime. If your queries are timing
%% out, reduce the
%% time range being searched or partition your query into a number of
%% queries.
%%
%% If you are using CloudWatch cross-account observability, you can use this
%% operation
%% in a monitoring account to start a query in a linked source account. For
%% more information, see
%% CloudWatch cross-account observability:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/CloudWatch-Unified-Cross-Account.html.
%% For a cross-account `StartQuery'
%% operation, the query definition must be defined in the monitoring account.
%%
%% You can have up to 100 concurrent CloudWatch Logs insights queries,
%% including queries
%% that have been added to dashboards.
-spec start_query(aws_client:aws_client(), start_query_request()) ->
    {ok, start_query_response(), tuple()} |
    {error, any()} |
    {error, start_query_errors(), tuple()}.
start_query(Client, Input)
  when is_map(Client), is_map(Input) ->
    start_query(Client, Input, []).

-spec start_query(aws_client:aws_client(), start_query_request(), proplists:proplist()) ->
    {ok, start_query_response(), tuple()} |
    {error, any()} |
    {error, start_query_errors(), tuple()}.
start_query(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"StartQuery">>, Input, Options).

%% @doc Stops a CloudWatch Logs Insights query that is in progress.
%%
%% If the query has already
%% ended, the operation returns an error indicating that the specified query
%% is not
%% running.
%%
%% This operation can be used to cancel both interactive queries and
%% individual scheduled
%% query executions. When used with scheduled queries, `StopQuery'
%% cancels only the
%% specific execution identified by the query ID, not the scheduled query
%% configuration
%% itself.
-spec stop_query(aws_client:aws_client(), stop_query_request()) ->
    {ok, stop_query_response(), tuple()} |
    {error, any()} |
    {error, stop_query_errors(), tuple()}.
stop_query(Client, Input)
  when is_map(Client), is_map(Input) ->
    stop_query(Client, Input, []).

-spec stop_query(aws_client:aws_client(), stop_query_request(), proplists:proplist()) ->
    {ok, stop_query_response(), tuple()} |
    {error, any()} |
    {error, stop_query_errors(), tuple()}.
stop_query(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"StopQuery">>, Input, Options).

%% @doc
%% The TagLogGroup operation is on the path to deprecation.
%%
%% We recommend that you use
%% TagResource:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_TagResource.html
%% instead.
%%
%% Adds or updates the specified tags for the specified log group.
%%
%% To list the tags for a log group, use ListTagsForResource:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_ListTagsForResource.html.
%% To remove tags, use UntagResource:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_UntagResource.html.
%%
%% For more information about tags, see Tag Log Groups in Amazon CloudWatch
%% Logs:
%% https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/Working-with-log-groups-and-streams.html#log-group-tagging
%% in the Amazon CloudWatch Logs
%% User Guide.
%%
%% CloudWatch Logs doesn't support IAM policies that prevent users from
%% assigning specified
%% tags to log groups using the
%% ```
%% aws:Resource/key-name ''' or
%% `aws:TagKeys' condition keys. For more information about using tags to
%% control
%% access, see Controlling access to Amazon Web Services resources using
%% tags: https://docs.aws.amazon.com/IAM/latest/UserGuide/access_tags.html.
-spec tag_log_group(aws_client:aws_client(), tag_log_group_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, tag_log_group_errors(), tuple()}.
tag_log_group(Client, Input)
  when is_map(Client), is_map(Input) ->
    tag_log_group(Client, Input, []).

-spec tag_log_group(aws_client:aws_client(), tag_log_group_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, tag_log_group_errors(), tuple()}.
tag_log_group(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"TagLogGroup">>, Input, Options).

%% @doc Assigns one or more tags (key-value pairs) to the specified
%% CloudWatch Logs resource.
%%
%% Currently, the only CloudWatch Logs resources that can be tagged are log
%% groups and
%% destinations.
%%
%% 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.
%%
%% 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 for the alarm, this tag is appended to the list
%% of tags associated
%% with the alarm. If you specify a tag key that is already associated with
%% the alarm, the new
%% tag value that you specify replaces the previous value for that tag.
%%
%% You can associate as many as 50 tags with a CloudWatch Logs resource.
-spec tag_resource(aws_client:aws_client(), tag_resource_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, tag_resource_errors(), tuple()}.
tag_resource(Client, Input)
  when is_map(Client), is_map(Input) ->
    tag_resource(Client, Input, []).

-spec tag_resource(aws_client:aws_client(), tag_resource_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, tag_resource_errors(), tuple()}.
tag_resource(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"TagResource">>, Input, Options).

%% @doc Tests the filter pattern of a metric filter against a sample of log
%% event messages.
%%
%% You
%% can use this operation to validate the correctness of a metric filter
%% pattern.
-spec test_metric_filter(aws_client:aws_client(), test_metric_filter_request()) ->
    {ok, test_metric_filter_response(), tuple()} |
    {error, any()} |
    {error, test_metric_filter_errors(), tuple()}.
test_metric_filter(Client, Input)
  when is_map(Client), is_map(Input) ->
    test_metric_filter(Client, Input, []).

-spec test_metric_filter(aws_client:aws_client(), test_metric_filter_request(), proplists:proplist()) ->
    {ok, test_metric_filter_response(), tuple()} |
    {error, any()} |
    {error, test_metric_filter_errors(), tuple()}.
test_metric_filter(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"TestMetricFilter">>, Input, Options).

%% @doc Use this operation to test a log transformer.
%%
%% You enter the transformer configuration and
%% a set of log events to test with. The operation responds with an array
%% that includes the
%% original log events and the transformed versions.
-spec test_transformer(aws_client:aws_client(), test_transformer_request()) ->
    {ok, test_transformer_response(), tuple()} |
    {error, any()} |
    {error, test_transformer_errors(), tuple()}.
test_transformer(Client, Input)
  when is_map(Client), is_map(Input) ->
    test_transformer(Client, Input, []).

-spec test_transformer(aws_client:aws_client(), test_transformer_request(), proplists:proplist()) ->
    {ok, test_transformer_response(), tuple()} |
    {error, any()} |
    {error, test_transformer_errors(), tuple()}.
test_transformer(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"TestTransformer">>, Input, Options).

%% @doc
%% The UntagLogGroup operation is on the path to deprecation.
%%
%% We recommend that you use
%% UntagResource:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_UntagResource.html
%% instead.
%%
%% Removes the specified tags from the specified log group.
%%
%% To list the tags for a log group, use ListTagsForResource:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_ListTagsForResource.html.
%% To add tags, use TagResource:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_TagResource.html.
%%
%% When using IAM policies to control tag management for CloudWatch Logs log
%% groups, the
%% condition keys `aws:Resource/key-name' and `aws:TagKeys' cannot be
%% used
%% to restrict which tags users can assign.
-spec untag_log_group(aws_client:aws_client(), untag_log_group_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, untag_log_group_errors(), tuple()}.
untag_log_group(Client, Input)
  when is_map(Client), is_map(Input) ->
    untag_log_group(Client, Input, []).

-spec untag_log_group(aws_client:aws_client(), untag_log_group_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, untag_log_group_errors(), tuple()}.
untag_log_group(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"UntagLogGroup">>, Input, Options).

%% @doc Removes one or more tags from the specified resource.
-spec untag_resource(aws_client:aws_client(), untag_resource_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, untag_resource_errors(), tuple()}.
untag_resource(Client, Input)
  when is_map(Client), is_map(Input) ->
    untag_resource(Client, Input, []).

-spec untag_resource(aws_client:aws_client(), untag_resource_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, untag_resource_errors(), tuple()}.
untag_resource(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"UntagResource">>, Input, Options).

%% @doc Use this operation to suppress anomaly detection for a specified
%% anomaly or pattern.
%%
%% If you suppress an anomaly, CloudWatch Logs won't report new
%% occurrences of that anomaly and won't update that anomaly with new
%% data. If you suppress a
%% pattern, CloudWatch Logs won't report any anomalies related to that
%% pattern.
%%
%% You must specify either `anomalyId' or `patternId', but you
%% can't
%% specify both parameters in the same operation.
%%
%% If you have previously used this operation to suppress detection of a
%% pattern or anomaly,
%% you can use it again to cause CloudWatch Logs to end the suppression. To
%% do this, use this
%% operation and specify the anomaly or pattern to stop suppressing, and omit
%% the
%% `suppressionType' and `suppressionPeriod' parameters.
-spec update_anomaly(aws_client:aws_client(), update_anomaly_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, update_anomaly_errors(), tuple()}.
update_anomaly(Client, Input)
  when is_map(Client), is_map(Input) ->
    update_anomaly(Client, Input, []).

-spec update_anomaly(aws_client:aws_client(), update_anomaly_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, update_anomaly_errors(), tuple()}.
update_anomaly(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"UpdateAnomaly">>, Input, Options).

%% @doc Use this operation to update the configuration of a delivery:
%% https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_Delivery.html
%% to change
%% either the S3 path pattern or the format of the delivered logs.
%%
%% You can't use this operation
%% to change the source or destination of the delivery.
-spec update_delivery_configuration(aws_client:aws_client(), update_delivery_configuration_request()) ->
    {ok, update_delivery_configuration_response(), tuple()} |
    {error, any()} |
    {error, update_delivery_configuration_errors(), tuple()}.
update_delivery_configuration(Client, Input)
  when is_map(Client), is_map(Input) ->
    update_delivery_configuration(Client, Input, []).

-spec update_delivery_configuration(aws_client:aws_client(), update_delivery_configuration_request(), proplists:proplist()) ->
    {ok, update_delivery_configuration_response(), tuple()} |
    {error, any()} |
    {error, update_delivery_configuration_errors(), tuple()}.
update_delivery_configuration(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"UpdateDeliveryConfiguration">>, Input, Options).

%% @doc Updates an existing log anomaly detector.
-spec update_log_anomaly_detector(aws_client:aws_client(), update_log_anomaly_detector_request()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, update_log_anomaly_detector_errors(), tuple()}.
update_log_anomaly_detector(Client, Input)
  when is_map(Client), is_map(Input) ->
    update_log_anomaly_detector(Client, Input, []).

-spec update_log_anomaly_detector(aws_client:aws_client(), update_log_anomaly_detector_request(), proplists:proplist()) ->
    {ok, undefined, tuple()} |
    {error, any()} |
    {error, update_log_anomaly_detector_errors(), tuple()}.
update_log_anomaly_detector(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"UpdateLogAnomalyDetector">>, Input, Options).

%% @doc Updates an existing lookup table by replacing all of its CSV content.
%%
%% After the update
%% completes, queries that use this table will use the new data.
%%
%% This is a full replacement operation. All existing content is replaced
%% with the new CSV
%% data.
-spec update_lookup_table(aws_client:aws_client(), update_lookup_table_request()) ->
    {ok, update_lookup_table_response(), tuple()} |
    {error, any()} |
    {error, update_lookup_table_errors(), tuple()}.
update_lookup_table(Client, Input)
  when is_map(Client), is_map(Input) ->
    update_lookup_table(Client, Input, []).

-spec update_lookup_table(aws_client:aws_client(), update_lookup_table_request(), proplists:proplist()) ->
    {ok, update_lookup_table_response(), tuple()} |
    {error, any()} |
    {error, update_lookup_table_errors(), tuple()}.
update_lookup_table(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"UpdateLookupTable">>, Input, Options).

%% @doc Updates an existing scheduled query with new configuration.
%%
%% This operation uses PUT
%% semantics, allowing modification of query parameters, schedule, and
%% destinations.
-spec update_scheduled_query(aws_client:aws_client(), update_scheduled_query_request()) ->
    {ok, update_scheduled_query_response(), tuple()} |
    {error, any()} |
    {error, update_scheduled_query_errors(), tuple()}.
update_scheduled_query(Client, Input)
  when is_map(Client), is_map(Input) ->
    update_scheduled_query(Client, Input, []).

-spec update_scheduled_query(aws_client:aws_client(), update_scheduled_query_request(), proplists:proplist()) ->
    {ok, update_scheduled_query_response(), tuple()} |
    {error, any()} |
    {error, update_scheduled_query_errors(), tuple()}.
update_scheduled_query(Client, Input, Options)
  when is_map(Client), is_map(Input), is_list(Options) ->
    request(Client, <<"UpdateScheduledQuery">>, Input, Options).

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

-spec request(aws_client:aws_client(), binary(), map(), list()) ->
    {ok, Result, {integer(), list(), hackney:client()}} |
    {error, Error, {integer(), list(), hackney:client()}} |
    {error, term()} when
    Result :: map() | undefined,
    Error :: map().
request(Client, Action, Input, Options) ->
    RequestFun = fun() -> do_request(Client, Action, Input, Options) end,
    aws_request:request(RequestFun, Options).

do_request(Client, Action, Input0, Options) ->
    Client1 = Client#{service => <<"logs">>},
    DefaultHost = build_host(<<"logs">>, Client1),
    {URL, Host} = aws_util:apply_endpoint_url_override(build_url(DefaultHost, Client1), DefaultHost, <<"/">>, <<"AWS_ENDPOINT_URL_AWS_CLOUDWATCH_LOGS">>),
    Headers = [
        {<<"Host">>, Host},
        {<<"Content-Type">>, <<"application/x-amz-json-1.1">>},
        {<<"X-Amz-Target">>, <<"Logs_20140328.", Action/binary>>}
    ],

    Input = Input0,

    Payload = jsx:encode(Input),
    SignedHeaders = aws_request:sign_request(Client1, <<"POST">>, URL, Headers, Payload),
    Response = hackney:request(post, URL, SignedHeaders, Payload, Options),
    handle_response(Response).

handle_response({ok, 200, ResponseHeaders, Client}) ->
    case hackney:body(Client) of
        {ok, <<>>} ->
            {ok, undefined, {200, ResponseHeaders, Client}};
        {ok, Body} ->
            Result = jsx:decode(Body),
            {ok, Result, {200, ResponseHeaders, Client}}
    end;
handle_response({ok, StatusCode, ResponseHeaders, Client}) ->
    {ok, Body} = hackney:body(Client),
    Error = jsx:decode(Body),
    {error, Error, {StatusCode, ResponseHeaders, Client}};
handle_response({error, Reason}) ->
    {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, Client) ->
    Proto = aws_client:proto(Client),
    Port = aws_client:port(Client),
    aws_util:binary_join([Proto, <<"://">>, Host, <<":">>, Port, <<"/">>], <<"">>).