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.DataplexServiceStub
build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void
cancelJob(CancelJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
Cancel jobs running for the task resource.void
createAsset(CreateAssetRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Creates an asset resource.void
createEnvironment(CreateEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Create an environment resource.void
createLake(CreateLakeRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Creates a lake resource.void
createTask(CreateTaskRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Creates a task resource within a lake.void
createZone(CreateZoneRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Creates a zone resource within a lake.void
deleteAsset(DeleteAssetRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes an asset resource.void
deleteEnvironment(DeleteEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Delete the environment resource.void
deleteLake(DeleteLakeRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes a lake resource.void
deleteTask(DeleteTaskRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Delete the task resource.void
deleteZone(DeleteZoneRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes a zone resource.void
getAsset(GetAssetRequest request, io.grpc.stub.StreamObserver<Asset> responseObserver)
Retrieves an asset resource.void
getEnvironment(GetEnvironmentRequest request, io.grpc.stub.StreamObserver<Environment> responseObserver)
Get environment resource.void
getJob(GetJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver)
Get job resource.void
getLake(GetLakeRequest request, io.grpc.stub.StreamObserver<Lake> responseObserver)
Retrieves a lake resource.void
getTask(GetTaskRequest request, io.grpc.stub.StreamObserver<Task> responseObserver)
Get task resource.void
getZone(GetZoneRequest request, io.grpc.stub.StreamObserver<Zone> responseObserver)
Retrieves a zone resource.void
listAssetActions(ListAssetActionsRequest request, io.grpc.stub.StreamObserver<ListActionsResponse> responseObserver)
Lists action resources in an asset.void
listAssets(ListAssetsRequest request, io.grpc.stub.StreamObserver<ListAssetsResponse> responseObserver)
Lists asset resources in a zone.void
listEnvironments(ListEnvironmentsRequest request, io.grpc.stub.StreamObserver<ListEnvironmentsResponse> responseObserver)
Lists environments under the given lake.void
listJobs(ListJobsRequest request, io.grpc.stub.StreamObserver<ListJobsResponse> responseObserver)
Lists Jobs under the given task.void
listLakeActions(ListLakeActionsRequest request, io.grpc.stub.StreamObserver<ListActionsResponse> responseObserver)
Lists action resources in a lake.void
listLakes(ListLakesRequest request, io.grpc.stub.StreamObserver<ListLakesResponse> responseObserver)
Lists lake resources in a project and location.void
listSessions(ListSessionsRequest request, io.grpc.stub.StreamObserver<ListSessionsResponse> responseObserver)
Lists session resources in an environment.void
listTasks(ListTasksRequest request, io.grpc.stub.StreamObserver<ListTasksResponse> responseObserver)
Lists tasks under the given lake.void
listZoneActions(ListZoneActionsRequest request, io.grpc.stub.StreamObserver<ListActionsResponse> responseObserver)
Lists action resources in a zone.void
listZones(ListZonesRequest request, io.grpc.stub.StreamObserver<ListZonesResponse> responseObserver)
Lists zone resources in a lake.void
runTask(RunTaskRequest request, io.grpc.stub.StreamObserver<RunTaskResponse> responseObserver)
Run an on demand execution of a Task.void
updateAsset(UpdateAssetRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Updates an asset resource.void
updateEnvironment(UpdateEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Update the environment resource.void
updateLake(UpdateLakeRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Updates a lake resource.void
updateTask(UpdateTaskRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Update the task resource.void
updateZone(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:
build
in 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.
-
-