Source file values.ml

(* generated by: awso-codegen generate-all --botocore-data vendor/botocore/botocore/data -o aws --runtime-dir lib/runtime/awso --cli-dir awso-cli *)
open Awso
open! Import
[@@@warning "-32"]
let service = Service.timestream_query
let apiVersion = "2018-11-01"
let endpointPrefix = "query.timestream"
let serviceFullName = "Amazon Timestream Query"
let signatureVersion = "v4"
let protocol = "json"
let globalEndpoint = endpointPrefix ^ ".amazonaws.com"
let serviceAbbreviation = "Timestream Query"
let targetPrefix = "Timestream_20181101"
let simple_to_json to_value x =
  Botodata.Json.value_to_json_scalar (to_value x)
let composed_to_json to_value x = Botodata.Json.value_to_json (to_value x)
let to_query to_value x = Client.Query.of_value (to_value x)
let structure_to_value_aux st ~f =
  let filter = function | (k, Some v) -> Some (k, v) | _ -> None in
  let pair k v = (k, v) in
  let defer_value (k, dv) = pair k dv in
  ((List.filter_map st ~f:filter) |> (List.map ~f:defer_value)) |>
    (fun x -> `Structure (f x))
let structure_to_value = structure_to_value_aux ~f:Fn.id
let structure_to_wrapped_value ~wrapper ~response =
  structure_to_value_aux
    ~f:(fun x -> [(wrapper, (`Structure x)); (response, (`Structure []))])
module ServiceErrorMessage =
  struct
    type nonrec t = string
    let context_ = "ServiceErrorMessage"
    let make i = i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"ServiceErrorMessage" j
    let to_json = simple_to_json to_value
  end
module AccessDeniedException =
  struct
    type nonrec t = {
      message: ServiceErrorMessage.t option }
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("Message", (Option.map x.message ~f:ServiceErrorMessage.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:ServiceErrorMessage.of_xml)
          (Xml.child xml_arg0 "Message") in
      make ?message ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let message = field_map json__ "Message" ServiceErrorMessage.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "You do not have the necessary permissions to access the account settings."]
module AmazonResourceName =
  struct
    type nonrec t = string
    let context_ = "AmazonResourceName"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_max i ~max:2048) >>=
             (fun () -> check_string_min i ~min:1));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"AmazonResourceName" j
    let to_json = simple_to_json to_value
  end
module SnsConfiguration =
  struct
    type nonrec t =
      {
      topicArn: AmazonResourceName.t
        [@ocaml.doc
          "SNS topic ARN that the scheduled query status notifications will be sent to."]}
    let context_ = "SnsConfiguration"
    let make ~topicArn = fun () -> { topicArn }
    let to_value x =
      structure_to_value
        [("TopicArn", (Some (AmazonResourceName.to_value x.topicArn)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let topicArn =
        AmazonResourceName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "TopicArn") in
      make ~topicArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let topicArn =
        field_map_exn json__ "TopicArn" AmazonResourceName.of_json in
      make ~topicArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Details on SNS that are required to send the notification."]
module AccountSettingsNotificationConfiguration =
  struct
    type nonrec t =
      {
      snsConfiguration: SnsConfiguration.t option ;
      roleArn: AmazonResourceName.t
        [@ocaml.doc
          "An Amazon Resource Name (ARN) that grants Timestream permission to publish notifications. This field is only visible if SNS Topic is provided when updating the account settings."]}
    let context_ = "AccountSettingsNotificationConfiguration"
    let make ?snsConfiguration =
      fun ~roleArn -> fun () -> { snsConfiguration; roleArn }
    let to_value x =
      structure_to_value
        [("SnsConfiguration",
           (Option.map x.snsConfiguration ~f:SnsConfiguration.to_value));
        ("RoleArn", (Some (AmazonResourceName.to_value x.roleArn)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let roleArn =
        AmazonResourceName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "RoleArn") in
      let snsConfiguration =
        (Option.map ~f:SnsConfiguration.of_xml)
          (Xml.child xml_arg0 "SnsConfiguration") in
      make ~roleArn ?snsConfiguration ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let roleArn = field_map_exn json__ "RoleArn" AmazonResourceName.of_json in
      let snsConfiguration =
        field_map json__ "SnsConfiguration" SnsConfiguration.of_json in
      make ~roleArn ?snsConfiguration ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Configuration settings for notifications related to account settings."]
module QueryId =
  struct
    type nonrec t = string
    let context_ = "QueryId"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_min i ~min:1) >>=
             (fun () ->
                (check_string_max i ~max:64) >>=
                  (fun () -> check_pattern i ~pattern:"[a-zA-Z0-9]+")));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"QueryId" j
    let to_json = simple_to_json to_value
  end
module CancelQueryRequest =
  struct
    type nonrec t =
      {
      queryId: QueryId.t
        [@ocaml.doc
          "The ID of the query that needs to be cancelled. QueryID is returned as part of the query result."]}
    let context_ = "CancelQueryRequest"
    let make ~queryId = fun () -> { queryId }
    let to_value x =
      structure_to_value [("QueryId", (Some (QueryId.to_value x.queryId)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let queryId =
        QueryId.of_xml (Xml.child_exn ~context:context_ xml_arg0 "QueryId") in
      make ~queryId ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let queryId = field_map_exn json__ "QueryId" QueryId.of_json in
      make ~queryId ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Cancels a query that has been issued. Cancellation is provided only if the query has not completed running before the cancellation request was issued. Because cancellation is an idempotent operation, subsequent cancellation requests will return a CancellationMessage, indicating that the query has already been canceled. See code sample for details."]
module ErrorMessage =
  struct
    type nonrec t = string
    let context_ = "ErrorMessage"
    let make i = i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"ErrorMessage" j
    let to_json = simple_to_json to_value
  end
module ValidationException =
  struct
    type nonrec t = {
      message: ErrorMessage.t option }
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("Message", (Option.map x.message ~f:ErrorMessage.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:ErrorMessage.of_xml) (Xml.child xml_arg0 "Message") in
      make ?message ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let message = field_map json__ "Message" ErrorMessage.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Invalid or malformed request."]
module ThrottlingException =
  struct
    type nonrec t = {
      message: ErrorMessage.t option }
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("Message", (Option.map x.message ~f:ErrorMessage.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:ErrorMessage.of_xml) (Xml.child xml_arg0 "Message") in
      make ?message ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let message = field_map json__ "Message" ErrorMessage.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "The request was throttled due to excessive requests."]
module String_ =
  struct
    type nonrec t = string
    let context_ = "String"
    let make i = i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"String" j
    let to_json = simple_to_json to_value
  end
module InvalidEndpointException =
  struct
    type nonrec t = {
      message: ErrorMessage.t option }
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("Message", (Option.map x.message ~f:ErrorMessage.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:ErrorMessage.of_xml) (Xml.child xml_arg0 "Message") in
      make ?message ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let message = field_map json__ "Message" ErrorMessage.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "The requested endpoint is invalid."]
module InternalServerException =
  struct
    type nonrec t = {
      message: ErrorMessage.t option }
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("Message", (Option.map x.message ~f:ErrorMessage.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:ErrorMessage.of_xml) (Xml.child xml_arg0 "Message") in
      make ?message ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let message = field_map json__ "Message" ErrorMessage.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "An internal server error occurred while processing the request."]
module CancelQueryResponse =
  struct
    type nonrec t =
      {
      cancellationMessage: String_.t option
        [@ocaml.doc
          "A CancellationMessage is returned when a CancelQuery request for the query specified by QueryId has already been issued."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `InternalServerException of InternalServerException.t 
      | `InvalidEndpointException of InvalidEndpointException.t 
      | `ThrottlingException of ThrottlingException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?cancellationMessage = fun () -> { cancellationMessage }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_json json)
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_json json)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_xml xml)
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_xml xml)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `InternalServerException e ->
          `Assoc
            [("error", (`String "InternalServerException"));
            ("details", (InternalServerException.to_json e))]
      | `InvalidEndpointException e ->
          `Assoc
            [("error", (`String "InvalidEndpointException"));
            ("details", (InvalidEndpointException.to_json e))]
      | `ThrottlingException e ->
          `Assoc
            [("error", (`String "ThrottlingException"));
            ("details", (ThrottlingException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("CancellationMessage",
           (Option.map x.cancellationMessage ~f:String_.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let cancellationMessage =
        (Option.map ~f:String_.of_xml)
          (Xml.child xml_arg0 "CancellationMessage") in
      make ?cancellationMessage ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let cancellationMessage =
        field_map json__ "CancellationMessage" String_.of_json in
      make ?cancellationMessage ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Cancels a query that has been issued. Cancellation is provided only if the query has not completed running before the cancellation request was issued. Because cancellation is an idempotent operation, subsequent cancellation requests will return a CancellationMessage, indicating that the query has already been canceled. See code sample for details."]
module ClientRequestToken =
  struct
    type nonrec t = string
    let context_ = "ClientRequestToken"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_max i ~max:128) >>=
             (fun () -> check_string_min i ~min:32));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"ClientRequestToken" j
    let to_json = simple_to_json to_value
  end
module ClientToken =
  struct
    type nonrec t = string
    let context_ = "ClientToken"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_max i ~max:128) >>=
             (fun () -> check_string_min i ~min:32));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"ClientToken" j
    let to_json = simple_to_json to_value
  end
module ScalarType =
  struct
    type nonrec t =
      | VARCHAR 
      | BOOLEAN 
      | BIGINT 
      | DOUBLE 
      | TIMESTAMP 
      | DATE 
      | TIME 
      | INTERVAL_DAY_TO_SECOND 
      | INTERVAL_YEAR_TO_MONTH 
      | UNKNOWN 
      | INTEGER 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | VARCHAR -> "VARCHAR"
      | BOOLEAN -> "BOOLEAN"
      | BIGINT -> "BIGINT"
      | DOUBLE -> "DOUBLE"
      | TIMESTAMP -> "TIMESTAMP"
      | DATE -> "DATE"
      | TIME -> "TIME"
      | INTERVAL_DAY_TO_SECOND -> "INTERVAL_DAY_TO_SECOND"
      | INTERVAL_YEAR_TO_MONTH -> "INTERVAL_YEAR_TO_MONTH"
      | UNKNOWN -> "UNKNOWN"
      | INTEGER -> "INTEGER"
      | Non_static_id s -> s
    let of_string =
      function
      | "VARCHAR" -> VARCHAR
      | "BOOLEAN" -> BOOLEAN
      | "BIGINT" -> BIGINT
      | "DOUBLE" -> DOUBLE
      | "TIMESTAMP" -> TIMESTAMP
      | "DATE" -> DATE
      | "TIME" -> TIME
      | "INTERVAL_DAY_TO_SECOND" -> INTERVAL_DAY_TO_SECOND
      | "INTERVAL_YEAR_TO_MONTH" -> INTERVAL_YEAR_TO_MONTH
      | "UNKNOWN" -> UNKNOWN
      | "INTEGER" -> INTEGER
      | x -> Non_static_id x
    let to_value x = `Enum (to_string x)
    let to_query v = to_query to_value v
    let to_header x = to_string x
    let of_xml xml_arg0 =
      of_string (string_of_xml ~kind:"enumeration ScalarType" xml_arg0)
    let of_json j = of_string (string_of_json ~kind:"ScalarType" j)
    let to_json = simple_to_json to_value
  end
module rec
  ColumnInfo:sig
               type nonrec t =
                 {
                 name: String_.t option
                   [@ocaml.doc
                     "The name of the result set column. The name of the result set is available for columns of all data types except for arrays."];
                 type_: Type.t option
                   [@ocaml.doc
                     "The data type of the result set column. The data type can be a scalar or complex. Scalar data types are integers, strings, doubles, Booleans, and others. Complex data types are types such as arrays, rows, and others."]}
               val make : ?name:String_.t -> ?type_:Type.t -> unit -> t
               val to_value : t -> Botodata.value
               val to_query : t -> Client.Query.t
               val of_xml : Xml.t -> t
               val of_json : Yojson.Safe.t -> t
               val to_json : t -> Yojson.Safe.t
             end =
  struct
    type nonrec t =
      {
      name: String_.t option
        [@ocaml.doc
          "The name of the result set column. The name of the result set is available for columns of all data types except for arrays."];
      type_: Type.t option
        [@ocaml.doc
          "The data type of the result set column. The data type can be a scalar or complex. Scalar data types are integers, strings, doubles, Booleans, and others. Complex data types are types such as arrays, rows, and others."]}
    let make ?name = fun ?type_ -> fun () -> { name; type_ }
    let to_value x =
      structure_to_value
        [("Name", (Option.map x.name ~f:String_.to_value));
        ("Type", (Option.map x.type_ ~f:Type.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let type_ = (Option.map ~f:Type.of_xml) (Xml.child xml_arg0 "Type") in
      let name = (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "Name") in
      make ?type_ ?name ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let type_ = field_map json__ "Type" Type.of_json in
      let name = field_map json__ "Name" String_.of_json in
      make ?type_ ?name ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Contains the metadata for query results such as the column names, data types, and other attributes."]
 and
  ColumnInfoList:sig
                   type nonrec t = ColumnInfo.t list
                   val make : ColumnInfo.t list -> t
                   val to_value : t -> Botodata.value
                   val to_query : t -> Client.Query.t
                   val of_xml : Xml.t -> ColumnInfo.t list
                   val of_json : Yojson.Safe.t -> t
                   val to_json : t -> Yojson.Safe.t
                   val to_header : t -> string
                 end =
  struct
    type nonrec t = ColumnInfo.t list
    let make i = i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:ColumnInfo.to_value)) |> (fun x -> `List x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for List_shape objects" ()
    let of_xml x =
      make
        (List.map
           ((Xml.all_children x) |>
              (List.filter
                 ~f:(function
                     | `Data s ->
                         (match Stdlib.String.trim s with
                          | "" -> false
                          | _ -> true)
                     | _ -> true))) ~f:ColumnInfo.of_xml)
    let of_json j =
      list_of_json ~kind:"ColumnInfoList" ~of_json:ColumnInfo.of_json j
    let to_json v = composed_to_json to_value v
  end and
       Type:sig
              type nonrec t =
                {
                scalarType: ScalarType.t option
                  [@ocaml.doc
                    "Indicates if the column is of type string, integer, Boolean, double, timestamp, date, time. For more information, see Supported data types."];
                arrayColumnInfo: ColumnInfo.t option
                  [@ocaml.doc "Indicates if the column is an array."];
                timeSeriesMeasureValueColumnInfo: ColumnInfo.t option
                  [@ocaml.doc
                    "Indicates if the column is a timeseries data type."];
                rowColumnInfo: ColumnInfoList.t option
                  [@ocaml.doc "Indicates if the column is a row."]}
              val make :
                ?scalarType:ScalarType.t ->
                  ?arrayColumnInfo:ColumnInfo.t ->
                    ?timeSeriesMeasureValueColumnInfo:ColumnInfo.t ->
                      ?rowColumnInfo:ColumnInfoList.t -> unit -> t
              val to_value : t -> Botodata.value
              val to_query : t -> Client.Query.t
              val of_xml : Xml.t -> t
              val of_json : Yojson.Safe.t -> t
              val to_json : t -> Yojson.Safe.t
            end =
       struct
         type nonrec t =
           {
           scalarType: ScalarType.t option
             [@ocaml.doc
               "Indicates if the column is of type string, integer, Boolean, double, timestamp, date, time. For more information, see Supported data types."];
           arrayColumnInfo: ColumnInfo.t option
             [@ocaml.doc "Indicates if the column is an array."];
           timeSeriesMeasureValueColumnInfo: ColumnInfo.t option
             [@ocaml.doc
               "Indicates if the column is a timeseries data type."];
           rowColumnInfo: ColumnInfoList.t option
             [@ocaml.doc "Indicates if the column is a row."]}
         let make ?scalarType =
           fun ?arrayColumnInfo ->
             fun ?timeSeriesMeasureValueColumnInfo ->
               fun ?rowColumnInfo ->
                 fun () ->
                   {
                     scalarType;
                     arrayColumnInfo;
                     timeSeriesMeasureValueColumnInfo;
                     rowColumnInfo
                   }
         let to_value x =
           structure_to_value
             [("ScalarType",
                (Option.map x.scalarType ~f:ScalarType.to_value));
             ("ArrayColumnInfo",
               (Option.map x.arrayColumnInfo ~f:ColumnInfo.to_value));
             ("TimeSeriesMeasureValueColumnInfo",
               (Option.map x.timeSeriesMeasureValueColumnInfo
                  ~f:ColumnInfo.to_value));
             ("RowColumnInfo",
               (Option.map x.rowColumnInfo ~f:ColumnInfoList.to_value))]
         let to_query v = to_query to_value v
         let of_xml xml_arg0 =
           let rowColumnInfo =
             (Option.map ~f:ColumnInfoList.of_xml)
               (Xml.child xml_arg0 "RowColumnInfo") in
           let timeSeriesMeasureValueColumnInfo =
             (Option.map ~f:ColumnInfo.of_xml)
               (Xml.child xml_arg0 "TimeSeriesMeasureValueColumnInfo") in
           let arrayColumnInfo =
             (Option.map ~f:ColumnInfo.of_xml)
               (Xml.child xml_arg0 "ArrayColumnInfo") in
           let scalarType =
             (Option.map ~f:ScalarType.of_xml)
               (Xml.child xml_arg0 "ScalarType") in
           make ?rowColumnInfo ?timeSeriesMeasureValueColumnInfo
             ?arrayColumnInfo ?scalarType ()
         let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning
                                                               "-32"]
         let of_json json__ =
           let rowColumnInfo =
             field_map json__ "RowColumnInfo" ColumnInfoList.of_json in
           let timeSeriesMeasureValueColumnInfo =
             field_map json__ "TimeSeriesMeasureValueColumnInfo"
               ColumnInfo.of_json in
           let arrayColumnInfo =
             field_map json__ "ArrayColumnInfo" ColumnInfo.of_json in
           let scalarType = field_map json__ "ScalarType" ScalarType.of_json in
           make ?rowColumnInfo ?timeSeriesMeasureValueColumnInfo
             ?arrayColumnInfo ?scalarType ()
         let to_json v = composed_to_json to_value v
       end[@@ocaml.doc
            "Contains the data type of a column in a query result set. The data type can be scalar or complex. The supported scalar data types are integers, Boolean, string, double, timestamp, date, time, and intervals. The supported complex data types are arrays, rows, and timeseries."]
module ComputeMode =
  struct
    type nonrec t =
      | ON_DEMAND 
      | PROVISIONED 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | ON_DEMAND -> "ON_DEMAND"
      | PROVISIONED -> "PROVISIONED"
      | Non_static_id s -> s
    let of_string =
      function
      | "ON_DEMAND" -> ON_DEMAND
      | "PROVISIONED" -> PROVISIONED
      | x -> Non_static_id x
    let to_value x = `Enum (to_string x)
    let to_query v = to_query to_value v
    let to_header x = to_string x
    let of_xml xml_arg0 =
      of_string (string_of_xml ~kind:"enumeration ComputeMode" xml_arg0)
    let of_json j = of_string (string_of_json ~kind:"ComputeMode" j)
    let to_json = simple_to_json to_value
  end
module ConflictException =
  struct
    type nonrec t = {
      message: ErrorMessage.t option }
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("Message", (Option.map x.message ~f:ErrorMessage.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:ErrorMessage.of_xml) (Xml.child xml_arg0 "Message") in
      make ?message ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let message = field_map json__ "Message" ErrorMessage.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Unable to poll results for a cancelled query."]
module SchemaName =
  struct
    type nonrec t = string
    let context_ = "SchemaName"
    let make i = i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"SchemaName" j
    let to_json = simple_to_json to_value
  end
module ResourceName =
  struct
    type nonrec t = string
    let context_ = "ResourceName"
    let make i = i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"ResourceName" j
    let to_json = simple_to_json to_value
  end
module ScalarMeasureValueType =
  struct
    type nonrec t =
      | BIGINT 
      | BOOLEAN 
      | DOUBLE 
      | VARCHAR 
      | TIMESTAMP 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | BIGINT -> "BIGINT"
      | BOOLEAN -> "BOOLEAN"
      | DOUBLE -> "DOUBLE"
      | VARCHAR -> "VARCHAR"
      | TIMESTAMP -> "TIMESTAMP"
      | Non_static_id s -> s
    let of_string =
      function
      | "BIGINT" -> BIGINT
      | "BOOLEAN" -> BOOLEAN
      | "DOUBLE" -> DOUBLE
      | "VARCHAR" -> VARCHAR
      | "TIMESTAMP" -> TIMESTAMP
      | x -> Non_static_id x
    let to_value x = `Enum (to_string x)
    let to_query v = to_query to_value v
    let to_header x = to_string x
    let of_xml xml_arg0 =
      of_string
        (string_of_xml ~kind:"enumeration ScalarMeasureValueType" xml_arg0)
    let of_json j =
      of_string (string_of_json ~kind:"ScalarMeasureValueType" j)
    let to_json = simple_to_json to_value
  end
module MultiMeasureAttributeMapping =
  struct
    type nonrec t =
      {
      sourceColumn: SchemaName.t
        [@ocaml.doc
          "Source column from where the attribute value is to be read."];
      targetMultiMeasureAttributeName: SchemaName.t option
        [@ocaml.doc
          "Custom name to be used for attribute name in derived table. If not provided, source column name would be used."];
      measureValueType: ScalarMeasureValueType.t
        [@ocaml.doc
          "Type of the attribute to be read from the source column."]}
    let context_ = "MultiMeasureAttributeMapping"
    let make ?targetMultiMeasureAttributeName =
      fun ~sourceColumn ->
        fun ~measureValueType ->
          fun () ->
            { targetMultiMeasureAttributeName; sourceColumn; measureValueType
            }
    let to_value x =
      structure_to_value
        [("SourceColumn", (Some (SchemaName.to_value x.sourceColumn)));
        ("TargetMultiMeasureAttributeName",
          (Option.map x.targetMultiMeasureAttributeName
             ~f:SchemaName.to_value));
        ("MeasureValueType",
          (Some (ScalarMeasureValueType.to_value x.measureValueType)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let measureValueType =
        ScalarMeasureValueType.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "MeasureValueType") in
      let targetMultiMeasureAttributeName =
        (Option.map ~f:SchemaName.of_xml)
          (Xml.child xml_arg0 "TargetMultiMeasureAttributeName") in
      let sourceColumn =
        SchemaName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "SourceColumn") in
      make ~measureValueType ?targetMultiMeasureAttributeName ~sourceColumn
        ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let measureValueType =
        field_map_exn json__ "MeasureValueType"
          ScalarMeasureValueType.of_json in
      let targetMultiMeasureAttributeName =
        field_map json__ "TargetMultiMeasureAttributeName" SchemaName.of_json in
      let sourceColumn =
        field_map_exn json__ "SourceColumn" SchemaName.of_json in
      make ~measureValueType ?targetMultiMeasureAttributeName ~sourceColumn
        ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Attribute mapping for MULTI value measures."]
module MultiMeasureAttributeMappingList =
  struct
    type nonrec t = MultiMeasureAttributeMapping.t list
    let make i =
      let open Result in ok_or_failwith (check_list_min i ~min:1); i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:MultiMeasureAttributeMapping.to_value)) |>
        (fun x -> `List x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for List_shape objects" ()
    let of_xml x =
      make
        (List.map
           ((Xml.all_children x) |>
              (List.filter
                 ~f:(function
                     | `Data s ->
                         (match Stdlib.String.trim s with
                          | "" -> false
                          | _ -> true)
                     | _ -> true))) ~f:MultiMeasureAttributeMapping.of_xml)
    let of_json j =
      list_of_json ~kind:"MultiMeasureAttributeMappingList"
        ~of_json:MultiMeasureAttributeMapping.of_json j
    let to_json v = composed_to_json to_value v
  end
