Source file cli.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 Core
open Async
let json_arg = Command.Arg_type.create Yojson.Safe.from_string
let call ?endpoint_url ?profile ?region f m result_to_json error_to_json =
  let region =
    match region with
    | Some region -> Some (Awso.Region.of_string region)
    | None -> None in
  (Awso_async.Cfg.get_exn ?profile ?region ()) >>=
    (fun cfg ->
       (f ?endpoint_url ?cfg:(Some cfg) m) >>=
         (fun result ->
            match result with
            | Error err ->
                (match error_to_json with
                 | None ->
                     failwithf
                       "endpoint error, but no error values defined in boto"
                       ()
                 | Some to_json ->
                     let s = (err |> to_json) |> Yojson.Safe.to_string in
                     failwithf "AWS error: %s" s ())
            | Ok result ->
                ((match result_to_json with
                  | None -> print_endline "ok response from endpoint"
                  | Some to_json ->
                      ((result |> to_json) |> Yojson.Safe.to_string) |>
                        print_endline);
                 return ())))
let batch_update_cluster =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and serviceUpdate =
         flag "service-update" (optional json_arg)
           ~doc:"JSON ServiceUpdateRequest"
       and clusterNames =
         flag "cluster-names" (required json_arg) ~doc:"JSON ClusterNameList" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.batch_update_cluster
           (Values.BatchUpdateClusterRequest.make
              ?serviceUpdate:(Option.map
                                ~f:Values.ServiceUpdateRequest.of_json
                                serviceUpdate)
              ~clusterNames:(Values.ClusterNameList.of_json clusterNames) ())
           (Some Values.BatchUpdateClusterResponse.to_json)
           (Some Values.BatchUpdateClusterResponse.error_to_json)])
let copy_snapshot =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and targetBucket =
         flag "target-bucket" (optional string) ~doc:"STRING TargetBucket"
       and kmsKeyId =
         flag "kms-key-id" (optional string) ~doc:"STRING KmsKeyId"
       and tags = flag "tags" (optional json_arg) ~doc:"JSON TagList"
       and sourceSnapshotName =
         flag "source-snapshot-name" (required string) ~doc:"STRING String"
       and targetSnapshotName =
         flag "target-snapshot-name" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.copy_snapshot
           (Values.CopySnapshotRequest.make ?targetBucket ?kmsKeyId
              ?tags:(Option.map ~f:Values.TagList.of_json tags)
              ~sourceSnapshotName ~targetSnapshotName ())
           (Some Values.CopySnapshotResponse.to_json)
           (Some Values.CopySnapshotResponse.error_to_json)])
let create_a_c_l =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and userNames =
         flag "user-names" (optional json_arg) ~doc:"JSON UserNameListInput"
       and tags = flag "tags" (optional json_arg) ~doc:"JSON TagList"
       and aCLName = flag "a-c-l-name" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.create_a_c_l
           (Values.CreateACLRequest.make
              ?userNames:(Option.map ~f:Values.UserNameListInput.of_json
                            userNames)
              ?tags:(Option.map ~f:Values.TagList.of_json tags) ~aCLName ())
           (Some Values.CreateACLResponse.to_json)
           (Some Values.CreateACLResponse.error_to_json)])
