Struct google_api_proto::google::cloud::orchestration::airflow::service::v1beta1::environments_client::EnvironmentsClient

source ·

pub struct EnvironmentsClient<T> { /* private fields */ }

Expand description

Managed Apache Airflow Environments.

Implementations§

source §

impl<T> EnvironmentsClient<T>
where T: GrpcService<BoxBody>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

source

pub fn new(inner: T) -> Self

source

pub fn with_origin(inner: T, origin: Uri) -> Self

source

pub fn with_interceptor<F>( inner: T, interceptor: F, ) -> EnvironmentsClient<InterceptedService<T, F>>
where F: Interceptor, T::ResponseBody: Default, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

source

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

source

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing responses.

source

pub fn max_decoding_message_size(self, limit: usize) -> Self

Limits the maximum size of a decoded message.

Default: 4MB

source

pub fn max_encoding_message_size(self, limit: usize) -> Self

Limits the maximum size of an encoded message.

Default: usize::MAX

source

pub async fn create_environment( &mut self, request: impl IntoRequest<CreateEnvironmentRequest>, ) -> Result<Response<Operation>, Status>

Create a new environment.

source

pub async fn get_environment( &mut self, request: impl IntoRequest<GetEnvironmentRequest>, ) -> Result<Response<Environment>, Status>

Get an existing environment.

source

pub async fn list_environments( &mut self, request: impl IntoRequest<ListEnvironmentsRequest>, ) -> Result<Response<ListEnvironmentsResponse>, Status>

List environments.

source

pub async fn update_environment( &mut self, request: impl IntoRequest<UpdateEnvironmentRequest>, ) -> Result<Response<Operation>, Status>

Update an environment.

source

pub async fn delete_environment( &mut self, request: impl IntoRequest<DeleteEnvironmentRequest>, ) -> Result<Response<Operation>, Status>

Delete an environment.

source

pub async fn restart_web_server( &mut self, request: impl IntoRequest<RestartWebServerRequest>, ) -> Result<Response<Operation>, Status>

Restart Airflow web server.

source

pub async fn check_upgrade( &mut self, request: impl IntoRequest<CheckUpgradeRequest>, ) -> Result<Response<Operation>, Status>

Check if an upgrade operation on the environment will succeed.

In case of problems detailed info can be found in the returned Operation.

source

pub async fn execute_airflow_command( &mut self, request: impl IntoRequest<ExecuteAirflowCommandRequest>, ) -> Result<Response<ExecuteAirflowCommandResponse>, Status>

Executes Airflow CLI command.

source

pub async fn stop_airflow_command( &mut self, request: impl IntoRequest<StopAirflowCommandRequest>, ) -> Result<Response<StopAirflowCommandResponse>, Status>

Stops Airflow CLI command execution.

source

pub async fn poll_airflow_command( &mut self, request: impl IntoRequest<PollAirflowCommandRequest>, ) -> Result<Response<PollAirflowCommandResponse>, Status>

Polls Airflow CLI command execution and fetches logs.

source

pub async fn list_workloads( &mut self, request: impl IntoRequest<ListWorkloadsRequest>, ) -> Result<Response<ListWorkloadsResponse>, Status>

Lists workloads in a Cloud Composer environment. Workload is a unit that runs a single Composer component.