module MultiMeasureMappings =
  struct
    type nonrec t =
      {
      targetMultiMeasureName: SchemaName.t option
        [@ocaml.doc
          "The name of the target multi-measure name in the derived table. This input is required when measureNameColumn is not provided. If MeasureNameColumn is provided, then value from that column will be used as multi-measure name."];
      multiMeasureAttributeMappings: MultiMeasureAttributeMappingList.t
        [@ocaml.doc
          "Required. Attribute mappings to be used for mapping query results to ingest data for multi-measure attributes."]}
    let context_ = "MultiMeasureMappings"
    let make ?targetMultiMeasureName =
      fun ~multiMeasureAttributeMappings ->
        fun () -> { targetMultiMeasureName; multiMeasureAttributeMappings }
    let to_value x =
      structure_to_value
        [("TargetMultiMeasureName",
           (Option.map x.targetMultiMeasureName ~f:SchemaName.to_value));
        ("MultiMeasureAttributeMappings",
          (Some
             (MultiMeasureAttributeMappingList.to_value
                x.multiMeasureAttributeMappings)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let multiMeasureAttributeMappings =
        MultiMeasureAttributeMappingList.of_xml
          (Xml.child_exn ~context:context_ xml_arg0
             "MultiMeasureAttributeMappings") in
      let targetMultiMeasureName =
        (Option.map ~f:SchemaName.of_xml)
          (Xml.child xml_arg0 "TargetMultiMeasureName") in
      make ~multiMeasureAttributeMappings ?targetMultiMeasureName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let multiMeasureAttributeMappings =
        field_map_exn json__ "MultiMeasureAttributeMappings"
          MultiMeasureAttributeMappingList.of_json in
      let targetMultiMeasureName =
        field_map json__ "TargetMultiMeasureName" SchemaName.of_json in
      make ~multiMeasureAttributeMappings ?targetMultiMeasureName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Only one of MixedMeasureMappings or MultiMeasureMappings is to be provided. MultiMeasureMappings can be used to ingest data as multi measures in the derived table."]
module MeasureValueType =
  struct
    type nonrec t =
      | BIGINT 
      | BOOLEAN 
      | DOUBLE 
      | VARCHAR 
      | MULTI 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | BIGINT -> "BIGINT"
      | BOOLEAN -> "BOOLEAN"
      | DOUBLE -> "DOUBLE"
      | VARCHAR -> "VARCHAR"
      | MULTI -> "MULTI"
      | Non_static_id s -> s
    let of_string =
      function
      | "BIGINT" -> BIGINT
      | "BOOLEAN" -> BOOLEAN
      | "DOUBLE" -> DOUBLE
      | "VARCHAR" -> VARCHAR
      | "MULTI" -> MULTI
      | x -> Non_static_id x
    let to_value x = `Enum (to_string x)
    let to_query v = to_query to_value v
    let to_header x = to_string x
    let of_xml xml_arg0 =
      of_string (string_of_xml ~kind:"enumeration MeasureValueType" xml_arg0)
    let of_json j = of_string (string_of_json ~kind:"MeasureValueType" j)
    let to_json = simple_to_json to_value
  end
module MixedMeasureMapping =
  struct
    type nonrec t =
      {
      measureName: SchemaName.t option
        [@ocaml.doc
          "Refers to the value of measure_name in a result row. This field is required if MeasureNameColumn is provided."];
      sourceColumn: SchemaName.t option
        [@ocaml.doc
          "This field refers to the source column from which measure-value is to be read for result materialization."];
      targetMeasureName: SchemaName.t option
        [@ocaml.doc
          "Target measure name to be used. If not provided, the target measure name by default would be measure-name if provided, or sourceColumn otherwise."];
      measureValueType: MeasureValueType.t
        [@ocaml.doc
          "Type of the value that is to be read from sourceColumn. If the mapping is for MULTI, use MeasureValueType.MULTI."];
      multiMeasureAttributeMappings:
        MultiMeasureAttributeMappingList.t option
        [@ocaml.doc
          "Required when measureValueType is MULTI. Attribute mappings for MULTI value measures."]}
    let context_ = "MixedMeasureMapping"
    let make ?measureName =
      fun ?sourceColumn ->
        fun ?targetMeasureName ->
          fun ?multiMeasureAttributeMappings ->
            fun ~measureValueType ->
              fun () ->
                {
                  measureName;
                  sourceColumn;
                  targetMeasureName;
                  multiMeasureAttributeMappings;
                  measureValueType
                }
    let to_value x =
      structure_to_value
        [("MeasureName", (Option.map x.measureName ~f:SchemaName.to_value));
        ("SourceColumn", (Option.map x.sourceColumn ~f:SchemaName.to_value));
        ("TargetMeasureName",
          (Option.map x.targetMeasureName ~f:SchemaName.to_value));
        ("MeasureValueType",
          (Some (MeasureValueType.to_value x.measureValueType)));
        ("MultiMeasureAttributeMappings",
          (Option.map x.multiMeasureAttributeMappings
             ~f:MultiMeasureAttributeMappingList.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let multiMeasureAttributeMappings =
        (Option.map ~f:MultiMeasureAttributeMappingList.of_xml)
          (Xml.child xml_arg0 "MultiMeasureAttributeMappings") in
      let measureValueType =
        MeasureValueType.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "MeasureValueType") in
      let targetMeasureName =
        (Option.map ~f:SchemaName.of_xml)
          (Xml.child xml_arg0 "TargetMeasureName") in
      let sourceColumn =
        (Option.map ~f:SchemaName.of_xml) (Xml.child xml_arg0 "SourceColumn") in
      let measureName =
        (Option.map ~f:SchemaName.of_xml) (Xml.child xml_arg0 "MeasureName") in
      make ?multiMeasureAttributeMappings ~measureValueType
        ?targetMeasureName ?sourceColumn ?measureName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let multiMeasureAttributeMappings =
        field_map json__ "MultiMeasureAttributeMappings"
          MultiMeasureAttributeMappingList.of_json in
      let measureValueType =
        field_map_exn json__ "MeasureValueType" MeasureValueType.of_json in
      let targetMeasureName =
        field_map json__ "TargetMeasureName" SchemaName.of_json in
      let sourceColumn = field_map json__ "SourceColumn" SchemaName.of_json in
      let measureName = field_map json__ "MeasureName" SchemaName.of_json in
      make ?multiMeasureAttributeMappings ~measureValueType
        ?targetMeasureName ?sourceColumn ?measureName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "MixedMeasureMappings are mappings that can be used to ingest data into a mixture of narrow and multi measures in the derived table."]
module MixedMeasureMappingList =
  struct
    type nonrec t = MixedMeasureMapping.t list
    let make i =
      let open Result in ok_or_failwith (check_list_min i ~min:1); i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:MixedMeasureMapping.to_value)) |>
        (fun x -> `List x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for List_shape objects" ()
    let of_xml x =
      make
        (List.map
           ((Xml.all_children x) |>
              (List.filter
                 ~f:(function
                     | `Data s ->
                         (match Stdlib.String.trim s with
                          | "" -> false
                          | _ -> true)
                     | _ -> true))) ~f:MixedMeasureMapping.of_xml)
    let of_json j =
      list_of_json ~kind:"MixedMeasureMappingList"
        ~of_json:MixedMeasureMapping.of_json j
    let to_json v = composed_to_json to_value v
  end
module DimensionValueType =
  struct
    type nonrec t =
      | VARCHAR 
      | Non_static_id of string 
    let make i = i
    let to_string = function | VARCHAR -> "VARCHAR" | Non_static_id s -> s
    let of_string = function | "VARCHAR" -> VARCHAR | x -> Non_static_id x
    let to_value x = `Enum (to_string x)
    let to_query v = to_query to_value v
    let to_header x = to_string x
    let of_xml xml_arg0 =
      of_string
        (string_of_xml ~kind:"enumeration DimensionValueType" xml_arg0)
    let of_json j = of_string (string_of_json ~kind:"DimensionValueType" j)
    let to_json = simple_to_json to_value
  end
module DimensionMapping =
  struct
    type nonrec t =
      {
      name: SchemaName.t [@ocaml.doc "Column name from query result."];
      dimensionValueType: DimensionValueType.t
        [@ocaml.doc "Type for the dimension."]}
    let context_ = "DimensionMapping"
    let make ~name =
      fun ~dimensionValueType -> fun () -> { name; dimensionValueType }
    let to_value x =
      structure_to_value
        [("Name", (Some (SchemaName.to_value x.name)));
        ("DimensionValueType",
          (Some (DimensionValueType.to_value x.dimensionValueType)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let dimensionValueType =
        DimensionValueType.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "DimensionValueType") in
      let name =
        SchemaName.of_xml (Xml.child_exn ~context:context_ xml_arg0 "Name") in
      make ~dimensionValueType ~name ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let dimensionValueType =
        field_map_exn json__ "DimensionValueType" DimensionValueType.of_json in
      let name = field_map_exn json__ "Name" SchemaName.of_json in
      make ~dimensionValueType ~name ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "This type is used to map column(s) from the query result to a dimension in the destination table."]
module DimensionMappingList =
  struct
    type nonrec t = DimensionMapping.t list
    let make i = i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:DimensionMapping.to_value)) |> (fun x -> `List x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for List_shape objects" ()
    let of_xml x =
      make
        (List.map
           ((Xml.all_children x) |>
              (List.filter
                 ~f:(function
                     | `Data s ->
                         (match Stdlib.String.trim s with
                          | "" -> false
                          | _ -> true)
                     | _ -> true))) ~f:DimensionMapping.of_xml)
    let of_json j =
      list_of_json ~kind:"DimensionMappingList"
        ~of_json:DimensionMapping.of_json j
    let to_json v = composed_to_json to_value v
  end
module TimestreamConfiguration =
  struct
    type nonrec t =
      {
      databaseName: ResourceName.t
        [@ocaml.doc
          "Name of Timestream database to which the query result will be written."];
      tableName: ResourceName.t
        [@ocaml.doc
          "Name of Timestream table that the query result will be written to. The table should be within the same database that is provided in Timestream configuration."];
      timeColumn: SchemaName.t
        [@ocaml.doc
          "Column from query result that should be used as the time column in destination table. Column type for this should be TIMESTAMP."];
      dimensionMappings: DimensionMappingList.t
        [@ocaml.doc
          "This is to allow mapping column(s) from the query result to the dimension in the destination table."];
      multiMeasureMappings: MultiMeasureMappings.t option
        [@ocaml.doc "Multi-measure mappings."];
      mixedMeasureMappings: MixedMeasureMappingList.t option
        [@ocaml.doc
          "Specifies how to map measures to multi-measure records."];
      measureNameColumn: SchemaName.t option
        [@ocaml.doc "Name of the measure column."]}
    let context_ = "TimestreamConfiguration"
    let make ?multiMeasureMappings =
      fun ?mixedMeasureMappings ->
        fun ?measureNameColumn ->
          fun ~databaseName ->
            fun ~tableName ->
              fun ~timeColumn ->
                fun ~dimensionMappings ->
                  fun () ->
                    {
                      multiMeasureMappings;
                      mixedMeasureMappings;
                      measureNameColumn;
                      databaseName;
                      tableName;
                      timeColumn;
                      dimensionMappings
                    }
    let to_value x =
      structure_to_value
        [("DatabaseName", (Some (ResourceName.to_value x.databaseName)));
        ("TableName", (Some (ResourceName.to_value x.tableName)));
        ("TimeColumn", (Some (SchemaName.to_value x.timeColumn)));
        ("DimensionMappings",
          (Some (DimensionMappingList.to_value x.dimensionMappings)));
        ("MultiMeasureMappings",
          (Option.map x.multiMeasureMappings ~f:MultiMeasureMappings.to_value));
        ("MixedMeasureMappings",
          (Option.map x.mixedMeasureMappings
             ~f:MixedMeasureMappingList.to_value));
        ("MeasureNameColumn",
          (Option.map x.measureNameColumn ~f:SchemaName.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let measureNameColumn =
        (Option.map ~f:SchemaName.of_xml)
          (Xml.child xml_arg0 "MeasureNameColumn") in
      let mixedMeasureMappings =
        (Option.map ~f:MixedMeasureMappingList.of_xml)
          (Xml.child xml_arg0 "MixedMeasureMappings") in
      let multiMeasureMappings =
        (Option.map ~f:MultiMeasureMappings.of_xml)
          (Xml.child xml_arg0 "MultiMeasureMappings") in
      let dimensionMappings =
        DimensionMappingList.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "DimensionMappings") in
      let timeColumn =
        SchemaName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "TimeColumn") in
      let tableName =
        ResourceName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "TableName") in
      let databaseName =
        ResourceName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "DatabaseName") in
      make ?measureNameColumn ?mixedMeasureMappings ?multiMeasureMappings
        ~dimensionMappings ~timeColumn ~tableName ~databaseName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let measureNameColumn =
        field_map json__ "MeasureNameColumn" SchemaName.of_json in
      let mixedMeasureMappings =
        field_map json__ "MixedMeasureMappings"
          MixedMeasureMappingList.of_json in
      let multiMeasureMappings =
        field_map json__ "MultiMeasureMappings" MultiMeasureMappings.of_json in
      let dimensionMappings =
        field_map_exn json__ "DimensionMappings" DimensionMappingList.of_json in
      let timeColumn = field_map_exn json__ "TimeColumn" SchemaName.of_json in
      let tableName = field_map_exn json__ "TableName" ResourceName.of_json in
      let databaseName =
        field_map_exn json__ "DatabaseName" ResourceName.of_json in
      make ?measureNameColumn ?mixedMeasureMappings ?multiMeasureMappings
        ~dimensionMappings ~timeColumn ~tableName ~databaseName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Configuration to write data into Timestream database and table. This configuration allows the user to map the query result select columns into the destination table columns."]
module TargetConfiguration =
  struct
    type nonrec t =
      {
      timestreamConfiguration: TimestreamConfiguration.t
        [@ocaml.doc
          "Configuration needed to write data into the Timestream database and table."]}
    let context_ = "TargetConfiguration"
    let make ~timestreamConfiguration = fun () -> { timestreamConfiguration }
    let to_value x =
      structure_to_value
        [("TimestreamConfiguration",
           (Some (TimestreamConfiguration.to_value x.timestreamConfiguration)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let timestreamConfiguration =
        TimestreamConfiguration.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "TimestreamConfiguration") in
      make ~timestreamConfiguration ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let timestreamConfiguration =
        field_map_exn json__ "TimestreamConfiguration"
          TimestreamConfiguration.of_json in
      make ~timestreamConfiguration ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Configuration used for writing the output of a query."]
module TagValue =
  struct
    type nonrec t = string
    let context_ = "TagValue"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_max i ~max:256) >>=
             (fun () -> check_string_min i ~min:0));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"TagValue" j
    let to_json = simple_to_json to_value
  end
module TagKey =
  struct
    type nonrec t = string
    let context_ = "TagKey"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_max i ~max:128) >>=
             (fun () -> check_string_min i ~min:1));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"TagKey" j
    let to_json = simple_to_json to_value
  end
module Tag =
  struct
    type nonrec t =
      {
      key: TagKey.t
        [@ocaml.doc "The key of the tag. Tag keys are case sensitive."];
      value: TagValue.t
        [@ocaml.doc
          "The value of the tag. Tag values are case sensitive and can be null."]}
    let context_ = "Tag"
    let make ~key = fun ~value -> fun () -> { key; value }
    let to_value x =
      structure_to_value
        [("Key", (Some (TagKey.to_value x.key)));
        ("Value", (Some (TagValue.to_value x.value)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let value =
        TagValue.of_xml (Xml.child_exn ~context:context_ xml_arg0 "Value") in
      let key =
        TagKey.of_xml (Xml.child_exn ~context:context_ xml_arg0 "Key") in
      make ~value ~key ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let value = field_map_exn json__ "Value" TagValue.of_json in
      let key = field_map_exn json__ "Key" TagKey.of_json in
      make ~value ~key ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "A tag is a label that you assign to a Timestream database and/or table. Each tag consists of a key and an optional value, both of which you define. Tags enable you to categorize databases and/or tables, for example, by purpose, owner, or environment."]
module TagList =
  struct
    type nonrec t = Tag.t list
    let make i =
      let open Result in
        ok_or_failwith
          ((check_list_max i ~max:200) >>=
             (fun () -> check_list_min i ~min:0));
        i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:Tag.to_value)) |> (fun x -> `List x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for List_shape objects" ()
    let of_xml x =
      make
        (List.map
           ((Xml.all_children x) |>
              (List.filter
                 ~f:(function
                     | `Data s ->
                         (match Stdlib.String.trim s with
                          | "" -> false
                          | _ -> true)
                     | _ -> true))) ~f:Tag.of_xml)
    let of_json j = list_of_json ~kind:"TagList" ~of_json:Tag.of_json j
    let to_json v = composed_to_json to_value v
  end
module StringValue2048 =
  struct
    type nonrec t = string
    let context_ = "StringValue2048"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_max i ~max:2048) >>=
             (fun () -> check_string_min i ~min:1));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"StringValue2048" j
    let to_json = simple_to_json to_value
  end
module ScheduledQueryName =
  struct
    type nonrec t = string
    let context_ = "ScheduledQueryName"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_min i ~min:1) >>=
             (fun () ->
                (check_string_max i ~max:64) >>=
                  (fun () ->
                     check_pattern i
                       ~pattern:"[a-zA-Z0-9|!\\-_*'\\(\\)]([a-zA-Z0-9]|[!\\-_*'\\(\\)\\/.])+")));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"ScheduledQueryName" j
    let to_json = simple_to_json to_value
  end
module ScheduleExpression =
  struct
    type nonrec t = string
    let context_ = "ScheduleExpression"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_max i ~max:256) >>=
             (fun () -> check_string_min i ~min:1));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"ScheduleExpression" j
    let to_json = simple_to_json to_value
  end
module ScheduleConfiguration =
  struct
    type nonrec t =
      {
      scheduleExpression: ScheduleExpression.t
        [@ocaml.doc
          "An expression that denotes when to trigger the scheduled query run. This can be a cron expression or a rate expression."]}
    let context_ = "ScheduleConfiguration"
    let make ~scheduleExpression = fun () -> { scheduleExpression }
    let to_value x =
      structure_to_value
        [("ScheduleExpression",
           (Some (ScheduleExpression.to_value x.scheduleExpression)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let scheduleExpression =
        ScheduleExpression.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "ScheduleExpression") in
      make ~scheduleExpression ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let scheduleExpression =
        field_map_exn json__ "ScheduleExpression" ScheduleExpression.of_json in
      make ~scheduleExpression ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Configuration of the schedule of the query."]
module QueryString =
  struct
    type nonrec t = string
    let context_ = "QueryString"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_max i ~max:262144) >>=
             (fun () -> check_string_min i ~min:1));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"QueryString" j
    let to_json = simple_to_json to_value
  end
module NotificationConfiguration =
  struct
    type nonrec t =
      {
      snsConfiguration: SnsConfiguration.t
        [@ocaml.doc
          "Details about the Amazon Simple Notification Service (SNS) configuration. This field is visible only when SNS Topic is provided when updating the account settings."]}
    let context_ = "NotificationConfiguration"
    let make ~snsConfiguration = fun () -> { snsConfiguration }
    let to_value x =
      structure_to_value
        [("SnsConfiguration",
           (Some (SnsConfiguration.to_value x.snsConfiguration)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let snsConfiguration =
        SnsConfiguration.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "SnsConfiguration") in
      make ~snsConfiguration ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let snsConfiguration =
        field_map_exn json__ "SnsConfiguration" SnsConfiguration.of_json in
      make ~snsConfiguration ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Notification configuration for a scheduled query. A notification is sent by Timestream when a scheduled query is created, its state is updated or when it is deleted."]
module S3ObjectKeyPrefix =
  struct
    type nonrec t = string
    let context_ = "S3ObjectKeyPrefix"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_min i ~min:1) >>=
             (fun () ->
                (check_string_max i ~max:896) >>=
                  (fun () ->
                     check_pattern i
                       ~pattern:"[a-zA-Z0-9|!\\-_*'\\(\\)]([a-zA-Z0-9]|[!\\-_*'\\(\\)\\/.])+")));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"S3ObjectKeyPrefix" j
    let to_json = simple_to_json to_value
  end
