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.osis
let apiVersion = "2022-01-01"
let endpointPrefix = "osis"
let serviceFullName = "Amazon OpenSearch Ingestion"
let signatureVersion = "v4"
let protocol = "rest_json"
let globalEndpoint = endpointPrefix ^ ".amazonaws.com"
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 SecurityGroupId =
  struct
    type nonrec t = string
    let context_ = "SecurityGroupId"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_min i ~min:11) >>=
             (fun () ->
                (check_string_max i ~max:20) >>=
                  (fun () -> check_pattern i ~pattern:"sg-\\w{8}(\\w{9})?")));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"SecurityGroupId" j
    let to_json = simple_to_json to_value
  end
module SubnetId =
  struct
    type nonrec t = string
    let context_ = "SubnetId"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_min i ~min:15) >>=
             (fun () ->
                (check_string_max i ~max:24) >>=
                  (fun () ->
                     check_pattern i ~pattern:"subnet-\\w{8}(\\w{9})?")));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"SubnetId" j
    let to_json = simple_to_json to_value
  end
module 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 CidrBlock =
  struct
    type nonrec t = string
    let context_ = "CidrBlock"
    let make i =
      let open Result in
        ok_or_failwith
          (check_pattern i
             ~pattern:"^((25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\\.){3}(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)/24$");
        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:"CidrBlock" j
    let to_json = simple_to_json to_value
  end
module SecurityGroupIds =
  struct
    type nonrec t = SecurityGroupId.t list
    let make i =
      let open Result in
        ok_or_failwith
          ((check_list_max i ~max:12) >>= (fun () -> check_list_min i ~min:1));
        i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:SecurityGroupId.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:SecurityGroupId.of_xml)
    let of_json j =
      list_of_json ~kind:"SecurityGroupIds" ~of_json:SecurityGroupId.of_json
        j
    let to_json v = composed_to_json to_value v
  end
module SubnetIds =
  struct
    type nonrec t = SubnetId.t list
    let make i =
      let open Result in
        ok_or_failwith
          ((check_list_max i ~max:12) >>= (fun () -> check_list_min i ~min:1));
        i
    let of_string _ =
      failwithf "of_string is not implemented for List_shape objects" ()
      [@@warning "-32"]
    let to_value xs =
      (xs |> (List.map ~f:SubnetId.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:SubnetId.of_xml)
    let of_json j =
      list_of_json ~kind:"SubnetIds" ~of_json:SubnetId.of_json j
    let to_json v = composed_to_json to_value v
  end
module VpcAttachmentOptions =
  struct
    type nonrec t =
      {
      attachToVpc: Boolean.t
        [@ocaml.doc "Whether a VPC is attached to the pipeline."];
      cidrBlock: CidrBlock.t option
        [@ocaml.doc
          "The CIDR block to be reserved for OpenSearch Ingestion to create elastic network interfaces (ENIs)."]}
    let context_ = "VpcAttachmentOptions"
    let make ?cidrBlock =
      fun ~attachToVpc -> fun () -> { cidrBlock; attachToVpc }
    let to_value x =
      structure_to_value
        [("AttachToVpc", (Some (Boolean.to_value x.attachToVpc)));
        ("CidrBlock", (Option.map x.cidrBlock ~f:CidrBlock.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let cidrBlock =
        (Option.map ~f:CidrBlock.of_xml) (Xml.child xml_arg0 "CidrBlock") in
      let attachToVpc =
        Boolean.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "AttachToVpc") in
      make ?cidrBlock ~attachToVpc ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let cidrBlock = field_map json__ "CidrBlock" CidrBlock.of_json in
      let attachToVpc = field_map_exn json__ "AttachToVpc" Boolean.of_json in
      make ?cidrBlock ~attachToVpc ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Options for attaching a VPC to pipeline."]
module VpcEndpointManagement =
  struct
    type nonrec t =
      | CUSTOMER 
      | SERVICE 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | CUSTOMER -> "CUSTOMER"
      | SERVICE -> "SERVICE"
      | Non_static_id s -> s
    let of_string =
      function
      | "CUSTOMER" -> CUSTOMER
      | "SERVICE" -> SERVICE
      | 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 VpcEndpointManagement" xml_arg0)
    let of_json j =
      of_string (string_of_json ~kind:"VpcEndpointManagement" j)
    let to_json = simple_to_json to_value
  end
module String_ =
  struct
    type nonrec t = string
    let context_ = "String"
    let make i = i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"String" j
    let to_json = simple_to_json to_value
  end
module TagKey =
  struct
    type nonrec t = string
    let context_ = "TagKey"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_min i ~min:1) >>=
             (fun () ->
                (check_string_max i ~max:128) >>=
                  (fun () -> check_pattern i ~pattern:".*")));
        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_min i ~min:0) >>=
             (fun () ->
                (check_string_max i ~max:256) >>=
                  (fun () -> check_pattern i ~pattern:".*")));
        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 ChangeProgressStageStatuses =
  struct
    type nonrec t =
      | PENDING 
      | IN_PROGRESS 
      | COMPLETED 
      | FAILED 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | PENDING -> "PENDING"
      | IN_PROGRESS -> "IN_PROGRESS"
      | COMPLETED -> "COMPLETED"
      | FAILED -> "FAILED"
      | Non_static_id s -> s
    let of_string =
      function
      | "PENDING" -> PENDING
      | "IN_PROGRESS" -> IN_PROGRESS
      | "COMPLETED" -> COMPLETED
      | "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 ChangeProgressStageStatuses"
           xml_arg0)
    let of_json j =
      of_string (string_of_json ~kind:"ChangeProgressStageStatuses" j)
    let to_json = simple_to_json to_value
  end
module Timestamp =
  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 LogGroup =
  struct
    type nonrec t = string
    let context_ = "LogGroup"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_min i ~min:1) >>=
             (fun () ->
                (check_string_max i ~max:512) >>=
                  (fun () ->
                     check_pattern i
                       ~pattern:"\\/aws\\/vendedlogs\\/[\\.\\-_/#A-Za-z0-9]+")));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"LogGroup" j
    let to_json = simple_to_json to_value
  end
module VpcEndpointServiceName =
  struct
    type nonrec t =
      | OPENSEARCH_SERVERLESS 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | OPENSEARCH_SERVERLESS -> "OPENSEARCH_SERVERLESS"
      | Non_static_id s -> s
    let of_string =
      function
      | "OPENSEARCH_SERVERLESS" -> OPENSEARCH_SERVERLESS
      | 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 VpcEndpointServiceName" xml_arg0)
    let of_json j =
      of_string (string_of_json ~kind:"VpcEndpointServiceName" j)
    let to_json = simple_to_json to_value
  end
