pub struct AlloyDbAdminClient<T> { /* private fields */ }
Expand description

Service describing handlers for resources

Implementations§

source§

impl<T> AlloyDbAdminClient<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, ) -> AlloyDbAdminClient<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 list_clusters( &mut self, request: impl IntoRequest<ListClustersRequest>, ) -> Result<Response<ListClustersResponse>, Status>

Lists Clusters in a given project and location.

source

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

Gets details of a single Cluster.

source

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

Creates a new Cluster in a given project and location.

source

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

Updates the parameters of a single Cluster.

source

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

Deletes a single Cluster.

source

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

Promotes a SECONDARY cluster. This turns down replication from the PRIMARY cluster and promotes a secondary cluster into its own standalone cluster. Imperative only.

source

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

Creates a new Cluster in a given project and location, with a volume restored from the provided source, either a backup ID or a point-in-time and a source cluster.

source

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

Creates a cluster of type SECONDARY in the given location using the primary cluster as the source.

source

pub async fn list_instances( &mut self, request: impl IntoRequest<ListInstancesRequest>, ) -> Result<Response<ListInstancesResponse>, Status>

Lists Instances in a given project and location.

source

pub async fn get_instance( &mut self, request: impl IntoRequest<GetInstanceRequest>, ) -> Result<Response<Instance>, Status>

Gets details of a single Instance.

source

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

Creates a new Instance in a given project and location.

source

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

Creates a new SECONDARY Instance in a given project and location.

source

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

Creates new instances under the given project, location and cluster. There can be only one primary instance in a cluster. If the primary instance exists in the cluster as well as this request, then API will throw an error. The primary instance should exist before any read pool instance is created. If the primary instance is a part of the request payload, then the API will take care of creating instances in the correct order. This method is here to support Google-internal use cases, and is not meant for external customers to consume. Please do not start relying on it; its behavior is subject to change without notice.

source

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

Updates the parameters of a single Instance.

source

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

Deletes a single Instance.

source

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

Forces a Failover for a highly available instance. Failover promotes the HA standby instance as the new primary. Imperative only.

source

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

Injects fault in an instance. Imperative only.

source

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

Restart an Instance in a cluster. Imperative only.

source

pub async fn list_backups( &mut self, request: impl IntoRequest<ListBackupsRequest>, ) -> Result<Response<ListBackupsResponse>, Status>

Lists Backups in a given project and location.

source

pub async fn get_backup( &mut self, request: impl IntoRequest<GetBackupRequest>, ) -> Result<Response<Backup>, Status>

Gets details of a single Backup.

source

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

Creates a new Backup in a given project and location.

source

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

Updates the parameters of a single Backup.

source

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

Deletes a single Backup.

source

pub async fn list_supported_database_flags( &mut self, request: impl IntoRequest<ListSupportedDatabaseFlagsRequest>, ) -> Result<Response<ListSupportedDatabaseFlagsResponse>, Status>

Lists SupportedDatabaseFlags for a given project and location.

source

pub async fn generate_client_certificate( &mut self, request: impl IntoRequest<GenerateClientCertificateRequest>, ) -> Result<Response<GenerateClientCertificateResponse>, Status>

Generate a client certificate signed by a Cluster CA. The sole purpose of this endpoint is to support AlloyDB connectors and the Auth Proxy client. The endpoint’s behavior is subject to change without notice, so do not rely on its behavior remaining constant. Future changes will not break AlloyDB connectors or the Auth Proxy client.

source

pub async fn get_connection_info( &mut self, request: impl IntoRequest<GetConnectionInfoRequest>, ) -> Result<Response<ConnectionInfo>, Status>

Get instance metadata used for a connection.

source

pub async fn list_users( &mut self, request: impl IntoRequest<ListUsersRequest>, ) -> Result<Response<ListUsersResponse>, Status>

Lists Users in a given project and location.

source

pub async fn get_user( &mut self, request: impl IntoRequest<GetUserRequest>, ) -> Result<Response<User>, Status>

Gets details of a single User.

source

pub async fn create_user( &mut self, request: impl IntoRequest<CreateUserRequest>, ) -> Result<Response<User>, Status>

Creates a new User in a given project, location, and cluster.

source

pub async fn update_user( &mut self, request: impl IntoRequest<UpdateUserRequest>, ) -> Result<Response<User>, Status>

Updates the parameters of a single User.

source

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

Deletes a single User.

Trait Implementations§

source§

impl<T: Clone> Clone for AlloyDbAdminClient<T>

source§

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

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl<T: Debug> Debug for AlloyDbAdminClient<T>

source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<T> !Freeze for AlloyDbAdminClient<T>

§

impl<T> RefUnwindSafe for AlloyDbAdminClient<T>
where T: RefUnwindSafe,

§

impl<T> Send for AlloyDbAdminClient<T>
where T: Send,

§

impl<T> Sync for AlloyDbAdminClient<T>
where T: Sync,

§

impl<T> Unpin for AlloyDbAdminClient<T>
where T: Unpin,

§

impl<T> UnwindSafe for AlloyDbAdminClient<T>
where T: UnwindSafe,

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> FromRef<T> for T
where T: Clone,

§

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.
§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> IntoRequest<T> for T

source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
source§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V

§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more