let create_cluster =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and multiRegionClusterName =
         flag "multi-region-cluster-name" (optional string)
           ~doc:"STRING String"
       and parameterGroupName =
         flag "parameter-group-name" (optional string) ~doc:"STRING String"
       and description =
         flag "description" (optional string) ~doc:"STRING String"
       and numShards =
         flag "num-shards" (optional int) ~doc:"INT IntegerOptional"
       and numReplicasPerShard =
         flag "num-replicas-per-shard" (optional int)
           ~doc:"INT IntegerOptional"
       and subnetGroupName =
         flag "subnet-group-name" (optional string) ~doc:"STRING String"
       and securityGroupIds =
         flag "security-group-ids" (optional json_arg)
           ~doc:"JSON SecurityGroupIdsList"
       and maintenanceWindow =
         flag "maintenance-window" (optional string) ~doc:"STRING String"
       and port = flag "port" (optional int) ~doc:"INT IntegerOptional"
       and snsTopicArn =
         flag "sns-topic-arn" (optional string) ~doc:"STRING String"
       and tLSEnabled =
         flag "t-l-s-enabled" (optional bool) ~doc:"BOOL BooleanOptional"
       and kmsKeyId =
         flag "kms-key-id" (optional string) ~doc:"STRING String"
       and snapshotArns =
         flag "snapshot-arns" (optional json_arg)
           ~doc:"JSON SnapshotArnsList"
       and snapshotName =
         flag "snapshot-name" (optional string) ~doc:"STRING String"
       and snapshotRetentionLimit =
         flag "snapshot-retention-limit" (optional int)
           ~doc:"INT IntegerOptional"
       and tags = flag "tags" (optional json_arg) ~doc:"JSON TagList"
       and snapshotWindow =
         flag "snapshot-window" (optional string) ~doc:"STRING String"
       and engine = flag "engine" (optional string) ~doc:"STRING String"
       and engineVersion =
         flag "engine-version" (optional string) ~doc:"STRING String"
       and autoMinorVersionUpgrade =
         flag "auto-minor-version-upgrade" (optional bool)
           ~doc:"BOOL BooleanOptional"
       and dataTiering =
         flag "data-tiering" (optional bool) ~doc:"BOOL BooleanOptional"
       and networkType =
         flag "network-type" (optional json_arg) ~doc:"JSON NetworkType"
       and ipDiscovery =
         flag "ip-discovery" (optional json_arg) ~doc:"JSON IpDiscovery"
       and clusterName =
         flag "cluster-name" (required string) ~doc:"STRING String"
       and nodeType = flag "node-type" (required string) ~doc:"STRING String"
       and aCLName =
         flag "a-c-l-name" (required string) ~doc:"STRING ACLName" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.create_cluster
           (Values.CreateClusterRequest.make ?multiRegionClusterName
              ?parameterGroupName ?description ?numShards
              ?numReplicasPerShard ?subnetGroupName
              ?securityGroupIds:(Option.map
                                   ~f:Values.SecurityGroupIdsList.of_json
                                   securityGroupIds) ?maintenanceWindow ?port
              ?snsTopicArn ?tLSEnabled ?kmsKeyId
              ?snapshotArns:(Option.map ~f:Values.SnapshotArnsList.of_json
                               snapshotArns) ?snapshotName
              ?snapshotRetentionLimit
              ?tags:(Option.map ~f:Values.TagList.of_json tags)
              ?snapshotWindow ?engine ?engineVersion ?autoMinorVersionUpgrade
              ?dataTiering
              ?networkType:(Option.map ~f:Values.NetworkType.of_json
                              networkType)
              ?ipDiscovery:(Option.map ~f:Values.IpDiscovery.of_json
                              ipDiscovery) ~clusterName ~nodeType ~aCLName ())
           (Some Values.CreateClusterResponse.to_json)
           (Some Values.CreateClusterResponse.error_to_json)])
let create_multi_region_cluster =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and description =
         flag "description" (optional string) ~doc:"STRING String"
       and engine = flag "engine" (optional string) ~doc:"STRING String"
       and engineVersion =
         flag "engine-version" (optional string) ~doc:"STRING String"
       and multiRegionParameterGroupName =
         flag "multi-region-parameter-group-name" (optional string)
           ~doc:"STRING String"
       and numShards =
         flag "num-shards" (optional int) ~doc:"INT IntegerOptional"
       and tLSEnabled =
         flag "t-l-s-enabled" (optional bool) ~doc:"BOOL BooleanOptional"
       and tags = flag "tags" (optional json_arg) ~doc:"JSON TagList"
       and multiRegionClusterNameSuffix =
         flag "multi-region-cluster-name-suffix" (required string)
           ~doc:"STRING String"
       and nodeType = flag "node-type" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.create_multi_region_cluster
           (Values.CreateMultiRegionClusterRequest.make ?description ?engine
              ?engineVersion ?multiRegionParameterGroupName ?numShards
              ?tLSEnabled ?tags:(Option.map ~f:Values.TagList.of_json tags)
              ~multiRegionClusterNameSuffix ~nodeType ())
           (Some Values.CreateMultiRegionClusterResponse.to_json)
           (Some Values.CreateMultiRegionClusterResponse.error_to_json)])
let create_parameter_group =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and description =
         flag "description" (optional string) ~doc:"STRING String"
       and tags = flag "tags" (optional json_arg) ~doc:"JSON TagList"
       and parameterGroupName =
         flag "parameter-group-name" (required string) ~doc:"STRING String"
       and family = flag "family" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.create_parameter_group
           (Values.CreateParameterGroupRequest.make ?description
              ?tags:(Option.map ~f:Values.TagList.of_json tags)
              ~parameterGroupName ~family ())
           (Some Values.CreateParameterGroupResponse.to_json)
           (Some Values.CreateParameterGroupResponse.error_to_json)])
let create_snapshot =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and kmsKeyId =
         flag "kms-key-id" (optional string) ~doc:"STRING String"
       and tags = flag "tags" (optional json_arg) ~doc:"JSON TagList"
       and clusterName =
         flag "cluster-name" (required string) ~doc:"STRING String"
       and snapshotName =
         flag "snapshot-name" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.create_snapshot
           (Values.CreateSnapshotRequest.make ?kmsKeyId
              ?tags:(Option.map ~f:Values.TagList.of_json tags) ~clusterName
              ~snapshotName ()) (Some Values.CreateSnapshotResponse.to_json)
           (Some Values.CreateSnapshotResponse.error_to_json)])
