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

Interface EnvironmentsGrpc.AsyncService

All Known Implementing Classes:
EnvironmentsGrpc.EnvironmentsImplBase
Enclosing class:
EnvironmentsGrpc
public static interface EnvironmentsGrpc.AsyncService
 Managed Apache Airflow Environments.

  • Method Details

    • createEnvironment

      default void createEnvironment(CreateEnvironmentRequest request, io.grpc.stub.StreamObserver<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<Operation> responseObserver)
       Update an environment.

    • deleteEnvironment

      default void deleteEnvironment(DeleteEnvironmentRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Delete an environment.

    • restartWebServer

      default void restartWebServer(RestartWebServerRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Restart Airflow web server.

    • checkUpgrade

      default void checkUpgrade(CheckUpgradeRequest request, io.grpc.stub.StreamObserver<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

      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.

    • listWorkloads

      default void listWorkloads(ListWorkloadsRequest request, io.grpc.stub.StreamObserver<ListWorkloadsResponse> responseObserver)
       Lists workloads in a Cloud Composer environment. Workload is a unit that
 runs a single Composer component.
 This method is supported for Cloud Composer environments in versions
 composer-2.*.*-airflow-*.*.* and newer.

    • createUserWorkloadsSecret

      default void createUserWorkloadsSecret(CreateUserWorkloadsSecretRequest request, io.grpc.stub.StreamObserver<UserWorkloadsSecret> responseObserver)
       Creates a user workloads Secret.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • getUserWorkloadsSecret

      default void getUserWorkloadsSecret(GetUserWorkloadsSecretRequest request, io.grpc.stub.StreamObserver<UserWorkloadsSecret> responseObserver)
       Gets an existing user workloads Secret.
 Values of the "data" field in the response are cleared.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • listUserWorkloadsSecrets

      default void listUserWorkloadsSecrets(ListUserWorkloadsSecretsRequest request, io.grpc.stub.StreamObserver<ListUserWorkloadsSecretsResponse> responseObserver)
       Lists user workloads Secrets.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • updateUserWorkloadsSecret

      default void updateUserWorkloadsSecret(UpdateUserWorkloadsSecretRequest request, io.grpc.stub.StreamObserver<UserWorkloadsSecret> responseObserver)
       Updates a user workloads Secret.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • deleteUserWorkloadsSecret

      default void deleteUserWorkloadsSecret(DeleteUserWorkloadsSecretRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
       Deletes a user workloads Secret.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • createUserWorkloadsConfigMap

      default void createUserWorkloadsConfigMap(CreateUserWorkloadsConfigMapRequest request, io.grpc.stub.StreamObserver<UserWorkloadsConfigMap> responseObserver)
       Creates a user workloads ConfigMap.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • getUserWorkloadsConfigMap

      default void getUserWorkloadsConfigMap(GetUserWorkloadsConfigMapRequest request, io.grpc.stub.StreamObserver<UserWorkloadsConfigMap> responseObserver)
       Gets an existing user workloads ConfigMap.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • listUserWorkloadsConfigMaps

      default void listUserWorkloadsConfigMaps(ListUserWorkloadsConfigMapsRequest request, io.grpc.stub.StreamObserver<ListUserWorkloadsConfigMapsResponse> responseObserver)
       Lists user workloads ConfigMaps.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • updateUserWorkloadsConfigMap

      default void updateUserWorkloadsConfigMap(UpdateUserWorkloadsConfigMapRequest request, io.grpc.stub.StreamObserver<UserWorkloadsConfigMap> responseObserver)
       Updates a user workloads ConfigMap.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • deleteUserWorkloadsConfigMap

      default void deleteUserWorkloadsConfigMap(DeleteUserWorkloadsConfigMapRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
       Deletes a user workloads ConfigMap.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • saveSnapshot

      default void saveSnapshot(SaveSnapshotRequest request, io.grpc.stub.StreamObserver<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<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<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.