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.kafkaconnect
let apiVersion = "2021-09-14"
let endpointPrefix = "kafkaconnect"
let serviceFullName = "Managed Streaming for Kafka Connect"
let signatureVersion = "v4"
let protocol = "rest_json"
let globalEndpoint = endpointPrefix ^ ".amazonaws.com"
let serviceAbbreviation = "Kafka Connect"
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 Zz__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 Zz__integer =
  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 __integer" 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 Zz__listOf__string =
  struct
    type nonrec t = Zz__string.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:Zz__string.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:Zz__string.of_xml)
    let of_json j =
      list_of_json ~kind:"__listOf__string" ~of_json:Zz__string.of_json j
    let to_json v = composed_to_json to_value v
  end
module Zz__boolean =
  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 Zz__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 S3LocationDescription =
  struct
    type nonrec t =
      {
      bucketArn: Zz__string.t option
        [@ocaml.doc "The Amazon Resource Name (ARN) of an S3 bucket."];
      fileKey: Zz__string.t option
        [@ocaml.doc "The file key for an object in an S3 bucket."];
      objectVersion: Zz__string.t option
        [@ocaml.doc "The version of an object in an S3 bucket."]}
    let make ?bucketArn =
      fun ?fileKey ->
        fun ?objectVersion -> fun () -> { bucketArn; fileKey; objectVersion }
    let to_value x =
      structure_to_value
        [("bucketArn", (Option.map x.bucketArn ~f:Zz__string.to_value));
        ("fileKey", (Option.map x.fileKey ~f:Zz__string.to_value));
        ("objectVersion",
          (Option.map x.objectVersion ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let objectVersion =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "objectVersion") in
      let fileKey =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "fileKey") in
      let bucketArn =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "bucketArn") in
      make ?objectVersion ?fileKey ?bucketArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let objectVersion = field_map json__ "objectVersion" Zz__string.of_json in
      let fileKey = field_map json__ "fileKey" Zz__string.of_json in
      let bucketArn = field_map json__ "bucketArn" Zz__string.of_json in
      make ?objectVersion ?fileKey ?bucketArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The description of the location of an object in Amazon S3."]
