Package com.google.cloud.orchestration.airflow.service.v1beta1

Class EnvironmentsGrpc.EnvironmentsStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<EnvironmentsGrpc.EnvironmentsStub>

com.google.cloud.orchestration.airflow.service.v1beta1.EnvironmentsGrpc.EnvironmentsStub

Enclosing class:

EnvironmentsGrpc

public static final class EnvironmentsGrpc.EnvironmentsStub
extends io.grpc.stub.AbstractAsyncStub<EnvironmentsGrpc.EnvironmentsStub>

A stub to allow clients to do asynchronous rpc calls to service Environments.

 Managed Apache Airflow Environments.
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
protected EnvironmentsGrpc.EnvironmentsStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	checkUpgrade(CheckUpgradeRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)	Check if an upgrade operation on the environment will succeed.
void	createEnvironment(CreateEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)	Create a new environment.
void	databaseFailover(DatabaseFailoverRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)	Triggers database failover (only for highly resilient environments).
void	deleteEnvironment(DeleteEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)	Delete an environment.
void	executeAirflowCommand(ExecuteAirflowCommandRequest request, io.grpc.stub.StreamObserver<ExecuteAirflowCommandResponse> responseObserver)	Executes Airflow CLI command.
void	fetchDatabaseProperties(FetchDatabasePropertiesRequest request, io.grpc.stub.StreamObserver<FetchDatabasePropertiesResponse> responseObserver)	Fetches database properties.
void	getEnvironment(GetEnvironmentRequest request, io.grpc.stub.StreamObserver<Environment> responseObserver)	Get an existing environment.
void	listEnvironments(ListEnvironmentsRequest request, io.grpc.stub.StreamObserver<ListEnvironmentsResponse> responseObserver)	List environments.
void	loadSnapshot(LoadSnapshotRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)	Loads a snapshot of a Cloud Composer environment.
void	pollAirflowCommand(PollAirflowCommandRequest request, io.grpc.stub.StreamObserver<PollAirflowCommandResponse> responseObserver)	Polls Airflow CLI command execution and fetches logs.
void	restartWebServer(RestartWebServerRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)	Restart Airflow web server.
void	saveSnapshot(SaveSnapshotRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)	Creates a snapshots of a Cloud Composer environment.
void	stopAirflowCommand(StopAirflowCommandRequest request, io.grpc.stub.StreamObserver<StopAirflowCommandResponse> responseObserver)	Stops Airflow CLI command execution.
void	updateEnvironment(UpdateEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)	Update an environment.

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

build

protected EnvironmentsGrpc.EnvironmentsStub build(io.grpc.Channel channel,
                                                  io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<EnvironmentsGrpc.EnvironmentsStub>

createEnvironment

public void createEnvironment(CreateEnvironmentRequest request,
                              io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)

 Create a new environment.
 

getEnvironment

public void getEnvironment(GetEnvironmentRequest request,
                           io.grpc.stub.StreamObserver<Environment> responseObserver)

 Get an existing environment.
 

listEnvironments

public void listEnvironments(ListEnvironmentsRequest request,
                             io.grpc.stub.StreamObserver<ListEnvironmentsResponse> responseObserver)

 List environments.
 

updateEnvironment

public void updateEnvironment(UpdateEnvironmentRequest request,
                              io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)

 Update an environment.
 

deleteEnvironment

public void deleteEnvironment(DeleteEnvironmentRequest request,
                              io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)

 Delete an environment.
 

restartWebServer

public void restartWebServer(RestartWebServerRequest request,
                             io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)

 Restart Airflow web server.
 

checkUpgrade

public void checkUpgrade(CheckUpgradeRequest request,
                         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)

 Check if an upgrade operation on the environment will succeed.
 In case of problems detailed info can be found in the returned Operation.
 

executeAirflowCommand

public void executeAirflowCommand(ExecuteAirflowCommandRequest request,
                                  io.grpc.stub.StreamObserver<ExecuteAirflowCommandResponse> responseObserver)

 Executes Airflow CLI command.
 

stopAirflowCommand

public void stopAirflowCommand(StopAirflowCommandRequest request,
                               io.grpc.stub.StreamObserver<StopAirflowCommandResponse> responseObserver)

 Stops Airflow CLI command execution.
 

pollAirflowCommand

public void pollAirflowCommand(PollAirflowCommandRequest request,
                               io.grpc.stub.StreamObserver<PollAirflowCommandResponse> responseObserver)

 Polls Airflow CLI command execution and fetches logs.
 

saveSnapshot

public void saveSnapshot(SaveSnapshotRequest request,
                         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)

 Creates a snapshots of a Cloud Composer environment.
 As a result of this operation, snapshot of environment's state is stored
 in a location specified in the SaveSnapshotRequest.
 

loadSnapshot

public void loadSnapshot(LoadSnapshotRequest request,
                         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)

 Loads a snapshot of a Cloud Composer environment.
 As a result of this operation, a snapshot of environment's specified in
 LoadSnapshotRequest is loaded into the environment.
 

databaseFailover

public void databaseFailover(DatabaseFailoverRequest request,
                             io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)

 Triggers database failover (only for highly resilient environments).
 

fetchDatabaseProperties

public void fetchDatabaseProperties(FetchDatabasePropertiesRequest request,
                                    io.grpc.stub.StreamObserver<FetchDatabasePropertiesResponse> responseObserver)

 Fetches database properties.