Package com.google.cloud.dataplex.v1
Class DataplexServiceGrpc.DataplexServiceStub
- java.lang.Object
-
- io.grpc.stub.AbstractStub<S>
-
- io.grpc.stub.AbstractAsyncStub<DataplexServiceGrpc.DataplexServiceStub>
-
- com.google.cloud.dataplex.v1.DataplexServiceGrpc.DataplexServiceStub
-
- Enclosing class:
- DataplexServiceGrpc
public static final class DataplexServiceGrpc.DataplexServiceStub extends io.grpc.stub.AbstractAsyncStub<DataplexServiceGrpc.DataplexServiceStub>
A stub to allow clients to do asynchronous 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.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected DataplexServiceGrpc.DataplexServiceStubbuild(io.grpc.Channel channel, io.grpc.CallOptions callOptions)voidcancelJob(CancelJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)Cancel jobs running for the task resource.voidcreateAsset(CreateAssetRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)Creates an asset resource.voidcreateEnvironment(CreateEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)Create an environment resource.voidcreateLake(CreateLakeRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)Creates a lake resource.voidcreateTask(CreateTaskRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)Creates a task resource within a lake.voidcreateZone(CreateZoneRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)Creates a zone resource within a lake.voiddeleteAsset(DeleteAssetRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)Deletes an asset resource.voiddeleteEnvironment(DeleteEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)Delete the environment resource.voiddeleteLake(DeleteLakeRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)Deletes a lake resource.voiddeleteTask(DeleteTaskRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)Delete the task resource.voiddeleteZone(DeleteZoneRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)Deletes a zone resource.voidgetAsset(GetAssetRequest request, io.grpc.stub.StreamObserver<Asset> responseObserver)Retrieves an asset resource.voidgetEnvironment(GetEnvironmentRequest request, io.grpc.stub.StreamObserver<Environment> responseObserver)Get environment resource.voidgetJob(GetJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver)Get job resource.voidgetLake(GetLakeRequest request, io.grpc.stub.StreamObserver<Lake> responseObserver)Retrieves a lake resource.voidgetTask(GetTaskRequest request, io.grpc.stub.StreamObserver<Task> responseObserver)Get task resource.voidgetZone(GetZoneRequest request, io.grpc.stub.StreamObserver<Zone> responseObserver)Retrieves a zone resource.voidlistAssetActions(ListAssetActionsRequest request, io.grpc.stub.StreamObserver<ListActionsResponse> responseObserver)Lists action resources in an asset.voidlistAssets(ListAssetsRequest request, io.grpc.stub.StreamObserver<ListAssetsResponse> responseObserver)Lists asset resources in a zone.voidlistEnvironments(ListEnvironmentsRequest request, io.grpc.stub.StreamObserver<ListEnvironmentsResponse> responseObserver)Lists environments under the given lake.voidlistJobs(ListJobsRequest request, io.grpc.stub.StreamObserver<ListJobsResponse> responseObserver)Lists Jobs under the given task.voidlistLakeActions(ListLakeActionsRequest request, io.grpc.stub.StreamObserver<ListActionsResponse> responseObserver)Lists action resources in a lake.voidlistLakes(ListLakesRequest request, io.grpc.stub.StreamObserver<ListLakesResponse> responseObserver)Lists lake resources in a project and location.voidlistSessions(ListSessionsRequest request, io.grpc.stub.StreamObserver<ListSessionsResponse> responseObserver)Lists session resources in an environment.voidlistTasks(ListTasksRequest request, io.grpc.stub.StreamObserver<ListTasksResponse> responseObserver)Lists tasks under the given lake.voidlistZoneActions(ListZoneActionsRequest request, io.grpc.stub.StreamObserver<ListActionsResponse> responseObserver)Lists action resources in a zone.voidlistZones(ListZonesRequest request, io.grpc.stub.StreamObserver<ListZonesResponse> responseObserver)Lists zone resources in a lake.voidrunTask(RunTaskRequest request, io.grpc.stub.StreamObserver<RunTaskResponse> responseObserver)Run an on demand execution of a Task.voidupdateAsset(UpdateAssetRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)Updates an asset resource.voidupdateEnvironment(UpdateEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)Update the environment resource.voidupdateLake(UpdateLakeRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)Updates a lake resource.voidupdateTask(UpdateTaskRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)Update the task resource.voidupdateZone(UpdateZoneRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)Updates a zone resource.
-
-
-
Method Detail
-
build
protected DataplexServiceGrpc.DataplexServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
- Specified by:
buildin classio.grpc.stub.AbstractStub<DataplexServiceGrpc.DataplexServiceStub>
-
createLake
public void createLake(CreateLakeRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Creates a lake resource.
-
updateLake
public void updateLake(UpdateLakeRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Updates a lake resource.
-
deleteLake
public void deleteLake(DeleteLakeRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes a lake resource. All zones within the lake must be deleted before the lake can be deleted.
-
listLakes
public void listLakes(ListLakesRequest request, io.grpc.stub.StreamObserver<ListLakesResponse> responseObserver)
Lists lake resources in a project and location.
-
getLake
public void getLake(GetLakeRequest request, io.grpc.stub.StreamObserver<Lake> responseObserver)
Retrieves a lake resource.
-
listLakeActions
public void listLakeActions(ListLakeActionsRequest request, io.grpc.stub.StreamObserver<ListActionsResponse> responseObserver)
Lists action resources in a lake.
-
createZone
public void createZone(CreateZoneRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Creates a zone resource within a lake.
-
updateZone
public void updateZone(UpdateZoneRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Updates a zone resource.
-
deleteZone
public void deleteZone(DeleteZoneRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes a zone resource. All assets within a zone must be deleted before the zone can be deleted.
-
listZones
public void listZones(ListZonesRequest request, io.grpc.stub.StreamObserver<ListZonesResponse> responseObserver)
Lists zone resources in a lake.
-
getZone
public void getZone(GetZoneRequest request, io.grpc.stub.StreamObserver<Zone> responseObserver)
Retrieves a zone resource.
-
listZoneActions
public void listZoneActions(ListZoneActionsRequest request, io.grpc.stub.StreamObserver<ListActionsResponse> responseObserver)
Lists action resources in a zone.
-
createAsset
public void createAsset(CreateAssetRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Creates an asset resource.
-
updateAsset
public void updateAsset(UpdateAssetRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Updates an asset resource.
-
deleteAsset
public void deleteAsset(DeleteAssetRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes an asset resource. The referenced storage resource is detached (default) or deleted based on the associated Lifecycle policy.
-
listAssets
public void listAssets(ListAssetsRequest request, io.grpc.stub.StreamObserver<ListAssetsResponse> responseObserver)
Lists asset resources in a zone.
-
getAsset
public void getAsset(GetAssetRequest request, io.grpc.stub.StreamObserver<Asset> responseObserver)
Retrieves an asset resource.
-
listAssetActions
public void listAssetActions(ListAssetActionsRequest request, io.grpc.stub.StreamObserver<ListActionsResponse> responseObserver)
Lists action resources in an asset.
-
createTask
public void createTask(CreateTaskRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Creates a task resource within a lake.
-
updateTask
public void updateTask(UpdateTaskRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Update the task resource.
-
deleteTask
public void deleteTask(DeleteTaskRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Delete the task resource.
-
listTasks
public void listTasks(ListTasksRequest request, io.grpc.stub.StreamObserver<ListTasksResponse> responseObserver)
Lists tasks under the given lake.
-
getTask
public void getTask(GetTaskRequest request, io.grpc.stub.StreamObserver<Task> responseObserver)
Get task resource.
-
listJobs
public void listJobs(ListJobsRequest request, io.grpc.stub.StreamObserver<ListJobsResponse> responseObserver)
Lists Jobs under the given task.
-
runTask
public void runTask(RunTaskRequest request, io.grpc.stub.StreamObserver<RunTaskResponse> responseObserver)
Run an on demand execution of a Task.
-
getJob
public void getJob(GetJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver)
Get job resource.
-
cancelJob
public void cancelJob(CancelJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
Cancel jobs running for the task resource.
-
createEnvironment
public void createEnvironment(CreateEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Create an environment resource.
-
updateEnvironment
public void updateEnvironment(UpdateEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Update the environment resource.
-
deleteEnvironment
public void deleteEnvironment(DeleteEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Delete the environment resource. All the child resources must have been deleted before environment deletion can be initiated.
-
listEnvironments
public void listEnvironments(ListEnvironmentsRequest request, io.grpc.stub.StreamObserver<ListEnvironmentsResponse> responseObserver)
Lists environments under the given lake.
-
getEnvironment
public void getEnvironment(GetEnvironmentRequest request, io.grpc.stub.StreamObserver<Environment> responseObserver)
Get environment resource.
-
listSessions
public void listSessions(ListSessionsRequest request, io.grpc.stub.StreamObserver<ListSessionsResponse> responseObserver)
Lists session resources in an environment.
-
-