let create_subnet_group =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and description =
         flag "description" (optional string) ~doc:"STRING String"
       and tags = flag "tags" (optional json_arg) ~doc:"JSON TagList"
       and subnetGroupName =
         flag "subnet-group-name" (required string) ~doc:"STRING String"
       and subnetIds =
         flag "subnet-ids" (required json_arg)
           ~doc:"JSON SubnetIdentifierList" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.create_subnet_group
           (Values.CreateSubnetGroupRequest.make ?description
              ?tags:(Option.map ~f:Values.TagList.of_json tags)
              ~subnetGroupName
              ~subnetIds:(Values.SubnetIdentifierList.of_json subnetIds) ())
           (Some Values.CreateSubnetGroupResponse.to_json)
           (Some Values.CreateSubnetGroupResponse.error_to_json)])
let create_user =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and tags = flag "tags" (optional json_arg) ~doc:"JSON TagList"
       and userName =
         flag "user-name" (required string) ~doc:"STRING UserName"
       and authenticationMode =
         flag "authentication-mode" (required json_arg)
           ~doc:"JSON AuthenticationMode"
       and accessString =
         flag "access-string" (required string) ~doc:"STRING AccessString" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.create_user
           (Values.CreateUserRequest.make
              ?tags:(Option.map ~f:Values.TagList.of_json tags) ~userName
              ~authenticationMode:(Values.AuthenticationMode.of_json
                                     authenticationMode) ~accessString ())
           (Some Values.CreateUserResponse.to_json)
           (Some Values.CreateUserResponse.error_to_json)])
let delete_a_c_l =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and aCLName = flag "a-c-l-name" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.delete_a_c_l (Values.DeleteACLRequest.make ~aCLName ())
           (Some Values.DeleteACLResponse.to_json)
           (Some Values.DeleteACLResponse.error_to_json)])
let delete_cluster =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and multiRegionClusterName =
         flag "multi-region-cluster-name" (optional string)
           ~doc:"STRING String"
       and finalSnapshotName =
         flag "final-snapshot-name" (optional string) ~doc:"STRING String"
       and clusterName =
         flag "cluster-name" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.delete_cluster
           (Values.DeleteClusterRequest.make ?multiRegionClusterName
              ?finalSnapshotName ~clusterName ())
           (Some Values.DeleteClusterResponse.to_json)
           (Some Values.DeleteClusterResponse.error_to_json)])
let delete_multi_region_cluster =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and multiRegionClusterName =
         flag "multi-region-cluster-name" (required string)
           ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.delete_multi_region_cluster
           (Values.DeleteMultiRegionClusterRequest.make
              ~multiRegionClusterName ())
           (Some Values.DeleteMultiRegionClusterResponse.to_json)
           (Some Values.DeleteMultiRegionClusterResponse.error_to_json)])
let delete_parameter_group =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and parameterGroupName =
         flag "parameter-group-name" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.delete_parameter_group
           (Values.DeleteParameterGroupRequest.make ~parameterGroupName ())
           (Some Values.DeleteParameterGroupResponse.to_json)
           (Some Values.DeleteParameterGroupResponse.error_to_json)])
let delete_snapshot =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and snapshotName =
         flag "snapshot-name" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.delete_snapshot
           (Values.DeleteSnapshotRequest.make ~snapshotName ())
           (Some Values.DeleteSnapshotResponse.to_json)
           (Some Values.DeleteSnapshotResponse.error_to_json)])
let delete_subnet_group =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and subnetGroupName =
         flag "subnet-group-name" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.delete_subnet_group
           (Values.DeleteSubnetGroupRequest.make ~subnetGroupName ())
           (Some Values.DeleteSubnetGroupResponse.to_json)
           (Some Values.DeleteSubnetGroupResponse.error_to_json)])
let delete_user =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and userName =
         flag "user-name" (required string) ~doc:"STRING UserName" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.delete_user (Values.DeleteUserRequest.make ~userName ())
           (Some Values.DeleteUserResponse.to_json)
           (Some Values.DeleteUserResponse.error_to_json)])
let describe_a_c_ls =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and aCLName = flag "a-c-l-name" (optional string) ~doc:"STRING String"
       and maxResults =
         flag "max-results" (optional int) ~doc:"INT IntegerOptional"
       and nextToken =
         flag "next-token" (optional string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.describe_a_c_ls
           (Values.DescribeACLsRequest.make ?aCLName ?maxResults ?nextToken
              ()) (Some Values.DescribeACLsResponse.to_json)
           (Some Values.DescribeACLsResponse.error_to_json)])
