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

TelcoAutomation Service manages the control plane cluster a.k.a. Orchestration Cluster (GKE cluster with config controller) of TNA. It also exposes blueprint APIs which manages the lifecycle of blueprints that control the infrastructure setup (e.g GDCE clusters) and deployment of network functions.

Implementations§

source§

impl<T> TelcoAutomationClient<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, ) -> TelcoAutomationClient<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_orchestration_clusters( &mut self, request: impl IntoRequest<ListOrchestrationClustersRequest>, ) -> Result<Response<ListOrchestrationClustersResponse>, Status>

Lists OrchestrationClusters in a given project and location.

source

pub async fn get_orchestration_cluster( &mut self, request: impl IntoRequest<GetOrchestrationClusterRequest>, ) -> Result<Response<OrchestrationCluster>, Status>

Gets details of a single OrchestrationCluster.

source

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

Creates a new OrchestrationCluster in a given project and location.

source

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

Deletes a single OrchestrationCluster.

source

pub async fn list_edge_slms( &mut self, request: impl IntoRequest<ListEdgeSlmsRequest>, ) -> Result<Response<ListEdgeSlmsResponse>, Status>

Lists EdgeSlms in a given project and location.

source

pub async fn get_edge_slm( &mut self, request: impl IntoRequest<GetEdgeSlmRequest>, ) -> Result<Response<EdgeSlm>, Status>

Gets details of a single EdgeSlm.

source

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

Creates a new EdgeSlm in a given project and location.

source

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

Deletes a single EdgeSlm.

source

pub async fn create_blueprint( &mut self, request: impl IntoRequest<CreateBlueprintRequest>, ) -> Result<Response<Blueprint>, Status>

Creates a blueprint.

source

pub async fn update_blueprint( &mut self, request: impl IntoRequest<UpdateBlueprintRequest>, ) -> Result<Response<Blueprint>, Status>

Updates a blueprint.

source

pub async fn get_blueprint( &mut self, request: impl IntoRequest<GetBlueprintRequest>, ) -> Result<Response<Blueprint>, Status>

Returns the requested blueprint.

source

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

Deletes a blueprint and all its revisions.

source

pub async fn list_blueprints( &mut self, request: impl IntoRequest<ListBlueprintsRequest>, ) -> Result<Response<ListBlueprintsResponse>, Status>

List all blueprints.

source

pub async fn approve_blueprint( &mut self, request: impl IntoRequest<ApproveBlueprintRequest>, ) -> Result<Response<Blueprint>, Status>

Approves a blueprint and commits a new revision.

source

pub async fn propose_blueprint( &mut self, request: impl IntoRequest<ProposeBlueprintRequest>, ) -> Result<Response<Blueprint>, Status>

Proposes a blueprint for approval of changes.

source

pub async fn reject_blueprint( &mut self, request: impl IntoRequest<RejectBlueprintRequest>, ) -> Result<Response<Blueprint>, Status>

Rejects a blueprint revision proposal and flips it back to Draft state.

source

pub async fn list_blueprint_revisions( &mut self, request: impl IntoRequest<ListBlueprintRevisionsRequest>, ) -> Result<Response<ListBlueprintRevisionsResponse>, Status>

List blueprint revisions of a given blueprint.

source

pub async fn search_blueprint_revisions( &mut self, request: impl IntoRequest<SearchBlueprintRevisionsRequest>, ) -> Result<Response<SearchBlueprintRevisionsResponse>, Status>

Searches across blueprint revisions.

source

pub async fn search_deployment_revisions( &mut self, request: impl IntoRequest<SearchDeploymentRevisionsRequest>, ) -> Result<Response<SearchDeploymentRevisionsResponse>, Status>

Searches across deployment revisions.

source

pub async fn discard_blueprint_changes( &mut self, request: impl IntoRequest<DiscardBlueprintChangesRequest>, ) -> Result<Response<DiscardBlueprintChangesResponse>, Status>

