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

Interface EnvironmentsGrpc.AsyncService

All Known Implementing Classes:

EnvironmentsGrpc.EnvironmentsImplBase

Enclosing class:

EnvironmentsGrpc

public static interface EnvironmentsGrpc.AsyncService

 Managed Apache Airflow Environments.
 

Method Summary

Modifier and Type	Method	Description
default void	createEnvironment(CreateEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)	Create a new environment.
default void	databaseFailover(DatabaseFailoverRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)	Triggers database failover (only for highly resilient environments).
default void	deleteEnvironment(DeleteEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)	Delete an environment.
default void	executeAirflowCommand(ExecuteAirflowCommandRequest request, io.grpc.stub.StreamObserver<ExecuteAirflowCommandResponse> responseObserver)	Executes Airflow CLI command.
default void	fetchDatabaseProperties(FetchDatabasePropertiesRequest request, io.grpc.stub.StreamObserver<FetchDatabasePropertiesResponse> responseObserver)	Fetches database properties.
default void	getEnvironment(GetEnvironmentRequest request, io.grpc.stub.StreamObserver<Environment> responseObserver)	Get an existing environment.
default void	listEnvironments(ListEnvironmentsRequest request, io.grpc.stub.StreamObserver<ListEnvironmentsResponse> responseObserver)	List environments.
default void	loadSnapshot(LoadSnapshotRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)	Loads a snapshot of a Cloud Composer environment.
default void	pollAirflowCommand(PollAirflowCommandRequest request, io.grpc.stub.StreamObserver<PollAirflowCommandResponse> responseObserver)	Polls Airflow CLI command execution and fetches logs.
default void	saveSnapshot(SaveSnapshotRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)	Creates a snapshots of a Cloud Composer environment.
default void	stopAirflowCommand(StopAirflowCommandRequest request, io.grpc.stub.StreamObserver<StopAirflowCommandResponse> responseObserver)	Stops Airflow CLI command execution.
default void	updateEnvironment(UpdateEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)	Update an environment.

Method Detail

createEnvironment

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

 Create a new environment.
 

getEnvironment

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

 Get an existing environment.
 

listEnvironments

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

 List environments.
 

updateEnvironment

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

 Update an environment.
 

deleteEnvironment

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

 Delete an environment.
 

executeAirflowCommand

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

 Executes Airflow CLI command.
 

stopAirflowCommand

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

 Stops Airflow CLI command execution.
 

pollAirflowCommand

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

 Polls Airflow CLI command execution and fetches logs.
 

saveSnapshot

default 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

default 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

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

 Triggers database failover (only for highly resilient environments).
 

fetchDatabaseProperties

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

 Fetches database properties.