let describe_clusters =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and clusterName =
         flag "cluster-name" (optional string) ~doc:"STRING String"
       and maxResults =
         flag "max-results" (optional int) ~doc:"INT IntegerOptional"
       and nextToken =
         flag "next-token" (optional string) ~doc:"STRING String"
       and showShardDetails =
         flag "show-shard-details" (optional bool)
           ~doc:"BOOL BooleanOptional" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.describe_clusters
           (Values.DescribeClustersRequest.make ?clusterName ?maxResults
              ?nextToken ?showShardDetails ())
           (Some Values.DescribeClustersResponse.to_json)
           (Some Values.DescribeClustersResponse.error_to_json)])
let describe_engine_versions =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and engine = flag "engine" (optional string) ~doc:"STRING String"
       and engineVersion =
         flag "engine-version" (optional string) ~doc:"STRING String"
       and parameterGroupFamily =
         flag "parameter-group-family" (optional string) ~doc:"STRING String"
       and maxResults =
         flag "max-results" (optional int) ~doc:"INT IntegerOptional"
       and nextToken =
         flag "next-token" (optional string) ~doc:"STRING String"
       and defaultOnly =
         flag "default-only" (optional bool) ~doc:"BOOL Boolean" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.describe_engine_versions
           (Values.DescribeEngineVersionsRequest.make ?engine ?engineVersion
              ?parameterGroupFamily ?maxResults ?nextToken ?defaultOnly ())
           (Some Values.DescribeEngineVersionsResponse.to_json)
           (Some Values.DescribeEngineVersionsResponse.error_to_json)])
let describe_events =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and sourceName =
         flag "source-name" (optional string) ~doc:"STRING String"
       and sourceType =
         flag "source-type" (optional json_arg) ~doc:"JSON SourceType"
       and startTime =
         flag "start-time" (optional json_arg) ~doc:"JSON TStamp"
       and endTime = flag "end-time" (optional json_arg) ~doc:"JSON TStamp"
       and duration =
         flag "duration" (optional int) ~doc:"INT IntegerOptional"
       and maxResults =
         flag "max-results" (optional int) ~doc:"INT IntegerOptional"
       and nextToken =
         flag "next-token" (optional string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.describe_events
           (Values.DescribeEventsRequest.make ?sourceName
              ?sourceType:(Option.map ~f:Values.SourceType.of_json sourceType)
              ?startTime:(Option.map ~f:Values.TStamp.of_json startTime)
              ?endTime:(Option.map ~f:Values.TStamp.of_json endTime)
              ?duration ?maxResults ?nextToken ())
           (Some Values.DescribeEventsResponse.to_json)
           (Some Values.DescribeEventsResponse.error_to_json)])
let describe_multi_region_clusters =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and multiRegionClusterName =
         flag "multi-region-cluster-name" (optional string)
           ~doc:"STRING String"
       and maxResults =
         flag "max-results" (optional int) ~doc:"INT IntegerOptional"
       and nextToken =
         flag "next-token" (optional string) ~doc:"STRING String"
       and showClusterDetails =
         flag "show-cluster-details" (optional bool)
           ~doc:"BOOL BooleanOptional" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.describe_multi_region_clusters
           (Values.DescribeMultiRegionClustersRequest.make
              ?multiRegionClusterName ?maxResults ?nextToken
              ?showClusterDetails ())
           (Some Values.DescribeMultiRegionClustersResponse.to_json)
           (Some Values.DescribeMultiRegionClustersResponse.error_to_json)])
let describe_multi_region_parameter_groups =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and multiRegionParameterGroupName =
         flag "multi-region-parameter-group-name" (optional string)
           ~doc:"STRING String"
       and maxResults =
         flag "max-results" (optional int) ~doc:"INT IntegerOptional"
       and nextToken =
         flag "next-token" (optional string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.describe_multi_region_parameter_groups
           (Values.DescribeMultiRegionParameterGroupsRequest.make
              ?multiRegionParameterGroupName ?maxResults ?nextToken ())
           (Some Values.DescribeMultiRegionParameterGroupsResponse.to_json)
           (Some
              Values.DescribeMultiRegionParameterGroupsResponse.error_to_json)])
let describe_multi_region_parameters =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and source = flag "source" (optional string) ~doc:"STRING String"
       and maxResults =
         flag "max-results" (optional int) ~doc:"INT IntegerOptional"
       and nextToken =
         flag "next-token" (optional string) ~doc:"STRING String"
       and multiRegionParameterGroupName =
         flag "multi-region-parameter-group-name" (required string)
           ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.describe_multi_region_parameters
           (Values.DescribeMultiRegionParametersRequest.make ?source
              ?maxResults ?nextToken ~multiRegionParameterGroupName ())
           (Some Values.DescribeMultiRegionParametersResponse.to_json)
           (Some Values.DescribeMultiRegionParametersResponse.error_to_json)])