Discards the changes in a blueprint and reverts the blueprint to the last approved blueprint revision. No changes take place if a blueprint does not have revisions.

source

pub async fn list_public_blueprints( &mut self, request: impl IntoRequest<ListPublicBlueprintsRequest>, ) -> Result<Response<ListPublicBlueprintsResponse>, Status>

Lists the blueprints in TNA’s public catalog. Default page size = 20, Max Page Size = 100.

source

pub async fn get_public_blueprint( &mut self, request: impl IntoRequest<GetPublicBlueprintRequest>, ) -> Result<Response<PublicBlueprint>, Status>

Returns the requested public blueprint.

source

pub async fn create_deployment( &mut self, request: impl IntoRequest<CreateDeploymentRequest>, ) -> Result<Response<Deployment>, Status>

Creates a deployment.

source

pub async fn update_deployment( &mut self, request: impl IntoRequest<UpdateDeploymentRequest>, ) -> Result<Response<Deployment>, Status>

Updates a deployment.

source

pub async fn get_deployment( &mut self, request: impl IntoRequest<GetDeploymentRequest>, ) -> Result<Response<Deployment>, Status>

Returns the requested deployment.

source

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

Removes the deployment by marking it as DELETING. Post which deployment and it’s revisions gets deleted.

source

pub async fn list_deployments( &mut self, request: impl IntoRequest<ListDeploymentsRequest>, ) -> Result<Response<ListDeploymentsResponse>, Status>

List all deployments.

source

pub async fn list_deployment_revisions( &mut self, request: impl IntoRequest<ListDeploymentRevisionsRequest>, ) -> Result<Response<ListDeploymentRevisionsResponse>, Status>

List deployment revisions of a given deployment.

source

pub async fn discard_deployment_changes( &mut self, request: impl IntoRequest<DiscardDeploymentChangesRequest>, ) -> Result<Response<DiscardDeploymentChangesResponse>, Status>

Discards the changes in a deployment and reverts the deployment to the last approved deployment revision. No changes take place if a deployment does not have revisions.

source

pub async fn apply_deployment( &mut self, request: impl IntoRequest<ApplyDeploymentRequest>, ) -> Result<Response<Deployment>, Status>

Applies the deployment’s YAML files to the parent orchestration cluster.

source

pub async fn compute_deployment_status( &mut self, request: impl IntoRequest<ComputeDeploymentStatusRequest>, ) -> Result<Response<ComputeDeploymentStatusResponse>, Status>

Returns the requested deployment status.

source

pub async fn rollback_deployment( &mut self, request: impl IntoRequest<RollbackDeploymentRequest>, ) -> Result<Response<Deployment>, Status>

Rollback the active deployment to the given past approved deployment revision.

source

pub async fn get_hydrated_deployment( &mut self, request: impl IntoRequest<GetHydratedDeploymentRequest>, ) -> Result<Response<HydratedDeployment>, Status>

Returns the requested hydrated deployment.

source

pub async fn list_hydrated_deployments( &mut self, request: impl IntoRequest<ListHydratedDeploymentsRequest>, ) -> Result<Response<ListHydratedDeploymentsResponse>, Status>

List all hydrated deployments present under a deployment.

source

pub async fn update_hydrated_deployment( &mut self, request: impl IntoRequest<UpdateHydratedDeploymentRequest>, ) -> Result<Response<HydratedDeployment>, Status>

Updates a hydrated deployment.

source

pub async fn apply_hydrated_deployment( &mut self, request: impl IntoRequest<ApplyHydratedDeploymentRequest>, ) -> Result<Response<HydratedDeployment>, Status>

Applies a hydrated deployment to a workload cluster.

Trait Implementations§

source§

impl<T: Clone> Clone for TelcoAutomationClient<T>

source§

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

§

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

§

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

§

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

§

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

§

impl<T> UnwindSafe for TelcoAutomationClient<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