Struct google_api_proto::google::container::v1beta1::cluster_manager_client::ClusterManagerClient

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

Google Kubernetes Engine Cluster Manager v1beta1

Implementations

impl<T> ClusterManagerClient<T>

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

pub fn new(inner: T) -> Self

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

pub fn with_interceptor<F>( inner: T, interceptor: F ) -> ClusterManagerClient<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,

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.

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

Enable decompressing responses.

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

Limits the maximum size of a decoded message.

Default: 4MB

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

Limits the maximum size of an encoded message.

Default: usize::MAX

pub async fn list_clusters( &mut self, request: impl IntoRequest<ListClustersRequest> ) -> Result<Response<ListClustersResponse>, Status>

Lists all clusters owned by a project in either the specified zone or all zones.

pub async fn get_cluster( &mut self, request: impl IntoRequest<GetClusterRequest> ) -> Result<Response<Cluster>, Status>

Gets the details for a specific cluster.

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

Creates a cluster, consisting of the specified number and type of Google Compute Engine instances.

By default, the cluster is created in the project’s default network.

One firewall is added for the cluster. After cluster creation, the Kubelet creates routes for each node to allow the containers on that node to communicate with all other instances in the cluster.

Finally, an entry is added to the project’s global metadata indicating which CIDR range the cluster is using.

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

Updates the settings for a specific cluster.

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

Updates the version and/or image type of a specific node pool.

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

Sets the autoscaling settings of a specific node pool.

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

Sets the logging service for a specific cluster.

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

Sets the monitoring service for a specific cluster.

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

Sets the addons for a specific cluster.

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

Sets the locations for a specific cluster. Deprecated. Use projects.locations.clusters.update instead.

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

Updates the master for a specific cluster.

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

Sets master auth materials. Currently supports changing the admin password or a specific cluster, either via password generation or explicitly setting the password.

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

Deletes the cluster, including the Kubernetes endpoint and all worker nodes.

Firewalls and routes that were configured during cluster creation are also deleted.

Other Google Compute Engine resources that might be in use by the cluster, such as load balancer resources, are not deleted if they weren’t present when the cluster was initially created.

pub async fn list_operations( &mut self, request: impl IntoRequest<ListOperationsRequest> ) -> Result<Response<ListOperationsResponse>, Status>

Lists all operations in a project in the specified zone or all zones.

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

Gets the specified operation.

pub async fn cancel_operation( &mut self, request: impl IntoRequest<CancelOperationRequest> ) -> Result<Response<()>, Status>

Cancels the specified operation.

pub async fn get_server_config( &mut self, request: impl IntoRequest<GetServerConfigRequest> ) -> Result<Response<ServerConfig>, Status>

Returns configuration info about the Google Kubernetes Engine service.

pub async fn get_json_web_keys( &mut self, request: impl IntoRequest<GetJsonWebKeysRequest> ) -> Result<Response<GetJsonWebKeysResponse>, Status>

Gets the public component of the cluster signing keys in JSON Web Key format.

pub async fn list_node_pools( &mut self, request: impl IntoRequest<ListNodePoolsRequest> ) -> Result<Response<ListNodePoolsResponse>, Status>

Lists the node pools for a cluster.

pub async fn get_node_pool( &mut self, request: impl IntoRequest<GetNodePoolRequest> ) -> Result<Response<NodePool>, Status>

Retrieves the requested node pool.

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

Creates a node pool for a cluster.

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

Deletes a node pool from a cluster.

pub async fn complete_node_pool_upgrade( &mut self, request: impl IntoRequest<CompleteNodePoolUpgradeRequest> ) -> Result<Response<()>, Status>

CompleteNodePoolUpgrade will signal an on-going node pool upgrade to complete.

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

Rolls back a previously Aborted or Failed NodePool upgrade. This makes no changes if the last upgrade successfully completed.

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

Sets the NodeManagement options for a node pool.

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

Sets labels on a cluster.

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

Enables or disables the ABAC authorization mechanism on a cluster.

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

Starts master IP rotation.

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

Completes master IP rotation.

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

SetNodePoolSizeRequest sets the size of a node pool. The new size will be used for all replicas, including future replicas created by modifying [NodePool.locations][google.container.v1beta1.NodePool.locations].

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

Enables or disables Network Policy for a cluster.

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

Sets the maintenance policy for a cluster.

pub async fn list_usable_subnetworks( &mut self, request: impl IntoRequest<ListUsableSubnetworksRequest> ) -> Result<Response<ListUsableSubnetworksResponse>, Status>

Lists subnetworks that can be used for creating clusters in a project.

pub async fn check_autopilot_compatibility( &mut self, request: impl IntoRequest<CheckAutopilotCompatibilityRequest> ) -> Result<Response<CheckAutopilotCompatibilityResponse>, Status>

Checks the cluster compatibility with Autopilot mode, and returns a list of compatibility issues.

pub async fn list_locations( &mut self, request: impl IntoRequest<ListLocationsRequest> ) -> Result<Response<ListLocationsResponse>, Status>

Fetches locations that offer Google Kubernetes Engine.

Trait Implementations

impl<T: Clone> Clone for ClusterManagerClient<T>

fn clone(&self) -> ClusterManagerClient<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for ClusterManagerClient<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.