let describe_parameter_groups =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and parameterGroupName =
         flag "parameter-group-name" (optional string) ~doc:"STRING String"
       and maxResults =
         flag "max-results" (optional int) ~doc:"INT IntegerOptional"
       and nextToken =
         flag "next-token" (optional string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.describe_parameter_groups
           (Values.DescribeParameterGroupsRequest.make ?parameterGroupName
              ?maxResults ?nextToken ())
           (Some Values.DescribeParameterGroupsResponse.to_json)
           (Some Values.DescribeParameterGroupsResponse.error_to_json)])
let describe_parameters =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and maxResults =
         flag "max-results" (optional int) ~doc:"INT IntegerOptional"
       and nextToken =
         flag "next-token" (optional string) ~doc:"STRING String"
       and parameterGroupName =
         flag "parameter-group-name" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.describe_parameters
           (Values.DescribeParametersRequest.make ?maxResults ?nextToken
              ~parameterGroupName ())
           (Some Values.DescribeParametersResponse.to_json)
           (Some Values.DescribeParametersResponse.error_to_json)])
let describe_reserved_nodes =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and reservationId =
         flag "reservation-id" (optional string) ~doc:"STRING String"
       and reservedNodesOfferingId =
         flag "reserved-nodes-offering-id" (optional string)
           ~doc:"STRING String"
       and nodeType = flag "node-type" (optional string) ~doc:"STRING String"
       and duration = flag "duration" (optional string) ~doc:"STRING String"
       and offeringType =
         flag "offering-type" (optional string) ~doc:"STRING String"
       and maxResults =
         flag "max-results" (optional int) ~doc:"INT IntegerOptional"
       and nextToken =
         flag "next-token" (optional string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.describe_reserved_nodes
           (Values.DescribeReservedNodesRequest.make ?reservationId
              ?reservedNodesOfferingId ?nodeType ?duration ?offeringType
              ?maxResults ?nextToken ())
           (Some Values.DescribeReservedNodesResponse.to_json)
           (Some Values.DescribeReservedNodesResponse.error_to_json)])
let describe_reserved_nodes_offerings =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and reservedNodesOfferingId =
         flag "reserved-nodes-offering-id" (optional string)
           ~doc:"STRING String"
       and nodeType = flag "node-type" (optional string) ~doc:"STRING String"
       and duration = flag "duration" (optional string) ~doc:"STRING String"
       and offeringType =
         flag "offering-type" (optional string) ~doc:"STRING String"
       and maxResults =
         flag "max-results" (optional int) ~doc:"INT IntegerOptional"
       and nextToken =
         flag "next-token" (optional string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.describe_reserved_nodes_offerings
           (Values.DescribeReservedNodesOfferingsRequest.make
              ?reservedNodesOfferingId ?nodeType ?duration ?offeringType
              ?maxResults ?nextToken ())
           (Some Values.DescribeReservedNodesOfferingsResponse.to_json)
           (Some Values.DescribeReservedNodesOfferingsResponse.error_to_json)])
let describe_service_updates =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and serviceUpdateName =
         flag "service-update-name" (optional string) ~doc:"STRING String"
       and clusterNames =
         flag "cluster-names" (optional json_arg) ~doc:"JSON ClusterNameList"
       and status =
         flag "status" (optional json_arg)
           ~doc:"JSON ServiceUpdateStatusList"
       and maxResults =
         flag "max-results" (optional int) ~doc:"INT IntegerOptional"
       and nextToken =
         flag "next-token" (optional string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.describe_service_updates
           (Values.DescribeServiceUpdatesRequest.make ?serviceUpdateName
              ?clusterNames:(Option.map ~f:Values.ClusterNameList.of_json
                               clusterNames)
              ?status:(Option.map ~f:Values.ServiceUpdateStatusList.of_json
                         status) ?maxResults ?nextToken ())
           (Some Values.DescribeServiceUpdatesResponse.to_json)
           (Some Values.DescribeServiceUpdatesResponse.error_to_json)])
let describe_snapshots =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and clusterName =
         flag "cluster-name" (optional string) ~doc:"STRING String"
       and snapshotName =
         flag "snapshot-name" (optional string) ~doc:"STRING String"
       and source = flag "source" (optional string) ~doc:"STRING String"
       and nextToken =
         flag "next-token" (optional string) ~doc:"STRING String"
       and maxResults =
         flag "max-results" (optional int) ~doc:"INT IntegerOptional"
       and showDetail =
         flag "show-detail" (optional bool) ~doc:"BOOL BooleanOptional" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.describe_snapshots
           (Values.DescribeSnapshotsRequest.make ?clusterName ?snapshotName
              ?source ?nextToken ?maxResults ?showDetail ())
           (Some Values.DescribeSnapshotsResponse.to_json)
           (Some Values.DescribeSnapshotsResponse.error_to_json)])
