Skip to content

Commit f7f03a8

Browse files
swallezswallez
committed
[codegen] Remove exceptions from async clients methods
Fixes #96
1 parent 0aecc5a commit f7f03a8

File tree

34 files changed

+852
-1541
lines changed

34 files changed

+852
-1541
lines changed

‎java-client/src/main/java/co/elastic/clients/elasticsearch/ElasticsearchAsyncClient.java

Lines changed: 89 additions & 149 deletions
Large diffs are not rendered by default.

‎java-client/src/main/java/co/elastic/clients/elasticsearch/async_search/ElasticsearchAsyncSearchAsyncClient.java

Lines changed: 8 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@
2424
package co.elastic.clients.elasticsearch.async_search;
2525

2626
import co.elastic.clients.ApiClient;
27-
import co.elastic.clients.elasticsearch._types.ElasticsearchException;
2827
import co.elastic.clients.elasticsearch._types.ErrorResponse;
2928
import co.elastic.clients.transport.ElasticsearchTransport;
3029
import co.elastic.clients.transport.Endpoint;
@@ -33,7 +32,6 @@
3332
import co.elastic.clients.transport.TransportOptions;
3433
import co.elastic.clients.transport.endpoints.EndpointWithResponseMapperAttr;
3534
import co.elastic.clients.util.ObjectBuilder;
36-
import java.io.IOException;
3735
import java.util.concurrent.CompletableFuture;
3836
import java.util.function.Function;
3937
import javax.annotation.Nullable;
@@ -70,8 +68,7 @@ public ElasticsearchAsyncSearchAsyncClient withTransportOptions(@Nullable Transp
7068
* on elastic.co</a>
7169
*/
7270

73-
public CompletableFuture<DeleteAsyncSearchResponse> delete(DeleteAsyncSearchRequest request)
74-
throws IOException, ElasticsearchException {
71+
public CompletableFuture<DeleteAsyncSearchResponse> delete(DeleteAsyncSearchRequest request) {
7572
@SuppressWarnings("unchecked")
7673
JsonEndpoint<DeleteAsyncSearchRequest, DeleteAsyncSearchResponse, ErrorResponse> endpoint = (JsonEndpoint<DeleteAsyncSearchRequest, DeleteAsyncSearchResponse, ErrorResponse>) DeleteAsyncSearchRequest._ENDPOINT;
7774

@@ -91,8 +88,7 @@ public CompletableFuture<DeleteAsyncSearchResponse> delete(DeleteAsyncSearchRequ
9188
*/
9289

9390
public final CompletableFuture<DeleteAsyncSearchResponse> delete(
94-
Function<DeleteAsyncSearchRequest.Builder, ObjectBuilder<DeleteAsyncSearchRequest>> fn)
95-
throws IOException, ElasticsearchException {
91+
Function<DeleteAsyncSearchRequest.Builder, ObjectBuilder<DeleteAsyncSearchRequest>> fn) {
9692
return delete(fn.apply(new DeleteAsyncSearchRequest.Builder()).build());
9793
}
9894

@@ -108,7 +104,7 @@ public final CompletableFuture<DeleteAsyncSearchResponse> delete(
108104
*/
109105

110106
public <TDocument> CompletableFuture<GetAsyncSearchResponse<TDocument>> get(GetAsyncSearchRequest request,
111-
Class<TDocument> tDocumentClass) throws IOException, ElasticsearchException {
107+
Class<TDocument> tDocumentClass) {
112108
@SuppressWarnings("unchecked")
113109
JsonEndpoint<GetAsyncSearchRequest, GetAsyncSearchResponse<TDocument>, ErrorResponse> endpoint = (JsonEndpoint<GetAsyncSearchRequest, GetAsyncSearchResponse<TDocument>, ErrorResponse>) GetAsyncSearchRequest._ENDPOINT;
114110
endpoint = new EndpointWithResponseMapperAttr<>(endpoint,
@@ -131,7 +127,7 @@ public <TDocument> CompletableFuture<GetAsyncSearchResponse<TDocument>> get(GetA
131127

132128
public final <TDocument> CompletableFuture<GetAsyncSearchResponse<TDocument>> get(
133129
Function<GetAsyncSearchRequest.Builder, ObjectBuilder<GetAsyncSearchRequest>> fn,
134-
Class<TDocument> tDocumentClass) throws IOException, ElasticsearchException {
130+
Class<TDocument> tDocumentClass) {
135131
return get(fn.apply(new GetAsyncSearchRequest.Builder()).build(), tDocumentClass);
136132
}
137133

@@ -147,7 +143,7 @@ public final <TDocument> CompletableFuture<GetAsyncSearchResponse<TDocument>> ge
147143
*/
148144

149145
public <TDocument> CompletableFuture<AsyncSearchStatusResponse<TDocument>> status(AsyncSearchStatusRequest request,
150-
Class<TDocument> tDocumentClass) throws IOException, ElasticsearchException {
146+
Class<TDocument> tDocumentClass) {
151147
@SuppressWarnings("unchecked")
152148
JsonEndpoint<AsyncSearchStatusRequest, AsyncSearchStatusResponse<TDocument>, ErrorResponse> endpoint = (JsonEndpoint<AsyncSearchStatusRequest, AsyncSearchStatusResponse<TDocument>, ErrorResponse>) AsyncSearchStatusRequest._ENDPOINT;
153149
endpoint = new EndpointWithResponseMapperAttr<>(endpoint,
@@ -170,7 +166,7 @@ public <TDocument> CompletableFuture<AsyncSearchStatusResponse<TDocument>> statu
170166

171167
public final <TDocument> CompletableFuture<AsyncSearchStatusResponse<TDocument>> status(
172168
Function<AsyncSearchStatusRequest.Builder, ObjectBuilder<AsyncSearchStatusRequest>> fn,
173-
Class<TDocument> tDocumentClass) throws IOException, ElasticsearchException {
169+
Class<TDocument> tDocumentClass) {
174170
return status(fn.apply(new AsyncSearchStatusRequest.Builder()).build(), tDocumentClass);
175171
}
176172

@@ -185,7 +181,7 @@ public final <TDocument> CompletableFuture<AsyncSearchStatusResponse<TDocument>>
185181
*/
186182

187183
public <TDocument> CompletableFuture<SubmitResponse<TDocument>> submit(SubmitRequest request,
188-
Class<TDocument> tDocumentClass) throws IOException, ElasticsearchException {
184+
Class<TDocument> tDocumentClass) {
189185
@SuppressWarnings("unchecked")
190186
JsonEndpoint<SubmitRequest, SubmitResponse<TDocument>, ErrorResponse> endpoint = (JsonEndpoint<SubmitRequest, SubmitResponse<TDocument>, ErrorResponse>) SubmitRequest._ENDPOINT;
191187
endpoint = new EndpointWithResponseMapperAttr<>(endpoint,
@@ -206,8 +202,7 @@ public <TDocument> CompletableFuture<SubmitResponse<TDocument>> submit(SubmitReq
206202
*/
207203

208204
public final <TDocument> CompletableFuture<SubmitResponse<TDocument>> submit(
209-
Function<SubmitRequest.Builder, ObjectBuilder<SubmitRequest>> fn, Class<TDocument> tDocumentClass)
210-
throws IOException, ElasticsearchException {
205+
Function<SubmitRequest.Builder, ObjectBuilder<SubmitRequest>> fn, Class<TDocument> tDocumentClass) {
211206
return submit(fn.apply(new SubmitRequest.Builder()).build(), tDocumentClass);
212207
}
213208

‎java-client/src/main/java/co/elastic/clients/elasticsearch/autoscaling/ElasticsearchAutoscalingAsyncClient.java

Lines changed: 7 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -24,15 +24,13 @@
2424
package co.elastic.clients.elasticsearch.autoscaling;
2525

2626
import co.elastic.clients.ApiClient;
27-
import co.elastic.clients.elasticsearch._types.ElasticsearchException;
2827
import co.elastic.clients.elasticsearch._types.ErrorResponse;
2928
import co.elastic.clients.transport.ElasticsearchTransport;
3029
import co.elastic.clients.transport.Endpoint;
3130
import co.elastic.clients.transport.JsonEndpoint;
3231
import co.elastic.clients.transport.Transport;
3332
import co.elastic.clients.transport.TransportOptions;
3433
import co.elastic.clients.util.ObjectBuilder;
35-
import java.io.IOException;
3634
import java.util.concurrent.CompletableFuture;
3735
import java.util.function.Function;
3836
import javax.annotation.Nullable;
@@ -70,7 +68,7 @@ public ElasticsearchAutoscalingAsyncClient withTransportOptions(@Nullable Transp
7068
*/
7169

7270
public CompletableFuture<DeleteAutoscalingPolicyResponse> deleteAutoscalingPolicy(
73-
DeleteAutoscalingPolicyRequest request) throws IOException, ElasticsearchException {
71+
DeleteAutoscalingPolicyRequest request) {
7472
@SuppressWarnings("unchecked")
7573
JsonEndpoint<DeleteAutoscalingPolicyRequest, DeleteAutoscalingPolicyResponse, ErrorResponse> endpoint = (JsonEndpoint<DeleteAutoscalingPolicyRequest, DeleteAutoscalingPolicyResponse, ErrorResponse>) DeleteAutoscalingPolicyRequest._ENDPOINT;
7674

@@ -90,8 +88,7 @@ public CompletableFuture<DeleteAutoscalingPolicyResponse> deleteAutoscalingPolic
9088
*/
9189

9290
public final CompletableFuture<DeleteAutoscalingPolicyResponse> deleteAutoscalingPolicy(
93-
Function<DeleteAutoscalingPolicyRequest.Builder, ObjectBuilder<DeleteAutoscalingPolicyRequest>> fn)
94-
throws IOException, ElasticsearchException {
91+
Function<DeleteAutoscalingPolicyRequest.Builder, ObjectBuilder<DeleteAutoscalingPolicyRequest>> fn) {
9592
return deleteAutoscalingPolicy(fn.apply(new DeleteAutoscalingPolicyRequest.Builder()).build());
9693
}
9794

@@ -106,8 +103,7 @@ public final CompletableFuture<DeleteAutoscalingPolicyResponse> deleteAutoscalin
106103
* "https://www.elastic.co/guide/en/elasticsearch/reference/current/autoscaling-get-autoscaling-capacity.html">Documentation
107104
* on elastic.co</a>
108105
*/
109-
public CompletableFuture<GetAutoscalingCapacityResponse> getAutoscalingCapacity()
110-
throws IOException, ElasticsearchException {
106+
public CompletableFuture<GetAutoscalingCapacityResponse> getAutoscalingCapacity() {
111107
return this.transport.performRequestAsync(GetAutoscalingCapacityRequest._INSTANCE,
112108
GetAutoscalingCapacityRequest._ENDPOINT, this.transportOptions);
113109
}
@@ -123,8 +119,7 @@ public CompletableFuture<GetAutoscalingCapacityResponse> getAutoscalingCapacity(
123119
* on elastic.co</a>
124120
*/
125121

126-
public CompletableFuture<GetAutoscalingPolicyResponse> getAutoscalingPolicy(GetAutoscalingPolicyRequest request)
127-
throws IOException, ElasticsearchException {
122+
public CompletableFuture<GetAutoscalingPolicyResponse> getAutoscalingPolicy(GetAutoscalingPolicyRequest request) {
128123
@SuppressWarnings("unchecked")
129124
JsonEndpoint<GetAutoscalingPolicyRequest, GetAutoscalingPolicyResponse, ErrorResponse> endpoint = (JsonEndpoint<GetAutoscalingPolicyRequest, GetAutoscalingPolicyResponse, ErrorResponse>) GetAutoscalingPolicyRequest._ENDPOINT;
130125

@@ -144,8 +139,7 @@ public CompletableFuture<GetAutoscalingPolicyResponse> getAutoscalingPolicy(GetA
144139
*/
145140

146141
public final CompletableFuture<GetAutoscalingPolicyResponse> getAutoscalingPolicy(
147-
Function<GetAutoscalingPolicyRequest.Builder, ObjectBuilder<GetAutoscalingPolicyRequest>> fn)
148-
throws IOException, ElasticsearchException {
142+
Function<GetAutoscalingPolicyRequest.Builder, ObjectBuilder<GetAutoscalingPolicyRequest>> fn) {
149143
return getAutoscalingPolicy(fn.apply(new GetAutoscalingPolicyRequest.Builder()).build());
150144
}
151145

@@ -160,8 +154,7 @@ public final CompletableFuture<GetAutoscalingPolicyResponse> getAutoscalingPolic
160154
* on elastic.co</a>
161155
*/
162156

163-
public CompletableFuture<PutAutoscalingPolicyResponse> putAutoscalingPolicy(PutAutoscalingPolicyRequest request)
164-
throws IOException, ElasticsearchException {
157+
public CompletableFuture<PutAutoscalingPolicyResponse> putAutoscalingPolicy(PutAutoscalingPolicyRequest request) {
165158
@SuppressWarnings("unchecked")
166159
JsonEndpoint<PutAutoscalingPolicyRequest, PutAutoscalingPolicyResponse, ErrorResponse> endpoint = (JsonEndpoint<PutAutoscalingPolicyRequest, PutAutoscalingPolicyResponse, ErrorResponse>) PutAutoscalingPolicyRequest._ENDPOINT;
167160

@@ -181,8 +174,7 @@ public CompletableFuture<PutAutoscalingPolicyResponse> putAutoscalingPolicy(PutA
181174
*/
182175

183176
public final CompletableFuture<PutAutoscalingPolicyResponse> putAutoscalingPolicy(
184-
Function<PutAutoscalingPolicyRequest.Builder, ObjectBuilder<PutAutoscalingPolicyRequest>> fn)
185-
throws IOException, ElasticsearchException {
177+
Function<PutAutoscalingPolicyRequest.Builder, ObjectBuilder<PutAutoscalingPolicyRequest>> fn) {
186178
return putAutoscalingPolicy(fn.apply(new PutAutoscalingPolicyRequest.Builder()).build());
187179
}
188180

0 commit comments

Comments
 (0)