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

RuntimeConfig API represents configuration objects and operations on those configuration objects. RuntimeConfig objects consist of Variables logically grouped in the those objects. Variables are simple key-value pairs. Variables can be watched for changes or deletions. Variable key can be hieararchical, e.g. ports/serving_port, ports/monitoring_port, etc. Variable names can be hierarchical. No variable name can be prefix of another. Config objects represent logical containers for variables, e.g. flags, passwords, etc.

Implementations§

source§

impl<T> RuntimeConfigManagerClient<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, ) -> RuntimeConfigManagerClient<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_configs( &mut self, request: impl IntoRequest<ListConfigsRequest>, ) -> Result<Response<ListConfigsResponse>, Status>

Lists all the RuntimeConfig resources within project.

source

pub async fn get_config( &mut self, request: impl IntoRequest<GetConfigRequest>, ) -> Result<Response<RuntimeConfig>, Status>

Gets information about a RuntimeConfig resource.

source

pub async fn create_config( &mut self, request: impl IntoRequest<CreateConfigRequest>, ) -> Result<Response<RuntimeConfig>, Status>

Creates a new RuntimeConfig resource. The configuration name must be unique within project.

source

pub async fn update_config( &mut self, request: impl IntoRequest<UpdateConfigRequest>, ) -> Result<Response<RuntimeConfig>, Status>

Updates a RuntimeConfig resource. The configuration must exist beforehand.

source

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

Deletes a RuntimeConfig resource.

source

pub async fn list_variables( &mut self, request: impl IntoRequest<ListVariablesRequest>, ) -> Result<Response<ListVariablesResponse>, Status>

Lists variables within given a configuration, matching any provided filters. This only lists variable names, not the values, unless return_values is true, in which case only variables that user has IAM permission to GetVariable will be returned.

source

pub async fn get_variable( &mut self, request: impl IntoRequest<GetVariableRequest>, ) -> Result<Response<Variable>, Status>

Gets information about a single variable.

source

pub async fn watch_variable( &mut self, request: impl IntoRequest<WatchVariableRequest>, ) -> Result<Response<Variable>, Status>

Watches a specific variable and waits for a change in the variable’s value. When there is a change, this method returns the new value or times out.

If a variable is deleted while being watched, the variableState state is set to DELETED and the method returns the last known variable value.

If you set the deadline for watching to a larger value than internal timeout (60 seconds), the current variable value is returned and the variableState will be VARIABLE_STATE_UNSPECIFIED.

To learn more about creating a watcher, read the Watching a Variable for Changes documentation.

source

pub async fn create_variable( &mut self, request: impl IntoRequest<CreateVariableRequest>, ) -> Result<Response<Variable>, Status>

Creates a variable within the given configuration. You cannot create a variable with a name that is a prefix of an existing variable name, or a name that has an existing variable name as a prefix.

To learn more about creating a variable, read the Setting and Getting Data documentation.

source

pub async fn update_variable( &mut self, request: impl IntoRequest<UpdateVariableRequest>, ) -> Result<Response<Variable>, Status>

Updates an existing variable with a new value.

source

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

Deletes a variable or multiple variables.

If you specify a variable name, then that variable is deleted. If you specify a prefix and recursive is true, then all variables with that prefix are deleted. You must set a recursive to true if you delete variables by prefix.

source

pub async fn list_waiters( &mut self, request: impl IntoRequest<ListWaitersRequest>, ) -> Result<Response<ListWaitersResponse>, Status>

List waiters within the given configuration.

source

pub async fn get_waiter( &mut self, request: impl IntoRequest<GetWaiterRequest>, ) -> Result<Response<Waiter>, Status>

Gets information about a single waiter.

source

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

Creates a Waiter resource. This operation returns a long-running Operation resource which can be polled for completion. However, a waiter with the given name will exist (and can be retrieved) prior to the operation completing. If the operation fails, the failed Waiter resource will still exist and must be deleted prior to subsequent creation attempts.

source

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

Deletes the waiter with the specified name.

Trait Implementations§

source§

impl<T: Clone> Clone for RuntimeConfigManagerClient<T>

source§

fn clone(&self) -> RuntimeConfigManagerClient<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 RuntimeConfigManagerClient<T>

source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

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