let describe_subnet_groups =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and subnetGroupName =
         flag "subnet-group-name" (optional string) ~doc:"STRING String"
       and maxResults =
         flag "max-results" (optional int) ~doc:"INT IntegerOptional"
       and nextToken =
         flag "next-token" (optional string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.describe_subnet_groups
           (Values.DescribeSubnetGroupsRequest.make ?subnetGroupName
              ?maxResults ?nextToken ())
           (Some Values.DescribeSubnetGroupsResponse.to_json)
           (Some Values.DescribeSubnetGroupsResponse.error_to_json)])
let describe_users =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and userName =
         flag "user-name" (optional string) ~doc:"STRING UserName"
       and filters =
         flag "filters" (optional json_arg) ~doc:"JSON FilterList"
       and maxResults =
         flag "max-results" (optional int) ~doc:"INT IntegerOptional"
       and nextToken =
         flag "next-token" (optional string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.describe_users
           (Values.DescribeUsersRequest.make ?userName
              ?filters:(Option.map ~f:Values.FilterList.of_json filters)
              ?maxResults ?nextToken ())
           (Some Values.DescribeUsersResponse.to_json)
           (Some Values.DescribeUsersResponse.error_to_json)])
let failover_shard =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and clusterName =
         flag "cluster-name" (required string) ~doc:"STRING String"
       and shardName =
         flag "shard-name" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.failover_shard
           (Values.FailoverShardRequest.make ~clusterName ~shardName ())
           (Some Values.FailoverShardResponse.to_json)
           (Some Values.FailoverShardResponse.error_to_json)])
let list_allowed_multi_region_cluster_updates =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and multiRegionClusterName =
         flag "multi-region-cluster-name" (required string)
           ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.list_allowed_multi_region_cluster_updates
           (Values.ListAllowedMultiRegionClusterUpdatesRequest.make
              ~multiRegionClusterName ())
           (Some Values.ListAllowedMultiRegionClusterUpdatesResponse.to_json)
           (Some
              Values.ListAllowedMultiRegionClusterUpdatesResponse.error_to_json)])
let list_allowed_node_type_updates =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and clusterName =
         flag "cluster-name" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.list_allowed_node_type_updates
           (Values.ListAllowedNodeTypeUpdatesRequest.make ~clusterName ())
           (Some Values.ListAllowedNodeTypeUpdatesResponse.to_json)
           (Some Values.ListAllowedNodeTypeUpdatesResponse.error_to_json)])
let list_tags =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and resourceArn =
         flag "resource-arn" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.list_tags (Values.ListTagsRequest.make ~resourceArn ())
           (Some Values.ListTagsResponse.to_json)
           (Some Values.ListTagsResponse.error_to_json)])
let purchase_reserved_nodes_offering =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and reservationId =
         flag "reservation-id" (optional string) ~doc:"STRING String"
       and nodeCount =
         flag "node-count" (optional int) ~doc:"INT IntegerOptional"
       and tags = flag "tags" (optional json_arg) ~doc:"JSON TagList"
       and reservedNodesOfferingId =
         flag "reserved-nodes-offering-id" (required string)
           ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.purchase_reserved_nodes_offering
           (Values.PurchaseReservedNodesOfferingRequest.make ?reservationId
              ?nodeCount ?tags:(Option.map ~f:Values.TagList.of_json tags)
              ~reservedNodesOfferingId ())
           (Some Values.PurchaseReservedNodesOfferingResponse.to_json)
           (Some Values.PurchaseReservedNodesOfferingResponse.error_to_json)])
let reset_parameter_group =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and allParameters =
         flag "all-parameters" (optional bool) ~doc:"BOOL Boolean"
       and parameterNames =
         flag "parameter-names" (optional json_arg)
           ~doc:"JSON ParameterNameList"
       and parameterGroupName =
         flag "parameter-group-name" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.reset_parameter_group
           (Values.ResetParameterGroupRequest.make ?allParameters
              ?parameterNames:(Option.map ~f:Values.ParameterNameList.of_json
                                 parameterNames) ~parameterGroupName ())
           (Some Values.ResetParameterGroupResponse.to_json)
           (Some Values.ResetParameterGroupResponse.error_to_json)])
let tag_resource =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and resourceArn =
         flag "resource-arn" (required string) ~doc:"STRING String"
       and tags = flag "tags" (required json_arg) ~doc:"JSON TagList" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.tag_resource
           (Values.TagResourceRequest.make ~resourceArn
              ~tags:(Values.TagList.of_json tags) ())
           (Some Values.TagResourceResponse.to_json)
           (Some Values.TagResourceResponse.error_to_json)])
