|
34 | 34 | import org.elasticsearch.client.indexlifecycle.RetryLifecyclePolicyRequest;
|
35 | 35 | import org.elasticsearch.client.indexlifecycle.StartILMRequest;
|
36 | 36 | import org.elasticsearch.client.indexlifecycle.StopILMRequest;
|
| 37 | +import org.elasticsearch.client.snapshotlifecycle.DeleteSnapshotLifecyclePolicyRequest; |
| 38 | +import org.elasticsearch.client.snapshotlifecycle.ExecuteSnapshotLifecyclePolicyRequest; |
| 39 | +import org.elasticsearch.client.snapshotlifecycle.ExecuteSnapshotLifecyclePolicyResponse; |
| 40 | +import org.elasticsearch.client.snapshotlifecycle.GetSnapshotLifecyclePolicyRequest; |
| 41 | +import org.elasticsearch.client.snapshotlifecycle.GetSnapshotLifecyclePolicyResponse; |
| 42 | +import org.elasticsearch.client.snapshotlifecycle.PutSnapshotLifecyclePolicyRequest; |
37 | 43 |
|
38 | 44 | import java.io.IOException;
|
39 | 45 |
|
@@ -300,4 +306,144 @@ public void retryLifecyclePolicyAsync(RetryLifecyclePolicyRequest request, Reque
|
300 | 306 | restHighLevelClient.performRequestAsyncAndParseEntity(request, IndexLifecycleRequestConverters::retryLifecycle, options,
|
301 | 307 | AcknowledgedResponse::fromXContent, listener, emptySet());
|
302 | 308 | }
|
| 309 | + |
| 310 | + /** |
| 311 | + * Retrieve one or more snapshot lifecycle policy definitions. |
| 312 | + * See <pre> |
| 313 | + * https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/ |
| 314 | + * java-rest-high-ilm-slm-get-snapshot-lifecycle-policy.html |
| 315 | + * </pre> |
| 316 | + * for more. |
| 317 | + * @param request the request |
| 318 | + * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized |
| 319 | + * @return the response |
| 320 | + * @throws IOException in case there is a problem sending the request or parsing back the response |
| 321 | + */ |
| 322 | + public GetSnapshotLifecyclePolicyResponse getSnapshotLifecyclePolicy(GetSnapshotLifecyclePolicyRequest request, |
| 323 | + RequestOptions options) throws IOException { |
| 324 | + return restHighLevelClient.performRequestAndParseEntity(request, IndexLifecycleRequestConverters::getSnapshotLifecyclePolicy, |
| 325 | + options, GetSnapshotLifecyclePolicyResponse::fromXContent, emptySet()); |
| 326 | + } |
| 327 | + |
| 328 | + /** |
| 329 | + * Asynchronously retrieve one or more snapshot lifecycle policy definition. |
| 330 | + * See <pre> |
| 331 | + * https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/ |
| 332 | + * java-rest-high-ilm-slm-get-snapshot-lifecycle-policy.html |
| 333 | + * </pre> |
| 334 | + * for more. |
| 335 | + * @param request the request |
| 336 | + * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized |
| 337 | + * @param listener the listener to be notified upon request completion |
| 338 | + */ |
| 339 | + public void getSnapshotLifecyclePolicyAsync(GetSnapshotLifecyclePolicyRequest request, RequestOptions options, |
| 340 | + ActionListener<GetSnapshotLifecyclePolicyResponse> listener) { |
| 341 | + restHighLevelClient.performRequestAsyncAndParseEntity(request, IndexLifecycleRequestConverters::getSnapshotLifecyclePolicy, |
| 342 | + options, GetSnapshotLifecyclePolicyResponse::fromXContent, listener, emptySet()); |
| 343 | + } |
| 344 | + |
| 345 | + /** |
| 346 | + * Create or modify a snapshot lifecycle definition. |
| 347 | + * See <pre> |
| 348 | + * https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/ |
| 349 | + * java-rest-high-ilm-slm-put-snapshot-lifecycle-policy.html |
| 350 | + * </pre> |
| 351 | + * for more. |
| 352 | + * @param request the request |
| 353 | + * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized |
| 354 | + * @return the response |
| 355 | + * @throws IOException in case there is a problem sending the request or parsing back the response |
| 356 | + */ |
| 357 | + public AcknowledgedResponse putSnapshotLifecyclePolicy(PutSnapshotLifecyclePolicyRequest request, |
| 358 | + RequestOptions options) throws IOException { |
| 359 | + return restHighLevelClient.performRequestAndParseEntity(request, IndexLifecycleRequestConverters::putSnapshotLifecyclePolicy, |
| 360 | + options, AcknowledgedResponse::fromXContent, emptySet()); |
| 361 | + } |
| 362 | + |
| 363 | + /** |
| 364 | + * Asynchronously create or modify a snapshot lifecycle definition. |
| 365 | + * See <pre> |
| 366 | + * https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/ |
| 367 | + * java-rest-high-ilm-slm-put-snapshot-lifecycle-policy.html |
| 368 | + * </pre> |
| 369 | + * for more. |
| 370 | + * @param request the request |
| 371 | + * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized |
| 372 | + * @param listener the listener to be notified upon request completion |
| 373 | + */ |
| 374 | + public void putSnapshotLifecyclePolicyAsync(PutSnapshotLifecyclePolicyRequest request, RequestOptions options, |
| 375 | + ActionListener<AcknowledgedResponse> listener) { |
| 376 | + restHighLevelClient.performRequestAsyncAndParseEntity(request, IndexLifecycleRequestConverters::putSnapshotLifecyclePolicy, |
| 377 | + options, AcknowledgedResponse::fromXContent, listener, emptySet()); |
| 378 | + } |
| 379 | + |
| 380 | + /** |
| 381 | + * Delete a snapshot lifecycle definition |
| 382 | + * See <pre> |
| 383 | + * https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/ |
| 384 | + * java-rest-high-ilm-slm-delete-snapshot-lifecycle-policy.html |
| 385 | + * </pre> |
| 386 | + * for more. |
| 387 | + * @param request the request |
| 388 | + * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized |
| 389 | + * @return the response |
| 390 | + * @throws IOException in case there is a problem sending the request or parsing back the response |
| 391 | + */ |
| 392 | + public AcknowledgedResponse deleteSnapshotLifecyclePolicy(DeleteSnapshotLifecyclePolicyRequest request, |
| 393 | + RequestOptions options) throws IOException { |
| 394 | + return restHighLevelClient.performRequestAndParseEntity(request, IndexLifecycleRequestConverters::deleteSnapshotLifecyclePolicy, |
| 395 | + options, AcknowledgedResponse::fromXContent, emptySet()); |
| 396 | + } |
| 397 | + |
| 398 | + /** |
| 399 | + * Asynchronously delete a snapshot lifecycle definition |
| 400 | + * See <pre> |
| 401 | + * https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/ |
| 402 | + * java-rest-high-ilm-slm-delete-snapshot-lifecycle-policy.html |
| 403 | + * </pre> |
| 404 | + * for more. |
| 405 | + * @param request the request |
| 406 | + * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized |
| 407 | + * @param listener the listener to be notified upon request completion |
| 408 | + */ |
| 409 | + public void deleteSnapshotLifecyclePolicyAsync(DeleteSnapshotLifecyclePolicyRequest request, RequestOptions options, |
| 410 | + ActionListener<AcknowledgedResponse> listener) { |
| 411 | + restHighLevelClient.performRequestAsyncAndParseEntity(request, IndexLifecycleRequestConverters::deleteSnapshotLifecyclePolicy, |
| 412 | + options, AcknowledgedResponse::fromXContent, listener, emptySet()); |
| 413 | + } |
| 414 | + |
| 415 | + /** |
| 416 | + * Execute a snapshot lifecycle definition |
| 417 | + * See <pre> |
| 418 | + * https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/ |
| 419 | + * java-rest-high-ilm-slm-execute-snapshot-lifecycle-policy.html |
| 420 | + * </pre> |
| 421 | + * for more. |
| 422 | + * @param request the request |
| 423 | + * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized |
| 424 | + * @return the response |
| 425 | + * @throws IOException in case there is a problem sending the request or parsing back the response |
| 426 | + */ |
| 427 | + public ExecuteSnapshotLifecyclePolicyResponse executeSnapshotLifecyclePolicy(ExecuteSnapshotLifecyclePolicyRequest request, |
| 428 | + RequestOptions options) throws IOException { |
| 429 | + return restHighLevelClient.performRequestAndParseEntity(request, IndexLifecycleRequestConverters::executeSnapshotLifecyclePolicy, |
| 430 | + options, ExecuteSnapshotLifecyclePolicyResponse::fromXContent, emptySet()); |
| 431 | + } |
| 432 | + |
| 433 | + /** |
| 434 | + * Asynchronously execute a snapshot lifecycle definition |
| 435 | + * See <pre> |
| 436 | + * https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/ |
| 437 | + * java-rest-high-ilm-slm-execute-snapshot-lifecycle-policy.html |
| 438 | + * </pre> |
| 439 | + * for more. |
| 440 | + * @param request the request |
| 441 | + * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized |
| 442 | + * @param listener the listener to be notified upon request completion |
| 443 | + */ |
| 444 | + public void executeSnapshotLifecyclePolicyAsync(ExecuteSnapshotLifecyclePolicyRequest request, RequestOptions options, |
| 445 | + ActionListener<ExecuteSnapshotLifecyclePolicyResponse> listener) { |
| 446 | + restHighLevelClient.performRequestAsyncAndParseEntity(request, IndexLifecycleRequestConverters::executeSnapshotLifecyclePolicy, |
| 447 | + options, ExecuteSnapshotLifecyclePolicyResponse::fromXContent, listener, emptySet()); |
| 448 | + } |
303 | 449 | }
|
0 commit comments