module VpcOptions =
  struct
    type nonrec t =
      {
      subnetIds: SubnetIds.t
        [@ocaml.doc "A list of subnet IDs associated with the VPC endpoint."];
      securityGroupIds: SecurityGroupIds.t option
        [@ocaml.doc
          "A list of security groups associated with the VPC endpoint."];
      vpcAttachmentOptions: VpcAttachmentOptions.t option
        [@ocaml.doc "Options for attaching a VPC to a pipeline."];
      vpcEndpointManagement: VpcEndpointManagement.t option
        [@ocaml.doc
          "Defines whether you or Amazon OpenSearch Ingestion service create and manage the VPC endpoint configured for the pipeline."]}
    let context_ = "VpcOptions"
    let make ?securityGroupIds =
      fun ?vpcAttachmentOptions ->
        fun ?vpcEndpointManagement ->
          fun ~subnetIds ->
            fun () ->
              {
                securityGroupIds;
                vpcAttachmentOptions;
                vpcEndpointManagement;
                subnetIds
              }
    let to_value x =
      structure_to_value
        [("SubnetIds", (Some (SubnetIds.to_value x.subnetIds)));
        ("SecurityGroupIds",
          (Option.map x.securityGroupIds ~f:SecurityGroupIds.to_value));
        ("VpcAttachmentOptions",
          (Option.map x.vpcAttachmentOptions ~f:VpcAttachmentOptions.to_value));
        ("VpcEndpointManagement",
          (Option.map x.vpcEndpointManagement
             ~f:VpcEndpointManagement.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let vpcEndpointManagement =
        (Option.map ~f:VpcEndpointManagement.of_xml)
          (Xml.child xml_arg0 "VpcEndpointManagement") in
      let vpcAttachmentOptions =
        (Option.map ~f:VpcAttachmentOptions.of_xml)
          (Xml.child xml_arg0 "VpcAttachmentOptions") in
      let securityGroupIds =
        (Option.map ~f:SecurityGroupIds.of_xml)
          (Xml.child xml_arg0 "SecurityGroupIds") in
      let subnetIds =
        SubnetIds.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "SubnetIds") in
      make ?vpcEndpointManagement ?vpcAttachmentOptions ?securityGroupIds
        ~subnetIds ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let vpcEndpointManagement =
        field_map json__ "VpcEndpointManagement"
          VpcEndpointManagement.of_json in
      let vpcAttachmentOptions =
        field_map json__ "VpcAttachmentOptions" VpcAttachmentOptions.of_json in
      let securityGroupIds =
        field_map json__ "SecurityGroupIds" SecurityGroupIds.of_json in
      let subnetIds = field_map_exn json__ "SubnetIds" SubnetIds.of_json in
      make ?vpcEndpointManagement ?vpcAttachmentOptions ?securityGroupIds
        ~subnetIds ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Options that specify the subnets and security groups for an OpenSearch Ingestion VPC endpoint."]
module PipelineDestination =
  struct
    type nonrec t =
      {
      serviceName: String_.t option
        [@ocaml.doc
          "The name of the service receiving data from the pipeline."];
      endpoint: String_.t option
        [@ocaml.doc "The endpoint receiving data from the pipeline."]}
    let make ?serviceName =
      fun ?endpoint -> fun () -> { serviceName; endpoint }
    let to_value x =
      structure_to_value
        [("ServiceName", (Option.map x.serviceName ~f:String_.to_value));
        ("Endpoint", (Option.map x.endpoint ~f:String_.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let endpoint =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "Endpoint") in
      let serviceName =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "ServiceName") in
      make ?endpoint ?serviceName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let endpoint = field_map json__ "Endpoint" String_.of_json in
      let serviceName = field_map json__ "ServiceName" String_.of_json in
      make ?endpoint ?serviceName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "An object representing the destination of a pipeline."]
module Tag =
  struct
    type nonrec t =
      {
      key: TagKey.t
        [@ocaml.doc
          "The tag key. Tag keys must be unique for the pipeline to which they are attached."];
      value: TagValue.t
        [@ocaml.doc
          "The value assigned to the corresponding tag key. Tag values can be null and don't have to be unique in a tag set. For example, you can have a key value pair in a tag set of project : Trinity and cost-center : Trinity"]}
    let context_ = "Tag"
    let make ~key = fun ~value -> fun () -> { key; value }
    let to_value x =
      structure_to_value
        [("Key", (Some (TagKey.to_value x.key)));
        ("Value", (Some (TagValue.to_value x.value)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let value =
        TagValue.of_xml (Xml.child_exn ~context:context_ xml_arg0 "Value") in
      let key =
        TagKey.of_xml (Xml.child_exn ~context:context_ xml_arg0 "Key") in
      make ~value ~key ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let value = field_map_exn json__ "Value" TagValue.of_json in
      let key = field_map_exn json__ "Key" TagKey.of_json in
      make ~value ~key ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "A tag (key-value pair) for an OpenSearch Ingestion pipeline."]
module ChangeProgressStage =
  struct
    type nonrec t =
      {
      name: String_.t option [@ocaml.doc "The name of the stage."];
      status: ChangeProgressStageStatuses.t option
        [@ocaml.doc "The current status of the stage that the change is in."];
      description: String_.t option
        [@ocaml.doc "A description of the stage."];
      lastUpdatedAt: Timestamp.t option
        [@ocaml.doc "The most recent updated timestamp of the stage."]}
    let make ?name =
      fun ?status ->
        fun ?description ->
          fun ?lastUpdatedAt ->
            fun () -> { name; status; description; lastUpdatedAt }
    let to_value x =
      structure_to_value
        [("Name", (Option.map x.name ~f:String_.to_value));
        ("Status",
          (Option.map x.status ~f:ChangeProgressStageStatuses.to_value));
        ("Description", (Option.map x.description ~f:String_.to_value));
        ("LastUpdatedAt", (Option.map x.lastUpdatedAt ~f:Timestamp.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let lastUpdatedAt =
        (Option.map ~f:Timestamp.of_xml) (Xml.child xml_arg0 "LastUpdatedAt") in
      let description =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "Description") in
      let status =
        (Option.map ~f:ChangeProgressStageStatuses.of_xml)
          (Xml.child xml_arg0 "Status") in
      let name = (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "Name") in
      make ?lastUpdatedAt ?description ?status ?name ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let lastUpdatedAt = field_map json__ "LastUpdatedAt" Timestamp.of_json in
      let description = field_map json__ "Description" String_.of_json in
      let status =
        field_map json__ "Status" ChangeProgressStageStatuses.of_json in
      let name = field_map json__ "Name" String_.of_json in
      make ?lastUpdatedAt ?description ?status ?name ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Progress details for a specific stage of a pipeline configuration change."]
module KmsKeyArn =
  struct
    type nonrec t = string
    let context_ = "KmsKeyArn"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_max i ~max:2048) >>=
             (fun () -> check_string_min i ~min:7));
        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:"KmsKeyArn" j
    let to_json = simple_to_json to_value
  end
module CloudWatchLogDestination =
  struct
    type nonrec t =
      {
      logGroup: LogGroup.t
        [@ocaml.doc
          "The name of the CloudWatch Logs group to send pipeline logs to. You can specify an existing log group or create a new one. For example, /aws/vendedlogs/OpenSearchService/pipelines."]}
    let context_ = "CloudWatchLogDestination"
    let make ~logGroup = fun () -> { logGroup }
    let to_value x =
      structure_to_value
        [("LogGroup", (Some (LogGroup.to_value x.logGroup)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let logGroup =
        LogGroup.of_xml (Xml.child_exn ~context:context_ xml_arg0 "LogGroup") in
      make ~logGroup ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let logGroup = field_map_exn json__ "LogGroup" LogGroup.of_json in
      make ~logGroup ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The destination for OpenSearch Ingestion logs sent to Amazon CloudWatch."]
module ServiceVpcEndpoint =
  struct
    type nonrec t =
      {
      serviceName: VpcEndpointServiceName.t option
        [@ocaml.doc
          "The name of the service for which a VPC endpoint was created."];
      vpcEndpointId: String_.t option
        [@ocaml.doc
          "The unique identifier of the VPC endpoint that was created."]}
    let make ?serviceName =
      fun ?vpcEndpointId -> fun () -> { serviceName; vpcEndpointId }
    let to_value x =
      structure_to_value
        [("ServiceName",
           (Option.map x.serviceName ~f:VpcEndpointServiceName.to_value));
        ("VpcEndpointId", (Option.map x.vpcEndpointId ~f:String_.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let vpcEndpointId =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "VpcEndpointId") in
      let serviceName =
        (Option.map ~f:VpcEndpointServiceName.of_xml)
          (Xml.child xml_arg0 "ServiceName") in
      make ?vpcEndpointId ?serviceName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let vpcEndpointId = field_map json__ "VpcEndpointId" String_.of_json in
      let serviceName =
        field_map json__ "ServiceName" VpcEndpointServiceName.of_json in
      make ?vpcEndpointId ?serviceName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "A container for information about VPC endpoints that were created to other services"]
module VpcEndpoint =
  struct
    type nonrec t =
      {
      vpcEndpointId: String_.t option
        [@ocaml.doc "The unique identifier of the endpoint."];
      vpcId: String_.t option
        [@ocaml.doc
          "The ID for your VPC. Amazon Web Services PrivateLink generates this value when you create a VPC."];
      vpcOptions: VpcOptions.t option
        [@ocaml.doc
          "Information about the VPC, including associated subnets and security groups."]}
    let make ?vpcEndpointId =
      fun ?vpcId ->
        fun ?vpcOptions -> fun () -> { vpcEndpointId; vpcId; vpcOptions }
    let to_value x =
      structure_to_value
        [("VpcEndpointId", (Option.map x.vpcEndpointId ~f:String_.to_value));
        ("VpcId", (Option.map x.vpcId ~f:String_.to_value));
        ("VpcOptions", (Option.map x.vpcOptions ~f:VpcOptions.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let vpcOptions =
        (Option.map ~f:VpcOptions.of_xml) (Xml.child xml_arg0 "VpcOptions") in
      let vpcId = (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "VpcId") in
      let vpcEndpointId =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "VpcEndpointId") in
      make ?vpcOptions ?vpcId ?vpcEndpointId ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let vpcOptions = field_map json__ "VpcOptions" VpcOptions.of_json in
      let vpcId = field_map json__ "VpcId" String_.of_json in
      let vpcEndpointId = field_map json__ "VpcEndpointId" String_.of_json in
      make ?vpcOptions ?vpcId ?vpcEndpointId ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "An OpenSearch Ingestion-managed VPC endpoint that will access one or more pipelines."]
module PipelineArn =
  struct
    type nonrec t = string
    let context_ = "PipelineArn"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_min i ~min:46) >>=
             (fun () ->
                (check_string_max i ~max:76) >>=
                  (fun () ->
                     check_pattern i
                       ~pattern:"^arn:(aws|aws\\-cn|aws\\-us\\-gov|aws\\-iso|aws\\-iso\\-b):osis:.+:pipeline\\/.+$")));
        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:"PipelineArn" j
    let to_json = simple_to_json to_value
  end
module PipelineDestinationList =
  struct
    type nonrec t = PipelineDestination.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:PipelineDestination.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:PipelineDestination.of_xml)
    let of_json j =
      list_of_json ~kind:"PipelineDestinationList"
        ~of_json:PipelineDestination.of_json j
    let to_json v = composed_to_json to_value v
  end
module PipelineName =
  struct
    type nonrec t = string
    let context_ = "PipelineName"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_min i ~min:3) >>=
             (fun () ->
                (check_string_max i ~max:28) >>=
                  (fun () -> check_pattern i ~pattern:"[a-z][a-z0-9\\-]+")));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"PipelineName" j
    let to_json = simple_to_json to_value
  end
module PipelineStatus =
  struct
    type nonrec t =
      | CREATING 
      | ACTIVE 
      | UPDATING 
      | DELETING 
      | CREATE_FAILED 
      | UPDATE_FAILED 
      | STARTING 
      | START_FAILED 
      | STOPPING 
      | STOPPED 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | CREATING -> "CREATING"
      | ACTIVE -> "ACTIVE"
      | UPDATING -> "UPDATING"
      | DELETING -> "DELETING"
      | CREATE_FAILED -> "CREATE_FAILED"
      | UPDATE_FAILED -> "UPDATE_FAILED"
      | STARTING -> "STARTING"
      | START_FAILED -> "START_FAILED"
      | STOPPING -> "STOPPING"
      | STOPPED -> "STOPPED"
      | Non_static_id s -> s
    let of_string =
      function
      | "CREATING" -> CREATING
      | "ACTIVE" -> ACTIVE
      | "UPDATING" -> UPDATING
      | "DELETING" -> DELETING
      | "CREATE_FAILED" -> CREATE_FAILED
      | "UPDATE_FAILED" -> UPDATE_FAILED
      | "STARTING" -> STARTING
      | "START_FAILED" -> START_FAILED
      | "STOPPING" -> STOPPING
      | "STOPPED" -> STOPPED
      | 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 PipelineStatus" xml_arg0)
    let of_json j = of_string (string_of_json ~kind:"PipelineStatus" j)
    let to_json = simple_to_json to_value
  end
module PipelineStatusReason =
  struct
    type nonrec t =
      {
      description: String_.t option
        [@ocaml.doc "A description of why a pipeline has a certain status."]}
    let make ?description = fun () -> { description }
    let to_value x =
      structure_to_value
        [("Description", (Option.map x.description ~f:String_.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let description =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "Description") in
      make ?description ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let description = field_map json__ "Description" String_.of_json in
      make ?description ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Information about a pipeline's current status."]
module PipelineUnits =
  struct
    type nonrec t = int
    let make i =
      let open Result in ok_or_failwith (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 PipelineUnits" 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 TagList =
  struct
    type nonrec t = Tag.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:Tag.to_value)) |> (fun x -> `List x)
    let to_query v = to_query to_value v
    let to_header _ =
      failwithf "to_header is not implemented for List_shape objects" ()
    let of_xml x =
      make
        (List.map
           ((Xml.all_children x) |>
              (List.filter
                 ~f:(function
                     | `Data s ->
                         (match Stdlib.String.trim s with
                          | "" -> false
                          | _ -> true)
                     | _ -> true))) ~f:Tag.of_xml)
    let of_json j = list_of_json ~kind:"TagList" ~of_json:Tag.of_json j
    let to_json v = composed_to_json to_value v
  end
module PipelineEndpointId =
  struct
    type nonrec t = string
    let context_ = "PipelineEndpointId"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_min i ~min:3) >>=
             (fun () ->
                (check_string_max i ~max:512) >>=
                  (fun () ->
                     check_pattern i ~pattern:"^[a-zA-Z0-9][a-zA-Z0-9-_]+$")));
        i
    let of_string x = x
    let to_value x = `String x
    let to_query v = to_query to_value v
    let to_header x = x
    let of_xml = Xml.string_data_exn ~context:context_
    let of_json j = string_of_json ~kind:"PipelineEndpointId" j
    let to_json = simple_to_json to_value
  end
module PipelineEndpointStatus =
  struct
    type nonrec t =
      | CREATING 
      | ACTIVE 
      | CREATE_FAILED 
      | DELETING 
      | REVOKING 
      | REVOKED 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | CREATING -> "CREATING"
      | ACTIVE -> "ACTIVE"
      | CREATE_FAILED -> "CREATE_FAILED"
      | DELETING -> "DELETING"
      | REVOKING -> "REVOKING"
      | REVOKED -> "REVOKED"
      | Non_static_id s -> s
    let of_string =
      function
      | "CREATING" -> CREATING
      | "ACTIVE" -> ACTIVE
      | "CREATE_FAILED" -> CREATE_FAILED
      | "DELETING" -> DELETING
      | "REVOKING" -> REVOKING
      | "REVOKED" -> REVOKED
      | 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 PipelineEndpointStatus" xml_arg0)
    let of_json j =
      of_string (string_of_json ~kind:"PipelineEndpointStatus" j)
    let to_json = simple_to_json to_value
  end
module PipelineEndpointVpcOptions =
  struct
    type nonrec t =
      {
      subnetIds: SubnetIds.t option
        [@ocaml.doc
          "A list of subnet IDs where the pipeline endpoint network interfaces are created."];
      securityGroupIds: SecurityGroupIds.t option
        [@ocaml.doc
          "A list of security group IDs that control network access to the pipeline endpoint."]}
    let make ?subnetIds =
      fun ?securityGroupIds -> fun () -> { subnetIds; securityGroupIds }
    let to_value x =
      structure_to_value
        [("SubnetIds", (Option.map x.subnetIds ~f:SubnetIds.to_value));
        ("SecurityGroupIds",
          (Option.map x.securityGroupIds ~f:SecurityGroupIds.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let securityGroupIds =
        (Option.map ~f:SecurityGroupIds.of_xml)
          (Xml.child xml_arg0 "SecurityGroupIds") in
      let subnetIds =
        (Option.map ~f:SubnetIds.of_xml) (Xml.child xml_arg0 "SubnetIds") in
      make ?securityGroupIds ?subnetIds ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let securityGroupIds =
        field_map json__ "SecurityGroupIds" SecurityGroupIds.of_json in
      let subnetIds = field_map json__ "SubnetIds" SubnetIds.of_json in
      make ?securityGroupIds ?subnetIds ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Configuration settings for the VPC endpoint, specifying network access controls."]
module AwsAccountId =
  struct
    type nonrec t = string
    let context_ = "AwsAccountId"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_min i ~min:12) >>=
             (fun () ->
                (check_string_max i ~max:12) >>=
                  (fun () -> check_pattern i ~pattern:"^\\\\d{12}$")));
        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:"AwsAccountId" j
    let to_json = simple_to_json to_value
  end
module ChangeProgressStageList =
  struct
    type nonrec t = ChangeProgressStage.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:ChangeProgressStage.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:ChangeProgressStage.of_xml)
    let of_json j =
      list_of_json ~kind:"ChangeProgressStageList"
        ~of_json:ChangeProgressStage.of_json j
    let to_json v = composed_to_json to_value v
  end
module ChangeProgressStatuses =
  struct
    type nonrec t =
      | PENDING 
      | IN_PROGRESS 
      | COMPLETED 
      | FAILED 
      | Non_static_id of string 
    let make i = i
    let to_string =
      function
      | PENDING -> "PENDING"
      | IN_PROGRESS -> "IN_PROGRESS"
      | COMPLETED -> "COMPLETED"
      | FAILED -> "FAILED"
      | Non_static_id s -> s
    let of_string =
      function
      | "PENDING" -> PENDING
      | "IN_PROGRESS" -> IN_PROGRESS
      | "COMPLETED" -> COMPLETED
      | "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 ChangeProgressStatuses" xml_arg0)
    let of_json j =
      of_string (string_of_json ~kind:"ChangeProgressStatuses" j)
    let to_json = simple_to_json to_value
  end
module 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 ValidationMessage =
  struct
    type nonrec t =
      {
      message: String_.t option [@ocaml.doc "The validation message."]}
    let make ?message = fun () -> { message }
    let to_value x =
      structure_to_value
        [("Message", (Option.map x.message ~f:String_.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let message =
        (Option.map ~f: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" String_.of_json in
      make ?message ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "A validation message associated with a ValidatePipeline request in OpenSearch Ingestion."]
module BufferOptions =
  struct
    type nonrec t =
      {
      persistentBufferEnabled: Boolean.t
        [@ocaml.doc "Whether persistent buffering should be enabled."]}
    let context_ = "BufferOptions"
    let make ~persistentBufferEnabled = fun () -> { persistentBufferEnabled }
    let to_value x =
      structure_to_value
        [("PersistentBufferEnabled",
           (Some (Boolean.to_value x.persistentBufferEnabled)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let persistentBufferEnabled =
        Boolean.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "PersistentBufferEnabled") in
      make ~persistentBufferEnabled ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let persistentBufferEnabled =
        field_map_exn json__ "PersistentBufferEnabled" Boolean.of_json in
      make ~persistentBufferEnabled ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Options that specify the configuration of a persistent buffer. To configure how OpenSearch Ingestion encrypts this data, set the EncryptionAtRestOptions. For more information, see Persistent buffering."]
module EncryptionAtRestOptions =
  struct
    type nonrec t =
      {
      kmsKeyArn: KmsKeyArn.t
        [@ocaml.doc
          "The ARN of the KMS key used to encrypt buffer data. By default, data is encrypted using an Amazon Web Services owned key."]}
    let context_ = "EncryptionAtRestOptions"
    let make ~kmsKeyArn = fun () -> { kmsKeyArn }
    let to_value x =
      structure_to_value
        [("KmsKeyArn", (Some (KmsKeyArn.to_value x.kmsKeyArn)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let kmsKeyArn =
        KmsKeyArn.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "KmsKeyArn") in
      make ~kmsKeyArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let kmsKeyArn = field_map_exn json__ "KmsKeyArn" KmsKeyArn.of_json in
      make ~kmsKeyArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Options to control how OpenSearch encrypts buffer data."]
module IngestEndpointUrlsList =
  struct
    type nonrec t = 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: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:String_.of_xml)
    let of_json j =
      list_of_json ~kind:"IngestEndpointUrlsList" ~of_json:String_.of_json j
    let to_json v = composed_to_json to_value v
  end
module LogPublishingOptions =
  struct
    type nonrec t =
      {
      isLoggingEnabled: Boolean.t option
        [@ocaml.doc "Whether logs should be published."];
      cloudWatchLogDestination: CloudWatchLogDestination.t option
        [@ocaml.doc
          "The destination for OpenSearch Ingestion logs sent to Amazon CloudWatch Logs. This parameter is required if IsLoggingEnabled is set to true."]}
    let make ?isLoggingEnabled =
      fun ?cloudWatchLogDestination ->
        fun () -> { isLoggingEnabled; cloudWatchLogDestination }
    let to_value x =
      structure_to_value
        [("IsLoggingEnabled",
           (Option.map x.isLoggingEnabled ~f:Boolean.to_value));
        ("CloudWatchLogDestination",
          (Option.map x.cloudWatchLogDestination
             ~f:CloudWatchLogDestination.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let cloudWatchLogDestination =
        (Option.map ~f:CloudWatchLogDestination.of_xml)
          (Xml.child xml_arg0 "CloudWatchLogDestination") in
      let isLoggingEnabled =
        (Option.map ~f:Boolean.of_xml)
          (Xml.child xml_arg0 "IsLoggingEnabled") in
      make ?cloudWatchLogDestination ?isLoggingEnabled ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let cloudWatchLogDestination =
        field_map json__ "CloudWatchLogDestination"
          CloudWatchLogDestination.of_json in
      let isLoggingEnabled =
        field_map json__ "IsLoggingEnabled" Boolean.of_json in
      make ?cloudWatchLogDestination ?isLoggingEnabled ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Container for the values required to configure logging for the pipeline. If you don't specify these values, OpenSearch Ingestion will not publish logs from your application to CloudWatch Logs."]
module PipelineRoleArn =
  struct
    type nonrec t = string
    let context_ = "PipelineRoleArn"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_min i ~min:20) >>=
             (fun () ->
                (check_string_max i ~max:2048) >>=
                  (fun () ->
                     check_pattern i
                       ~pattern:"^arn:(aws|aws\\-cn|aws\\-us\\-gov|aws\\-iso|aws\\-iso\\-b|aws\\-iso\\-e|aws\\-iso\\-f):iam::[0-9]+:role\\/.*$")));
        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:"PipelineRoleArn" j
    let to_json = simple_to_json to_value
  end
module ServiceVpcEndpointsList =
  struct
    type nonrec t = ServiceVpcEndpoint.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:ServiceVpcEndpoint.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:ServiceVpcEndpoint.of_xml)
    let of_json j =
      list_of_json ~kind:"ServiceVpcEndpointsList"
        ~of_json:ServiceVpcEndpoint.of_json j
    let to_json v = composed_to_json to_value v
  end
module VpcEndpointsList =
  struct
    type nonrec t = VpcEndpoint.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:VpcEndpoint.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:VpcEndpoint.of_xml)
    let of_json j =
      list_of_json ~kind:"VpcEndpointsList" ~of_json:VpcEndpoint.of_json j
    let to_json v = composed_to_json to_value v
  end
module PipelineSummary =
  struct
    type nonrec t =
      {
      status: PipelineStatus.t option
        [@ocaml.doc "The current status of the pipeline."];
      statusReason: PipelineStatusReason.t option ;
      pipelineName: PipelineName.t option
        [@ocaml.doc "The name of the pipeline."];
      pipelineArn: PipelineArn.t option
        [@ocaml.doc "The Amazon Resource Name (ARN) of the pipeline."];
      minUnits: PipelineUnits.t option
        [@ocaml.doc
          "The minimum pipeline capacity, in Ingestion Compute Units (ICUs)."];
      maxUnits: PipelineUnits.t option
        [@ocaml.doc
          "The maximum pipeline capacity, in Ingestion Compute Units (ICUs)."];
      createdAt: Timestamp.t option
        [@ocaml.doc "The date and time when the pipeline was created."];
      lastUpdatedAt: Timestamp.t option
        [@ocaml.doc "The date and time when the pipeline was last updated."];
      destinations: PipelineDestinationList.t option
        [@ocaml.doc
          "A list of destinations to which the pipeline writes data."];
      tags: TagList.t option
        [@ocaml.doc "A list of tags associated with the given pipeline."]}
    let make ?status =
      fun ?statusReason ->
        fun ?pipelineName ->
          fun ?pipelineArn ->
            fun ?minUnits ->
              fun ?maxUnits ->
                fun ?createdAt ->
                  fun ?lastUpdatedAt ->
                    fun ?destinations ->
                      fun ?tags ->
                        fun () ->
                          {
                            status;
                            statusReason;
                            pipelineName;
                            pipelineArn;
                            minUnits;
                            maxUnits;
                            createdAt;
                            lastUpdatedAt;
                            destinations;
                            tags
                          }
    let to_value x =
      structure_to_value
        [("Status", (Option.map x.status ~f:PipelineStatus.to_value));
        ("StatusReason",
          (Option.map x.statusReason ~f:PipelineStatusReason.to_value));
        ("PipelineName",
          (Option.map x.pipelineName ~f:PipelineName.to_value));
        ("PipelineArn", (Option.map x.pipelineArn ~f:PipelineArn.to_value));
        ("MinUnits", (Option.map x.minUnits ~f:PipelineUnits.to_value));
        ("MaxUnits", (Option.map x.maxUnits ~f:PipelineUnits.to_value));
        ("CreatedAt", (Option.map x.createdAt ~f:Timestamp.to_value));
        ("LastUpdatedAt", (Option.map x.lastUpdatedAt ~f:Timestamp.to_value));
        ("Destinations",
          (Option.map x.destinations ~f:PipelineDestinationList.to_value));
        ("Tags", (Option.map x.tags ~f:TagList.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let tags = (Option.map ~f:TagList.of_xml) (Xml.child xml_arg0 "Tags") in
      let destinations =
        (Option.map ~f:PipelineDestinationList.of_xml)
          (Xml.child xml_arg0 "Destinations") in
      let lastUpdatedAt =
        (Option.map ~f:Timestamp.of_xml) (Xml.child xml_arg0 "LastUpdatedAt") in
      let createdAt =
        (Option.map ~f:Timestamp.of_xml) (Xml.child xml_arg0 "CreatedAt") in
      let maxUnits =
        (Option.map ~f:PipelineUnits.of_xml) (Xml.child xml_arg0 "MaxUnits") in
      let minUnits =
        (Option.map ~f:PipelineUnits.of_xml) (Xml.child xml_arg0 "MinUnits") in
      let pipelineArn =
        (Option.map ~f:PipelineArn.of_xml) (Xml.child xml_arg0 "PipelineArn") in
      let pipelineName =
        (Option.map ~f:PipelineName.of_xml)
          (Xml.child xml_arg0 "PipelineName") in
      let statusReason =
        (Option.map ~f:PipelineStatusReason.of_xml)
          (Xml.child xml_arg0 "StatusReason") in
      let status =
        (Option.map ~f:PipelineStatus.of_xml) (Xml.child xml_arg0 "Status") in
      make ?tags ?destinations ?lastUpdatedAt ?createdAt ?maxUnits ?minUnits
        ?pipelineArn ?pipelineName ?statusReason ?status ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let tags = field_map json__ "Tags" TagList.of_json in
      let destinations =
        field_map json__ "Destinations" PipelineDestinationList.of_json in
      let lastUpdatedAt = field_map json__ "LastUpdatedAt" Timestamp.of_json in
      let createdAt = field_map json__ "CreatedAt" Timestamp.of_json in
      let maxUnits = field_map json__ "MaxUnits" PipelineUnits.of_json in
      let minUnits = field_map json__ "MinUnits" PipelineUnits.of_json in
      let pipelineArn = field_map json__ "PipelineArn" PipelineArn.of_json in
      let pipelineName = field_map json__ "PipelineName" PipelineName.of_json in
      let statusReason =
        field_map json__ "StatusReason" PipelineStatusReason.of_json in
      let status = field_map json__ "Status" PipelineStatus.of_json in
      make ?tags ?destinations ?lastUpdatedAt ?createdAt ?maxUnits ?minUnits
        ?pipelineArn ?pipelineName ?statusReason ?status ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Summary information for an OpenSearch Ingestion pipeline."]
module PipelineEndpoint =
  struct
    type nonrec t =
      {
      pipelineArn: PipelineArn.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the pipeline associated with this endpoint."];
      endpointId: PipelineEndpointId.t option
        [@ocaml.doc "The unique identifier for the pipeline endpoint."];
      status: PipelineEndpointStatus.t option
        [@ocaml.doc "The current status of the pipeline endpoint."];
      vpcId: String_.t option
        [@ocaml.doc
          "The ID of the VPC where the pipeline endpoint is created."];
      vpcOptions: PipelineEndpointVpcOptions.t option
        [@ocaml.doc
          "Configuration options for the VPC endpoint, including subnet and security group settings."];
      ingestEndpointUrl: String_.t option
        [@ocaml.doc
          "The URL used to ingest data to the pipeline through the VPC endpoint."]}
    let make ?pipelineArn =
      fun ?endpointId ->
        fun ?status ->
          fun ?vpcId ->
            fun ?vpcOptions ->
              fun ?ingestEndpointUrl ->
                fun () ->
                  {
                    pipelineArn;
                    endpointId;
                    status;
                    vpcId;
                    vpcOptions;
                    ingestEndpointUrl
                  }
    let to_value x =
      structure_to_value
        [("PipelineArn", (Option.map x.pipelineArn ~f:PipelineArn.to_value));
        ("EndpointId",
          (Option.map x.endpointId ~f:PipelineEndpointId.to_value));
        ("Status", (Option.map x.status ~f:PipelineEndpointStatus.to_value));
        ("VpcId", (Option.map x.vpcId ~f:String_.to_value));
        ("VpcOptions",
          (Option.map x.vpcOptions ~f:PipelineEndpointVpcOptions.to_value));
        ("IngestEndpointUrl",
          (Option.map x.ingestEndpointUrl ~f:String_.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let ingestEndpointUrl =
        (Option.map ~f:String_.of_xml)
          (Xml.child xml_arg0 "IngestEndpointUrl") in
      let vpcOptions =
        (Option.map ~f:PipelineEndpointVpcOptions.of_xml)
          (Xml.child xml_arg0 "VpcOptions") in
      let vpcId = (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "VpcId") in
      let status =
        (Option.map ~f:PipelineEndpointStatus.of_xml)
          (Xml.child xml_arg0 "Status") in
      let endpointId =
        (Option.map ~f:PipelineEndpointId.of_xml)
          (Xml.child xml_arg0 "EndpointId") in
      let pipelineArn =
        (Option.map ~f:PipelineArn.of_xml) (Xml.child xml_arg0 "PipelineArn") in
      make ?ingestEndpointUrl ?vpcOptions ?vpcId ?status ?endpointId
        ?pipelineArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let ingestEndpointUrl =
        field_map json__ "IngestEndpointUrl" String_.of_json in
      let vpcOptions =
        field_map json__ "VpcOptions" PipelineEndpointVpcOptions.of_json in
      let vpcId = field_map json__ "VpcId" String_.of_json in
      let status = field_map json__ "Status" PipelineEndpointStatus.of_json in
      let endpointId =
        field_map json__ "EndpointId" PipelineEndpointId.of_json in
      let pipelineArn = field_map json__ "PipelineArn" PipelineArn.of_json in
      make ?ingestEndpointUrl ?vpcOptions ?vpcId ?status ?endpointId
        ?pipelineArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Represents a VPC endpoint for an OpenSearch Ingestion pipeline, enabling private connectivity between your VPC and the pipeline."]
module PipelineEndpointConnection =
  struct
    type nonrec t =
      {
      pipelineArn: PipelineArn.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the pipeline in the endpoint connection."];
      endpointId: PipelineEndpointId.t option
        [@ocaml.doc
          "The unique identifier of the endpoint in the connection."];
      status: PipelineEndpointStatus.t option
        [@ocaml.doc
          "The current status of the pipeline endpoint connection."];
      vpcEndpointOwner: AwsAccountId.t option
        [@ocaml.doc
          "The Amazon Web Services account ID that owns the VPC endpoint used in this connection."]}
    let make ?pipelineArn =
      fun ?endpointId ->
        fun ?status ->
          fun ?vpcEndpointOwner ->
            fun () -> { pipelineArn; endpointId; status; vpcEndpointOwner }
    let to_value x =
      structure_to_value
        [("PipelineArn", (Option.map x.pipelineArn ~f:PipelineArn.to_value));
        ("EndpointId",
          (Option.map x.endpointId ~f:PipelineEndpointId.to_value));
        ("Status", (Option.map x.status ~f:PipelineEndpointStatus.to_value));
        ("VpcEndpointOwner",
          (Option.map x.vpcEndpointOwner ~f:AwsAccountId.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let vpcEndpointOwner =
        (Option.map ~f:AwsAccountId.of_xml)
          (Xml.child xml_arg0 "VpcEndpointOwner") in
      let status =
        (Option.map ~f:PipelineEndpointStatus.of_xml)
          (Xml.child xml_arg0 "Status") in
      let endpointId =
        (Option.map ~f:PipelineEndpointId.of_xml)
          (Xml.child xml_arg0 "EndpointId") in
      let pipelineArn =
        (Option.map ~f:PipelineArn.of_xml) (Xml.child xml_arg0 "PipelineArn") in
      make ?vpcEndpointOwner ?status ?endpointId ?pipelineArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let vpcEndpointOwner =
        field_map json__ "VpcEndpointOwner" AwsAccountId.of_json in
      let status = field_map json__ "Status" PipelineEndpointStatus.of_json in
      let endpointId =
        field_map json__ "EndpointId" PipelineEndpointId.of_json in
      let pipelineArn = field_map json__ "PipelineArn" PipelineArn.of_json in
      make ?vpcEndpointOwner ?status ?endpointId ?pipelineArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Represents a connection to a pipeline endpoint, containing details about the endpoint association."]
module PipelineBlueprintSummary =
  struct
    type nonrec t =
      {
      blueprintName: String_.t option
        [@ocaml.doc "The name of the blueprint."];
      displayName: String_.t option
        [@ocaml.doc "The display name of the blueprint."];
      displayDescription: String_.t option
        [@ocaml.doc "A description of the blueprint."];
      service: String_.t option
        [@ocaml.doc
          "The name of the service that the blueprint is associated with."];
      useCase: String_.t option
        [@ocaml.doc "The use case that the blueprint relates to."]}
    let make ?blueprintName =
      fun ?displayName ->
        fun ?displayDescription ->
          fun ?service ->
            fun ?useCase ->
              fun () ->
                {
                  blueprintName;
                  displayName;
                  displayDescription;
                  service;
                  useCase
                }
    let to_value x =
      structure_to_value
        [("BlueprintName", (Option.map x.blueprintName ~f:String_.to_value));
        ("DisplayName", (Option.map x.displayName ~f:String_.to_value));
        ("DisplayDescription",
          (Option.map x.displayDescription ~f:String_.to_value));
        ("Service", (Option.map x.service ~f:String_.to_value));
        ("UseCase", (Option.map x.useCase ~f:String_.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let useCase =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "UseCase") in
      let service =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "Service") in
      let displayDescription =
        (Option.map ~f:String_.of_xml)
          (Xml.child xml_arg0 "DisplayDescription") in
      let displayName =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "DisplayName") in
      let blueprintName =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "BlueprintName") in
      make ?useCase ?service ?displayDescription ?displayName ?blueprintName
        ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let useCase = field_map json__ "UseCase" String_.of_json in
      let service = field_map json__ "Service" String_.of_json in
      let displayDescription =
        field_map json__ "DisplayDescription" String_.of_json in
      let displayName = field_map json__ "DisplayName" String_.of_json in
      let blueprintName = field_map json__ "BlueprintName" String_.of_json in
      make ?useCase ?service ?displayDescription ?displayName ?blueprintName
        ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "A summary of an OpenSearch Ingestion blueprint."]
module ChangeProgressStatus =
  struct
    type nonrec t =
      {
      startTime: Timestamp.t option
        [@ocaml.doc
          "The time at which the configuration change is made on the pipeline."];
      status: ChangeProgressStatuses.t option
        [@ocaml.doc
          "The overall status of the pipeline configuration change."];
      totalNumberOfStages: Integer.t option
        [@ocaml.doc
          "The total number of stages required for the pipeline configuration change."];
      changeProgressStages: ChangeProgressStageList.t option
        [@ocaml.doc
          "Information about the stages that the pipeline is going through to perform the configuration change."]}
    let make ?startTime =
      fun ?status ->
        fun ?totalNumberOfStages ->
          fun ?changeProgressStages ->
            fun () ->
              { startTime; status; totalNumberOfStages; changeProgressStages
              }
    let to_value x =
      structure_to_value
        [("StartTime", (Option.map x.startTime ~f:Timestamp.to_value));
        ("Status", (Option.map x.status ~f:ChangeProgressStatuses.to_value));
        ("TotalNumberOfStages",
          (Option.map x.totalNumberOfStages ~f:Integer.to_value));
        ("ChangeProgressStages",
          (Option.map x.changeProgressStages
             ~f:ChangeProgressStageList.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let changeProgressStages =
        (Option.map ~f:ChangeProgressStageList.of_xml)
          (Xml.child xml_arg0 "ChangeProgressStages") in
      let totalNumberOfStages =
        (Option.map ~f:Integer.of_xml)
          (Xml.child xml_arg0 "TotalNumberOfStages") in
      let status =
        (Option.map ~f:ChangeProgressStatuses.of_xml)
          (Xml.child xml_arg0 "Status") in
      let startTime =
        (Option.map ~f:Timestamp.of_xml) (Xml.child xml_arg0 "StartTime") in
      make ?changeProgressStages ?totalNumberOfStages ?status ?startTime ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let changeProgressStages =
        field_map json__ "ChangeProgressStages"
          ChangeProgressStageList.of_json in
      let totalNumberOfStages =
        field_map json__ "TotalNumberOfStages" Integer.of_json in
      let status = field_map json__ "Status" ChangeProgressStatuses.of_json in
      let startTime = field_map json__ "StartTime" Timestamp.of_json in
      make ?changeProgressStages ?totalNumberOfStages ?status ?startTime ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "The progress details of a pipeline configuration change."]
module AccessDeniedException =
  struct
    type nonrec t = unit
    let make () = ()
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "You don't have permissions to access the resource."]
module DisabledOperationException =
  struct
    type nonrec t = unit
    let make () = ()
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Exception is thrown when an operation has been disabled."]
module InternalException =
  struct
    type nonrec t = unit
    let make () = ()
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The request failed because of an unknown error, exception, or failure (the failure is internal to the service)."]
module ValidationException =
  struct
    type nonrec t = unit
    let make () = ()
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "An exception for missing or invalid input fields."]
module ValidationMessageList =
  struct
    type nonrec t = ValidationMessage.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:ValidationMessage.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:ValidationMessage.of_xml)
    let of_json j =
      list_of_json ~kind:"ValidationMessageList"
        ~of_json:ValidationMessage.of_json j
    let to_json v = composed_to_json to_value v
  end
module PipelineConfigurationBody =
  struct
    type nonrec t = string
    let context_ = "PipelineConfigurationBody"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_max i ~max:100000) >>=
             (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:"PipelineConfigurationBody" j
    let to_json = simple_to_json to_value
  end
module ConflictException =
  struct
    type nonrec t = unit
    let make () = ()
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "The client attempted to remove a resource that is currently in use."]
module Pipeline =
  struct
    type nonrec t =
      {
      pipelineName: String_.t option [@ocaml.doc "The name of the pipeline."];
      pipelineArn: String_.t option
        [@ocaml.doc "The Amazon Resource Name (ARN) of the pipeline."];
      minUnits: Integer.t option
        [@ocaml.doc
          "The minimum pipeline capacity, in Ingestion Compute Units (ICUs)."];
      maxUnits: Integer.t option
        [@ocaml.doc
          "The maximum pipeline capacity, in Ingestion Compute Units (ICUs)."];
      status: PipelineStatus.t option
        [@ocaml.doc "The current status of the pipeline."];
      statusReason: PipelineStatusReason.t option
        [@ocaml.doc "The reason for the current status of the pipeline."];
      pipelineConfigurationBody: String_.t option
        [@ocaml.doc
          "The Data Prepper pipeline configuration in YAML format."];
      createdAt: Timestamp.t option
        [@ocaml.doc "The date and time when the pipeline was created."];
      lastUpdatedAt: Timestamp.t option
        [@ocaml.doc "The date and time when the pipeline was last updated."];
      ingestEndpointUrls: IngestEndpointUrlsList.t option
        [@ocaml.doc
          "The ingestion endpoints for the pipeline, which you can send data to."];
      logPublishingOptions: LogPublishingOptions.t option
        [@ocaml.doc
          "Key-value pairs that represent log publishing settings."];
      vpcEndpoints: VpcEndpointsList.t option
        [@ocaml.doc
          "The VPC interface endpoints that have access to the pipeline."];
      bufferOptions: BufferOptions.t option ;
      encryptionAtRestOptions: EncryptionAtRestOptions.t option ;
      vpcEndpointService: String_.t option
        [@ocaml.doc "The VPC endpoint service name for the pipeline."];
      serviceVpcEndpoints: ServiceVpcEndpointsList.t option
        [@ocaml.doc
          "A list of VPC endpoints that OpenSearch Ingestion has created to other Amazon Web Services services."];
      destinations: PipelineDestinationList.t option
        [@ocaml.doc "Destinations to which the pipeline writes data."];
      tags: TagList.t option
        [@ocaml.doc "A list of tags associated with the given pipeline."];
      pipelineRoleArn: PipelineRoleArn.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the IAM role that the pipeline uses to access AWS resources."]}
    let make ?pipelineName =
      fun ?pipelineArn ->
        fun ?minUnits ->
          fun ?maxUnits ->
            fun ?status ->
              fun ?statusReason ->
                fun ?pipelineConfigurationBody ->
                  fun ?createdAt ->
                    fun ?lastUpdatedAt ->
                      fun ?ingestEndpointUrls ->
                        fun ?logPublishingOptions ->
                          fun ?vpcEndpoints ->
                            fun ?bufferOptions ->
                              fun ?encryptionAtRestOptions ->
                                fun ?vpcEndpointService ->
                                  fun ?serviceVpcEndpoints ->
                                    fun ?destinations ->
                                      fun ?tags ->
                                        fun ?pipelineRoleArn ->
                                          fun () ->
                                            {
                                              pipelineName;
                                              pipelineArn;
                                              minUnits;
                                              maxUnits;
                                              status;
                                              statusReason;
                                              pipelineConfigurationBody;
                                              createdAt;
                                              lastUpdatedAt;
                                              ingestEndpointUrls;
                                              logPublishingOptions;
                                              vpcEndpoints;
                                              bufferOptions;
                                              encryptionAtRestOptions;
                                              vpcEndpointService;
                                              serviceVpcEndpoints;
                                              destinations;
                                              tags;
                                              pipelineRoleArn
                                            }
    let to_value x =
      structure_to_value
        [("PipelineName", (Option.map x.pipelineName ~f:String_.to_value));
        ("PipelineArn", (Option.map x.pipelineArn ~f:String_.to_value));
        ("MinUnits", (Option.map x.minUnits ~f:Integer.to_value));
        ("MaxUnits", (Option.map x.maxUnits ~f:Integer.to_value));
        ("Status", (Option.map x.status ~f:PipelineStatus.to_value));
        ("StatusReason",
          (Option.map x.statusReason ~f:PipelineStatusReason.to_value));
        ("PipelineConfigurationBody",
          (Option.map x.pipelineConfigurationBody ~f:String_.to_value));
        ("CreatedAt", (Option.map x.createdAt ~f:Timestamp.to_value));
        ("LastUpdatedAt", (Option.map x.lastUpdatedAt ~f:Timestamp.to_value));
        ("IngestEndpointUrls",
          (Option.map x.ingestEndpointUrls ~f:IngestEndpointUrlsList.to_value));
        ("LogPublishingOptions",
          (Option.map x.logPublishingOptions ~f:LogPublishingOptions.to_value));
        ("VpcEndpoints",
          (Option.map x.vpcEndpoints ~f:VpcEndpointsList.to_value));
        ("BufferOptions",
          (Option.map x.bufferOptions ~f:BufferOptions.to_value));
        ("EncryptionAtRestOptions",
          (Option.map x.encryptionAtRestOptions
             ~f:EncryptionAtRestOptions.to_value));
        ("VpcEndpointService",
          (Option.map x.vpcEndpointService ~f:String_.to_value));
        ("ServiceVpcEndpoints",
          (Option.map x.serviceVpcEndpoints
             ~f:ServiceVpcEndpointsList.to_value));
        ("Destinations",
          (Option.map x.destinations ~f:PipelineDestinationList.to_value));
        ("Tags", (Option.map x.tags ~f:TagList.to_value));
        ("PipelineRoleArn",
          (Option.map x.pipelineRoleArn ~f:PipelineRoleArn.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipelineRoleArn =
        (Option.map ~f:PipelineRoleArn.of_xml)
          (Xml.child xml_arg0 "PipelineRoleArn") in
      let tags = (Option.map ~f:TagList.of_xml) (Xml.child xml_arg0 "Tags") in
      let destinations =
        (Option.map ~f:PipelineDestinationList.of_xml)
          (Xml.child xml_arg0 "Destinations") in
      let serviceVpcEndpoints =
        (Option.map ~f:ServiceVpcEndpointsList.of_xml)
          (Xml.child xml_arg0 "ServiceVpcEndpoints") in
      let vpcEndpointService =
        (Option.map ~f:String_.of_xml)
          (Xml.child xml_arg0 "VpcEndpointService") in
      let encryptionAtRestOptions =
        (Option.map ~f:EncryptionAtRestOptions.of_xml)
          (Xml.child xml_arg0 "EncryptionAtRestOptions") in
      let bufferOptions =
        (Option.map ~f:BufferOptions.of_xml)
          (Xml.child xml_arg0 "BufferOptions") in
      let vpcEndpoints =
        (Option.map ~f:VpcEndpointsList.of_xml)
          (Xml.child xml_arg0 "VpcEndpoints") in
      let logPublishingOptions =
        (Option.map ~f:LogPublishingOptions.of_xml)
          (Xml.child xml_arg0 "LogPublishingOptions") in
      let ingestEndpointUrls =
        (Option.map ~f:IngestEndpointUrlsList.of_xml)
          (Xml.child xml_arg0 "IngestEndpointUrls") in
      let lastUpdatedAt =
        (Option.map ~f:Timestamp.of_xml) (Xml.child xml_arg0 "LastUpdatedAt") in
      let createdAt =
        (Option.map ~f:Timestamp.of_xml) (Xml.child xml_arg0 "CreatedAt") in
      let pipelineConfigurationBody =
        (Option.map ~f:String_.of_xml)
          (Xml.child xml_arg0 "PipelineConfigurationBody") in
      let statusReason =
        (Option.map ~f:PipelineStatusReason.of_xml)
          (Xml.child xml_arg0 "StatusReason") in
      let status =
        (Option.map ~f:PipelineStatus.of_xml) (Xml.child xml_arg0 "Status") in
      let maxUnits =
        (Option.map ~f:Integer.of_xml) (Xml.child xml_arg0 "MaxUnits") in
      let minUnits =
        (Option.map ~f:Integer.of_xml) (Xml.child xml_arg0 "MinUnits") in
      let pipelineArn =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "PipelineArn") in
      let pipelineName =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "PipelineName") in
      make ?pipelineRoleArn ?tags ?destinations ?serviceVpcEndpoints
        ?vpcEndpointService ?encryptionAtRestOptions ?bufferOptions
        ?vpcEndpoints ?logPublishingOptions ?ingestEndpointUrls
        ?lastUpdatedAt ?createdAt ?pipelineConfigurationBody ?statusReason
        ?status ?maxUnits ?minUnits ?pipelineArn ?pipelineName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipelineRoleArn =
        field_map json__ "PipelineRoleArn" PipelineRoleArn.of_json in
      let tags = field_map json__ "Tags" TagList.of_json in
      let destinations =
        field_map json__ "Destinations" PipelineDestinationList.of_json in
      let serviceVpcEndpoints =
        field_map json__ "ServiceVpcEndpoints"
          ServiceVpcEndpointsList.of_json in
      let vpcEndpointService =
        field_map json__ "VpcEndpointService" String_.of_json in
      let encryptionAtRestOptions =
        field_map json__ "EncryptionAtRestOptions"
          EncryptionAtRestOptions.of_json in
      let bufferOptions =
        field_map json__ "BufferOptions" BufferOptions.of_json in
      let vpcEndpoints =
        field_map json__ "VpcEndpoints" VpcEndpointsList.of_json in
      let logPublishingOptions =
        field_map json__ "LogPublishingOptions" LogPublishingOptions.of_json in
      let ingestEndpointUrls =
        field_map json__ "IngestEndpointUrls" IngestEndpointUrlsList.of_json in
      let lastUpdatedAt = field_map json__ "LastUpdatedAt" Timestamp.of_json in
      let createdAt = field_map json__ "CreatedAt" Timestamp.of_json in
      let pipelineConfigurationBody =
        field_map json__ "PipelineConfigurationBody" String_.of_json in
      let statusReason =
        field_map json__ "StatusReason" PipelineStatusReason.of_json in
      let status = field_map json__ "Status" PipelineStatus.of_json in
      let maxUnits = field_map json__ "MaxUnits" Integer.of_json in
      let minUnits = field_map json__ "MinUnits" Integer.of_json in
      let pipelineArn = field_map json__ "PipelineArn" String_.of_json in
      let pipelineName = field_map json__ "PipelineName" String_.of_json in
      make ?pipelineRoleArn ?tags ?destinations ?serviceVpcEndpoints
        ?vpcEndpointService ?encryptionAtRestOptions ?bufferOptions
        ?vpcEndpoints ?logPublishingOptions ?ingestEndpointUrls
        ?lastUpdatedAt ?createdAt ?pipelineConfigurationBody ?statusReason
        ?status ?maxUnits ?minUnits ?pipelineArn ?pipelineName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Information about an existing OpenSearch Ingestion pipeline."]
module ResourceNotFoundException =
  struct
    type nonrec t = unit
    let make () = ()
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "You attempted to access or delete a resource that does not exist."]
module StringList =
  struct
    type nonrec t = 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: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:String_.of_xml)
    let of_json j =
      list_of_json ~kind:"StringList" ~of_json:String_.of_json j
    let to_json v = composed_to_json to_value v
  end
module LimitExceededException =
  struct
    type nonrec t = unit
    let make () = ()
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "You attempted to create more than the allowed number of tags."]
module PipelineEndpointIdsList =
  struct
    type nonrec t = PipelineEndpointId.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:PipelineEndpointId.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:PipelineEndpointId.of_xml)
    let of_json j =
      list_of_json ~kind:"PipelineEndpointIdsList"
        ~of_json:PipelineEndpointId.of_json j
    let to_json v = composed_to_json to_value v
  end
module ResourcePolicy =
  struct
    type nonrec t = string
    let context_ = "ResourcePolicy"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_max i ~max:204800) >>=
             (fun () -> check_string_min i ~min:2));
        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:"ResourcePolicy" j
    let to_json = simple_to_json to_value
  end
module InvalidPaginationTokenException =
  struct
    type nonrec t = unit
    let make () = ()
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "An invalid pagination token provided in the request."]
module NextToken =
  struct
    type nonrec t = string
    let context_ = "NextToken"
    let make i =
      let open Result in
        ok_or_failwith
          ((check_string_min i ~min:0) >>=
             (fun () ->
                (check_string_max i ~max:3000) >>=
                  (fun () -> check_pattern i ~pattern:"^([\\s\\S]*)$")));
        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:"NextToken" j
    let to_json = simple_to_json to_value
  end
module PipelineSummaryList =
  struct
    type nonrec t = PipelineSummary.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:PipelineSummary.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:PipelineSummary.of_xml)
    let of_json j =
      list_of_json ~kind:"PipelineSummaryList"
        ~of_json:PipelineSummary.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 PipelineEndpointsSummaryList =
  struct
    type nonrec t = PipelineEndpoint.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:PipelineEndpoint.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:PipelineEndpoint.of_xml)
    let of_json j =
      list_of_json ~kind:"PipelineEndpointsSummaryList"
        ~of_json:PipelineEndpoint.of_json j
    let to_json v = composed_to_json to_value v
  end
module PipelineEndpointConnectionsSummaryList =
  struct
    type nonrec t = PipelineEndpointConnection.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:PipelineEndpointConnection.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:PipelineEndpointConnection.of_xml)
    let of_json j =
      list_of_json ~kind:"PipelineEndpointConnectionsSummaryList"
        ~of_json:PipelineEndpointConnection.of_json j
    let to_json v = composed_to_json to_value v
  end
module PipelineBlueprintsSummaryList =
  struct
    type nonrec t = PipelineBlueprintSummary.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:PipelineBlueprintSummary.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:PipelineBlueprintSummary.of_xml)
    let of_json j =
      list_of_json ~kind:"PipelineBlueprintsSummaryList"
        ~of_json:PipelineBlueprintSummary.of_json j
    let to_json v = composed_to_json to_value v
  end
module ChangeProgressStatusList =
  struct
    type nonrec t = ChangeProgressStatus.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:ChangeProgressStatus.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:ChangeProgressStatus.of_xml)
    let of_json j =
      list_of_json ~kind:"ChangeProgressStatusList"
        ~of_json:ChangeProgressStatus.of_json j
    let to_json v = composed_to_json to_value v
  end
module PipelineBlueprint =
  struct
    type nonrec t =
      {
      blueprintName: String_.t option
        [@ocaml.doc "The name of the blueprint."];
      pipelineConfigurationBody: String_.t option
        [@ocaml.doc "The YAML configuration of the blueprint."];
      displayName: String_.t option
        [@ocaml.doc "The display name of the blueprint."];
      displayDescription: String_.t option
        [@ocaml.doc "A description of the blueprint."];
      service: String_.t option
        [@ocaml.doc
          "The name of the service that the blueprint is associated with."];
      useCase: String_.t option
        [@ocaml.doc "The use case that the blueprint relates to."]}
    let make ?blueprintName =
      fun ?pipelineConfigurationBody ->
        fun ?displayName ->
          fun ?displayDescription ->
            fun ?service ->
              fun ?useCase ->
                fun () ->
                  {
                    blueprintName;
                    pipelineConfigurationBody;
                    displayName;
                    displayDescription;
                    service;
                    useCase
                  }
    let to_value x =
      structure_to_value
        [("BlueprintName", (Option.map x.blueprintName ~f:String_.to_value));
        ("PipelineConfigurationBody",
          (Option.map x.pipelineConfigurationBody ~f:String_.to_value));
        ("DisplayName", (Option.map x.displayName ~f:String_.to_value));
        ("DisplayDescription",
          (Option.map x.displayDescription ~f:String_.to_value));
        ("Service", (Option.map x.service ~f:String_.to_value));
        ("UseCase", (Option.map x.useCase ~f:String_.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let useCase =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "UseCase") in
      let service =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "Service") in
      let displayDescription =
        (Option.map ~f:String_.of_xml)
          (Xml.child xml_arg0 "DisplayDescription") in
      let displayName =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "DisplayName") in
      let pipelineConfigurationBody =
        (Option.map ~f:String_.of_xml)
          (Xml.child xml_arg0 "PipelineConfigurationBody") in
      let blueprintName =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "BlueprintName") in
      make ?useCase ?service ?displayDescription ?displayName
        ?pipelineConfigurationBody ?blueprintName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let useCase = field_map json__ "UseCase" String_.of_json in
      let service = field_map json__ "Service" String_.of_json in
      let displayDescription =
        field_map json__ "DisplayDescription" String_.of_json in
      let displayName = field_map json__ "DisplayName" String_.of_json in
      let pipelineConfigurationBody =
        field_map json__ "PipelineConfigurationBody" String_.of_json in
      let blueprintName = field_map json__ "BlueprintName" String_.of_json in
      make ?useCase ?service ?displayDescription ?displayName
        ?pipelineConfigurationBody ?blueprintName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Container for information about an OpenSearch Ingestion blueprint."]
module BlueprintFormat =
  struct
    type nonrec t = string
    let context_ = "BlueprintFormat"
    let make i =
      let open Result in
        ok_or_failwith (check_pattern i ~pattern:"(YAML|JSON)"); 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:"BlueprintFormat" j
    let to_json = simple_to_json to_value
  end
module ResourceAlreadyExistsException =
  struct
    type nonrec t = unit
    let make () = ()
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "You attempted to create a resource that already exists."]
module ValidatePipelineResponse =
  struct
    type nonrec t =
      {
      isValid: Boolean.t option
        [@ocaml.doc
          "A boolean indicating whether or not the pipeline configuration is valid."];
      errors: ValidationMessageList.t option
        [@ocaml.doc "A list of errors if the configuration is invalid."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?isValid = fun ?errors -> fun () -> { isValid; errors }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("isValid", (Option.map x.isValid ~f:Boolean.to_value));
        ("Errors", (Option.map x.errors ~f:ValidationMessageList.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let errors =
        (Option.map ~f:ValidationMessageList.of_xml)
          (Xml.child xml_arg0 "Errors") in
      let isValid =
        (Option.map ~f:Boolean.of_xml) (Xml.child xml_arg0 "isValid") in
      make ?errors ?isValid ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let errors = field_map json__ "Errors" ValidationMessageList.of_json in
      let isValid = field_map json__ "isValid" Boolean.of_json in
      make ?errors ?isValid ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Checks whether an OpenSearch Ingestion pipeline configuration is valid prior to creation. For more information, see Creating Amazon OpenSearch Ingestion pipelines."]
module ValidatePipelineRequest =
  struct
    type nonrec t =
      {
      pipelineConfigurationBody: PipelineConfigurationBody.t
        [@ocaml.doc
          "The pipeline configuration in YAML format. The command accepts the pipeline configuration as a string or within a .yaml file. If you provide the configuration as a string, each new line must be escaped with \\n."]}
    let context_ = "ValidatePipelineRequest"
    let make ~pipelineConfigurationBody =
      fun () -> { pipelineConfigurationBody }
    let to_value x =
      structure_to_value
        [("PipelineConfigurationBody",
           (Some
              (PipelineConfigurationBody.to_value x.pipelineConfigurationBody)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipelineConfigurationBody =
        PipelineConfigurationBody.of_xml
          (Xml.child_exn ~context:context_ xml_arg0
             "PipelineConfigurationBody") in
      make ~pipelineConfigurationBody ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipelineConfigurationBody =
        field_map_exn json__ "PipelineConfigurationBody"
          PipelineConfigurationBody.of_json in
      make ~pipelineConfigurationBody ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Checks whether an OpenSearch Ingestion pipeline configuration is valid prior to creation. For more information, see Creating Amazon OpenSearch Ingestion pipelines."]
module UpdatePipelineResponse =
  struct
    type nonrec t =
      {
      pipeline: Pipeline.t option
        [@ocaml.doc "Container for information about the updated pipeline."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `ConflictException of ConflictException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?pipeline = fun () -> { pipeline }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `ConflictException e ->
          `Assoc
            [("error", (`String "ConflictException"));
            ("details", (ConflictException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("Pipeline", (Option.map x.pipeline ~f:Pipeline.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipeline =
        (Option.map ~f:Pipeline.of_xml) (Xml.child xml_arg0 "Pipeline") in
      make ?pipeline ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipeline = field_map json__ "Pipeline" Pipeline.of_json in
      make ?pipeline ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Updates an OpenSearch Ingestion pipeline. For more information, see Updating Amazon OpenSearch Ingestion pipelines."]
module UpdatePipelineRequest =
  struct
    type nonrec t =
      {
      pipelineName: PipelineName.t
        [@ocaml.doc "The name of the pipeline to update."];
      minUnits: PipelineUnits.t option
        [@ocaml.doc
          "The minimum pipeline capacity, in Ingestion Compute Units (ICUs)."];
      maxUnits: PipelineUnits.t option
        [@ocaml.doc
          "The maximum pipeline capacity, in Ingestion Compute Units (ICUs)"];
      pipelineConfigurationBody: PipelineConfigurationBody.t option
        [@ocaml.doc
          "The pipeline configuration in YAML format. The command accepts the pipeline configuration as a string or within a .yaml file. If you provide the configuration as a string, each new line must be escaped with \\n."];
      logPublishingOptions: LogPublishingOptions.t option
        [@ocaml.doc "Key-value pairs to configure log publishing."];
      bufferOptions: BufferOptions.t option
        [@ocaml.doc
          "Key-value pairs to configure persistent buffering for the pipeline."];
      encryptionAtRestOptions: EncryptionAtRestOptions.t option
        [@ocaml.doc
          "Key-value pairs to configure encryption for data that is written to a persistent buffer."];
      pipelineRoleArn: PipelineRoleArn.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the IAM role that grants the pipeline permission to access Amazon Web Services resources."]}
    let context_ = "UpdatePipelineRequest"
    let make ?minUnits =
      fun ?maxUnits ->
        fun ?pipelineConfigurationBody ->
          fun ?logPublishingOptions ->
            fun ?bufferOptions ->
              fun ?encryptionAtRestOptions ->
                fun ?pipelineRoleArn ->
                  fun ~pipelineName ->
                    fun () ->
                      {
                        minUnits;
                        maxUnits;
                        pipelineConfigurationBody;
                        logPublishingOptions;
                        bufferOptions;
                        encryptionAtRestOptions;
                        pipelineRoleArn;
                        pipelineName
                      }
    let to_value x =
      structure_to_value
        [("PipelineName", (Some (PipelineName.to_value x.pipelineName)));
        ("MinUnits", (Option.map x.minUnits ~f:PipelineUnits.to_value));
        ("MaxUnits", (Option.map x.maxUnits ~f:PipelineUnits.to_value));
        ("PipelineConfigurationBody",
          (Option.map x.pipelineConfigurationBody
             ~f:PipelineConfigurationBody.to_value));
        ("LogPublishingOptions",
          (Option.map x.logPublishingOptions ~f:LogPublishingOptions.to_value));
        ("BufferOptions",
          (Option.map x.bufferOptions ~f:BufferOptions.to_value));
        ("EncryptionAtRestOptions",
          (Option.map x.encryptionAtRestOptions
             ~f:EncryptionAtRestOptions.to_value));
        ("PipelineRoleArn",
          (Option.map x.pipelineRoleArn ~f:PipelineRoleArn.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipelineRoleArn =
        (Option.map ~f:PipelineRoleArn.of_xml)
          (Xml.child xml_arg0 "PipelineRoleArn") in
      let encryptionAtRestOptions =
        (Option.map ~f:EncryptionAtRestOptions.of_xml)
          (Xml.child xml_arg0 "EncryptionAtRestOptions") in
      let bufferOptions =
        (Option.map ~f:BufferOptions.of_xml)
          (Xml.child xml_arg0 "BufferOptions") in
      let logPublishingOptions =
        (Option.map ~f:LogPublishingOptions.of_xml)
          (Xml.child xml_arg0 "LogPublishingOptions") in
      let pipelineConfigurationBody =
        (Option.map ~f:PipelineConfigurationBody.of_xml)
          (Xml.child xml_arg0 "PipelineConfigurationBody") in
      let maxUnits =
        (Option.map ~f:PipelineUnits.of_xml) (Xml.child xml_arg0 "MaxUnits") in
      let minUnits =
        (Option.map ~f:PipelineUnits.of_xml) (Xml.child xml_arg0 "MinUnits") in
      let pipelineName =
        PipelineName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "PipelineName") in
      make ?pipelineRoleArn ?encryptionAtRestOptions ?bufferOptions
        ?logPublishingOptions ?pipelineConfigurationBody ?maxUnits ?minUnits
        ~pipelineName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipelineRoleArn =
        field_map json__ "PipelineRoleArn" PipelineRoleArn.of_json in
      let encryptionAtRestOptions =
        field_map json__ "EncryptionAtRestOptions"
          EncryptionAtRestOptions.of_json in
      let bufferOptions =
        field_map json__ "BufferOptions" BufferOptions.of_json in
      let logPublishingOptions =
        field_map json__ "LogPublishingOptions" LogPublishingOptions.of_json in
      let pipelineConfigurationBody =
        field_map json__ "PipelineConfigurationBody"
          PipelineConfigurationBody.of_json in
      let maxUnits = field_map json__ "MaxUnits" PipelineUnits.of_json in
      let minUnits = field_map json__ "MinUnits" PipelineUnits.of_json in
      let pipelineName =
        field_map_exn json__ "PipelineName" PipelineName.of_json in
      make ?pipelineRoleArn ?encryptionAtRestOptions ?bufferOptions
        ?logPublishingOptions ?pipelineConfigurationBody ?maxUnits ?minUnits
        ~pipelineName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Updates an OpenSearch Ingestion pipeline. For more information, see Updating Amazon OpenSearch Ingestion pipelines."]
module UntagResourceResponse =
  struct
    type nonrec t = unit
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make () = ()
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Removes one or more tags from an OpenSearch Ingestion pipeline. For more information, see Tagging Amazon OpenSearch Ingestion pipelines."]
module UntagResourceRequest =
  struct
    type nonrec t =
      {
      arn: PipelineArn.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the pipeline to remove tags from."];
      tagKeys: StringList.t [@ocaml.doc "The tag keys to remove."]}
    let context_ = "UntagResourceRequest"
    let make ~arn = fun ~tagKeys -> fun () -> { arn; tagKeys }
    let to_value x =
      structure_to_value
        [("arn", (Some (PipelineArn.to_value x.arn)));
        ("TagKeys", (Some (StringList.to_value x.tagKeys)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let tagKeys =
        StringList.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "TagKeys") in
      let arn =
        PipelineArn.of_xml (Xml.child_exn ~context:context_ xml_arg0 "arn") in
      make ~tagKeys ~arn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let tagKeys = field_map_exn json__ "TagKeys" StringList.of_json in
      let arn = field_map_exn json__ "Arn" PipelineArn.of_json in
      make ~tagKeys ~arn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Removes one or more tags from an OpenSearch Ingestion pipeline. For more information, see Tagging Amazon OpenSearch Ingestion pipelines."]
module TagResourceResponse =
  struct
    type nonrec t = unit
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `LimitExceededException of LimitExceededException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make () = ()
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `LimitExceededException e ->
          `Assoc
            [("error", (`String "LimitExceededException"));
            ("details", (LimitExceededException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Tags an OpenSearch Ingestion pipeline. For more information, see Tagging Amazon OpenSearch Ingestion pipelines."]
module TagResourceRequest =
  struct
    type nonrec t =
      {
      arn: PipelineArn.t
        [@ocaml.doc "The Amazon Resource Name (ARN) of the pipeline to tag."];
      tags: TagList.t
        [@ocaml.doc "The list of key-value tags to add to the pipeline."]}
    let context_ = "TagResourceRequest"
    let make ~arn = fun ~tags -> fun () -> { arn; tags }
    let to_value x =
      structure_to_value
        [("arn", (Some (PipelineArn.to_value x.arn)));
        ("Tags", (Some (TagList.to_value x.tags)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let tags =
        TagList.of_xml (Xml.child_exn ~context:context_ xml_arg0 "Tags") in
      let arn =
        PipelineArn.of_xml (Xml.child_exn ~context:context_ xml_arg0 "arn") in
      make ~tags ~arn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let tags = field_map_exn json__ "Tags" TagList.of_json in
      let arn = field_map_exn json__ "Arn" PipelineArn.of_json in
      make ~tags ~arn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Tags an OpenSearch Ingestion pipeline. For more information, see Tagging Amazon OpenSearch Ingestion pipelines."]
module StopPipelineResponse =
  struct
    type nonrec t = {
      pipeline: Pipeline.t option }
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `ConflictException of ConflictException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?pipeline = fun () -> { pipeline }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `ConflictException e ->
          `Assoc
            [("error", (`String "ConflictException"));
            ("details", (ConflictException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("Pipeline", (Option.map x.pipeline ~f:Pipeline.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipeline =
        (Option.map ~f:Pipeline.of_xml) (Xml.child xml_arg0 "Pipeline") in
      make ?pipeline ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipeline = field_map json__ "Pipeline" Pipeline.of_json in
      make ?pipeline ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Stops an OpenSearch Ingestion pipeline. For more information, see Stopping an OpenSearch Ingestion pipeline."]
module StopPipelineRequest =
  struct
    type nonrec t =
      {
      pipelineName: PipelineName.t
        [@ocaml.doc "The name of the pipeline to stop."]}
    let context_ = "StopPipelineRequest"
    let make ~pipelineName = fun () -> { pipelineName }
    let to_value x =
      structure_to_value
        [("PipelineName", (Some (PipelineName.to_value x.pipelineName)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipelineName =
        PipelineName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "PipelineName") in
      make ~pipelineName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipelineName =
        field_map_exn json__ "PipelineName" PipelineName.of_json in
      make ~pipelineName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Stops an OpenSearch Ingestion pipeline. For more information, see Stopping an OpenSearch Ingestion pipeline."]
module StartPipelineResponse =
  struct
    type nonrec t = {
      pipeline: Pipeline.t option }
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `ConflictException of ConflictException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?pipeline = fun () -> { pipeline }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `ConflictException e ->
          `Assoc
            [("error", (`String "ConflictException"));
            ("details", (ConflictException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("Pipeline", (Option.map x.pipeline ~f:Pipeline.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipeline =
        (Option.map ~f:Pipeline.of_xml) (Xml.child xml_arg0 "Pipeline") in
      make ?pipeline ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipeline = field_map json__ "Pipeline" Pipeline.of_json in
      make ?pipeline ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Starts an OpenSearch Ingestion pipeline. For more information, see Starting an OpenSearch Ingestion pipeline."]
module StartPipelineRequest =
  struct
    type nonrec t =
      {
      pipelineName: PipelineName.t
        [@ocaml.doc "The name of the pipeline to start."]}
    let context_ = "StartPipelineRequest"
    let make ~pipelineName = fun () -> { pipelineName }
    let to_value x =
      structure_to_value
        [("PipelineName", (Some (PipelineName.to_value x.pipelineName)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipelineName =
        PipelineName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "PipelineName") in
      make ~pipelineName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipelineName =
        field_map_exn json__ "PipelineName" PipelineName.of_json in
      make ~pipelineName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Starts an OpenSearch Ingestion pipeline. For more information, see Starting an OpenSearch Ingestion pipeline."]
module RevokePipelineEndpointConnectionsResponse =
  struct
    type nonrec t =
      {
      pipelineArn: PipelineArn.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the pipeline from which endpoint connections were revoked."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `LimitExceededException of LimitExceededException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?pipelineArn = fun () -> { pipelineArn }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `LimitExceededException e ->
          `Assoc
            [("error", (`String "LimitExceededException"));
            ("details", (LimitExceededException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("PipelineArn", (Option.map x.pipelineArn ~f:PipelineArn.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipelineArn =
        (Option.map ~f:PipelineArn.of_xml) (Xml.child xml_arg0 "PipelineArn") in
      make ?pipelineArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipelineArn = field_map json__ "PipelineArn" PipelineArn.of_json in
      make ?pipelineArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Revokes pipeline endpoints from specified endpoint IDs."]
module RevokePipelineEndpointConnectionsRequest =
  struct
    type nonrec t =
      {
      pipelineArn: PipelineArn.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the pipeline from which to revoke endpoint connections."];
      endpointIds: PipelineEndpointIdsList.t
        [@ocaml.doc
          "A list of endpoint IDs for which to revoke access to the pipeline."]}
    let context_ = "RevokePipelineEndpointConnectionsRequest"
    let make ~pipelineArn =
      fun ~endpointIds -> fun () -> { pipelineArn; endpointIds }
    let to_value x =
      structure_to_value
        [("PipelineArn", (Some (PipelineArn.to_value x.pipelineArn)));
        ("EndpointIds",
          (Some (PipelineEndpointIdsList.to_value x.endpointIds)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let endpointIds =
        PipelineEndpointIdsList.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "EndpointIds") in
      let pipelineArn =
        PipelineArn.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "PipelineArn") in
      make ~endpointIds ~pipelineArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let endpointIds =
        field_map_exn json__ "EndpointIds" PipelineEndpointIdsList.of_json in
      let pipelineArn =
        field_map_exn json__ "PipelineArn" PipelineArn.of_json in
      make ~endpointIds ~pipelineArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Revokes pipeline endpoints from specified endpoint IDs."]
module PutResourcePolicyResponse =
  struct
    type nonrec t =
      {
      resourceArn: PipelineArn.t option
        [@ocaml.doc "The Amazon Resource Name (ARN) of the resource."];
      policy: ResourcePolicy.t option
        [@ocaml.doc
          "The resource-based policy document that was attached to the resource."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `LimitExceededException of LimitExceededException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?resourceArn = fun ?policy -> fun () -> { resourceArn; policy }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `LimitExceededException e ->
          `Assoc
            [("error", (`String "LimitExceededException"));
            ("details", (LimitExceededException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("ResourceArn", (Option.map x.resourceArn ~f:PipelineArn.to_value));
        ("Policy", (Option.map x.policy ~f:ResourcePolicy.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let policy =
        (Option.map ~f:ResourcePolicy.of_xml) (Xml.child xml_arg0 "Policy") in
      let resourceArn =
        (Option.map ~f:PipelineArn.of_xml) (Xml.child xml_arg0 "ResourceArn") in
      make ?policy ?resourceArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let policy = field_map json__ "Policy" ResourcePolicy.of_json in
      let resourceArn = field_map json__ "ResourceArn" PipelineArn.of_json in
      make ?policy ?resourceArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Attaches a resource-based policy to an OpenSearch Ingestion resource. Resource-based policies grant permissions to principals to perform actions on the resource."]
module PutResourcePolicyRequest =
  struct
    type nonrec t =
      {
      resourceArn: PipelineArn.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the resource to attach the policy to."];
      policy: ResourcePolicy.t
        [@ocaml.doc "The resource-based policy document in JSON format."]}
    let context_ = "PutResourcePolicyRequest"
    let make ~resourceArn = fun ~policy -> fun () -> { resourceArn; policy }
    let to_value x =
      structure_to_value
        [("ResourceArn", (Some (PipelineArn.to_value x.resourceArn)));
        ("Policy", (Some (ResourcePolicy.to_value x.policy)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let policy =
        ResourcePolicy.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "Policy") in
      let resourceArn =
        PipelineArn.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "ResourceArn") in
      make ~policy ~resourceArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let policy = field_map_exn json__ "Policy" ResourcePolicy.of_json in
      let resourceArn =
        field_map_exn json__ "ResourceArn" PipelineArn.of_json in
      make ~policy ~resourceArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Attaches a resource-based policy to an OpenSearch Ingestion resource. Resource-based policies grant permissions to principals to perform actions on the resource."]
module ListTagsForResourceResponse =
  struct
    type nonrec t =
      {
      tags: TagList.t option
        [@ocaml.doc "A list of tags associated with the given pipeline."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?tags = fun () -> { tags }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value [("Tags", (Option.map x.tags ~f:TagList.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let tags = (Option.map ~f:TagList.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" TagList.of_json in make ?tags ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Lists all resource tags associated with an OpenSearch Ingestion pipeline. For more information, see Tagging Amazon OpenSearch Ingestion pipelines."]
module ListTagsForResourceRequest =
  struct
    type nonrec t =
      {
      arn: PipelineArn.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the pipeline to retrieve tags for."]}
    let context_ = "ListTagsForResourceRequest"
    let make ~arn = fun () -> { arn }
    let to_value x =
      structure_to_value [("arn", (Some (PipelineArn.to_value x.arn)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let arn =
        PipelineArn.of_xml (Xml.child_exn ~context:context_ xml_arg0 "arn") in
      make ~arn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let arn = field_map_exn json__ "Arn" PipelineArn.of_json in
      make ~arn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Lists all resource tags associated with an OpenSearch Ingestion pipeline. For more information, see Tagging Amazon OpenSearch Ingestion pipelines."]
module ListPipelinesResponse =
  struct
    type nonrec t =
      {
      nextToken: NextToken.t option
        [@ocaml.doc
          "When nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page."];
      pipelines: PipelineSummaryList.t option
        [@ocaml.doc "A list of all existing Data Prepper pipelines."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `InvalidPaginationTokenException of InvalidPaginationTokenException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?nextToken =
      fun ?pipelines -> fun () -> { nextToken; pipelines }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "InvalidPaginationTokenException" ->
          `InvalidPaginationTokenException
            (InvalidPaginationTokenException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "InvalidPaginationTokenException" ->
          `InvalidPaginationTokenException
            (InvalidPaginationTokenException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `InvalidPaginationTokenException e ->
          `Assoc
            [("error", (`String "InvalidPaginationTokenException"));
            ("details", (InvalidPaginationTokenException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("NextToken", (Option.map x.nextToken ~f:NextToken.to_value));
        ("Pipelines",
          (Option.map x.pipelines ~f:PipelineSummaryList.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipelines =
        (Option.map ~f:PipelineSummaryList.of_xml)
          (Xml.child xml_arg0 "Pipelines") in
      let nextToken =
        (Option.map ~f:NextToken.of_xml) (Xml.child xml_arg0 "NextToken") in
      make ?pipelines ?nextToken ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipelines =
        field_map json__ "Pipelines" PipelineSummaryList.of_json in
      let nextToken = field_map json__ "NextToken" NextToken.of_json in
      make ?pipelines ?nextToken ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Lists all OpenSearch Ingestion pipelines in the current Amazon Web Services account and Region. For more information, see Viewing Amazon OpenSearch Ingestion pipelines."]
module ListPipelinesRequest =
  struct
    type nonrec t =
      {
      maxResults: MaxResults.t option
        [@ocaml.doc
          "An optional parameter that specifies the maximum number of results to return. You can use nextToken to get the next page of results."];
      nextToken: NextToken.t option
        [@ocaml.doc
          "If your initial ListPipelines operation returns a nextToken, you can include the returned nextToken in subsequent ListPipelines operations, which returns results in the next page."]}
    let make ?maxResults =
      fun ?nextToken -> fun () -> { maxResults; nextToken }
    let to_value x =
      structure_to_value
        [("maxResults", (Option.map x.maxResults ~f:MaxResults.to_value));
        ("nextToken", (Option.map x.nextToken ~f:NextToken.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let nextToken =
        (Option.map ~f:NextToken.of_xml) (Xml.child xml_arg0 "nextToken") in
      let maxResults =
        (Option.map ~f:MaxResults.of_xml) (Xml.child xml_arg0 "maxResults") in
      make ?nextToken ?maxResults ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let nextToken = field_map json__ "NextToken" NextToken.of_json in
      let maxResults = field_map json__ "MaxResults" MaxResults.of_json in
      make ?nextToken ?maxResults ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Lists all OpenSearch Ingestion pipelines in the current Amazon Web Services account and Region. For more information, see Viewing Amazon OpenSearch Ingestion pipelines."]
module ListPipelineEndpointsResponse =
  struct
    type nonrec t =
      {
      nextToken: NextToken.t option
        [@ocaml.doc
          "When NextToken is returned, there are more results available. The value of NextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page."];
      pipelineEndpoints: PipelineEndpointsSummaryList.t option
        [@ocaml.doc "A list of pipeline endpoints."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `LimitExceededException of LimitExceededException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?nextToken =
      fun ?pipelineEndpoints -> fun () -> { nextToken; pipelineEndpoints }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `LimitExceededException e ->
          `Assoc
            [("error", (`String "LimitExceededException"));
            ("details", (LimitExceededException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("NextToken", (Option.map x.nextToken ~f:NextToken.to_value));
        ("PipelineEndpoints",
          (Option.map x.pipelineEndpoints
             ~f:PipelineEndpointsSummaryList.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipelineEndpoints =
        (Option.map ~f:PipelineEndpointsSummaryList.of_xml)
          (Xml.child xml_arg0 "PipelineEndpoints") in
      let nextToken =
        (Option.map ~f:NextToken.of_xml) (Xml.child xml_arg0 "NextToken") in
      make ?pipelineEndpoints ?nextToken ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipelineEndpoints =
        field_map json__ "PipelineEndpoints"
          PipelineEndpointsSummaryList.of_json in
      let nextToken = field_map json__ "NextToken" NextToken.of_json in
      make ?pipelineEndpoints ?nextToken ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Lists all pipeline endpoints in your account."]
module ListPipelineEndpointsRequest =
  struct
    type nonrec t =
      {
      maxResults: MaxResults.t option
        [@ocaml.doc
          "The maximum number of pipeline endpoints to return in the response."];
      nextToken: NextToken.t option
        [@ocaml.doc
          "If your initial ListPipelineEndpoints operation returns a NextToken, you can include the returned NextToken in subsequent ListPipelineEndpoints operations, which returns results in the next page."]}
    let make ?maxResults =
      fun ?nextToken -> fun () -> { maxResults; nextToken }
    let to_value x =
      structure_to_value
        [("maxResults", (Option.map x.maxResults ~f:MaxResults.to_value));
        ("nextToken", (Option.map x.nextToken ~f:NextToken.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let nextToken =
        (Option.map ~f:NextToken.of_xml) (Xml.child xml_arg0 "nextToken") in
      let maxResults =
        (Option.map ~f:MaxResults.of_xml) (Xml.child xml_arg0 "maxResults") in
      make ?nextToken ?maxResults ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let nextToken = field_map json__ "NextToken" NextToken.of_json in
      let maxResults = field_map json__ "MaxResults" MaxResults.of_json in
      make ?nextToken ?maxResults ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc "Lists all pipeline endpoints in your account."]
module ListPipelineEndpointConnectionsResponse =
  struct
    type nonrec t =
      {
      nextToken: NextToken.t option
        [@ocaml.doc
          "When nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page."];
      pipelineEndpointConnections:
        PipelineEndpointConnectionsSummaryList.t option
        [@ocaml.doc "A list of pipeline endpoint connections."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `LimitExceededException of LimitExceededException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?nextToken =
      fun ?pipelineEndpointConnections ->
        fun () -> { nextToken; pipelineEndpointConnections }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `LimitExceededException e ->
          `Assoc
            [("error", (`String "LimitExceededException"));
            ("details", (LimitExceededException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("NextToken", (Option.map x.nextToken ~f:NextToken.to_value));
        ("PipelineEndpointConnections",
          (Option.map x.pipelineEndpointConnections
             ~f:PipelineEndpointConnectionsSummaryList.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipelineEndpointConnections =
        (Option.map ~f:PipelineEndpointConnectionsSummaryList.of_xml)
          (Xml.child xml_arg0 "PipelineEndpointConnections") in
      let nextToken =
        (Option.map ~f:NextToken.of_xml) (Xml.child xml_arg0 "NextToken") in
      make ?pipelineEndpointConnections ?nextToken ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipelineEndpointConnections =
        field_map json__ "PipelineEndpointConnections"
          PipelineEndpointConnectionsSummaryList.of_json in
      let nextToken = field_map json__ "NextToken" NextToken.of_json in
      make ?pipelineEndpointConnections ?nextToken ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Lists the pipeline endpoints connected to pipelines in your account."]
module ListPipelineEndpointConnectionsRequest =
  struct
    type nonrec t =
      {
      maxResults: MaxResults.t option
        [@ocaml.doc
          "The maximum number of pipeline endpoint connections to return in the response."];
      nextToken: NextToken.t option
        [@ocaml.doc
          "If your initial ListPipelineEndpointConnections operation returns a nextToken, you can include the returned nextToken in subsequent ListPipelineEndpointConnections operations, which returns results in the next page."]}
    let make ?maxResults =
      fun ?nextToken -> fun () -> { maxResults; nextToken }
    let to_value x =
      structure_to_value
        [("maxResults", (Option.map x.maxResults ~f:MaxResults.to_value));
        ("nextToken", (Option.map x.nextToken ~f:NextToken.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let nextToken =
        (Option.map ~f:NextToken.of_xml) (Xml.child xml_arg0 "nextToken") in
      let maxResults =
        (Option.map ~f:MaxResults.of_xml) (Xml.child xml_arg0 "maxResults") in
      make ?nextToken ?maxResults ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let nextToken = field_map json__ "NextToken" NextToken.of_json in
      let maxResults = field_map json__ "MaxResults" MaxResults.of_json in
      make ?nextToken ?maxResults ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Lists the pipeline endpoints connected to pipelines in your account."]
module ListPipelineBlueprintsResponse =
  struct
    type nonrec t =
      {
      blueprints: PipelineBlueprintsSummaryList.t option
        [@ocaml.doc "A list of available blueprints for Data Prepper."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `InvalidPaginationTokenException of InvalidPaginationTokenException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?blueprints = fun () -> { blueprints }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "InvalidPaginationTokenException" ->
          `InvalidPaginationTokenException
            (InvalidPaginationTokenException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "InvalidPaginationTokenException" ->
          `InvalidPaginationTokenException
            (InvalidPaginationTokenException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `InvalidPaginationTokenException e ->
          `Assoc
            [("error", (`String "InvalidPaginationTokenException"));
            ("details", (InvalidPaginationTokenException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("Blueprints",
           (Option.map x.blueprints ~f:PipelineBlueprintsSummaryList.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let blueprints =
        (Option.map ~f:PipelineBlueprintsSummaryList.of_xml)
          (Xml.child xml_arg0 "Blueprints") in
      make ?blueprints ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let blueprints =
        field_map json__ "Blueprints" PipelineBlueprintsSummaryList.of_json in
      make ?blueprints ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Retrieves a list of all available blueprints for Data Prepper. For more information, see Using blueprints to create a pipeline."]
module ListPipelineBlueprintsRequest =
  struct
    type nonrec t = unit
    let make () = ()
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Retrieves a list of all available blueprints for Data Prepper. For more information, see Using blueprints to create a pipeline."]
module GetResourcePolicyResponse =
  struct
    type nonrec t =
      {
      resourceArn: PipelineArn.t option
        [@ocaml.doc "The Amazon Resource Name (ARN) of the resource."];
      policy: ResourcePolicy.t option
        [@ocaml.doc "The resource-based policy document in JSON format."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `LimitExceededException of LimitExceededException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?resourceArn = fun ?policy -> fun () -> { resourceArn; policy }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `LimitExceededException e ->
          `Assoc
            [("error", (`String "LimitExceededException"));
            ("details", (LimitExceededException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("ResourceArn", (Option.map x.resourceArn ~f:PipelineArn.to_value));
        ("Policy", (Option.map x.policy ~f:ResourcePolicy.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let policy =
        (Option.map ~f:ResourcePolicy.of_xml) (Xml.child xml_arg0 "Policy") in
      let resourceArn =
        (Option.map ~f:PipelineArn.of_xml) (Xml.child xml_arg0 "ResourceArn") in
      make ?policy ?resourceArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let policy = field_map json__ "Policy" ResourcePolicy.of_json in
      let resourceArn = field_map json__ "ResourceArn" PipelineArn.of_json in
      make ?policy ?resourceArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Retrieves the resource-based policy attached to an OpenSearch Ingestion resource."]
module GetResourcePolicyRequest =
  struct
    type nonrec t =
      {
      resourceArn: PipelineArn.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the resource for which to retrieve the policy."]}
    let context_ = "GetResourcePolicyRequest"
    let make ~resourceArn = fun () -> { resourceArn }
    let to_value x =
      structure_to_value
        [("ResourceArn", (Some (PipelineArn.to_value x.resourceArn)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let resourceArn =
        PipelineArn.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" PipelineArn.of_json in
      make ~resourceArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Retrieves the resource-based policy attached to an OpenSearch Ingestion resource."]
module GetPipelineResponse =
  struct
    type nonrec t =
      {
      pipeline: Pipeline.t option
        [@ocaml.doc "Detailed information about the requested pipeline."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?pipeline = fun () -> { pipeline }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("Pipeline", (Option.map x.pipeline ~f:Pipeline.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipeline =
        (Option.map ~f:Pipeline.of_xml) (Xml.child xml_arg0 "Pipeline") in
      make ?pipeline ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipeline = field_map json__ "Pipeline" Pipeline.of_json in
      make ?pipeline ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Retrieves information about an OpenSearch Ingestion pipeline."]
module GetPipelineRequest =
  struct
    type nonrec t =
      {
      pipelineName: PipelineName.t [@ocaml.doc "The name of the pipeline."]}
    let context_ = "GetPipelineRequest"
    let make ~pipelineName = fun () -> { pipelineName }
    let to_value x =
      structure_to_value
        [("PipelineName", (Some (PipelineName.to_value x.pipelineName)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipelineName =
        PipelineName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "PipelineName") in
      make ~pipelineName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipelineName =
        field_map_exn json__ "PipelineName" PipelineName.of_json in
      make ~pipelineName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Retrieves information about an OpenSearch Ingestion pipeline."]
module GetPipelineChangeProgressResponse =
  struct
    type nonrec t =
      {
      changeProgressStatuses: ChangeProgressStatusList.t option
        [@ocaml.doc
          "The current status of the change happening on the pipeline."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?changeProgressStatuses = fun () -> { changeProgressStatuses }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("ChangeProgressStatuses",
           (Option.map x.changeProgressStatuses
              ~f:ChangeProgressStatusList.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let changeProgressStatuses =
        (Option.map ~f:ChangeProgressStatusList.of_xml)
          (Xml.child xml_arg0 "ChangeProgressStatuses") in
      make ?changeProgressStatuses ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let changeProgressStatuses =
        field_map json__ "ChangeProgressStatuses"
          ChangeProgressStatusList.of_json in
      make ?changeProgressStatuses ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Returns progress information for the current change happening on an OpenSearch Ingestion pipeline. Currently, this operation only returns information when a pipeline is being created. For more information, see Tracking the status of pipeline creation."]
module GetPipelineChangeProgressRequest =
  struct
    type nonrec t =
      {
      pipelineName: PipelineName.t [@ocaml.doc "The name of the pipeline."]}
    let context_ = "GetPipelineChangeProgressRequest"
    let make ~pipelineName = fun () -> { pipelineName }
    let to_value x =
      structure_to_value
        [("PipelineName", (Some (PipelineName.to_value x.pipelineName)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipelineName =
        PipelineName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "PipelineName") in
      make ~pipelineName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipelineName =
        field_map_exn json__ "PipelineName" PipelineName.of_json in
      make ~pipelineName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Returns progress information for the current change happening on an OpenSearch Ingestion pipeline. Currently, this operation only returns information when a pipeline is being created. For more information, see Tracking the status of pipeline creation."]
module GetPipelineBlueprintResponse =
  struct
    type nonrec t =
      {
      blueprint: PipelineBlueprint.t option
        [@ocaml.doc "The requested blueprint in YAML format."];
      format: String_.t option [@ocaml.doc "The format of the blueprint."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?blueprint = fun ?format -> fun () -> { blueprint; format }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("Blueprint",
           (Option.map x.blueprint ~f:PipelineBlueprint.to_value));
        ("Format", (Option.map x.format ~f:String_.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let format =
        (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "Format") in
      let blueprint =
        (Option.map ~f:PipelineBlueprint.of_xml)
          (Xml.child xml_arg0 "Blueprint") in
      make ?format ?blueprint ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let format = field_map json__ "Format" String_.of_json in
      let blueprint = field_map json__ "Blueprint" PipelineBlueprint.of_json in
      make ?format ?blueprint ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Retrieves information about a specific blueprint for OpenSearch Ingestion. Blueprints are templates for the configuration needed for a CreatePipeline request. For more information, see Using blueprints to create a pipeline."]
module GetPipelineBlueprintRequest =
  struct
    type nonrec t =
      {
      blueprintName: String_.t
        [@ocaml.doc "The name of the blueprint to retrieve."];
      format: BlueprintFormat.t option
        [@ocaml.doc "The format format of the blueprint to retrieve."]}
    let context_ = "GetPipelineBlueprintRequest"
    let make ?format =
      fun ~blueprintName -> fun () -> { format; blueprintName }
    let to_value x =
      structure_to_value
        [("BlueprintName", (Some (String_.to_value x.blueprintName)));
        ("format", (Option.map x.format ~f:BlueprintFormat.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let format =
        (Option.map ~f:BlueprintFormat.of_xml) (Xml.child xml_arg0 "format") in
      let blueprintName =
        String_.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "BlueprintName") in
      make ?format ~blueprintName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let format = field_map json__ "Format" BlueprintFormat.of_json in
      let blueprintName =
        field_map_exn json__ "BlueprintName" String_.of_json in
      make ?format ~blueprintName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Retrieves information about a specific blueprint for OpenSearch Ingestion. Blueprints are templates for the configuration needed for a CreatePipeline request. For more information, see Using blueprints to create a pipeline."]
module DeleteResourcePolicyResponse =
  struct
    type nonrec t = unit
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `LimitExceededException of LimitExceededException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make () = ()
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `LimitExceededException e ->
          `Assoc
            [("error", (`String "LimitExceededException"));
            ("details", (LimitExceededException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Deletes a resource-based policy from an OpenSearch Ingestion resource."]
module DeleteResourcePolicyRequest =
  struct
    type nonrec t =
      {
      resourceArn: PipelineArn.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the resource from which to delete the policy."]}
    let context_ = "DeleteResourcePolicyRequest"
    let make ~resourceArn = fun () -> { resourceArn }
    let to_value x =
      structure_to_value
        [("ResourceArn", (Some (PipelineArn.to_value x.resourceArn)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let resourceArn =
        PipelineArn.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" PipelineArn.of_json in
      make ~resourceArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Deletes a resource-based policy from an OpenSearch Ingestion resource."]
module DeletePipelineResponse =
  struct
    type nonrec t = unit
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `ConflictException of ConflictException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make () = ()
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "ConflictException" ->
          `ConflictException (ConflictException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `ConflictException e ->
          `Assoc
            [("error", (`String "ConflictException"));
            ("details", (ConflictException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Deletes an OpenSearch Ingestion pipeline. For more information, see Deleting Amazon OpenSearch Ingestion pipelines."]
module DeletePipelineRequest =
  struct
    type nonrec t =
      {
      pipelineName: PipelineName.t
        [@ocaml.doc "The name of the pipeline to delete."]}
    let context_ = "DeletePipelineRequest"
    let make ~pipelineName = fun () -> { pipelineName }
    let to_value x =
      structure_to_value
        [("PipelineName", (Some (PipelineName.to_value x.pipelineName)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipelineName =
        PipelineName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "PipelineName") in
      make ~pipelineName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipelineName =
        field_map_exn json__ "PipelineName" PipelineName.of_json in
      make ~pipelineName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Deletes an OpenSearch Ingestion pipeline. For more information, see Deleting Amazon OpenSearch Ingestion pipelines."]
module DeletePipelineEndpointResponse =
  struct
    type nonrec t = unit
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make () = ()
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let of_header_and_body = ((fun (xs, pipe) -> make ())[@warning "-27"])
    let to_value _ = `Structure []
    let to_query v = to_query to_value v
    let of_xml _ = make ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json _ = make ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Deletes a VPC endpoint for an OpenSearch Ingestion pipeline."]
module DeletePipelineEndpointRequest =
  struct
    type nonrec t =
      {
      endpointId: PipelineEndpointId.t
        [@ocaml.doc
          "The unique identifier of the pipeline endpoint to delete."]}
    let context_ = "DeletePipelineEndpointRequest"
    let make ~endpointId = fun () -> { endpointId }
    let to_value x =
      structure_to_value
        [("EndpointId", (Some (PipelineEndpointId.to_value x.endpointId)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let endpointId =
        PipelineEndpointId.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "EndpointId") in
      make ~endpointId ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let endpointId =
        field_map_exn json__ "EndpointId" PipelineEndpointId.of_json in
      make ~endpointId ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Deletes a VPC endpoint for an OpenSearch Ingestion pipeline."]
module CreatePipelineResponse =
  struct
    type nonrec t =
      {
      pipeline: Pipeline.t option
        [@ocaml.doc "Container for information about the created pipeline."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `LimitExceededException of LimitExceededException.t 
      | `ResourceAlreadyExistsException of ResourceAlreadyExistsException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?pipeline = fun () -> { pipeline }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_json json)
      | "ResourceAlreadyExistsException" ->
          `ResourceAlreadyExistsException
            (ResourceAlreadyExistsException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_xml xml)
      | "ResourceAlreadyExistsException" ->
          `ResourceAlreadyExistsException
            (ResourceAlreadyExistsException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `LimitExceededException e ->
          `Assoc
            [("error", (`String "LimitExceededException"));
            ("details", (LimitExceededException.to_json e))]
      | `ResourceAlreadyExistsException e ->
          `Assoc
            [("error", (`String "ResourceAlreadyExistsException"));
            ("details", (ResourceAlreadyExistsException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("Pipeline", (Option.map x.pipeline ~f:Pipeline.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipeline =
        (Option.map ~f:Pipeline.of_xml) (Xml.child xml_arg0 "Pipeline") in
      make ?pipeline ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipeline = field_map json__ "Pipeline" Pipeline.of_json in
      make ?pipeline ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Creates an OpenSearch Ingestion pipeline. For more information, see Creating Amazon OpenSearch Ingestion pipelines."]
module CreatePipelineRequest =
  struct
    type nonrec t =
      {
      pipelineName: PipelineName.t
        [@ocaml.doc
          "The name of the OpenSearch Ingestion pipeline to create. Pipeline names are unique across the pipelines owned by an account within an Amazon Web Services Region."];
      minUnits: PipelineUnits.t
        [@ocaml.doc
          "The minimum pipeline capacity, in Ingestion Compute Units (ICUs)."];
      maxUnits: PipelineUnits.t
        [@ocaml.doc
          "The maximum pipeline capacity, in Ingestion Compute Units (ICUs)."];
      pipelineConfigurationBody: PipelineConfigurationBody.t
        [@ocaml.doc
          "The pipeline configuration in YAML format. The command accepts the pipeline configuration as a string or within a .yaml file. If you provide the configuration as a string, each new line must be escaped with \\n."];
      logPublishingOptions: LogPublishingOptions.t option
        [@ocaml.doc "Key-value pairs to configure log publishing."];
      vpcOptions: VpcOptions.t option
        [@ocaml.doc
          "Container for the values required to configure VPC access for the pipeline. If you don't specify these values, OpenSearch Ingestion creates the pipeline with a public endpoint."];
      bufferOptions: BufferOptions.t option
        [@ocaml.doc
          "Key-value pairs to configure persistent buffering for the pipeline."];
      encryptionAtRestOptions: EncryptionAtRestOptions.t option
        [@ocaml.doc
          "Key-value pairs to configure encryption for data that is written to a persistent buffer."];
      tags: TagList.t option
        [@ocaml.doc "List of tags to add to the pipeline upon creation."];
      pipelineRoleArn: PipelineRoleArn.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the IAM role that grants the pipeline permission to access Amazon Web Services resources."]}
    let context_ = "CreatePipelineRequest"
    let make ?logPublishingOptions =
      fun ?vpcOptions ->
        fun ?bufferOptions ->
          fun ?encryptionAtRestOptions ->
            fun ?tags ->
              fun ?pipelineRoleArn ->
                fun ~pipelineName ->
                  fun ~minUnits ->
                    fun ~maxUnits ->
                      fun ~pipelineConfigurationBody ->
                        fun () ->
                          {
                            logPublishingOptions;
                            vpcOptions;
                            bufferOptions;
                            encryptionAtRestOptions;
                            tags;
                            pipelineRoleArn;
                            pipelineName;
                            minUnits;
                            maxUnits;
                            pipelineConfigurationBody
                          }
    let to_value x =
      structure_to_value
        [("PipelineName", (Some (PipelineName.to_value x.pipelineName)));
        ("MinUnits", (Some (PipelineUnits.to_value x.minUnits)));
        ("MaxUnits", (Some (PipelineUnits.to_value x.maxUnits)));
        ("PipelineConfigurationBody",
          (Some
             (PipelineConfigurationBody.to_value x.pipelineConfigurationBody)));
        ("LogPublishingOptions",
          (Option.map x.logPublishingOptions ~f:LogPublishingOptions.to_value));
        ("VpcOptions", (Option.map x.vpcOptions ~f:VpcOptions.to_value));
        ("BufferOptions",
          (Option.map x.bufferOptions ~f:BufferOptions.to_value));
        ("EncryptionAtRestOptions",
          (Option.map x.encryptionAtRestOptions
             ~f:EncryptionAtRestOptions.to_value));
        ("Tags", (Option.map x.tags ~f:TagList.to_value));
        ("PipelineRoleArn",
          (Option.map x.pipelineRoleArn ~f:PipelineRoleArn.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let pipelineRoleArn =
        (Option.map ~f:PipelineRoleArn.of_xml)
          (Xml.child xml_arg0 "PipelineRoleArn") in
      let tags = (Option.map ~f:TagList.of_xml) (Xml.child xml_arg0 "Tags") in
      let encryptionAtRestOptions =
        (Option.map ~f:EncryptionAtRestOptions.of_xml)
          (Xml.child xml_arg0 "EncryptionAtRestOptions") in
      let bufferOptions =
        (Option.map ~f:BufferOptions.of_xml)
          (Xml.child xml_arg0 "BufferOptions") in
      let vpcOptions =
        (Option.map ~f:VpcOptions.of_xml) (Xml.child xml_arg0 "VpcOptions") in
      let logPublishingOptions =
        (Option.map ~f:LogPublishingOptions.of_xml)
          (Xml.child xml_arg0 "LogPublishingOptions") in
      let pipelineConfigurationBody =
        PipelineConfigurationBody.of_xml
          (Xml.child_exn ~context:context_ xml_arg0
             "PipelineConfigurationBody") in
      let maxUnits =
        PipelineUnits.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "MaxUnits") in
      let minUnits =
        PipelineUnits.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "MinUnits") in
      let pipelineName =
        PipelineName.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "PipelineName") in
      make ?pipelineRoleArn ?tags ?encryptionAtRestOptions ?bufferOptions
        ?vpcOptions ?logPublishingOptions ~pipelineConfigurationBody
        ~maxUnits ~minUnits ~pipelineName ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let pipelineRoleArn =
        field_map json__ "PipelineRoleArn" PipelineRoleArn.of_json in
      let tags = field_map json__ "Tags" TagList.of_json in
      let encryptionAtRestOptions =
        field_map json__ "EncryptionAtRestOptions"
          EncryptionAtRestOptions.of_json in
      let bufferOptions =
        field_map json__ "BufferOptions" BufferOptions.of_json in
      let vpcOptions = field_map json__ "VpcOptions" VpcOptions.of_json in
      let logPublishingOptions =
        field_map json__ "LogPublishingOptions" LogPublishingOptions.of_json in
      let pipelineConfigurationBody =
        field_map_exn json__ "PipelineConfigurationBody"
          PipelineConfigurationBody.of_json in
      let maxUnits = field_map_exn json__ "MaxUnits" PipelineUnits.of_json in
      let minUnits = field_map_exn json__ "MinUnits" PipelineUnits.of_json in
      let pipelineName =
        field_map_exn json__ "PipelineName" PipelineName.of_json in
      make ?pipelineRoleArn ?tags ?encryptionAtRestOptions ?bufferOptions
        ?vpcOptions ?logPublishingOptions ~pipelineConfigurationBody
        ~maxUnits ~minUnits ~pipelineName ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Creates an OpenSearch Ingestion pipeline. For more information, see Creating Amazon OpenSearch Ingestion pipelines."]
module CreatePipelineEndpointResponse =
  struct
    type nonrec t =
      {
      pipelineArn: PipelineArn.t option
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the pipeline associated with the endpoint."];
      endpointId: PipelineEndpointId.t option
        [@ocaml.doc "The unique identifier of the pipeline endpoint."];
      status: PipelineEndpointStatus.t option
        [@ocaml.doc "The current status of the pipeline endpoint."];
      vpcId: String_.t option
        [@ocaml.doc
          "The ID of the VPC where the pipeline endpoint was created."]}
    type nonrec error =
      [ `AccessDeniedException of AccessDeniedException.t 
      | `DisabledOperationException of DisabledOperationException.t 
      | `InternalException of InternalException.t 
      | `LimitExceededException of LimitExceededException.t 
      | `ResourceNotFoundException of ResourceNotFoundException.t 
      | `ValidationException of ValidationException.t 
      | `Unknown_operation_error of (string * string option) ]
    let make ?pipelineArn =
      fun ?endpointId ->
        fun ?status ->
          fun ?vpcId -> fun () -> { pipelineArn; endpointId; status; vpcId }
    let error_of_json name json =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_json json)
      | "DisabledOperationException" ->
          `DisabledOperationException
            (DisabledOperationException.of_json json)
      | "InternalException" ->
          `InternalException (InternalException.of_json json)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_json json)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_json json)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_json json)
      | name ->
          `Unknown_operation_error
            (name, (Some (Yojson.Safe.to_string json)))
    let error_of_xml name xml =
      match name with
      | "AccessDeniedException" ->
          `AccessDeniedException (AccessDeniedException.of_xml xml)
      | "DisabledOperationException" ->
          `DisabledOperationException (DisabledOperationException.of_xml xml)
      | "InternalException" ->
          `InternalException (InternalException.of_xml xml)
      | "LimitExceededException" ->
          `LimitExceededException (LimitExceededException.of_xml xml)
      | "ResourceNotFoundException" ->
          `ResourceNotFoundException (ResourceNotFoundException.of_xml xml)
      | "ValidationException" ->
          `ValidationException (ValidationException.of_xml xml)
      | name ->
          `Unknown_operation_error (name, (Some (Awso.Xml.to_string xml)))
    let error_to_json : error -> Yojson.Safe.t =
      function
      | `AccessDeniedException e ->
          `Assoc
            [("error", (`String "AccessDeniedException"));
            ("details", (AccessDeniedException.to_json e))]
      | `DisabledOperationException e ->
          `Assoc
            [("error", (`String "DisabledOperationException"));
            ("details", (DisabledOperationException.to_json e))]
      | `InternalException e ->
          `Assoc
            [("error", (`String "InternalException"));
            ("details", (InternalException.to_json e))]
      | `LimitExceededException e ->
          `Assoc
            [("error", (`String "LimitExceededException"));
            ("details", (LimitExceededException.to_json e))]
      | `ResourceNotFoundException e ->
          `Assoc
            [("error", (`String "ResourceNotFoundException"));
            ("details", (ResourceNotFoundException.to_json e))]
      | `ValidationException e ->
          `Assoc
            [("error", (`String "ValidationException"));
            ("details", (ValidationException.to_json e))]
      | `Unknown_operation_error (code, msg) ->
          `Assoc (("error", (`String code)) ::
            ((match msg with
              | None -> []
              | Some m -> [("message", (`String m))])))
    let to_value x =
      structure_to_value
        [("PipelineArn", (Option.map x.pipelineArn ~f:PipelineArn.to_value));
        ("EndpointId",
          (Option.map x.endpointId ~f:PipelineEndpointId.to_value));
        ("Status", (Option.map x.status ~f:PipelineEndpointStatus.to_value));
        ("VpcId", (Option.map x.vpcId ~f:String_.to_value))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let vpcId = (Option.map ~f:String_.of_xml) (Xml.child xml_arg0 "VpcId") in
      let status =
        (Option.map ~f:PipelineEndpointStatus.of_xml)
          (Xml.child xml_arg0 "Status") in
      let endpointId =
        (Option.map ~f:PipelineEndpointId.of_xml)
          (Xml.child xml_arg0 "EndpointId") in
      let pipelineArn =
        (Option.map ~f:PipelineArn.of_xml) (Xml.child xml_arg0 "PipelineArn") in
      make ?vpcId ?status ?endpointId ?pipelineArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let vpcId = field_map json__ "VpcId" String_.of_json in
      let status = field_map json__ "Status" PipelineEndpointStatus.of_json in
      let endpointId =
        field_map json__ "EndpointId" PipelineEndpointId.of_json in
      let pipelineArn = field_map json__ "PipelineArn" PipelineArn.of_json in
      make ?vpcId ?status ?endpointId ?pipelineArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Creates a VPC endpoint for an OpenSearch Ingestion pipeline. Pipeline endpoints allow you to ingest data from your VPC into pipelines that you have access to."]
module CreatePipelineEndpointRequest =
  struct
    type nonrec t =
      {
      pipelineArn: PipelineArn.t
        [@ocaml.doc
          "The Amazon Resource Name (ARN) of the pipeline to create the endpoint for."];
      vpcOptions: PipelineEndpointVpcOptions.t
        [@ocaml.doc
          "Container for the VPC configuration for the pipeline endpoint, including subnet IDs and security group IDs."]}
    let context_ = "CreatePipelineEndpointRequest"
    let make ~pipelineArn =
      fun ~vpcOptions -> fun () -> { pipelineArn; vpcOptions }
    let to_value x =
      structure_to_value
        [("PipelineArn", (Some (PipelineArn.to_value x.pipelineArn)));
        ("VpcOptions",
          (Some (PipelineEndpointVpcOptions.to_value x.vpcOptions)))]
    let to_query v = to_query to_value v
    let of_xml xml_arg0 =
      let vpcOptions =
        PipelineEndpointVpcOptions.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "VpcOptions") in
      let pipelineArn =
        PipelineArn.of_xml
          (Xml.child_exn ~context:context_ xml_arg0 "PipelineArn") in
      make ~vpcOptions ~pipelineArn ()
    let of_string s = of_xml (Awso.Xml.parse_response s)[@@warning "-32"]
    let of_json json__ =
      let vpcOptions =
        field_map_exn json__ "VpcOptions" PipelineEndpointVpcOptions.of_json in
      let pipelineArn =
        field_map_exn json__ "PipelineArn" PipelineArn.of_json in
      make ~vpcOptions ~pipelineArn ()
    let to_json v = composed_to_json to_value v
  end[@@ocaml.doc
       "Creates a VPC endpoint for an OpenSearch Ingestion pipeline. Pipeline endpoints allow you to ingest data from your VPC into pipelines that you have access to."]