let untag_resource =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and resourceArn =
         flag "resource-arn" (required string) ~doc:"STRING String"
       and tagKeys = flag "tag-keys" (required json_arg) ~doc:"JSON KeyList" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.untag_resource
           (Values.UntagResourceRequest.make ~resourceArn
              ~tagKeys:(Values.KeyList.of_json tagKeys) ())
           (Some Values.UntagResourceResponse.to_json)
           (Some Values.UntagResourceResponse.error_to_json)])
let update_a_c_l =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and userNamesToAdd =
         flag "user-names-to-add" (optional json_arg)
           ~doc:"JSON UserNameListInput"
       and userNamesToRemove =
         flag "user-names-to-remove" (optional json_arg)
           ~doc:"JSON UserNameListInput"
       and aCLName = flag "a-c-l-name" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.update_a_c_l
           (Values.UpdateACLRequest.make
              ?userNamesToAdd:(Option.map ~f:Values.UserNameListInput.of_json
                                 userNamesToAdd)
              ?userNamesToRemove:(Option.map
                                    ~f:Values.UserNameListInput.of_json
                                    userNamesToRemove) ~aCLName ())
           (Some Values.UpdateACLResponse.to_json)
           (Some Values.UpdateACLResponse.error_to_json)])
let update_cluster =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and description =
         flag "description" (optional string) ~doc:"STRING String"
       and securityGroupIds =
         flag "security-group-ids" (optional json_arg)
           ~doc:"JSON SecurityGroupIdsList"
       and maintenanceWindow =
         flag "maintenance-window" (optional string) ~doc:"STRING String"
       and snsTopicArn =
         flag "sns-topic-arn" (optional string) ~doc:"STRING String"
       and snsTopicStatus =
         flag "sns-topic-status" (optional string) ~doc:"STRING String"
       and parameterGroupName =
         flag "parameter-group-name" (optional string) ~doc:"STRING String"
       and snapshotWindow =
         flag "snapshot-window" (optional string) ~doc:"STRING String"
       and snapshotRetentionLimit =
         flag "snapshot-retention-limit" (optional int)
           ~doc:"INT IntegerOptional"
       and nodeType = flag "node-type" (optional string) ~doc:"STRING String"
       and engine = flag "engine" (optional string) ~doc:"STRING String"
       and engineVersion =
         flag "engine-version" (optional string) ~doc:"STRING String"
       and replicaConfiguration =
         flag "replica-configuration" (optional json_arg)
           ~doc:"JSON ReplicaConfigurationRequest"
       and shardConfiguration =
         flag "shard-configuration" (optional json_arg)
           ~doc:"JSON ShardConfigurationRequest"
       and aCLName =
         flag "a-c-l-name" (optional string) ~doc:"STRING ACLName"
       and ipDiscovery =
         flag "ip-discovery" (optional json_arg) ~doc:"JSON IpDiscovery"
       and clusterName =
         flag "cluster-name" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.update_cluster
           (Values.UpdateClusterRequest.make ?description
              ?securityGroupIds:(Option.map
                                   ~f:Values.SecurityGroupIdsList.of_json
                                   securityGroupIds) ?maintenanceWindow
              ?snsTopicArn ?snsTopicStatus ?parameterGroupName
              ?snapshotWindow ?snapshotRetentionLimit ?nodeType ?engine
              ?engineVersion
              ?replicaConfiguration:(Option.map
                                       ~f:Values.ReplicaConfigurationRequest.of_json
                                       replicaConfiguration)
              ?shardConfiguration:(Option.map
                                     ~f:Values.ShardConfigurationRequest.of_json
                                     shardConfiguration) ?aCLName
              ?ipDiscovery:(Option.map ~f:Values.IpDiscovery.of_json
                              ipDiscovery) ~clusterName ())
           (Some Values.UpdateClusterResponse.to_json)
           (Some Values.UpdateClusterResponse.error_to_json)])
let update_multi_region_cluster =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and nodeType = flag "node-type" (optional string) ~doc:"STRING String"
       and description =
         flag "description" (optional string) ~doc:"STRING String"
       and engineVersion =
         flag "engine-version" (optional string) ~doc:"STRING String"
       and shardConfiguration =
         flag "shard-configuration" (optional json_arg)
           ~doc:"JSON ShardConfigurationRequest"
       and multiRegionParameterGroupName =
         flag "multi-region-parameter-group-name" (optional string)
           ~doc:"STRING String"
       and updateStrategy =
         flag "update-strategy" (optional json_arg)
           ~doc:"JSON UpdateStrategy"
       and multiRegionClusterName =
         flag "multi-region-cluster-name" (required string)
           ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.update_multi_region_cluster
           (Values.UpdateMultiRegionClusterRequest.make ?nodeType
              ?description ?engineVersion
              ?shardConfiguration:(Option.map
                                     ~f:Values.ShardConfigurationRequest.of_json
                                     shardConfiguration)
              ?multiRegionParameterGroupName
              ?updateStrategy:(Option.map ~f:Values.UpdateStrategy.of_json
                                 updateStrategy) ~multiRegionClusterName ())
           (Some Values.UpdateMultiRegionClusterResponse.to_json)
           (Some Values.UpdateMultiRegionClusterResponse.error_to_json)])