module S3EncryptionOption =
  struct
    type nonrec t =
      | SSE_S3 
      | SSE_KMS 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | SSE_S3 -> "SSE_S3"
      | SSE_KMS -> "SSE_KMS"
      | Non_static_id s -> s
    let of_string =
      function
      | "SSE_S3" -> SSE_S3
      | "SSE_KMS" -> SSE_KMS
      | x -> Non_static_id x
    let to_value x = `Enum (to_string x)
    let to_query v = to_query to_value v
    let to_header x = to_string x
    let of_xml xml_arg0 =
      of_string
        (string_of_xml ~kind:"enumeration S3EncryptionOption" xml_arg0)
    let of_json j = of_string (string_of_json ~kind:"S3EncryptionOption" j)
    let to_json = simple_to_json to_value
  end
module S3BucketName =
  struct
    type nonrec t = string
    let context_ = "S3BucketName"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_min i ~min:3) >>=
             (fun () ->
                (check_string_max i ~max:63) >>=
                  (fun () ->
                     check_pattern i
                       ~pattern:"[a-z0-9][\\.\\-a-z0-9]{1,61}[a-z0-9]")));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"S3BucketName" j
    let to_json = simple_to_json to_value
  end
module S3Configuration =
  struct
    type nonrec t =
      {
      bucketName: S3BucketName.t
        [@ocaml.doc
          "Name of the S3 bucket under which error reports will be created."];
      objectKeyPrefix: S3ObjectKeyPrefix.t option
        [@ocaml.doc
          "Prefix for the error report key. Timestream by default adds the following prefix to the error report path."];
      encryptionOption: S3EncryptionOption.t option
        [@ocaml.doc
          "Encryption at rest options for the error reports. If no encryption option is specified, Timestream will choose SSE_S3 as default."]}
    let context_ = "S3Configuration"
    let make ?objectKeyPrefix =
      fun ?encryptionOption ->
        fun ~bucketName ->
          fun () -> { objectKeyPrefix; encryptionOption; bucketName }
    let to_value x =
      structure_to_value
        [("BucketName", (Some (S3BucketName.to_value x.bucketName)));
        ("ObjectKeyPrefix",
          (Option.map x.objectKeyPrefix ~f:S3ObjectKeyPrefix.to_value));
        ("EncryptionOption",
          (Option.map x.encryptionOption ~f:S3EncryptionOption.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let encryptionOption =
        (Option.map ~f:S3EncryptionOption.of_xml)
          (Xml.child xml_arg0 "EncryptionOption") in
      let objectKeyPrefix =
        (Option.map ~f:S3ObjectKeyPrefix.of_xml)
          (Xml.child xml_arg0 "ObjectKeyPrefix") in
      let bucketName =
        S3BucketName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "BucketName") in
      make ?encryptionOption ?objectKeyPrefix ~bucketName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let encryptionOption =
        field_map json__ "EncryptionOption" S3EncryptionOption.of_json in
      let objectKeyPrefix =
        field_map json__ "ObjectKeyPrefix" S3ObjectKeyPrefix.of_json in
      let bucketName = field_map_exn json__ "BucketName" S3BucketName.of_json in
      make ?encryptionOption ?objectKeyPrefix ~bucketName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Details on S3 location for error reports that result from running a query."]
module ErrorReportConfiguration =
  struct
    type nonrec t =
      {
      s3Configuration: S3Configuration.t
        [@ocaml.doc "The S3 configuration for the error reports."]}
    let context_ = "ErrorReportConfiguration"
    let make ~s3Configuration = fun () -> { s3Configuration }
    let to_value x =
      structure_to_value
        [("S3Configuration",
           (Some (S3Configuration.to_value x.s3Configuration)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let s3Configuration =
        S3Configuration.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "S3Configuration") in
      make ~s3Configuration ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let s3Configuration =
        field_map_exn json__ "S3Configuration" S3Configuration.of_json in
      make ~s3Configuration ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Configuration required for error reporting."]
module CreateScheduledQueryRequest =
  struct
    type nonrec t =
      {
      name: ScheduledQueryName.t [@ocaml.doc "Name of the scheduled query."];
      queryString: QueryString.t
        [@ocaml.doc
          "The query string to run. Parameter names can be specified in the query string \\@ character followed by an identifier. The named Parameter \\@scheduled_runtime is reserved and can be used in the query to get the time at which the query is scheduled to run. The timestamp calculated according to the ScheduleConfiguration parameter, will be the value of \\@scheduled_runtime paramater for each query run. For example, consider an instance of a scheduled query executing on 2021-12-01 00:00:00. For this instance, the \\@scheduled_runtime parameter is initialized to the timestamp 2021-12-01 00:00:00 when invoking the query."];
      scheduleConfiguration: ScheduleConfiguration.t
        [@ocaml.doc "The schedule configuration for the query."];
      notificationConfiguration: NotificationConfiguration.t
        [@ocaml.doc
          "Notification configuration for the scheduled query. A notification is sent by Timestream when a query run finishes, when the state is updated or when you delete it."];
      targetConfiguration: TargetConfiguration.t option
        [@ocaml.doc "Configuration used for writing the result of a query."];
      clientToken: ClientToken.t option
        [@ocaml.doc
          "Using a ClientToken makes the call to CreateScheduledQuery idempotent, in other words, making the same request repeatedly will produce the same result. Making multiple identical CreateScheduledQuery requests has the same effect as making a single request. If CreateScheduledQuery is called without a ClientToken, the Query SDK generates a ClientToken on your behalf. After 8 hours, any request with the same ClientToken is treated as a new request."];
      scheduledQueryExecutionRoleArn: AmazonResourceName.t
        [@ocaml.doc
          "The ARN for the IAM role that Timestream will assume when running the scheduled query."];
      tags: TagList.t option
        [@ocaml.doc
          "A list of key-value pairs to label the scheduled query."];
      kmsKeyId: StringValue2048.t option
        [@ocaml.doc
          "The Amazon KMS key used to encrypt the scheduled query resource, at-rest. If the Amazon KMS key is not specified, the scheduled query resource will be encrypted with a Timestream owned Amazon KMS key. To specify a KMS key, use the key ID, key ARN, alias name, or alias ARN. When using an alias name, prefix the name with alias/ If ErrorReportConfiguration uses SSE_KMS as encryption type, the same KmsKeyId is used to encrypt the error report at rest."];
      errorReportConfiguration: ErrorReportConfiguration.t
        [@ocaml.doc
          "Configuration for error reporting. Error reports will be generated when a problem is encountered when writing the query results."]}
    let context_ = "CreateScheduledQueryRequest"
    let make ?targetConfiguration =
      fun ?clientToken ->
        fun ?tags ->
          fun ?kmsKeyId ->
            fun ~name ->
              fun ~queryString ->
                fun ~scheduleConfiguration ->
                  fun ~notificationConfiguration ->
                    fun ~scheduledQueryExecutionRoleArn ->
                      fun ~errorReportConfiguration ->
                        fun () ->
                          {
                            targetConfiguration;
                            clientToken;
                            tags;
                            kmsKeyId;
                            name;
                            queryString;
                            scheduleConfiguration;
                            notificationConfiguration;
                            scheduledQueryExecutionRoleArn;
                            errorReportConfiguration
                          }
    let to_value x =
      structure_to_value
        [("Name", (Some (ScheduledQueryName.to_value x.name)));
        ("QueryString", (Some (QueryString.to_value x.queryString)));
        ("ScheduleConfiguration",
          (Some (ScheduleConfiguration.to_value x.scheduleConfiguration)));
        ("NotificationConfiguration",
          (Some
             (NotificationConfiguration.to_value x.notificationConfiguration)));
        ("TargetConfiguration",
          (Option.map x.targetConfiguration ~f:TargetConfiguration.to_value));
        ("ClientToken", (Option.map x.clientToken ~f:ClientToken.to_value));
        ("ScheduledQueryExecutionRoleArn",
          (Some
             (AmazonResourceName.to_value x.scheduledQueryExecutionRoleArn)));
        ("Tags", (Option.map x.tags ~f:TagList.to_value));
        ("KmsKeyId", (Option.map x.kmsKeyId ~f:StringValue2048.to_value));
        ("ErrorReportConfiguration",
          (Some
             (ErrorReportConfiguration.to_value x.errorReportConfiguration)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let errorReportConfiguration =
        ErrorReportConfiguration.of_xml
          (Xml.child_exn ~context:context_ xml_arg0
             "ErrorReportConfiguration") in
      let kmsKeyId =
        (Option.map ~f:StringValue2048.of_xml)
          (Xml.child xml_arg0 "KmsKeyId") in
      let tags = (Option.map ~f:TagList.of_xml) (Xml.child xml_arg0 "Tags") in
      let scheduledQueryExecutionRoleArn =
        AmazonResourceName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0
             "ScheduledQueryExecutionRoleArn") in
      let clientToken =
        (Option.map ~f:ClientToken.of_xml) (Xml.child xml_arg0 "ClientToken") in
      let targetConfiguration =
        (Option.map ~f:TargetConfiguration.of_xml)
          (Xml.child xml_arg0 "TargetConfiguration") in
      let notificationConfiguration =
        NotificationConfiguration.of_xml
          (Xml.child_exn ~context:context_ xml_arg0
             "NotificationConfiguration") in
      let scheduleConfiguration =
        ScheduleConfiguration.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "ScheduleConfiguration") in
      let queryString =
        QueryString.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "QueryString") in
      let name =
        ScheduledQueryName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "Name") in
      make ~errorReportConfiguration ?kmsKeyId ?tags
        ~scheduledQueryExecutionRoleArn ?clientToken ?targetConfiguration
        ~notificationConfiguration ~scheduleConfiguration ~queryString ~name
        ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let errorReportConfiguration =
        field_map_exn json__ "ErrorReportConfiguration"
          ErrorReportConfiguration.of_json in
      let kmsKeyId = field_map json__ "KmsKeyId" StringValue2048.of_json in
      let tags = field_map json__ "Tags" TagList.of_json in
      let scheduledQueryExecutionRoleArn =
        field_map_exn json__ "ScheduledQueryExecutionRoleArn"
          AmazonResourceName.of_json in
      let clientToken = field_map json__ "ClientToken" ClientToken.of_json in
      let targetConfiguration =
        field_map json__ "TargetConfiguration" TargetConfiguration.of_json in
      let notificationConfiguration =
        field_map_exn json__ "NotificationConfiguration"
          NotificationConfiguration.of_json in
      let scheduleConfiguration =
        field_map_exn json__ "ScheduleConfiguration"
          ScheduleConfiguration.of_json in
      let queryString =
        field_map_exn json__ "QueryString" QueryString.of_json in
      let name = field_map_exn json__ "Name" ScheduledQueryName.of_json in
      make ~errorReportConfiguration ?kmsKeyId ?tags
        ~scheduledQueryExecutionRoleArn ?clientToken ?targetConfiguration
        ~notificationConfiguration ~scheduleConfiguration ~queryString ~name
        ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Create a scheduled query that will be run on your behalf at the configured schedule. Timestream assumes the execution role provided as part of the ScheduledQueryExecutionRoleArn parameter to run the query. You can use the NotificationConfiguration parameter to configure notification for your scheduled query operations."]
module ServiceQuotaExceededException =
  struct
    type nonrec t = {
      message: ErrorMessage.t option }
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("Message", (Option.map x.message ~f:ErrorMessage.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:ErrorMessage.of_xml) (Xml.child xml_arg0 "Message") in
      make ?message ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let message = field_map json__ "Message" ErrorMessage.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "You have exceeded the service quota."]
module CreateScheduledQueryResponse =
  struct
    type nonrec t =
      {
      arn: AmazonResourceName.t option
        [@ocaml.doc "ARN for the created scheduled query."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `ConflictException of ConflictException.t 
      | `InternalServerException of InternalServerException.t 
      | `InvalidEndpointException of InvalidEndpointException.t 
      | `ServiceQuotaExceededException of ServiceQuotaExceededException.t 
      | `ThrottlingException of ThrottlingException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?arn = fun () -> { arn }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_json json)
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_json json)
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_json json)
      | "ServiceQuotaExceededException" ->
          `ServiceQuotaExceededException
            (ServiceQuotaExceededException.of_json json)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_xml xml)
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_xml xml)
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_xml xml)
      | "ServiceQuotaExceededException" ->
          `ServiceQuotaExceededException
            (ServiceQuotaExceededException.of_xml xml)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `ConflictException e ->
          `Assoc
            [("error", (`String "ConflictException"));
            ("details", (ConflictException.to_json e))]
      | `InternalServerException e ->
          `Assoc
            [("error", (`String "InternalServerException"));
            ("details", (InternalServerException.to_json e))]
      | `InvalidEndpointException e ->
          `Assoc
            [("error", (`String "InvalidEndpointException"));
            ("details", (InvalidEndpointException.to_json e))]
      | `ServiceQuotaExceededException e ->
          `Assoc
            [("error", (`String "ServiceQuotaExceededException"));
            ("details", (ServiceQuotaExceededException.to_json e))]
      | `ThrottlingException e ->
          `Assoc
            [("error", (`String "ThrottlingException"));
            ("details", (ThrottlingException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("Arn", (Option.map x.arn ~f:AmazonResourceName.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let arn =
        (Option.map ~f:AmazonResourceName.of_xml) (Xml.child xml_arg0 "Arn") in
      make ?arn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let arn = field_map json__ "Arn" AmazonResourceName.of_json in
      make ?arn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Create a scheduled query that will be run on your behalf at the configured schedule. Timestream assumes the execution role provided as part of the ScheduledQueryExecutionRoleArn parameter to run the query. You can use the NotificationConfiguration parameter to configure notification for your scheduled query operations."]
module Timestamp =
  struct
    type nonrec t = string
    let context_ = "Timestamp"
    let make i = i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"Timestamp" j
    let to_json = simple_to_json to_value
  end
module ScalarValue =
  struct
    type nonrec t = string
    let context_ = "ScalarValue"
    let make i = i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"ScalarValue" j
    let to_json = simple_to_json to_value
  end
module NullableBoolean =
  struct
    type nonrec t = bool
    let make i = i
    let of_string = Bool.of_string
    let to_value x = `Boolean x
    let to_query v = to_query to_value v
    let to_header x = Bool.to_string x
    let of_xml xml_arg0 =
      Bool.of_string (string_of_xml ~kind:"a boolean" xml_arg0)
    let of_json = bool_of_json
    let to_json = simple_to_json to_value
  end
module rec
  Datum:sig
          type nonrec t =
            {
            scalarValue: ScalarValue.t option
              [@ocaml.doc
                "Indicates if the data point is a scalar value such as integer, string, double, or Boolean."];
            timeSeriesValue: TimeSeriesDataPointList.t option
              [@ocaml.doc
                "Indicates if the data point is a timeseries data type."];
            arrayValue: DatumList.t option
              [@ocaml.doc "Indicates if the data point is an array."];
            rowValue: Row.t option
              [@ocaml.doc "Indicates if the data point is a row."];
            nullValue: NullableBoolean.t option
              [@ocaml.doc "Indicates if the data point is null."]}
          val make :
            ?scalarValue:ScalarValue.t ->
              ?timeSeriesValue:TimeSeriesDataPointList.t ->
                ?arrayValue:DatumList.t ->
                  ?rowValue:Row.t ->
                    ?nullValue:NullableBoolean.t -> unit -> t
          val to_value : t -> Botodata.value
          val to_query : t -> Client.Query.t
          val of_xml : Xml.t -> t
          val of_json : Yojson.Safe.t -> t
          val to_json : t -> Yojson.Safe.t
        end =
  struct
    type nonrec t =
      {
      scalarValue: ScalarValue.t option
        [@ocaml.doc
          "Indicates if the data point is a scalar value such as integer, string, double, or Boolean."];
      timeSeriesValue: TimeSeriesDataPointList.t option
        [@ocaml.doc "Indicates if the data point is a timeseries data type."];
      arrayValue: DatumList.t option
        [@ocaml.doc "Indicates if the data point is an array."];
      rowValue: Row.t option
        [@ocaml.doc "Indicates if the data point is a row."];
      nullValue: NullableBoolean.t option
        [@ocaml.doc "Indicates if the data point is null."]}
    let make ?scalarValue =
      fun ?timeSeriesValue ->
        fun ?arrayValue ->
          fun ?rowValue ->
            fun ?nullValue ->
              fun () ->
                {
                  scalarValue;
                  timeSeriesValue;
                  arrayValue;
                  rowValue;
                  nullValue
                }
    let to_value x =
      structure_to_value
        [("ScalarValue", (Option.map x.scalarValue ~f:ScalarValue.to_value));
        ("TimeSeriesValue",
          (Option.map x.timeSeriesValue ~f:TimeSeriesDataPointList.to_value));
        ("ArrayValue", (Option.map x.arrayValue ~f:DatumList.to_value));
        ("RowValue", (Option.map x.rowValue ~f:Row.to_value));
        ("NullValue", (Option.map x.nullValue ~f:NullableBoolean.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let nullValue =
        (Option.map ~f:NullableBoolean.of_xml)
          (Xml.child xml_arg0 "NullValue") in
      let rowValue =
        (Option.map ~f:Row.of_xml) (Xml.child xml_arg0 "RowValue") in
      let arrayValue =
        (Option.map ~f:DatumList.of_xml) (Xml.child xml_arg0 "ArrayValue") in
      let timeSeriesValue =
        (Option.map ~f:TimeSeriesDataPointList.of_xml)
          (Xml.child xml_arg0 "TimeSeriesValue") in
      let scalarValue =
        (Option.map ~f:ScalarValue.of_xml) (Xml.child xml_arg0 "ScalarValue") in
      make ?nullValue ?rowValue ?arrayValue ?timeSeriesValue ?scalarValue ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let nullValue = field_map json__ "NullValue" NullableBoolean.of_json in
      let rowValue = field_map json__ "RowValue" Row.of_json in
      let arrayValue = field_map json__ "ArrayValue" DatumList.of_json in
      let timeSeriesValue =
        field_map json__ "TimeSeriesValue" TimeSeriesDataPointList.of_json in
      let scalarValue = field_map json__ "ScalarValue" ScalarValue.of_json in
      make ?nullValue ?rowValue ?arrayValue ?timeSeriesValue ?scalarValue ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Datum represents a single data point in a query result."]
 and
  DatumList:sig
              type nonrec t = Datum.t list
              val make : Datum.t list -> t
              val to_value : t -> Botodata.value
              val to_query : t -> Client.Query.t
              val of_xml : Xml.t -> Datum.t list
              val of_json : Yojson.Safe.t -> t
              val to_json : t -> Yojson.Safe.t
              val to_header : t -> string
            end =
  struct
    type nonrec t = Datum.t list
    let make i = i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:Datum.to_value)) |> (fun x -> `List x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for List_shape objects" ()
    let of_xml x =
      make
        (List.map
           ((Xml.all_children x) |>
              (List.filter
                 ~f:(function
                     | `Data s ->
                         (match Stdlib.String.trim s with
                          | "" -> false
                          | _ -> true)
                     | _ -> true))) ~f:Datum.of_xml)
    let of_json j = list_of_json ~kind:"DatumList" ~of_json:Datum.of_json j
    let to_json v = composed_to_json to_value v
  end and
       Row:sig
             type nonrec t =
               {
               data: DatumList.t option
                 [@ocaml.doc
                   "List of data points in a single row of the result set."]}
             val make : ?data:DatumList.t -> unit -> t
             val to_value : t -> Botodata.value
             val to_query : t -> Client.Query.t
             val of_xml : Xml.t -> t
             val of_json : Yojson.Safe.t -> t
             val to_json : t -> Yojson.Safe.t
           end =
       struct
         type nonrec t =
           {
           data: DatumList.t option
             [@ocaml.doc
               "List of data points in a single row of the result set."]}
         let make ?data = fun () -> { data }
         let to_value x =
           structure_to_value
             [("Data", (Option.map x.data ~f:DatumList.to_value))]
         let to_query v = to_query to_value v
         let of_xml xml_arg0 =
           let data =
             (Option.map ~f:DatumList.of_xml) (Xml.child xml_arg0 "Data") in
           make ?data ()
         let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning
                                                               "-32"]
         let of_json json__ =
           let data = field_map json__ "Data" DatumList.of_json in
           make ?data ()
         let to_json v = composed_to_json to_value v
       end[@@ocaml.doc "Represents a single row in the query results."]
 and
  TimeSeriesDataPoint:sig
                        type nonrec t =
                          {
                          time: Timestamp.t option
                            [@ocaml.doc
                              "The timestamp when the measure value was collected."];
                          value: Datum.t option
                            [@ocaml.doc
                              "The measure value for the data point."]}
                        val make :
                          ?time:Timestamp.t -> ?value:Datum.t -> unit -> t
                        val to_value : t -> Botodata.value
                        val to_query : t -> Client.Query.t
                        val of_xml : Xml.t -> t
                        val of_json : Yojson.Safe.t -> t
                        val to_json : t -> Yojson.Safe.t
                      end =
  struct
    type nonrec t =
      {
      time: Timestamp.t option
        [@ocaml.doc "The timestamp when the measure value was collected."];
      value: Datum.t option
        [@ocaml.doc "The measure value for the data point."]}
    let make ?time = fun ?value -> fun () -> { time; value }
    let to_value x =
      structure_to_value
        [("Time", (Option.map x.time ~f:Timestamp.to_value));
        ("Value", (Option.map x.value ~f:Datum.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let value = (Option.map ~f:Datum.of_xml) (Xml.child xml_arg0 "Value") in
      let time = (Option.map ~f:Timestamp.of_xml) (Xml.child xml_arg0 "Time") in
      make ?value ?time ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let value = field_map json__ "Value" Datum.of_json in
      let time = field_map json__ "Time" Timestamp.of_json in
      make ?value ?time ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The timeseries data type represents the values of a measure over time. A time series is an array of rows of timestamps and measure values, with rows sorted in ascending order of time. A TimeSeriesDataPoint is a single data point in the time series. It represents a tuple of (time, measure value) in a time series."]
 and
  TimeSeriesDataPointList:sig
                            type nonrec t = TimeSeriesDataPoint.t list
                            val make : TimeSeriesDataPoint.t list -> t
                            val to_value : t -> Botodata.value
                            val to_query : t -> Client.Query.t
                            val of_xml : Xml.t -> TimeSeriesDataPoint.t list
                            val of_json : Yojson.Safe.t -> t
                            val to_json : t -> Yojson.Safe.t
                            val to_header : t -> string
                          end =
  struct
    type nonrec t = TimeSeriesDataPoint.t list
    let make i = i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:TimeSeriesDataPoint.to_value)) |>
        (fun x -> `List x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for List_shape objects" ()
    let of_xml x =
      make
        (List.map
           ((Xml.all_children x) |>
              (List.filter
                 ~f:(function
                     | `Data s ->
                         (match Stdlib.String.trim s with
                          | "" -> false
                          | _ -> true)
                     | _ -> true))) ~f:TimeSeriesDataPoint.of_xml)
    let of_json j =
      list_of_json ~kind:"TimeSeriesDataPointList"
        ~of_json:TimeSeriesDataPoint.of_json j
    let to_json v = composed_to_json to_value v
  end
