{
private DataplexServiceBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected DataplexServiceBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new DataplexServiceBlockingStub(channel, callOptions);
}
/**
*
*
*
* Creates a lake resource.
*
*/
public com.google.longrunning.Operation createLake(
com.google.cloud.dataplex.v1.CreateLakeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateLakeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates a lake resource.
*
*/
public com.google.longrunning.Operation updateLake(
com.google.cloud.dataplex.v1.UpdateLakeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateLakeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a lake resource. All zones within the lake must be deleted before
* the lake can be deleted.
*
*/
public com.google.longrunning.Operation deleteLake(
com.google.cloud.dataplex.v1.DeleteLakeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteLakeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists lake resources in a project and location.
*
*/
public com.google.cloud.dataplex.v1.ListLakesResponse listLakes(
com.google.cloud.dataplex.v1.ListLakesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListLakesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Retrieves a lake resource.
*
*/
public com.google.cloud.dataplex.v1.Lake getLake(
com.google.cloud.dataplex.v1.GetLakeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetLakeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists action resources in a lake.
*
*/
public com.google.cloud.dataplex.v1.ListActionsResponse listLakeActions(
com.google.cloud.dataplex.v1.ListLakeActionsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListLakeActionsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a zone resource within a lake.
*
*/
public com.google.longrunning.Operation createZone(
com.google.cloud.dataplex.v1.CreateZoneRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateZoneMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates a zone resource.
*
*/
public com.google.longrunning.Operation updateZone(
com.google.cloud.dataplex.v1.UpdateZoneRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateZoneMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a zone resource. All assets within a zone must be deleted before
* the zone can be deleted.
*
*/
public com.google.longrunning.Operation deleteZone(
com.google.cloud.dataplex.v1.DeleteZoneRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteZoneMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists zone resources in a lake.
*
*/
public com.google.cloud.dataplex.v1.ListZonesResponse listZones(
com.google.cloud.dataplex.v1.ListZonesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListZonesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Retrieves a zone resource.
*
*/
public com.google.cloud.dataplex.v1.Zone getZone(
com.google.cloud.dataplex.v1.GetZoneRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetZoneMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists action resources in a zone.
*
*/
public com.google.cloud.dataplex.v1.ListActionsResponse listZoneActions(
com.google.cloud.dataplex.v1.ListZoneActionsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListZoneActionsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates an asset resource.
*
*/
public com.google.longrunning.Operation createAsset(
com.google.cloud.dataplex.v1.CreateAssetRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateAssetMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates an asset resource.
*
*/
public com.google.longrunning.Operation updateAsset(
com.google.cloud.dataplex.v1.UpdateAssetRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateAssetMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes an asset resource. The referenced storage resource is detached
* (default) or deleted based on the associated Lifecycle policy.
*
*/
public com.google.longrunning.Operation deleteAsset(
com.google.cloud.dataplex.v1.DeleteAssetRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteAssetMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists asset resources in a zone.
*
*/
public com.google.cloud.dataplex.v1.ListAssetsResponse listAssets(
com.google.cloud.dataplex.v1.ListAssetsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListAssetsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Retrieves an asset resource.
*
*/
public com.google.cloud.dataplex.v1.Asset getAsset(
com.google.cloud.dataplex.v1.GetAssetRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetAssetMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists action resources in an asset.
*
*/
public com.google.cloud.dataplex.v1.ListActionsResponse listAssetActions(
com.google.cloud.dataplex.v1.ListAssetActionsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListAssetActionsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a task resource within a lake.
*
*/
public com.google.longrunning.Operation createTask(
com.google.cloud.dataplex.v1.CreateTaskRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateTaskMethod(), getCallOptions(), request);
}
/**
*
*
*
* Update the task resource.
*
*/
public com.google.longrunning.Operation updateTask(
com.google.cloud.dataplex.v1.UpdateTaskRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateTaskMethod(), getCallOptions(), request);
}
/**
*
*
*
* Delete the task resource.
*
*/
public com.google.longrunning.Operation deleteTask(
com.google.cloud.dataplex.v1.DeleteTaskRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteTaskMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists tasks under the given lake.
*
*/
public com.google.cloud.dataplex.v1.ListTasksResponse listTasks(
com.google.cloud.dataplex.v1.ListTasksRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListTasksMethod(), getCallOptions(), request);
}
/**
*
*
*
* Get task resource.
*
*/
public com.google.cloud.dataplex.v1.Task getTask(
com.google.cloud.dataplex.v1.GetTaskRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetTaskMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists Jobs under the given task.
*
*/
public com.google.cloud.dataplex.v1.ListJobsResponse listJobs(
com.google.cloud.dataplex.v1.ListJobsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListJobsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Run an on demand execution of a Task.
*
*/
public com.google.cloud.dataplex.v1.RunTaskResponse runTask(
com.google.cloud.dataplex.v1.RunTaskRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getRunTaskMethod(), getCallOptions(), request);
}
/**
*
*
*
* Get job resource.
*
*/
public com.google.cloud.dataplex.v1.Job getJob(
com.google.cloud.dataplex.v1.GetJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Cancel jobs running for the task resource.
*
*/
public com.google.protobuf.Empty cancelJob(
com.google.cloud.dataplex.v1.CancelJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCancelJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Create an environment resource.
*
*/
public com.google.longrunning.Operation createEnvironment(
com.google.cloud.dataplex.v1.CreateEnvironmentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateEnvironmentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Update the environment resource.
*
*/
public com.google.longrunning.Operation updateEnvironment(
com.google.cloud.dataplex.v1.UpdateEnvironmentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateEnvironmentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Delete the environment resource. All the child resources must have been
* deleted before environment deletion can be initiated.
*
*/
public com.google.longrunning.Operation deleteEnvironment(
com.google.cloud.dataplex.v1.DeleteEnvironmentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteEnvironmentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists environments under the given lake.
*
*/
public com.google.cloud.dataplex.v1.ListEnvironmentsResponse listEnvironments(
com.google.cloud.dataplex.v1.ListEnvironmentsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListEnvironmentsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Get environment resource.
*
*/
public com.google.cloud.dataplex.v1.Environment getEnvironment(
com.google.cloud.dataplex.v1.GetEnvironmentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetEnvironmentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists session resources in an environment.
*
*/
public com.google.cloud.dataplex.v1.ListSessionsResponse listSessions(
com.google.cloud.dataplex.v1.ListSessionsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListSessionsMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service DataplexService.
*
*
* Dataplex service provides data lakes as a service. The primary resources
* offered by this service are Lakes, Zones and Assets which collectively allow
* a data administrator to organize, manage, secure and catalog data across
* their organization located across cloud projects in a variety of storage
* systems including Cloud Storage and BigQuery.
*
*/
public static final class DataplexServiceFutureStub
extends io.grpc.stub.AbstractFutureStub {
private DataplexServiceFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected DataplexServiceFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new DataplexServiceFutureStub(channel, callOptions);
}
/**
*
*
*
* Creates a lake resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createLake(com.google.cloud.dataplex.v1.CreateLakeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateLakeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates a lake resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateLake(com.google.cloud.dataplex.v1.UpdateLakeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateLakeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a lake resource. All zones within the lake must be deleted before
* the lake can be deleted.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteLake(com.google.cloud.dataplex.v1.DeleteLakeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteLakeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists lake resources in a project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dataplex.v1.ListLakesResponse>
listLakes(com.google.cloud.dataplex.v1.ListLakesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListLakesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Retrieves a lake resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getLake(com.google.cloud.dataplex.v1.GetLakeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetLakeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists action resources in a lake.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dataplex.v1.ListActionsResponse>
listLakeActions(com.google.cloud.dataplex.v1.ListLakeActionsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListLakeActionsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a zone resource within a lake.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createZone(com.google.cloud.dataplex.v1.CreateZoneRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateZoneMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates a zone resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateZone(com.google.cloud.dataplex.v1.UpdateZoneRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateZoneMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a zone resource. All assets within a zone must be deleted before
* the zone can be deleted.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteZone(com.google.cloud.dataplex.v1.DeleteZoneRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteZoneMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists zone resources in a lake.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dataplex.v1.ListZonesResponse>
listZones(com.google.cloud.dataplex.v1.ListZonesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListZonesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Retrieves a zone resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getZone(com.google.cloud.dataplex.v1.GetZoneRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetZoneMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists action resources in a zone.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dataplex.v1.ListActionsResponse>
listZoneActions(com.google.cloud.dataplex.v1.ListZoneActionsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListZoneActionsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates an asset resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createAsset(com.google.cloud.dataplex.v1.CreateAssetRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateAssetMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates an asset resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateAsset(com.google.cloud.dataplex.v1.UpdateAssetRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateAssetMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes an asset resource. The referenced storage resource is detached
* (default) or deleted based on the associated Lifecycle policy.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteAsset(com.google.cloud.dataplex.v1.DeleteAssetRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteAssetMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists asset resources in a zone.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dataplex.v1.ListAssetsResponse>
listAssets(com.google.cloud.dataplex.v1.ListAssetsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListAssetsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Retrieves an asset resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getAsset(com.google.cloud.dataplex.v1.GetAssetRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetAssetMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists action resources in an asset.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dataplex.v1.ListActionsResponse>
listAssetActions(com.google.cloud.dataplex.v1.ListAssetActionsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListAssetActionsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a task resource within a lake.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createTask(com.google.cloud.dataplex.v1.CreateTaskRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateTaskMethod(), getCallOptions()), request);
}
/**
*
*
*
* Update the task resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateTask(com.google.cloud.dataplex.v1.UpdateTaskRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateTaskMethod(), getCallOptions()), request);
}
/**
*
*
*
* Delete the task resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteTask(com.google.cloud.dataplex.v1.DeleteTaskRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteTaskMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists tasks under the given lake.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dataplex.v1.ListTasksResponse>
listTasks(com.google.cloud.dataplex.v1.ListTasksRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListTasksMethod(), getCallOptions()), request);
}
/**
*
*
*
* Get task resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getTask(com.google.cloud.dataplex.v1.GetTaskRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetTaskMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists Jobs under the given task.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dataplex.v1.ListJobsResponse>
listJobs(com.google.cloud.dataplex.v1.ListJobsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListJobsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Run an on demand execution of a Task.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dataplex.v1.RunTaskResponse>
runTask(com.google.cloud.dataplex.v1.RunTaskRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getRunTaskMethod(), getCallOptions()), request);
}
/**
*
*
*
* Get job resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getJob(com.google.cloud.dataplex.v1.GetJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Cancel jobs running for the task resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture cancelJob(
com.google.cloud.dataplex.v1.CancelJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCancelJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Create an environment resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createEnvironment(com.google.cloud.dataplex.v1.CreateEnvironmentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateEnvironmentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Update the environment resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateEnvironment(com.google.cloud.dataplex.v1.UpdateEnvironmentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateEnvironmentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Delete the environment resource. All the child resources must have been
* deleted before environment deletion can be initiated.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteEnvironment(com.google.cloud.dataplex.v1.DeleteEnvironmentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteEnvironmentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists environments under the given lake.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dataplex.v1.ListEnvironmentsResponse>
listEnvironments(com.google.cloud.dataplex.v1.ListEnvironmentsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListEnvironmentsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Get environment resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dataplex.v1.Environment>
getEnvironment(com.google.cloud.dataplex.v1.GetEnvironmentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetEnvironmentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists session resources in an environment.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dataplex.v1.ListSessionsResponse>
listSessions(com.google.cloud.dataplex.v1.ListSessionsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListSessionsMethod(), getCallOptions()), request);
}
}
private static final int METHODID_CREATE_LAKE = 0;
private static final int METHODID_UPDATE_LAKE = 1;
private static final int METHODID_DELETE_LAKE = 2;
private static final int METHODID_LIST_LAKES = 3;
private static final int METHODID_GET_LAKE = 4;
private static final int METHODID_LIST_LAKE_ACTIONS = 5;
private static final int METHODID_CREATE_ZONE = 6;
private static final int METHODID_UPDATE_ZONE = 7;
private static final int METHODID_DELETE_ZONE = 8;
private static final int METHODID_LIST_ZONES = 9;
private static final int METHODID_GET_ZONE = 10;
private static final int METHODID_LIST_ZONE_ACTIONS = 11;
private static final int METHODID_CREATE_ASSET = 12;
private static final int METHODID_UPDATE_ASSET = 13;
private static final int METHODID_DELETE_ASSET = 14;
private static final int METHODID_LIST_ASSETS = 15;
private static final int METHODID_GET_ASSET = 16;
private static final int METHODID_LIST_ASSET_ACTIONS = 17;
private static final int METHODID_CREATE_TASK = 18;
private static final int METHODID_UPDATE_TASK = 19;
private static final int METHODID_DELETE_TASK = 20;
private static final int METHODID_LIST_TASKS = 21;
private static final int METHODID_GET_TASK = 22;
private static final int METHODID_LIST_JOBS = 23;
private static final int METHODID_RUN_TASK = 24;
private static final int METHODID_GET_JOB = 25;
private static final int METHODID_CANCEL_JOB = 26;
private static final int METHODID_CREATE_ENVIRONMENT = 27;
private static final int METHODID_UPDATE_ENVIRONMENT = 28;
private static final int METHODID_DELETE_ENVIRONMENT = 29;
private static final int METHODID_LIST_ENVIRONMENTS = 30;
private static final int METHODID_GET_ENVIRONMENT = 31;
private static final int METHODID_LIST_SESSIONS = 32;
private static final class MethodHandlers
implements io.grpc.stub.ServerCalls.UnaryMethod,
io.grpc.stub.ServerCalls.ServerStreamingMethod,
io.grpc.stub.ServerCalls.ClientStreamingMethod,
io.grpc.stub.ServerCalls.BidiStreamingMethod {
private final AsyncService serviceImpl;
private final int methodId;
MethodHandlers(AsyncService serviceImpl, int methodId) {
this.serviceImpl = serviceImpl;
this.methodId = methodId;
}
@java.lang.Override
@java.lang.SuppressWarnings("unchecked")
public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
case METHODID_CREATE_LAKE:
serviceImpl.createLake(
(com.google.cloud.dataplex.v1.CreateLakeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_LAKE:
serviceImpl.updateLake(
(com.google.cloud.dataplex.v1.UpdateLakeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_LAKE:
serviceImpl.deleteLake(
(com.google.cloud.dataplex.v1.DeleteLakeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_LAKES:
serviceImpl.listLakes(
(com.google.cloud.dataplex.v1.ListLakesRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_LAKE:
serviceImpl.getLake(
(com.google.cloud.dataplex.v1.GetLakeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_LAKE_ACTIONS:
serviceImpl.listLakeActions(
(com.google.cloud.dataplex.v1.ListLakeActionsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_ZONE:
serviceImpl.createZone(
(com.google.cloud.dataplex.v1.CreateZoneRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_ZONE:
serviceImpl.updateZone(
(com.google.cloud.dataplex.v1.UpdateZoneRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_ZONE:
serviceImpl.deleteZone(
(com.google.cloud.dataplex.v1.DeleteZoneRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_ZONES:
serviceImpl.listZones(
(com.google.cloud.dataplex.v1.ListZonesRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_ZONE:
serviceImpl.getZone(
(com.google.cloud.dataplex.v1.GetZoneRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_ZONE_ACTIONS:
serviceImpl.listZoneActions(
(com.google.cloud.dataplex.v1.ListZoneActionsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_ASSET:
serviceImpl.createAsset(
(com.google.cloud.dataplex.v1.CreateAssetRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_ASSET:
serviceImpl.updateAsset(
(com.google.cloud.dataplex.v1.UpdateAssetRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_ASSET:
serviceImpl.deleteAsset(
(com.google.cloud.dataplex.v1.DeleteAssetRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_ASSETS:
serviceImpl.listAssets(
(com.google.cloud.dataplex.v1.ListAssetsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_ASSET:
serviceImpl.getAsset(
(com.google.cloud.dataplex.v1.GetAssetRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_ASSET_ACTIONS:
serviceImpl.listAssetActions(
(com.google.cloud.dataplex.v1.ListAssetActionsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_TASK:
serviceImpl.createTask(
(com.google.cloud.dataplex.v1.CreateTaskRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_TASK:
serviceImpl.updateTask(
(com.google.cloud.dataplex.v1.UpdateTaskRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_TASK:
serviceImpl.deleteTask(
(com.google.cloud.dataplex.v1.DeleteTaskRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_TASKS:
serviceImpl.listTasks(
(com.google.cloud.dataplex.v1.ListTasksRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_TASK:
serviceImpl.getTask(
(com.google.cloud.dataplex.v1.GetTaskRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_JOBS:
serviceImpl.listJobs(
(com.google.cloud.dataplex.v1.ListJobsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_RUN_TASK:
serviceImpl.runTask(
(com.google.cloud.dataplex.v1.RunTaskRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_JOB:
serviceImpl.getJob(
(com.google.cloud.dataplex.v1.GetJobRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_CANCEL_JOB:
serviceImpl.cancelJob(
(com.google.cloud.dataplex.v1.CancelJobRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_CREATE_ENVIRONMENT:
serviceImpl.createEnvironment(
(com.google.cloud.dataplex.v1.CreateEnvironmentRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_ENVIRONMENT:
serviceImpl.updateEnvironment(
(com.google.cloud.dataplex.v1.UpdateEnvironmentRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_ENVIRONMENT:
serviceImpl.deleteEnvironment(
(com.google.cloud.dataplex.v1.DeleteEnvironmentRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_ENVIRONMENTS:
serviceImpl.listEnvironments(
(com.google.cloud.dataplex.v1.ListEnvironmentsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_ENVIRONMENT:
serviceImpl.getEnvironment(
(com.google.cloud.dataplex.v1.GetEnvironmentRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_SESSIONS:
serviceImpl.listSessions(
(com.google.cloud.dataplex.v1.ListSessionsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
default:
throw new AssertionError();
}
}
@java.lang.Override
@java.lang.SuppressWarnings("unchecked")
public io.grpc.stub.StreamObserver invoke(
io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
default:
throw new AssertionError();
}
}
}
public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getCreateLakeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.CreateLakeRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_LAKE)))
.addMethod(
getUpdateLakeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.UpdateLakeRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_LAKE)))
.addMethod(
getDeleteLakeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.DeleteLakeRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_LAKE)))
.addMethod(
getListLakesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.ListLakesRequest,
com.google.cloud.dataplex.v1.ListLakesResponse>(service, METHODID_LIST_LAKES)))
.addMethod(
getGetLakeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.GetLakeRequest, com.google.cloud.dataplex.v1.Lake>(
service, METHODID_GET_LAKE)))
.addMethod(
getListLakeActionsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.ListLakeActionsRequest,
com.google.cloud.dataplex.v1.ListActionsResponse>(
service, METHODID_LIST_LAKE_ACTIONS)))
.addMethod(
getCreateZoneMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.CreateZoneRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_ZONE)))
.addMethod(
getUpdateZoneMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.UpdateZoneRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_ZONE)))
.addMethod(
getDeleteZoneMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.DeleteZoneRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_ZONE)))
.addMethod(
getListZonesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.ListZonesRequest,
com.google.cloud.dataplex.v1.ListZonesResponse>(service, METHODID_LIST_ZONES)))
.addMethod(
getGetZoneMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.GetZoneRequest, com.google.cloud.dataplex.v1.Zone>(
service, METHODID_GET_ZONE)))
.addMethod(
getListZoneActionsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.ListZoneActionsRequest,
com.google.cloud.dataplex.v1.ListActionsResponse>(
service, METHODID_LIST_ZONE_ACTIONS)))
.addMethod(
getCreateAssetMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.CreateAssetRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_ASSET)))
.addMethod(
getUpdateAssetMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.UpdateAssetRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_ASSET)))
.addMethod(
getDeleteAssetMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.DeleteAssetRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_ASSET)))
.addMethod(
getListAssetsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.ListAssetsRequest,
com.google.cloud.dataplex.v1.ListAssetsResponse>(
service, METHODID_LIST_ASSETS)))
.addMethod(
getGetAssetMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.GetAssetRequest,
com.google.cloud.dataplex.v1.Asset>(service, METHODID_GET_ASSET)))
.addMethod(
getListAssetActionsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.ListAssetActionsRequest,
com.google.cloud.dataplex.v1.ListActionsResponse>(
service, METHODID_LIST_ASSET_ACTIONS)))
.addMethod(
getCreateTaskMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.CreateTaskRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_TASK)))
.addMethod(
getUpdateTaskMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.UpdateTaskRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_TASK)))
.addMethod(
getDeleteTaskMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.DeleteTaskRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_TASK)))
.addMethod(
getListTasksMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.ListTasksRequest,
com.google.cloud.dataplex.v1.ListTasksResponse>(service, METHODID_LIST_TASKS)))
.addMethod(
getGetTaskMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.GetTaskRequest, com.google.cloud.dataplex.v1.Task>(
service, METHODID_GET_TASK)))
.addMethod(
getListJobsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.ListJobsRequest,
com.google.cloud.dataplex.v1.ListJobsResponse>(service, METHODID_LIST_JOBS)))
.addMethod(
getRunTaskMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.RunTaskRequest,
com.google.cloud.dataplex.v1.RunTaskResponse>(service, METHODID_RUN_TASK)))
.addMethod(
getGetJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.GetJobRequest, com.google.cloud.dataplex.v1.Job>(
service, METHODID_GET_JOB)))
.addMethod(
getCancelJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.CancelJobRequest, com.google.protobuf.Empty>(
service, METHODID_CANCEL_JOB)))
.addMethod(
getCreateEnvironmentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.CreateEnvironmentRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_ENVIRONMENT)))
.addMethod(
getUpdateEnvironmentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.UpdateEnvironmentRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_ENVIRONMENT)))
.addMethod(
getDeleteEnvironmentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.DeleteEnvironmentRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_ENVIRONMENT)))
.addMethod(
getListEnvironmentsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.ListEnvironmentsRequest,
com.google.cloud.dataplex.v1.ListEnvironmentsResponse>(
service, METHODID_LIST_ENVIRONMENTS)))
.addMethod(
getGetEnvironmentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.GetEnvironmentRequest,
com.google.cloud.dataplex.v1.Environment>(service, METHODID_GET_ENVIRONMENT)))
.addMethod(
getListSessionsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dataplex.v1.ListSessionsRequest,
com.google.cloud.dataplex.v1.ListSessionsResponse>(
service, METHODID_LIST_SESSIONS)))
.build();
}
private abstract static class DataplexServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
DataplexServiceBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.dataplex.v1.ServiceProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("DataplexService");
}
}
private static final class DataplexServiceFileDescriptorSupplier
extends DataplexServiceBaseDescriptorSupplier {
DataplexServiceFileDescriptorSupplier() {}
}
private static final class DataplexServiceMethodDescriptorSupplier
extends DataplexServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
DataplexServiceMethodDescriptorSupplier(String methodName) {
this.methodName = methodName;
}
@java.lang.Override
public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
return getServiceDescriptor().findMethodByName(methodName);
}
}
private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
public static io.grpc.ServiceDescriptor getServiceDescriptor() {
io.grpc.ServiceDescriptor result = serviceDescriptor;
if (result == null) {
synchronized (DataplexServiceGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new DataplexServiceFileDescriptorSupplier())
.addMethod(getCreateLakeMethod())
.addMethod(getUpdateLakeMethod())
.addMethod(getDeleteLakeMethod())
.addMethod(getListLakesMethod())
.addMethod(getGetLakeMethod())
.addMethod(getListLakeActionsMethod())
.addMethod(getCreateZoneMethod())
.addMethod(getUpdateZoneMethod())
.addMethod(getDeleteZoneMethod())
.addMethod(getListZonesMethod())
.addMethod(getGetZoneMethod())
.addMethod(getListZoneActionsMethod())
.addMethod(getCreateAssetMethod())
.addMethod(getUpdateAssetMethod())
.addMethod(getDeleteAssetMethod())
.addMethod(getListAssetsMethod())
.addMethod(getGetAssetMethod())
.addMethod(getListAssetActionsMethod())
.addMethod(getCreateTaskMethod())
.addMethod(getUpdateTaskMethod())
.addMethod(getDeleteTaskMethod())
.addMethod(getListTasksMethod())
.addMethod(getGetTaskMethod())
.addMethod(getListJobsMethod())
.addMethod(getRunTaskMethod())
.addMethod(getGetJobMethod())
.addMethod(getCancelJobMethod())
.addMethod(getCreateEnvironmentMethod())
.addMethod(getUpdateEnvironmentMethod())
.addMethod(getDeleteEnvironmentMethod())
.addMethod(getListEnvironmentsMethod())
.addMethod(getGetEnvironmentMethod())
.addMethod(getListSessionsMethod())
.build();
}
}
}
return result;
}
}