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

Class EnvironmentsGrpc.EnvironmentsFutureStub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractFutureStub<EnvironmentsGrpc.EnvironmentsFutureStub>
com.google.cloud.orchestration.airflow.service.v1beta1.EnvironmentsGrpc.EnvironmentsFutureStub
Enclosing class:
EnvironmentsGrpc
public static final class EnvironmentsGrpc.EnvironmentsFutureStub extends io.grpc.stub.AbstractFutureStub<EnvironmentsGrpc.EnvironmentsFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service Environments. 
 Managed Apache Airflow Environments.

  • Method Details

    • build

      protected EnvironmentsGrpc.EnvironmentsFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<EnvironmentsGrpc.EnvironmentsFutureStub>

    • createEnvironment

      public com.google.common.util.concurrent.ListenableFuture<Operation> createEnvironment(CreateEnvironmentRequest request)
       Create a new environment.

    • getEnvironment

      public com.google.common.util.concurrent.ListenableFuture<Environment> getEnvironment(GetEnvironmentRequest request)
       Get an existing environment.

    • listEnvironments

      public com.google.common.util.concurrent.ListenableFuture<ListEnvironmentsResponse> listEnvironments(ListEnvironmentsRequest request)
       List environments.

    • updateEnvironment

      public com.google.common.util.concurrent.ListenableFuture<Operation> updateEnvironment(UpdateEnvironmentRequest request)
       Update an environment.

    • deleteEnvironment

      public com.google.common.util.concurrent.ListenableFuture<Operation> deleteEnvironment(DeleteEnvironmentRequest request)
       Delete an environment.

    • restartWebServer

      public com.google.common.util.concurrent.ListenableFuture<Operation> restartWebServer(RestartWebServerRequest request)
       Restart Airflow web server.

    • checkUpgrade

      public com.google.common.util.concurrent.ListenableFuture<Operation> checkUpgrade(CheckUpgradeRequest request)
       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 com.google.common.util.concurrent.ListenableFuture<ExecuteAirflowCommandResponse> executeAirflowCommand(ExecuteAirflowCommandRequest request)
       Executes Airflow CLI command.

    • stopAirflowCommand

      public com.google.common.util.concurrent.ListenableFuture<StopAirflowCommandResponse> stopAirflowCommand(StopAirflowCommandRequest request)
       Stops Airflow CLI command execution.

    • pollAirflowCommand

      public com.google.common.util.concurrent.ListenableFuture<PollAirflowCommandResponse> pollAirflowCommand(PollAirflowCommandRequest request)
       Polls Airflow CLI command execution and fetches logs.

    • listWorkloads

      public com.google.common.util.concurrent.ListenableFuture<ListWorkloadsResponse> listWorkloads(ListWorkloadsRequest request)
       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

      public com.google.common.util.concurrent.ListenableFuture<UserWorkloadsSecret> createUserWorkloadsSecret(CreateUserWorkloadsSecretRequest request)
       Creates a user workloads Secret.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • getUserWorkloadsSecret

      public com.google.common.util.concurrent.ListenableFuture<UserWorkloadsSecret> getUserWorkloadsSecret(GetUserWorkloadsSecretRequest request)
       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

      public com.google.common.util.concurrent.ListenableFuture<ListUserWorkloadsSecretsResponse> listUserWorkloadsSecrets(ListUserWorkloadsSecretsRequest request)
       Lists user workloads Secrets.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • updateUserWorkloadsSecret

      public com.google.common.util.concurrent.ListenableFuture<UserWorkloadsSecret> updateUserWorkloadsSecret(UpdateUserWorkloadsSecretRequest request)
       Updates a user workloads Secret.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • deleteUserWorkloadsSecret

      public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteUserWorkloadsSecret(DeleteUserWorkloadsSecretRequest request)
       Deletes a user workloads Secret.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • createUserWorkloadsConfigMap

      public com.google.common.util.concurrent.ListenableFuture<UserWorkloadsConfigMap> createUserWorkloadsConfigMap(CreateUserWorkloadsConfigMapRequest request)
       Creates a user workloads ConfigMap.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • getUserWorkloadsConfigMap

      public com.google.common.util.concurrent.ListenableFuture<UserWorkloadsConfigMap> getUserWorkloadsConfigMap(GetUserWorkloadsConfigMapRequest request)
       Gets an existing user workloads ConfigMap.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • listUserWorkloadsConfigMaps

      public com.google.common.util.concurrent.ListenableFuture<ListUserWorkloadsConfigMapsResponse> listUserWorkloadsConfigMaps(ListUserWorkloadsConfigMapsRequest request)
       Lists user workloads ConfigMaps.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • updateUserWorkloadsConfigMap

      public com.google.common.util.concurrent.ListenableFuture<UserWorkloadsConfigMap> updateUserWorkloadsConfigMap(UpdateUserWorkloadsConfigMapRequest request)
       Updates a user workloads ConfigMap.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • deleteUserWorkloadsConfigMap

      public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteUserWorkloadsConfigMap(DeleteUserWorkloadsConfigMapRequest request)
       Deletes a user workloads ConfigMap.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • saveSnapshot

      public com.google.common.util.concurrent.ListenableFuture<Operation> saveSnapshot(SaveSnapshotRequest request)
       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 com.google.common.util.concurrent.ListenableFuture<Operation> loadSnapshot(LoadSnapshotRequest request)
       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 com.google.common.util.concurrent.ListenableFuture<Operation> databaseFailover(DatabaseFailoverRequest request)
       Triggers database failover (only for highly resilient environments).

    • fetchDatabaseProperties

      public com.google.common.util.concurrent.ListenableFuture<FetchDatabasePropertiesResponse> fetchDatabaseProperties(FetchDatabasePropertiesRequest request)
       Fetches database properties.