diff --git a/CHANGELOG.md b/CHANGELOG.md
index 1ea19b9a516..e7883abcb96 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -3,6 +3,17 @@ All notable changes to this project will be documented in this file.
The format is based on [Keep a Changelog](http://keepachangelog.com/).
+## 1.21.0 - 2020-08-04
+### Added
+- Support for calling Oracle Cloud Infrastructure services in the uk-gov-cardiff-1 region
+- Support for creating and managing private endpoints in the Data Flow service
+- Support for changing instance shapes and restarting nodes in the Big Data service
+- Support for additional versions (for example CSQL) in the Big Data service
+- Support for creating stacks from compartments in the Resource Manager service
+
+### Breaking Changes
+- Renamed the property of `lifeCycleDetails` to `lifecycleDetails` from the model of `BlockchainPlatformSummary` and `BlockchainPlatformByHostname` in the Blockchain service
+
## 1.20.0 - 2020-07-28
### Added
- Support for calling Oracle Cloud Infrastructure services in the us-sanjose-1 region
diff --git a/bmc-addons/bmc-apache-connector-provider/pom.xml b/bmc-addons/bmc-apache-connector-provider/pom.xml
index 00a38a34b24..796c40ccb4e 100644
--- a/bmc-addons/bmc-apache-connector-provider/pom.xml
+++ b/bmc-addons/bmc-apache-connector-provider/pom.xml
@@ -4,7 +4,7 @@
com.oracle.oci.sdk
oci-java-sdk-addons
- 1.20.0
+ 1.21.0
../pom.xml
@@ -42,7 +42,7 @@
com.oracle.oci.sdk
oci-java-sdk-common
- 1.20.0
+ 1.21.0
com.oracle.oci.sdk
oci-java-sdk-audit
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-containerengine
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-core
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-database
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-dns
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-email
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-filestorage
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-identity
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-loadbalancer
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-objectstorage
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-addons-resteasy-client-configurator
- 1.20.0
+ 1.21.0
com.oracle.oci.sdk
oci-java-sdk-addons-sasl
- 1.20.0
+ 1.21.0
com.oracle.oci.sdk
oci-java-sdk-resourcesearch
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-addons-apache
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-keymanagement
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-announcementsservice
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-healthchecks
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-waas
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-streaming
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-resourcemanager
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-monitoring
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-ons
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-autoscaling
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-budget
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-workrequests
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-limits
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-functions
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-events
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-dts
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-oce
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-oda
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-analytics
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-integration
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-osmanagement
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-marketplace
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-apigateway
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-applicationmigration
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-datacatalog
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-dataflow
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-datascience
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-nosql
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-secrets
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-vault
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-bds
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-encryption
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-cims
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-datasafe
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-mysql
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-dataintegration
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-ocvp
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-usageapi
- 1.20.0
+ 1.21.0
false
com.oracle.oci.sdk
oci-java-sdk-blockchain
- 1.20.0
+ 1.21.0
false
diff --git a/bmc-budget/pom.xml b/bmc-budget/pom.xml
index 3c4c470f280..4062f5c6221 100644
--- a/bmc-budget/pom.xml
+++ b/bmc-budget/pom.xml
@@ -4,7 +4,7 @@
com.oracle.oci.sdk
oci-java-sdk
- 1.20.0
+ 1.21.0
../pom.xml
oci-java-sdk-budget
@@ -15,7 +15,7 @@
com.oracle.oci.sdk
oci-java-sdk-common
- 1.20.0
+ 1.21.0
\ No newline at end of file
diff --git a/bmc-cims/pom.xml b/bmc-cims/pom.xml
index f71660420d2..0324758e897 100644
--- a/bmc-cims/pom.xml
+++ b/bmc-cims/pom.xml
@@ -4,7 +4,7 @@
com.oracle.oci.sdk
oci-java-sdk
- 1.20.0
+ 1.21.0
../pom.xml
oci-java-sdk-cims
@@ -15,7 +15,7 @@
com.oracle.oci.sdk
oci-java-sdk-common
- 1.20.0
+ 1.21.0
\ No newline at end of file
diff --git a/bmc-circuitbreaker/pom.xml b/bmc-circuitbreaker/pom.xml
index a2798465f8c..e3f66a16d93 100644
--- a/bmc-circuitbreaker/pom.xml
+++ b/bmc-circuitbreaker/pom.xml
@@ -5,7 +5,7 @@
com.oracle.oci.sdk
oci-java-sdk
- 1.20.0
+ 1.21.0
../pom.xml
oci-java-sdk-circuitbreaker
diff --git a/bmc-common/pom.xml b/bmc-common/pom.xml
index ca20e00848c..c7f6b8b3a80 100644
--- a/bmc-common/pom.xml
+++ b/bmc-common/pom.xml
@@ -4,7 +4,7 @@
com.oracle.oci.sdk
oci-java-sdk
- 1.20.0
+ 1.21.0
../pom.xml
@@ -94,7 +94,7 @@
com.oracle.oci.sdk
oci-java-sdk-circuitbreaker
- 1.20.0
+ 1.21.0
diff --git a/bmc-common/src/main/java/com/oracle/bmc/Region.java b/bmc-common/src/main/java/com/oracle/bmc/Region.java
index 7fa9ea778b1..12298303af5 100644
--- a/bmc-common/src/main/java/com/oracle/bmc/Region.java
+++ b/bmc-common/src/main/java/com/oracle/bmc/Region.java
@@ -108,6 +108,7 @@ public final class Region implements Serializable, Comparable {
// OC4
public static final Region UK_GOV_LONDON_1 = register("uk-gov-london-1", Realm.OC4, "ltn");
+ public static final Region UK_GOV_CARDIFF_1 = register("uk-gov-cardiff-1", Realm.OC4, "brs");
private static final Map> SERVICE_TO_REGION_ENDPOINTS =
new HashMap<>();
diff --git a/bmc-containerengine/pom.xml b/bmc-containerengine/pom.xml
index 9cc20104628..d9c58e23a48 100644
--- a/bmc-containerengine/pom.xml
+++ b/bmc-containerengine/pom.xml
@@ -5,7 +5,7 @@
com.oracle.oci.sdk
oci-java-sdk
- 1.20.0
+ 1.21.0
../pom.xml
@@ -19,7 +19,7 @@
com.oracle.oci.sdk
oci-java-sdk-common
- 1.20.0
+ 1.21.0
diff --git a/bmc-core/pom.xml b/bmc-core/pom.xml
index 40107e10413..5ff95133cf9 100644
--- a/bmc-core/pom.xml
+++ b/bmc-core/pom.xml
@@ -5,7 +5,7 @@
com.oracle.oci.sdk
oci-java-sdk
- 1.20.0
+ 1.21.0
../pom.xml
@@ -19,12 +19,12 @@
com.oracle.oci.sdk
oci-java-sdk-common
- 1.20.0
+ 1.21.0
com.oracle.oci.sdk
oci-java-sdk-workrequests
- 1.20.0
+ 1.21.0
diff --git a/bmc-database/pom.xml b/bmc-database/pom.xml
index 69854606374..a34fea68065 100644
--- a/bmc-database/pom.xml
+++ b/bmc-database/pom.xml
@@ -5,7 +5,7 @@
com.oracle.oci.sdk
oci-java-sdk
- 1.20.0
+ 1.21.0
../pom.xml
@@ -19,12 +19,12 @@
com.oracle.oci.sdk
oci-java-sdk-common
- 1.20.0
+ 1.21.0
com.oracle.oci.sdk
oci-java-sdk-workrequests
- 1.20.0
+ 1.21.0
diff --git a/bmc-datacatalog/pom.xml b/bmc-datacatalog/pom.xml
index 4007449e635..3fad18211eb 100644
--- a/bmc-datacatalog/pom.xml
+++ b/bmc-datacatalog/pom.xml
@@ -4,7 +4,7 @@
com.oracle.oci.sdk
oci-java-sdk
- 1.20.0
+ 1.21.0
../pom.xml
oci-java-sdk-datacatalog
@@ -15,7 +15,7 @@
com.oracle.oci.sdk
oci-java-sdk-common
- 1.20.0
+ 1.21.0
\ No newline at end of file
diff --git a/bmc-dataflow/pom.xml b/bmc-dataflow/pom.xml
index 6107e1a35ef..523c7cdd2af 100644
--- a/bmc-dataflow/pom.xml
+++ b/bmc-dataflow/pom.xml
@@ -4,7 +4,7 @@
com.oracle.oci.sdk
oci-java-sdk
- 1.20.0
+ 1.21.0
../pom.xml
oci-java-sdk-dataflow
@@ -15,7 +15,7 @@
com.oracle.oci.sdk
oci-java-sdk-common
- 1.20.0
+ 1.21.0
\ No newline at end of file
diff --git a/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlow.java b/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlow.java
index b28a3f06a7b..5d930e142f4 100644
--- a/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlow.java
+++ b/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlow.java
@@ -52,6 +52,16 @@ public interface DataFlow extends AutoCloseable {
ChangeApplicationCompartmentResponse changeApplicationCompartment(
ChangeApplicationCompartmentRequest request);
+ /**
+ * Moves a private endpoint into a different compartment. When provided, If-Match is checked against ETag values of the resource.
+ *
+ * @param request The request object containing the details to send
+ * @return A response object containing details about the completed operation
+ * @throws BmcException when an error occurs.
+ */
+ ChangePrivateEndpointCompartmentResponse changePrivateEndpointCompartment(
+ ChangePrivateEndpointCompartmentRequest request);
+
/**
* Moves a run into a different compartment. When provided, If-Match is checked against ETag
* values of the resource. Associated resources, like historical metrics, will not be
@@ -73,6 +83,15 @@ ChangeApplicationCompartmentResponse changeApplicationCompartment(
*/
CreateApplicationResponse createApplication(CreateApplicationRequest request);
+ /**
+ * Creates a private endpoint to be used by an application.
+ *
+ * @param request The request object containing the details to send
+ * @return A response object containing details about the completed operation
+ * @throws BmcException when an error occurs.
+ */
+ CreatePrivateEndpointResponse createPrivateEndpoint(CreatePrivateEndpointRequest request);
+
/**
* Creates a run for an application.
*
@@ -91,6 +110,15 @@ ChangeApplicationCompartmentResponse changeApplicationCompartment(
*/
DeleteApplicationResponse deleteApplication(DeleteApplicationRequest request);
+ /**
+ * Deletes a private endpoint using a `privateEndpointId`.
+ *
+ * @param request The request object containing the details to send
+ * @return A response object containing details about the completed operation
+ * @throws BmcException when an error occurs.
+ */
+ DeletePrivateEndpointResponse deletePrivateEndpoint(DeletePrivateEndpointRequest request);
+
/**
* Cancels the specified run if it has not already completed or was previously cancelled.
* If a run is in progress, the executing job will be killed.
@@ -110,6 +138,15 @@ ChangeApplicationCompartmentResponse changeApplicationCompartment(
*/
GetApplicationResponse getApplication(GetApplicationRequest request);
+ /**
+ * Retrieves an private endpoint using a `privateEndpointId`.
+ *
+ * @param request The request object containing the details to send
+ * @return A response object containing details about the completed operation
+ * @throws BmcException when an error occurs.
+ */
+ GetPrivateEndpointResponse getPrivateEndpoint(GetPrivateEndpointRequest request);
+
/**
* Retrieves the run for the specified `runId`.
*
@@ -128,6 +165,15 @@ ChangeApplicationCompartmentResponse changeApplicationCompartment(
*/
GetRunLogResponse getRunLog(GetRunLogRequest request);
+ /**
+ * Gets the status of the work request with the given OCID.
+ *
+ * @param request The request object containing the details to send
+ * @return A response object containing details about the completed operation
+ * @throws BmcException when an error occurs.
+ */
+ GetWorkRequestResponse getWorkRequest(GetWorkRequestRequest request);
+
/**
* Lists all applications in the specified compartment.
*
@@ -137,6 +183,15 @@ ChangeApplicationCompartmentResponse changeApplicationCompartment(
*/
ListApplicationsResponse listApplications(ListApplicationsRequest request);
+ /**
+ * Lists all private endpoints in the specified compartment.
+ *
+ * @param request The request object containing the details to send
+ * @return A response object containing details about the completed operation
+ * @throws BmcException when an error occurs.
+ */
+ ListPrivateEndpointsResponse listPrivateEndpoints(ListPrivateEndpointsRequest request);
+
/**
* Retrieves summaries of the run's logs.
*
@@ -155,6 +210,33 @@ ChangeApplicationCompartmentResponse changeApplicationCompartment(
*/
ListRunsResponse listRuns(ListRunsRequest request);
+ /**
+ * Return a (paginated) list of errors for a given work request.
+ *
+ * @param request The request object containing the details to send
+ * @return A response object containing details about the completed operation
+ * @throws BmcException when an error occurs.
+ */
+ ListWorkRequestErrorsResponse listWorkRequestErrors(ListWorkRequestErrorsRequest request);
+
+ /**
+ * Return a paginated list of logs for a given work request.
+ *
+ * @param request The request object containing the details to send
+ * @return A response object containing details about the completed operation
+ * @throws BmcException when an error occurs.
+ */
+ ListWorkRequestLogsResponse listWorkRequestLogs(ListWorkRequestLogsRequest request);
+
+ /**
+ * Lists the work requests in a compartment.
+ *
+ * @param request The request object containing the details to send
+ * @return A response object containing details about the completed operation
+ * @throws BmcException when an error occurs.
+ */
+ ListWorkRequestsResponse listWorkRequests(ListWorkRequestsRequest request);
+
/**
* Updates an application using an `applicationId`.
*
@@ -164,6 +246,17 @@ ChangeApplicationCompartmentResponse changeApplicationCompartment(
*/
UpdateApplicationResponse updateApplication(UpdateApplicationRequest request);
+ /**
+ * Updates a private endpoint using a `privateEndpointId`. If changes to a private endpoint match
+ * a previously defined private endpoint, then a 409 status code will be returned. This indicates
+ * that a conflict has been detected.
+ *
+ * @param request The request object containing the details to send
+ * @return A response object containing details about the completed operation
+ * @throws BmcException when an error occurs.
+ */
+ UpdatePrivateEndpointResponse updatePrivateEndpoint(UpdatePrivateEndpointRequest request);
+
/**
* Updates a run using a `runId`.
*
diff --git a/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlowAsync.java b/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlowAsync.java
index e2967d12557..b6939dc031c 100644
--- a/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlowAsync.java
+++ b/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlowAsync.java
@@ -60,6 +60,25 @@ java.util.concurrent.Future changeApplicat
ChangeApplicationCompartmentResponse>
handler);
+ /**
+ * Moves a private endpoint into a different compartment. When provided, If-Match is checked against ETag values of the resource.
+ *
+ *
+ * @param request The request object containing the details to send
+ * @param handler The request handler to invoke upon completion, may be null.
+ * @return A Future that can be used to get the response if no AsyncHandler was
+ * provided. Note, if you provide an AsyncHandler and use the Future, some
+ * types of responses (like java.io.InputStream) may not be able to be read in
+ * both places as the underlying stream may only be consumed once.
+ */
+ java.util.concurrent.Future
+ changePrivateEndpointCompartment(
+ ChangePrivateEndpointCompartmentRequest request,
+ com.oracle.bmc.responses.AsyncHandler<
+ ChangePrivateEndpointCompartmentRequest,
+ ChangePrivateEndpointCompartmentResponse>
+ handler);
+
/**
* Moves a run into a different compartment. When provided, If-Match is checked against ETag
* values of the resource. Associated resources, like historical metrics, will not be
@@ -97,6 +116,23 @@ java.util.concurrent.Future createApplication(
CreateApplicationRequest, CreateApplicationResponse>
handler);
+ /**
+ * Creates a private endpoint to be used by an application.
+ *
+ *
+ * @param request The request object containing the details to send
+ * @param handler The request handler to invoke upon completion, may be null.
+ * @return A Future that can be used to get the response if no AsyncHandler was
+ * provided. Note, if you provide an AsyncHandler and use the Future, some
+ * types of responses (like java.io.InputStream) may not be able to be read in
+ * both places as the underlying stream may only be consumed once.
+ */
+ java.util.concurrent.Future createPrivateEndpoint(
+ CreatePrivateEndpointRequest request,
+ com.oracle.bmc.responses.AsyncHandler<
+ CreatePrivateEndpointRequest, CreatePrivateEndpointResponse>
+ handler);
+
/**
* Creates a run for an application.
*
@@ -129,6 +165,23 @@ java.util.concurrent.Future deleteApplication(
DeleteApplicationRequest, DeleteApplicationResponse>
handler);
+ /**
+ * Deletes a private endpoint using a `privateEndpointId`.
+ *
+ *
+ * @param request The request object containing the details to send
+ * @param handler The request handler to invoke upon completion, may be null.
+ * @return A Future that can be used to get the response if no AsyncHandler was
+ * provided. Note, if you provide an AsyncHandler and use the Future, some
+ * types of responses (like java.io.InputStream) may not be able to be read in
+ * both places as the underlying stream may only be consumed once.
+ */
+ java.util.concurrent.Future deletePrivateEndpoint(
+ DeletePrivateEndpointRequest request,
+ com.oracle.bmc.responses.AsyncHandler<
+ DeletePrivateEndpointRequest, DeletePrivateEndpointResponse>
+ handler);
+
/**
* Cancels the specified run if it has not already completed or was previously cancelled.
* If a run is in progress, the executing job will be killed.
@@ -161,6 +214,23 @@ java.util.concurrent.Future getApplication(
com.oracle.bmc.responses.AsyncHandler
handler);
+ /**
+ * Retrieves an private endpoint using a `privateEndpointId`.
+ *
+ *
+ * @param request The request object containing the details to send
+ * @param handler The request handler to invoke upon completion, may be null.
+ * @return A Future that can be used to get the response if no AsyncHandler was
+ * provided. Note, if you provide an AsyncHandler and use the Future, some
+ * types of responses (like java.io.InputStream) may not be able to be read in
+ * both places as the underlying stream may only be consumed once.
+ */
+ java.util.concurrent.Future getPrivateEndpoint(
+ GetPrivateEndpointRequest request,
+ com.oracle.bmc.responses.AsyncHandler<
+ GetPrivateEndpointRequest, GetPrivateEndpointResponse>
+ handler);
+
/**
* Retrieves the run for the specified `runId`.
*
@@ -191,6 +261,22 @@ java.util.concurrent.Future getRunLog(
GetRunLogRequest request,
com.oracle.bmc.responses.AsyncHandler handler);
+ /**
+ * Gets the status of the work request with the given OCID.
+ *
+ *
+ * @param request The request object containing the details to send
+ * @param handler The request handler to invoke upon completion, may be null.
+ * @return A Future that can be used to get the response if no AsyncHandler was
+ * provided. Note, if you provide an AsyncHandler and use the Future, some
+ * types of responses (like java.io.InputStream) may not be able to be read in
+ * both places as the underlying stream may only be consumed once.
+ */
+ java.util.concurrent.Future getWorkRequest(
+ GetWorkRequestRequest request,
+ com.oracle.bmc.responses.AsyncHandler
+ handler);
+
/**
* Lists all applications in the specified compartment.
*
@@ -207,6 +293,23 @@ java.util.concurrent.Future listApplications(
com.oracle.bmc.responses.AsyncHandler
handler);
+ /**
+ * Lists all private endpoints in the specified compartment.
+ *
+ *
+ * @param request The request object containing the details to send
+ * @param handler The request handler to invoke upon completion, may be null.
+ * @return A Future that can be used to get the response if no AsyncHandler was
+ * provided. Note, if you provide an AsyncHandler and use the Future, some
+ * types of responses (like java.io.InputStream) may not be able to be read in
+ * both places as the underlying stream may only be consumed once.
+ */
+ java.util.concurrent.Future listPrivateEndpoints(
+ ListPrivateEndpointsRequest request,
+ com.oracle.bmc.responses.AsyncHandler<
+ ListPrivateEndpointsRequest, ListPrivateEndpointsResponse>
+ handler);
+
/**
* Retrieves summaries of the run's logs.
*
@@ -237,6 +340,56 @@ java.util.concurrent.Future listRuns(
ListRunsRequest request,
com.oracle.bmc.responses.AsyncHandler handler);
+ /**
+ * Return a (paginated) list of errors for a given work request.
+ *
+ *
+ * @param request The request object containing the details to send
+ * @param handler The request handler to invoke upon completion, may be null.
+ * @return A Future that can be used to get the response if no AsyncHandler was
+ * provided. Note, if you provide an AsyncHandler and use the Future, some
+ * types of responses (like java.io.InputStream) may not be able to be read in
+ * both places as the underlying stream may only be consumed once.
+ */
+ java.util.concurrent.Future listWorkRequestErrors(
+ ListWorkRequestErrorsRequest request,
+ com.oracle.bmc.responses.AsyncHandler<
+ ListWorkRequestErrorsRequest, ListWorkRequestErrorsResponse>
+ handler);
+
+ /**
+ * Return a paginated list of logs for a given work request.
+ *
+ *
+ * @param request The request object containing the details to send
+ * @param handler The request handler to invoke upon completion, may be null.
+ * @return A Future that can be used to get the response if no AsyncHandler was
+ * provided. Note, if you provide an AsyncHandler and use the Future, some
+ * types of responses (like java.io.InputStream) may not be able to be read in
+ * both places as the underlying stream may only be consumed once.
+ */
+ java.util.concurrent.Future listWorkRequestLogs(
+ ListWorkRequestLogsRequest request,
+ com.oracle.bmc.responses.AsyncHandler<
+ ListWorkRequestLogsRequest, ListWorkRequestLogsResponse>
+ handler);
+
+ /**
+ * Lists the work requests in a compartment.
+ *
+ *
+ * @param request The request object containing the details to send
+ * @param handler The request handler to invoke upon completion, may be null.
+ * @return A Future that can be used to get the response if no AsyncHandler was
+ * provided. Note, if you provide an AsyncHandler and use the Future, some
+ * types of responses (like java.io.InputStream) may not be able to be read in
+ * both places as the underlying stream may only be consumed once.
+ */
+ java.util.concurrent.Future listWorkRequests(
+ ListWorkRequestsRequest request,
+ com.oracle.bmc.responses.AsyncHandler
+ handler);
+
/**
* Updates an application using an `applicationId`.
*
@@ -254,6 +407,25 @@ java.util.concurrent.Future updateApplication(
UpdateApplicationRequest, UpdateApplicationResponse>
handler);
+ /**
+ * Updates a private endpoint using a `privateEndpointId`. If changes to a private endpoint match
+ * a previously defined private endpoint, then a 409 status code will be returned. This indicates
+ * that a conflict has been detected.
+ *
+ *
+ * @param request The request object containing the details to send
+ * @param handler The request handler to invoke upon completion, may be null.
+ * @return A Future that can be used to get the response if no AsyncHandler was
+ * provided. Note, if you provide an AsyncHandler and use the Future, some
+ * types of responses (like java.io.InputStream) may not be able to be read in
+ * both places as the underlying stream may only be consumed once.
+ */
+ java.util.concurrent.Future updatePrivateEndpoint(
+ UpdatePrivateEndpointRequest request,
+ com.oracle.bmc.responses.AsyncHandler<
+ UpdatePrivateEndpointRequest, UpdatePrivateEndpointResponse>
+ handler);
+
/**
* Updates a run using a `runId`.
*
diff --git a/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlowAsyncClient.java b/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlowAsyncClient.java
index c3c7e1a4c31..df93d680d92 100644
--- a/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlowAsyncClient.java
+++ b/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlowAsyncClient.java
@@ -397,6 +397,101 @@ public java.util.concurrent.Future get() {
}
}
+ @Override
+ public java.util.concurrent.Future
+ changePrivateEndpointCompartment(
+ final ChangePrivateEndpointCompartmentRequest request,
+ final com.oracle.bmc.responses.AsyncHandler<
+ ChangePrivateEndpointCompartmentRequest,
+ ChangePrivateEndpointCompartmentResponse>
+ handler) {
+ LOG.trace("Called async changePrivateEndpointCompartment");
+ final ChangePrivateEndpointCompartmentRequest interceptedRequest =
+ ChangePrivateEndpointCompartmentConverter.interceptRequest(request);
+ final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ ChangePrivateEndpointCompartmentConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function<
+ javax.ws.rs.core.Response, ChangePrivateEndpointCompartmentResponse>
+ transformer = ChangePrivateEndpointCompartmentConverter.fromResponse();
+
+ com.oracle.bmc.responses.AsyncHandler<
+ ChangePrivateEndpointCompartmentRequest,
+ ChangePrivateEndpointCompartmentResponse>
+ handlerToUse = handler;
+ if (handler != null
+ && this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ handlerToUse =
+ new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
+ ChangePrivateEndpointCompartmentRequest,
+ ChangePrivateEndpointCompartmentResponse>(
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ handler) {
+ @Override
+ public void retryCall() {
+ final com.oracle.bmc.util.internal.Consumer
+ onSuccess =
+ new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ this, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ this, interceptedRequest);
+ client.post(
+ ib,
+ interceptedRequest.getChangePrivateEndpointCompartmentDetails(),
+ interceptedRequest,
+ onSuccess,
+ onError);
+ }
+ };
+ }
+
+ final com.oracle.bmc.util.internal.Consumer onSuccess =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ handlerToUse, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ handlerToUse, interceptedRequest);
+
+ java.util.concurrent.Future responseFuture =
+ client.post(
+ ib,
+ interceptedRequest.getChangePrivateEndpointCompartmentDetails(),
+ interceptedRequest,
+ onSuccess,
+ onError);
+
+ if (this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
+ javax.ws.rs.core.Response, ChangePrivateEndpointCompartmentResponse>(
+ responseFuture,
+ transformer,
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ new com.google.common.base.Supplier<
+ java.util.concurrent.Future>() {
+ @Override
+ public java.util.concurrent.Future get() {
+ return client.post(
+ ib,
+ interceptedRequest.getChangePrivateEndpointCompartmentDetails(),
+ interceptedRequest,
+ onSuccess,
+ onError);
+ }
+ });
+ } else {
+ return new com.oracle.bmc.util.internal.TransformingFuture<>(
+ responseFuture, transformer);
+ }
+ }
+
@Override
public java.util.concurrent.Future changeRunCompartment(
final ChangeRunCompartmentRequest request,
@@ -554,7 +649,702 @@ public void retryCall() {
if (this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
- javax.ws.rs.core.Response, CreateApplicationResponse>(
+ javax.ws.rs.core.Response, CreateApplicationResponse>(
+ responseFuture,
+ transformer,
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ new com.google.common.base.Supplier<
+ java.util.concurrent.Future>() {
+ @Override
+ public java.util.concurrent.Future get() {
+ return client.post(
+ ib,
+ interceptedRequest.getCreateApplicationDetails(),
+ interceptedRequest,
+ onSuccess,
+ onError);
+ }
+ });
+ } else {
+ return new com.oracle.bmc.util.internal.TransformingFuture<>(
+ responseFuture, transformer);
+ }
+ }
+
+ @Override
+ public java.util.concurrent.Future createPrivateEndpoint(
+ final CreatePrivateEndpointRequest request,
+ final com.oracle.bmc.responses.AsyncHandler<
+ CreatePrivateEndpointRequest, CreatePrivateEndpointResponse>
+ handler) {
+ LOG.trace("Called async createPrivateEndpoint");
+ final CreatePrivateEndpointRequest interceptedRequest =
+ CreatePrivateEndpointConverter.interceptRequest(request);
+ final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ CreatePrivateEndpointConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function<
+ javax.ws.rs.core.Response, CreatePrivateEndpointResponse>
+ transformer = CreatePrivateEndpointConverter.fromResponse();
+
+ com.oracle.bmc.responses.AsyncHandler<
+ CreatePrivateEndpointRequest, CreatePrivateEndpointResponse>
+ handlerToUse = handler;
+ if (handler != null
+ && this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ handlerToUse =
+ new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
+ CreatePrivateEndpointRequest, CreatePrivateEndpointResponse>(
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ handler) {
+ @Override
+ public void retryCall() {
+ final com.oracle.bmc.util.internal.Consumer
+ onSuccess =
+ new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ this, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ this, interceptedRequest);
+ client.post(
+ ib,
+ interceptedRequest.getCreatePrivateEndpointDetails(),
+ interceptedRequest,
+ onSuccess,
+ onError);
+ }
+ };
+ }
+
+ final com.oracle.bmc.util.internal.Consumer onSuccess =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ handlerToUse, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ handlerToUse, interceptedRequest);
+
+ java.util.concurrent.Future responseFuture =
+ client.post(
+ ib,
+ interceptedRequest.getCreatePrivateEndpointDetails(),
+ interceptedRequest,
+ onSuccess,
+ onError);
+
+ if (this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
+ javax.ws.rs.core.Response, CreatePrivateEndpointResponse>(
+ responseFuture,
+ transformer,
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ new com.google.common.base.Supplier<
+ java.util.concurrent.Future>() {
+ @Override
+ public java.util.concurrent.Future get() {
+ return client.post(
+ ib,
+ interceptedRequest.getCreatePrivateEndpointDetails(),
+ interceptedRequest,
+ onSuccess,
+ onError);
+ }
+ });
+ } else {
+ return new com.oracle.bmc.util.internal.TransformingFuture<>(
+ responseFuture, transformer);
+ }
+ }
+
+ @Override
+ public java.util.concurrent.Future createRun(
+ final CreateRunRequest request,
+ final com.oracle.bmc.responses.AsyncHandler
+ handler) {
+ LOG.trace("Called async createRun");
+ final CreateRunRequest interceptedRequest = CreateRunConverter.interceptRequest(request);
+ final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ CreateRunConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function
+ transformer = CreateRunConverter.fromResponse();
+
+ com.oracle.bmc.responses.AsyncHandler handlerToUse =
+ handler;
+ if (handler != null
+ && this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ handlerToUse =
+ new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
+ CreateRunRequest, CreateRunResponse>(
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ handler) {
+ @Override
+ public void retryCall() {
+ final com.oracle.bmc.util.internal.Consumer
+ onSuccess =
+ new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ this, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ this, interceptedRequest);
+ client.post(
+ ib,
+ interceptedRequest.getCreateRunDetails(),
+ interceptedRequest,
+ onSuccess,
+ onError);
+ }
+ };
+ }
+
+ final com.oracle.bmc.util.internal.Consumer onSuccess =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ handlerToUse, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ handlerToUse, interceptedRequest);
+
+ java.util.concurrent.Future responseFuture =
+ client.post(
+ ib,
+ interceptedRequest.getCreateRunDetails(),
+ interceptedRequest,
+ onSuccess,
+ onError);
+
+ if (this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
+ javax.ws.rs.core.Response, CreateRunResponse>(
+ responseFuture,
+ transformer,
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ new com.google.common.base.Supplier<
+ java.util.concurrent.Future>() {
+ @Override
+ public java.util.concurrent.Future get() {
+ return client.post(
+ ib,
+ interceptedRequest.getCreateRunDetails(),
+ interceptedRequest,
+ onSuccess,
+ onError);
+ }
+ });
+ } else {
+ return new com.oracle.bmc.util.internal.TransformingFuture<>(
+ responseFuture, transformer);
+ }
+ }
+
+ @Override
+ public java.util.concurrent.Future deleteApplication(
+ final DeleteApplicationRequest request,
+ final com.oracle.bmc.responses.AsyncHandler<
+ DeleteApplicationRequest, DeleteApplicationResponse>
+ handler) {
+ LOG.trace("Called async deleteApplication");
+ final DeleteApplicationRequest interceptedRequest =
+ DeleteApplicationConverter.interceptRequest(request);
+ final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ DeleteApplicationConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function
+ transformer = DeleteApplicationConverter.fromResponse();
+
+ com.oracle.bmc.responses.AsyncHandler
+ handlerToUse = handler;
+ if (handler != null
+ && this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ handlerToUse =
+ new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
+ DeleteApplicationRequest, DeleteApplicationResponse>(
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ handler) {
+ @Override
+ public void retryCall() {
+ final com.oracle.bmc.util.internal.Consumer
+ onSuccess =
+ new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ this, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ this, interceptedRequest);
+ client.delete(ib, interceptedRequest, onSuccess, onError);
+ }
+ };
+ }
+
+ final com.oracle.bmc.util.internal.Consumer onSuccess =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ handlerToUse, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ handlerToUse, interceptedRequest);
+
+ java.util.concurrent.Future responseFuture =
+ client.delete(ib, interceptedRequest, onSuccess, onError);
+
+ if (this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
+ javax.ws.rs.core.Response, DeleteApplicationResponse>(
+ responseFuture,
+ transformer,
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ new com.google.common.base.Supplier<
+ java.util.concurrent.Future>() {
+ @Override
+ public java.util.concurrent.Future get() {
+ return client.delete(ib, interceptedRequest, onSuccess, onError);
+ }
+ });
+ } else {
+ return new com.oracle.bmc.util.internal.TransformingFuture<>(
+ responseFuture, transformer);
+ }
+ }
+
+ @Override
+ public java.util.concurrent.Future deletePrivateEndpoint(
+ final DeletePrivateEndpointRequest request,
+ final com.oracle.bmc.responses.AsyncHandler<
+ DeletePrivateEndpointRequest, DeletePrivateEndpointResponse>
+ handler) {
+ LOG.trace("Called async deletePrivateEndpoint");
+ final DeletePrivateEndpointRequest interceptedRequest =
+ DeletePrivateEndpointConverter.interceptRequest(request);
+ final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ DeletePrivateEndpointConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function<
+ javax.ws.rs.core.Response, DeletePrivateEndpointResponse>
+ transformer = DeletePrivateEndpointConverter.fromResponse();
+
+ com.oracle.bmc.responses.AsyncHandler<
+ DeletePrivateEndpointRequest, DeletePrivateEndpointResponse>
+ handlerToUse = handler;
+ if (handler != null
+ && this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ handlerToUse =
+ new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
+ DeletePrivateEndpointRequest, DeletePrivateEndpointResponse>(
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ handler) {
+ @Override
+ public void retryCall() {
+ final com.oracle.bmc.util.internal.Consumer
+ onSuccess =
+ new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ this, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ this, interceptedRequest);
+ client.delete(ib, interceptedRequest, onSuccess, onError);
+ }
+ };
+ }
+
+ final com.oracle.bmc.util.internal.Consumer onSuccess =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ handlerToUse, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ handlerToUse, interceptedRequest);
+
+ java.util.concurrent.Future responseFuture =
+ client.delete(ib, interceptedRequest, onSuccess, onError);
+
+ if (this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
+ javax.ws.rs.core.Response, DeletePrivateEndpointResponse>(
+ responseFuture,
+ transformer,
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ new com.google.common.base.Supplier<
+ java.util.concurrent.Future>() {
+ @Override
+ public java.util.concurrent.Future get() {
+ return client.delete(ib, interceptedRequest, onSuccess, onError);
+ }
+ });
+ } else {
+ return new com.oracle.bmc.util.internal.TransformingFuture<>(
+ responseFuture, transformer);
+ }
+ }
+
+ @Override
+ public java.util.concurrent.Future deleteRun(
+ final DeleteRunRequest request,
+ final com.oracle.bmc.responses.AsyncHandler
+ handler) {
+ LOG.trace("Called async deleteRun");
+ final DeleteRunRequest interceptedRequest = DeleteRunConverter.interceptRequest(request);
+ final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ DeleteRunConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function
+ transformer = DeleteRunConverter.fromResponse();
+
+ com.oracle.bmc.responses.AsyncHandler handlerToUse =
+ handler;
+ if (handler != null
+ && this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ handlerToUse =
+ new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
+ DeleteRunRequest, DeleteRunResponse>(
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ handler) {
+ @Override
+ public void retryCall() {
+ final com.oracle.bmc.util.internal.Consumer
+ onSuccess =
+ new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ this, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ this, interceptedRequest);
+ client.delete(ib, interceptedRequest, onSuccess, onError);
+ }
+ };
+ }
+
+ final com.oracle.bmc.util.internal.Consumer onSuccess =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ handlerToUse, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ handlerToUse, interceptedRequest);
+
+ java.util.concurrent.Future responseFuture =
+ client.delete(ib, interceptedRequest, onSuccess, onError);
+
+ if (this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
+ javax.ws.rs.core.Response, DeleteRunResponse>(
+ responseFuture,
+ transformer,
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ new com.google.common.base.Supplier<
+ java.util.concurrent.Future>() {
+ @Override
+ public java.util.concurrent.Future get() {
+ return client.delete(ib, interceptedRequest, onSuccess, onError);
+ }
+ });
+ } else {
+ return new com.oracle.bmc.util.internal.TransformingFuture<>(
+ responseFuture, transformer);
+ }
+ }
+
+ @Override
+ public java.util.concurrent.Future getApplication(
+ final GetApplicationRequest request,
+ final com.oracle.bmc.responses.AsyncHandler<
+ GetApplicationRequest, GetApplicationResponse>
+ handler) {
+ LOG.trace("Called async getApplication");
+ final GetApplicationRequest interceptedRequest =
+ GetApplicationConverter.interceptRequest(request);
+ final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ GetApplicationConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function
+ transformer = GetApplicationConverter.fromResponse();
+
+ com.oracle.bmc.responses.AsyncHandler
+ handlerToUse = handler;
+ if (handler != null
+ && this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ handlerToUse =
+ new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
+ GetApplicationRequest, GetApplicationResponse>(
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ handler) {
+ @Override
+ public void retryCall() {
+ final com.oracle.bmc.util.internal.Consumer
+ onSuccess =
+ new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ this, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ this, interceptedRequest);
+ client.get(ib, interceptedRequest, onSuccess, onError);
+ }
+ };
+ }
+
+ final com.oracle.bmc.util.internal.Consumer onSuccess =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ handlerToUse, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ handlerToUse, interceptedRequest);
+
+ java.util.concurrent.Future responseFuture =
+ client.get(ib, interceptedRequest, onSuccess, onError);
+
+ if (this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
+ javax.ws.rs.core.Response, GetApplicationResponse>(
+ responseFuture,
+ transformer,
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ new com.google.common.base.Supplier<
+ java.util.concurrent.Future>() {
+ @Override
+ public java.util.concurrent.Future get() {
+ return client.get(ib, interceptedRequest, onSuccess, onError);
+ }
+ });
+ } else {
+ return new com.oracle.bmc.util.internal.TransformingFuture<>(
+ responseFuture, transformer);
+ }
+ }
+
+ @Override
+ public java.util.concurrent.Future getPrivateEndpoint(
+ final GetPrivateEndpointRequest request,
+ final com.oracle.bmc.responses.AsyncHandler<
+ GetPrivateEndpointRequest, GetPrivateEndpointResponse>
+ handler) {
+ LOG.trace("Called async getPrivateEndpoint");
+ final GetPrivateEndpointRequest interceptedRequest =
+ GetPrivateEndpointConverter.interceptRequest(request);
+ final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ GetPrivateEndpointConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function
+ transformer = GetPrivateEndpointConverter.fromResponse();
+
+ com.oracle.bmc.responses.AsyncHandler
+ handlerToUse = handler;
+ if (handler != null
+ && this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ handlerToUse =
+ new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
+ GetPrivateEndpointRequest, GetPrivateEndpointResponse>(
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ handler) {
+ @Override
+ public void retryCall() {
+ final com.oracle.bmc.util.internal.Consumer
+ onSuccess =
+ new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ this, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ this, interceptedRequest);
+ client.get(ib, interceptedRequest, onSuccess, onError);
+ }
+ };
+ }
+
+ final com.oracle.bmc.util.internal.Consumer onSuccess =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ handlerToUse, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ handlerToUse, interceptedRequest);
+
+ java.util.concurrent.Future responseFuture =
+ client.get(ib, interceptedRequest, onSuccess, onError);
+
+ if (this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
+ javax.ws.rs.core.Response, GetPrivateEndpointResponse>(
+ responseFuture,
+ transformer,
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ new com.google.common.base.Supplier<
+ java.util.concurrent.Future>() {
+ @Override
+ public java.util.concurrent.Future get() {
+ return client.get(ib, interceptedRequest, onSuccess, onError);
+ }
+ });
+ } else {
+ return new com.oracle.bmc.util.internal.TransformingFuture<>(
+ responseFuture, transformer);
+ }
+ }
+
+ @Override
+ public java.util.concurrent.Future getRun(
+ final GetRunRequest request,
+ final com.oracle.bmc.responses.AsyncHandler handler) {
+ LOG.trace("Called async getRun");
+ final GetRunRequest interceptedRequest = GetRunConverter.interceptRequest(request);
+ final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ GetRunConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function
+ transformer = GetRunConverter.fromResponse();
+
+ com.oracle.bmc.responses.AsyncHandler handlerToUse = handler;
+ if (handler != null
+ && this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ handlerToUse =
+ new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
+ GetRunRequest, GetRunResponse>(
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ handler) {
+ @Override
+ public void retryCall() {
+ final com.oracle.bmc.util.internal.Consumer
+ onSuccess =
+ new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ this, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ this, interceptedRequest);
+ client.get(ib, interceptedRequest, onSuccess, onError);
+ }
+ };
+ }
+
+ final com.oracle.bmc.util.internal.Consumer onSuccess =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ handlerToUse, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ handlerToUse, interceptedRequest);
+
+ java.util.concurrent.Future responseFuture =
+ client.get(ib, interceptedRequest, onSuccess, onError);
+
+ if (this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
+ javax.ws.rs.core.Response, GetRunResponse>(
+ responseFuture,
+ transformer,
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ new com.google.common.base.Supplier<
+ java.util.concurrent.Future>() {
+ @Override
+ public java.util.concurrent.Future get() {
+ return client.get(ib, interceptedRequest, onSuccess, onError);
+ }
+ });
+ } else {
+ return new com.oracle.bmc.util.internal.TransformingFuture<>(
+ responseFuture, transformer);
+ }
+ }
+
+ @Override
+ public java.util.concurrent.Future getRunLog(
+ final GetRunLogRequest request,
+ final com.oracle.bmc.responses.AsyncHandler
+ handler) {
+ LOG.trace("Called async getRunLog");
+ final GetRunLogRequest interceptedRequest = GetRunLogConverter.interceptRequest(request);
+ final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ GetRunLogConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function
+ transformer = GetRunLogConverter.fromResponse();
+
+ com.oracle.bmc.responses.AsyncHandler handlerToUse =
+ handler;
+ if (handler != null
+ && this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ handlerToUse =
+ new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
+ GetRunLogRequest, GetRunLogResponse>(
+ (com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
+ this.authenticationDetailsProvider,
+ handler) {
+ @Override
+ public void retryCall() {
+ final com.oracle.bmc.util.internal.Consumer
+ onSuccess =
+ new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ this, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ this, interceptedRequest);
+ client.get(ib, interceptedRequest, onSuccess, onError);
+ }
+ };
+ }
+
+ final com.oracle.bmc.util.internal.Consumer onSuccess =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.SuccessConsumer<>(
+ handlerToUse, transformer, interceptedRequest);
+ final com.oracle.bmc.util.internal.Consumer onError =
+ (handler == null)
+ ? null
+ : new com.oracle.bmc.http.internal.ErrorConsumer<>(
+ handlerToUse, interceptedRequest);
+
+ java.util.concurrent.Future responseFuture =
+ client.get(ib, interceptedRequest, onSuccess, onError);
+
+ if (this.authenticationDetailsProvider
+ instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
+ return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
+ javax.ws.rs.core.Response, GetRunLogResponse>(
responseFuture,
transformer,
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
@@ -563,12 +1353,7 @@ public void retryCall() {
java.util.concurrent.Future>() {
@Override
public java.util.concurrent.Future get() {
- return client.post(
- ib,
- interceptedRequest.getCreateApplicationDetails(),
- interceptedRequest,
- onSuccess,
- onError);
+ return client.get(ib, interceptedRequest, onSuccess, onError);
}
});
} else {
@@ -578,25 +1363,27 @@ public java.util.concurrent.Future get() {
}
@Override
- public java.util.concurrent.Future createRun(
- final CreateRunRequest request,
- final com.oracle.bmc.responses.AsyncHandler
+ public java.util.concurrent.Future getWorkRequest(
+ final GetWorkRequestRequest request,
+ final com.oracle.bmc.responses.AsyncHandler<
+ GetWorkRequestRequest, GetWorkRequestResponse>
handler) {
- LOG.trace("Called async createRun");
- final CreateRunRequest interceptedRequest = CreateRunConverter.interceptRequest(request);
+ LOG.trace("Called async getWorkRequest");
+ final GetWorkRequestRequest interceptedRequest =
+ GetWorkRequestConverter.interceptRequest(request);
final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
- CreateRunConverter.fromRequest(client, interceptedRequest);
- final com.google.common.base.Function
- transformer = CreateRunConverter.fromResponse();
+ GetWorkRequestConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function
+ transformer = GetWorkRequestConverter.fromResponse();
- com.oracle.bmc.responses.AsyncHandler handlerToUse =
- handler;
+ com.oracle.bmc.responses.AsyncHandler
+ handlerToUse = handler;
if (handler != null
&& this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
handlerToUse =
new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
- CreateRunRequest, CreateRunResponse>(
+ GetWorkRequestRequest, GetWorkRequestResponse>(
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
this.authenticationDetailsProvider,
handler) {
@@ -609,12 +1396,7 @@ public void retryCall() {
final com.oracle.bmc.util.internal.Consumer onError =
new com.oracle.bmc.http.internal.ErrorConsumer<>(
this, interceptedRequest);
- client.post(
- ib,
- interceptedRequest.getCreateRunDetails(),
- interceptedRequest,
- onSuccess,
- onError);
+ client.get(ib, interceptedRequest, onSuccess, onError);
}
};
}
@@ -631,17 +1413,12 @@ public void retryCall() {
handlerToUse, interceptedRequest);
java.util.concurrent.Future responseFuture =
- client.post(
- ib,
- interceptedRequest.getCreateRunDetails(),
- interceptedRequest,
- onSuccess,
- onError);
+ client.get(ib, interceptedRequest, onSuccess, onError);
if (this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
- javax.ws.rs.core.Response, CreateRunResponse>(
+ javax.ws.rs.core.Response, GetWorkRequestResponse>(
responseFuture,
transformer,
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
@@ -650,12 +1427,7 @@ public void retryCall() {
java.util.concurrent.Future>() {
@Override
public java.util.concurrent.Future get() {
- return client.post(
- ib,
- interceptedRequest.getCreateRunDetails(),
- interceptedRequest,
- onSuccess,
- onError);
+ return client.get(ib, interceptedRequest, onSuccess, onError);
}
});
} else {
@@ -665,27 +1437,27 @@ public java.util.concurrent.Future get() {
}
@Override
- public java.util.concurrent.Future deleteApplication(
- final DeleteApplicationRequest request,
+ public java.util.concurrent.Future listApplications(
+ final ListApplicationsRequest request,
final com.oracle.bmc.responses.AsyncHandler<
- DeleteApplicationRequest, DeleteApplicationResponse>
+ ListApplicationsRequest, ListApplicationsResponse>
handler) {
- LOG.trace("Called async deleteApplication");
- final DeleteApplicationRequest interceptedRequest =
- DeleteApplicationConverter.interceptRequest(request);
+ LOG.trace("Called async listApplications");
+ final ListApplicationsRequest interceptedRequest =
+ ListApplicationsConverter.interceptRequest(request);
final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
- DeleteApplicationConverter.fromRequest(client, interceptedRequest);
- final com.google.common.base.Function
- transformer = DeleteApplicationConverter.fromResponse();
+ ListApplicationsConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function
+ transformer = ListApplicationsConverter.fromResponse();
- com.oracle.bmc.responses.AsyncHandler
+ com.oracle.bmc.responses.AsyncHandler
handlerToUse = handler;
if (handler != null
&& this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
handlerToUse =
new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
- DeleteApplicationRequest, DeleteApplicationResponse>(
+ ListApplicationsRequest, ListApplicationsResponse>(
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
this.authenticationDetailsProvider,
handler) {
@@ -698,7 +1470,7 @@ public void retryCall() {
final com.oracle.bmc.util.internal.Consumer onError =
new com.oracle.bmc.http.internal.ErrorConsumer<>(
this, interceptedRequest);
- client.delete(ib, interceptedRequest, onSuccess, onError);
+ client.get(ib, interceptedRequest, onSuccess, onError);
}
};
}
@@ -715,12 +1487,12 @@ public void retryCall() {
handlerToUse, interceptedRequest);
java.util.concurrent.Future responseFuture =
- client.delete(ib, interceptedRequest, onSuccess, onError);
+ client.get(ib, interceptedRequest, onSuccess, onError);
if (this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
- javax.ws.rs.core.Response, DeleteApplicationResponse>(
+ javax.ws.rs.core.Response, ListApplicationsResponse>(
responseFuture,
transformer,
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
@@ -729,7 +1501,7 @@ public void retryCall() {
java.util.concurrent.Future>() {
@Override
public java.util.concurrent.Future get() {
- return client.delete(ib, interceptedRequest, onSuccess, onError);
+ return client.get(ib, interceptedRequest, onSuccess, onError);
}
});
} else {
@@ -739,25 +1511,29 @@ public java.util.concurrent.Future get() {
}
@Override
- public java.util.concurrent.Future deleteRun(
- final DeleteRunRequest request,
- final com.oracle.bmc.responses.AsyncHandler
+ public java.util.concurrent.Future listPrivateEndpoints(
+ final ListPrivateEndpointsRequest request,
+ final com.oracle.bmc.responses.AsyncHandler<
+ ListPrivateEndpointsRequest, ListPrivateEndpointsResponse>
handler) {
- LOG.trace("Called async deleteRun");
- final DeleteRunRequest interceptedRequest = DeleteRunConverter.interceptRequest(request);
+ LOG.trace("Called async listPrivateEndpoints");
+ final ListPrivateEndpointsRequest interceptedRequest =
+ ListPrivateEndpointsConverter.interceptRequest(request);
final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
- DeleteRunConverter.fromRequest(client, interceptedRequest);
- final com.google.common.base.Function
- transformer = DeleteRunConverter.fromResponse();
+ ListPrivateEndpointsConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function<
+ javax.ws.rs.core.Response, ListPrivateEndpointsResponse>
+ transformer = ListPrivateEndpointsConverter.fromResponse();
- com.oracle.bmc.responses.AsyncHandler handlerToUse =
- handler;
+ com.oracle.bmc.responses.AsyncHandler<
+ ListPrivateEndpointsRequest, ListPrivateEndpointsResponse>
+ handlerToUse = handler;
if (handler != null
&& this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
handlerToUse =
new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
- DeleteRunRequest, DeleteRunResponse>(
+ ListPrivateEndpointsRequest, ListPrivateEndpointsResponse>(
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
this.authenticationDetailsProvider,
handler) {
@@ -770,7 +1546,7 @@ public void retryCall() {
final com.oracle.bmc.util.internal.Consumer onError =
new com.oracle.bmc.http.internal.ErrorConsumer<>(
this, interceptedRequest);
- client.delete(ib, interceptedRequest, onSuccess, onError);
+ client.get(ib, interceptedRequest, onSuccess, onError);
}
};
}
@@ -787,12 +1563,12 @@ public void retryCall() {
handlerToUse, interceptedRequest);
java.util.concurrent.Future responseFuture =
- client.delete(ib, interceptedRequest, onSuccess, onError);
+ client.get(ib, interceptedRequest, onSuccess, onError);
if (this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
- javax.ws.rs.core.Response, DeleteRunResponse>(
+ javax.ws.rs.core.Response, ListPrivateEndpointsResponse>(
responseFuture,
transformer,
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
@@ -801,7 +1577,7 @@ public void retryCall() {
java.util.concurrent.Future>() {
@Override
public java.util.concurrent.Future get() {
- return client.delete(ib, interceptedRequest, onSuccess, onError);
+ return client.get(ib, interceptedRequest, onSuccess, onError);
}
});
} else {
@@ -811,27 +1587,26 @@ public java.util.concurrent.Future get() {
}
@Override
- public java.util.concurrent.Future getApplication(
- final GetApplicationRequest request,
- final com.oracle.bmc.responses.AsyncHandler<
- GetApplicationRequest, GetApplicationResponse>
+ public java.util.concurrent.Future listRunLogs(
+ final ListRunLogsRequest request,
+ final com.oracle.bmc.responses.AsyncHandler
handler) {
- LOG.trace("Called async getApplication");
- final GetApplicationRequest interceptedRequest =
- GetApplicationConverter.interceptRequest(request);
+ LOG.trace("Called async listRunLogs");
+ final ListRunLogsRequest interceptedRequest =
+ ListRunLogsConverter.interceptRequest(request);
final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
- GetApplicationConverter.fromRequest(client, interceptedRequest);
- final com.google.common.base.Function
- transformer = GetApplicationConverter.fromResponse();
+ ListRunLogsConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function
+ transformer = ListRunLogsConverter.fromResponse();
- com.oracle.bmc.responses.AsyncHandler
+ com.oracle.bmc.responses.AsyncHandler
handlerToUse = handler;
if (handler != null
&& this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
handlerToUse =
new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
- GetApplicationRequest, GetApplicationResponse>(
+ ListRunLogsRequest, ListRunLogsResponse>(
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
this.authenticationDetailsProvider,
handler) {
@@ -866,7 +1641,7 @@ public void retryCall() {
if (this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
- javax.ws.rs.core.Response, GetApplicationResponse>(
+ javax.ws.rs.core.Response, ListRunLogsResponse>(
responseFuture,
transformer,
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
@@ -885,23 +1660,25 @@ public java.util.concurrent.Future get() {
}
@Override
- public java.util.concurrent.Future getRun(
- final GetRunRequest request,
- final com.oracle.bmc.responses.AsyncHandler handler) {
- LOG.trace("Called async getRun");
- final GetRunRequest interceptedRequest = GetRunConverter.interceptRequest(request);
+ public java.util.concurrent.Future listRuns(
+ final ListRunsRequest request,
+ final com.oracle.bmc.responses.AsyncHandler
+ handler) {
+ LOG.trace("Called async listRuns");
+ final ListRunsRequest interceptedRequest = ListRunsConverter.interceptRequest(request);
final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
- GetRunConverter.fromRequest(client, interceptedRequest);
- final com.google.common.base.Function
- transformer = GetRunConverter.fromResponse();
+ ListRunsConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function
+ transformer = ListRunsConverter.fromResponse();
- com.oracle.bmc.responses.AsyncHandler handlerToUse = handler;
+ com.oracle.bmc.responses.AsyncHandler handlerToUse =
+ handler;
if (handler != null
&& this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
handlerToUse =
new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
- GetRunRequest, GetRunResponse>(
+ ListRunsRequest, ListRunsResponse>(
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
this.authenticationDetailsProvider,
handler) {
@@ -936,7 +1713,7 @@ public void retryCall() {
if (this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
- javax.ws.rs.core.Response, GetRunResponse>(
+ javax.ws.rs.core.Response, ListRunsResponse>(
responseFuture,
transformer,
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
@@ -955,25 +1732,29 @@ public java.util.concurrent.Future get() {
}
@Override
- public java.util.concurrent.Future getRunLog(
- final GetRunLogRequest request,
- final com.oracle.bmc.responses.AsyncHandler
+ public java.util.concurrent.Future listWorkRequestErrors(
+ final ListWorkRequestErrorsRequest request,
+ final com.oracle.bmc.responses.AsyncHandler<
+ ListWorkRequestErrorsRequest, ListWorkRequestErrorsResponse>
handler) {
- LOG.trace("Called async getRunLog");
- final GetRunLogRequest interceptedRequest = GetRunLogConverter.interceptRequest(request);
+ LOG.trace("Called async listWorkRequestErrors");
+ final ListWorkRequestErrorsRequest interceptedRequest =
+ ListWorkRequestErrorsConverter.interceptRequest(request);
final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
- GetRunLogConverter.fromRequest(client, interceptedRequest);
- final com.google.common.base.Function
- transformer = GetRunLogConverter.fromResponse();
+ ListWorkRequestErrorsConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function<
+ javax.ws.rs.core.Response, ListWorkRequestErrorsResponse>
+ transformer = ListWorkRequestErrorsConverter.fromResponse();
- com.oracle.bmc.responses.AsyncHandler handlerToUse =
- handler;
+ com.oracle.bmc.responses.AsyncHandler<
+ ListWorkRequestErrorsRequest, ListWorkRequestErrorsResponse>
+ handlerToUse = handler;
if (handler != null
&& this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
handlerToUse =
new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
- GetRunLogRequest, GetRunLogResponse>(
+ ListWorkRequestErrorsRequest, ListWorkRequestErrorsResponse>(
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
this.authenticationDetailsProvider,
handler) {
@@ -1008,7 +1789,7 @@ public void retryCall() {
if (this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
- javax.ws.rs.core.Response, GetRunLogResponse>(
+ javax.ws.rs.core.Response, ListWorkRequestErrorsResponse>(
responseFuture,
transformer,
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
@@ -1027,27 +1808,29 @@ public java.util.concurrent.Future get() {
}
@Override
- public java.util.concurrent.Future listApplications(
- final ListApplicationsRequest request,
+ public java.util.concurrent.Future listWorkRequestLogs(
+ final ListWorkRequestLogsRequest request,
final com.oracle.bmc.responses.AsyncHandler<
- ListApplicationsRequest, ListApplicationsResponse>
+ ListWorkRequestLogsRequest, ListWorkRequestLogsResponse>
handler) {
- LOG.trace("Called async listApplications");
- final ListApplicationsRequest interceptedRequest =
- ListApplicationsConverter.interceptRequest(request);
+ LOG.trace("Called async listWorkRequestLogs");
+ final ListWorkRequestLogsRequest interceptedRequest =
+ ListWorkRequestLogsConverter.interceptRequest(request);
final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
- ListApplicationsConverter.fromRequest(client, interceptedRequest);
- final com.google.common.base.Function
- transformer = ListApplicationsConverter.fromResponse();
+ ListWorkRequestLogsConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function<
+ javax.ws.rs.core.Response, ListWorkRequestLogsResponse>
+ transformer = ListWorkRequestLogsConverter.fromResponse();
- com.oracle.bmc.responses.AsyncHandler
+ com.oracle.bmc.responses.AsyncHandler<
+ ListWorkRequestLogsRequest, ListWorkRequestLogsResponse>
handlerToUse = handler;
if (handler != null
&& this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
handlerToUse =
new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
- ListApplicationsRequest, ListApplicationsResponse>(
+ ListWorkRequestLogsRequest, ListWorkRequestLogsResponse>(
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
this.authenticationDetailsProvider,
handler) {
@@ -1082,7 +1865,7 @@ public void retryCall() {
if (this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
- javax.ws.rs.core.Response, ListApplicationsResponse>(
+ javax.ws.rs.core.Response, ListWorkRequestLogsResponse>(
responseFuture,
transformer,
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
@@ -1101,26 +1884,27 @@ public java.util.concurrent.Future get() {
}
@Override
- public java.util.concurrent.Future listRunLogs(
- final ListRunLogsRequest request,
- final com.oracle.bmc.responses.AsyncHandler
+ public java.util.concurrent.Future listWorkRequests(
+ final ListWorkRequestsRequest request,
+ final com.oracle.bmc.responses.AsyncHandler<
+ ListWorkRequestsRequest, ListWorkRequestsResponse>
handler) {
- LOG.trace("Called async listRunLogs");
- final ListRunLogsRequest interceptedRequest =
- ListRunLogsConverter.interceptRequest(request);
+ LOG.trace("Called async listWorkRequests");
+ final ListWorkRequestsRequest interceptedRequest =
+ ListWorkRequestsConverter.interceptRequest(request);
final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
- ListRunLogsConverter.fromRequest(client, interceptedRequest);
- final com.google.common.base.Function
- transformer = ListRunLogsConverter.fromResponse();
+ ListWorkRequestsConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function
+ transformer = ListWorkRequestsConverter.fromResponse();
- com.oracle.bmc.responses.AsyncHandler
+ com.oracle.bmc.responses.AsyncHandler
handlerToUse = handler;
if (handler != null
&& this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
handlerToUse =
new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
- ListRunLogsRequest, ListRunLogsResponse>(
+ ListWorkRequestsRequest, ListWorkRequestsResponse>(
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
this.authenticationDetailsProvider,
handler) {
@@ -1155,7 +1939,7 @@ public void retryCall() {
if (this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
- javax.ws.rs.core.Response, ListRunLogsResponse>(
+ javax.ws.rs.core.Response, ListWorkRequestsResponse>(
responseFuture,
transformer,
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
@@ -1174,25 +1958,27 @@ public java.util.concurrent.Future get() {
}
@Override
- public java.util.concurrent.Future listRuns(
- final ListRunsRequest request,
- final com.oracle.bmc.responses.AsyncHandler
+ public java.util.concurrent.Future updateApplication(
+ final UpdateApplicationRequest request,
+ final com.oracle.bmc.responses.AsyncHandler<
+ UpdateApplicationRequest, UpdateApplicationResponse>
handler) {
- LOG.trace("Called async listRuns");
- final ListRunsRequest interceptedRequest = ListRunsConverter.interceptRequest(request);
+ LOG.trace("Called async updateApplication");
+ final UpdateApplicationRequest interceptedRequest =
+ UpdateApplicationConverter.interceptRequest(request);
final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
- ListRunsConverter.fromRequest(client, interceptedRequest);
- final com.google.common.base.Function
- transformer = ListRunsConverter.fromResponse();
+ UpdateApplicationConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function
+ transformer = UpdateApplicationConverter.fromResponse();
- com.oracle.bmc.responses.AsyncHandler handlerToUse =
- handler;
+ com.oracle.bmc.responses.AsyncHandler
+ handlerToUse = handler;
if (handler != null
&& this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
handlerToUse =
new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
- ListRunsRequest, ListRunsResponse>(
+ UpdateApplicationRequest, UpdateApplicationResponse>(
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
this.authenticationDetailsProvider,
handler) {
@@ -1205,7 +1991,12 @@ public void retryCall() {
final com.oracle.bmc.util.internal.Consumer onError =
new com.oracle.bmc.http.internal.ErrorConsumer<>(
this, interceptedRequest);
- client.get(ib, interceptedRequest, onSuccess, onError);
+ client.put(
+ ib,
+ interceptedRequest.getUpdateApplicationDetails(),
+ interceptedRequest,
+ onSuccess,
+ onError);
}
};
}
@@ -1222,12 +2013,17 @@ public void retryCall() {
handlerToUse, interceptedRequest);
java.util.concurrent.Future responseFuture =
- client.get(ib, interceptedRequest, onSuccess, onError);
+ client.put(
+ ib,
+ interceptedRequest.getUpdateApplicationDetails(),
+ interceptedRequest,
+ onSuccess,
+ onError);
if (this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
- javax.ws.rs.core.Response, ListRunsResponse>(
+ javax.ws.rs.core.Response, UpdateApplicationResponse>(
responseFuture,
transformer,
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
@@ -1236,7 +2032,12 @@ public void retryCall() {
java.util.concurrent.Future>() {
@Override
public java.util.concurrent.Future get() {
- return client.get(ib, interceptedRequest, onSuccess, onError);
+ return client.put(
+ ib,
+ interceptedRequest.getUpdateApplicationDetails(),
+ interceptedRequest,
+ onSuccess,
+ onError);
}
});
} else {
@@ -1246,27 +2047,29 @@ public java.util.concurrent.Future get() {
}
@Override
- public java.util.concurrent.Future updateApplication(
- final UpdateApplicationRequest request,
+ public java.util.concurrent.Future updatePrivateEndpoint(
+ final UpdatePrivateEndpointRequest request,
final com.oracle.bmc.responses.AsyncHandler<
- UpdateApplicationRequest, UpdateApplicationResponse>
+ UpdatePrivateEndpointRequest, UpdatePrivateEndpointResponse>
handler) {
- LOG.trace("Called async updateApplication");
- final UpdateApplicationRequest interceptedRequest =
- UpdateApplicationConverter.interceptRequest(request);
+ LOG.trace("Called async updatePrivateEndpoint");
+ final UpdatePrivateEndpointRequest interceptedRequest =
+ UpdatePrivateEndpointConverter.interceptRequest(request);
final com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
- UpdateApplicationConverter.fromRequest(client, interceptedRequest);
- final com.google.common.base.Function
- transformer = UpdateApplicationConverter.fromResponse();
+ UpdatePrivateEndpointConverter.fromRequest(client, interceptedRequest);
+ final com.google.common.base.Function<
+ javax.ws.rs.core.Response, UpdatePrivateEndpointResponse>
+ transformer = UpdatePrivateEndpointConverter.fromResponse();
- com.oracle.bmc.responses.AsyncHandler
+ com.oracle.bmc.responses.AsyncHandler<
+ UpdatePrivateEndpointRequest, UpdatePrivateEndpointResponse>
handlerToUse = handler;
if (handler != null
&& this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
handlerToUse =
new com.oracle.bmc.util.internal.RefreshAuthTokenWrappingAsyncHandler<
- UpdateApplicationRequest, UpdateApplicationResponse>(
+ UpdatePrivateEndpointRequest, UpdatePrivateEndpointResponse>(
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
this.authenticationDetailsProvider,
handler) {
@@ -1281,7 +2084,7 @@ public void retryCall() {
this, interceptedRequest);
client.put(
ib,
- interceptedRequest.getUpdateApplicationDetails(),
+ interceptedRequest.getUpdatePrivateEndpointDetails(),
interceptedRequest,
onSuccess,
onError);
@@ -1303,7 +2106,7 @@ public void retryCall() {
java.util.concurrent.Future responseFuture =
client.put(
ib,
- interceptedRequest.getUpdateApplicationDetails(),
+ interceptedRequest.getUpdatePrivateEndpointDetails(),
interceptedRequest,
onSuccess,
onError);
@@ -1311,7 +2114,7 @@ public void retryCall() {
if (this.authenticationDetailsProvider
instanceof com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider) {
return new com.oracle.bmc.util.internal.RefreshAuthTokenTransformingFuture<
- javax.ws.rs.core.Response, UpdateApplicationResponse>(
+ javax.ws.rs.core.Response, UpdatePrivateEndpointResponse>(
responseFuture,
transformer,
(com.oracle.bmc.auth.RefreshableOnNotAuthenticatedProvider)
@@ -1322,7 +2125,7 @@ public void retryCall() {
public java.util.concurrent.Future get() {
return client.put(
ib,
- interceptedRequest.getUpdateApplicationDetails(),
+ interceptedRequest.getUpdatePrivateEndpointDetails(),
interceptedRequest,
onSuccess,
onError);
diff --git a/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlowClient.java b/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlowClient.java
index c32efa135e4..a311b242500 100644
--- a/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlowClient.java
+++ b/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlowClient.java
@@ -454,6 +454,41 @@ public ChangeApplicationCompartmentResponse changeApplicationCompartment(
});
}
+ @Override
+ public ChangePrivateEndpointCompartmentResponse changePrivateEndpointCompartment(
+ ChangePrivateEndpointCompartmentRequest request) {
+ LOG.trace("Called changePrivateEndpointCompartment");
+ final ChangePrivateEndpointCompartmentRequest interceptedRequest =
+ ChangePrivateEndpointCompartmentConverter.interceptRequest(request);
+ com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ ChangePrivateEndpointCompartmentConverter.fromRequest(client, interceptedRequest);
+ com.google.common.base.Function<
+ javax.ws.rs.core.Response, ChangePrivateEndpointCompartmentResponse>
+ transformer = ChangePrivateEndpointCompartmentConverter.fromResponse();
+
+ final com.oracle.bmc.retrier.BmcGenericRetrier retrier =
+ com.oracle.bmc.retrier.Retriers.createPreferredRetrier(
+ interceptedRequest.getRetryConfiguration(), retryConfiguration);
+ return retrier.execute(
+ interceptedRequest,
+ retryRequest -> {
+ final com.oracle.bmc.retrier.TokenRefreshRetrier tokenRefreshRetrier =
+ new com.oracle.bmc.retrier.TokenRefreshRetrier(
+ authenticationDetailsProvider);
+ return tokenRefreshRetrier.execute(
+ retryRequest,
+ retriedRequest -> {
+ javax.ws.rs.core.Response response =
+ client.post(
+ ib,
+ retriedRequest
+ .getChangePrivateEndpointCompartmentDetails(),
+ retriedRequest);
+ return transformer.apply(response);
+ });
+ });
+ }
+
@Override
public ChangeRunCompartmentResponse changeRunCompartment(ChangeRunCompartmentRequest request) {
LOG.trace("Called changeRunCompartment");
@@ -518,6 +553,39 @@ public CreateApplicationResponse createApplication(CreateApplicationRequest requ
});
}
+ @Override
+ public CreatePrivateEndpointResponse createPrivateEndpoint(
+ CreatePrivateEndpointRequest request) {
+ LOG.trace("Called createPrivateEndpoint");
+ final CreatePrivateEndpointRequest interceptedRequest =
+ CreatePrivateEndpointConverter.interceptRequest(request);
+ com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ CreatePrivateEndpointConverter.fromRequest(client, interceptedRequest);
+ com.google.common.base.Function
+ transformer = CreatePrivateEndpointConverter.fromResponse();
+
+ final com.oracle.bmc.retrier.BmcGenericRetrier retrier =
+ com.oracle.bmc.retrier.Retriers.createPreferredRetrier(
+ interceptedRequest.getRetryConfiguration(), retryConfiguration);
+ return retrier.execute(
+ interceptedRequest,
+ retryRequest -> {
+ final com.oracle.bmc.retrier.TokenRefreshRetrier tokenRefreshRetrier =
+ new com.oracle.bmc.retrier.TokenRefreshRetrier(
+ authenticationDetailsProvider);
+ return tokenRefreshRetrier.execute(
+ retryRequest,
+ retriedRequest -> {
+ javax.ws.rs.core.Response response =
+ client.post(
+ ib,
+ retriedRequest.getCreatePrivateEndpointDetails(),
+ retriedRequest);
+ return transformer.apply(response);
+ });
+ });
+ }
+
@Override
public CreateRunResponse createRun(CreateRunRequest request) {
LOG.trace("Called createRun");
@@ -578,6 +646,36 @@ public DeleteApplicationResponse deleteApplication(DeleteApplicationRequest requ
});
}
+ @Override
+ public DeletePrivateEndpointResponse deletePrivateEndpoint(
+ DeletePrivateEndpointRequest request) {
+ LOG.trace("Called deletePrivateEndpoint");
+ final DeletePrivateEndpointRequest interceptedRequest =
+ DeletePrivateEndpointConverter.interceptRequest(request);
+ com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ DeletePrivateEndpointConverter.fromRequest(client, interceptedRequest);
+ com.google.common.base.Function
+ transformer = DeletePrivateEndpointConverter.fromResponse();
+
+ final com.oracle.bmc.retrier.BmcGenericRetrier retrier =
+ com.oracle.bmc.retrier.Retriers.createPreferredRetrier(
+ interceptedRequest.getRetryConfiguration(), retryConfiguration);
+ return retrier.execute(
+ interceptedRequest,
+ retryRequest -> {
+ final com.oracle.bmc.retrier.TokenRefreshRetrier tokenRefreshRetrier =
+ new com.oracle.bmc.retrier.TokenRefreshRetrier(
+ authenticationDetailsProvider);
+ return tokenRefreshRetrier.execute(
+ retryRequest,
+ retriedRequest -> {
+ javax.ws.rs.core.Response response =
+ client.delete(ib, retriedRequest);
+ return transformer.apply(response);
+ });
+ });
+ }
+
@Override
public DeleteRunResponse deleteRun(DeleteRunRequest request) {
LOG.trace("Called deleteRun");
@@ -634,6 +732,34 @@ public GetApplicationResponse getApplication(GetApplicationRequest request) {
});
}
+ @Override
+ public GetPrivateEndpointResponse getPrivateEndpoint(GetPrivateEndpointRequest request) {
+ LOG.trace("Called getPrivateEndpoint");
+ final GetPrivateEndpointRequest interceptedRequest =
+ GetPrivateEndpointConverter.interceptRequest(request);
+ com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ GetPrivateEndpointConverter.fromRequest(client, interceptedRequest);
+ com.google.common.base.Function
+ transformer = GetPrivateEndpointConverter.fromResponse();
+
+ final com.oracle.bmc.retrier.BmcGenericRetrier retrier =
+ com.oracle.bmc.retrier.Retriers.createPreferredRetrier(
+ interceptedRequest.getRetryConfiguration(), retryConfiguration);
+ return retrier.execute(
+ interceptedRequest,
+ retryRequest -> {
+ final com.oracle.bmc.retrier.TokenRefreshRetrier tokenRefreshRetrier =
+ new com.oracle.bmc.retrier.TokenRefreshRetrier(
+ authenticationDetailsProvider);
+ return tokenRefreshRetrier.execute(
+ retryRequest,
+ retriedRequest -> {
+ javax.ws.rs.core.Response response = client.get(ib, retriedRequest);
+ return transformer.apply(response);
+ });
+ });
+ }
+
@Override
public GetRunResponse getRun(GetRunRequest request) {
LOG.trace("Called getRun");
@@ -688,6 +814,34 @@ public GetRunLogResponse getRunLog(GetRunLogRequest request) {
});
}
+ @Override
+ public GetWorkRequestResponse getWorkRequest(GetWorkRequestRequest request) {
+ LOG.trace("Called getWorkRequest");
+ final GetWorkRequestRequest interceptedRequest =
+ GetWorkRequestConverter.interceptRequest(request);
+ com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ GetWorkRequestConverter.fromRequest(client, interceptedRequest);
+ com.google.common.base.Function
+ transformer = GetWorkRequestConverter.fromResponse();
+
+ final com.oracle.bmc.retrier.BmcGenericRetrier retrier =
+ com.oracle.bmc.retrier.Retriers.createPreferredRetrier(
+ interceptedRequest.getRetryConfiguration(), retryConfiguration);
+ return retrier.execute(
+ interceptedRequest,
+ retryRequest -> {
+ final com.oracle.bmc.retrier.TokenRefreshRetrier tokenRefreshRetrier =
+ new com.oracle.bmc.retrier.TokenRefreshRetrier(
+ authenticationDetailsProvider);
+ return tokenRefreshRetrier.execute(
+ retryRequest,
+ retriedRequest -> {
+ javax.ws.rs.core.Response response = client.get(ib, retriedRequest);
+ return transformer.apply(response);
+ });
+ });
+ }
+
@Override
public ListApplicationsResponse listApplications(ListApplicationsRequest request) {
LOG.trace("Called listApplications");
@@ -716,6 +870,34 @@ public ListApplicationsResponse listApplications(ListApplicationsRequest request
});
}
+ @Override
+ public ListPrivateEndpointsResponse listPrivateEndpoints(ListPrivateEndpointsRequest request) {
+ LOG.trace("Called listPrivateEndpoints");
+ final ListPrivateEndpointsRequest interceptedRequest =
+ ListPrivateEndpointsConverter.interceptRequest(request);
+ com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ ListPrivateEndpointsConverter.fromRequest(client, interceptedRequest);
+ com.google.common.base.Function
+ transformer = ListPrivateEndpointsConverter.fromResponse();
+
+ final com.oracle.bmc.retrier.BmcGenericRetrier retrier =
+ com.oracle.bmc.retrier.Retriers.createPreferredRetrier(
+ interceptedRequest.getRetryConfiguration(), retryConfiguration);
+ return retrier.execute(
+ interceptedRequest,
+ retryRequest -> {
+ final com.oracle.bmc.retrier.TokenRefreshRetrier tokenRefreshRetrier =
+ new com.oracle.bmc.retrier.TokenRefreshRetrier(
+ authenticationDetailsProvider);
+ return tokenRefreshRetrier.execute(
+ retryRequest,
+ retriedRequest -> {
+ javax.ws.rs.core.Response response = client.get(ib, retriedRequest);
+ return transformer.apply(response);
+ });
+ });
+ }
+
@Override
public ListRunLogsResponse listRunLogs(ListRunLogsRequest request) {
LOG.trace("Called listRunLogs");
@@ -771,6 +953,91 @@ public ListRunsResponse listRuns(ListRunsRequest request) {
});
}
+ @Override
+ public ListWorkRequestErrorsResponse listWorkRequestErrors(
+ ListWorkRequestErrorsRequest request) {
+ LOG.trace("Called listWorkRequestErrors");
+ final ListWorkRequestErrorsRequest interceptedRequest =
+ ListWorkRequestErrorsConverter.interceptRequest(request);
+ com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ ListWorkRequestErrorsConverter.fromRequest(client, interceptedRequest);
+ com.google.common.base.Function
+ transformer = ListWorkRequestErrorsConverter.fromResponse();
+
+ final com.oracle.bmc.retrier.BmcGenericRetrier retrier =
+ com.oracle.bmc.retrier.Retriers.createPreferredRetrier(
+ interceptedRequest.getRetryConfiguration(), retryConfiguration);
+ return retrier.execute(
+ interceptedRequest,
+ retryRequest -> {
+ final com.oracle.bmc.retrier.TokenRefreshRetrier tokenRefreshRetrier =
+ new com.oracle.bmc.retrier.TokenRefreshRetrier(
+ authenticationDetailsProvider);
+ return tokenRefreshRetrier.execute(
+ retryRequest,
+ retriedRequest -> {
+ javax.ws.rs.core.Response response = client.get(ib, retriedRequest);
+ return transformer.apply(response);
+ });
+ });
+ }
+
+ @Override
+ public ListWorkRequestLogsResponse listWorkRequestLogs(ListWorkRequestLogsRequest request) {
+ LOG.trace("Called listWorkRequestLogs");
+ final ListWorkRequestLogsRequest interceptedRequest =
+ ListWorkRequestLogsConverter.interceptRequest(request);
+ com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ ListWorkRequestLogsConverter.fromRequest(client, interceptedRequest);
+ com.google.common.base.Function
+ transformer = ListWorkRequestLogsConverter.fromResponse();
+
+ final com.oracle.bmc.retrier.BmcGenericRetrier retrier =
+ com.oracle.bmc.retrier.Retriers.createPreferredRetrier(
+ interceptedRequest.getRetryConfiguration(), retryConfiguration);
+ return retrier.execute(
+ interceptedRequest,
+ retryRequest -> {
+ final com.oracle.bmc.retrier.TokenRefreshRetrier tokenRefreshRetrier =
+ new com.oracle.bmc.retrier.TokenRefreshRetrier(
+ authenticationDetailsProvider);
+ return tokenRefreshRetrier.execute(
+ retryRequest,
+ retriedRequest -> {
+ javax.ws.rs.core.Response response = client.get(ib, retriedRequest);
+ return transformer.apply(response);
+ });
+ });
+ }
+
+ @Override
+ public ListWorkRequestsResponse listWorkRequests(ListWorkRequestsRequest request) {
+ LOG.trace("Called listWorkRequests");
+ final ListWorkRequestsRequest interceptedRequest =
+ ListWorkRequestsConverter.interceptRequest(request);
+ com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ ListWorkRequestsConverter.fromRequest(client, interceptedRequest);
+ com.google.common.base.Function
+ transformer = ListWorkRequestsConverter.fromResponse();
+
+ final com.oracle.bmc.retrier.BmcGenericRetrier retrier =
+ com.oracle.bmc.retrier.Retriers.createPreferredRetrier(
+ interceptedRequest.getRetryConfiguration(), retryConfiguration);
+ return retrier.execute(
+ interceptedRequest,
+ retryRequest -> {
+ final com.oracle.bmc.retrier.TokenRefreshRetrier tokenRefreshRetrier =
+ new com.oracle.bmc.retrier.TokenRefreshRetrier(
+ authenticationDetailsProvider);
+ return tokenRefreshRetrier.execute(
+ retryRequest,
+ retriedRequest -> {
+ javax.ws.rs.core.Response response = client.get(ib, retriedRequest);
+ return transformer.apply(response);
+ });
+ });
+ }
+
@Override
public UpdateApplicationResponse updateApplication(UpdateApplicationRequest request) {
LOG.trace("Called updateApplication");
@@ -803,6 +1070,39 @@ public UpdateApplicationResponse updateApplication(UpdateApplicationRequest requ
});
}
+ @Override
+ public UpdatePrivateEndpointResponse updatePrivateEndpoint(
+ UpdatePrivateEndpointRequest request) {
+ LOG.trace("Called updatePrivateEndpoint");
+ final UpdatePrivateEndpointRequest interceptedRequest =
+ UpdatePrivateEndpointConverter.interceptRequest(request);
+ com.oracle.bmc.http.internal.WrappedInvocationBuilder ib =
+ UpdatePrivateEndpointConverter.fromRequest(client, interceptedRequest);
+ com.google.common.base.Function
+ transformer = UpdatePrivateEndpointConverter.fromResponse();
+
+ final com.oracle.bmc.retrier.BmcGenericRetrier retrier =
+ com.oracle.bmc.retrier.Retriers.createPreferredRetrier(
+ interceptedRequest.getRetryConfiguration(), retryConfiguration);
+ return retrier.execute(
+ interceptedRequest,
+ retryRequest -> {
+ final com.oracle.bmc.retrier.TokenRefreshRetrier tokenRefreshRetrier =
+ new com.oracle.bmc.retrier.TokenRefreshRetrier(
+ authenticationDetailsProvider);
+ return tokenRefreshRetrier.execute(
+ retryRequest,
+ retriedRequest -> {
+ javax.ws.rs.core.Response response =
+ client.put(
+ ib,
+ retriedRequest.getUpdatePrivateEndpointDetails(),
+ retriedRequest);
+ return transformer.apply(response);
+ });
+ });
+ }
+
@Override
public UpdateRunResponse updateRun(UpdateRunRequest request) {
LOG.trace("Called updateRun");
diff --git a/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlowPaginators.java b/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlowPaginators.java
index 5af366fbe0d..926cff28991 100644
--- a/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlowPaginators.java
+++ b/bmc-dataflow/src/main/java/com/oracle/bmc/dataflow/DataFlowPaginators.java
@@ -142,6 +142,119 @@ public java.util.List apply(
});
}
+ /**
+ * Creates a new iterable which will iterate over the responses received from the listPrivateEndpoints operation. This iterable
+ * will fetch more data from the server as needed.
+ *
+ * @param request a request which can be sent to the service operation
+ * @return an {@link java.lang.Iterable} which can be used to iterate over the responses received from the service.
+ */
+ public Iterable listPrivateEndpointsResponseIterator(
+ final ListPrivateEndpointsRequest request) {
+ return new com.oracle.bmc.paginator.internal.ResponseIterable<
+ ListPrivateEndpointsRequest.Builder, ListPrivateEndpointsRequest,
+ ListPrivateEndpointsResponse>(
+ new com.google.common.base.Supplier() {
+ @Override
+ public ListPrivateEndpointsRequest.Builder get() {
+ return ListPrivateEndpointsRequest.builder().copy(request);
+ }
+ },
+ new com.google.common.base.Function() {
+ @Override
+ public String apply(ListPrivateEndpointsResponse response) {
+ return response.getOpcNextPage();
+ }
+ },
+ new com.google.common.base.Function<
+ com.oracle.bmc.paginator.internal.RequestBuilderAndToken<
+ ListPrivateEndpointsRequest.Builder>,
+ ListPrivateEndpointsRequest>() {
+ @Override
+ public ListPrivateEndpointsRequest apply(
+ com.oracle.bmc.paginator.internal.RequestBuilderAndToken<
+ ListPrivateEndpointsRequest.Builder>
+ input) {
+ if (input.getToken() == null) {
+ return input.getRequestBuilder().build();
+ } else {
+ return input.getRequestBuilder()
+ .page(input.getToken().orNull())
+ .build();
+ }
+ }
+ },
+ new com.google.common.base.Function<
+ ListPrivateEndpointsRequest, ListPrivateEndpointsResponse>() {
+ @Override
+ public ListPrivateEndpointsResponse apply(ListPrivateEndpointsRequest request) {
+ return client.listPrivateEndpoints(request);
+ }
+ });
+ }
+
+ /**
+ * Creates a new iterable which will iterate over the {@link com.oracle.bmc.dataflow.model.PrivateEndpointSummary} objects
+ * contained in responses from the listPrivateEndpoints operation. This iterable will fetch more data from the
+ * server as needed.
+ *
+ * @param request a request which can be sent to the service operation
+ * @return an {@link java.lang.Iterable} which can be used to iterate over the {@link com.oracle.bmc.dataflow.model.PrivateEndpointSummary} objects
+ * contained in responses received from the service.
+ */
+ public Iterable
+ listPrivateEndpointsRecordIterator(final ListPrivateEndpointsRequest request) {
+ return new com.oracle.bmc.paginator.internal.ResponseRecordIterable<
+ ListPrivateEndpointsRequest.Builder, ListPrivateEndpointsRequest,
+ ListPrivateEndpointsResponse, com.oracle.bmc.dataflow.model.PrivateEndpointSummary>(
+ new com.google.common.base.Supplier() {
+ @Override
+ public ListPrivateEndpointsRequest.Builder get() {
+ return ListPrivateEndpointsRequest.builder().copy(request);
+ }
+ },
+ new com.google.common.base.Function() {
+ @Override
+ public String apply(ListPrivateEndpointsResponse response) {
+ return response.getOpcNextPage();
+ }
+ },
+ new com.google.common.base.Function<
+ com.oracle.bmc.paginator.internal.RequestBuilderAndToken<
+ ListPrivateEndpointsRequest.Builder>,
+ ListPrivateEndpointsRequest>() {
+ @Override
+ public ListPrivateEndpointsRequest apply(
+ com.oracle.bmc.paginator.internal.RequestBuilderAndToken<
+ ListPrivateEndpointsRequest.Builder>
+ input) {
+ if (input.getToken() == null) {
+ return input.getRequestBuilder().build();
+ } else {
+ return input.getRequestBuilder()
+ .page(input.getToken().orNull())
+ .build();
+ }
+ }
+ },
+ new com.google.common.base.Function<
+ ListPrivateEndpointsRequest, ListPrivateEndpointsResponse>() {
+ @Override
+ public ListPrivateEndpointsResponse apply(ListPrivateEndpointsRequest request) {
+ return client.listPrivateEndpoints(request);
+ }
+ },
+ new com.google.common.base.Function<
+ ListPrivateEndpointsResponse,
+ java.util.List>() {
+ @Override
+ public java.util.List
+ apply(ListPrivateEndpointsResponse response) {
+ return response.getPrivateEndpointCollection().getItems();
+ }
+ });
+ }
+
/**
* Creates a new iterable which will iterate over the responses received from the listRunLogs operation. This iterable
* will fetch more data from the server as needed.
@@ -360,4 +473,344 @@ public java.util.List apply(
}
});
}
+
+ /**
+ * Creates a new iterable which will iterate over the responses received from the listWorkRequestErrors operation. This iterable
+ * will fetch more data from the server as needed.
+ *
+ * @param request a request which can be sent to the service operation
+ * @return an {@link java.lang.Iterable} which can be used to iterate over the responses received from the service.
+ */
+ public Iterable listWorkRequestErrorsResponseIterator(
+ final ListWorkRequestErrorsRequest request) {
+ return new com.oracle.bmc.paginator.internal.ResponseIterable<
+ ListWorkRequestErrorsRequest.Builder, ListWorkRequestErrorsRequest,
+ ListWorkRequestErrorsResponse>(
+ new com.google.common.base.Supplier() {
+ @Override
+ public ListWorkRequestErrorsRequest.Builder get() {
+ return ListWorkRequestErrorsRequest.builder().copy(request);
+ }
+ },
+ new com.google.common.base.Function() {
+ @Override
+ public String apply(ListWorkRequestErrorsResponse response) {
+ return response.getOpcNextPage();
+ }
+ },
+ new com.google.common.base.Function<
+ com.oracle.bmc.paginator.internal.RequestBuilderAndToken<
+ ListWorkRequestErrorsRequest.Builder>,
+ ListWorkRequestErrorsRequest>() {
+ @Override
+ public ListWorkRequestErrorsRequest apply(
+ com.oracle.bmc.paginator.internal.RequestBuilderAndToken<
+ ListWorkRequestErrorsRequest.Builder>
+ input) {
+ if (input.getToken() == null) {
+ return input.getRequestBuilder().build();
+ } else {
+ return input.getRequestBuilder()
+ .page(input.getToken().orNull())
+ .build();
+ }
+ }
+ },
+ new com.google.common.base.Function<
+ ListWorkRequestErrorsRequest, ListWorkRequestErrorsResponse>() {
+ @Override
+ public ListWorkRequestErrorsResponse apply(
+ ListWorkRequestErrorsRequest request) {
+ return client.listWorkRequestErrors(request);
+ }
+ });
+ }
+
+ /**
+ * Creates a new iterable which will iterate over the {@link com.oracle.bmc.dataflow.model.WorkRequestError} objects
+ * contained in responses from the listWorkRequestErrors operation. This iterable will fetch more data from the
+ * server as needed.
+ *
+ * @param request a request which can be sent to the service operation
+ * @return an {@link java.lang.Iterable} which can be used to iterate over the {@link com.oracle.bmc.dataflow.model.WorkRequestError} objects
+ * contained in responses received from the service.
+ */
+ public Iterable
+ listWorkRequestErrorsRecordIterator(final ListWorkRequestErrorsRequest request) {
+ return new com.oracle.bmc.paginator.internal.ResponseRecordIterable<
+ ListWorkRequestErrorsRequest.Builder, ListWorkRequestErrorsRequest,
+ ListWorkRequestErrorsResponse, com.oracle.bmc.dataflow.model.WorkRequestError>(
+ new com.google.common.base.Supplier() {
+ @Override
+ public ListWorkRequestErrorsRequest.Builder get() {
+ return ListWorkRequestErrorsRequest.builder().copy(request);
+ }
+ },
+ new com.google.common.base.Function() {
+ @Override
+ public String apply(ListWorkRequestErrorsResponse response) {
+ return response.getOpcNextPage();
+ }
+ },
+ new com.google.common.base.Function<
+ com.oracle.bmc.paginator.internal.RequestBuilderAndToken<
+ ListWorkRequestErrorsRequest.Builder>,
+ ListWorkRequestErrorsRequest>() {
+ @Override
+ public ListWorkRequestErrorsRequest apply(
+ com.oracle.bmc.paginator.internal.RequestBuilderAndToken<
+ ListWorkRequestErrorsRequest.Builder>
+ input) {
+ if (input.getToken() == null) {
+ return input.getRequestBuilder().build();
+ } else {
+ return input.getRequestBuilder()
+ .page(input.getToken().orNull())
+ .build();
+ }
+ }
+ },
+ new com.google.common.base.Function<
+ ListWorkRequestErrorsRequest, ListWorkRequestErrorsResponse>() {
+ @Override
+ public ListWorkRequestErrorsResponse apply(
+ ListWorkRequestErrorsRequest request) {
+ return client.listWorkRequestErrors(request);
+ }
+ },
+ new com.google.common.base.Function<
+ ListWorkRequestErrorsResponse,
+ java.util.List>() {
+ @Override
+ public java.util.List apply(
+ ListWorkRequestErrorsResponse response) {
+ return response.getWorkRequestErrorCollection().getItems();
+ }
+ });
+ }
+
+ /**
+ * Creates a new iterable which will iterate over the responses received from the listWorkRequestLogs operation. This iterable
+ * will fetch more data from the server as needed.
+ *
+ * @param request a request which can be sent to the service operation
+ * @return an {@link java.lang.Iterable} which can be used to iterate over the responses received from the service.
+ */
+ public Iterable listWorkRequestLogsResponseIterator(
+ final ListWorkRequestLogsRequest request) {
+ return new com.oracle.bmc.paginator.internal.ResponseIterable<
+ ListWorkRequestLogsRequest.Builder, ListWorkRequestLogsRequest,
+ ListWorkRequestLogsResponse>(
+ new com.google.common.base.Supplier() {
+ @Override
+ public ListWorkRequestLogsRequest.Builder get() {
+ return ListWorkRequestLogsRequest.builder().copy(request);
+ }
+ },
+ new com.google.common.base.Function() {
+ @Override
+ public String apply(ListWorkRequestLogsResponse response) {
+ return response.getOpcNextPage();
+ }
+ },
+ new com.google.common.base.Function<
+ com.oracle.bmc.paginator.internal.RequestBuilderAndToken<
+ ListWorkRequestLogsRequest.Builder>,
+ ListWorkRequestLogsRequest>() {
+ @Override
+ public ListWorkRequestLogsRequest apply(
+ com.oracle.bmc.paginator.internal.RequestBuilderAndToken<
+ ListWorkRequestLogsRequest.Builder>
+ input) {
+ if (input.getToken() == null) {
+ return input.getRequestBuilder().build();
+ } else {
+ return input.getRequestBuilder()
+ .page(input.getToken().orNull())
+ .build();
+ }
+ }
+ },
+ new com.google.common.base.Function<
+ ListWorkRequestLogsRequest, ListWorkRequestLogsResponse>() {
+ @Override
+ public ListWorkRequestLogsResponse apply(ListWorkRequestLogsRequest request) {
+ return client.listWorkRequestLogs(request);
+ }
+ });
+ }
+
+ /**
+ * Creates a new iterable which will iterate over the {@link com.oracle.bmc.dataflow.model.WorkRequestLog} objects
+ * contained in responses from the listWorkRequestLogs operation. This iterable will fetch more data from the
+ * server as needed.
+ *
+ * @param request a request which can be sent to the service operation
+ * @return an {@link java.lang.Iterable} which can be used to iterate over the {@link com.oracle.bmc.dataflow.model.WorkRequestLog} objects
+ * contained in responses received from the service.
+ */
+ public Iterable listWorkRequestLogsRecordIterator(
+ final ListWorkRequestLogsRequest request) {
+ return new com.oracle.bmc.paginator.internal.ResponseRecordIterable<
+ ListWorkRequestLogsRequest.Builder, ListWorkRequestLogsRequest,
+ ListWorkRequestLogsResponse, com.oracle.bmc.dataflow.model.WorkRequestLog>(
+ new com.google.common.base.Supplier() {
+ @Override
+ public ListWorkRequestLogsRequest.Builder get() {
+ return ListWorkRequestLogsRequest.builder().copy(request);
+ }
+ },
+ new com.google.common.base.Function() {
+ @Override
+ public String apply(ListWorkRequestLogsResponse response) {
+ return response.getOpcNextPage();
+ }
+ },
+ new com.google.common.base.Function<
+ com.oracle.bmc.paginator.internal.RequestBuilderAndToken<
+ ListWorkRequestLogsRequest.Builder>,
+ ListWorkRequestLogsRequest>() {
+ @Override
+ public ListWorkRequestLogsRequest apply(
+ com.oracle.bmc.paginator.internal.RequestBuilderAndToken<
+ ListWorkRequestLogsRequest.Builder>
+ input) {
+ if (input.getToken() == null) {
+ return input.getRequestBuilder().build();
+ } else {
+ return input.getRequestBuilder()
+ .page(input.getToken().orNull())
+ .build();
+ }
+ }
+ },
+ new com.google.common.base.Function<
+ ListWorkRequestLogsRequest, ListWorkRequestLogsResponse>() {
+ @Override
+ public ListWorkRequestLogsResponse apply(ListWorkRequestLogsRequest request) {
+ return client.listWorkRequestLogs(request);
+ }
+ },
+ new com.google.common.base.Function<
+ ListWorkRequestLogsResponse,
+ java.util.List>() {
+ @Override
+ public java.util.List apply(
+ ListWorkRequestLogsResponse response) {
+ return response.getWorkRequestLogCollection().getItems();
+ }
+ });
+ }
+
+ /**
+ * Creates a new iterable which will iterate over the responses received from the listWorkRequests operation. This iterable
+ * will fetch more data from the server as needed.
+ *
+ * @param request a request which can be sent to the service operation
+ * @return an {@link java.lang.Iterable} which can be used to iterate over the responses received from the service.
+ */
+ public Iterable listWorkRequestsResponseIterator(
+ final ListWorkRequestsRequest request) {
+ return new com.oracle.bmc.paginator.internal.ResponseIterable<
+ ListWorkRequestsRequest.Builder, ListWorkRequestsRequest, ListWorkRequestsResponse>(
+ new com.google.common.base.Supplier() {
+ @Override
+ public ListWorkRequestsRequest.Builder get() {
+ return ListWorkRequestsRequest.builder().copy(request);
+ }
+ },
+ new com.google.common.base.Function() {
+ @Override
+ public String apply(ListWorkRequestsResponse response) {
+ return response.getOpcNextPage();
+ }
+ },
+ new com.google.common.base.Function<
+ com.oracle.bmc.paginator.internal.RequestBuilderAndToken<
+ ListWorkRequestsRequest.Builder>,
+ ListWorkRequestsRequest>() {
+ @Override
+ public ListWorkRequestsRequest apply(
+ com.oracle.bmc.paginator.internal.RequestBuilderAndToken<
+ ListWorkRequestsRequest.Builder>
+ input) {
+ if (input.getToken() == null) {
+ return input.getRequestBuilder().build();
+ } else {
+ return input.getRequestBuilder()
+ .page(input.getToken().orNull())
+ .build();
+ }
+ }
+ },
+ new com.google.common.base.Function<
+ ListWorkRequestsRequest, ListWorkRequestsResponse>() {
+ @Override
+ public ListWorkRequestsResponse apply(ListWorkRequestsRequest request) {
+ return client.listWorkRequests(request);
+ }
+ });
+ }
+
+ /**
+ * Creates a new iterable which will iterate over the {@link com.oracle.bmc.dataflow.model.WorkRequestSummary} objects
+ * contained in responses from the listWorkRequests operation. This iterable will fetch more data from the
+ * server as needed.
+ *
+ * @param request a request which can be sent to the service operation
+ * @return an {@link java.lang.Iterable} which can be used to iterate over the {@link com.oracle.bmc.dataflow.model.WorkRequestSummary} objects
+ * contained in responses received from the service.
+ */
+ public Iterable