module DeleteScheduledQueryRequest =
  struct
    type nonrec t =
      {
      scheduledQueryArn: AmazonResourceName.t
        [@ocaml.doc "The ARN of the scheduled query."]}
    let context_ = "DeleteScheduledQueryRequest"
    let make ~scheduledQueryArn = fun () -> { scheduledQueryArn }
    let to_value x =
      structure_to_value
        [("ScheduledQueryArn",
           (Some (AmazonResourceName.to_value x.scheduledQueryArn)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let scheduledQueryArn =
        AmazonResourceName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "ScheduledQueryArn") in
      make ~scheduledQueryArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let scheduledQueryArn =
        field_map_exn json__ "ScheduledQueryArn" AmazonResourceName.of_json in
      make ~scheduledQueryArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Deletes a given scheduled query. This is an irreversible operation."]
module DescribeAccountSettingsRequest =
  struct
    type nonrec t = unit
    let make () = ()
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Describes the settings for your account that include the query pricing model and the configured maximum TCUs the service can use for your query workload. You're charged only for the duration of compute units used for your workloads."]
module QueryPricingModel =
  struct
    type nonrec t =
      | BYTES_SCANNED 
      | COMPUTE_UNITS 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | BYTES_SCANNED -> "BYTES_SCANNED"
      | COMPUTE_UNITS -> "COMPUTE_UNITS"
      | Non_static_id s -> s
    let of_string =
      function
      | "BYTES_SCANNED" -> BYTES_SCANNED
      | "COMPUTE_UNITS" -> COMPUTE_UNITS
      | x -> Non_static_id x
    let to_value x = `Enum (to_string x)
    let to_query v = to_query to_value v
    let to_header x = to_string x
    let of_xml xml_arg0 =
      of_string
        (string_of_xml ~kind:"enumeration QueryPricingModel" xml_arg0)
    let of_json j = of_string (string_of_json ~kind:"QueryPricingModel" j)
    let to_json = simple_to_json to_value
  end
module QueryTCU =
  struct
    type nonrec t = int
    let make i = i
    let of_string = Int.of_string
    let to_value x = `Integer x
    let to_query v = to_query to_value v
    let to_header x = Int.to_string x
    let of_xml xml_arg0 =
      Int.of_string (string_of_xml ~kind:"an integer for QueryTCU" xml_arg0)
    let of_json j = Int.of_float (float_of_json ~kind:"an integer" j)
    let to_json = simple_to_json to_value
  end
module LastUpdateStatus =
  struct
    type nonrec t =
      | PENDING 
      | FAILED 
      | SUCCEEDED 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | PENDING -> "PENDING"
      | FAILED -> "FAILED"
      | SUCCEEDED -> "SUCCEEDED"
      | Non_static_id s -> s
    let of_string =
      function
      | "PENDING" -> PENDING
      | "FAILED" -> FAILED
      | "SUCCEEDED" -> SUCCEEDED
      | x -> Non_static_id x
    let to_value x = `Enum (to_string x)
    let to_query v = to_query to_value v
    let to_header x = to_string x
    let of_xml xml_arg0 =
      of_string (string_of_xml ~kind:"enumeration LastUpdateStatus" xml_arg0)
    let of_json j = of_string (string_of_json ~kind:"LastUpdateStatus" j)
    let to_json = simple_to_json to_value
  end
module LastUpdate =
  struct
    type nonrec t =
      {
      targetQueryTCU: QueryTCU.t option
        [@ocaml.doc
          "The number of TimeStream Compute Units (TCUs) requested in the last account settings update."];
      status: LastUpdateStatus.t option
        [@ocaml.doc
          "The status of the last update. Can be either PENDING, FAILED, or SUCCEEDED."];
      statusMessage: String_.t option
        [@ocaml.doc
          "Error message describing the last account settings update status, visible only if an error occurred."]}
    let make ?targetQueryTCU =
      fun ?status ->
        fun ?statusMessage ->
          fun () -> { targetQueryTCU; status; statusMessage }
    let to_value x =
      structure_to_value
        [("TargetQueryTCU",
           (Option.map x.targetQueryTCU ~f:QueryTCU.to_value));
        ("Status", (Option.map x.status ~f:LastUpdateStatus.to_value));
        ("StatusMessage", (Option.map x.statusMessage ~f:String_.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let statusMessage =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "StatusMessage") in
      let status =
        (Option.map ~f:LastUpdateStatus.of_xml) (Xml.child xml_arg0 "Status") in
      let targetQueryTCU =
        (Option.map ~f:QueryTCU.of_xml) (Xml.child xml_arg0 "TargetQueryTCU") in
      make ?statusMessage ?status ?targetQueryTCU ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let statusMessage = field_map json__ "StatusMessage" String_.of_json in
      let status = field_map json__ "Status" LastUpdateStatus.of_json in
      let targetQueryTCU = field_map json__ "TargetQueryTCU" QueryTCU.of_json in
      make ?statusMessage ?status ?targetQueryTCU ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Configuration object that contains the most recent account settings update, visible only if settings have been updated previously."]
module ProvisionedCapacityResponse =
  struct
    type nonrec t =
      {
      activeQueryTCU: QueryTCU.t option
        [@ocaml.doc
          "The number of Timestream Compute Units (TCUs) provisioned in the account. This field is only visible when the compute mode is PROVISIONED."];
      notificationConfiguration:
        AccountSettingsNotificationConfiguration.t option
        [@ocaml.doc
          "An object that contains settings for notifications that are sent whenever the provisioned capacity settings are modified. This field is only visible when the compute mode is PROVISIONED."];
      lastUpdate: LastUpdate.t option
        [@ocaml.doc
          "Information about the last update to the provisioned capacity settings."]}
    let make ?activeQueryTCU =
      fun ?notificationConfiguration ->
        fun ?lastUpdate ->
          fun () -> { activeQueryTCU; notificationConfiguration; lastUpdate }
    let to_value x =
      structure_to_value
        [("ActiveQueryTCU",
           (Option.map x.activeQueryTCU ~f:QueryTCU.to_value));
        ("NotificationConfiguration",
          (Option.map x.notificationConfiguration
             ~f:AccountSettingsNotificationConfiguration.to_value));
        ("LastUpdate", (Option.map x.lastUpdate ~f:LastUpdate.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let lastUpdate =
        (Option.map ~f:LastUpdate.of_xml) (Xml.child xml_arg0 "LastUpdate") in
      let notificationConfiguration =
        (Option.map ~f:AccountSettingsNotificationConfiguration.of_xml)
          (Xml.child xml_arg0 "NotificationConfiguration") in
      let activeQueryTCU =
        (Option.map ~f:QueryTCU.of_xml) (Xml.child xml_arg0 "ActiveQueryTCU") in
      make ?lastUpdate ?notificationConfiguration ?activeQueryTCU ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let lastUpdate = field_map json__ "LastUpdate" LastUpdate.of_json in
      let notificationConfiguration =
        field_map json__ "NotificationConfiguration"
          AccountSettingsNotificationConfiguration.of_json in
      let activeQueryTCU = field_map json__ "ActiveQueryTCU" QueryTCU.of_json in
      make ?lastUpdate ?notificationConfiguration ?activeQueryTCU ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The response to a request to update the provisioned capacity settings for querying data."]
module QueryComputeResponse =
  struct
    type nonrec t =
      {
      computeMode: ComputeMode.t option
        [@ocaml.doc
          "The mode in which Timestream Compute Units (TCUs) are allocated and utilized within an account. Note that in the Asia Pacific (Mumbai) region, the API operation only recognizes the value PROVISIONED."];
      provisionedCapacity: ProvisionedCapacityResponse.t option
        [@ocaml.doc
          "Configuration object that contains settings for provisioned Timestream Compute Units (TCUs) in your account."]}
    let make ?computeMode =
      fun ?provisionedCapacity ->
        fun () -> { computeMode; provisionedCapacity }
    let to_value x =
      structure_to_value
        [("ComputeMode", (Option.map x.computeMode ~f:ComputeMode.to_value));
        ("ProvisionedCapacity",
          (Option.map x.provisionedCapacity
             ~f:ProvisionedCapacityResponse.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let provisionedCapacity =
        (Option.map ~f:ProvisionedCapacityResponse.of_xml)
          (Xml.child xml_arg0 "ProvisionedCapacity") in
      let computeMode =
        (Option.map ~f:ComputeMode.of_xml) (Xml.child xml_arg0 "ComputeMode") in
      make ?provisionedCapacity ?computeMode ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let provisionedCapacity =
        field_map json__ "ProvisionedCapacity"
          ProvisionedCapacityResponse.of_json in
      let computeMode = field_map json__ "ComputeMode" ComputeMode.of_json in
      make ?provisionedCapacity ?computeMode ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The response to a request to retrieve or update the compute capacity settings for querying data."]
module MaxQueryCapacity =
  struct
    type nonrec t = int
    let make i = i
    let of_string = Int.of_string
    let to_value x = `Integer x
    let to_query v = to_query to_value v
    let to_header x = Int.to_string x
    let of_xml xml_arg0 =
      Int.of_string
        (string_of_xml ~kind:"an integer for MaxQueryCapacity" xml_arg0)
    let of_json j = Int.of_float (float_of_json ~kind:"an integer" j)
    let to_json = simple_to_json to_value
  end
module DescribeAccountSettingsResponse =
  struct
    type nonrec t =
      {
      maxQueryTCU: MaxQueryCapacity.t option
        [@ocaml.doc
          "The maximum number of Timestream compute units (TCUs) the service will use at any point in time to serve your queries. To run queries, you must set a minimum capacity of 4 TCU. You can set the maximum number of TCU in multiples of 4, for example, 4, 8, 16, 32, and so on. This configuration is applicable only for on-demand usage of (TCUs)."];
      queryPricingModel: QueryPricingModel.t option
        [@ocaml.doc
          "The pricing model for queries in your account. The QueryPricingModel parameter is used by several Timestream operations; however, the UpdateAccountSettings API operation doesn't recognize any values other than COMPUTE_UNITS."];
      queryCompute: QueryComputeResponse.t option
        [@ocaml.doc
          "An object that contains the usage settings for Timestream Compute Units (TCUs) in your account for the query workload."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `InternalServerException of InternalServerException.t 
      | `InvalidEndpointException of InvalidEndpointException.t 
      | `ThrottlingException of ThrottlingException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?maxQueryTCU =
      fun ?queryPricingModel ->
        fun ?queryCompute ->
          fun () -> { maxQueryTCU; queryPricingModel; queryCompute }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_json json)
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_json json)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_xml xml)
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_xml xml)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `InternalServerException e ->
          `Assoc
            [("error", (`String "InternalServerException"));
            ("details", (InternalServerException.to_json e))]
      | `InvalidEndpointException e ->
          `Assoc
            [("error", (`String "InvalidEndpointException"));
            ("details", (InvalidEndpointException.to_json e))]
      | `ThrottlingException e ->
          `Assoc
            [("error", (`String "ThrottlingException"));
            ("details", (ThrottlingException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("MaxQueryTCU",
           (Option.map x.maxQueryTCU ~f:MaxQueryCapacity.to_value));
        ("QueryPricingModel",
          (Option.map x.queryPricingModel ~f:QueryPricingModel.to_value));
        ("QueryCompute",
          (Option.map x.queryCompute ~f:QueryComputeResponse.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let queryCompute =
        (Option.map ~f:QueryComputeResponse.of_xml)
          (Xml.child xml_arg0 "QueryCompute") in
      let queryPricingModel =
        (Option.map ~f:QueryPricingModel.of_xml)
          (Xml.child xml_arg0 "QueryPricingModel") in
      let maxQueryTCU =
        (Option.map ~f:MaxQueryCapacity.of_xml)
          (Xml.child xml_arg0 "MaxQueryTCU") in
      make ?queryCompute ?queryPricingModel ?maxQueryTCU ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let queryCompute =
        field_map json__ "QueryCompute" QueryComputeResponse.of_json in
      let queryPricingModel =
        field_map json__ "QueryPricingModel" QueryPricingModel.of_json in
      let maxQueryTCU =
        field_map json__ "MaxQueryTCU" MaxQueryCapacity.of_json in
      make ?queryCompute ?queryPricingModel ?maxQueryTCU ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Describes the settings for your account that include the query pricing model and the configured maximum TCUs the service can use for your query workload. You're charged only for the duration of compute units used for your workloads."]
module DescribeEndpointsRequest =
  struct
    type nonrec t = unit
    let make () = ()
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "DescribeEndpoints returns a list of available endpoints to make Timestream API calls against. This API is available through both Write and Query. Because the Timestream SDKs are designed to transparently work with the service\226\128\153s architecture, including the management and mapping of the service endpoints, it is not recommended that you use this API unless: You are using VPC endpoints (Amazon Web Services PrivateLink) with Timestream Your application uses a programming language that does not yet have SDK support You require better control over the client-side implementation For detailed information on how and when to use and implement DescribeEndpoints, see The Endpoint Discovery Pattern."]
module Long =
  struct
    type nonrec t = Int64.t
    let make i = i
    let of_string = Int64.of_string
    let to_value x = `Long x
    let to_query v = to_query to_value v
    let to_header x = Int64.to_string x
    let of_xml xml_arg0 =
      Int64.of_string (string_of_xml ~kind:"a long" xml_arg0)
    let of_json j = Int64.of_float (float_of_json ~kind:"a long" j)
    let to_json = simple_to_json to_value
  end
module Endpoint =
  struct
    type nonrec t =
      {
      address: String_.t option [@ocaml.doc "An endpoint address."];
      cachePeriodInMinutes: Long.t option
        [@ocaml.doc "The TTL for the endpoint, in minutes."]}
    let make ?address =
      fun ?cachePeriodInMinutes ->
        fun () -> { address; cachePeriodInMinutes }
    let to_value x =
      structure_to_value
        [("Address", (Option.map x.address ~f:String_.to_value));
        ("CachePeriodInMinutes",
          (Option.map x.cachePeriodInMinutes ~f:Long.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let cachePeriodInMinutes =
        (Option.map ~f:Long.of_xml)
          (Xml.child xml_arg0 "CachePeriodInMinutes") in
      let address =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "Address") in
      make ?cachePeriodInMinutes ?address ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let cachePeriodInMinutes =
        field_map json__ "CachePeriodInMinutes" Long.of_json in
      let address = field_map json__ "Address" String_.of_json in
      make ?cachePeriodInMinutes ?address ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Represents an available endpoint against which to make API calls against, as well as the TTL for that endpoint."]
module Endpoints =
  struct
    type nonrec t = Endpoint.t list
    let make i = i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:Endpoint.to_value)) |> (fun x -> `List x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for List_shape objects" ()
    let of_xml x =
      make
        (List.map
           ((Xml.all_children x) |>
              (List.filter
                 ~f:(function
                     | `Data s ->
                         (match Stdlib.String.trim s with
                          | "" -> false
                          | _ -> true)
                     | _ -> true))) ~f:Endpoint.of_xml)
    let of_json j =
      list_of_json ~kind:"Endpoints" ~of_json:Endpoint.of_json j
    let to_json v = composed_to_json to_value v
  end
module DescribeEndpointsResponse =
  struct
    type nonrec t =
      {
      endpoints: Endpoints.t option
        [@ocaml.doc
          "An Endpoints object is returned when a DescribeEndpoints request is made."]}
    type nonrec error =
      [ `InternalServerException of InternalServerException.t 
      | `ThrottlingException of ThrottlingException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?endpoints = fun () -> { endpoints }
    let error_of_json name json =
      match name with
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_json json)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_xml xml)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `InternalServerException e ->
          `Assoc
            [("error", (`String "InternalServerException"));
            ("details", (InternalServerException.to_json e))]
      | `ThrottlingException e ->
          `Assoc
            [("error", (`String "ThrottlingException"));
            ("details", (ThrottlingException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("Endpoints", (Option.map x.endpoints ~f:Endpoints.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let endpoints =
        (Option.map ~f:Endpoints.of_xml) (Xml.child xml_arg0 "Endpoints") in
      make ?endpoints ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let endpoints = field_map json__ "Endpoints" Endpoints.of_json in
      make ?endpoints ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "DescribeEndpoints returns a list of available endpoints to make Timestream API calls against. This API is available through both Write and Query. Because the Timestream SDKs are designed to transparently work with the service\226\128\153s architecture, including the management and mapping of the service endpoints, it is not recommended that you use this API unless: You are using VPC endpoints (Amazon Web Services PrivateLink) with Timestream Your application uses a programming language that does not yet have SDK support You require better control over the client-side implementation For detailed information on how and when to use and implement DescribeEndpoints, see The Endpoint Discovery Pattern."]
module DescribeScheduledQueryRequest =
  struct
    type nonrec t =
      {
      scheduledQueryArn: AmazonResourceName.t
        [@ocaml.doc "The ARN of the scheduled query."]}
    let context_ = "DescribeScheduledQueryRequest"
    let make ~scheduledQueryArn = fun () -> { scheduledQueryArn }
    let to_value x =
      structure_to_value
        [("ScheduledQueryArn",
           (Some (AmazonResourceName.to_value x.scheduledQueryArn)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let scheduledQueryArn =
        AmazonResourceName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "ScheduledQueryArn") in
      make ~scheduledQueryArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let scheduledQueryArn =
        field_map_exn json__ "ScheduledQueryArn" AmazonResourceName.of_json in
      make ~scheduledQueryArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Provides detailed information about a scheduled query."]
module Time =
  struct
    type nonrec t = string
    let make i = i
    let of_string x = x
    let to_value x = `Timestamp x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = string_of_xml ~kind:"a timestamp"
    let of_json = timestamp_of_json
    let to_json = simple_to_json to_value
  end
module ScheduledQueryState =
  struct
    type nonrec t =
      | ENABLED 
      | DISABLED 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | ENABLED -> "ENABLED"
      | DISABLED -> "DISABLED"
      | Non_static_id s -> s
    let of_string =
      function
      | "ENABLED" -> ENABLED
      | "DISABLED" -> DISABLED
      | x -> Non_static_id x
    let to_value x = `Enum (to_string x)
    let to_query v = to_query to_value v
    let to_header x = to_string x
    let of_xml xml_arg0 =
      of_string
        (string_of_xml ~kind:"enumeration ScheduledQueryState" xml_arg0)
    let of_json j = of_string (string_of_json ~kind:"ScheduledQueryState" j)
    let to_json = simple_to_json to_value
  end
module ScheduledQueryRunStatus =
  struct
    type nonrec t =
      | AUTO_TRIGGER_SUCCESS 
      | AUTO_TRIGGER_FAILURE 
      | MANUAL_TRIGGER_SUCCESS 
      | MANUAL_TRIGGER_FAILURE 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | AUTO_TRIGGER_SUCCESS -> "AUTO_TRIGGER_SUCCESS"
      | AUTO_TRIGGER_FAILURE -> "AUTO_TRIGGER_FAILURE"
      | MANUAL_TRIGGER_SUCCESS -> "MANUAL_TRIGGER_SUCCESS"
      | MANUAL_TRIGGER_FAILURE -> "MANUAL_TRIGGER_FAILURE"
      | Non_static_id s -> s
    let of_string =
      function
      | "AUTO_TRIGGER_SUCCESS" -> AUTO_TRIGGER_SUCCESS
      | "AUTO_TRIGGER_FAILURE" -> AUTO_TRIGGER_FAILURE
      | "MANUAL_TRIGGER_SUCCESS" -> MANUAL_TRIGGER_SUCCESS
      | "MANUAL_TRIGGER_FAILURE" -> MANUAL_TRIGGER_FAILURE
      | x -> Non_static_id x
    let to_value x = `Enum (to_string x)
    let to_query v = to_query to_value v
    let to_header x = to_string x
    let of_xml xml_arg0 =
      of_string
        (string_of_xml ~kind:"enumeration ScheduledQueryRunStatus" xml_arg0)
    let of_json j =
      of_string (string_of_json ~kind:"ScheduledQueryRunStatus" j)
    let to_json = simple_to_json to_value
  end
module QueryTemporalRangeMax =
  struct
    type nonrec t =
      {
      value: Long.t option
        [@ocaml.doc
          "The maximum duration in nanoseconds between the start and end of the query."];
      tableArn: AmazonResourceName.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the table which is queried with the largest time range."]}
    let make ?value = fun ?tableArn -> fun () -> { value; tableArn }
    let to_value x =
      structure_to_value
        [("Value", (Option.map x.value ~f:Long.to_value));
        ("TableArn", (Option.map x.tableArn ~f:AmazonResourceName.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let tableArn =
        (Option.map ~f:AmazonResourceName.of_xml)
          (Xml.child xml_arg0 "TableArn") in
      let value = (Option.map ~f:Long.of_xml) (Xml.child xml_arg0 "Value") in
      make ?tableArn ?value ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let tableArn = field_map json__ "TableArn" AmazonResourceName.of_json in
      let value = field_map json__ "Value" Long.of_json in
      make ?tableArn ?value ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Provides insights into the table with the most sub-optimal temporal pruning scanned by your query."]
module QueryTemporalRange =
  struct
    type nonrec t =
      {
      max: QueryTemporalRangeMax.t option
        [@ocaml.doc
          "Encapsulates the following properties that provide insights into the most sub-optimal performing table on the temporal axis: Value \226\128\147 The maximum duration in nanoseconds between the start and end of the query. TableArn \226\128\147 The Amazon Resource Name (ARN) of the table which is queried with the largest time range."]}
    let make ?max = fun () -> { max }
    let to_value x =
      structure_to_value
        [("Max", (Option.map x.max ~f:QueryTemporalRangeMax.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let max =
        (Option.map ~f:QueryTemporalRangeMax.of_xml)
          (Xml.child xml_arg0 "Max") in
      make ?max ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let max = field_map json__ "Max" QueryTemporalRangeMax.of_json in
      make ?max ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Provides insights into the temporal range of the query, including the table with the largest (max) time range."]
module PartitionKey =
  struct
    type nonrec t = string
    let context_ = "PartitionKey"
    let make i = i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"PartitionKey" j
    let to_json = simple_to_json to_value
  end
module PartitionKeyList =
  struct
    type nonrec t = PartitionKey.t list
    let make i = i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:PartitionKey.to_value)) |> (fun x -> `List x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for List_shape objects" ()
    let of_xml x =
      make
        (List.map
           ((Xml.all_children x) |>
              (List.filter
                 ~f:(function
                     | `Data s ->
                         (match Stdlib.String.trim s with
                          | "" -> false
                          | _ -> true)
                     | _ -> true))) ~f:PartitionKey.of_xml)
    let of_json j =
      list_of_json ~kind:"PartitionKeyList" ~of_json:PartitionKey.of_json j
    let to_json v = composed_to_json to_value v
  end
module Double =
  struct
    type nonrec t = float
    let make i = i
    let of_string = Float.of_string
    let to_value x = `Double x
    let to_query v = to_query to_value v
    let to_header x = Stdlib.Float.to_string x
    let of_xml xml_arg0 =
      Float.of_string (string_of_xml ~kind:"a double" xml_arg0)
    let of_json j = float_of_json ~kind:"a double" j
    let to_json = simple_to_json to_value
  end
module QuerySpatialCoverageMax =
  struct
    type nonrec t =
      {
      value: Double.t option
        [@ocaml.doc "The maximum ratio of spatial coverage."];
      tableArn: AmazonResourceName.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the table with the most sub-optimal spatial pruning."];
      partitionKey: PartitionKeyList.t option
        [@ocaml.doc
          "The partition key used for partitioning, which can be a default measure_name or a customer defined partition key."]}
    let make ?value =
      fun ?tableArn ->
        fun ?partitionKey -> fun () -> { value; tableArn; partitionKey }
    let to_value x =
      structure_to_value
        [("Value", (Option.map x.value ~f:Double.to_value));
        ("TableArn", (Option.map x.tableArn ~f:AmazonResourceName.to_value));
        ("PartitionKey",
          (Option.map x.partitionKey ~f:PartitionKeyList.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let partitionKey =
        (Option.map ~f:PartitionKeyList.of_xml)
          (Xml.child xml_arg0 "PartitionKey") in
      let tableArn =
        (Option.map ~f:AmazonResourceName.of_xml)
          (Xml.child xml_arg0 "TableArn") in
      let value = (Option.map ~f:Double.of_xml) (Xml.child xml_arg0 "Value") in
      make ?partitionKey ?tableArn ?value ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let partitionKey =
        field_map json__ "PartitionKey" PartitionKeyList.of_json in
      let tableArn = field_map json__ "TableArn" AmazonResourceName.of_json in
      let value = field_map json__ "Value" Double.of_json in
      make ?partitionKey ?tableArn ?value ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Provides insights into the table with the most sub-optimal spatial range scanned by your query."]
module QuerySpatialCoverage =
  struct
    type nonrec t =
      {
      max: QuerySpatialCoverageMax.t option
        [@ocaml.doc
          "Provides insights into the spatial coverage of the executed query and the table with the most inefficient spatial pruning. Value \226\128\147 The maximum ratio of spatial coverage. TableArn \226\128\147 The Amazon Resource Name (ARN) of the table with sub-optimal spatial pruning. PartitionKey \226\128\147 The partition key used for partitioning, which can be a default measure_name or a CDPK."]}
    let make ?max = fun () -> { max }
    let to_value x =
      structure_to_value
        [("Max", (Option.map x.max ~f:QuerySpatialCoverageMax.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let max =
        (Option.map ~f:QuerySpatialCoverageMax.of_xml)
          (Xml.child xml_arg0 "Max") in
      make ?max ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let max = field_map json__ "Max" QuerySpatialCoverageMax.of_json in
      make ?max ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Provides insights into the spatial coverage of the query, including the table with sub-optimal (max) spatial pruning. This information can help you identify areas for improvement in your partitioning strategy to enhance spatial pruning For example, you can do the following with the QuerySpatialCoverage information: Add measure_name or use customer-defined partition key (CDPK) predicates. If you've already done the preceding action, remove functions around them or clauses, such as LIKE."]
module ScheduledQueryInsightsResponse =
  struct
    type nonrec t =
      {
      querySpatialCoverage: QuerySpatialCoverage.t option
        [@ocaml.doc
          "Provides insights into the spatial coverage of the query, including the table with sub-optimal (max) spatial pruning. This information can help you identify areas for improvement in your partitioning strategy to enhance spatial pruning."];
      queryTemporalRange: QueryTemporalRange.t option
        [@ocaml.doc
          "Provides insights into the temporal range of the query, including the table with the largest (max) time range. Following are some of the potential options for optimizing time-based pruning: Add missing time-predicates. Remove functions around the time predicates. Add time predicates to all the sub-queries."];
      queryTableCount: Long.t option
        [@ocaml.doc "Indicates the number of tables in the query."];
      outputRows: Long.t option
        [@ocaml.doc
          "Indicates the total number of rows returned as part of the query result set. You can use this data to validate if the number of rows in the result set have changed as part of the query tuning exercise."];
      outputBytes: Long.t option
        [@ocaml.doc
          "Indicates the size of query result set in bytes. You can use this data to validate if the result set has changed as part of the query tuning exercise."]}
    let make ?querySpatialCoverage =
      fun ?queryTemporalRange ->
        fun ?queryTableCount ->
          fun ?outputRows ->
            fun ?outputBytes ->
              fun () ->
                {
                  querySpatialCoverage;
                  queryTemporalRange;
                  queryTableCount;
                  outputRows;
                  outputBytes
                }
    let to_value x =
      structure_to_value
        [("QuerySpatialCoverage",
           (Option.map x.querySpatialCoverage
              ~f:QuerySpatialCoverage.to_value));
        ("QueryTemporalRange",
          (Option.map x.queryTemporalRange ~f:QueryTemporalRange.to_value));
        ("QueryTableCount", (Option.map x.queryTableCount ~f:Long.to_value));
        ("OutputRows", (Option.map x.outputRows ~f:Long.to_value));
        ("OutputBytes", (Option.map x.outputBytes ~f:Long.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let outputBytes =
        (Option.map ~f:Long.of_xml) (Xml.child xml_arg0 "OutputBytes") in
      let outputRows =
        (Option.map ~f:Long.of_xml) (Xml.child xml_arg0 "OutputRows") in
      let queryTableCount =
        (Option.map ~f:Long.of_xml) (Xml.child xml_arg0 "QueryTableCount") in
      let queryTemporalRange =
        (Option.map ~f:QueryTemporalRange.of_xml)
          (Xml.child xml_arg0 "QueryTemporalRange") in
      let querySpatialCoverage =
        (Option.map ~f:QuerySpatialCoverage.of_xml)
          (Xml.child xml_arg0 "QuerySpatialCoverage") in
      make ?outputBytes ?outputRows ?queryTableCount ?queryTemporalRange
        ?querySpatialCoverage ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let outputBytes = field_map json__ "OutputBytes" Long.of_json in
      let outputRows = field_map json__ "OutputRows" Long.of_json in
      let queryTableCount = field_map json__ "QueryTableCount" Long.of_json in
      let queryTemporalRange =
        field_map json__ "QueryTemporalRange" QueryTemporalRange.of_json in
      let querySpatialCoverage =
        field_map json__ "QuerySpatialCoverage" QuerySpatialCoverage.of_json in
      make ?outputBytes ?outputRows ?queryTableCount ?queryTemporalRange
        ?querySpatialCoverage ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Provides various insights and metrics related to the ExecuteScheduledQueryRequest that was executed."]
module ExecutionStats =
  struct
    type nonrec t =
      {
      executionTimeInMillis: Long.t option
        [@ocaml.doc
          "Total time, measured in milliseconds, that was needed for the scheduled query run to complete."];
      dataWrites: Long.t option
        [@ocaml.doc
          "Data writes metered for records ingested in a single scheduled query run."];
      bytesMetered: Long.t option
        [@ocaml.doc "Bytes metered for a single scheduled query run."];
      cumulativeBytesScanned: Long.t option
        [@ocaml.doc "Bytes scanned for a single scheduled query run."];
      recordsIngested: Long.t option
        [@ocaml.doc
          "The number of records ingested for a single scheduled query run."];
      queryResultRows: Long.t option
        [@ocaml.doc
          "Number of rows present in the output from running a query before ingestion to destination data source."]}
    let make ?executionTimeInMillis =
      fun ?dataWrites ->
        fun ?bytesMetered ->
          fun ?cumulativeBytesScanned ->
            fun ?recordsIngested ->
              fun ?queryResultRows ->
                fun () ->
                  {
                    executionTimeInMillis;
                    dataWrites;
                    bytesMetered;
                    cumulativeBytesScanned;
                    recordsIngested;
                    queryResultRows
                  }
    let to_value x =
      structure_to_value
        [("ExecutionTimeInMillis",
           (Option.map x.executionTimeInMillis ~f:Long.to_value));
        ("DataWrites", (Option.map x.dataWrites ~f:Long.to_value));
        ("BytesMetered", (Option.map x.bytesMetered ~f:Long.to_value));
        ("CumulativeBytesScanned",
          (Option.map x.cumulativeBytesScanned ~f:Long.to_value));
        ("RecordsIngested", (Option.map x.recordsIngested ~f:Long.to_value));
        ("QueryResultRows", (Option.map x.queryResultRows ~f:Long.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let queryResultRows =
        (Option.map ~f:Long.of_xml) (Xml.child xml_arg0 "QueryResultRows") in
      let recordsIngested =
        (Option.map ~f:Long.of_xml) (Xml.child xml_arg0 "RecordsIngested") in
      let cumulativeBytesScanned =
        (Option.map ~f:Long.of_xml)
          (Xml.child xml_arg0 "CumulativeBytesScanned") in
      let bytesMetered =
        (Option.map ~f:Long.of_xml) (Xml.child xml_arg0 "BytesMetered") in
      let dataWrites =
        (Option.map ~f:Long.of_xml) (Xml.child xml_arg0 "DataWrites") in
      let executionTimeInMillis =
        (Option.map ~f:Long.of_xml)
          (Xml.child xml_arg0 "ExecutionTimeInMillis") in
      make ?queryResultRows ?recordsIngested ?cumulativeBytesScanned
        ?bytesMetered ?dataWrites ?executionTimeInMillis ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let queryResultRows = field_map json__ "QueryResultRows" Long.of_json in
      let recordsIngested = field_map json__ "RecordsIngested" Long.of_json in
      let cumulativeBytesScanned =
        field_map json__ "CumulativeBytesScanned" Long.of_json in
      let bytesMetered = field_map json__ "BytesMetered" Long.of_json in
      let dataWrites = field_map json__ "DataWrites" Long.of_json in
      let executionTimeInMillis =
        field_map json__ "ExecutionTimeInMillis" Long.of_json in
      make ?queryResultRows ?recordsIngested ?cumulativeBytesScanned
        ?bytesMetered ?dataWrites ?executionTimeInMillis ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Statistics for a single scheduled query run."]
module S3ObjectKey =
  struct
    type nonrec t = string
    let context_ = "S3ObjectKey"
    let make i = i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"S3ObjectKey" j
    let to_json = simple_to_json to_value
  end
module S3ReportLocation =
  struct
    type nonrec t =
      {
      bucketName: S3BucketName.t option [@ocaml.doc "S3 bucket name."];
      objectKey: S3ObjectKey.t option [@ocaml.doc "S3 key."]}
    let make ?bucketName =
      fun ?objectKey -> fun () -> { bucketName; objectKey }
    let to_value x =
      structure_to_value
        [("BucketName", (Option.map x.bucketName ~f:S3BucketName.to_value));
        ("ObjectKey", (Option.map x.objectKey ~f:S3ObjectKey.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let objectKey =
        (Option.map ~f:S3ObjectKey.of_xml) (Xml.child xml_arg0 "ObjectKey") in
      let bucketName =
        (Option.map ~f:S3BucketName.of_xml) (Xml.child xml_arg0 "BucketName") in
      make ?objectKey ?bucketName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let objectKey = field_map json__ "ObjectKey" S3ObjectKey.of_json in
      let bucketName = field_map json__ "BucketName" S3BucketName.of_json in
      make ?objectKey ?bucketName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "S3 report location for the scheduled query run."]
module ErrorReportLocation =
  struct
    type nonrec t =
      {
      s3ReportLocation: S3ReportLocation.t option
        [@ocaml.doc "The S3 location where error reports are written."]}
    let make ?s3ReportLocation = fun () -> { s3ReportLocation }
    let to_value x =
      structure_to_value
        [("S3ReportLocation",
           (Option.map x.s3ReportLocation ~f:S3ReportLocation.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let s3ReportLocation =
        (Option.map ~f:S3ReportLocation.of_xml)
          (Xml.child xml_arg0 "S3ReportLocation") in
      make ?s3ReportLocation ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let s3ReportLocation =
        field_map json__ "S3ReportLocation" S3ReportLocation.of_json in
      make ?s3ReportLocation ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "This contains the location of the error report for a single scheduled query call."]
module ScheduledQueryRunSummary =
  struct
    type nonrec t =
      {
      invocationTime: Time.t option
        [@ocaml.doc
          "InvocationTime for this run. This is the time at which the query is scheduled to run. Parameter \\@scheduled_runtime can be used in the query to get the value."];
      triggerTime: Time.t option
        [@ocaml.doc "The actual time when the query was run."];
      runStatus: ScheduledQueryRunStatus.t option
        [@ocaml.doc "The status of a scheduled query run."];
      executionStats: ExecutionStats.t option
        [@ocaml.doc "Runtime statistics for a scheduled run."];
      queryInsightsResponse: ScheduledQueryInsightsResponse.t option
        [@ocaml.doc
          "Provides various insights and metrics related to the run summary of the scheduled query."];
      errorReportLocation: ErrorReportLocation.t option
        [@ocaml.doc "S3 location for error report."];
      failureReason: ErrorMessage.t option
        [@ocaml.doc
          "Error message for the scheduled query in case of failure. You might have to look at the error report to get more detailed error reasons."]}
    let make ?invocationTime =
      fun ?triggerTime ->
        fun ?runStatus ->
          fun ?executionStats ->
            fun ?queryInsightsResponse ->
              fun ?errorReportLocation ->
                fun ?failureReason ->
                  fun () ->
                    {
                      invocationTime;
                      triggerTime;
                      runStatus;
                      executionStats;
                      queryInsightsResponse;
                      errorReportLocation;
                      failureReason
                    }
    let to_value x =
      structure_to_value
        [("InvocationTime", (Option.map x.invocationTime ~f:Time.to_value));
        ("TriggerTime", (Option.map x.triggerTime ~f:Time.to_value));
        ("RunStatus",
          (Option.map x.runStatus ~f:ScheduledQueryRunStatus.to_value));
        ("ExecutionStats",
          (Option.map x.executionStats ~f:ExecutionStats.to_value));
        ("QueryInsightsResponse",
          (Option.map x.queryInsightsResponse
             ~f:ScheduledQueryInsightsResponse.to_value));
        ("ErrorReportLocation",
          (Option.map x.errorReportLocation ~f:ErrorReportLocation.to_value));
        ("FailureReason",
          (Option.map x.failureReason ~f:ErrorMessage.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let failureReason =
        (Option.map ~f:ErrorMessage.of_xml)
          (Xml.child xml_arg0 "FailureReason") in
      let errorReportLocation =
        (Option.map ~f:ErrorReportLocation.of_xml)
          (Xml.child xml_arg0 "ErrorReportLocation") in
      let queryInsightsResponse =
        (Option.map ~f:ScheduledQueryInsightsResponse.of_xml)
          (Xml.child xml_arg0 "QueryInsightsResponse") in
      let executionStats =
        (Option.map ~f:ExecutionStats.of_xml)
          (Xml.child xml_arg0 "ExecutionStats") in
      let runStatus =
        (Option.map ~f:ScheduledQueryRunStatus.of_xml)
          (Xml.child xml_arg0 "RunStatus") in
      let triggerTime =
        (Option.map ~f:Time.of_xml) (Xml.child xml_arg0 "TriggerTime") in
      let invocationTime =
        (Option.map ~f:Time.of_xml) (Xml.child xml_arg0 "InvocationTime") in
      make ?failureReason ?errorReportLocation ?queryInsightsResponse
        ?executionStats ?runStatus ?triggerTime ?invocationTime ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let failureReason =
        field_map json__ "FailureReason" ErrorMessage.of_json in
      let errorReportLocation =
        field_map json__ "ErrorReportLocation" ErrorReportLocation.of_json in
      let queryInsightsResponse =
        field_map json__ "QueryInsightsResponse"
          ScheduledQueryInsightsResponse.of_json in
      let executionStats =
        field_map json__ "ExecutionStats" ExecutionStats.of_json in
      let runStatus =
        field_map json__ "RunStatus" ScheduledQueryRunStatus.of_json in
      let triggerTime = field_map json__ "TriggerTime" Time.of_json in
      let invocationTime = field_map json__ "InvocationTime" Time.of_json in
      make ?failureReason ?errorReportLocation ?queryInsightsResponse
        ?executionStats ?runStatus ?triggerTime ?invocationTime ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Run summary for the scheduled query"]
module ScheduledQueryRunSummaryList =
  struct
    type nonrec t = ScheduledQueryRunSummary.t list
    let make i = i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:ScheduledQueryRunSummary.to_value)) |>
        (fun x -> `List x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for List_shape objects" ()
    let of_xml x =
      make
        (List.map
           ((Xml.all_children x) |>
              (List.filter
                 ~f:(function
                     | `Data s ->
                         (match Stdlib.String.trim s with
                          | "" -> false
                          | _ -> true)
                     | _ -> true))) ~f:ScheduledQueryRunSummary.of_xml)
    let of_json j =
      list_of_json ~kind:"ScheduledQueryRunSummaryList"
        ~of_json:ScheduledQueryRunSummary.of_json j
    let to_json v = composed_to_json to_value v
  end
module ScheduledQueryDescription =
  struct
    type nonrec t =
      {
      arn: AmazonResourceName.t option [@ocaml.doc "Scheduled query ARN."];
      name: ScheduledQueryName.t option
        [@ocaml.doc "Name of the scheduled query."];
      queryString: QueryString.t option [@ocaml.doc "The query to be run."];
      creationTime: Time.t option
        [@ocaml.doc "Creation time of the scheduled query."];
      state: ScheduledQueryState.t option
        [@ocaml.doc "State of the scheduled query."];
      previousInvocationTime: Time.t option
        [@ocaml.doc "Last time the query was run."];
      nextInvocationTime: Time.t option
        [@ocaml.doc "The next time the scheduled query is scheduled to run."];
      scheduleConfiguration: ScheduleConfiguration.t option
        [@ocaml.doc "Schedule configuration."];
      notificationConfiguration: NotificationConfiguration.t option
        [@ocaml.doc "Notification configuration."];
      targetConfiguration: TargetConfiguration.t option
        [@ocaml.doc "Scheduled query target store configuration."];
      scheduledQueryExecutionRoleArn: AmazonResourceName.t option
        [@ocaml.doc
          "IAM role that Timestream uses to run the schedule query."];
      kmsKeyId: StringValue2048.t option
        [@ocaml.doc
          "A customer provided KMS key used to encrypt the scheduled query resource."];
      errorReportConfiguration: ErrorReportConfiguration.t option
        [@ocaml.doc "Error-reporting configuration for the scheduled query."];
      lastRunSummary: ScheduledQueryRunSummary.t option
        [@ocaml.doc "Runtime summary for the last scheduled query run."];
      recentlyFailedRuns: ScheduledQueryRunSummaryList.t option
        [@ocaml.doc
          "Runtime summary for the last five failed scheduled query runs."]}
    let make ?arn =
      fun ?name ->
        fun ?queryString ->
          fun ?creationTime ->
            fun ?state ->
              fun ?previousInvocationTime ->
                fun ?nextInvocationTime ->
                  fun ?scheduleConfiguration ->
                    fun ?notificationConfiguration ->
                      fun ?targetConfiguration ->
                        fun ?scheduledQueryExecutionRoleArn ->
                          fun ?kmsKeyId ->
                            fun ?errorReportConfiguration ->
                              fun ?lastRunSummary ->
                                fun ?recentlyFailedRuns ->
                                  fun () ->
                                    {
                                      arn;
                                      name;
                                      queryString;
                                      creationTime;
                                      state;
                                      previousInvocationTime;
                                      nextInvocationTime;
                                      scheduleConfiguration;
                                      notificationConfiguration;
                                      targetConfiguration;
                                      scheduledQueryExecutionRoleArn;
                                      kmsKeyId;
                                      errorReportConfiguration;
                                      lastRunSummary;
                                      recentlyFailedRuns
                                    }
    let to_value x =
      structure_to_value
        [("Arn", (Option.map x.arn ~f:AmazonResourceName.to_value));
        ("Name", (Option.map x.name ~f:ScheduledQueryName.to_value));
        ("QueryString", (Option.map x.queryString ~f:QueryString.to_value));
        ("CreationTime", (Option.map x.creationTime ~f:Time.to_value));
        ("State", (Option.map x.state ~f:ScheduledQueryState.to_value));
        ("PreviousInvocationTime",
          (Option.map x.previousInvocationTime ~f:Time.to_value));
        ("NextInvocationTime",
          (Option.map x.nextInvocationTime ~f:Time.to_value));
        ("ScheduleConfiguration",
          (Option.map x.scheduleConfiguration
             ~f:ScheduleConfiguration.to_value));
        ("NotificationConfiguration",
          (Option.map x.notificationConfiguration
             ~f:NotificationConfiguration.to_value));
        ("TargetConfiguration",
          (Option.map x.targetConfiguration ~f:TargetConfiguration.to_value));
        ("ScheduledQueryExecutionRoleArn",
          (Option.map x.scheduledQueryExecutionRoleArn
             ~f:AmazonResourceName.to_value));
        ("KmsKeyId", (Option.map x.kmsKeyId ~f:StringValue2048.to_value));
        ("ErrorReportConfiguration",
          (Option.map x.errorReportConfiguration
             ~f:ErrorReportConfiguration.to_value));
        ("LastRunSummary",
          (Option.map x.lastRunSummary ~f:ScheduledQueryRunSummary.to_value));
        ("RecentlyFailedRuns",
          (Option.map x.recentlyFailedRuns
             ~f:ScheduledQueryRunSummaryList.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let recentlyFailedRuns =
        (Option.map ~f:ScheduledQueryRunSummaryList.of_xml)
          (Xml.child xml_arg0 "RecentlyFailedRuns") in
      let lastRunSummary =
        (Option.map ~f:ScheduledQueryRunSummary.of_xml)
          (Xml.child xml_arg0 "LastRunSummary") in
      let errorReportConfiguration =
        (Option.map ~f:ErrorReportConfiguration.of_xml)
          (Xml.child xml_arg0 "ErrorReportConfiguration") in
      let kmsKeyId =
        (Option.map ~f:StringValue2048.of_xml)
          (Xml.child xml_arg0 "KmsKeyId") in
      let scheduledQueryExecutionRoleArn =
        (Option.map ~f:AmazonResourceName.of_xml)
          (Xml.child xml_arg0 "ScheduledQueryExecutionRoleArn") in
      let targetConfiguration =
        (Option.map ~f:TargetConfiguration.of_xml)
          (Xml.child xml_arg0 "TargetConfiguration") in
      let notificationConfiguration =
        (Option.map ~f:NotificationConfiguration.of_xml)
          (Xml.child xml_arg0 "NotificationConfiguration") in
      let scheduleConfiguration =
        (Option.map ~f:ScheduleConfiguration.of_xml)
          (Xml.child xml_arg0 "ScheduleConfiguration") in
      let nextInvocationTime =
        (Option.map ~f:Time.of_xml) (Xml.child xml_arg0 "NextInvocationTime") in
      let previousInvocationTime =
        (Option.map ~f:Time.of_xml)
          (Xml.child xml_arg0 "PreviousInvocationTime") in
      let state =
        (Option.map ~f:ScheduledQueryState.of_xml)
          (Xml.child xml_arg0 "State") in
      let creationTime =
        (Option.map ~f:Time.of_xml) (Xml.child xml_arg0 "CreationTime") in
      let queryString =
        (Option.map ~f:QueryString.of_xml) (Xml.child xml_arg0 "QueryString") in
      let name =
        (Option.map ~f:ScheduledQueryName.of_xml) (Xml.child xml_arg0 "Name") in
      let arn =
        (Option.map ~f:AmazonResourceName.of_xml) (Xml.child xml_arg0 "Arn") in
      make ?recentlyFailedRuns ?lastRunSummary ?errorReportConfiguration
        ?kmsKeyId ?scheduledQueryExecutionRoleArn ?targetConfiguration
        ?notificationConfiguration ?scheduleConfiguration ?nextInvocationTime
        ?previousInvocationTime ?state ?creationTime ?queryString ?name ?arn
        ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let recentlyFailedRuns =
        field_map json__ "RecentlyFailedRuns"
          ScheduledQueryRunSummaryList.of_json in
      let lastRunSummary =
        field_map json__ "LastRunSummary" ScheduledQueryRunSummary.of_json in
      let errorReportConfiguration =
        field_map json__ "ErrorReportConfiguration"
          ErrorReportConfiguration.of_json in
      let kmsKeyId = field_map json__ "KmsKeyId" StringValue2048.of_json in
      let scheduledQueryExecutionRoleArn =
        field_map json__ "ScheduledQueryExecutionRoleArn"
          AmazonResourceName.of_json in
      let targetConfiguration =
        field_map json__ "TargetConfiguration" TargetConfiguration.of_json in
      let notificationConfiguration =
        field_map json__ "NotificationConfiguration"
          NotificationConfiguration.of_json in
      let scheduleConfiguration =
        field_map json__ "ScheduleConfiguration"
          ScheduleConfiguration.of_json in
      let nextInvocationTime =
        field_map json__ "NextInvocationTime" Time.of_json in
      let previousInvocationTime =
        field_map json__ "PreviousInvocationTime" Time.of_json in
      let state = field_map json__ "State" ScheduledQueryState.of_json in
      let creationTime = field_map json__ "CreationTime" Time.of_json in
      let queryString = field_map json__ "QueryString" QueryString.of_json in
      let name = field_map json__ "Name" ScheduledQueryName.of_json in
      let arn = field_map json__ "Arn" AmazonResourceName.of_json in
      make ?recentlyFailedRuns ?lastRunSummary ?errorReportConfiguration
        ?kmsKeyId ?scheduledQueryExecutionRoleArn ?targetConfiguration
        ?notificationConfiguration ?scheduleConfiguration ?nextInvocationTime
        ?previousInvocationTime ?state ?creationTime ?queryString ?name ?arn
        ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Structure that describes scheduled query."]
module ResourceNotFoundException =
  struct
    type nonrec t =
      {
      message: ErrorMessage.t option ;
      scheduledQueryArn: AmazonResourceName.t option
        [@ocaml.doc "The ARN of the scheduled query."]}
    let make ?message =
      fun ?scheduledQueryArn -> fun () -> { message; scheduledQueryArn }
    let to_value x =
      structure_to_value
        [("Message", (Option.map x.message ~f:ErrorMessage.to_value));
        ("ScheduledQueryArn",
          (Option.map x.scheduledQueryArn ~f:AmazonResourceName.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let scheduledQueryArn =
        (Option.map ~f:AmazonResourceName.of_xml)
          (Xml.child xml_arg0 "ScheduledQueryArn") in
      let message =
        (Option.map ~f:ErrorMessage.of_xml) (Xml.child xml_arg0 "Message") in
      make ?scheduledQueryArn ?message ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let scheduledQueryArn =
        field_map json__ "ScheduledQueryArn" AmazonResourceName.of_json in
      let message = field_map json__ "Message" ErrorMessage.of_json in
      make ?scheduledQueryArn ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "The requested resource could not be found."]
module DescribeScheduledQueryResponse =
  struct
    type nonrec t =
      {
      scheduledQuery: ScheduledQueryDescription.t option
        [@ocaml.doc "The scheduled query."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `InternalServerException of InternalServerException.t 
      | `InvalidEndpointException of InvalidEndpointException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ThrottlingException of ThrottlingException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?scheduledQuery = fun () -> { scheduledQuery }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_json json)
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_xml xml)
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `InternalServerException e ->
          `Assoc
            [("error", (`String "InternalServerException"));
            ("details", (InternalServerException.to_json e))]
      | `InvalidEndpointException e ->
          `Assoc
            [("error", (`String "InvalidEndpointException"));
            ("details", (InvalidEndpointException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ThrottlingException e ->
          `Assoc
            [("error", (`String "ThrottlingException"));
            ("details", (ThrottlingException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("ScheduledQuery",
           (Option.map x.scheduledQuery ~f:ScheduledQueryDescription.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let scheduledQuery =
        (Option.map ~f:ScheduledQueryDescription.of_xml)
          (Xml.child xml_arg0 "ScheduledQuery") in
      make ?scheduledQuery ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let scheduledQuery =
        field_map json__ "ScheduledQuery" ScheduledQueryDescription.of_json in
      make ?scheduledQuery ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Provides detailed information about a scheduled query."]
module ScheduledQueryInsightsMode =
  struct
    type nonrec t =
      | ENABLED_WITH_RATE_CONTROL 
      | DISABLED 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | ENABLED_WITH_RATE_CONTROL -> "ENABLED_WITH_RATE_CONTROL"
      | DISABLED -> "DISABLED"
      | Non_static_id s -> s
    let of_string =
      function
      | "ENABLED_WITH_RATE_CONTROL" -> ENABLED_WITH_RATE_CONTROL
      | "DISABLED" -> DISABLED
      | x -> Non_static_id x
    let to_value x = `Enum (to_string x)
    let to_query v = to_query to_value v
    let to_header x = to_string x
    let of_xml xml_arg0 =
      of_string
        (string_of_xml ~kind:"enumeration ScheduledQueryInsightsMode"
           xml_arg0)
    let of_json j =
      of_string (string_of_json ~kind:"ScheduledQueryInsightsMode" j)
    let to_json = simple_to_json to_value
  end
module ScheduledQueryInsights =
  struct
    type nonrec t =
      {
      mode: ScheduledQueryInsightsMode.t
        [@ocaml.doc
          "Provides the following modes to enable ScheduledQueryInsights: ENABLED_WITH_RATE_CONTROL \226\128\147 Enables ScheduledQueryInsights for the queries being processed. This mode also includes a rate control mechanism, which limits the QueryInsights feature to 1 query per second (QPS). DISABLED \226\128\147 Disables ScheduledQueryInsights."]}
    let context_ = "ScheduledQueryInsights"
    let make ~mode = fun () -> { mode }
    let to_value x =
      structure_to_value
        [("Mode", (Some (ScheduledQueryInsightsMode.to_value x.mode)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let mode =
        ScheduledQueryInsightsMode.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "Mode") in
      make ~mode ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let mode =
        field_map_exn json__ "Mode" ScheduledQueryInsightsMode.of_json in
      make ~mode ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Encapsulates settings for enabling QueryInsights on an ExecuteScheduledQueryRequest."]
module ExecuteScheduledQueryRequest =
  struct
    type nonrec t =
      {
      scheduledQueryArn: AmazonResourceName.t
        [@ocaml.doc "ARN of the scheduled query."];
      invocationTime: Time.t
        [@ocaml.doc
          "The timestamp in UTC. Query will be run as if it was invoked at this timestamp."];
      clientToken: ClientToken.t option [@ocaml.doc "Not used."];
      queryInsights: ScheduledQueryInsights.t option
        [@ocaml.doc
          "Encapsulates settings for enabling QueryInsights. Enabling QueryInsights returns insights and metrics as a part of the Amazon SNS notification for the query that you executed. You can use QueryInsights to tune your query performance and cost."]}
    let context_ = "ExecuteScheduledQueryRequest"
    let make ?clientToken =
      fun ?queryInsights ->
        fun ~scheduledQueryArn ->
          fun ~invocationTime ->
            fun () ->
              { clientToken; queryInsights; scheduledQueryArn; invocationTime
              }
    let to_value x =
      structure_to_value
        [("ScheduledQueryArn",
           (Some (AmazonResourceName.to_value x.scheduledQueryArn)));
        ("InvocationTime", (Some (Time.to_value x.invocationTime)));
        ("ClientToken", (Option.map x.clientToken ~f:ClientToken.to_value));
        ("QueryInsights",
          (Option.map x.queryInsights ~f:ScheduledQueryInsights.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let queryInsights =
        (Option.map ~f:ScheduledQueryInsights.of_xml)
          (Xml.child xml_arg0 "QueryInsights") in
      let clientToken =
        (Option.map ~f:ClientToken.of_xml) (Xml.child xml_arg0 "ClientToken") in
      let invocationTime =
        Time.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "InvocationTime") in
      let scheduledQueryArn =
        AmazonResourceName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "ScheduledQueryArn") in
      make ?queryInsights ?clientToken ~invocationTime ~scheduledQueryArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let queryInsights =
        field_map json__ "QueryInsights" ScheduledQueryInsights.of_json in
      let clientToken = field_map json__ "ClientToken" ClientToken.of_json in
      let invocationTime = field_map_exn json__ "InvocationTime" Time.of_json in
      let scheduledQueryArn =
        field_map_exn json__ "ScheduledQueryArn" AmazonResourceName.of_json in
      make ?queryInsights ?clientToken ~invocationTime ~scheduledQueryArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "You can use this API to run a scheduled query manually. If you enabled QueryInsights, this API also returns insights and metrics related to the query that you executed as part of an Amazon SNS notification. QueryInsights helps with performance tuning of your query. For more information about QueryInsights, see Using query insights to optimize queries in Amazon Timestream."]
module NextScheduledQueriesResultsToken =
  struct
    type nonrec t = string
    let context_ = "NextScheduledQueriesResultsToken"
    let make i = i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"NextScheduledQueriesResultsToken" j
    let to_json = simple_to_json to_value
  end
module MaxScheduledQueriesResults =
  struct
    type nonrec t = int
    let make i =
      let open Result in
        ok_or_failwith
          ((check_int_max i ~max:1000) >>= (fun () -> check_int_min i ~min:1));
        i
    let of_string = Int.of_string
    let to_value x = `Integer x
    let to_query v = to_query to_value v
    let to_header x = Int.to_string x
    let of_xml xml_arg0 =
      Int.of_string
        (string_of_xml ~kind:"an integer for MaxScheduledQueriesResults"
           xml_arg0)
    let of_json j = Int.of_float (float_of_json ~kind:"an integer" j)
    let to_json = simple_to_json to_value
  end
module ListScheduledQueriesRequest =
  struct
    type nonrec t =
      {
      maxResults: MaxScheduledQueriesResults.t option
        [@ocaml.doc
          "The maximum number of items to return in the output. If the total number of items available is more than the value specified, a NextToken is provided in the output. To resume pagination, provide the NextToken value as the argument to the subsequent call to ListScheduledQueriesRequest."];
      nextToken: NextScheduledQueriesResultsToken.t option
        [@ocaml.doc "A pagination token to resume pagination."]}
    let make ?maxResults =
      fun ?nextToken -> fun () -> { maxResults; nextToken }
    let to_value x =
      structure_to_value
        [("MaxResults",
           (Option.map x.maxResults ~f:MaxScheduledQueriesResults.to_value));
        ("NextToken",
          (Option.map x.nextToken
             ~f:NextScheduledQueriesResultsToken.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let nextToken =
        (Option.map ~f:NextScheduledQueriesResultsToken.of_xml)
          (Xml.child xml_arg0 "NextToken") in
      let maxResults =
        (Option.map ~f:MaxScheduledQueriesResults.of_xml)
          (Xml.child xml_arg0 "MaxResults") in
      make ?nextToken ?maxResults ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let nextToken =
        field_map json__ "NextToken" NextScheduledQueriesResultsToken.of_json in
      let maxResults =
        field_map json__ "MaxResults" MaxScheduledQueriesResults.of_json in
      make ?nextToken ?maxResults ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Gets a list of all scheduled queries in the caller's Amazon account and Region. ListScheduledQueries is eventually consistent."]
module TimestreamDestination =
  struct
    type nonrec t =
      {
      databaseName: ResourceName.t option
        [@ocaml.doc "Timestream database name."];
      tableName: ResourceName.t option [@ocaml.doc "Timestream table name."]}
    let make ?databaseName =
      fun ?tableName -> fun () -> { databaseName; tableName }
    let to_value x =
      structure_to_value
        [("DatabaseName",
           (Option.map x.databaseName ~f:ResourceName.to_value));
        ("TableName", (Option.map x.tableName ~f:ResourceName.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let tableName =
        (Option.map ~f:ResourceName.of_xml) (Xml.child xml_arg0 "TableName") in
      let databaseName =
        (Option.map ~f:ResourceName.of_xml)
          (Xml.child xml_arg0 "DatabaseName") in
      make ?tableName ?databaseName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let tableName = field_map json__ "TableName" ResourceName.of_json in
      let databaseName = field_map json__ "DatabaseName" ResourceName.of_json in
      make ?tableName ?databaseName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Destination for scheduled query."]
module TargetDestination =
  struct
    type nonrec t =
      {
      timestreamDestination: TimestreamDestination.t option
        [@ocaml.doc
          "Query result destination details for Timestream data source."]}
    let make ?timestreamDestination = fun () -> { timestreamDestination }
    let to_value x =
      structure_to_value
        [("TimestreamDestination",
           (Option.map x.timestreamDestination
              ~f:TimestreamDestination.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let timestreamDestination =
        (Option.map ~f:TimestreamDestination.of_xml)
          (Xml.child xml_arg0 "TimestreamDestination") in
      make ?timestreamDestination ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let timestreamDestination =
        field_map json__ "TimestreamDestination"
          TimestreamDestination.of_json in
      make ?timestreamDestination ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Destination details to write data for a target data source. Current supported data source is Timestream."]
module ScheduledQuery =
  struct
    type nonrec t =
      {
      arn: AmazonResourceName.t option
        [@ocaml.doc "The Amazon Resource Name."];
      name: ScheduledQueryName.t option
        [@ocaml.doc "The name of the scheduled query."];
      creationTime: Time.t option
        [@ocaml.doc "The creation time of the scheduled query."];
      state: ScheduledQueryState.t option
        [@ocaml.doc "State of scheduled query."];
      previousInvocationTime: Time.t option
        [@ocaml.doc "The last time the scheduled query was run."];
      nextInvocationTime: Time.t option
        [@ocaml.doc "The next time the scheduled query is to be run."];
      errorReportConfiguration: ErrorReportConfiguration.t option
        [@ocaml.doc "Configuration for scheduled query error reporting."];
      targetDestination: TargetDestination.t option
        [@ocaml.doc
          "Target data source where final scheduled query result will be written."];
      lastRunStatus: ScheduledQueryRunStatus.t option
        [@ocaml.doc "Status of the last scheduled query run."]}
    let make ?arn =
      fun ?name ->
        fun ?creationTime ->
          fun ?state ->
            fun ?previousInvocationTime ->
              fun ?nextInvocationTime ->
                fun ?errorReportConfiguration ->
                  fun ?targetDestination ->
                    fun ?lastRunStatus ->
                      fun () ->
                        {
                          arn;
                          name;
                          creationTime;
                          state;
                          previousInvocationTime;
                          nextInvocationTime;
                          errorReportConfiguration;
                          targetDestination;
                          lastRunStatus
                        }
    let to_value x =
      structure_to_value
        [("Arn", (Option.map x.arn ~f:AmazonResourceName.to_value));
        ("Name", (Option.map x.name ~f:ScheduledQueryName.to_value));
        ("CreationTime", (Option.map x.creationTime ~f:Time.to_value));
        ("State", (Option.map x.state ~f:ScheduledQueryState.to_value));
        ("PreviousInvocationTime",
          (Option.map x.previousInvocationTime ~f:Time.to_value));
        ("NextInvocationTime",
          (Option.map x.nextInvocationTime ~f:Time.to_value));
        ("ErrorReportConfiguration",
          (Option.map x.errorReportConfiguration
             ~f:ErrorReportConfiguration.to_value));
        ("TargetDestination",
          (Option.map x.targetDestination ~f:TargetDestination.to_value));
        ("LastRunStatus",
          (Option.map x.lastRunStatus ~f:ScheduledQueryRunStatus.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let lastRunStatus =
        (Option.map ~f:ScheduledQueryRunStatus.of_xml)
          (Xml.child xml_arg0 "LastRunStatus") in
      let targetDestination =
        (Option.map ~f:TargetDestination.of_xml)
          (Xml.child xml_arg0 "TargetDestination") in
      let errorReportConfiguration =
        (Option.map ~f:ErrorReportConfiguration.of_xml)
          (Xml.child xml_arg0 "ErrorReportConfiguration") in
      let nextInvocationTime =
        (Option.map ~f:Time.of_xml) (Xml.child xml_arg0 "NextInvocationTime") in
      let previousInvocationTime =
        (Option.map ~f:Time.of_xml)
          (Xml.child xml_arg0 "PreviousInvocationTime") in
      let state =
        (Option.map ~f:ScheduledQueryState.of_xml)
          (Xml.child xml_arg0 "State") in
      let creationTime =
        (Option.map ~f:Time.of_xml) (Xml.child xml_arg0 "CreationTime") in
      let name =
        (Option.map ~f:ScheduledQueryName.of_xml) (Xml.child xml_arg0 "Name") in
      let arn =
        (Option.map ~f:AmazonResourceName.of_xml) (Xml.child xml_arg0 "Arn") in
      make ?lastRunStatus ?targetDestination ?errorReportConfiguration
        ?nextInvocationTime ?previousInvocationTime ?state ?creationTime
        ?name ?arn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let lastRunStatus =
        field_map json__ "LastRunStatus" ScheduledQueryRunStatus.of_json in
      let targetDestination =
        field_map json__ "TargetDestination" TargetDestination.of_json in
      let errorReportConfiguration =
        field_map json__ "ErrorReportConfiguration"
          ErrorReportConfiguration.of_json in
      let nextInvocationTime =
        field_map json__ "NextInvocationTime" Time.of_json in
      let previousInvocationTime =
        field_map json__ "PreviousInvocationTime" Time.of_json in
      let state = field_map json__ "State" ScheduledQueryState.of_json in
      let creationTime = field_map json__ "CreationTime" Time.of_json in
      let name = field_map json__ "Name" ScheduledQueryName.of_json in
      let arn = field_map json__ "Arn" AmazonResourceName.of_json in
      make ?lastRunStatus ?targetDestination ?errorReportConfiguration
        ?nextInvocationTime ?previousInvocationTime ?state ?creationTime
        ?name ?arn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Scheduled Query"]
module ScheduledQueryList =
  struct
    type nonrec t = ScheduledQuery.t list
    let make i = i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:ScheduledQuery.to_value)) |> (fun x -> `List x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for List_shape objects" ()
    let of_xml x =
      make
        (List.map
           ((Xml.all_children x) |>
              (List.filter
                 ~f:(function
                     | `Data s ->
                         (match Stdlib.String.trim s with
                          | "" -> false
                          | _ -> true)
                     | _ -> true))) ~f:ScheduledQuery.of_xml)
    let of_json j =
      list_of_json ~kind:"ScheduledQueryList" ~of_json:ScheduledQuery.of_json
        j
    let to_json v = composed_to_json to_value v
  end
module ListScheduledQueriesResponse =
  struct
    type nonrec t =
      {
      scheduledQueries: ScheduledQueryList.t option
        [@ocaml.doc "A list of scheduled queries."];
      nextToken: NextScheduledQueriesResultsToken.t option
        [@ocaml.doc
          "A token to specify where to start paginating. This is the NextToken from a previously truncated response."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `InternalServerException of InternalServerException.t 
      | `InvalidEndpointException of InvalidEndpointException.t 
      | `ThrottlingException of ThrottlingException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?scheduledQueries =
      fun ?nextToken -> fun () -> { scheduledQueries; nextToken }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_json json)
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_json json)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_xml xml)
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_xml xml)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `InternalServerException e ->
          `Assoc
            [("error", (`String "InternalServerException"));
            ("details", (InternalServerException.to_json e))]
      | `InvalidEndpointException e ->
          `Assoc
            [("error", (`String "InvalidEndpointException"));
            ("details", (InvalidEndpointException.to_json e))]
      | `ThrottlingException e ->
          `Assoc
            [("error", (`String "ThrottlingException"));
            ("details", (ThrottlingException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("ScheduledQueries",
           (Option.map x.scheduledQueries ~f:ScheduledQueryList.to_value));
        ("NextToken",
          (Option.map x.nextToken
             ~f:NextScheduledQueriesResultsToken.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let nextToken =
        (Option.map ~f:NextScheduledQueriesResultsToken.of_xml)
          (Xml.child xml_arg0 "NextToken") in
      let scheduledQueries =
        (Option.map ~f:ScheduledQueryList.of_xml)
          (Xml.child xml_arg0 "ScheduledQueries") in
      make ?nextToken ?scheduledQueries ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let nextToken =
        field_map json__ "NextToken" NextScheduledQueriesResultsToken.of_json in
      let scheduledQueries =
        field_map json__ "ScheduledQueries" ScheduledQueryList.of_json in
      make ?nextToken ?scheduledQueries ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Gets a list of all scheduled queries in the caller's Amazon account and Region. ListScheduledQueries is eventually consistent."]
module NextTagsForResourceResultsToken =
  struct
    type nonrec t = string
    let context_ = "NextTagsForResourceResultsToken"
    let make i = i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"NextTagsForResourceResultsToken" j
    let to_json = simple_to_json to_value
  end
module MaxTagsForResourceResult =
  struct
    type nonrec t = int
    let make i =
      let open Result in
        ok_or_failwith
          ((check_int_max i ~max:200) >>= (fun () -> check_int_min i ~min:1));
        i
    let of_string = Int.of_string
    let to_value x = `Integer x
    let to_query v = to_query to_value v
    let to_header x = Int.to_string x
    let of_xml xml_arg0 =
      Int.of_string
        (string_of_xml ~kind:"an integer for MaxTagsForResourceResult"
           xml_arg0)
    let of_json j = Int.of_float (float_of_json ~kind:"an integer" j)
    let to_json = simple_to_json to_value
  end
module ListTagsForResourceRequest =
  struct
    type nonrec t =
      {
      resourceARN: AmazonResourceName.t
        [@ocaml.doc
          "The Timestream resource with tags to be listed. This value is an Amazon Resource Name (ARN)."];
      maxResults: MaxTagsForResourceResult.t option
        [@ocaml.doc "The maximum number of tags to return."];
      nextToken: NextTagsForResourceResultsToken.t option
        [@ocaml.doc "A pagination token to resume pagination."]}
    let context_ = "ListTagsForResourceRequest"
    let make ?maxResults =
      fun ?nextToken ->
        fun ~resourceARN -> fun () -> { maxResults; nextToken; resourceARN }
    let to_value x =
      structure_to_value
        [("ResourceARN", (Some (AmazonResourceName.to_value x.resourceARN)));
        ("MaxResults",
          (Option.map x.maxResults ~f:MaxTagsForResourceResult.to_value));
        ("NextToken",
          (Option.map x.nextToken ~f:NextTagsForResourceResultsToken.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let nextToken =
        (Option.map ~f:NextTagsForResourceResultsToken.of_xml)
          (Xml.child xml_arg0 "NextToken") in
      let maxResults =
        (Option.map ~f:MaxTagsForResourceResult.of_xml)
          (Xml.child xml_arg0 "MaxResults") in
      let resourceARN =
        AmazonResourceName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "ResourceARN") in
      make ?nextToken ?maxResults ~resourceARN ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let nextToken =
        field_map json__ "NextToken" NextTagsForResourceResultsToken.of_json in
      let maxResults =
        field_map json__ "MaxResults" MaxTagsForResourceResult.of_json in
      let resourceARN =
        field_map_exn json__ "ResourceARN" AmazonResourceName.of_json in
      make ?nextToken ?maxResults ~resourceARN ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "List all tags on a Timestream query resource."]
module ListTagsForResourceResponse =
  struct
    type nonrec t =
      {
      tags: TagList.t option
        [@ocaml.doc
          "The tags currently associated with the Timestream resource."];
      nextToken: NextTagsForResourceResultsToken.t option
        [@ocaml.doc
          "A pagination token to resume pagination with a subsequent call to ListTagsForResourceResponse."]}
    type nonrec error =
      [ `InvalidEndpointException of InvalidEndpointException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ThrottlingException of ThrottlingException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?tags = fun ?nextToken -> fun () -> { tags; nextToken }
    let error_of_json name json =
      match name with
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `InvalidEndpointException e ->
          `Assoc
            [("error", (`String "InvalidEndpointException"));
            ("details", (InvalidEndpointException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ThrottlingException e ->
          `Assoc
            [("error", (`String "ThrottlingException"));
            ("details", (ThrottlingException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("Tags", (Option.map x.tags ~f:TagList.to_value));
        ("NextToken",
          (Option.map x.nextToken ~f:NextTagsForResourceResultsToken.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let nextToken =
        (Option.map ~f:NextTagsForResourceResultsToken.of_xml)
          (Xml.child xml_arg0 "NextToken") in
      let tags = (Option.map ~f:TagList.of_xml) (Xml.child xml_arg0 "Tags") in
      make ?nextToken ?tags ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let nextToken =
        field_map json__ "NextToken" NextTagsForResourceResultsToken.of_json in
      let tags = field_map json__ "Tags" TagList.of_json in
      make ?nextToken ?tags ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "List all tags on a Timestream query resource."]
module MaxQueryResults =
  struct
    type nonrec t = int
    let make i =
      let open Result in
        ok_or_failwith
          ((check_int_max i ~max:1000) >>= (fun () -> check_int_min i ~min:1));
        i
    let of_string = Int.of_string
    let to_value x = `Integer x
    let to_query v = to_query to_value v
    let to_header x = Int.to_string x
    let of_xml xml_arg0 =
      Int.of_string
        (string_of_xml ~kind:"an integer for MaxQueryResults" xml_arg0)
    let of_json j = Int.of_float (float_of_json ~kind:"an integer" j)
    let to_json = simple_to_json to_value
  end
module PaginationToken =
  struct
    type nonrec t = string
    let context_ = "PaginationToken"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_max i ~max:2048) >>=
             (fun () -> check_string_min i ~min:1));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"PaginationToken" j
    let to_json = simple_to_json to_value
  end
module ParameterMapping =
  struct
    type nonrec t =
      {
      name: String_.t option [@ocaml.doc "Parameter name."];
      type_: Type.t option }
    let make ?name = fun ?type_ -> fun () -> { name; type_ }
    let to_value x =
      structure_to_value
        [("Name", (Option.map x.name ~f:String_.to_value));
        ("Type", (Option.map x.type_ ~f:Type.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let type_ = (Option.map ~f:Type.of_xml) (Xml.child xml_arg0 "Type") in
      let name = (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "Name") in
      make ?type_ ?name ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let type_ = field_map json__ "Type" Type.of_json in
      let name = field_map json__ "Name" String_.of_json in
      make ?type_ ?name ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Mapping for named parameters."]
module ParameterMappingList =
  struct
    type nonrec t = ParameterMapping.t list
    let make i = i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:ParameterMapping.to_value)) |> (fun x -> `List x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for List_shape objects" ()
    let of_xml x =
      make
        (List.map
           ((Xml.all_children x) |>
              (List.filter
                 ~f:(function
                     | `Data s ->
                         (match Stdlib.String.trim s with
                          | "" -> false
                          | _ -> true)
                     | _ -> true))) ~f:ParameterMapping.of_xml)
    let of_json j =
      list_of_json ~kind:"ParameterMappingList"
        ~of_json:ParameterMapping.of_json j
    let to_json v = composed_to_json to_value v
  end
module PrepareQueryRequest =
  struct
    type nonrec t =
      {
      queryString: QueryString.t
        [@ocaml.doc
          "The Timestream query string that you want to use as a prepared statement. Parameter names can be specified in the query string \\@ character followed by an identifier."];
      validateOnly: NullableBoolean.t option
        [@ocaml.doc
          "By setting this value to true, Timestream will only validate that the query string is a valid Timestream query, and not store the prepared query for later use."]}
    let context_ = "PrepareQueryRequest"
    let make ?validateOnly =
      fun ~queryString -> fun () -> { validateOnly; queryString }
    let to_value x =
      structure_to_value
        [("QueryString", (Some (QueryString.to_value x.queryString)));
        ("ValidateOnly",
          (Option.map x.validateOnly ~f:NullableBoolean.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let validateOnly =
        (Option.map ~f:NullableBoolean.of_xml)
          (Xml.child xml_arg0 "ValidateOnly") in
      let queryString =
        QueryString.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "QueryString") in
      make ?validateOnly ~queryString ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let validateOnly =
        field_map json__ "ValidateOnly" NullableBoolean.of_json in
      let queryString =
        field_map_exn json__ "QueryString" QueryString.of_json in
      make ?validateOnly ~queryString ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "A synchronous operation that allows you to submit a query with parameters to be stored by Timestream for later running. Timestream only supports using this operation with ValidateOnly set to true."]
module SelectColumn =
  struct
    type nonrec t =
      {
      name: String_.t option [@ocaml.doc "Name of the column."];
      type_: Type.t option ;
      databaseName: ResourceName.t option
        [@ocaml.doc "Database that has this column."];
      tableName: ResourceName.t option
        [@ocaml.doc "Table within the database that has this column."];
      aliased: NullableBoolean.t option
        [@ocaml.doc
          "True, if the column name was aliased by the query. False otherwise."]}
    let make ?name =
      fun ?type_ ->
        fun ?databaseName ->
          fun ?tableName ->
            fun ?aliased ->
              fun () -> { name; type_; databaseName; tableName; aliased }
    let to_value x =
      structure_to_value
        [("Name", (Option.map x.name ~f:String_.to_value));
        ("Type", (Option.map x.type_ ~f:Type.to_value));
        ("DatabaseName",
          (Option.map x.databaseName ~f:ResourceName.to_value));
        ("TableName", (Option.map x.tableName ~f:ResourceName.to_value));
        ("Aliased", (Option.map x.aliased ~f:NullableBoolean.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let aliased =
        (Option.map ~f:NullableBoolean.of_xml) (Xml.child xml_arg0 "Aliased") in
      let tableName =
        (Option.map ~f:ResourceName.of_xml) (Xml.child xml_arg0 "TableName") in
      let databaseName =
        (Option.map ~f:ResourceName.of_xml)
          (Xml.child xml_arg0 "DatabaseName") in
      let type_ = (Option.map ~f:Type.of_xml) (Xml.child xml_arg0 "Type") in
      let name = (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "Name") in
      make ?aliased ?tableName ?databaseName ?type_ ?name ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let aliased = field_map json__ "Aliased" NullableBoolean.of_json in
      let tableName = field_map json__ "TableName" ResourceName.of_json in
      let databaseName = field_map json__ "DatabaseName" ResourceName.of_json in
      let type_ = field_map json__ "Type" Type.of_json in
      let name = field_map json__ "Name" String_.of_json in
      make ?aliased ?tableName ?databaseName ?type_ ?name ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Details of the column that is returned by the query."]
module SelectColumnList =
  struct
    type nonrec t = SelectColumn.t list
    let make i = i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:SelectColumn.to_value)) |> (fun x -> `List x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for List_shape objects" ()
    let of_xml x =
      make
        (List.map
           ((Xml.all_children x) |>
              (List.filter
                 ~f:(function
                     | `Data s ->
                         (match Stdlib.String.trim s with
                          | "" -> false
                          | _ -> true)
                     | _ -> true))) ~f:SelectColumn.of_xml)
    let of_json j =
      list_of_json ~kind:"SelectColumnList" ~of_json:SelectColumn.of_json j
    let to_json v = composed_to_json to_value v
  end
module PrepareQueryResponse =
  struct
    type nonrec t =
      {
      queryString: QueryString.t option
        [@ocaml.doc "The query string that you want prepare."];
      columns: SelectColumnList.t option
        [@ocaml.doc
          "A list of SELECT clause columns of the submitted query string."];
      parameters: ParameterMappingList.t option
        [@ocaml.doc
          "A list of parameters used in the submitted query string."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `InternalServerException of InternalServerException.t 
      | `InvalidEndpointException of InvalidEndpointException.t 
      | `ThrottlingException of ThrottlingException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?queryString =
      fun ?columns ->
        fun ?parameters -> fun () -> { queryString; columns; parameters }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_json json)
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_json json)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_xml xml)
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_xml xml)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `InternalServerException e ->
          `Assoc
            [("error", (`String "InternalServerException"));
            ("details", (InternalServerException.to_json e))]
      | `InvalidEndpointException e ->
          `Assoc
            [("error", (`String "InvalidEndpointException"));
            ("details", (InvalidEndpointException.to_json e))]
      | `ThrottlingException e ->
          `Assoc
            [("error", (`String "ThrottlingException"));
            ("details", (ThrottlingException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("QueryString", (Option.map x.queryString ~f:QueryString.to_value));
        ("Columns", (Option.map x.columns ~f:SelectColumnList.to_value));
        ("Parameters",
          (Option.map x.parameters ~f:ParameterMappingList.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let parameters =
        (Option.map ~f:ParameterMappingList.of_xml)
          (Xml.child xml_arg0 "Parameters") in
      let columns =
        (Option.map ~f:SelectColumnList.of_xml)
          (Xml.child xml_arg0 "Columns") in
      let queryString =
        (Option.map ~f:QueryString.of_xml) (Xml.child xml_arg0 "QueryString") in
      make ?parameters ?columns ?queryString ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let parameters =
        field_map json__ "Parameters" ParameterMappingList.of_json in
      let columns = field_map json__ "Columns" SelectColumnList.of_json in
      let queryString = field_map json__ "QueryString" QueryString.of_json in
      make ?parameters ?columns ?queryString ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "A synchronous operation that allows you to submit a query with parameters to be stored by Timestream for later running. Timestream only supports using this operation with ValidateOnly set to true."]
module ProvisionedCapacityRequest =
  struct
    type nonrec t =
      {
      targetQueryTCU: QueryTCU.t
        [@ocaml.doc
          "The target compute capacity for querying data, specified in Timestream Compute Units (TCUs)."];
      notificationConfiguration:
        AccountSettingsNotificationConfiguration.t option
        [@ocaml.doc
          "Configuration settings for notifications related to the provisioned capacity update."]}
    let context_ = "ProvisionedCapacityRequest"
    let make ?notificationConfiguration =
      fun ~targetQueryTCU ->
        fun () -> { notificationConfiguration; targetQueryTCU }
    let to_value x =
      structure_to_value
        [("TargetQueryTCU", (Some (QueryTCU.to_value x.targetQueryTCU)));
        ("NotificationConfiguration",
          (Option.map x.notificationConfiguration
             ~f:AccountSettingsNotificationConfiguration.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let notificationConfiguration =
        (Option.map ~f:AccountSettingsNotificationConfiguration.of_xml)
          (Xml.child xml_arg0 "NotificationConfiguration") in
      let targetQueryTCU =
        QueryTCU.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "TargetQueryTCU") in
      make ?notificationConfiguration ~targetQueryTCU ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let notificationConfiguration =
        field_map json__ "NotificationConfiguration"
          AccountSettingsNotificationConfiguration.of_json in
      let targetQueryTCU =
        field_map_exn json__ "TargetQueryTCU" QueryTCU.of_json in
      make ?notificationConfiguration ~targetQueryTCU ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "A request to update the provisioned capacity settings for querying data."]
module QueryComputeRequest =
  struct
    type nonrec t =
      {
      computeMode: ComputeMode.t option
        [@ocaml.doc
          "The mode in which Timestream Compute Units (TCUs) are allocated and utilized within an account. Note that in the Asia Pacific (Mumbai) region, the API operation only recognizes the value PROVISIONED."];
      provisionedCapacity: ProvisionedCapacityRequest.t option
        [@ocaml.doc
          "Configuration object that contains settings for provisioned Timestream Compute Units (TCUs) in your account."]}
    let make ?computeMode =
      fun ?provisionedCapacity ->
        fun () -> { computeMode; provisionedCapacity }
    let to_value x =
      structure_to_value
        [("ComputeMode", (Option.map x.computeMode ~f:ComputeMode.to_value));
        ("ProvisionedCapacity",
          (Option.map x.provisionedCapacity
             ~f:ProvisionedCapacityRequest.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let provisionedCapacity =
        (Option.map ~f:ProvisionedCapacityRequest.of_xml)
          (Xml.child xml_arg0 "ProvisionedCapacity") in
      let computeMode =
        (Option.map ~f:ComputeMode.of_xml) (Xml.child xml_arg0 "ComputeMode") in
      make ?provisionedCapacity ?computeMode ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let provisionedCapacity =
        field_map json__ "ProvisionedCapacity"
          ProvisionedCapacityRequest.of_json in
      let computeMode = field_map json__ "ComputeMode" ComputeMode.of_json in
      make ?provisionedCapacity ?computeMode ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "A request to retrieve or update the compute capacity settings for querying data."]
module QueryExecutionException =
  struct
    type nonrec t = {
      message: ErrorMessage.t option }
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("Message", (Option.map x.message ~f:ErrorMessage.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:ErrorMessage.of_xml) (Xml.child xml_arg0 "Message") in
      make ?message ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let message = field_map json__ "Message" ErrorMessage.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Timestream was unable to run the query successfully."]
module QueryInsightsMode =
  struct
    type nonrec t =
      | ENABLED_WITH_RATE_CONTROL 
      | DISABLED 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | ENABLED_WITH_RATE_CONTROL -> "ENABLED_WITH_RATE_CONTROL"
      | DISABLED -> "DISABLED"
      | Non_static_id s -> s
    let of_string =
      function
      | "ENABLED_WITH_RATE_CONTROL" -> ENABLED_WITH_RATE_CONTROL
      | "DISABLED" -> DISABLED
      | x -> Non_static_id x
    let to_value x = `Enum (to_string x)
    let to_query v = to_query to_value v
    let to_header x = to_string x
    let of_xml xml_arg0 =
      of_string
        (string_of_xml ~kind:"enumeration QueryInsightsMode" xml_arg0)
    let of_json j = of_string (string_of_json ~kind:"QueryInsightsMode" j)
    let to_json = simple_to_json to_value
  end
module QueryInsights =
  struct
    type nonrec t =
      {
      mode: QueryInsightsMode.t
        [@ocaml.doc
          "Provides the following modes to enable QueryInsights: ENABLED_WITH_RATE_CONTROL \226\128\147 Enables QueryInsights for the queries being processed. This mode also includes a rate control mechanism, which limits the QueryInsights feature to 1 query per second (QPS). DISABLED \226\128\147 Disables QueryInsights."]}
    let context_ = "QueryInsights"
    let make ~mode = fun () -> { mode }
    let to_value x =
      structure_to_value
        [("Mode", (Some (QueryInsightsMode.to_value x.mode)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let mode =
        QueryInsightsMode.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "Mode") in
      make ~mode ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let mode = field_map_exn json__ "Mode" QueryInsightsMode.of_json in
      make ~mode ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "QueryInsights is a performance tuning feature that helps you optimize your queries, reducing costs and improving performance. With QueryInsights, you can assess the pruning efficiency of your queries and identify areas for improvement to enhance query performance. With QueryInsights, you can also analyze the effectiveness of your queries in terms of temporal and spatial pruning, and identify opportunities to improve performance. Specifically, you can evaluate how well your queries use time-based and partition key-based indexing strategies to optimize data retrieval. To optimize query performance, it's essential that you fine-tune both the temporal and spatial parameters that govern query execution. The key metrics provided by QueryInsights are QuerySpatialCoverage and QueryTemporalRange. QuerySpatialCoverage indicates how much of the spatial axis the query scans, with lower values being more efficient. QueryTemporalRange shows the time range scanned, with narrower ranges being more performant. Benefits of QueryInsights The following are the key benefits of using QueryInsights: Identifying inefficient queries \226\128\147 QueryInsights provides information on the time-based and attribute-based pruning of the tables accessed by the query. This information helps you identify the tables that are sub-optimally accessed. Optimizing your data model and partitioning \226\128\147 You can use the QueryInsights information to access and fine-tune your data model and partitioning strategy. Tuning queries \226\128\147 QueryInsights highlights opportunities to use indexes more effectively. The maximum number of Query API requests you're allowed to make with QueryInsights enabled is 1 query per second (QPS). If you exceed this query rate, it might result in throttling."]
module QueryInsightsResponse =
  struct
    type nonrec t =
      {
      querySpatialCoverage: QuerySpatialCoverage.t option
        [@ocaml.doc
          "Provides insights into the spatial coverage of the query, including the table with sub-optimal (max) spatial pruning. This information can help you identify areas for improvement in your partitioning strategy to enhance spatial pruning."];
      queryTemporalRange: QueryTemporalRange.t option
        [@ocaml.doc
          "Provides insights into the temporal range of the query, including the table with the largest (max) time range. Following are some of the potential options for optimizing time-based pruning: Add missing time-predicates. Remove functions around the time predicates. Add time predicates to all the sub-queries."];
      queryTableCount: Long.t option
        [@ocaml.doc "Indicates the number of tables in the query."];
      outputRows: Long.t option
        [@ocaml.doc
          "Indicates the total number of rows returned as part of the query result set. You can use this data to validate if the number of rows in the result set have changed as part of the query tuning exercise."];
      outputBytes: Long.t option
        [@ocaml.doc
          "Indicates the size of query result set in bytes. You can use this data to validate if the result set has changed as part of the query tuning exercise."];
      unloadPartitionCount: Long.t option
        [@ocaml.doc
          "Indicates the partitions created by the Unload operation."];
      unloadWrittenRows: Long.t option
        [@ocaml.doc "Indicates the rows written by the Unload query."];
      unloadWrittenBytes: Long.t option
        [@ocaml.doc
          "Indicates the size, in bytes, written by the Unload operation."]}
    let make ?querySpatialCoverage =
      fun ?queryTemporalRange ->
        fun ?queryTableCount ->
          fun ?outputRows ->
            fun ?outputBytes ->
              fun ?unloadPartitionCount ->
                fun ?unloadWrittenRows ->
                  fun ?unloadWrittenBytes ->
                    fun () ->
                      {
                        querySpatialCoverage;
                        queryTemporalRange;
                        queryTableCount;
                        outputRows;
                        outputBytes;
                        unloadPartitionCount;
                        unloadWrittenRows;
                        unloadWrittenBytes
                      }
    let to_value x =
      structure_to_value
        [("QuerySpatialCoverage",
           (Option.map x.querySpatialCoverage
              ~f:QuerySpatialCoverage.to_value));
        ("QueryTemporalRange",
          (Option.map x.queryTemporalRange ~f:QueryTemporalRange.to_value));
        ("QueryTableCount", (Option.map x.queryTableCount ~f:Long.to_value));
        ("OutputRows", (Option.map x.outputRows ~f:Long.to_value));
        ("OutputBytes", (Option.map x.outputBytes ~f:Long.to_value));
        ("UnloadPartitionCount",
          (Option.map x.unloadPartitionCount ~f:Long.to_value));
        ("UnloadWrittenRows",
          (Option.map x.unloadWrittenRows ~f:Long.to_value));
        ("UnloadWrittenBytes",
          (Option.map x.unloadWrittenBytes ~f:Long.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let unloadWrittenBytes =
        (Option.map ~f:Long.of_xml) (Xml.child xml_arg0 "UnloadWrittenBytes") in
      let unloadWrittenRows =
        (Option.map ~f:Long.of_xml) (Xml.child xml_arg0 "UnloadWrittenRows") in
      let unloadPartitionCount =
        (Option.map ~f:Long.of_xml)
          (Xml.child xml_arg0 "UnloadPartitionCount") in
      let outputBytes =
        (Option.map ~f:Long.of_xml) (Xml.child xml_arg0 "OutputBytes") in
      let outputRows =
        (Option.map ~f:Long.of_xml) (Xml.child xml_arg0 "OutputRows") in
      let queryTableCount =
        (Option.map ~f:Long.of_xml) (Xml.child xml_arg0 "QueryTableCount") in
      let queryTemporalRange =
        (Option.map ~f:QueryTemporalRange.of_xml)
          (Xml.child xml_arg0 "QueryTemporalRange") in
      let querySpatialCoverage =
        (Option.map ~f:QuerySpatialCoverage.of_xml)
          (Xml.child xml_arg0 "QuerySpatialCoverage") in
      make ?unloadWrittenBytes ?unloadWrittenRows ?unloadPartitionCount
        ?outputBytes ?outputRows ?queryTableCount ?queryTemporalRange
        ?querySpatialCoverage ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let unloadWrittenBytes =
        field_map json__ "UnloadWrittenBytes" Long.of_json in
      let unloadWrittenRows =
        field_map json__ "UnloadWrittenRows" Long.of_json in
      let unloadPartitionCount =
        field_map json__ "UnloadPartitionCount" Long.of_json in
      let outputBytes = field_map json__ "OutputBytes" Long.of_json in
      let outputRows = field_map json__ "OutputRows" Long.of_json in
      let queryTableCount = field_map json__ "QueryTableCount" Long.of_json in
      let queryTemporalRange =
        field_map json__ "QueryTemporalRange" QueryTemporalRange.of_json in
      let querySpatialCoverage =
        field_map json__ "QuerySpatialCoverage" QuerySpatialCoverage.of_json in
      make ?unloadWrittenBytes ?unloadWrittenRows ?unloadPartitionCount
        ?outputBytes ?outputRows ?queryTableCount ?queryTemporalRange
        ?querySpatialCoverage ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Provides various insights and metrics related to the query that you executed."]
module QueryRequest =
  struct
    type nonrec t =
      {
      queryString: QueryString.t
        [@ocaml.doc "The query to be run by Timestream."];
      clientToken: ClientRequestToken.t option
        [@ocaml.doc
          "Unique, case-sensitive string of up to 64 ASCII characters specified when a Query request is made. Providing a ClientToken makes the call to Query idempotent. This means that running the same query repeatedly will produce the same result. In other words, making multiple identical Query requests has the same effect as making a single request. When using ClientToken in a query, note the following: If the Query API is instantiated without a ClientToken, the Query SDK generates a ClientToken on your behalf. If the Query invocation only contains the ClientToken but does not include a NextToken, that invocation of Query is assumed to be a new query run. If the invocation contains NextToken, that particular invocation is assumed to be a subsequent invocation of a prior call to the Query API, and a result set is returned. After 4 hours, any request with the same ClientToken is treated as a new request."];
      nextToken: PaginationToken.t option
        [@ocaml.doc
          "A pagination token used to return a set of results. When the Query API is invoked using NextToken, that particular invocation is assumed to be a subsequent invocation of a prior call to Query, and a result set is returned. However, if the Query invocation only contains the ClientToken, that invocation of Query is assumed to be a new query run. Note the following when using NextToken in a query: A pagination token can be used for up to five Query invocations, OR for a duration of up to 1 hour \226\128\147 whichever comes first. Using the same NextToken will return the same set of records. To keep paginating through the result set, you must to use the most recent nextToken. Suppose a Query invocation returns two NextToken values, TokenA and TokenB. If TokenB is used in a subsequent Query invocation, then TokenA is invalidated and cannot be reused. To request a previous result set from a query after pagination has begun, you must re-invoke the Query API. The latest NextToken should be used to paginate until null is returned, at which point a new NextToken should be used. If the IAM principal of the query initiator and the result reader are not the same and/or the query initiator and the result reader do not have the same query string in the query requests, the query will fail with an Invalid pagination token error."];
      maxRows: MaxQueryResults.t option
        [@ocaml.doc
          "The total number of rows to be returned in the Query output. The initial run of Query with a MaxRows value specified will return the result set of the query in two cases: The size of the result is less than 1MB. The number of rows in the result set is less than the value of maxRows. Otherwise, the initial invocation of Query only returns a NextToken, which can then be used in subsequent calls to fetch the result set. To resume pagination, provide the NextToken value in the subsequent command. If the row size is large (e.g. a row has many columns), Timestream may return fewer rows to keep the response size from exceeding the 1 MB limit. If MaxRows is not provided, Timestream will send the necessary number of rows to meet the 1 MB limit."];
      queryInsights: QueryInsights.t option
        [@ocaml.doc
          "Encapsulates settings for enabling QueryInsights. Enabling QueryInsights returns insights and metrics in addition to query results for the query that you executed. You can use QueryInsights to tune your query performance."]}
    let context_ = "QueryRequest"
    let make ?clientToken =
      fun ?nextToken ->
        fun ?maxRows ->
          fun ?queryInsights ->
            fun ~queryString ->
              fun () ->
                { clientToken; nextToken; maxRows; queryInsights; queryString
                }
    let to_value x =
      structure_to_value
        [("QueryString", (Some (QueryString.to_value x.queryString)));
        ("ClientToken",
          (Option.map x.clientToken ~f:ClientRequestToken.to_value));
        ("NextToken", (Option.map x.nextToken ~f:PaginationToken.to_value));
        ("MaxRows", (Option.map x.maxRows ~f:MaxQueryResults.to_value));
        ("QueryInsights",
          (Option.map x.queryInsights ~f:QueryInsights.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let queryInsights =
        (Option.map ~f:QueryInsights.of_xml)
          (Xml.child xml_arg0 "QueryInsights") in
      let maxRows =
        (Option.map ~f:MaxQueryResults.of_xml) (Xml.child xml_arg0 "MaxRows") in
      let nextToken =
        (Option.map ~f:PaginationToken.of_xml)
          (Xml.child xml_arg0 "NextToken") in
      let clientToken =
        (Option.map ~f:ClientRequestToken.of_xml)
          (Xml.child xml_arg0 "ClientToken") in
      let queryString =
        QueryString.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "QueryString") in
      make ?queryInsights ?maxRows ?nextToken ?clientToken ~queryString ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let queryInsights =
        field_map json__ "QueryInsights" QueryInsights.of_json in
      let maxRows = field_map json__ "MaxRows" MaxQueryResults.of_json in
      let nextToken = field_map json__ "NextToken" PaginationToken.of_json in
      let clientToken =
        field_map json__ "ClientToken" ClientRequestToken.of_json in
      let queryString =
        field_map_exn json__ "QueryString" QueryString.of_json in
      make ?queryInsights ?maxRows ?nextToken ?clientToken ~queryString ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Query is a synchronous operation that enables you to run a query against your Amazon Timestream data. If you enabled QueryInsights, this API also returns insights and metrics related to the query that you executed. QueryInsights helps with performance tuning of your query. For more information about QueryInsights, see Using query insights to optimize queries in Amazon Timestream. The maximum number of Query API requests you're allowed to make with QueryInsights enabled is 1 query per second (QPS). If you exceed this query rate, it might result in throttling. Query will time out after 60 seconds. You must update the default timeout in the SDK to support a timeout of 60 seconds. See the code sample for details. Your query request will fail in the following cases: If you submit a Query request with the same client token outside of the 5-minute idempotency window. If you submit a Query request with the same client token, but change other parameters, within the 5-minute idempotency window. If the size of the row (including the query metadata) exceeds 1 MB, then the query will fail with the following error message: Query aborted as max page response size has been exceeded by the output result row If the IAM principal of the query initiator and the result reader are not the same and/or the query initiator and the result reader do not have the same query string in the query requests, the query will fail with an Invalid pagination token error."]
module RowList =
  struct
    type nonrec t = Row.t list
    let make i = i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:Row.to_value)) |> (fun x -> `List x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for List_shape objects" ()
    let of_xml x =
      make
        (List.map
           ((Xml.all_children x) |>
              (List.filter
                 ~f:(function
                     | `Data s ->
                         (match Stdlib.String.trim s with
                          | "" -> false
                          | _ -> true)
                     | _ -> true))) ~f:Row.of_xml)
    let of_json j = list_of_json ~kind:"RowList" ~of_json:Row.of_json j
    let to_json v = composed_to_json to_value v
  end
module QueryStatus =
  struct
    type nonrec t =
      {
      progressPercentage: Double.t option
        [@ocaml.doc "The progress of the query, expressed as a percentage."];
      cumulativeBytesScanned: Long.t option
        [@ocaml.doc
          "The amount of data scanned by the query in bytes. This is a cumulative sum and represents the total amount of bytes scanned since the query was started."];
      cumulativeBytesMetered: Long.t option
        [@ocaml.doc
          "The amount of data scanned by the query in bytes that you will be charged for. This is a cumulative sum and represents the total amount of data that you will be charged for since the query was started. The charge is applied only once and is either applied when the query completes running or when the query is cancelled."]}
    let make ?progressPercentage =
      fun ?cumulativeBytesScanned ->
        fun ?cumulativeBytesMetered ->
          fun () ->
            {
              progressPercentage;
              cumulativeBytesScanned;
              cumulativeBytesMetered
            }
    let to_value x =
      structure_to_value
        [("ProgressPercentage",
           (Option.map x.progressPercentage ~f:Double.to_value));
        ("CumulativeBytesScanned",
          (Option.map x.cumulativeBytesScanned ~f:Long.to_value));
        ("CumulativeBytesMetered",
          (Option.map x.cumulativeBytesMetered ~f:Long.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let cumulativeBytesMetered =
        (Option.map ~f:Long.of_xml)
          (Xml.child xml_arg0 "CumulativeBytesMetered") in
      let cumulativeBytesScanned =
        (Option.map ~f:Long.of_xml)
          (Xml.child xml_arg0 "CumulativeBytesScanned") in
      let progressPercentage =
        (Option.map ~f:Double.of_xml)
          (Xml.child xml_arg0 "ProgressPercentage") in
      make ?cumulativeBytesMetered ?cumulativeBytesScanned
        ?progressPercentage ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let cumulativeBytesMetered =
        field_map json__ "CumulativeBytesMetered" Long.of_json in
      let cumulativeBytesScanned =
        field_map json__ "CumulativeBytesScanned" Long.of_json in
      let progressPercentage =
        field_map json__ "ProgressPercentage" Double.of_json in
      make ?cumulativeBytesMetered ?cumulativeBytesScanned
        ?progressPercentage ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Information about the status of the query, including progress and bytes scanned."]
module QueryResponse =
  struct
    type nonrec t =
      {
      queryId: QueryId.t option
        [@ocaml.doc "A unique ID for the given query."];
      nextToken: PaginationToken.t option
        [@ocaml.doc
          "A pagination token that can be used again on a Query call to get the next set of results."];
      rows: RowList.t option
        [@ocaml.doc "The result set rows returned by the query."];
      columnInfo: ColumnInfoList.t option
        [@ocaml.doc "The column data types of the returned result set."];
      queryStatus: QueryStatus.t option
        [@ocaml.doc
          "Information about the status of the query, including progress and bytes scanned."];
      queryInsightsResponse: QueryInsightsResponse.t option
        [@ocaml.doc
          "Encapsulates QueryInsights containing insights and metrics related to the query that you executed."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `ConflictException of ConflictException.t 
      | `InternalServerException of InternalServerException.t 
      | `InvalidEndpointException of InvalidEndpointException.t 
      | `QueryExecutionException of QueryExecutionException.t 
      | `ThrottlingException of ThrottlingException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?queryId =
      fun ?nextToken ->
        fun ?rows ->
          fun ?columnInfo ->
            fun ?queryStatus ->
              fun ?queryInsightsResponse ->
                fun () ->
                  {
                    queryId;
                    nextToken;
                    rows;
                    columnInfo;
                    queryStatus;
                    queryInsightsResponse
                  }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_json json)
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_json json)
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_json json)
      | "QueryExecutionException" ->
          `QueryExecutionException (QueryExecutionException.of_json json)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_xml xml)
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_xml xml)
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_xml xml)
      | "QueryExecutionException" ->
          `QueryExecutionException (QueryExecutionException.of_xml xml)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `ConflictException e ->
          `Assoc
            [("error", (`String "ConflictException"));
            ("details", (ConflictException.to_json e))]
      | `InternalServerException e ->
          `Assoc
            [("error", (`String "InternalServerException"));
            ("details", (InternalServerException.to_json e))]
      | `InvalidEndpointException e ->
          `Assoc
            [("error", (`String "InvalidEndpointException"));
            ("details", (InvalidEndpointException.to_json e))]
      | `QueryExecutionException e ->
          `Assoc
            [("error", (`String "QueryExecutionException"));
            ("details", (QueryExecutionException.to_json e))]
      | `ThrottlingException e ->
          `Assoc
            [("error", (`String "ThrottlingException"));
            ("details", (ThrottlingException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("QueryId", (Option.map x.queryId ~f:QueryId.to_value));
        ("NextToken", (Option.map x.nextToken ~f:PaginationToken.to_value));
        ("Rows", (Option.map x.rows ~f:RowList.to_value));
        ("ColumnInfo", (Option.map x.columnInfo ~f:ColumnInfoList.to_value));
        ("QueryStatus", (Option.map x.queryStatus ~f:QueryStatus.to_value));
        ("QueryInsightsResponse",
          (Option.map x.queryInsightsResponse
             ~f:QueryInsightsResponse.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let queryInsightsResponse =
        (Option.map ~f:QueryInsightsResponse.of_xml)
          (Xml.child xml_arg0 "QueryInsightsResponse") in
      let queryStatus =
        (Option.map ~f:QueryStatus.of_xml) (Xml.child xml_arg0 "QueryStatus") in
      let columnInfo =
        (Option.map ~f:ColumnInfoList.of_xml)
          (Xml.child xml_arg0 "ColumnInfo") in
      let rows = (Option.map ~f:RowList.of_xml) (Xml.child xml_arg0 "Rows") in
      let nextToken =
        (Option.map ~f:PaginationToken.of_xml)
          (Xml.child xml_arg0 "NextToken") in
      let queryId =
        (Option.map ~f:QueryId.of_xml) (Xml.child xml_arg0 "QueryId") in
      make ?queryInsightsResponse ?queryStatus ?columnInfo ?rows ?nextToken
        ?queryId ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let queryInsightsResponse =
        field_map json__ "QueryInsightsResponse"
          QueryInsightsResponse.of_json in
      let queryStatus = field_map json__ "QueryStatus" QueryStatus.of_json in
      let columnInfo = field_map json__ "ColumnInfo" ColumnInfoList.of_json in
      let rows = field_map json__ "Rows" RowList.of_json in
      let nextToken = field_map json__ "NextToken" PaginationToken.of_json in
      let queryId = field_map json__ "QueryId" QueryId.of_json in
      make ?queryInsightsResponse ?queryStatus ?columnInfo ?rows ?nextToken
        ?queryId ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Query is a synchronous operation that enables you to run a query against your Amazon Timestream data. If you enabled QueryInsights, this API also returns insights and metrics related to the query that you executed. QueryInsights helps with performance tuning of your query. For more information about QueryInsights, see Using query insights to optimize queries in Amazon Timestream. The maximum number of Query API requests you're allowed to make with QueryInsights enabled is 1 query per second (QPS). If you exceed this query rate, it might result in throttling. Query will time out after 60 seconds. You must update the default timeout in the SDK to support a timeout of 60 seconds. See the code sample for details. Your query request will fail in the following cases: If you submit a Query request with the same client token outside of the 5-minute idempotency window. If you submit a Query request with the same client token, but change other parameters, within the 5-minute idempotency window. If the size of the row (including the query metadata) exceeds 1 MB, then the query will fail with the following error message: Query aborted as max page response size has been exceeded by the output result row If the IAM principal of the query initiator and the result reader are not the same and/or the query initiator and the result reader do not have the same query string in the query requests, the query will fail with an Invalid pagination token error."]
module TagKeyList =
  struct
    type nonrec t = TagKey.t list
    let make i =
      let open Result in
        ok_or_failwith
          ((check_list_max i ~max:200) >>=
             (fun () -> check_list_min i ~min:0));
        i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:TagKey.to_value)) |> (fun x -> `List x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for List_shape objects" ()
    let of_xml x =
      make
        (List.map
           ((Xml.all_children x) |>
              (List.filter
                 ~f:(function
                     | `Data s ->
                         (match Stdlib.String.trim s with
                          | "" -> false
                          | _ -> true)
                     | _ -> true))) ~f:TagKey.of_xml)
    let of_json j = list_of_json ~kind:"TagKeyList" ~of_json:TagKey.of_json j
    let to_json v = composed_to_json to_value v
  end
module TagResourceRequest =
  struct
    type nonrec t =
      {
      resourceARN: AmazonResourceName.t
        [@ocaml.doc
          "Identifies the Timestream resource to which tags should be added. This value is an Amazon Resource Name (ARN)."];
      tags: TagList.t
        [@ocaml.doc "The tags to be assigned to the Timestream resource."]}
    let context_ = "TagResourceRequest"
    let make ~resourceARN = fun ~tags -> fun () -> { resourceARN; tags }
    let to_value x =
      structure_to_value
        [("ResourceARN", (Some (AmazonResourceName.to_value x.resourceARN)));
        ("Tags", (Some (TagList.to_value x.tags)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let tags =
        TagList.of_xml (Xml.child_exn ~context:context_ xml_arg0 "Tags") in
      let resourceARN =
        AmazonResourceName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "ResourceARN") in
      make ~tags ~resourceARN ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let tags = field_map_exn json__ "Tags" TagList.of_json in
      let resourceARN =
        field_map_exn json__ "ResourceARN" AmazonResourceName.of_json in
      make ~tags ~resourceARN ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Associate a set of tags with a Timestream resource. You can then activate these user-defined tags so that they appear on the Billing and Cost Management console for cost allocation tracking."]
module TagResourceResponse =
  struct
    type nonrec t = unit
    type nonrec error =
      [ `InvalidEndpointException of InvalidEndpointException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ServiceQuotaExceededException of ServiceQuotaExceededException.t 
      | `ThrottlingException of ThrottlingException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make () = ()
    let error_of_json name json =
      match name with
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ServiceQuotaExceededException" ->
          `ServiceQuotaExceededException
            (ServiceQuotaExceededException.of_json json)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ServiceQuotaExceededException" ->
          `ServiceQuotaExceededException
            (ServiceQuotaExceededException.of_xml xml)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `InvalidEndpointException e ->
          `Assoc
            [("error", (`String "InvalidEndpointException"));
            ("details", (InvalidEndpointException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ServiceQuotaExceededException e ->
          `Assoc
            [("error", (`String "ServiceQuotaExceededException"));
            ("details", (ServiceQuotaExceededException.to_json e))]
      | `ThrottlingException e ->
          `Assoc
            [("error", (`String "ThrottlingException"));
            ("details", (ThrottlingException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Associate a set of tags with a Timestream resource. You can then activate these user-defined tags so that they appear on the Billing and Cost Management console for cost allocation tracking."]
module UntagResourceRequest =
  struct
    type nonrec t =
      {
      resourceARN: AmazonResourceName.t
        [@ocaml.doc
          "The Timestream resource that the tags will be removed from. This value is an Amazon Resource Name (ARN)."];
      tagKeys: TagKeyList.t
        [@ocaml.doc
          "A list of tags keys. Existing tags of the resource whose keys are members of this list will be removed from the Timestream resource."]}
    let context_ = "UntagResourceRequest"
    let make ~resourceARN =
      fun ~tagKeys -> fun () -> { resourceARN; tagKeys }
    let to_value x =
      structure_to_value
        [("ResourceARN", (Some (AmazonResourceName.to_value x.resourceARN)));
        ("TagKeys", (Some (TagKeyList.to_value x.tagKeys)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let tagKeys =
        TagKeyList.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "TagKeys") in
      let resourceARN =
        AmazonResourceName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "ResourceARN") in
      make ~tagKeys ~resourceARN ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let tagKeys = field_map_exn json__ "TagKeys" TagKeyList.of_json in
      let resourceARN =
        field_map_exn json__ "ResourceARN" AmazonResourceName.of_json in
      make ~tagKeys ~resourceARN ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Removes the association of tags from a Timestream query resource."]
module UntagResourceResponse =
  struct
    type nonrec t = unit
    type nonrec error =
      [ `InvalidEndpointException of InvalidEndpointException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ThrottlingException of ThrottlingException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make () = ()
    let error_of_json name json =
      match name with
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `InvalidEndpointException e ->
          `Assoc
            [("error", (`String "InvalidEndpointException"));
            ("details", (InvalidEndpointException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ThrottlingException e ->
          `Assoc
            [("error", (`String "ThrottlingException"));
            ("details", (ThrottlingException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Removes the association of tags from a Timestream query resource."]
module UpdateAccountSettingsRequest =
  struct
    type nonrec t =
      {
      maxQueryTCU: MaxQueryCapacity.t option
        [@ocaml.doc
          "The maximum number of compute units the service will use at any point in time to serve your queries. To run queries, you must set a minimum capacity of 4 TCU. You can set the maximum number of TCU in multiples of 4, for example, 4, 8, 16, 32, and so on. The maximum value supported for MaxQueryTCU is 1000. To request an increase to this soft limit, contact Amazon Web Services Support. For information about the default quota for maxQueryTCU, see Default quotas. This configuration is applicable only for on-demand usage of Timestream Compute Units (TCUs). The maximum value supported for MaxQueryTCU is 1000. To request an increase to this soft limit, contact Amazon Web Services Support. For information about the default quota for maxQueryTCU, see Default quotas."];
      queryPricingModel: QueryPricingModel.t option
        [@ocaml.doc
          "The pricing model for queries in an account. The QueryPricingModel parameter is used by several Timestream operations; however, the UpdateAccountSettings API operation doesn't recognize any values other than COMPUTE_UNITS."];
      queryCompute: QueryComputeRequest.t option
        [@ocaml.doc
          "Modifies the query compute settings configured in your account, including the query pricing model and provisioned Timestream Compute Units (TCUs) in your account. This API is idempotent, meaning that making the same request multiple times will have the same effect as making the request once."]}
    let make ?maxQueryTCU =
      fun ?queryPricingModel ->
        fun ?queryCompute ->
          fun () -> { maxQueryTCU; queryPricingModel; queryCompute }
    let to_value x =
      structure_to_value
        [("MaxQueryTCU",
           (Option.map x.maxQueryTCU ~f:MaxQueryCapacity.to_value));
        ("QueryPricingModel",
          (Option.map x.queryPricingModel ~f:QueryPricingModel.to_value));
        ("QueryCompute",
          (Option.map x.queryCompute ~f:QueryComputeRequest.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let queryCompute =
        (Option.map ~f:QueryComputeRequest.of_xml)
          (Xml.child xml_arg0 "QueryCompute") in
      let queryPricingModel =
        (Option.map ~f:QueryPricingModel.of_xml)
          (Xml.child xml_arg0 "QueryPricingModel") in
      let maxQueryTCU =
        (Option.map ~f:MaxQueryCapacity.of_xml)
          (Xml.child xml_arg0 "MaxQueryTCU") in
      make ?queryCompute ?queryPricingModel ?maxQueryTCU ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let queryCompute =
        field_map json__ "QueryCompute" QueryComputeRequest.of_json in
      let queryPricingModel =
        field_map json__ "QueryPricingModel" QueryPricingModel.of_json in
      let maxQueryTCU =
        field_map json__ "MaxQueryTCU" MaxQueryCapacity.of_json in
      make ?queryCompute ?queryPricingModel ?maxQueryTCU ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Transitions your account to use TCUs for query pricing and modifies the maximum query compute units that you've configured. If you reduce the value of MaxQueryTCU to a desired configuration, the new value can take up to 24 hours to be effective. After you've transitioned your account to use TCUs for query pricing, you can't transition to using bytes scanned for query pricing."]
module UpdateAccountSettingsResponse =
  struct
    type nonrec t =
      {
      maxQueryTCU: MaxQueryCapacity.t option
        [@ocaml.doc
          "The configured maximum number of compute units the service will use at any point in time to serve your queries."];
      queryPricingModel: QueryPricingModel.t option
        [@ocaml.doc "The pricing model for an account."];
      queryCompute: QueryComputeResponse.t option
        [@ocaml.doc
          "Confirms the updated account settings for querying data in your account."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `InternalServerException of InternalServerException.t 
      | `InvalidEndpointException of InvalidEndpointException.t 
      | `ThrottlingException of ThrottlingException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?maxQueryTCU =
      fun ?queryPricingModel ->
        fun ?queryCompute ->
          fun () -> { maxQueryTCU; queryPricingModel; queryCompute }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_json json)
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_json json)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "InternalServerException" ->
          `InternalServerException (InternalServerException.of_xml xml)
      | "InvalidEndpointException" ->
          `InvalidEndpointException (InvalidEndpointException.of_xml xml)
      | "ThrottlingException" ->
          `ThrottlingException (ThrottlingException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `InternalServerException e ->
          `Assoc
            [("error", (`String "InternalServerException"));
            ("details", (InternalServerException.to_json e))]
      | `InvalidEndpointException e ->
          `Assoc
            [("error", (`String "InvalidEndpointException"));
            ("details", (InvalidEndpointException.to_json e))]
      | `ThrottlingException e ->
          `Assoc
            [("error", (`String "ThrottlingException"));
            ("details", (ThrottlingException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("MaxQueryTCU",
           (Option.map x.maxQueryTCU ~f:MaxQueryCapacity.to_value));
        ("QueryPricingModel",
          (Option.map x.queryPricingModel ~f:QueryPricingModel.to_value));
        ("QueryCompute",
          (Option.map x.queryCompute ~f:QueryComputeResponse.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let queryCompute =
        (Option.map ~f:QueryComputeResponse.of_xml)
          (Xml.child xml_arg0 "QueryCompute") in
      let queryPricingModel =
        (Option.map ~f:QueryPricingModel.of_xml)
          (Xml.child xml_arg0 "QueryPricingModel") in
      let maxQueryTCU =
        (Option.map ~f:MaxQueryCapacity.of_xml)
          (Xml.child xml_arg0 "MaxQueryTCU") in
      make ?queryCompute ?queryPricingModel ?maxQueryTCU ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let queryCompute =
        field_map json__ "QueryCompute" QueryComputeResponse.of_json in
      let queryPricingModel =
        field_map json__ "QueryPricingModel" QueryPricingModel.of_json in
      let maxQueryTCU =
        field_map json__ "MaxQueryTCU" MaxQueryCapacity.of_json in
      make ?queryCompute ?queryPricingModel ?maxQueryTCU ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Transitions your account to use TCUs for query pricing and modifies the maximum query compute units that you've configured. If you reduce the value of MaxQueryTCU to a desired configuration, the new value can take up to 24 hours to be effective. After you've transitioned your account to use TCUs for query pricing, you can't transition to using bytes scanned for query pricing."]
module UpdateScheduledQueryRequest =
  struct
    type nonrec t =
      {
      scheduledQueryArn: AmazonResourceName.t
        [@ocaml.doc "ARN of the scheuled query."];
      state: ScheduledQueryState.t
        [@ocaml.doc "State of the scheduled query."]}
    let context_ = "UpdateScheduledQueryRequest"
    let make ~scheduledQueryArn =
      fun ~state -> fun () -> { scheduledQueryArn; state }
    let to_value x =
      structure_to_value
        [("ScheduledQueryArn",
           (Some (AmazonResourceName.to_value x.scheduledQueryArn)));
        ("State", (Some (ScheduledQueryState.to_value x.state)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let state =
        ScheduledQueryState.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "State") in
      let scheduledQueryArn =
        AmazonResourceName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "ScheduledQueryArn") in
      make ~state ~scheduledQueryArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let state = field_map_exn json__ "State" ScheduledQueryState.of_json in
      let scheduledQueryArn =
        field_map_exn json__ "ScheduledQueryArn" AmazonResourceName.of_json in
      make ~state ~scheduledQueryArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Update a scheduled query."]