let update_parameter_group =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and parameterGroupName =
         flag "parameter-group-name" (required string) ~doc:"STRING String"
       and parameterNameValues =
         flag "parameter-name-values" (required json_arg)
           ~doc:"JSON ParameterNameValueList" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.update_parameter_group
           (Values.UpdateParameterGroupRequest.make ~parameterGroupName
              ~parameterNameValues:(Values.ParameterNameValueList.of_json
                                      parameterNameValues) ())
           (Some Values.UpdateParameterGroupResponse.to_json)
           (Some Values.UpdateParameterGroupResponse.error_to_json)])
let update_subnet_group =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and description =
         flag "description" (optional string) ~doc:"STRING String"
       and subnetIds =
         flag "subnet-ids" (optional json_arg)
           ~doc:"JSON SubnetIdentifierList"
       and subnetGroupName =
         flag "subnet-group-name" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.update_subnet_group
           (Values.UpdateSubnetGroupRequest.make ?description
              ?subnetIds:(Option.map ~f:Values.SubnetIdentifierList.of_json
                            subnetIds) ~subnetGroupName ())
           (Some Values.UpdateSubnetGroupResponse.to_json)
           (Some Values.UpdateSubnetGroupResponse.error_to_json)])
let update_user =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and authenticationMode =
         flag "authentication-mode" (optional json_arg)
           ~doc:"JSON AuthenticationMode"
       and accessString =
         flag "access-string" (optional string) ~doc:"STRING AccessString"
       and userName =
         flag "user-name" (required string) ~doc:"STRING UserName" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.update_user
           (Values.UpdateUserRequest.make
              ?authenticationMode:(Option.map
                                     ~f:Values.AuthenticationMode.of_json
                                     authenticationMode) ?accessString
              ~userName ()) (Some Values.UpdateUserResponse.to_json)
           (Some Values.UpdateUserResponse.error_to_json)])
let main =
  Command.group
    ~summary:((Awso.Service.to_string Values.service) ^ " commands")
    [("batch-update-cluster", batch_update_cluster);
    ("copy-snapshot", copy_snapshot);
    ("create-a-c-l", create_a_c_l);
    ("create-cluster", create_cluster);
    ("create-multi-region-cluster", create_multi_region_cluster);
    ("create-parameter-group", create_parameter_group);
    ("create-snapshot", create_snapshot);
    ("create-subnet-group", create_subnet_group);
    ("create-user", create_user);
    ("delete-a-c-l", delete_a_c_l);
    ("delete-cluster", delete_cluster);
    ("delete-multi-region-cluster", delete_multi_region_cluster);
    ("delete-parameter-group", delete_parameter_group);
    ("delete-snapshot", delete_snapshot);
    ("delete-subnet-group", delete_subnet_group);
    ("delete-user", delete_user);
    ("describe-a-c-ls", describe_a_c_ls);
    ("describe-clusters", describe_clusters);
    ("describe-engine-versions", describe_engine_versions);
    ("describe-events", describe_events);
    ("describe-multi-region-clusters", describe_multi_region_clusters);
    ("describe-multi-region-parameter-groups",
      describe_multi_region_parameter_groups);
    ("describe-multi-region-parameters", describe_multi_region_parameters);
    ("describe-parameter-groups", describe_parameter_groups);
    ("describe-parameters", describe_parameters);
    ("describe-reserved-nodes", describe_reserved_nodes);
    ("describe-reserved-nodes-offerings", describe_reserved_nodes_offerings);
    ("describe-service-updates", describe_service_updates);
    ("describe-snapshots", describe_snapshots);
    ("describe-subnet-groups", describe_subnet_groups);
    ("describe-users", describe_users);
    ("failover-shard", failover_shard);
    ("list-allowed-multi-region-cluster-updates",
      list_allowed_multi_region_cluster_updates);
    ("list-allowed-node-type-updates", list_allowed_node_type_updates);
    ("list-tags", list_tags);
    ("purchase-reserved-nodes-offering", purchase_reserved_nodes_offering);
    ("reset-parameter-group", reset_parameter_group);
    ("tag-resource", tag_resource);
    ("untag-resource", untag_resource);
    ("update-a-c-l", update_a_c_l);
    ("update-cluster", update_cluster);
    ("update-multi-region-cluster", update_multi_region_cluster);
    ("update-parameter-group", update_parameter_group);
    ("update-subnet-group", update_subnet_group);
    ("update-user", update_user)]