module ScaleInPolicyDescription =
  struct
    type nonrec t =
      {
      cpuUtilizationPercentage: Zz__integer.t option
        [@ocaml.doc
          "Specifies the CPU utilization percentage threshold at which you want connector scale in to be triggered."]}
    let make ?cpuUtilizationPercentage =
      fun () -> { cpuUtilizationPercentage }
    let to_value x =
      structure_to_value
        [("cpuUtilizationPercentage",
           (Option.map x.cpuUtilizationPercentage ~f:Zz__integer.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let cpuUtilizationPercentage =
        (Option.map ~f:Zz__integer.of_xml)
          (Xml.child xml_arg0 "cpuUtilizationPercentage") in
      make ?cpuUtilizationPercentage ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let cpuUtilizationPercentage =
        field_map json__ "cpuUtilizationPercentage" Zz__integer.of_json in
      make ?cpuUtilizationPercentage ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The description of the scale-in policy for the connector."]
module ScaleOutPolicyDescription =
  struct
    type nonrec t =
      {
      cpuUtilizationPercentage: Zz__integer.t option
        [@ocaml.doc
          "The CPU utilization percentage threshold at which you want connector scale out to be triggered."]}
    let make ?cpuUtilizationPercentage =
      fun () -> { cpuUtilizationPercentage }
    let to_value x =
      structure_to_value
        [("cpuUtilizationPercentage",
           (Option.map x.cpuUtilizationPercentage ~f:Zz__integer.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let cpuUtilizationPercentage =
        (Option.map ~f:Zz__integer.of_xml)
          (Xml.child xml_arg0 "cpuUtilizationPercentage") in
      make ?cpuUtilizationPercentage ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let cpuUtilizationPercentage =
        field_map json__ "cpuUtilizationPercentage" Zz__integer.of_json in
      make ?cpuUtilizationPercentage ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The description of the scale-out policy for the connector."]
module VpcDescription =
  struct
    type nonrec t =
      {
      securityGroups: Zz__listOf__string.t option
        [@ocaml.doc "The security groups for the connector."];
      subnets: Zz__listOf__string.t option
        [@ocaml.doc "The subnets for the connector."]}
    let make ?securityGroups =
      fun ?subnets -> fun () -> { securityGroups; subnets }
    let to_value x =
      structure_to_value
        [("securityGroups",
           (Option.map x.securityGroups ~f:Zz__listOf__string.to_value));
        ("subnets", (Option.map x.subnets ~f:Zz__listOf__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let subnets =
        (Option.map ~f:Zz__listOf__string.of_xml)
          (Xml.child xml_arg0 "subnets") in
      let securityGroups =
        (Option.map ~f:Zz__listOf__string.of_xml)
          (Xml.child xml_arg0 "securityGroups") in
      make ?subnets ?securityGroups ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let subnets = field_map json__ "subnets" Zz__listOf__string.of_json in
      let securityGroups =
        field_map json__ "securityGroups" Zz__listOf__string.of_json in
      make ?subnets ?securityGroups ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The description of the VPC in which the connector resides."]
module CloudWatchLogsLogDeliveryDescription =
  struct
    type nonrec t =
      {
      enabled: Zz__boolean.t option
        [@ocaml.doc
          "Whether log delivery to Amazon CloudWatch Logs is enabled."];
      logGroup: Zz__string.t option
        [@ocaml.doc
          "The name of the CloudWatch log group that is the destination for log delivery."]}
    let make ?enabled = fun ?logGroup -> fun () -> { enabled; logGroup }
    let to_value x =
      structure_to_value
        [("enabled", (Option.map x.enabled ~f:Zz__boolean.to_value));
        ("logGroup", (Option.map x.logGroup ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let logGroup =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "logGroup") in
      let enabled =
        (Option.map ~f:Zz__boolean.of_xml) (Xml.child xml_arg0 "enabled") in
      make ?logGroup ?enabled ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let logGroup = field_map json__ "logGroup" Zz__string.of_json in
      let enabled = field_map json__ "enabled" Zz__boolean.of_json in
      make ?logGroup ?enabled ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "A description of the log delivery settings."]
module FirehoseLogDeliveryDescription =
  struct
    type nonrec t =
      {
      deliveryStream: Zz__string.t option
        [@ocaml.doc
          "The name of the Kinesis Data Firehose delivery stream that is the destination for log delivery."];
      enabled: Zz__boolean.t option
        [@ocaml.doc
          "Specifies whether connector logs get delivered to Amazon Kinesis Data Firehose."]}
    let make ?deliveryStream =
      fun ?enabled -> fun () -> { deliveryStream; enabled }
    let to_value x =
      structure_to_value
        [("deliveryStream",
           (Option.map x.deliveryStream ~f:Zz__string.to_value));
        ("enabled", (Option.map x.enabled ~f:Zz__boolean.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let enabled =
        (Option.map ~f:Zz__boolean.of_xml) (Xml.child xml_arg0 "enabled") in
      let deliveryStream =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "deliveryStream") in
      make ?enabled ?deliveryStream ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let enabled = field_map json__ "enabled" Zz__boolean.of_json in
      let deliveryStream =
        field_map json__ "deliveryStream" Zz__string.of_json in
      make ?enabled ?deliveryStream ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "A description of the settings for delivering logs to Amazon Kinesis Data Firehose."]
module S3LogDeliveryDescription =
  struct
    type nonrec t =
      {
      bucket: Zz__string.t option
        [@ocaml.doc
          "The name of the S3 bucket that is the destination for log delivery."];
      enabled: Zz__boolean.t option
        [@ocaml.doc
          "Specifies whether connector logs get sent to the specified Amazon S3 destination."];
      prefix: Zz__string.t option
        [@ocaml.doc
          "The S3 prefix that is the destination for log delivery."]}
    let make ?bucket =
      fun ?enabled -> fun ?prefix -> fun () -> { bucket; enabled; prefix }
    let to_value x =
      structure_to_value
        [("bucket", (Option.map x.bucket ~f:Zz__string.to_value));
        ("enabled", (Option.map x.enabled ~f:Zz__boolean.to_value));
        ("prefix", (Option.map x.prefix ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let prefix =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "prefix") in
      let enabled =
        (Option.map ~f:Zz__boolean.of_xml) (Xml.child xml_arg0 "enabled") in
      let bucket =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "bucket") in
      make ?prefix ?enabled ?bucket ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let prefix = field_map json__ "prefix" Zz__string.of_json in
      let enabled = field_map json__ "enabled" Zz__boolean.of_json in
      let bucket = field_map json__ "bucket" Zz__string.of_json in
      make ?prefix ?enabled ?bucket ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The description of the details about delivering logs to Amazon S3."]
module CustomPluginDescription =
  struct
    type nonrec t =
      {
      customPluginArn: Zz__string.t option
        [@ocaml.doc "The Amazon Resource Name (ARN) of the custom plugin."];
      revision: Zz__long.t option
        [@ocaml.doc "The revision of the custom plugin."]}
    let make ?customPluginArn =
      fun ?revision -> fun () -> { customPluginArn; revision }
    let to_value x =
      structure_to_value
        [("customPluginArn",
           (Option.map x.customPluginArn ~f:Zz__string.to_value));
        ("revision", (Option.map x.revision ~f:Zz__long.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let revision =
        (Option.map ~f:Zz__long.of_xml) (Xml.child xml_arg0 "revision") in
      let customPluginArn =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "customPluginArn") in
      make ?revision ?customPluginArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let revision = field_map json__ "revision" Zz__long.of_json in
      let customPluginArn =
        field_map json__ "customPluginArn" Zz__string.of_json in
      make ?revision ?customPluginArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Details about a custom plugin."]
module Zz__integerMin1Max100 =
  struct
    type nonrec t = int
    let make i =
      let open Result in
        ok_or_failwith
          ((check_int_max i ~max:100) >>= (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 __integerMin1Max100" 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 Zz__timestampIso8601 =
  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 CustomPluginContentType =
  struct
    type nonrec t =
      | JAR 
      | ZIP 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function | JAR -> "JAR" | ZIP -> "ZIP" | Non_static_id s -> s
    let of_string =
      function | "JAR" -> JAR | "ZIP" -> ZIP | 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 CustomPluginContentType" xml_arg0)
    let of_json j =
      of_string (string_of_json ~kind:"CustomPluginContentType" j)
    let to_json = simple_to_json to_value
  end
module CustomPluginFileDescription =
  struct
    type nonrec t =
      {
      fileMd5: Zz__string.t option
        [@ocaml.doc
          "The hex-encoded MD5 checksum of the custom plugin file. You can use it to validate the file."];
      fileSize: Zz__long.t option
        [@ocaml.doc
          "The size in bytes of the custom plugin file. You can use it to validate the file."]}
    let make ?fileMd5 = fun ?fileSize -> fun () -> { fileMd5; fileSize }
    let to_value x =
      structure_to_value
        [("fileMd5", (Option.map x.fileMd5 ~f:Zz__string.to_value));
        ("fileSize", (Option.map x.fileSize ~f:Zz__long.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let fileSize =
        (Option.map ~f:Zz__long.of_xml) (Xml.child xml_arg0 "fileSize") in
      let fileMd5 =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "fileMd5") in
      make ?fileSize ?fileMd5 ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let fileSize = field_map json__ "fileSize" Zz__long.of_json in
      let fileMd5 = field_map json__ "fileMd5" Zz__string.of_json in
      make ?fileSize ?fileMd5 ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Details about a custom plugin file."]
module CustomPluginLocationDescription =
  struct
    type nonrec t =
      {
      s3Location: S3LocationDescription.t option
        [@ocaml.doc
          "The S3 bucket Amazon Resource Name (ARN), file key, and object version of the plugin file stored in Amazon S3."]}
    let make ?s3Location = fun () -> { s3Location }
    let to_value x =
      structure_to_value
        [("s3Location",
           (Option.map x.s3Location ~f:S3LocationDescription.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let s3Location =
        (Option.map ~f:S3LocationDescription.of_xml)
          (Xml.child xml_arg0 "s3Location") in
      make ?s3Location ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let s3Location =
        field_map json__ "s3Location" S3LocationDescription.of_json in
      make ?s3Location ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Information about the location of a custom plugin."]
module AutoScalingDescription =
  struct
    type nonrec t =
      {
      maxWorkerCount: Zz__integer.t option
        [@ocaml.doc
          "The maximum number of workers allocated to the connector."];
      mcuCount: Zz__integer.t option
        [@ocaml.doc
          "The number of microcontroller units (MCUs) allocated to each connector worker. The valid values are 1,2,4,8."];
      minWorkerCount: Zz__integer.t option
        [@ocaml.doc
          "The minimum number of workers allocated to the connector."];
      scaleInPolicy: ScaleInPolicyDescription.t option
        [@ocaml.doc "The scale-in policy for the connector."];
      scaleOutPolicy: ScaleOutPolicyDescription.t option
        [@ocaml.doc "The scale-out policy for the connector."];
      maxAutoscalingTaskCount: Zz__integer.t option
        [@ocaml.doc
          "The maximum number of tasks allocated to the connector during autoscaling operations. Must be at least equal to maxWorkerCount."]}
    let make ?maxWorkerCount =
      fun ?mcuCount ->
        fun ?minWorkerCount ->
          fun ?scaleInPolicy ->
            fun ?scaleOutPolicy ->
              fun ?maxAutoscalingTaskCount ->
                fun () ->
                  {
                    maxWorkerCount;
                    mcuCount;
                    minWorkerCount;
                    scaleInPolicy;
                    scaleOutPolicy;
                    maxAutoscalingTaskCount
                  }
    let to_value x =
      structure_to_value
        [("maxWorkerCount",
           (Option.map x.maxWorkerCount ~f:Zz__integer.to_value));
        ("mcuCount", (Option.map x.mcuCount ~f:Zz__integer.to_value));
        ("minWorkerCount",
          (Option.map x.minWorkerCount ~f:Zz__integer.to_value));
        ("scaleInPolicy",
          (Option.map x.scaleInPolicy ~f:ScaleInPolicyDescription.to_value));
        ("scaleOutPolicy",
          (Option.map x.scaleOutPolicy ~f:ScaleOutPolicyDescription.to_value));
        ("maxAutoscalingTaskCount",
          (Option.map x.maxAutoscalingTaskCount ~f:Zz__integer.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let maxAutoscalingTaskCount =
        (Option.map ~f:Zz__integer.of_xml)
          (Xml.child xml_arg0 "maxAutoscalingTaskCount") in
      let scaleOutPolicy =
        (Option.map ~f:ScaleOutPolicyDescription.of_xml)
          (Xml.child xml_arg0 "scaleOutPolicy") in
      let scaleInPolicy =
        (Option.map ~f:ScaleInPolicyDescription.of_xml)
          (Xml.child xml_arg0 "scaleInPolicy") in
      let minWorkerCount =
        (Option.map ~f:Zz__integer.of_xml)
          (Xml.child xml_arg0 "minWorkerCount") in
      let mcuCount =
        (Option.map ~f:Zz__integer.of_xml) (Xml.child xml_arg0 "mcuCount") in
      let maxWorkerCount =
        (Option.map ~f:Zz__integer.of_xml)
          (Xml.child xml_arg0 "maxWorkerCount") in
      make ?maxAutoscalingTaskCount ?scaleOutPolicy ?scaleInPolicy
        ?minWorkerCount ?mcuCount ?maxWorkerCount ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let maxAutoscalingTaskCount =
        field_map json__ "maxAutoscalingTaskCount" Zz__integer.of_json in
      let scaleOutPolicy =
        field_map json__ "scaleOutPolicy" ScaleOutPolicyDescription.of_json in
      let scaleInPolicy =
        field_map json__ "scaleInPolicy" ScaleInPolicyDescription.of_json in
      let minWorkerCount =
        field_map json__ "minWorkerCount" Zz__integer.of_json in
      let mcuCount = field_map json__ "mcuCount" Zz__integer.of_json in
      let maxWorkerCount =
        field_map json__ "maxWorkerCount" Zz__integer.of_json in
      make ?maxAutoscalingTaskCount ?scaleOutPolicy ?scaleInPolicy
        ?minWorkerCount ?mcuCount ?maxWorkerCount ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Information about the auto scaling parameters for the connector."]
module ProvisionedCapacityDescription =
  struct
    type nonrec t =
      {
      mcuCount: Zz__integer.t option
        [@ocaml.doc
          "The number of microcontroller units (MCUs) allocated to each connector worker. The valid values are 1,2,4,8."];
      workerCount: Zz__integer.t option
        [@ocaml.doc
          "The number of workers that are allocated to the connector."]}
    let make ?mcuCount =
      fun ?workerCount -> fun () -> { mcuCount; workerCount }
    let to_value x =
      structure_to_value
        [("mcuCount", (Option.map x.mcuCount ~f:Zz__integer.to_value));
        ("workerCount", (Option.map x.workerCount ~f:Zz__integer.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let workerCount =
        (Option.map ~f:Zz__integer.of_xml) (Xml.child xml_arg0 "workerCount") in
      let mcuCount =
        (Option.map ~f:Zz__integer.of_xml) (Xml.child xml_arg0 "mcuCount") in
      make ?workerCount ?mcuCount ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let workerCount = field_map json__ "workerCount" Zz__integer.of_json in
      let mcuCount = field_map json__ "mcuCount" Zz__integer.of_json in
      make ?workerCount ?mcuCount ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "The description of a connector's provisioned capacity."]
module KafkaClusterClientAuthenticationType =
  struct
    type nonrec t =
      | NONE 
      | IAM 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function | NONE -> "NONE" | IAM -> "IAM" | Non_static_id s -> s
    let of_string =
      function | "NONE" -> NONE | "IAM" -> IAM | 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 KafkaClusterClientAuthenticationType" xml_arg0)
    let of_json j =
      of_string
        (string_of_json ~kind:"KafkaClusterClientAuthenticationType" j)
    let to_json = simple_to_json to_value
  end
module ApacheKafkaClusterDescription =
  struct
    type nonrec t =
      {
      bootstrapServers: Zz__string.t option
        [@ocaml.doc "The bootstrap servers of the cluster."];
      vpc: VpcDescription.t option
        [@ocaml.doc
          "Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster."]}
    let make ?bootstrapServers =
      fun ?vpc -> fun () -> { bootstrapServers; vpc }
    let to_value x =
      structure_to_value
        [("bootstrapServers",
           (Option.map x.bootstrapServers ~f:Zz__string.to_value));
        ("vpc", (Option.map x.vpc ~f:VpcDescription.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let vpc =
        (Option.map ~f:VpcDescription.of_xml) (Xml.child xml_arg0 "vpc") in
      let bootstrapServers =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "bootstrapServers") in
      make ?vpc ?bootstrapServers ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let vpc = field_map json__ "vpc" VpcDescription.of_json in
      let bootstrapServers =
        field_map json__ "bootstrapServers" Zz__string.of_json in
      make ?vpc ?bootstrapServers ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The description of the Apache Kafka cluster to which the connector is connected."]
module KafkaClusterEncryptionInTransitType =
  struct
    type nonrec t =
      | PLAINTEXT 
      | TLS 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | PLAINTEXT -> "PLAINTEXT"
      | TLS -> "TLS"
      | Non_static_id s -> s
    let of_string =
      function
      | "PLAINTEXT" -> PLAINTEXT
      | "TLS" -> TLS
      | 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 KafkaClusterEncryptionInTransitType" xml_arg0)
    let of_json j =
      of_string
        (string_of_json ~kind:"KafkaClusterEncryptionInTransitType" j)
    let to_json = simple_to_json to_value
  end
module WorkerLogDeliveryDescription =
  struct
    type nonrec t =
      {
      cloudWatchLogs: CloudWatchLogsLogDeliveryDescription.t option
        [@ocaml.doc
          "Details about delivering logs to Amazon CloudWatch Logs."];
      firehose: FirehoseLogDeliveryDescription.t option
        [@ocaml.doc
          "Details about delivering logs to Amazon Kinesis Data Firehose."];
      s3: S3LogDeliveryDescription.t option
        [@ocaml.doc "Details about delivering logs to Amazon S3."]}
    let make ?cloudWatchLogs =
      fun ?firehose -> fun ?s3 -> fun () -> { cloudWatchLogs; firehose; s3 }
    let to_value x =
      structure_to_value
        [("cloudWatchLogs",
           (Option.map x.cloudWatchLogs
              ~f:CloudWatchLogsLogDeliveryDescription.to_value));
        ("firehose",
          (Option.map x.firehose ~f:FirehoseLogDeliveryDescription.to_value));
        ("s3", (Option.map x.s3 ~f:S3LogDeliveryDescription.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let s3 =
        (Option.map ~f:S3LogDeliveryDescription.of_xml)
          (Xml.child xml_arg0 "s3") in
      let firehose =
        (Option.map ~f:FirehoseLogDeliveryDescription.of_xml)
          (Xml.child xml_arg0 "firehose") in
      let cloudWatchLogs =
        (Option.map ~f:CloudWatchLogsLogDeliveryDescription.of_xml)
          (Xml.child xml_arg0 "cloudWatchLogs") in
      make ?s3 ?firehose ?cloudWatchLogs ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let s3 = field_map json__ "s3" S3LogDeliveryDescription.of_json in
      let firehose =
        field_map json__ "firehose" FirehoseLogDeliveryDescription.of_json in
      let cloudWatchLogs =
        field_map json__ "cloudWatchLogs"
          CloudWatchLogsLogDeliveryDescription.of_json in
      make ?s3 ?firehose ?cloudWatchLogs ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Workers can send worker logs to different destination types. This configuration specifies the details of these destinations."]
module PluginDescription =
  struct
    type nonrec t =
      {
      customPlugin: CustomPluginDescription.t option
        [@ocaml.doc "Details about a custom plugin."]}
    let make ?customPlugin = fun () -> { customPlugin }
    let to_value x =
      structure_to_value
        [("customPlugin",
           (Option.map x.customPlugin ~f:CustomPluginDescription.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let customPlugin =
        (Option.map ~f:CustomPluginDescription.of_xml)
          (Xml.child xml_arg0 "customPlugin") in
      make ?customPlugin ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let customPlugin =
        field_map json__ "customPlugin" CustomPluginDescription.of_json in
      make ?customPlugin ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "The description of the plugin."]
module Zz__longMin1 =
  struct
    type nonrec t = Int64.t
    let make i =
      let open Result in
        ok_or_failwith
          ((check_int64_max i ~max:9223372036854775807L) >>=
             (fun () -> check_int64_min i ~min:1L));
        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 ScaleInPolicyUpdate =
  struct
    type nonrec t =
      {
      cpuUtilizationPercentage: Zz__integerMin1Max100.t
        [@ocaml.doc
          "The target CPU utilization percentage threshold at which you want connector scale in to be triggered."]}
    let context_ = "ScaleInPolicyUpdate"
    let make ~cpuUtilizationPercentage =
      fun () -> { cpuUtilizationPercentage }
    let to_value x =
      structure_to_value
        [("cpuUtilizationPercentage",
           (Some (Zz__integerMin1Max100.to_value x.cpuUtilizationPercentage)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let cpuUtilizationPercentage =
        Zz__integerMin1Max100.of_xml
          (Xml.child_exn ~context:context_ xml_arg0
             "cpuUtilizationPercentage") in
      make ~cpuUtilizationPercentage ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let cpuUtilizationPercentage =
        field_map_exn json__ "cpuUtilizationPercentage"
          Zz__integerMin1Max100.of_json in
      make ~cpuUtilizationPercentage ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "An update to the connector's scale-in policy."]
module ScaleOutPolicyUpdate =
  struct
    type nonrec t =
      {
      cpuUtilizationPercentage: Zz__integerMin1Max100.t
        [@ocaml.doc
          "The target CPU utilization percentage threshold at which you want connector scale out to be triggered."]}
    let context_ = "ScaleOutPolicyUpdate"
    let make ~cpuUtilizationPercentage =
      fun () -> { cpuUtilizationPercentage }
    let to_value x =
      structure_to_value
        [("cpuUtilizationPercentage",
           (Some (Zz__integerMin1Max100.to_value x.cpuUtilizationPercentage)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let cpuUtilizationPercentage =
        Zz__integerMin1Max100.of_xml
          (Xml.child_exn ~context:context_ xml_arg0
             "cpuUtilizationPercentage") in
      make ~cpuUtilizationPercentage ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let cpuUtilizationPercentage =
        field_map_exn json__ "cpuUtilizationPercentage"
          Zz__integerMin1Max100.of_json in
      make ~cpuUtilizationPercentage ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "An update to the connector's scale-out policy."]
module Zz__integerMin1Max8 =
  struct
    type nonrec t = int
    let make i =
      let open Result in
        ok_or_failwith
          ((check_int_max i ~max:8) >>= (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 __integerMin1Max8" 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 WorkerConfigurationRevisionSummary =
  struct
    type nonrec t =
      {
      creationTime: Zz__timestampIso8601.t option
        [@ocaml.doc
          "The time that a worker configuration revision was created."];
      description: Zz__string.t option
        [@ocaml.doc "The description of a worker configuration revision."];
      revision: Zz__long.t option
        [@ocaml.doc "The revision of a worker configuration."]}
    let make ?creationTime =
      fun ?description ->
        fun ?revision -> fun () -> { creationTime; description; revision }
    let to_value x =
      structure_to_value
        [("creationTime",
           (Option.map x.creationTime ~f:Zz__timestampIso8601.to_value));
        ("description", (Option.map x.description ~f:Zz__string.to_value));
        ("revision", (Option.map x.revision ~f:Zz__long.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let revision =
        (Option.map ~f:Zz__long.of_xml) (Xml.child xml_arg0 "revision") in
      let description =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "description") in
      let creationTime =
        (Option.map ~f:Zz__timestampIso8601.of_xml)
          (Xml.child xml_arg0 "creationTime") in
      make ?revision ?description ?creationTime ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let revision = field_map json__ "revision" Zz__long.of_json in
      let description = field_map json__ "description" Zz__string.of_json in
      let creationTime =
        field_map json__ "creationTime" Zz__timestampIso8601.of_json in
      make ?revision ?description ?creationTime ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "The summary of a worker configuration revision."]
module WorkerConfigurationState =
  struct
    type nonrec t =
      | ACTIVE 
      | DELETING 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | ACTIVE -> "ACTIVE"
      | DELETING -> "DELETING"
      | Non_static_id s -> s
    let of_string =
      function
      | "ACTIVE" -> ACTIVE
      | "DELETING" -> DELETING
      | 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 WorkerConfigurationState" xml_arg0)
    let of_json j =
      of_string (string_of_json ~kind:"WorkerConfigurationState" j)
    let to_json = simple_to_json to_value
  end
module CustomPluginRevisionSummary =
  struct
    type nonrec t =
      {
      contentType: CustomPluginContentType.t option
        [@ocaml.doc "The format of the plugin file."];
      creationTime: Zz__timestampIso8601.t option
        [@ocaml.doc "The time that the custom plugin was created."];
      description: Zz__string.t option
        [@ocaml.doc "The description of the custom plugin."];
      fileDescription: CustomPluginFileDescription.t option
        [@ocaml.doc "Details about the custom plugin file."];
      location: CustomPluginLocationDescription.t option
        [@ocaml.doc "Information about the location of the custom plugin."];
      revision: Zz__long.t option
        [@ocaml.doc "The revision of the custom plugin."]}
    let make ?contentType =
      fun ?creationTime ->
        fun ?description ->
          fun ?fileDescription ->
            fun ?location ->
              fun ?revision ->
                fun () ->
                  {
                    contentType;
                    creationTime;
                    description;
                    fileDescription;
                    location;
                    revision
                  }
    let to_value x =
      structure_to_value
        [("contentType",
           (Option.map x.contentType ~f:CustomPluginContentType.to_value));
        ("creationTime",
          (Option.map x.creationTime ~f:Zz__timestampIso8601.to_value));
        ("description", (Option.map x.description ~f:Zz__string.to_value));
        ("fileDescription",
          (Option.map x.fileDescription
             ~f:CustomPluginFileDescription.to_value));
        ("location",
          (Option.map x.location ~f:CustomPluginLocationDescription.to_value));
        ("revision", (Option.map x.revision ~f:Zz__long.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let revision =
        (Option.map ~f:Zz__long.of_xml) (Xml.child xml_arg0 "revision") in
      let location =
        (Option.map ~f:CustomPluginLocationDescription.of_xml)
          (Xml.child xml_arg0 "location") in
      let fileDescription =
        (Option.map ~f:CustomPluginFileDescription.of_xml)
          (Xml.child xml_arg0 "fileDescription") in
      let description =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "description") in
      let creationTime =
        (Option.map ~f:Zz__timestampIso8601.of_xml)
          (Xml.child xml_arg0 "creationTime") in
      let contentType =
        (Option.map ~f:CustomPluginContentType.of_xml)
          (Xml.child xml_arg0 "contentType") in
      make ?revision ?location ?fileDescription ?description ?creationTime
        ?contentType ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let revision = field_map json__ "revision" Zz__long.of_json in
      let location =
        field_map json__ "location" CustomPluginLocationDescription.of_json in
      let fileDescription =
        field_map json__ "fileDescription"
          CustomPluginFileDescription.of_json in
      let description = field_map json__ "description" Zz__string.of_json in
      let creationTime =
        field_map json__ "creationTime" Zz__timestampIso8601.of_json in
      let contentType =
        field_map json__ "contentType" CustomPluginContentType.of_json in
      make ?revision ?location ?fileDescription ?description ?creationTime
        ?contentType ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Details about the revision of a custom plugin."]
module CustomPluginState =
  struct
    type nonrec t =
      | CREATING 
      | CREATE_FAILED 
      | ACTIVE 
      | UPDATING 
      | UPDATE_FAILED 
      | DELETING 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | CREATING -> "CREATING"
      | CREATE_FAILED -> "CREATE_FAILED"
      | ACTIVE -> "ACTIVE"
      | UPDATING -> "UPDATING"
      | UPDATE_FAILED -> "UPDATE_FAILED"
      | DELETING -> "DELETING"
      | Non_static_id s -> s
    let of_string =
      function
      | "CREATING" -> CREATING
      | "CREATE_FAILED" -> CREATE_FAILED
      | "ACTIVE" -> ACTIVE
      | "UPDATING" -> UPDATING
      | "UPDATE_FAILED" -> UPDATE_FAILED
      | "DELETING" -> DELETING
      | 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 CustomPluginState" xml_arg0)
    let of_json j = of_string (string_of_json ~kind:"CustomPluginState" j)
    let to_json = simple_to_json to_value
  end
module CapacityDescription =
  struct
    type nonrec t =
      {
      autoScaling: AutoScalingDescription.t option
        [@ocaml.doc "Describes the connector's auto scaling capacity."];
      provisionedCapacity: ProvisionedCapacityDescription.t option
        [@ocaml.doc "Describes a connector's provisioned capacity."]}
    let make ?autoScaling =
      fun ?provisionedCapacity ->
        fun () -> { autoScaling; provisionedCapacity }
    let to_value x =
      structure_to_value
        [("autoScaling",
           (Option.map x.autoScaling ~f:AutoScalingDescription.to_value));
        ("provisionedCapacity",
          (Option.map x.provisionedCapacity
             ~f:ProvisionedCapacityDescription.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let provisionedCapacity =
        (Option.map ~f:ProvisionedCapacityDescription.of_xml)
          (Xml.child xml_arg0 "provisionedCapacity") in
      let autoScaling =
        (Option.map ~f:AutoScalingDescription.of_xml)
          (Xml.child xml_arg0 "autoScaling") in
      make ?provisionedCapacity ?autoScaling ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let provisionedCapacity =
        field_map json__ "provisionedCapacity"
          ProvisionedCapacityDescription.of_json in
      let autoScaling =
        field_map json__ "autoScaling" AutoScalingDescription.of_json in
      make ?provisionedCapacity ?autoScaling ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "A description of the connector's capacity."]
module ConnectorState =
  struct
    type nonrec t =
      | RUNNING 
      | CREATING 
      | UPDATING 
      | DELETING 
      | FAILED 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | RUNNING -> "RUNNING"
      | CREATING -> "CREATING"
      | UPDATING -> "UPDATING"
      | DELETING -> "DELETING"
      | FAILED -> "FAILED"
      | Non_static_id s -> s
    let of_string =
      function
      | "RUNNING" -> RUNNING
      | "CREATING" -> CREATING
      | "UPDATING" -> UPDATING
      | "DELETING" -> DELETING
      | "FAILED" -> FAILED
      | 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 ConnectorState" xml_arg0)
    let of_json j = of_string (string_of_json ~kind:"ConnectorState" j)
    let to_json = simple_to_json to_value
  end
module KafkaClusterClientAuthenticationDescription =
  struct
    type nonrec t =
      {
      authenticationType: KafkaClusterClientAuthenticationType.t option
        [@ocaml.doc
          "The type of client authentication used to connect to the Apache Kafka cluster. Value NONE means that no client authentication is used."]}
    let make ?authenticationType = fun () -> { authenticationType }
    let to_value x =
      structure_to_value
        [("authenticationType",
           (Option.map x.authenticationType
              ~f:KafkaClusterClientAuthenticationType.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let authenticationType =
        (Option.map ~f:KafkaClusterClientAuthenticationType.of_xml)
          (Xml.child xml_arg0 "authenticationType") in
      make ?authenticationType ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let authenticationType =
        field_map json__ "authenticationType"
          KafkaClusterClientAuthenticationType.of_json in
      make ?authenticationType ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The client authentication information used in order to authenticate with the Apache Kafka cluster."]
module KafkaClusterDescription =
  struct
    type nonrec t =
      {
      apacheKafkaCluster: ApacheKafkaClusterDescription.t option
        [@ocaml.doc
          "The Apache Kafka cluster to which the connector is connected."]}
    let make ?apacheKafkaCluster = fun () -> { apacheKafkaCluster }
    let to_value x =
      structure_to_value
        [("apacheKafkaCluster",
           (Option.map x.apacheKafkaCluster
              ~f:ApacheKafkaClusterDescription.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let apacheKafkaCluster =
        (Option.map ~f:ApacheKafkaClusterDescription.of_xml)
          (Xml.child xml_arg0 "apacheKafkaCluster") in
      make ?apacheKafkaCluster ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let apacheKafkaCluster =
        field_map json__ "apacheKafkaCluster"
          ApacheKafkaClusterDescription.of_json in
      make ?apacheKafkaCluster ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Details of how to connect to the Apache Kafka cluster."]
module KafkaClusterEncryptionInTransitDescription =
  struct
    type nonrec t =
      {
      encryptionType: KafkaClusterEncryptionInTransitType.t option
        [@ocaml.doc
          "The type of encryption in transit to the Apache Kafka cluster."]}
    let make ?encryptionType = fun () -> { encryptionType }
    let to_value x =
      structure_to_value
        [("encryptionType",
           (Option.map x.encryptionType
              ~f:KafkaClusterEncryptionInTransitType.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let encryptionType =
        (Option.map ~f:KafkaClusterEncryptionInTransitType.of_xml)
          (Xml.child xml_arg0 "encryptionType") in
      make ?encryptionType ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let encryptionType =
        field_map json__ "encryptionType"
          KafkaClusterEncryptionInTransitType.of_json in
      make ?encryptionType ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The description of the encryption in transit to the Apache Kafka cluster."]
module LogDeliveryDescription =
  struct
    type nonrec t =
      {
      workerLogDelivery: WorkerLogDeliveryDescription.t option
        [@ocaml.doc
          "The workers can send worker logs to different destination types. This configuration specifies the details of these destinations."]}
    let make ?workerLogDelivery = fun () -> { workerLogDelivery }
    let to_value x =
      structure_to_value
        [("workerLogDelivery",
           (Option.map x.workerLogDelivery
              ~f:WorkerLogDeliveryDescription.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let workerLogDelivery =
        (Option.map ~f:WorkerLogDeliveryDescription.of_xml)
          (Xml.child xml_arg0 "workerLogDelivery") in
      make ?workerLogDelivery ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let workerLogDelivery =
        field_map json__ "workerLogDelivery"
          WorkerLogDeliveryDescription.of_json in
      make ?workerLogDelivery ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "The description of the log delivery settings."]
module NetworkType =
  struct
    type nonrec t =
      | IPV4 
      | DUAL 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function | IPV4 -> "IPV4" | DUAL -> "DUAL" | Non_static_id s -> s
    let of_string =
      function | "IPV4" -> IPV4 | "DUAL" -> DUAL | 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 NetworkType" xml_arg0)
    let of_json j = of_string (string_of_json ~kind:"NetworkType" j)
    let to_json = simple_to_json to_value
  end
module WorkerConfigurationDescription =
  struct
    type nonrec t =
      {
      revision: Zz__long.t option
        [@ocaml.doc "The revision of the worker configuration."];
      workerConfigurationArn: Zz__string.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the worker configuration."]}
    let make ?revision =
      fun ?workerConfigurationArn ->
        fun () -> { revision; workerConfigurationArn }
    let to_value x =
      structure_to_value
        [("revision", (Option.map x.revision ~f:Zz__long.to_value));
        ("workerConfigurationArn",
          (Option.map x.workerConfigurationArn ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let workerConfigurationArn =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "workerConfigurationArn") in
      let revision =
        (Option.map ~f:Zz__long.of_xml) (Xml.child xml_arg0 "revision") in
      make ?workerConfigurationArn ?revision ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let workerConfigurationArn =
        field_map json__ "workerConfigurationArn" Zz__string.of_json in
      let revision = field_map json__ "revision" Zz__long.of_json in
      make ?workerConfigurationArn ?revision ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "The description of the worker configuration."]
module Zz__listOfPluginDescription =
  struct
    type nonrec t = PluginDescription.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:PluginDescription.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:PluginDescription.of_xml)
    let of_json j =
      list_of_json ~kind:"__listOfPluginDescription"
        ~of_json:PluginDescription.of_json j
    let to_json v = composed_to_json to_value v
  end
module ConnectorOperationState =
  struct
    type nonrec t =
      | PENDING 
      | UPDATE_IN_PROGRESS 
      | UPDATE_COMPLETE 
      | UPDATE_FAILED 
      | ROLLBACK_IN_PROGRESS 
      | ROLLBACK_FAILED 
      | ROLLBACK_COMPLETE 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | PENDING -> "PENDING"
      | UPDATE_IN_PROGRESS -> "UPDATE_IN_PROGRESS"
      | UPDATE_COMPLETE -> "UPDATE_COMPLETE"
      | UPDATE_FAILED -> "UPDATE_FAILED"
      | ROLLBACK_IN_PROGRESS -> "ROLLBACK_IN_PROGRESS"
      | ROLLBACK_FAILED -> "ROLLBACK_FAILED"
      | ROLLBACK_COMPLETE -> "ROLLBACK_COMPLETE"
      | Non_static_id s -> s
    let of_string =
      function
      | "PENDING" -> PENDING
      | "UPDATE_IN_PROGRESS" -> UPDATE_IN_PROGRESS
      | "UPDATE_COMPLETE" -> UPDATE_COMPLETE
      | "UPDATE_FAILED" -> UPDATE_FAILED
      | "ROLLBACK_IN_PROGRESS" -> ROLLBACK_IN_PROGRESS
      | "ROLLBACK_FAILED" -> ROLLBACK_FAILED
      | "ROLLBACK_COMPLETE" -> ROLLBACK_COMPLETE
      | 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 ConnectorOperationState" xml_arg0)
    let of_json j =
      of_string (string_of_json ~kind:"ConnectorOperationState" j)
    let to_json = simple_to_json to_value
  end
module ConnectorOperationType =
  struct
    type nonrec t =
      | UPDATE_WORKER_SETTING 
      | UPDATE_CONNECTOR_CONFIGURATION 
      | ISOLATE_CONNECTOR 
      | RESTORE_CONNECTOR 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | UPDATE_WORKER_SETTING -> "UPDATE_WORKER_SETTING"
      | UPDATE_CONNECTOR_CONFIGURATION -> "UPDATE_CONNECTOR_CONFIGURATION"
      | ISOLATE_CONNECTOR -> "ISOLATE_CONNECTOR"
      | RESTORE_CONNECTOR -> "RESTORE_CONNECTOR"
      | Non_static_id s -> s
    let of_string =
      function
      | "UPDATE_WORKER_SETTING" -> UPDATE_WORKER_SETTING
      | "UPDATE_CONNECTOR_CONFIGURATION" -> UPDATE_CONNECTOR_CONFIGURATION
      | "ISOLATE_CONNECTOR" -> ISOLATE_CONNECTOR
      | "RESTORE_CONNECTOR" -> RESTORE_CONNECTOR
      | 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 ConnectorOperationType" xml_arg0)
    let of_json j =
      of_string (string_of_json ~kind:"ConnectorOperationType" j)
    let to_json = simple_to_json to_value
  end
module ConnectorOperationStepState =
  struct
    type nonrec t =
      | PENDING 
      | IN_PROGRESS 
      | COMPLETED 
      | FAILED 
      | CANCELLED 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | PENDING -> "PENDING"
      | IN_PROGRESS -> "IN_PROGRESS"
      | COMPLETED -> "COMPLETED"
      | FAILED -> "FAILED"
      | CANCELLED -> "CANCELLED"
      | Non_static_id s -> s
    let of_string =
      function
      | "PENDING" -> PENDING
      | "IN_PROGRESS" -> IN_PROGRESS
      | "COMPLETED" -> COMPLETED
      | "FAILED" -> FAILED
      | "CANCELLED" -> CANCELLED
      | 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 ConnectorOperationStepState"
           xml_arg0)
    let of_json j =
      of_string (string_of_json ~kind:"ConnectorOperationStepState" j)
    let to_json = simple_to_json to_value
  end
module ConnectorOperationStepType =
  struct
    type nonrec t =
      | INITIALIZE_UPDATE 
      | FINALIZE_UPDATE 
      | UPDATE_WORKER_SETTING 
      | UPDATE_CONNECTOR_CONFIGURATION 
      | VALIDATE_UPDATE 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | INITIALIZE_UPDATE -> "INITIALIZE_UPDATE"
      | FINALIZE_UPDATE -> "FINALIZE_UPDATE"
      | UPDATE_WORKER_SETTING -> "UPDATE_WORKER_SETTING"
      | UPDATE_CONNECTOR_CONFIGURATION -> "UPDATE_CONNECTOR_CONFIGURATION"
      | VALIDATE_UPDATE -> "VALIDATE_UPDATE"
      | Non_static_id s -> s
    let of_string =
      function
      | "INITIALIZE_UPDATE" -> INITIALIZE_UPDATE
      | "FINALIZE_UPDATE" -> FINALIZE_UPDATE
      | "UPDATE_WORKER_SETTING" -> UPDATE_WORKER_SETTING
      | "UPDATE_CONNECTOR_CONFIGURATION" -> UPDATE_CONNECTOR_CONFIGURATION
      | "VALIDATE_UPDATE" -> VALIDATE_UPDATE
      | 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 ConnectorOperationStepType"
           xml_arg0)
    let of_json j =
      of_string (string_of_json ~kind:"ConnectorOperationStepType" j)
    let to_json = simple_to_json to_value
  end
module ScaleInPolicy =
  struct
    type nonrec t =
      {
      cpuUtilizationPercentage: Zz__integerMin1Max100.t
        [@ocaml.doc
          "Specifies the CPU utilization percentage threshold at which you want connector scale in to be triggered."]}
    let context_ = "ScaleInPolicy"
    let make ~cpuUtilizationPercentage =
      fun () -> { cpuUtilizationPercentage }
    let to_value x =
      structure_to_value
        [("cpuUtilizationPercentage",
           (Some (Zz__integerMin1Max100.to_value x.cpuUtilizationPercentage)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let cpuUtilizationPercentage =
        Zz__integerMin1Max100.of_xml
          (Xml.child_exn ~context:context_ xml_arg0
             "cpuUtilizationPercentage") in
      make ~cpuUtilizationPercentage ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let cpuUtilizationPercentage =
        field_map_exn json__ "cpuUtilizationPercentage"
          Zz__integerMin1Max100.of_json in
      make ~cpuUtilizationPercentage ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "The scale-in policy for the connector."]
module ScaleOutPolicy =
  struct
    type nonrec t =
      {
      cpuUtilizationPercentage: Zz__integerMin1Max100.t
        [@ocaml.doc
          "The CPU utilization percentage threshold at which you want connector scale out to be triggered."]}
    let context_ = "ScaleOutPolicy"
    let make ~cpuUtilizationPercentage =
      fun () -> { cpuUtilizationPercentage }
    let to_value x =
      structure_to_value
        [("cpuUtilizationPercentage",
           (Some (Zz__integerMin1Max100.to_value x.cpuUtilizationPercentage)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let cpuUtilizationPercentage =
        Zz__integerMin1Max100.of_xml
          (Xml.child_exn ~context:context_ xml_arg0
             "cpuUtilizationPercentage") in
      make ~cpuUtilizationPercentage ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let cpuUtilizationPercentage =
        field_map_exn json__ "cpuUtilizationPercentage"
          Zz__integerMin1Max100.of_json in
      make ~cpuUtilizationPercentage ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "The scale-out policy for the connector."]
module Vpc =
  struct
    type nonrec t =
      {
      securityGroups: Zz__listOf__string.t option
        [@ocaml.doc "The security groups for the connector."];
      subnets: Zz__listOf__string.t
        [@ocaml.doc "The subnets for the connector."]}
    let context_ = "Vpc"
    let make ?securityGroups =
      fun ~subnets -> fun () -> { securityGroups; subnets }
    let to_value x =
      structure_to_value
        [("securityGroups",
           (Option.map x.securityGroups ~f:Zz__listOf__string.to_value));
        ("subnets", (Some (Zz__listOf__string.to_value x.subnets)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let subnets =
        Zz__listOf__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "subnets") in
      let securityGroups =
        (Option.map ~f:Zz__listOf__string.of_xml)
          (Xml.child xml_arg0 "securityGroups") in
      make ~subnets ?securityGroups ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let subnets = field_map_exn json__ "subnets" Zz__listOf__string.of_json in
      let securityGroups =
        field_map json__ "securityGroups" Zz__listOf__string.of_json in
      make ~subnets ?securityGroups ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Information about the VPC in which the connector resides."]
module CloudWatchLogsLogDelivery =
  struct
    type nonrec t =
      {
      enabled: Zz__boolean.t
        [@ocaml.doc
          "Whether log delivery to Amazon CloudWatch Logs is enabled."];
      logGroup: Zz__string.t option
        [@ocaml.doc
          "The name of the CloudWatch log group that is the destination for log delivery."]}
    let context_ = "CloudWatchLogsLogDelivery"
    let make ?logGroup = fun ~enabled -> fun () -> { logGroup; enabled }
    let to_value x =
      structure_to_value
        [("enabled", (Some (Zz__boolean.to_value x.enabled)));
        ("logGroup", (Option.map x.logGroup ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let logGroup =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "logGroup") in
      let enabled =
        Zz__boolean.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "enabled") in
      make ?logGroup ~enabled ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let logGroup = field_map json__ "logGroup" Zz__string.of_json in
      let enabled = field_map_exn json__ "enabled" Zz__boolean.of_json in
      make ?logGroup ~enabled ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The settings for delivering connector logs to Amazon CloudWatch Logs."]
module FirehoseLogDelivery =
  struct
    type nonrec t =
      {
      deliveryStream: Zz__string.t option
        [@ocaml.doc
          "The name of the Kinesis Data Firehose delivery stream that is the destination for log delivery."];
      enabled: Zz__boolean.t
        [@ocaml.doc
          "Specifies whether connector logs get delivered to Amazon Kinesis Data Firehose."]}
    let context_ = "FirehoseLogDelivery"
    let make ?deliveryStream =
      fun ~enabled -> fun () -> { deliveryStream; enabled }
    let to_value x =
      structure_to_value
        [("deliveryStream",
           (Option.map x.deliveryStream ~f:Zz__string.to_value));
        ("enabled", (Some (Zz__boolean.to_value x.enabled)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let enabled =
        Zz__boolean.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "enabled") in
      let deliveryStream =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "deliveryStream") in
      make ~enabled ?deliveryStream ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let enabled = field_map_exn json__ "enabled" Zz__boolean.of_json in
      let deliveryStream =
        field_map json__ "deliveryStream" Zz__string.of_json in
      make ~enabled ?deliveryStream ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The settings for delivering logs to Amazon Kinesis Data Firehose."]
module S3LogDelivery =
  struct
    type nonrec t =
      {
      bucket: Zz__string.t option
        [@ocaml.doc
          "The name of the S3 bucket that is the destination for log delivery."];
      enabled: Zz__boolean.t
        [@ocaml.doc
          "Specifies whether connector logs get sent to the specified Amazon S3 destination."];
      prefix: Zz__string.t option
        [@ocaml.doc
          "The S3 prefix that is the destination for log delivery."]}
    let context_ = "S3LogDelivery"
    let make ?bucket =
      fun ?prefix -> fun ~enabled -> fun () -> { bucket; prefix; enabled }
    let to_value x =
      structure_to_value
        [("bucket", (Option.map x.bucket ~f:Zz__string.to_value));
        ("enabled", (Some (Zz__boolean.to_value x.enabled)));
        ("prefix", (Option.map x.prefix ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let prefix =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "prefix") in
      let enabled =
        Zz__boolean.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "enabled") in
      let bucket =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "bucket") in
      make ?prefix ~enabled ?bucket ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let prefix = field_map json__ "prefix" Zz__string.of_json in
      let enabled = field_map_exn json__ "enabled" Zz__boolean.of_json in
      let bucket = field_map json__ "bucket" Zz__string.of_json in
      make ?prefix ~enabled ?bucket ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Details about delivering logs to Amazon S3."]
module CustomPlugin =
  struct
    type nonrec t =
      {
      customPluginArn: Zz__string.t
        [@ocaml.doc "The Amazon Resource Name (ARN) of the custom plugin."];
      revision: Zz__longMin1.t
        [@ocaml.doc "The revision of the custom plugin."]}
    let context_ = "CustomPlugin"
    let make ~customPluginArn =
      fun ~revision -> fun () -> { customPluginArn; revision }
    let to_value x =
      structure_to_value
        [("customPluginArn", (Some (Zz__string.to_value x.customPluginArn)));
        ("revision", (Some (Zz__longMin1.to_value x.revision)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let revision =
        Zz__longMin1.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "revision") in
      let customPluginArn =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "customPluginArn") in
      make ~revision ~customPluginArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let revision = field_map_exn json__ "revision" Zz__longMin1.of_json in
      let customPluginArn =
        field_map_exn json__ "customPluginArn" Zz__string.of_json in
      make ~revision ~customPluginArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "A plugin is an Amazon Web Services resource that contains the code that defines a connector's logic."]
module AutoScalingUpdate =
  struct
    type nonrec t =
      {
      maxWorkerCount: Zz__integer.t
        [@ocaml.doc
          "The target maximum number of workers allocated to the connector."];
      mcuCount: Zz__integerMin1Max8.t
        [@ocaml.doc
          "The target number of microcontroller units (MCUs) allocated to each connector worker. The valid values are 1,2,4,8."];
      minWorkerCount: Zz__integer.t
        [@ocaml.doc
          "The target minimum number of workers allocated to the connector."];
      scaleInPolicy: ScaleInPolicyUpdate.t
        [@ocaml.doc "The target scale-in policy for the connector."];
      scaleOutPolicy: ScaleOutPolicyUpdate.t
        [@ocaml.doc "The target scale-out policy for the connector."];
      maxAutoscalingTaskCount: Zz__integer.t option
        [@ocaml.doc
          "The maximum number of tasks allocated to the connector during autoscaling operations. Must be at least equal to maxWorkerCount."]}
    let context_ = "AutoScalingUpdate"
    let make ?maxAutoscalingTaskCount =
      fun ~maxWorkerCount ->
        fun ~mcuCount ->
          fun ~minWorkerCount ->
            fun ~scaleInPolicy ->
              fun ~scaleOutPolicy ->
                fun () ->
                  {
                    maxAutoscalingTaskCount;
                    maxWorkerCount;
                    mcuCount;
                    minWorkerCount;
                    scaleInPolicy;
                    scaleOutPolicy
                  }
    let to_value x =
      structure_to_value
        [("maxWorkerCount", (Some (Zz__integer.to_value x.maxWorkerCount)));
        ("mcuCount", (Some (Zz__integerMin1Max8.to_value x.mcuCount)));
        ("minWorkerCount", (Some (Zz__integer.to_value x.minWorkerCount)));
        ("scaleInPolicy",
          (Some (ScaleInPolicyUpdate.to_value x.scaleInPolicy)));
        ("scaleOutPolicy",
          (Some (ScaleOutPolicyUpdate.to_value x.scaleOutPolicy)));
        ("maxAutoscalingTaskCount",
          (Option.map x.maxAutoscalingTaskCount ~f:Zz__integer.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let maxAutoscalingTaskCount =
        (Option.map ~f:Zz__integer.of_xml)
          (Xml.child xml_arg0 "maxAutoscalingTaskCount") in
      let scaleOutPolicy =
        ScaleOutPolicyUpdate.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "scaleOutPolicy") in
      let scaleInPolicy =
        ScaleInPolicyUpdate.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "scaleInPolicy") in
      let minWorkerCount =
        Zz__integer.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "minWorkerCount") in
      let mcuCount =
        Zz__integerMin1Max8.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "mcuCount") in
      let maxWorkerCount =
        Zz__integer.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "maxWorkerCount") in
      make ?maxAutoscalingTaskCount ~scaleOutPolicy ~scaleInPolicy
        ~minWorkerCount ~mcuCount ~maxWorkerCount ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let maxAutoscalingTaskCount =
        field_map json__ "maxAutoscalingTaskCount" Zz__integer.of_json in
      let scaleOutPolicy =
        field_map_exn json__ "scaleOutPolicy" ScaleOutPolicyUpdate.of_json in
      let scaleInPolicy =
        field_map_exn json__ "scaleInPolicy" ScaleInPolicyUpdate.of_json in
      let minWorkerCount =
        field_map_exn json__ "minWorkerCount" Zz__integer.of_json in
      let mcuCount =
        field_map_exn json__ "mcuCount" Zz__integerMin1Max8.of_json in
      let maxWorkerCount =
        field_map_exn json__ "maxWorkerCount" Zz__integer.of_json in
      make ?maxAutoscalingTaskCount ~scaleOutPolicy ~scaleInPolicy
        ~minWorkerCount ~mcuCount ~maxWorkerCount ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The updates to the auto scaling parameters for the connector."]
module ProvisionedCapacityUpdate =
  struct
    type nonrec t =
      {
      mcuCount: Zz__integerMin1Max8.t
        [@ocaml.doc
          "The number of microcontroller units (MCUs) allocated to each connector worker. The valid values are 1,2,4,8."];
      workerCount: Zz__integer.t
        [@ocaml.doc
          "The number of workers that are allocated to the connector."]}
    let context_ = "ProvisionedCapacityUpdate"
    let make ~mcuCount =
      fun ~workerCount -> fun () -> { mcuCount; workerCount }
    let to_value x =
      structure_to_value
        [("mcuCount", (Some (Zz__integerMin1Max8.to_value x.mcuCount)));
        ("workerCount", (Some (Zz__integer.to_value x.workerCount)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let workerCount =
        Zz__integer.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "workerCount") in
      let mcuCount =
        Zz__integerMin1Max8.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "mcuCount") in
      make ~workerCount ~mcuCount ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let workerCount =
        field_map_exn json__ "workerCount" Zz__integer.of_json in
      let mcuCount =
        field_map_exn json__ "mcuCount" Zz__integerMin1Max8.of_json in
      make ~workerCount ~mcuCount ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "An update to a connector's fixed capacity."]
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 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 WorkerConfigurationSummary =
  struct
    type nonrec t =
      {
      creationTime: Zz__timestampIso8601.t option
        [@ocaml.doc "The time that a worker configuration was created."];
      description: Zz__string.t option
        [@ocaml.doc "The description of a worker configuration."];
      latestRevision: WorkerConfigurationRevisionSummary.t option
        [@ocaml.doc "The latest revision of a worker configuration."];
      name: Zz__string.t option
        [@ocaml.doc "The name of the worker configuration."];
      workerConfigurationArn: Zz__string.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the worker configuration."];
      workerConfigurationState: WorkerConfigurationState.t option
        [@ocaml.doc "The state of the worker configuration."]}
    let make ?creationTime =
      fun ?description ->
        fun ?latestRevision ->
          fun ?name ->
            fun ?workerConfigurationArn ->
              fun ?workerConfigurationState ->
                fun () ->
                  {
                    creationTime;
                    description;
                    latestRevision;
                    name;
                    workerConfigurationArn;
                    workerConfigurationState
                  }
    let to_value x =
      structure_to_value
        [("creationTime",
           (Option.map x.creationTime ~f:Zz__timestampIso8601.to_value));
        ("description", (Option.map x.description ~f:Zz__string.to_value));
        ("latestRevision",
          (Option.map x.latestRevision
             ~f:WorkerConfigurationRevisionSummary.to_value));
        ("name", (Option.map x.name ~f:Zz__string.to_value));
        ("workerConfigurationArn",
          (Option.map x.workerConfigurationArn ~f:Zz__string.to_value));
        ("workerConfigurationState",
          (Option.map x.workerConfigurationState
             ~f:WorkerConfigurationState.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let workerConfigurationState =
        (Option.map ~f:WorkerConfigurationState.of_xml)
          (Xml.child xml_arg0 "workerConfigurationState") in
      let workerConfigurationArn =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "workerConfigurationArn") in
      let name =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "name") in
      let latestRevision =
        (Option.map ~f:WorkerConfigurationRevisionSummary.of_xml)
          (Xml.child xml_arg0 "latestRevision") in
      let description =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "description") in
      let creationTime =
        (Option.map ~f:Zz__timestampIso8601.of_xml)
          (Xml.child xml_arg0 "creationTime") in
      make ?workerConfigurationState ?workerConfigurationArn ?name
        ?latestRevision ?description ?creationTime ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let workerConfigurationState =
        field_map json__ "workerConfigurationState"
          WorkerConfigurationState.of_json in
      let workerConfigurationArn =
        field_map json__ "workerConfigurationArn" Zz__string.of_json in
      let name = field_map json__ "name" Zz__string.of_json in
      let latestRevision =
        field_map json__ "latestRevision"
          WorkerConfigurationRevisionSummary.of_json in
      let description = field_map json__ "description" Zz__string.of_json in
      let creationTime =
        field_map json__ "creationTime" Zz__timestampIso8601.of_json in
      make ?workerConfigurationState ?workerConfigurationArn ?name
        ?latestRevision ?description ?creationTime ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "The summary of a worker configuration."]
module CustomPluginSummary =
  struct
    type nonrec t =
      {
      creationTime: Zz__timestampIso8601.t option
        [@ocaml.doc "The time that the custom plugin was created."];
      customPluginArn: Zz__string.t option
        [@ocaml.doc "The Amazon Resource Name (ARN) of the custom plugin."];
      customPluginState: CustomPluginState.t option
        [@ocaml.doc "The state of the custom plugin."];
      description: Zz__string.t option
        [@ocaml.doc "A description of the custom plugin."];
      latestRevision: CustomPluginRevisionSummary.t option
        [@ocaml.doc "The latest revision of the custom plugin."];
      name: Zz__string.t option [@ocaml.doc "The name of the custom plugin."]}
    let make ?creationTime =
      fun ?customPluginArn ->
        fun ?customPluginState ->
          fun ?description ->
            fun ?latestRevision ->
              fun ?name ->
                fun () ->
                  {
                    creationTime;
                    customPluginArn;
                    customPluginState;
                    description;
                    latestRevision;
                    name
                  }
    let to_value x =
      structure_to_value
        [("creationTime",
           (Option.map x.creationTime ~f:Zz__timestampIso8601.to_value));
        ("customPluginArn",
          (Option.map x.customPluginArn ~f:Zz__string.to_value));
        ("customPluginState",
          (Option.map x.customPluginState ~f:CustomPluginState.to_value));
        ("description", (Option.map x.description ~f:Zz__string.to_value));
        ("latestRevision",
          (Option.map x.latestRevision
             ~f:CustomPluginRevisionSummary.to_value));
        ("name", (Option.map x.name ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let name =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "name") in
      let latestRevision =
        (Option.map ~f:CustomPluginRevisionSummary.of_xml)
          (Xml.child xml_arg0 "latestRevision") in
      let description =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "description") in
      let customPluginState =
        (Option.map ~f:CustomPluginState.of_xml)
          (Xml.child xml_arg0 "customPluginState") in
      let customPluginArn =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "customPluginArn") in
      let creationTime =
        (Option.map ~f:Zz__timestampIso8601.of_xml)
          (Xml.child xml_arg0 "creationTime") in
      make ?name ?latestRevision ?description ?customPluginState
        ?customPluginArn ?creationTime ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let name = field_map json__ "name" Zz__string.of_json in
      let latestRevision =
        field_map json__ "latestRevision" CustomPluginRevisionSummary.of_json in
      let description = field_map json__ "description" Zz__string.of_json in
      let customPluginState =
        field_map json__ "customPluginState" CustomPluginState.of_json in
      let customPluginArn =
        field_map json__ "customPluginArn" Zz__string.of_json in
      let creationTime =
        field_map json__ "creationTime" Zz__timestampIso8601.of_json in
      make ?name ?latestRevision ?description ?customPluginState
        ?customPluginArn ?creationTime ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "A summary of the custom plugin."]
module ConnectorSummary =
  struct
    type nonrec t =
      {
      capacity: CapacityDescription.t option
        [@ocaml.doc "The connector's compute capacity settings."];
      connectorArn: Zz__string.t option
        [@ocaml.doc "The Amazon Resource Name (ARN) of the connector."];
      connectorDescription: Zz__string.t option
        [@ocaml.doc "The description of the connector."];
      connectorName: Zz__string.t option
        [@ocaml.doc "The name of the connector."];
      connectorState: ConnectorState.t option
        [@ocaml.doc "The state of the connector."];
      creationTime: Zz__timestampIso8601.t option
        [@ocaml.doc "The time that the connector was created."];
      currentVersion: Zz__string.t option
        [@ocaml.doc "The current version of the connector."];
      kafkaCluster: KafkaClusterDescription.t option
        [@ocaml.doc
          "The details of the Apache Kafka cluster to which the connector is connected."];
      kafkaClusterClientAuthentication:
        KafkaClusterClientAuthenticationDescription.t option
        [@ocaml.doc
          "The type of client authentication used to connect to the Apache Kafka cluster. The value is NONE when no client authentication is used."];
      kafkaClusterEncryptionInTransit:
        KafkaClusterEncryptionInTransitDescription.t option
        [@ocaml.doc
          "Details of encryption in transit to the Apache Kafka cluster."];
      kafkaConnectVersion: Zz__string.t option
        [@ocaml.doc
          "The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins."];
      logDelivery: LogDeliveryDescription.t option
        [@ocaml.doc
          "The settings for delivering connector logs to Amazon CloudWatch Logs."];
      networkType: NetworkType.t option
        [@ocaml.doc
          "The network type of the connector. It gives connectors connectivity to either IPv4 (IPV4) or IPv4 and IPv6 (DUAL) destinations. Defaults to IPV4."];
      plugins: Zz__listOfPluginDescription.t option
        [@ocaml.doc "Specifies which plugins were used for this connector."];
      serviceExecutionRoleArn: Zz__string.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon Web Services resources."];
      workerConfiguration: WorkerConfigurationDescription.t option
        [@ocaml.doc
          "The worker configurations that are in use with the connector."]}
    let make ?capacity =
      fun ?connectorArn ->
        fun ?connectorDescription ->
          fun ?connectorName ->
            fun ?connectorState ->
              fun ?creationTime ->
                fun ?currentVersion ->
                  fun ?kafkaCluster ->
                    fun ?kafkaClusterClientAuthentication ->
                      fun ?kafkaClusterEncryptionInTransit ->
                        fun ?kafkaConnectVersion ->
                          fun ?logDelivery ->
                            fun ?networkType ->
                              fun ?plugins ->
                                fun ?serviceExecutionRoleArn ->
                                  fun ?workerConfiguration ->
                                    fun () ->
                                      {
                                        capacity;
                                        connectorArn;
                                        connectorDescription;
                                        connectorName;
                                        connectorState;
                                        creationTime;
                                        currentVersion;
                                        kafkaCluster;
                                        kafkaClusterClientAuthentication;
                                        kafkaClusterEncryptionInTransit;
                                        kafkaConnectVersion;
                                        logDelivery;
                                        networkType;
                                        plugins;
                                        serviceExecutionRoleArn;
                                        workerConfiguration
                                      }
    let to_value x =
      structure_to_value
        [("capacity",
           (Option.map x.capacity ~f:CapacityDescription.to_value));
        ("connectorArn", (Option.map x.connectorArn ~f:Zz__string.to_value));
        ("connectorDescription",
          (Option.map x.connectorDescription ~f:Zz__string.to_value));
        ("connectorName",
          (Option.map x.connectorName ~f:Zz__string.to_value));
        ("connectorState",
          (Option.map x.connectorState ~f:ConnectorState.to_value));
        ("creationTime",
          (Option.map x.creationTime ~f:Zz__timestampIso8601.to_value));
        ("currentVersion",
          (Option.map x.currentVersion ~f:Zz__string.to_value));
        ("kafkaCluster",
          (Option.map x.kafkaCluster ~f:KafkaClusterDescription.to_value));
        ("kafkaClusterClientAuthentication",
          (Option.map x.kafkaClusterClientAuthentication
             ~f:KafkaClusterClientAuthenticationDescription.to_value));
        ("kafkaClusterEncryptionInTransit",
          (Option.map x.kafkaClusterEncryptionInTransit
             ~f:KafkaClusterEncryptionInTransitDescription.to_value));
        ("kafkaConnectVersion",
          (Option.map x.kafkaConnectVersion ~f:Zz__string.to_value));
        ("logDelivery",
          (Option.map x.logDelivery ~f:LogDeliveryDescription.to_value));
        ("networkType", (Option.map x.networkType ~f:NetworkType.to_value));
        ("plugins",
          (Option.map x.plugins ~f:Zz__listOfPluginDescription.to_value));
        ("serviceExecutionRoleArn",
          (Option.map x.serviceExecutionRoleArn ~f:Zz__string.to_value));
        ("workerConfiguration",
          (Option.map x.workerConfiguration
             ~f:WorkerConfigurationDescription.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let workerConfiguration =
        (Option.map ~f:WorkerConfigurationDescription.of_xml)
          (Xml.child xml_arg0 "workerConfiguration") in
      let serviceExecutionRoleArn =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "serviceExecutionRoleArn") in
      let plugins =
        (Option.map ~f:Zz__listOfPluginDescription.of_xml)
          (Xml.child xml_arg0 "plugins") in
      let networkType =
        (Option.map ~f:NetworkType.of_xml) (Xml.child xml_arg0 "networkType") in
      let logDelivery =
        (Option.map ~f:LogDeliveryDescription.of_xml)
          (Xml.child xml_arg0 "logDelivery") in
      let kafkaConnectVersion =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "kafkaConnectVersion") in
      let kafkaClusterEncryptionInTransit =
        (Option.map ~f:KafkaClusterEncryptionInTransitDescription.of_xml)
          (Xml.child xml_arg0 "kafkaClusterEncryptionInTransit") in
      let kafkaClusterClientAuthentication =
        (Option.map ~f:KafkaClusterClientAuthenticationDescription.of_xml)
          (Xml.child xml_arg0 "kafkaClusterClientAuthentication") in
      let kafkaCluster =
        (Option.map ~f:KafkaClusterDescription.of_xml)
          (Xml.child xml_arg0 "kafkaCluster") in
      let currentVersion =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "currentVersion") in
      let creationTime =
        (Option.map ~f:Zz__timestampIso8601.of_xml)
          (Xml.child xml_arg0 "creationTime") in
      let connectorState =
        (Option.map ~f:ConnectorState.of_xml)
          (Xml.child xml_arg0 "connectorState") in
      let connectorName =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "connectorName") in
      let connectorDescription =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "connectorDescription") in
      let connectorArn =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "connectorArn") in
      let capacity =
        (Option.map ~f:CapacityDescription.of_xml)
          (Xml.child xml_arg0 "capacity") in
      make ?workerConfiguration ?serviceExecutionRoleArn ?plugins
        ?networkType ?logDelivery ?kafkaConnectVersion
        ?kafkaClusterEncryptionInTransit ?kafkaClusterClientAuthentication
        ?kafkaCluster ?currentVersion ?creationTime ?connectorState
        ?connectorName ?connectorDescription ?connectorArn ?capacity ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let workerConfiguration =
        field_map json__ "workerConfiguration"
          WorkerConfigurationDescription.of_json in
      let serviceExecutionRoleArn =
        field_map json__ "serviceExecutionRoleArn" Zz__string.of_json in
      let plugins =
        field_map json__ "plugins" Zz__listOfPluginDescription.of_json in
      let networkType = field_map json__ "networkType" NetworkType.of_json in
      let logDelivery =
        field_map json__ "logDelivery" LogDeliveryDescription.of_json in
      let kafkaConnectVersion =
        field_map json__ "kafkaConnectVersion" Zz__string.of_json in
      let kafkaClusterEncryptionInTransit =
        field_map json__ "kafkaClusterEncryptionInTransit"
          KafkaClusterEncryptionInTransitDescription.of_json in
      let kafkaClusterClientAuthentication =
        field_map json__ "kafkaClusterClientAuthentication"
          KafkaClusterClientAuthenticationDescription.of_json in
      let kafkaCluster =
        field_map json__ "kafkaCluster" KafkaClusterDescription.of_json in
      let currentVersion =
        field_map json__ "currentVersion" Zz__string.of_json in
      let creationTime =
        field_map json__ "creationTime" Zz__timestampIso8601.of_json in
      let connectorState =
        field_map json__ "connectorState" ConnectorState.of_json in
      let connectorName = field_map json__ "connectorName" Zz__string.of_json in
      let connectorDescription =
        field_map json__ "connectorDescription" Zz__string.of_json in
      let connectorArn = field_map json__ "connectorArn" Zz__string.of_json in
      let capacity = field_map json__ "capacity" CapacityDescription.of_json in
      make ?workerConfiguration ?serviceExecutionRoleArn ?plugins
        ?networkType ?logDelivery ?kafkaConnectVersion
        ?kafkaClusterEncryptionInTransit ?kafkaClusterClientAuthentication
        ?kafkaCluster ?currentVersion ?creationTime ?connectorState
        ?connectorName ?connectorDescription ?connectorArn ?capacity ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Summary of a connector."]
module ConnectorOperationSummary =
  struct
    type nonrec t =
      {
      connectorOperationArn: Zz__string.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the connector operation."];
      connectorOperationType: ConnectorOperationType.t option
        [@ocaml.doc "The type of connector operation performed."];
      connectorOperationState: ConnectorOperationState.t option
        [@ocaml.doc "The state of the connector operation."];
      creationTime: Zz__timestampIso8601.t option
        [@ocaml.doc "The time when operation was created."];
      endTime: Zz__timestampIso8601.t option
        [@ocaml.doc "The time when operation ended."]}
    let make ?connectorOperationArn =
      fun ?connectorOperationType ->
        fun ?connectorOperationState ->
          fun ?creationTime ->
            fun ?endTime ->
              fun () ->
                {
                  connectorOperationArn;
                  connectorOperationType;
                  connectorOperationState;
                  creationTime;
                  endTime
                }
    let to_value x =
      structure_to_value
        [("connectorOperationArn",
           (Option.map x.connectorOperationArn ~f:Zz__string.to_value));
        ("connectorOperationType",
          (Option.map x.connectorOperationType
             ~f:ConnectorOperationType.to_value));
        ("connectorOperationState",
          (Option.map x.connectorOperationState
             ~f:ConnectorOperationState.to_value));
        ("creationTime",
          (Option.map x.creationTime ~f:Zz__timestampIso8601.to_value));
        ("endTime", (Option.map x.endTime ~f:Zz__timestampIso8601.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let endTime =
        (Option.map ~f:Zz__timestampIso8601.of_xml)
          (Xml.child xml_arg0 "endTime") in
      let creationTime =
        (Option.map ~f:Zz__timestampIso8601.of_xml)
          (Xml.child xml_arg0 "creationTime") in
      let connectorOperationState =
        (Option.map ~f:ConnectorOperationState.of_xml)
          (Xml.child xml_arg0 "connectorOperationState") in
      let connectorOperationType =
        (Option.map ~f:ConnectorOperationType.of_xml)
          (Xml.child xml_arg0 "connectorOperationType") in
      let connectorOperationArn =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "connectorOperationArn") in
      make ?endTime ?creationTime ?connectorOperationState
        ?connectorOperationType ?connectorOperationArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let endTime = field_map json__ "endTime" Zz__timestampIso8601.of_json in
      let creationTime =
        field_map json__ "creationTime" Zz__timestampIso8601.of_json in
      let connectorOperationState =
        field_map json__ "connectorOperationState"
          ConnectorOperationState.of_json in
      let connectorOperationType =
        field_map json__ "connectorOperationType"
          ConnectorOperationType.of_json in
      let connectorOperationArn =
        field_map json__ "connectorOperationArn" Zz__string.of_json in
      make ?endTime ?creationTime ?connectorOperationState
        ?connectorOperationType ?connectorOperationArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Summary of a connector operation."]
module Zz__sensitiveString =
  struct
    type nonrec t = string
    let context_ = "__sensitiveString"
    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:"__sensitiveString" j
    let to_json = simple_to_json to_value
  end
module ConnectorOperationStep =
  struct
    type nonrec t =
      {
      stepType: ConnectorOperationStepType.t option
        [@ocaml.doc "The step type of the operation."];
      stepState: ConnectorOperationStepState.t option
        [@ocaml.doc "The step state of the operation."]}
    let make ?stepType = fun ?stepState -> fun () -> { stepType; stepState }
    let to_value x =
      structure_to_value
        [("stepType",
           (Option.map x.stepType ~f:ConnectorOperationStepType.to_value));
        ("stepState",
          (Option.map x.stepState ~f:ConnectorOperationStepState.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let stepState =
        (Option.map ~f:ConnectorOperationStepState.of_xml)
          (Xml.child xml_arg0 "stepState") in
      let stepType =
        (Option.map ~f:ConnectorOperationStepType.of_xml)
          (Xml.child xml_arg0 "stepType") in
      make ?stepState ?stepType ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let stepState =
        field_map json__ "stepState" ConnectorOperationStepState.of_json in
      let stepType =
        field_map json__ "stepType" ConnectorOperationStepType.of_json in
      make ?stepState ?stepType ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Details of a step that is involved in a connector's operation."]
module S3Location =
  struct
    type nonrec t =
      {
      bucketArn: Zz__string.t
        [@ocaml.doc "The Amazon Resource Name (ARN) of an S3 bucket."];
      fileKey: Zz__string.t
        [@ocaml.doc "The file key for an object in an S3 bucket."];
      objectVersion: Zz__string.t option
        [@ocaml.doc "The version of an object in an S3 bucket."]}
    let context_ = "S3Location"
    let make ?objectVersion =
      fun ~bucketArn ->
        fun ~fileKey -> fun () -> { objectVersion; bucketArn; fileKey }
    let to_value x =
      structure_to_value
        [("bucketArn", (Some (Zz__string.to_value x.bucketArn)));
        ("fileKey", (Some (Zz__string.to_value x.fileKey)));
        ("objectVersion",
          (Option.map x.objectVersion ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let objectVersion =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "objectVersion") in
      let fileKey =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "fileKey") in
      let bucketArn =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "bucketArn") in
      make ?objectVersion ~fileKey ~bucketArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let objectVersion = field_map json__ "objectVersion" Zz__string.of_json in
      let fileKey = field_map_exn json__ "fileKey" Zz__string.of_json in
      let bucketArn = field_map_exn json__ "bucketArn" Zz__string.of_json in
      make ?objectVersion ~fileKey ~bucketArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "The location of an object in Amazon S3."]
module AutoScaling =
  struct
    type nonrec t =
      {
      maxWorkerCount: Zz__integer.t
        [@ocaml.doc
          "The maximum number of workers allocated to the connector."];
      mcuCount: Zz__integerMin1Max8.t
        [@ocaml.doc
          "The number of microcontroller units (MCUs) allocated to each connector worker. The valid values are 1,2,4,8."];
      minWorkerCount: Zz__integer.t
        [@ocaml.doc
          "The minimum number of workers allocated to the connector."];
      scaleInPolicy: ScaleInPolicy.t option
        [@ocaml.doc "The scale-in policy for the connector."];
      scaleOutPolicy: ScaleOutPolicy.t option
        [@ocaml.doc "The scale-out policy for the connector."];
      maxAutoscalingTaskCount: Zz__integer.t option
        [@ocaml.doc
          "The maximum number of tasks allocated to the connector during autoscaling operations. Must be at least equal to maxWorkerCount."]}
    let context_ = "AutoScaling"
    let make ?scaleInPolicy =
      fun ?scaleOutPolicy ->
        fun ?maxAutoscalingTaskCount ->
          fun ~maxWorkerCount ->
            fun ~mcuCount ->
              fun ~minWorkerCount ->
                fun () ->
                  {
                    scaleInPolicy;
                    scaleOutPolicy;
                    maxAutoscalingTaskCount;
                    maxWorkerCount;
                    mcuCount;
                    minWorkerCount
                  }
    let to_value x =
      structure_to_value
        [("maxWorkerCount", (Some (Zz__integer.to_value x.maxWorkerCount)));
        ("mcuCount", (Some (Zz__integerMin1Max8.to_value x.mcuCount)));
        ("minWorkerCount", (Some (Zz__integer.to_value x.minWorkerCount)));
        ("scaleInPolicy",
          (Option.map x.scaleInPolicy ~f:ScaleInPolicy.to_value));
        ("scaleOutPolicy",
          (Option.map x.scaleOutPolicy ~f:ScaleOutPolicy.to_value));
        ("maxAutoscalingTaskCount",
          (Option.map x.maxAutoscalingTaskCount ~f:Zz__integer.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let maxAutoscalingTaskCount =
        (Option.map ~f:Zz__integer.of_xml)
          (Xml.child xml_arg0 "maxAutoscalingTaskCount") in
      let scaleOutPolicy =
        (Option.map ~f:ScaleOutPolicy.of_xml)
          (Xml.child xml_arg0 "scaleOutPolicy") in
      let scaleInPolicy =
        (Option.map ~f:ScaleInPolicy.of_xml)
          (Xml.child xml_arg0 "scaleInPolicy") in
      let minWorkerCount =
        Zz__integer.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "minWorkerCount") in
      let mcuCount =
        Zz__integerMin1Max8.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "mcuCount") in
      let maxWorkerCount =
        Zz__integer.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "maxWorkerCount") in
      make ?maxAutoscalingTaskCount ?scaleOutPolicy ?scaleInPolicy
        ~minWorkerCount ~mcuCount ~maxWorkerCount ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let maxAutoscalingTaskCount =
        field_map json__ "maxAutoscalingTaskCount" Zz__integer.of_json in
      let scaleOutPolicy =
        field_map json__ "scaleOutPolicy" ScaleOutPolicy.of_json in
      let scaleInPolicy =
        field_map json__ "scaleInPolicy" ScaleInPolicy.of_json in
      let minWorkerCount =
        field_map_exn json__ "minWorkerCount" Zz__integer.of_json in
      let mcuCount =
        field_map_exn json__ "mcuCount" Zz__integerMin1Max8.of_json in
      let maxWorkerCount =
        field_map_exn json__ "maxWorkerCount" Zz__integer.of_json in
      make ?maxAutoscalingTaskCount ?scaleOutPolicy ?scaleInPolicy
        ~minWorkerCount ~mcuCount ~maxWorkerCount ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Specifies how the connector scales."]
module ProvisionedCapacity =
  struct
    type nonrec t =
      {
      mcuCount: Zz__integerMin1Max8.t
        [@ocaml.doc
          "The number of microcontroller units (MCUs) allocated to each connector worker. The valid values are 1,2,4,8."];
      workerCount: Zz__integer.t
        [@ocaml.doc
          "The number of workers that are allocated to the connector."]}
    let context_ = "ProvisionedCapacity"
    let make ~mcuCount =
      fun ~workerCount -> fun () -> { mcuCount; workerCount }
    let to_value x =
      structure_to_value
        [("mcuCount", (Some (Zz__integerMin1Max8.to_value x.mcuCount)));
        ("workerCount", (Some (Zz__integer.to_value x.workerCount)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let workerCount =
        Zz__integer.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "workerCount") in
      let mcuCount =
        Zz__integerMin1Max8.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "mcuCount") in
      make ~workerCount ~mcuCount ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let workerCount =
        field_map_exn json__ "workerCount" Zz__integer.of_json in
      let mcuCount =
        field_map_exn json__ "mcuCount" Zz__integerMin1Max8.of_json in
      make ~workerCount ~mcuCount ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Details about a connector's provisioned capacity."]
module ApacheKafkaCluster =
  struct
    type nonrec t =
      {
      bootstrapServers: Zz__string.t
        [@ocaml.doc "The bootstrap servers of the cluster."];
      vpc: Vpc.t
        [@ocaml.doc
          "Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster."]}
    let context_ = "ApacheKafkaCluster"
    let make ~bootstrapServers =
      fun ~vpc -> fun () -> { bootstrapServers; vpc }
    let to_value x =
      structure_to_value
        [("bootstrapServers",
           (Some (Zz__string.to_value x.bootstrapServers)));
        ("vpc", (Some (Vpc.to_value x.vpc)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let vpc = Vpc.of_xml (Xml.child_exn ~context:context_ xml_arg0 "vpc") in
      let bootstrapServers =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "bootstrapServers") in
      make ~vpc ~bootstrapServers ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let vpc = field_map_exn json__ "vpc" Vpc.of_json in
      let bootstrapServers =
        field_map_exn json__ "bootstrapServers" Zz__string.of_json in
      make ~vpc ~bootstrapServers ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The details of the Apache Kafka cluster to which the connector is connected."]
module WorkerLogDelivery =
  struct
    type nonrec t =
      {
      cloudWatchLogs: CloudWatchLogsLogDelivery.t option
        [@ocaml.doc
          "Details about delivering logs to Amazon CloudWatch Logs."];
      firehose: FirehoseLogDelivery.t option
        [@ocaml.doc
          "Details about delivering logs to Amazon Kinesis Data Firehose."];
      s3: S3LogDelivery.t option
        [@ocaml.doc "Details about delivering logs to Amazon S3."]}
    let make ?cloudWatchLogs =
      fun ?firehose -> fun ?s3 -> fun () -> { cloudWatchLogs; firehose; s3 }
    let to_value x =
      structure_to_value
        [("cloudWatchLogs",
           (Option.map x.cloudWatchLogs ~f:CloudWatchLogsLogDelivery.to_value));
        ("firehose", (Option.map x.firehose ~f:FirehoseLogDelivery.to_value));
        ("s3", (Option.map x.s3 ~f:S3LogDelivery.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let s3 = (Option.map ~f:S3LogDelivery.of_xml) (Xml.child xml_arg0 "s3") in
      let firehose =
        (Option.map ~f:FirehoseLogDelivery.of_xml)
          (Xml.child xml_arg0 "firehose") in
      let cloudWatchLogs =
        (Option.map ~f:CloudWatchLogsLogDelivery.of_xml)
          (Xml.child xml_arg0 "cloudWatchLogs") in
      make ?s3 ?firehose ?cloudWatchLogs ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let s3 = field_map json__ "s3" S3LogDelivery.of_json in
      let firehose = field_map json__ "firehose" FirehoseLogDelivery.of_json in
      let cloudWatchLogs =
        field_map json__ "cloudWatchLogs" CloudWatchLogsLogDelivery.of_json in
      make ?s3 ?firehose ?cloudWatchLogs ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Workers can send worker logs to different destination types. This configuration specifies the details of these destinations."]
module Plugin =
  struct
    type nonrec t =
      {
      customPlugin: CustomPlugin.t
        [@ocaml.doc "Details about a custom plugin."]}
    let context_ = "Plugin"
    let make ~customPlugin = fun () -> { customPlugin }
    let to_value x =
      structure_to_value
        [("customPlugin", (Some (CustomPlugin.to_value x.customPlugin)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let customPlugin =
        CustomPlugin.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "customPlugin") in
      make ~customPlugin ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let customPlugin =
        field_map_exn json__ "customPlugin" CustomPlugin.of_json in
      make ~customPlugin ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "A plugin is an Amazon Web Services resource that contains the code that defines your connector logic."]
module BadRequestException =
  struct
    type nonrec t = {
      message: Zz__string.t option }
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("message", (Option.map x.message ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:Zz__string.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" Zz__string.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it."]
module ForbiddenException =
  struct
    type nonrec t = {
      message: Zz__string.t option }
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("message", (Option.map x.message ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:Zz__string.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" Zz__string.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request."]
module InternalServerErrorException =
  struct
    type nonrec t = {
      message: Zz__string.t option }
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("message", (Option.map x.message ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:Zz__string.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" Zz__string.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue."]
module NotFoundException =
  struct
    type nonrec t = {
      message: Zz__string.t option }
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("message", (Option.map x.message ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:Zz__string.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" Zz__string.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it."]
module ServiceUnavailableException =
  struct
    type nonrec t = {
      message: Zz__string.t option }
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("message", (Option.map x.message ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:Zz__string.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" Zz__string.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue."]
module TooManyRequestsException =
  struct
    type nonrec t = {
      message: Zz__string.t option }
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("message", (Option.map x.message ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:Zz__string.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" Zz__string.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "HTTP Status Code 429: Limit exceeded. Resource limit reached."]
module UnauthorizedException =
  struct
    type nonrec t = {
      message: Zz__string.t option }
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("message", (Option.map x.message ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:Zz__string.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" Zz__string.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated."]
module CapacityUpdate =
  struct
    type nonrec t =
      {
      autoScaling: AutoScalingUpdate.t option
        [@ocaml.doc "The target auto scaling setting."];
      provisionedCapacity: ProvisionedCapacityUpdate.t option
        [@ocaml.doc "The target settings for provisioned capacity."]}
    let make ?autoScaling =
      fun ?provisionedCapacity ->
        fun () -> { autoScaling; provisionedCapacity }
    let to_value x =
      structure_to_value
        [("autoScaling",
           (Option.map x.autoScaling ~f:AutoScalingUpdate.to_value));
        ("provisionedCapacity",
          (Option.map x.provisionedCapacity
             ~f:ProvisionedCapacityUpdate.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let provisionedCapacity =
        (Option.map ~f:ProvisionedCapacityUpdate.of_xml)
          (Xml.child xml_arg0 "provisionedCapacity") in
      let autoScaling =
        (Option.map ~f:AutoScalingUpdate.of_xml)
          (Xml.child xml_arg0 "autoScaling") in
      make ?provisionedCapacity ?autoScaling ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let provisionedCapacity =
        field_map json__ "provisionedCapacity"
          ProvisionedCapacityUpdate.of_json in
      let autoScaling =
        field_map json__ "autoScaling" AutoScalingUpdate.of_json in
      make ?provisionedCapacity ?autoScaling ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The target capacity for the connector. The capacity can be auto scaled or provisioned."]
module ConnectorConfigurationUpdate =
  struct
    type nonrec t = (Zz__string.t * Zz__string.t) list
    let make i = i
    let of_header xs =
      make
        (List.filter_map xs
           ~f:(fun (k, v) ->
                 (Base.String.chop_prefix k ~prefix:"x-amz-meta-") |>
                   (Option.map
                      ~f:(fun chopped ->
                            ((Zz__string.of_string chopped),
                              (Zz__string.of_string v))))))
    let to_value xs =
      (xs |>
         (List.map
            ~f:(fun (x, y) ->
                  (Zz__string.to_value x) |>
                    (fun x -> (Zz__string.to_value y) |> (fun y -> (x, y))))))
        |> (fun x -> `Map x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for Map_shape objects" ()
    let of_xml _ =
      failwith "of_xml_converter_of_shape: Map_shape case not implemented"
    let of_json j =
      object_of_json ~key_of_string:Zz__string.of_string
        ~of_json:Zz__string.of_json j
    let to_json v = composed_to_json to_value v
  end
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 ConflictException =
  struct
    type nonrec t = {
      message: Zz__string.t option }
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("message", (Option.map x.message ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:Zz__string.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" Zz__string.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your request with another name."]
module Tags =
  struct
    type nonrec t = (TagKey.t * TagValue.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_header xs =
      make
        (List.filter_map xs
           ~f:(fun (k, v) ->
                 (Base.String.chop_prefix k ~prefix:"x-amz-meta-") |>
                   (Option.map
                      ~f:(fun chopped ->
                            ((TagKey.of_string chopped),
                              (TagValue.of_string v))))))
    let to_value xs =
      (xs |>
         (List.map
            ~f:(fun (x, y) ->
                  (TagKey.to_value x) |>
                    (fun x -> (TagValue.to_value y) |> (fun y -> (x, y))))))
        |> (fun x -> `Map x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for Map_shape objects" ()
    let of_xml _ =
      failwith "of_xml_converter_of_shape: Map_shape case not implemented"
    let of_json j =
      object_of_json ~key_of_string:TagKey.of_string
        ~of_json:TagValue.of_json j
    let to_json v = composed_to_json to_value v
  end
module Zz__listOfWorkerConfigurationSummary =
  struct
    type nonrec t = WorkerConfigurationSummary.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:WorkerConfigurationSummary.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:WorkerConfigurationSummary.of_xml)
    let of_json j =
      list_of_json ~kind:"__listOfWorkerConfigurationSummary"
        ~of_json:WorkerConfigurationSummary.of_json j
    let to_json v = composed_to_json to_value v
  end
module MaxResults =
  struct
    type nonrec t = int
    let make i =
      let open Result in
        ok_or_failwith
          ((check_int_max i ~max:100) >>= (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 MaxResults" 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 Zz__listOfCustomPluginSummary =
  struct
    type nonrec t = CustomPluginSummary.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:CustomPluginSummary.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:CustomPluginSummary.of_xml)
    let of_json j =
      list_of_json ~kind:"__listOfCustomPluginSummary"
        ~of_json:CustomPluginSummary.of_json j
    let to_json v = composed_to_json to_value v
  end
module Zz__listOfConnectorSummary =
  struct
    type nonrec t = ConnectorSummary.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:ConnectorSummary.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:ConnectorSummary.of_xml)
    let of_json j =
      list_of_json ~kind:"__listOfConnectorSummary"
        ~of_json:ConnectorSummary.of_json j
    let to_json v = composed_to_json to_value v
  end
module Zz__listOfConnectorOperationSummary =
  struct
    type nonrec t = ConnectorOperationSummary.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:ConnectorOperationSummary.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:ConnectorOperationSummary.of_xml)
    let of_json j =
      list_of_json ~kind:"__listOfConnectorOperationSummary"
        ~of_json:ConnectorOperationSummary.of_json j
    let to_json v = composed_to_json to_value v
  end
module WorkerConfigurationRevisionDescription =
  struct
    type nonrec t =
      {
      creationTime: Zz__timestampIso8601.t option
        [@ocaml.doc "The time that the worker configuration was created."];
      description: Zz__string.t option
        [@ocaml.doc "The description of the worker configuration revision."];
      propertiesFileContent: Zz__sensitiveString.t option
        [@ocaml.doc
          "Base64 encoded contents of the connect-distributed.properties file."];
      revision: Zz__long.t option
        [@ocaml.doc
          "The description of a revision of the worker configuration."]}
    let make ?creationTime =
      fun ?description ->
        fun ?propertiesFileContent ->
          fun ?revision ->
            fun () ->
              { creationTime; description; propertiesFileContent; revision }
    let to_value x =
      structure_to_value
        [("creationTime",
           (Option.map x.creationTime ~f:Zz__timestampIso8601.to_value));
        ("description", (Option.map x.description ~f:Zz__string.to_value));
        ("propertiesFileContent",
          (Option.map x.propertiesFileContent ~f:Zz__sensitiveString.to_value));
        ("revision", (Option.map x.revision ~f:Zz__long.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let revision =
        (Option.map ~f:Zz__long.of_xml) (Xml.child xml_arg0 "revision") in
      let propertiesFileContent =
        (Option.map ~f:Zz__sensitiveString.of_xml)
          (Xml.child xml_arg0 "propertiesFileContent") in
      let description =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "description") in
      let creationTime =
        (Option.map ~f:Zz__timestampIso8601.of_xml)
          (Xml.child xml_arg0 "creationTime") in
      make ?revision ?propertiesFileContent ?description ?creationTime ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let revision = field_map json__ "revision" Zz__long.of_json in
      let propertiesFileContent =
        field_map json__ "propertiesFileContent" Zz__sensitiveString.of_json in
      let description = field_map json__ "description" Zz__string.of_json in
      let creationTime =
        field_map json__ "creationTime" Zz__timestampIso8601.of_json in
      make ?revision ?propertiesFileContent ?description ?creationTime ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "The description of the worker configuration revision."]
module StateDescription =
  struct
    type nonrec t =
      {
      code: Zz__string.t option
        [@ocaml.doc "A code that describes the state of a resource."];
      message: Zz__string.t option
        [@ocaml.doc "A message that describes the state of a resource."]}
    let make ?code = fun ?message -> fun () -> { code; message }
    let to_value x =
      structure_to_value
        [("code", (Option.map x.code ~f:Zz__string.to_value));
        ("message", (Option.map x.message ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "message") in
      let code =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "code") in
      make ?message ?code ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let message = field_map json__ "message" Zz__string.of_json in
      let code = field_map json__ "code" Zz__string.of_json in
      make ?message ?code ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Details about the state of a resource."]
module ConnectorConfiguration =
  struct
    type nonrec t = (Zz__string.t * Zz__string.t) list
    let make i = i
    let of_header xs =
      make
        (List.filter_map xs
           ~f:(fun (k, v) ->
                 (Base.String.chop_prefix k ~prefix:"x-amz-meta-") |>
                   (Option.map
                      ~f:(fun chopped ->
                            ((Zz__string.of_string chopped),
                              (Zz__string.of_string v))))))
    let to_value xs =
      (xs |>
         (List.map
            ~f:(fun (x, y) ->
                  (Zz__string.to_value x) |>
                    (fun x -> (Zz__string.to_value y) |> (fun y -> (x, y))))))
        |> (fun x -> `Map x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for Map_shape objects" ()
    let of_xml _ =
      failwith "of_xml_converter_of_shape: Map_shape case not implemented"
    let of_json j =
      object_of_json ~key_of_string:Zz__string.of_string
        ~of_json:Zz__string.of_json j
    let to_json v = composed_to_json to_value v
  end
module WorkerSetting =
  struct
    type nonrec t = {
      capacity: CapacityDescription.t option }
    let make ?capacity = fun () -> { capacity }
    let to_value x =
      structure_to_value
        [("capacity",
           (Option.map x.capacity ~f:CapacityDescription.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let capacity =
        (Option.map ~f:CapacityDescription.of_xml)
          (Xml.child xml_arg0 "capacity") in
      make ?capacity ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let capacity = field_map json__ "capacity" CapacityDescription.of_json in
      make ?capacity ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Details about worker setting of a connector"]
module Zz__listOfConnectorOperationStep =
  struct
    type nonrec t = ConnectorOperationStep.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:ConnectorOperationStep.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:ConnectorOperationStep.of_xml)
    let of_json j =
      list_of_json ~kind:"__listOfConnectorOperationStep"
        ~of_json:ConnectorOperationStep.of_json j
    let to_json v = composed_to_json to_value v
  end
module Zz__stringMax1024 =
  struct
    type nonrec t = string
    let context_ = "__stringMax1024"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_max i ~max:1024) >>=
             (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:"__stringMax1024" j
    let to_json = simple_to_json to_value
  end
module Zz__stringMin1Max128 =
  struct
    type nonrec t = string
    let context_ = "__stringMin1Max128"
    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:"__stringMin1Max128" j
    let to_json = simple_to_json to_value
  end
module CustomPluginLocation =
  struct
    type nonrec t =
      {
      s3Location: S3Location.t
        [@ocaml.doc
          "The S3 bucket Amazon Resource Name (ARN), file key, and object version of the plugin file stored in Amazon S3."]}
    let context_ = "CustomPluginLocation"
    let make ~s3Location = fun () -> { s3Location }
    let to_value x =
      structure_to_value
        [("s3Location", (Some (S3Location.to_value x.s3Location)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let s3Location =
        S3Location.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "s3Location") in
      make ~s3Location ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let s3Location = field_map_exn json__ "s3Location" S3Location.of_json in
      make ~s3Location ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Information about the location of a custom plugin."]
module Capacity =
  struct
    type nonrec t =
      {
      autoScaling: AutoScaling.t option
        [@ocaml.doc
          "Information about the auto scaling parameters for the connector."];
      provisionedCapacity: ProvisionedCapacity.t option
        [@ocaml.doc
          "Details about a fixed capacity allocated to a connector."]}
    let make ?autoScaling =
      fun ?provisionedCapacity ->
        fun () -> { autoScaling; provisionedCapacity }
    let to_value x =
      structure_to_value
        [("autoScaling", (Option.map x.autoScaling ~f:AutoScaling.to_value));
        ("provisionedCapacity",
          (Option.map x.provisionedCapacity ~f:ProvisionedCapacity.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let provisionedCapacity =
        (Option.map ~f:ProvisionedCapacity.of_xml)
          (Xml.child xml_arg0 "provisionedCapacity") in
      let autoScaling =
        (Option.map ~f:AutoScaling.of_xml) (Xml.child xml_arg0 "autoScaling") in
      make ?provisionedCapacity ?autoScaling ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let provisionedCapacity =
        field_map json__ "provisionedCapacity" ProvisionedCapacity.of_json in
      let autoScaling = field_map json__ "autoScaling" AutoScaling.of_json in
      make ?provisionedCapacity ?autoScaling ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Information about the capacity of the connector, whether it is auto scaled or provisioned."]
module KafkaCluster =
  struct
    type nonrec t =
      {
      apacheKafkaCluster: ApacheKafkaCluster.t
        [@ocaml.doc
          "The Apache Kafka cluster to which the connector is connected."]}
    let context_ = "KafkaCluster"
    let make ~apacheKafkaCluster = fun () -> { apacheKafkaCluster }
    let to_value x =
      structure_to_value
        [("apacheKafkaCluster",
           (Some (ApacheKafkaCluster.to_value x.apacheKafkaCluster)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let apacheKafkaCluster =
        ApacheKafkaCluster.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "apacheKafkaCluster") in
      make ~apacheKafkaCluster ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let apacheKafkaCluster =
        field_map_exn json__ "apacheKafkaCluster" ApacheKafkaCluster.of_json in
      make ~apacheKafkaCluster ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The details of the Apache Kafka cluster to which the connector is connected."]
module KafkaClusterClientAuthentication =
  struct
    type nonrec t =
      {
      authenticationType: KafkaClusterClientAuthenticationType.t
        [@ocaml.doc
          "The type of client authentication used to connect to the Apache Kafka cluster. Value NONE means that no client authentication is used."]}
    let context_ = "KafkaClusterClientAuthentication"
    let make ~authenticationType = fun () -> { authenticationType }
    let to_value x =
      structure_to_value
        [("authenticationType",
           (Some
              (KafkaClusterClientAuthenticationType.to_value
                 x.authenticationType)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let authenticationType =
        KafkaClusterClientAuthenticationType.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "authenticationType") in
      make ~authenticationType ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let authenticationType =
        field_map_exn json__ "authenticationType"
          KafkaClusterClientAuthenticationType.of_json in
      make ~authenticationType ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The client authentication information used in order to authenticate with the Apache Kafka cluster."]
module KafkaClusterEncryptionInTransit =
  struct
    type nonrec t =
      {
      encryptionType: KafkaClusterEncryptionInTransitType.t
        [@ocaml.doc
          "The type of encryption in transit to the Apache Kafka cluster."]}
    let context_ = "KafkaClusterEncryptionInTransit"
    let make ~encryptionType = fun () -> { encryptionType }
    let to_value x =
      structure_to_value
        [("encryptionType",
           (Some
              (KafkaClusterEncryptionInTransitType.to_value x.encryptionType)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let encryptionType =
        KafkaClusterEncryptionInTransitType.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "encryptionType") in
      make ~encryptionType ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let encryptionType =
        field_map_exn json__ "encryptionType"
          KafkaClusterEncryptionInTransitType.of_json in
      make ~encryptionType ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Details of encryption in transit to the Apache Kafka cluster."]
module LogDelivery =
  struct
    type nonrec t =
      {
      workerLogDelivery: WorkerLogDelivery.t
        [@ocaml.doc
          "The workers can send worker logs to different destination types. This configuration specifies the details of these destinations."]}
    let context_ = "LogDelivery"
    let make ~workerLogDelivery = fun () -> { workerLogDelivery }
    let to_value x =
      structure_to_value
        [("workerLogDelivery",
           (Some (WorkerLogDelivery.to_value x.workerLogDelivery)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let workerLogDelivery =
        WorkerLogDelivery.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "workerLogDelivery") in
      make ~workerLogDelivery ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let workerLogDelivery =
        field_map_exn json__ "workerLogDelivery" WorkerLogDelivery.of_json in
      make ~workerLogDelivery ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Details about log delivery."]
module WorkerConfiguration =
  struct
    type nonrec t =
      {
      revision: Zz__longMin1.t
        [@ocaml.doc "The revision of the worker configuration."];
      workerConfigurationArn: Zz__string.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the worker configuration."]}
    let context_ = "WorkerConfiguration"
    let make ~revision =
      fun ~workerConfigurationArn ->
        fun () -> { revision; workerConfigurationArn }
    let to_value x =
      structure_to_value
        [("revision", (Some (Zz__longMin1.to_value x.revision)));
        ("workerConfigurationArn",
          (Some (Zz__string.to_value x.workerConfigurationArn)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let workerConfigurationArn =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "workerConfigurationArn") in
      let revision =
        Zz__longMin1.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "revision") in
      make ~workerConfigurationArn ~revision ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let workerConfigurationArn =
        field_map_exn json__ "workerConfigurationArn" Zz__string.of_json in
      let revision = field_map_exn json__ "revision" Zz__longMin1.of_json in
      make ~workerConfigurationArn ~revision ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The configuration of the workers, which are the processes that run the connector logic."]
module Zz__listOfPlugin =
  struct
    type nonrec t = Plugin.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:Plugin.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:Plugin.of_xml)
    let of_json j =
      list_of_json ~kind:"__listOfPlugin" ~of_json:Plugin.of_json j
    let to_json v = composed_to_json to_value v
  end
module UpdateConnectorResponse =
  struct
    type nonrec t =
      {
      connectorArn: Zz__string.t option
        [@ocaml.doc "The Amazon Resource Name (ARN) of the connector."];
      connectorState: ConnectorState.t option
        [@ocaml.doc "The state of the connector."];
      connectorOperationArn: Zz__string.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the connector operation."]}
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?connectorArn =
      fun ?connectorState ->
        fun ?connectorOperationArn ->
          fun () -> { connectorArn; connectorState; connectorOperationArn }
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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
        [("connectorArn", (Option.map x.connectorArn ~f:Zz__string.to_value));
        ("connectorState",
          (Option.map x.connectorState ~f:ConnectorState.to_value));
        ("connectorOperationArn",
          (Option.map x.connectorOperationArn ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let connectorOperationArn =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "connectorOperationArn") in
      let connectorState =
        (Option.map ~f:ConnectorState.of_xml)
          (Xml.child xml_arg0 "connectorState") in
      let connectorArn =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "connectorArn") in
      make ?connectorOperationArn ?connectorState ?connectorArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let connectorOperationArn =
        field_map json__ "connectorOperationArn" Zz__string.of_json in
      let connectorState =
        field_map json__ "connectorState" ConnectorState.of_json in
      let connectorArn = field_map json__ "connectorArn" Zz__string.of_json in
      make ?connectorOperationArn ?connectorState ?connectorArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Updates the specified connector. For request body, specify only one parameter: either capacity or connectorConfiguration."]
module UpdateConnectorRequest =
  struct
    type nonrec t =
      {
      capacity: CapacityUpdate.t option [@ocaml.doc "The target capacity."];
      connectorConfiguration: ConnectorConfigurationUpdate.t option
        [@ocaml.doc
          "A map of keys to values that represent the configuration for the connector."];
      connectorArn: Zz__string.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the connector that you want to update."];
      currentVersion: Zz__string.t
        [@ocaml.doc
          "The current version of the connector that you want to update."]}
    let context_ = "UpdateConnectorRequest"
    let make ?capacity =
      fun ?connectorConfiguration ->
        fun ~connectorArn ->
          fun ~currentVersion ->
            fun () ->
              {
                capacity;
                connectorConfiguration;
                connectorArn;
                currentVersion
              }
    let to_value x =
      structure_to_value
        [("capacity", (Option.map x.capacity ~f:CapacityUpdate.to_value));
        ("connectorConfiguration",
          (Option.map x.connectorConfiguration
             ~f:ConnectorConfigurationUpdate.to_value));
        ("connectorArn", (Some (Zz__string.to_value x.connectorArn)));
        ("currentVersion", (Some (Zz__string.to_value x.currentVersion)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let currentVersion =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "currentVersion") in
      let connectorArn =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "connectorArn") in
      let connectorConfiguration =
        (Option.map ~f:ConnectorConfigurationUpdate.of_xml)
          (Xml.child xml_arg0 "connectorConfiguration") in
      let capacity =
        (Option.map ~f:CapacityUpdate.of_xml) (Xml.child xml_arg0 "capacity") in
      make ~currentVersion ~connectorArn ?connectorConfiguration ?capacity ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let currentVersion =
        field_map_exn json__ "currentVersion" Zz__string.of_json in
      let connectorArn =
        field_map_exn json__ "connectorArn" Zz__string.of_json in
      let connectorConfiguration =
        field_map json__ "connectorConfiguration"
          ConnectorConfigurationUpdate.of_json in
      let capacity = field_map json__ "capacity" CapacityUpdate.of_json in
      make ~currentVersion ~connectorArn ?connectorConfiguration ?capacity ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Updates the specified connector. For request body, specify only one parameter: either capacity or connectorConfiguration."]
module UntagResourceResponse =
  struct
    type nonrec t = unit
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make () = ()
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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 tags from the specified resource."]
module UntagResourceRequest =
  struct
    type nonrec t =
      {
      resourceArn: Zz__string.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the resource from which you want to remove tags."];
      tagKeys: TagKeyList.t
        [@ocaml.doc
          "The keys of the tags that you want to remove from the resource."]}
    let context_ = "UntagResourceRequest"
    let make ~resourceArn =
      fun ~tagKeys -> fun () -> { resourceArn; tagKeys }
    let to_value x =
      structure_to_value
        [("resourceArn", (Some (Zz__string.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 =
        Zz__string.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" Zz__string.of_json in
      make ~tagKeys ~resourceArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Removes tags from the specified resource."]
module TagResourceResponse =
  struct
    type nonrec t = unit
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ConflictException of ConflictException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make () = ()
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ConflictException e ->
          `Assoc
            [("error", (`String "ConflictException"));
            ("details", (ConflictException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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 "Attaches tags to the specified resource."]
module TagResourceRequest =
  struct
    type nonrec t =
      {
      resourceArn: Zz__string.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the resource to which you want to attach tags."];
      tags: Tags.t
        [@ocaml.doc "The tags that you want to attach to the resource."]}
    let context_ = "TagResourceRequest"
    let make ~resourceArn = fun ~tags -> fun () -> { resourceArn; tags }
    let to_value x =
      structure_to_value
        [("resourceArn", (Some (Zz__string.to_value x.resourceArn)));
        ("tags", (Some (Tags.to_value x.tags)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let tags =
        Tags.of_xml (Xml.child_exn ~context:context_ xml_arg0 "tags") in
      let resourceArn =
        Zz__string.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" Tags.of_json in
      let resourceArn = field_map_exn json__ "resourceArn" Zz__string.of_json in
      make ~tags ~resourceArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Attaches tags to the specified resource."]
module ListWorkerConfigurationsResponse =
  struct
    type nonrec t =
      {
      nextToken: Zz__string.t option
        [@ocaml.doc
          "If the response of a ListWorkerConfigurations operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where the previous operation left off."];
      workerConfigurations: Zz__listOfWorkerConfigurationSummary.t option
        [@ocaml.doc "An array of worker configuration descriptions."]}
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?nextToken =
      fun ?workerConfigurations ->
        fun () -> { nextToken; workerConfigurations }
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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
        [("nextToken", (Option.map x.nextToken ~f:Zz__string.to_value));
        ("workerConfigurations",
          (Option.map x.workerConfigurations
             ~f:Zz__listOfWorkerConfigurationSummary.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let workerConfigurations =
        (Option.map ~f:Zz__listOfWorkerConfigurationSummary.of_xml)
          (Xml.child xml_arg0 "workerConfigurations") in
      let nextToken =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "nextToken") in
      make ?workerConfigurations ?nextToken ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let workerConfigurations =
        field_map json__ "workerConfigurations"
          Zz__listOfWorkerConfigurationSummary.of_json in
      let nextToken = field_map json__ "nextToken" Zz__string.of_json in
      make ?workerConfigurations ?nextToken ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Returns a list of all of the worker configurations in this account and Region."]
module ListWorkerConfigurationsRequest =
  struct
    type nonrec t =
      {
      maxResults: MaxResults.t option
        [@ocaml.doc
          "The maximum number of worker configurations to list in one response."];
      nextToken: Zz__string.t option
        [@ocaml.doc
          "If the response of a ListWorkerConfigurations operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where the previous operation left off."];
      namePrefix: Zz__string.t option
        [@ocaml.doc
          "Lists worker configuration names that start with the specified text string."]}
    let make ?maxResults =
      fun ?nextToken ->
        fun ?namePrefix -> fun () -> { maxResults; nextToken; namePrefix }
    let to_value x =
      structure_to_value
        [("maxResults", (Option.map x.maxResults ~f:MaxResults.to_value));
        ("nextToken", (Option.map x.nextToken ~f:Zz__string.to_value));
        ("namePrefix", (Option.map x.namePrefix ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let namePrefix =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "namePrefix") in
      let nextToken =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "nextToken") in
      let maxResults =
        (Option.map ~f:MaxResults.of_xml) (Xml.child xml_arg0 "maxResults") in
      make ?namePrefix ?nextToken ?maxResults ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let namePrefix = field_map json__ "namePrefix" Zz__string.of_json in
      let nextToken = field_map json__ "nextToken" Zz__string.of_json in
      let maxResults = field_map json__ "maxResults" MaxResults.of_json in
      make ?namePrefix ?nextToken ?maxResults ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Returns a list of all of the worker configurations in this account and Region."]
module ListTagsForResourceResponse =
  struct
    type nonrec t =
      {
      tags: Tags.t option
        [@ocaml.doc
          "Lists the tags attached to the specified resource in the corresponding request."]}
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?tags = fun () -> { tags }
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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:Tags.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let tags = (Option.map ~f:Tags.of_xml) (Xml.child xml_arg0 "tags") in
      make ?tags ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let tags = field_map json__ "tags" Tags.of_json in make ?tags ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Lists all the tags attached to the specified resource."]
module ListTagsForResourceRequest =
  struct
    type nonrec t =
      {
      resourceArn: Zz__string.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the resource for which you want to list all attached tags."]}
    let context_ = "ListTagsForResourceRequest"
    let make ~resourceArn = fun () -> { resourceArn }
    let to_value x =
      structure_to_value
        [("resourceArn", (Some (Zz__string.to_value x.resourceArn)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let resourceArn =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "resourceArn") in
      make ~resourceArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let resourceArn = field_map_exn json__ "resourceArn" Zz__string.of_json in
      make ~resourceArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Lists all the tags attached to the specified resource."]
module ListCustomPluginsResponse =
  struct
    type nonrec t =
      {
      customPlugins: Zz__listOfCustomPluginSummary.t option
        [@ocaml.doc "An array of custom plugin descriptions."];
      nextToken: Zz__string.t option
        [@ocaml.doc
          "If the response of a ListCustomPlugins operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where the previous operation left off."]}
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?customPlugins =
      fun ?nextToken -> fun () -> { customPlugins; nextToken }
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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
        [("customPlugins",
           (Option.map x.customPlugins
              ~f:Zz__listOfCustomPluginSummary.to_value));
        ("nextToken", (Option.map x.nextToken ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let nextToken =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "nextToken") in
      let customPlugins =
        (Option.map ~f:Zz__listOfCustomPluginSummary.of_xml)
          (Xml.child xml_arg0 "customPlugins") in
      make ?nextToken ?customPlugins ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let nextToken = field_map json__ "nextToken" Zz__string.of_json in
      let customPlugins =
        field_map json__ "customPlugins"
          Zz__listOfCustomPluginSummary.of_json in
      make ?nextToken ?customPlugins ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Returns a list of all of the custom plugins in this account and Region."]
module ListCustomPluginsRequest =
  struct
    type nonrec t =
      {
      maxResults: MaxResults.t option
        [@ocaml.doc
          "The maximum number of custom plugins to list in one response."];
      nextToken: Zz__string.t option
        [@ocaml.doc
          "If the response of a ListCustomPlugins operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where the previous operation left off."];
      namePrefix: Zz__string.t option
        [@ocaml.doc
          "Lists custom plugin names that start with the specified text string."]}
    let make ?maxResults =
      fun ?nextToken ->
        fun ?namePrefix -> fun () -> { maxResults; nextToken; namePrefix }
    let to_value x =
      structure_to_value
        [("maxResults", (Option.map x.maxResults ~f:MaxResults.to_value));
        ("nextToken", (Option.map x.nextToken ~f:Zz__string.to_value));
        ("namePrefix", (Option.map x.namePrefix ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let namePrefix =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "namePrefix") in
      let nextToken =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "nextToken") in
      let maxResults =
        (Option.map ~f:MaxResults.of_xml) (Xml.child xml_arg0 "maxResults") in
      make ?namePrefix ?nextToken ?maxResults ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let namePrefix = field_map json__ "namePrefix" Zz__string.of_json in
      let nextToken = field_map json__ "nextToken" Zz__string.of_json in
      let maxResults = field_map json__ "maxResults" MaxResults.of_json in
      make ?namePrefix ?nextToken ?maxResults ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Returns a list of all of the custom plugins in this account and Region."]
module ListConnectorsResponse =
  struct
    type nonrec t =
      {
      connectors: Zz__listOfConnectorSummary.t option
        [@ocaml.doc "An array of connector descriptions."];
      nextToken: Zz__string.t option
        [@ocaml.doc
          "If the response of a ListConnectors operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where it left off."]}
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?connectors =
      fun ?nextToken -> fun () -> { connectors; nextToken }
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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
        [("connectors",
           (Option.map x.connectors ~f:Zz__listOfConnectorSummary.to_value));
        ("nextToken", (Option.map x.nextToken ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let nextToken =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "nextToken") in
      let connectors =
        (Option.map ~f:Zz__listOfConnectorSummary.of_xml)
          (Xml.child xml_arg0 "connectors") in
      make ?nextToken ?connectors ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let nextToken = field_map json__ "nextToken" Zz__string.of_json in
      let connectors =
        field_map json__ "connectors" Zz__listOfConnectorSummary.of_json in
      make ?nextToken ?connectors ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Returns a list of all the connectors in this account and Region. The list is limited to connectors whose name starts with the specified prefix. The response also includes a description of each of the listed connectors."]
module ListConnectorsRequest =
  struct
    type nonrec t =
      {
      connectorNamePrefix: Zz__string.t option
        [@ocaml.doc
          "The name prefix that you want to use to search for and list connectors."];
      maxResults: MaxResults.t option
        [@ocaml.doc
          "The maximum number of connectors to list in one response."];
      nextToken: Zz__string.t option
        [@ocaml.doc
          "If the response of a ListConnectors operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where the previous operation left off."]}
    let make ?connectorNamePrefix =
      fun ?maxResults ->
        fun ?nextToken ->
          fun () -> { connectorNamePrefix; maxResults; nextToken }
    let to_value x =
      structure_to_value
        [("connectorNamePrefix",
           (Option.map x.connectorNamePrefix ~f:Zz__string.to_value));
        ("maxResults", (Option.map x.maxResults ~f:MaxResults.to_value));
        ("nextToken", (Option.map x.nextToken ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let nextToken =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "nextToken") in
      let maxResults =
        (Option.map ~f:MaxResults.of_xml) (Xml.child xml_arg0 "maxResults") in
      let connectorNamePrefix =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "connectorNamePrefix") in
      make ?nextToken ?maxResults ?connectorNamePrefix ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let nextToken = field_map json__ "nextToken" Zz__string.of_json in
      let maxResults = field_map json__ "maxResults" MaxResults.of_json in
      let connectorNamePrefix =
        field_map json__ "connectorNamePrefix" Zz__string.of_json in
      make ?nextToken ?maxResults ?connectorNamePrefix ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Returns a list of all the connectors in this account and Region. The list is limited to connectors whose name starts with the specified prefix. The response also includes a description of each of the listed connectors."]
module ListConnectorOperationsResponse =
  struct
    type nonrec t =
      {
      connectorOperations: Zz__listOfConnectorOperationSummary.t option
        [@ocaml.doc "An array of connector operation descriptions."];
      nextToken: Zz__string.t option
        [@ocaml.doc
          "If the response is truncated, it includes a NextToken. Send this NextToken in a subsequent request to continue listing from where it left off."]}
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?connectorOperations =
      fun ?nextToken -> fun () -> { connectorOperations; nextToken }
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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
        [("connectorOperations",
           (Option.map x.connectorOperations
              ~f:Zz__listOfConnectorOperationSummary.to_value));
        ("nextToken", (Option.map x.nextToken ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let nextToken =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "nextToken") in
      let connectorOperations =
        (Option.map ~f:Zz__listOfConnectorOperationSummary.of_xml)
          (Xml.child xml_arg0 "connectorOperations") in
      make ?nextToken ?connectorOperations ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let nextToken = field_map json__ "nextToken" Zz__string.of_json in
      let connectorOperations =
        field_map json__ "connectorOperations"
          Zz__listOfConnectorOperationSummary.of_json in
      make ?nextToken ?connectorOperations ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Lists information about a connector's operation(s)."]
module ListConnectorOperationsRequest =
  struct
    type nonrec t =
      {
      connectorArn: Zz__string.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the connector for which to list operations."];
      maxResults: MaxResults.t option
        [@ocaml.doc
          "Maximum number of connector operations to fetch in one get request."];
      nextToken: Zz__string.t option
        [@ocaml.doc
          "If the response is truncated, it includes a NextToken. Send this NextToken in a subsequent request to continue listing from where it left off."]}
    let context_ = "ListConnectorOperationsRequest"
    let make ?maxResults =
      fun ?nextToken ->
        fun ~connectorArn ->
          fun () -> { maxResults; nextToken; connectorArn }
    let to_value x =
      structure_to_value
        [("connectorArn", (Some (Zz__string.to_value x.connectorArn)));
        ("maxResults", (Option.map x.maxResults ~f:MaxResults.to_value));
        ("nextToken", (Option.map x.nextToken ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let nextToken =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "nextToken") in
      let maxResults =
        (Option.map ~f:MaxResults.of_xml) (Xml.child xml_arg0 "maxResults") in
      let connectorArn =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "connectorArn") in
      make ?nextToken ?maxResults ~connectorArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let nextToken = field_map json__ "nextToken" Zz__string.of_json in
      let maxResults = field_map json__ "maxResults" MaxResults.of_json in
      let connectorArn =
        field_map_exn json__ "connectorArn" Zz__string.of_json in
      make ?nextToken ?maxResults ~connectorArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Lists information about a connector's operation(s)."]
module DescribeWorkerConfigurationResponse =
  struct
    type nonrec t =
      {
      creationTime: Zz__timestampIso8601.t option
        [@ocaml.doc "The time that the worker configuration was created."];
      description: Zz__string.t option
        [@ocaml.doc "The description of the worker configuration."];
      latestRevision: WorkerConfigurationRevisionDescription.t option
        [@ocaml.doc "The latest revision of the custom configuration."];
      name: Zz__string.t option
        [@ocaml.doc "The name of the worker configuration."];
      workerConfigurationArn: Zz__string.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the custom configuration."];
      workerConfigurationState: WorkerConfigurationState.t option
        [@ocaml.doc "The state of the worker configuration."]}
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?creationTime =
      fun ?description ->
        fun ?latestRevision ->
          fun ?name ->
            fun ?workerConfigurationArn ->
              fun ?workerConfigurationState ->
                fun () ->
                  {
                    creationTime;
                    description;
                    latestRevision;
                    name;
                    workerConfigurationArn;
                    workerConfigurationState
                  }
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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
        [("creationTime",
           (Option.map x.creationTime ~f:Zz__timestampIso8601.to_value));
        ("description", (Option.map x.description ~f:Zz__string.to_value));
        ("latestRevision",
          (Option.map x.latestRevision
             ~f:WorkerConfigurationRevisionDescription.to_value));
        ("name", (Option.map x.name ~f:Zz__string.to_value));
        ("workerConfigurationArn",
          (Option.map x.workerConfigurationArn ~f:Zz__string.to_value));
        ("workerConfigurationState",
          (Option.map x.workerConfigurationState
             ~f:WorkerConfigurationState.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let workerConfigurationState =
        (Option.map ~f:WorkerConfigurationState.of_xml)
          (Xml.child xml_arg0 "workerConfigurationState") in
      let workerConfigurationArn =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "workerConfigurationArn") in
      let name =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "name") in
      let latestRevision =
        (Option.map ~f:WorkerConfigurationRevisionDescription.of_xml)
          (Xml.child xml_arg0 "latestRevision") in
      let description =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "description") in
      let creationTime =
        (Option.map ~f:Zz__timestampIso8601.of_xml)
          (Xml.child xml_arg0 "creationTime") in
      make ?workerConfigurationState ?workerConfigurationArn ?name
        ?latestRevision ?description ?creationTime ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let workerConfigurationState =
        field_map json__ "workerConfigurationState"
          WorkerConfigurationState.of_json in
      let workerConfigurationArn =
        field_map json__ "workerConfigurationArn" Zz__string.of_json in
      let name = field_map json__ "name" Zz__string.of_json in
      let latestRevision =
        field_map json__ "latestRevision"
          WorkerConfigurationRevisionDescription.of_json in
      let description = field_map json__ "description" Zz__string.of_json in
      let creationTime =
        field_map json__ "creationTime" Zz__timestampIso8601.of_json in
      make ?workerConfigurationState ?workerConfigurationArn ?name
        ?latestRevision ?description ?creationTime ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Returns information about a worker configuration."]
module DescribeWorkerConfigurationRequest =
  struct
    type nonrec t =
      {
      workerConfigurationArn: Zz__string.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the worker configuration that you want to get information about."]}
    let context_ = "DescribeWorkerConfigurationRequest"
    let make ~workerConfigurationArn = fun () -> { workerConfigurationArn }
    let to_value x =
      structure_to_value
        [("workerConfigurationArn",
           (Some (Zz__string.to_value x.workerConfigurationArn)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let workerConfigurationArn =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "workerConfigurationArn") in
      make ~workerConfigurationArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let workerConfigurationArn =
        field_map_exn json__ "workerConfigurationArn" Zz__string.of_json in
      make ~workerConfigurationArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Returns information about a worker configuration."]
module DescribeCustomPluginResponse =
  struct
    type nonrec t =
      {
      creationTime: Zz__timestampIso8601.t option
        [@ocaml.doc "The time that the custom plugin was created."];
      customPluginArn: Zz__string.t option
        [@ocaml.doc "The Amazon Resource Name (ARN) of the custom plugin."];
      customPluginState: CustomPluginState.t option
        [@ocaml.doc "The state of the custom plugin."];
      description: Zz__string.t option
        [@ocaml.doc "The description of the custom plugin."];
      latestRevision: CustomPluginRevisionSummary.t option
        [@ocaml.doc
          "The latest successfully created revision of the custom plugin. If there are no successfully created revisions, this field will be absent."];
      name: Zz__string.t option [@ocaml.doc "The name of the custom plugin."];
      stateDescription: StateDescription.t option
        [@ocaml.doc "Details about the state of a custom plugin."]}
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?creationTime =
      fun ?customPluginArn ->
        fun ?customPluginState ->
          fun ?description ->
            fun ?latestRevision ->
              fun ?name ->
                fun ?stateDescription ->
                  fun () ->
                    {
                      creationTime;
                      customPluginArn;
                      customPluginState;
                      description;
                      latestRevision;
                      name;
                      stateDescription
                    }
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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
        [("creationTime",
           (Option.map x.creationTime ~f:Zz__timestampIso8601.to_value));
        ("customPluginArn",
          (Option.map x.customPluginArn ~f:Zz__string.to_value));
        ("customPluginState",
          (Option.map x.customPluginState ~f:CustomPluginState.to_value));
        ("description", (Option.map x.description ~f:Zz__string.to_value));
        ("latestRevision",
          (Option.map x.latestRevision
             ~f:CustomPluginRevisionSummary.to_value));
        ("name", (Option.map x.name ~f:Zz__string.to_value));
        ("stateDescription",
          (Option.map x.stateDescription ~f:StateDescription.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let stateDescription =
        (Option.map ~f:StateDescription.of_xml)
          (Xml.child xml_arg0 "stateDescription") in
      let name =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "name") in
      let latestRevision =
        (Option.map ~f:CustomPluginRevisionSummary.of_xml)
          (Xml.child xml_arg0 "latestRevision") in
      let description =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "description") in
      let customPluginState =
        (Option.map ~f:CustomPluginState.of_xml)
          (Xml.child xml_arg0 "customPluginState") in
      let customPluginArn =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "customPluginArn") in
      let creationTime =
        (Option.map ~f:Zz__timestampIso8601.of_xml)
          (Xml.child xml_arg0 "creationTime") in
      make ?stateDescription ?name ?latestRevision ?description
        ?customPluginState ?customPluginArn ?creationTime ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let stateDescription =
        field_map json__ "stateDescription" StateDescription.of_json in
      let name = field_map json__ "name" Zz__string.of_json in
      let latestRevision =
        field_map json__ "latestRevision" CustomPluginRevisionSummary.of_json in
      let description = field_map json__ "description" Zz__string.of_json in
      let customPluginState =
        field_map json__ "customPluginState" CustomPluginState.of_json in
      let customPluginArn =
        field_map json__ "customPluginArn" Zz__string.of_json in
      let creationTime =
        field_map json__ "creationTime" Zz__timestampIso8601.of_json in
      make ?stateDescription ?name ?latestRevision ?description
        ?customPluginState ?customPluginArn ?creationTime ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "A summary description of the custom plugin."]
module DescribeCustomPluginRequest =
  struct
    type nonrec t =
      {
      customPluginArn: Zz__string.t
        [@ocaml.doc "Returns information about a custom plugin."]}
    let context_ = "DescribeCustomPluginRequest"
    let make ~customPluginArn = fun () -> { customPluginArn }
    let to_value x =
      structure_to_value
        [("customPluginArn", (Some (Zz__string.to_value x.customPluginArn)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let customPluginArn =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "customPluginArn") in
      make ~customPluginArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let customPluginArn =
        field_map_exn json__ "customPluginArn" Zz__string.of_json in
      make ~customPluginArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "A summary description of the custom plugin."]
module DescribeConnectorResponse =
  struct
    type nonrec t =
      {
      capacity: CapacityDescription.t option
        [@ocaml.doc
          "Information about the capacity of the connector, whether it is auto scaled or provisioned."];
      connectorArn: Zz__string.t option
        [@ocaml.doc "The Amazon Resource Name (ARN) of the connector."];
      connectorConfiguration: ConnectorConfiguration.t option
        [@ocaml.doc
          "A map of keys to values that represent the configuration for the connector."];
      connectorDescription: Zz__string.t option
        [@ocaml.doc "A summary description of the connector."];
      connectorName: Zz__string.t option
        [@ocaml.doc "The name of the connector."];
      connectorState: ConnectorState.t option
        [@ocaml.doc "The state of the connector."];
      creationTime: Zz__timestampIso8601.t option
        [@ocaml.doc "The time the connector was created."];
      currentVersion: Zz__string.t option
        [@ocaml.doc "The current version of the connector."];
      kafkaCluster: KafkaClusterDescription.t option
        [@ocaml.doc
          "The Apache Kafka cluster that the connector is connected to."];
      kafkaClusterClientAuthentication:
        KafkaClusterClientAuthenticationDescription.t option
        [@ocaml.doc
          "The type of client authentication used to connect to the Apache Kafka cluster. The value is NONE when no client authentication is used."];
      kafkaClusterEncryptionInTransit:
        KafkaClusterEncryptionInTransitDescription.t option
        [@ocaml.doc
          "Details of encryption in transit to the Apache Kafka cluster."];
      kafkaConnectVersion: Zz__string.t option
        [@ocaml.doc
          "The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins."];
      logDelivery: LogDeliveryDescription.t option
        [@ocaml.doc
          "Details about delivering logs to Amazon CloudWatch Logs."];
      networkType: NetworkType.t option
        [@ocaml.doc
          "The network type of the connector. It gives connectors connectivity to either IPv4 (IPV4) or IPv4 and IPv6 (DUAL) destinations. Defaults to IPV4."];
      plugins: Zz__listOfPluginDescription.t option
        [@ocaml.doc "Specifies which plugins were used for this connector."];
      serviceExecutionRoleArn: Zz__string.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon Web Services resources."];
      workerConfiguration: WorkerConfigurationDescription.t option
        [@ocaml.doc
          "Specifies which worker configuration was used for the connector."];
      stateDescription: StateDescription.t option
        [@ocaml.doc "Details about the state of a connector."]}
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?capacity =
      fun ?connectorArn ->
        fun ?connectorConfiguration ->
          fun ?connectorDescription ->
            fun ?connectorName ->
              fun ?connectorState ->
                fun ?creationTime ->
                  fun ?currentVersion ->
                    fun ?kafkaCluster ->
                      fun ?kafkaClusterClientAuthentication ->
                        fun ?kafkaClusterEncryptionInTransit ->
                          fun ?kafkaConnectVersion ->
                            fun ?logDelivery ->
                              fun ?networkType ->
                                fun ?plugins ->
                                  fun ?serviceExecutionRoleArn ->
                                    fun ?workerConfiguration ->
                                      fun ?stateDescription ->
                                        fun () ->
                                          {
                                            capacity;
                                            connectorArn;
                                            connectorConfiguration;
                                            connectorDescription;
                                            connectorName;
                                            connectorState;
                                            creationTime;
                                            currentVersion;
                                            kafkaCluster;
                                            kafkaClusterClientAuthentication;
                                            kafkaClusterEncryptionInTransit;
                                            kafkaConnectVersion;
                                            logDelivery;
                                            networkType;
                                            plugins;
                                            serviceExecutionRoleArn;
                                            workerConfiguration;
                                            stateDescription
                                          }
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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
        [("capacity",
           (Option.map x.capacity ~f:CapacityDescription.to_value));
        ("connectorArn", (Option.map x.connectorArn ~f:Zz__string.to_value));
        ("connectorConfiguration",
          (Option.map x.connectorConfiguration
             ~f:ConnectorConfiguration.to_value));
        ("connectorDescription",
          (Option.map x.connectorDescription ~f:Zz__string.to_value));
        ("connectorName",
          (Option.map x.connectorName ~f:Zz__string.to_value));
        ("connectorState",
          (Option.map x.connectorState ~f:ConnectorState.to_value));
        ("creationTime",
          (Option.map x.creationTime ~f:Zz__timestampIso8601.to_value));
        ("currentVersion",
          (Option.map x.currentVersion ~f:Zz__string.to_value));
        ("kafkaCluster",
          (Option.map x.kafkaCluster ~f:KafkaClusterDescription.to_value));
        ("kafkaClusterClientAuthentication",
          (Option.map x.kafkaClusterClientAuthentication
             ~f:KafkaClusterClientAuthenticationDescription.to_value));
        ("kafkaClusterEncryptionInTransit",
          (Option.map x.kafkaClusterEncryptionInTransit
             ~f:KafkaClusterEncryptionInTransitDescription.to_value));
        ("kafkaConnectVersion",
          (Option.map x.kafkaConnectVersion ~f:Zz__string.to_value));
        ("logDelivery",
          (Option.map x.logDelivery ~f:LogDeliveryDescription.to_value));
        ("networkType", (Option.map x.networkType ~f:NetworkType.to_value));
        ("plugins",
          (Option.map x.plugins ~f:Zz__listOfPluginDescription.to_value));
        ("serviceExecutionRoleArn",
          (Option.map x.serviceExecutionRoleArn ~f:Zz__string.to_value));
        ("workerConfiguration",
          (Option.map x.workerConfiguration
             ~f:WorkerConfigurationDescription.to_value));
        ("stateDescription",
          (Option.map x.stateDescription ~f:StateDescription.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let stateDescription =
        (Option.map ~f:StateDescription.of_xml)
          (Xml.child xml_arg0 "stateDescription") in
      let workerConfiguration =
        (Option.map ~f:WorkerConfigurationDescription.of_xml)
          (Xml.child xml_arg0 "workerConfiguration") in
      let serviceExecutionRoleArn =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "serviceExecutionRoleArn") in
      let plugins =
        (Option.map ~f:Zz__listOfPluginDescription.of_xml)
          (Xml.child xml_arg0 "plugins") in
      let networkType =
        (Option.map ~f:NetworkType.of_xml) (Xml.child xml_arg0 "networkType") in
      let logDelivery =
        (Option.map ~f:LogDeliveryDescription.of_xml)
          (Xml.child xml_arg0 "logDelivery") in
      let kafkaConnectVersion =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "kafkaConnectVersion") in
      let kafkaClusterEncryptionInTransit =
        (Option.map ~f:KafkaClusterEncryptionInTransitDescription.of_xml)
          (Xml.child xml_arg0 "kafkaClusterEncryptionInTransit") in
      let kafkaClusterClientAuthentication =
        (Option.map ~f:KafkaClusterClientAuthenticationDescription.of_xml)
          (Xml.child xml_arg0 "kafkaClusterClientAuthentication") in
      let kafkaCluster =
        (Option.map ~f:KafkaClusterDescription.of_xml)
          (Xml.child xml_arg0 "kafkaCluster") in
      let currentVersion =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "currentVersion") in
      let creationTime =
        (Option.map ~f:Zz__timestampIso8601.of_xml)
          (Xml.child xml_arg0 "creationTime") in
      let connectorState =
        (Option.map ~f:ConnectorState.of_xml)
          (Xml.child xml_arg0 "connectorState") in
      let connectorName =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "connectorName") in
      let connectorDescription =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "connectorDescription") in
      let connectorConfiguration =
        (Option.map ~f:ConnectorConfiguration.of_xml)
          (Xml.child xml_arg0 "connectorConfiguration") in
      let connectorArn =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "connectorArn") in
      let capacity =
        (Option.map ~f:CapacityDescription.of_xml)
          (Xml.child xml_arg0 "capacity") in
      make ?stateDescription ?workerConfiguration ?serviceExecutionRoleArn
        ?plugins ?networkType ?logDelivery ?kafkaConnectVersion
        ?kafkaClusterEncryptionInTransit ?kafkaClusterClientAuthentication
        ?kafkaCluster ?currentVersion ?creationTime ?connectorState
        ?connectorName ?connectorDescription ?connectorConfiguration
        ?connectorArn ?capacity ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let stateDescription =
        field_map json__ "stateDescription" StateDescription.of_json in
      let workerConfiguration =
        field_map json__ "workerConfiguration"
          WorkerConfigurationDescription.of_json in
      let serviceExecutionRoleArn =
        field_map json__ "serviceExecutionRoleArn" Zz__string.of_json in
      let plugins =
        field_map json__ "plugins" Zz__listOfPluginDescription.of_json in
      let networkType = field_map json__ "networkType" NetworkType.of_json in
      let logDelivery =
        field_map json__ "logDelivery" LogDeliveryDescription.of_json in
      let kafkaConnectVersion =
        field_map json__ "kafkaConnectVersion" Zz__string.of_json in
      let kafkaClusterEncryptionInTransit =
        field_map json__ "kafkaClusterEncryptionInTransit"
          KafkaClusterEncryptionInTransitDescription.of_json in
      let kafkaClusterClientAuthentication =
        field_map json__ "kafkaClusterClientAuthentication"
          KafkaClusterClientAuthenticationDescription.of_json in
      let kafkaCluster =
        field_map json__ "kafkaCluster" KafkaClusterDescription.of_json in
      let currentVersion =
        field_map json__ "currentVersion" Zz__string.of_json in
      let creationTime =
        field_map json__ "creationTime" Zz__timestampIso8601.of_json in
      let connectorState =
        field_map json__ "connectorState" ConnectorState.of_json in
      let connectorName = field_map json__ "connectorName" Zz__string.of_json in
      let connectorDescription =
        field_map json__ "connectorDescription" Zz__string.of_json in
      let connectorConfiguration =
        field_map json__ "connectorConfiguration"
          ConnectorConfiguration.of_json in
      let connectorArn = field_map json__ "connectorArn" Zz__string.of_json in
      let capacity = field_map json__ "capacity" CapacityDescription.of_json in
      make ?stateDescription ?workerConfiguration ?serviceExecutionRoleArn
        ?plugins ?networkType ?logDelivery ?kafkaConnectVersion
        ?kafkaClusterEncryptionInTransit ?kafkaClusterClientAuthentication
        ?kafkaCluster ?currentVersion ?creationTime ?connectorState
        ?connectorName ?connectorDescription ?connectorConfiguration
        ?connectorArn ?capacity ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Returns summary information about the connector."]
module DescribeConnectorRequest =
  struct
    type nonrec t =
      {
      connectorArn: Zz__string.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the connector that you want to describe."]}
    let context_ = "DescribeConnectorRequest"
    let make ~connectorArn = fun () -> { connectorArn }
    let to_value x =
      structure_to_value
        [("connectorArn", (Some (Zz__string.to_value x.connectorArn)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let connectorArn =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "connectorArn") in
      make ~connectorArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let connectorArn =
        field_map_exn json__ "connectorArn" Zz__string.of_json in
      make ~connectorArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Returns summary information about the connector."]
module DescribeConnectorOperationResponse =
  struct
    type nonrec t =
      {
      connectorArn: Zz__string.t option
        [@ocaml.doc "The Amazon Resource Name (ARN) of the connector."];
      connectorOperationArn: Zz__string.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the connector operation."];
      connectorOperationState: ConnectorOperationState.t option
        [@ocaml.doc "The state of the connector operation."];
      connectorOperationType: ConnectorOperationType.t option
        [@ocaml.doc "The type of connector operation performed."];
      operationSteps: Zz__listOfConnectorOperationStep.t option
        [@ocaml.doc "The array of operation steps taken."];
      originWorkerSetting: WorkerSetting.t option
        [@ocaml.doc "The origin worker setting."];
      originConnectorConfiguration: ConnectorConfiguration.t option
        [@ocaml.doc "The origin connector configuration."];
      targetWorkerSetting: WorkerSetting.t option
        [@ocaml.doc "The target worker setting."];
      targetConnectorConfiguration: ConnectorConfiguration.t option
        [@ocaml.doc "The target connector configuration."];
      errorInfo: StateDescription.t option ;
      creationTime: Zz__timestampIso8601.t option
        [@ocaml.doc "The time when the operation was created."];
      endTime: Zz__timestampIso8601.t option
        [@ocaml.doc "The time when the operation ended."]}
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?connectorArn =
      fun ?connectorOperationArn ->
        fun ?connectorOperationState ->
          fun ?connectorOperationType ->
            fun ?operationSteps ->
              fun ?originWorkerSetting ->
                fun ?originConnectorConfiguration ->
                  fun ?targetWorkerSetting ->
                    fun ?targetConnectorConfiguration ->
                      fun ?errorInfo ->
                        fun ?creationTime ->
                          fun ?endTime ->
                            fun () ->
                              {
                                connectorArn;
                                connectorOperationArn;
                                connectorOperationState;
                                connectorOperationType;
                                operationSteps;
                                originWorkerSetting;
                                originConnectorConfiguration;
                                targetWorkerSetting;
                                targetConnectorConfiguration;
                                errorInfo;
                                creationTime;
                                endTime
                              }
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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
        [("connectorArn", (Option.map x.connectorArn ~f:Zz__string.to_value));
        ("connectorOperationArn",
          (Option.map x.connectorOperationArn ~f:Zz__string.to_value));
        ("connectorOperationState",
          (Option.map x.connectorOperationState
             ~f:ConnectorOperationState.to_value));
        ("connectorOperationType",
          (Option.map x.connectorOperationType
             ~f:ConnectorOperationType.to_value));
        ("operationSteps",
          (Option.map x.operationSteps
             ~f:Zz__listOfConnectorOperationStep.to_value));
        ("originWorkerSetting",
          (Option.map x.originWorkerSetting ~f:WorkerSetting.to_value));
        ("originConnectorConfiguration",
          (Option.map x.originConnectorConfiguration
             ~f:ConnectorConfiguration.to_value));
        ("targetWorkerSetting",
          (Option.map x.targetWorkerSetting ~f:WorkerSetting.to_value));
        ("targetConnectorConfiguration",
          (Option.map x.targetConnectorConfiguration
             ~f:ConnectorConfiguration.to_value));
        ("errorInfo", (Option.map x.errorInfo ~f:StateDescription.to_value));
        ("creationTime",
          (Option.map x.creationTime ~f:Zz__timestampIso8601.to_value));
        ("endTime", (Option.map x.endTime ~f:Zz__timestampIso8601.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let endTime =
        (Option.map ~f:Zz__timestampIso8601.of_xml)
          (Xml.child xml_arg0 "endTime") in
      let creationTime =
        (Option.map ~f:Zz__timestampIso8601.of_xml)
          (Xml.child xml_arg0 "creationTime") in
      let errorInfo =
        (Option.map ~f:StateDescription.of_xml)
          (Xml.child xml_arg0 "errorInfo") in
      let targetConnectorConfiguration =
        (Option.map ~f:ConnectorConfiguration.of_xml)
          (Xml.child xml_arg0 "targetConnectorConfiguration") in
      let targetWorkerSetting =
        (Option.map ~f:WorkerSetting.of_xml)
          (Xml.child xml_arg0 "targetWorkerSetting") in
      let originConnectorConfiguration =
        (Option.map ~f:ConnectorConfiguration.of_xml)
          (Xml.child xml_arg0 "originConnectorConfiguration") in
      let originWorkerSetting =
        (Option.map ~f:WorkerSetting.of_xml)
          (Xml.child xml_arg0 "originWorkerSetting") in
      let operationSteps =
        (Option.map ~f:Zz__listOfConnectorOperationStep.of_xml)
          (Xml.child xml_arg0 "operationSteps") in
      let connectorOperationType =
        (Option.map ~f:ConnectorOperationType.of_xml)
          (Xml.child xml_arg0 "connectorOperationType") in
      let connectorOperationState =
        (Option.map ~f:ConnectorOperationState.of_xml)
          (Xml.child xml_arg0 "connectorOperationState") in
      let connectorOperationArn =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "connectorOperationArn") in
      let connectorArn =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "connectorArn") in
      make ?endTime ?creationTime ?errorInfo ?targetConnectorConfiguration
        ?targetWorkerSetting ?originConnectorConfiguration
        ?originWorkerSetting ?operationSteps ?connectorOperationType
        ?connectorOperationState ?connectorOperationArn ?connectorArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let endTime = field_map json__ "endTime" Zz__timestampIso8601.of_json in
      let creationTime =
        field_map json__ "creationTime" Zz__timestampIso8601.of_json in
      let errorInfo = field_map json__ "errorInfo" StateDescription.of_json in
      let targetConnectorConfiguration =
        field_map json__ "targetConnectorConfiguration"
          ConnectorConfiguration.of_json in
      let targetWorkerSetting =
        field_map json__ "targetWorkerSetting" WorkerSetting.of_json in
      let originConnectorConfiguration =
        field_map json__ "originConnectorConfiguration"
          ConnectorConfiguration.of_json in
      let originWorkerSetting =
        field_map json__ "originWorkerSetting" WorkerSetting.of_json in
      let operationSteps =
        field_map json__ "operationSteps"
          Zz__listOfConnectorOperationStep.of_json in
      let connectorOperationType =
        field_map json__ "connectorOperationType"
          ConnectorOperationType.of_json in
      let connectorOperationState =
        field_map json__ "connectorOperationState"
          ConnectorOperationState.of_json in
      let connectorOperationArn =
        field_map json__ "connectorOperationArn" Zz__string.of_json in
      let connectorArn = field_map json__ "connectorArn" Zz__string.of_json in
      make ?endTime ?creationTime ?errorInfo ?targetConnectorConfiguration
        ?targetWorkerSetting ?originConnectorConfiguration
        ?originWorkerSetting ?operationSteps ?connectorOperationType
        ?connectorOperationState ?connectorOperationArn ?connectorArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Returns information about the specified connector's operations."]
module DescribeConnectorOperationRequest =
  struct
    type nonrec t =
      {
      connectorOperationArn: Zz__string.t
        [@ocaml.doc "ARN of the connector operation to be described."]}
    let context_ = "DescribeConnectorOperationRequest"
    let make ~connectorOperationArn = fun () -> { connectorOperationArn }
    let to_value x =
      structure_to_value
        [("connectorOperationArn",
           (Some (Zz__string.to_value x.connectorOperationArn)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let connectorOperationArn =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "connectorOperationArn") in
      make ~connectorOperationArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let connectorOperationArn =
        field_map_exn json__ "connectorOperationArn" Zz__string.of_json in
      make ~connectorOperationArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Returns information about the specified connector's operations."]
module DeleteWorkerConfigurationResponse =
  struct
    type nonrec t =
      {
      workerConfigurationArn: Zz__string.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the worker configuration that you requested to delete."];
      workerConfigurationState: WorkerConfigurationState.t option
        [@ocaml.doc "The state of the worker configuration."]}
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?workerConfigurationArn =
      fun ?workerConfigurationState ->
        fun () -> { workerConfigurationArn; workerConfigurationState }
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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
        [("workerConfigurationArn",
           (Option.map x.workerConfigurationArn ~f:Zz__string.to_value));
        ("workerConfigurationState",
          (Option.map x.workerConfigurationState
             ~f:WorkerConfigurationState.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let workerConfigurationState =
        (Option.map ~f:WorkerConfigurationState.of_xml)
          (Xml.child xml_arg0 "workerConfigurationState") in
      let workerConfigurationArn =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "workerConfigurationArn") in
      make ?workerConfigurationState ?workerConfigurationArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let workerConfigurationState =
        field_map json__ "workerConfigurationState"
          WorkerConfigurationState.of_json in
      let workerConfigurationArn =
        field_map json__ "workerConfigurationArn" Zz__string.of_json in
      make ?workerConfigurationState ?workerConfigurationArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Deletes the specified worker configuration."]
module DeleteWorkerConfigurationRequest =
  struct
    type nonrec t =
      {
      workerConfigurationArn: Zz__string.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the worker configuration that you want to delete."]}
    let context_ = "DeleteWorkerConfigurationRequest"
    let make ~workerConfigurationArn = fun () -> { workerConfigurationArn }
    let to_value x =
      structure_to_value
        [("workerConfigurationArn",
           (Some (Zz__string.to_value x.workerConfigurationArn)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let workerConfigurationArn =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "workerConfigurationArn") in
      make ~workerConfigurationArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let workerConfigurationArn =
        field_map_exn json__ "workerConfigurationArn" Zz__string.of_json in
      make ~workerConfigurationArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Deletes the specified worker configuration."]
module DeleteCustomPluginResponse =
  struct
    type nonrec t =
      {
      customPluginArn: Zz__string.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the custom plugin that you requested to delete."];
      customPluginState: CustomPluginState.t option
        [@ocaml.doc "The state of the custom plugin."]}
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?customPluginArn =
      fun ?customPluginState ->
        fun () -> { customPluginArn; customPluginState }
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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
        [("customPluginArn",
           (Option.map x.customPluginArn ~f:Zz__string.to_value));
        ("customPluginState",
          (Option.map x.customPluginState ~f:CustomPluginState.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let customPluginState =
        (Option.map ~f:CustomPluginState.of_xml)
          (Xml.child xml_arg0 "customPluginState") in
      let customPluginArn =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "customPluginArn") in
      make ?customPluginState ?customPluginArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let customPluginState =
        field_map json__ "customPluginState" CustomPluginState.of_json in
      let customPluginArn =
        field_map json__ "customPluginArn" Zz__string.of_json in
      make ?customPluginState ?customPluginArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Deletes a custom plugin."]
module DeleteCustomPluginRequest =
  struct
    type nonrec t =
      {
      customPluginArn: Zz__string.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the custom plugin that you want to delete."]}
    let context_ = "DeleteCustomPluginRequest"
    let make ~customPluginArn = fun () -> { customPluginArn }
    let to_value x =
      structure_to_value
        [("customPluginArn", (Some (Zz__string.to_value x.customPluginArn)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let customPluginArn =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "customPluginArn") in
      make ~customPluginArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let customPluginArn =
        field_map_exn json__ "customPluginArn" Zz__string.of_json in
      make ~customPluginArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Deletes a custom plugin."]
module DeleteConnectorResponse =
  struct
    type nonrec t =
      {
      connectorArn: Zz__string.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the connector that you requested to delete."];
      connectorState: ConnectorState.t option
        [@ocaml.doc
          "The state of the connector that you requested to delete."]}
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?connectorArn =
      fun ?connectorState -> fun () -> { connectorArn; connectorState }
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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
        [("connectorArn", (Option.map x.connectorArn ~f:Zz__string.to_value));
        ("connectorState",
          (Option.map x.connectorState ~f:ConnectorState.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let connectorState =
        (Option.map ~f:ConnectorState.of_xml)
          (Xml.child xml_arg0 "connectorState") in
      let connectorArn =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "connectorArn") in
      make ?connectorState ?connectorArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let connectorState =
        field_map json__ "connectorState" ConnectorState.of_json in
      let connectorArn = field_map json__ "connectorArn" Zz__string.of_json in
      make ?connectorState ?connectorArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Deletes the specified connector."]
module DeleteConnectorRequest =
  struct
    type nonrec t =
      {
      connectorArn: Zz__string.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the connector that you want to delete."];
      currentVersion: Zz__string.t option
        [@ocaml.doc
          "The current version of the connector that you want to delete."]}
    let context_ = "DeleteConnectorRequest"
    let make ?currentVersion =
      fun ~connectorArn -> fun () -> { currentVersion; connectorArn }
    let to_value x =
      structure_to_value
        [("connectorArn", (Some (Zz__string.to_value x.connectorArn)));
        ("currentVersion",
          (Option.map x.currentVersion ~f:Zz__string.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let currentVersion =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "currentVersion") in
      let connectorArn =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "connectorArn") in
      make ?currentVersion ~connectorArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let currentVersion =
        field_map json__ "currentVersion" Zz__string.of_json in
      let connectorArn =
        field_map_exn json__ "connectorArn" Zz__string.of_json in
      make ?currentVersion ~connectorArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Deletes the specified connector."]
module CreateWorkerConfigurationResponse =
  struct
    type nonrec t =
      {
      creationTime: Zz__timestampIso8601.t option
        [@ocaml.doc "The time that the worker configuration was created."];
      latestRevision: WorkerConfigurationRevisionSummary.t option
        [@ocaml.doc "The latest revision of the worker configuration."];
      name: Zz__string.t option
        [@ocaml.doc "The name of the worker configuration."];
      workerConfigurationArn: Zz__string.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) that Amazon assigned to the worker configuration."];
      workerConfigurationState: WorkerConfigurationState.t option
        [@ocaml.doc "The state of the worker configuration."]}
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ConflictException of ConflictException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?creationTime =
      fun ?latestRevision ->
        fun ?name ->
          fun ?workerConfigurationArn ->
            fun ?workerConfigurationState ->
              fun () ->
                {
                  creationTime;
                  latestRevision;
                  name;
                  workerConfigurationArn;
                  workerConfigurationState
                }
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ConflictException e ->
          `Assoc
            [("error", (`String "ConflictException"));
            ("details", (ConflictException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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
        [("creationTime",
           (Option.map x.creationTime ~f:Zz__timestampIso8601.to_value));
        ("latestRevision",
          (Option.map x.latestRevision
             ~f:WorkerConfigurationRevisionSummary.to_value));
        ("name", (Option.map x.name ~f:Zz__string.to_value));
        ("workerConfigurationArn",
          (Option.map x.workerConfigurationArn ~f:Zz__string.to_value));
        ("workerConfigurationState",
          (Option.map x.workerConfigurationState
             ~f:WorkerConfigurationState.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let workerConfigurationState =
        (Option.map ~f:WorkerConfigurationState.of_xml)
          (Xml.child xml_arg0 "workerConfigurationState") in
      let workerConfigurationArn =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "workerConfigurationArn") in
      let name =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "name") in
      let latestRevision =
        (Option.map ~f:WorkerConfigurationRevisionSummary.of_xml)
          (Xml.child xml_arg0 "latestRevision") in
      let creationTime =
        (Option.map ~f:Zz__timestampIso8601.of_xml)
          (Xml.child xml_arg0 "creationTime") in
      make ?workerConfigurationState ?workerConfigurationArn ?name
        ?latestRevision ?creationTime ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let workerConfigurationState =
        field_map json__ "workerConfigurationState"
          WorkerConfigurationState.of_json in
      let workerConfigurationArn =
        field_map json__ "workerConfigurationArn" Zz__string.of_json in
      let name = field_map json__ "name" Zz__string.of_json in
      let latestRevision =
        field_map json__ "latestRevision"
          WorkerConfigurationRevisionSummary.of_json in
      let creationTime =
        field_map json__ "creationTime" Zz__timestampIso8601.of_json in
      make ?workerConfigurationState ?workerConfigurationArn ?name
        ?latestRevision ?creationTime ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Creates a worker configuration using the specified properties."]
module CreateWorkerConfigurationRequest =
  struct
    type nonrec t =
      {
      description: Zz__stringMax1024.t option
        [@ocaml.doc "A summary description of the worker configuration."];
      name: Zz__stringMin1Max128.t
        [@ocaml.doc "The name of the worker configuration."];
      propertiesFileContent: Zz__sensitiveString.t
        [@ocaml.doc
          "Base64 encoded contents of connect-distributed.properties file."];
      tags: Tags.t option
        [@ocaml.doc
          "The tags you want to attach to the worker configuration."]}
    let context_ = "CreateWorkerConfigurationRequest"
    let make ?description =
      fun ?tags ->
        fun ~name ->
          fun ~propertiesFileContent ->
            fun () -> { description; tags; name; propertiesFileContent }
    let to_value x =
      structure_to_value
        [("description",
           (Option.map x.description ~f:Zz__stringMax1024.to_value));
        ("name", (Some (Zz__stringMin1Max128.to_value x.name)));
        ("propertiesFileContent",
          (Some (Zz__sensitiveString.to_value x.propertiesFileContent)));
        ("tags", (Option.map x.tags ~f:Tags.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let tags = (Option.map ~f:Tags.of_xml) (Xml.child xml_arg0 "tags") in
      let propertiesFileContent =
        Zz__sensitiveString.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "propertiesFileContent") in
      let name =
        Zz__stringMin1Max128.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "name") in
      let description =
        (Option.map ~f:Zz__stringMax1024.of_xml)
          (Xml.child xml_arg0 "description") in
      make ?tags ~propertiesFileContent ~name ?description ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let tags = field_map json__ "tags" Tags.of_json in
      let propertiesFileContent =
        field_map_exn json__ "propertiesFileContent"
          Zz__sensitiveString.of_json in
      let name = field_map_exn json__ "name" Zz__stringMin1Max128.of_json in
      let description =
        field_map json__ "description" Zz__stringMax1024.of_json in
      make ?tags ~propertiesFileContent ~name ?description ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Creates a worker configuration using the specified properties."]
module CreateCustomPluginResponse =
  struct
    type nonrec t =
      {
      customPluginArn: Zz__string.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) that Amazon assigned to the custom plugin."];
      customPluginState: CustomPluginState.t option
        [@ocaml.doc "The state of the custom plugin."];
      name: Zz__string.t option [@ocaml.doc "The name of the custom plugin."];
      revision: Zz__long.t option
        [@ocaml.doc "The revision of the custom plugin."]}
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ConflictException of ConflictException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?customPluginArn =
      fun ?customPluginState ->
        fun ?name ->
          fun ?revision ->
            fun () -> { customPluginArn; customPluginState; name; revision }
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ConflictException e ->
          `Assoc
            [("error", (`String "ConflictException"));
            ("details", (ConflictException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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
        [("customPluginArn",
           (Option.map x.customPluginArn ~f:Zz__string.to_value));
        ("customPluginState",
          (Option.map x.customPluginState ~f:CustomPluginState.to_value));
        ("name", (Option.map x.name ~f:Zz__string.to_value));
        ("revision", (Option.map x.revision ~f:Zz__long.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let revision =
        (Option.map ~f:Zz__long.of_xml) (Xml.child xml_arg0 "revision") in
      let name =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "name") in
      let customPluginState =
        (Option.map ~f:CustomPluginState.of_xml)
          (Xml.child xml_arg0 "customPluginState") in
      let customPluginArn =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "customPluginArn") in
      make ?revision ?name ?customPluginState ?customPluginArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let revision = field_map json__ "revision" Zz__long.of_json in
      let name = field_map json__ "name" Zz__string.of_json in
      let customPluginState =
        field_map json__ "customPluginState" CustomPluginState.of_json in
      let customPluginArn =
        field_map json__ "customPluginArn" Zz__string.of_json in
      make ?revision ?name ?customPluginState ?customPluginArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Creates a custom plugin using the specified properties."]
module CreateCustomPluginRequest =
  struct
    type nonrec t =
      {
      contentType: CustomPluginContentType.t
        [@ocaml.doc "The type of the plugin file."];
      description: Zz__stringMax1024.t option
        [@ocaml.doc "A summary description of the custom plugin."];
      location: CustomPluginLocation.t
        [@ocaml.doc "Information about the location of a custom plugin."];
      name: Zz__stringMin1Max128.t
        [@ocaml.doc "The name of the custom plugin."];
      tags: Tags.t option
        [@ocaml.doc "The tags you want to attach to the custom plugin."]}
    let context_ = "CreateCustomPluginRequest"
    let make ?description =
      fun ?tags ->
        fun ~contentType ->
          fun ~location ->
            fun ~name ->
              fun () -> { description; tags; contentType; location; name }
    let to_value x =
      structure_to_value
        [("contentType",
           (Some (CustomPluginContentType.to_value x.contentType)));
        ("description",
          (Option.map x.description ~f:Zz__stringMax1024.to_value));
        ("location", (Some (CustomPluginLocation.to_value x.location)));
        ("name", (Some (Zz__stringMin1Max128.to_value x.name)));
        ("tags", (Option.map x.tags ~f:Tags.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let tags = (Option.map ~f:Tags.of_xml) (Xml.child xml_arg0 "tags") in
      let name =
        Zz__stringMin1Max128.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "name") in
      let location =
        CustomPluginLocation.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "location") in
      let description =
        (Option.map ~f:Zz__stringMax1024.of_xml)
          (Xml.child xml_arg0 "description") in
      let contentType =
        CustomPluginContentType.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "contentType") in
      make ?tags ~name ~location ?description ~contentType ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let tags = field_map json__ "tags" Tags.of_json in
      let name = field_map_exn json__ "name" Zz__stringMin1Max128.of_json in
      let location =
        field_map_exn json__ "location" CustomPluginLocation.of_json in
      let description =
        field_map json__ "description" Zz__stringMax1024.of_json in
      let contentType =
        field_map_exn json__ "contentType" CustomPluginContentType.of_json in
      make ?tags ~name ~location ?description ~contentType ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Creates a custom plugin using the specified properties."]
module CreateConnectorResponse =
  struct
    type nonrec t =
      {
      connectorArn: Zz__string.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) that Amazon assigned to the connector."];
      connectorName: Zz__string.t option
        [@ocaml.doc "The name of the connector."];
      connectorState: ConnectorState.t option
        [@ocaml.doc "The state of the connector."]}
    type nonrec error =
      [ `BadRequestException of BadRequestException.t 
      | `ConflictException of ConflictException.t 
      | `ForbiddenException of ForbiddenException.t 
      | `InternalServerErrorException of InternalServerErrorException.t 
      | `NotFoundException of NotFoundException.t 
      | `ServiceUnavailableException of ServiceUnavailableException.t 
      | `TooManyRequestsException of TooManyRequestsException.t 
      | `UnauthorizedException of UnauthorizedException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?connectorArn =
      fun ?connectorName ->
        fun ?connectorState ->
          fun () -> { connectorArn; connectorName; connectorState }
    let error_of_json name json =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_json json)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_json json)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_json json)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_json json)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_json json)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_json json)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_json json)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "BadRequestException" ->
          `BadRequestException (BadRequestException.of_xml xml)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_xml xml)
      | "ForbiddenException" ->
          `ForbiddenException (ForbiddenException.of_xml xml)
      | "InternalServerErrorException" ->
          `InternalServerErrorException
            (InternalServerErrorException.of_xml xml)
      | "NotFoundException" ->
          `NotFoundException (NotFoundException.of_xml xml)
      | "ServiceUnavailableException" ->
          `ServiceUnavailableException
            (ServiceUnavailableException.of_xml xml)
      | "TooManyRequestsException" ->
          `TooManyRequestsException (TooManyRequestsException.of_xml xml)
      | "UnauthorizedException" ->
          `UnauthorizedException (UnauthorizedException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `BadRequestException e ->
          `Assoc
            [("error", (`String "BadRequestException"));
            ("details", (BadRequestException.to_json e))]
      | `ConflictException e ->
          `Assoc
            [("error", (`String "ConflictException"));
            ("details", (ConflictException.to_json e))]
      | `ForbiddenException e ->
          `Assoc
            [("error", (`String "ForbiddenException"));
            ("details", (ForbiddenException.to_json e))]
      | `InternalServerErrorException e ->
          `Assoc
            [("error", (`String "InternalServerErrorException"));
            ("details", (InternalServerErrorException.to_json e))]
      | `NotFoundException e ->
          `Assoc
            [("error", (`String "NotFoundException"));
            ("details", (NotFoundException.to_json e))]
      | `ServiceUnavailableException e ->
          `Assoc
            [("error", (`String "ServiceUnavailableException"));
            ("details", (ServiceUnavailableException.to_json e))]
      | `TooManyRequestsException e ->
          `Assoc
            [("error", (`String "TooManyRequestsException"));
            ("details", (TooManyRequestsException.to_json e))]
      | `UnauthorizedException e ->
          `Assoc
            [("error", (`String "UnauthorizedException"));
            ("details", (UnauthorizedException.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
        [("connectorArn", (Option.map x.connectorArn ~f:Zz__string.to_value));
        ("connectorName",
          (Option.map x.connectorName ~f:Zz__string.to_value));
        ("connectorState",
          (Option.map x.connectorState ~f:ConnectorState.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let connectorState =
        (Option.map ~f:ConnectorState.of_xml)
          (Xml.child xml_arg0 "connectorState") in
      let connectorName =
        (Option.map ~f:Zz__string.of_xml)
          (Xml.child xml_arg0 "connectorName") in
      let connectorArn =
        (Option.map ~f:Zz__string.of_xml) (Xml.child xml_arg0 "connectorArn") in
      make ?connectorState ?connectorName ?connectorArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let connectorState =
        field_map json__ "connectorState" ConnectorState.of_json in
      let connectorName = field_map json__ "connectorName" Zz__string.of_json in
      let connectorArn = field_map json__ "connectorArn" Zz__string.of_json in
      make ?connectorState ?connectorName ?connectorArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Creates a connector using the specified properties."]
module CreateConnectorRequest =
  struct
    type nonrec t =
      {
      capacity: Capacity.t
        [@ocaml.doc
          "Information about the capacity allocated to the connector. Exactly one of the two properties must be specified."];
      connectorConfiguration: ConnectorConfiguration.t
        [@ocaml.doc
          "A map of keys to values that represent the configuration for the connector."];
      connectorDescription: Zz__stringMax1024.t option
        [@ocaml.doc "A summary description of the connector."];
      connectorName: Zz__stringMin1Max128.t
        [@ocaml.doc "The name of the connector."];
      kafkaCluster: KafkaCluster.t
        [@ocaml.doc "Specifies which Apache Kafka cluster to connect to."];
      kafkaClusterClientAuthentication: KafkaClusterClientAuthentication.t
        [@ocaml.doc
          "Details of the client authentication used by the Apache Kafka cluster."];
      kafkaClusterEncryptionInTransit: KafkaClusterEncryptionInTransit.t
        [@ocaml.doc
          "Details of encryption in transit to the Apache Kafka cluster."];
      kafkaConnectVersion: Zz__string.t
        [@ocaml.doc
          "The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins."];
      logDelivery: LogDelivery.t option
        [@ocaml.doc "Details about log delivery."];
      networkType: NetworkType.t option
        [@ocaml.doc
          "The network type of the connector. It gives connectors connectivity to either IPv4 (IPV4) or IPv4 and IPv6 (DUAL) destinations. Defaults to IPV4."];
      plugins: Zz__listOfPlugin.t
        [@ocaml.doc
          "Amazon MSK Connect does not currently support specifying multiple plugins as a list. To use more than one plugin for your connector, you can create a single custom plugin using a ZIP file that bundles multiple plugins together. Specifies which plugin to use for the connector. You must specify a single-element list containing one customPlugin object."];
      serviceExecutionRoleArn: Zz__string.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket."];
      workerConfiguration: WorkerConfiguration.t option
        [@ocaml.doc
          "Specifies which worker configuration to use with the connector."];
      tags: Tags.t option
        [@ocaml.doc "The tags you want to attach to the connector."]}
    let context_ = "CreateConnectorRequest"
    let make ?connectorDescription =
      fun ?logDelivery ->
        fun ?networkType ->
          fun ?workerConfiguration ->
            fun ?tags ->
              fun ~capacity ->
                fun ~connectorConfiguration ->
                  fun ~connectorName ->
                    fun ~kafkaCluster ->
                      fun ~kafkaClusterClientAuthentication ->
                        fun ~kafkaClusterEncryptionInTransit ->
                          fun ~kafkaConnectVersion ->
                            fun ~plugins ->
                              fun ~serviceExecutionRoleArn ->
                                fun () ->
                                  {
                                    connectorDescription;
                                    logDelivery;
                                    networkType;
                                    workerConfiguration;
                                    tags;
                                    capacity;
                                    connectorConfiguration;
                                    connectorName;
                                    kafkaCluster;
                                    kafkaClusterClientAuthentication;
                                    kafkaClusterEncryptionInTransit;
                                    kafkaConnectVersion;
                                    plugins;
                                    serviceExecutionRoleArn
                                  }
    let to_value x =
      structure_to_value
        [("capacity", (Some (Capacity.to_value x.capacity)));
        ("connectorConfiguration",
          (Some (ConnectorConfiguration.to_value x.connectorConfiguration)));
        ("connectorDescription",
          (Option.map x.connectorDescription ~f:Zz__stringMax1024.to_value));
        ("connectorName",
          (Some (Zz__stringMin1Max128.to_value x.connectorName)));
        ("kafkaCluster", (Some (KafkaCluster.to_value x.kafkaCluster)));
        ("kafkaClusterClientAuthentication",
          (Some
             (KafkaClusterClientAuthentication.to_value
                x.kafkaClusterClientAuthentication)));
        ("kafkaClusterEncryptionInTransit",
          (Some
             (KafkaClusterEncryptionInTransit.to_value
                x.kafkaClusterEncryptionInTransit)));
        ("kafkaConnectVersion",
          (Some (Zz__string.to_value x.kafkaConnectVersion)));
        ("logDelivery", (Option.map x.logDelivery ~f:LogDelivery.to_value));
        ("networkType", (Option.map x.networkType ~f:NetworkType.to_value));
        ("plugins", (Some (Zz__listOfPlugin.to_value x.plugins)));
        ("serviceExecutionRoleArn",
          (Some (Zz__string.to_value x.serviceExecutionRoleArn)));
        ("workerConfiguration",
          (Option.map x.workerConfiguration ~f:WorkerConfiguration.to_value));
        ("tags", (Option.map x.tags ~f:Tags.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let tags = (Option.map ~f:Tags.of_xml) (Xml.child xml_arg0 "tags") in
      let workerConfiguration =
        (Option.map ~f:WorkerConfiguration.of_xml)
          (Xml.child xml_arg0 "workerConfiguration") in
      let serviceExecutionRoleArn =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "serviceExecutionRoleArn") in
      let plugins =
        Zz__listOfPlugin.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "plugins") in
      let networkType =
        (Option.map ~f:NetworkType.of_xml) (Xml.child xml_arg0 "networkType") in
      let logDelivery =
        (Option.map ~f:LogDelivery.of_xml) (Xml.child xml_arg0 "logDelivery") in
      let kafkaConnectVersion =
        Zz__string.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "kafkaConnectVersion") in
      let kafkaClusterEncryptionInTransit =
        KafkaClusterEncryptionInTransit.of_xml
          (Xml.child_exn ~context:context_ xml_arg0
             "kafkaClusterEncryptionInTransit") in
      let kafkaClusterClientAuthentication =
        KafkaClusterClientAuthentication.of_xml
          (Xml.child_exn ~context:context_ xml_arg0
             "kafkaClusterClientAuthentication") in
      let kafkaCluster =
        KafkaCluster.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "kafkaCluster") in
      let connectorName =
        Zz__stringMin1Max128.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "connectorName") in
      let connectorDescription =
        (Option.map ~f:Zz__stringMax1024.of_xml)
          (Xml.child xml_arg0 "connectorDescription") in
      let connectorConfiguration =
        ConnectorConfiguration.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "connectorConfiguration") in
      let capacity =
        Capacity.of_xml (Xml.child_exn ~context:context_ xml_arg0 "capacity") in
      make ?tags ?workerConfiguration ~serviceExecutionRoleArn ~plugins
        ?networkType ?logDelivery ~kafkaConnectVersion
        ~kafkaClusterEncryptionInTransit ~kafkaClusterClientAuthentication
        ~kafkaCluster ~connectorName ?connectorDescription
        ~connectorConfiguration ~capacity ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let tags = field_map json__ "tags" Tags.of_json in
      let workerConfiguration =
        field_map json__ "workerConfiguration" WorkerConfiguration.of_json in
      let serviceExecutionRoleArn =
        field_map_exn json__ "serviceExecutionRoleArn" Zz__string.of_json in
      let plugins = field_map_exn json__ "plugins" Zz__listOfPlugin.of_json in
      let networkType = field_map json__ "networkType" NetworkType.of_json in
      let logDelivery = field_map json__ "logDelivery" LogDelivery.of_json in
      let kafkaConnectVersion =
        field_map_exn json__ "kafkaConnectVersion" Zz__string.of_json in
      let kafkaClusterEncryptionInTransit =
        field_map_exn json__ "kafkaClusterEncryptionInTransit"
          KafkaClusterEncryptionInTransit.of_json in
      let kafkaClusterClientAuthentication =
        field_map_exn json__ "kafkaClusterClientAuthentication"
          KafkaClusterClientAuthentication.of_json in
      let kafkaCluster =
        field_map_exn json__ "kafkaCluster" KafkaCluster.of_json in
      let connectorName =
        field_map_exn json__ "connectorName" Zz__stringMin1Max128.of_json in
      let connectorDescription =
        field_map json__ "connectorDescription" Zz__stringMax1024.of_json in
      let connectorConfiguration =
        field_map_exn json__ "connectorConfiguration"
          ConnectorConfiguration.of_json in
      let capacity = field_map_exn json__ "capacity" Capacity.of_json in
      make ?tags ?workerConfiguration ~serviceExecutionRoleArn ~plugins
        ?networkType ?logDelivery ~kafkaConnectVersion
        ~kafkaClusterEncryptionInTransit ~kafkaClusterClientAuthentication
        ~kafkaCluster ~connectorName ?connectorDescription
        ~connectorConfiguration ~capacity ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Creates a connector using the specified properties."]