1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
open Awso_kafka
open Awso_lwt
module Io = Http.Io
let eval ?endpoint_url ?cfg endpoint input =
Io.bind (Io.resolve_cfg cfg)
(fun cfg ->
let meth = Endpoints.method_of_endpoint endpoint in
let uri = Endpoints.uri_of_endpoint endpoint input in
Io.map
(Io.call ?endpoint_url ~cfg ~service:Values.service meth
(Endpoints.to_request endpoint input) uri)
(fun resp_result -> Endpoints.of_response endpoint resp_result))
let batch_associate_scram_secret ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.BatchAssociateScramSecret input
let create_cluster ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.CreateCluster input
let create_cluster_v2 ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.CreateClusterV2 input
let create_configuration ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.CreateConfiguration input
let create_replicator ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.CreateReplicator input
let create_topic ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.CreateTopic input
let create_vpc_connection ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.CreateVpcConnection input
let delete_cluster ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.DeleteCluster input
let delete_cluster_policy ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.DeleteClusterPolicy input
let delete_configuration ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.DeleteConfiguration input
let delete_replicator ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.DeleteReplicator input
let delete_topic ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.DeleteTopic input
let delete_vpc_connection ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.DeleteVpcConnection input
let describe_cluster ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.DescribeCluster input
let describe_cluster_v2 ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.DescribeClusterV2 input
let describe_cluster_operation ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.DescribeClusterOperation input
let describe_cluster_operation_v2 ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.DescribeClusterOperationV2 input
let describe_configuration ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.DescribeConfiguration input
let describe_configuration_revision ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.DescribeConfigurationRevision input
let describe_replicator ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.DescribeReplicator input
let describe_topic ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.DescribeTopic input
let describe_topic_partitions ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.DescribeTopicPartitions input
let describe_vpc_connection ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.DescribeVpcConnection input
let batch_disassociate_scram_secret ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.BatchDisassociateScramSecret input
let get_bootstrap_brokers ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.GetBootstrapBrokers input
let get_compatible_kafka_versions ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.GetCompatibleKafkaVersions input
let get_cluster_policy ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.GetClusterPolicy input
let list_cluster_operations ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.ListClusterOperations input
let list_cluster_operations_v2 ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.ListClusterOperationsV2 input
let list_clusters ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.ListClusters input
let list_clusters_v2 ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.ListClustersV2 input
let list_configuration_revisions ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.ListConfigurationRevisions input
let list_configurations ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.ListConfigurations input
let list_kafka_versions ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.ListKafkaVersions input
let list_nodes ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.ListNodes input
let list_replicators ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.ListReplicators input
let list_scram_secrets ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.ListScramSecrets input
let list_tags_for_resource ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.ListTagsForResource input
let list_client_vpc_connections ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.ListClientVpcConnections input
let list_topics ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.ListTopics input
let list_vpc_connections ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.ListVpcConnections input
let reject_client_vpc_connection ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.RejectClientVpcConnection input
let put_cluster_policy ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.PutClusterPolicy input
let reboot_broker ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.RebootBroker input
let tag_resource ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.TagResource input
let untag_resource ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.UntagResource input
let update_broker_count ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.UpdateBrokerCount input
let update_broker_type ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.UpdateBrokerType input
let update_broker_storage ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.UpdateBrokerStorage input
let update_configuration ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.UpdateConfiguration input
let update_connectivity ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.UpdateConnectivity input
let update_cluster_configuration ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.UpdateClusterConfiguration input
let update_cluster_kafka_version ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.UpdateClusterKafkaVersion input
let update_monitoring ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.UpdateMonitoring input
let update_rebalancing ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.UpdateRebalancing input
let update_replication_info ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.UpdateReplicationInfo input
let update_security ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.UpdateSecurity input
let update_storage ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.UpdateStorage input
let update_topic ?endpoint_url ?cfg input =
eval ?endpoint_url ?cfg Endpoints.UpdateTopic input