Struct MacpRuntimeServiceClient

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

Implementations§

Attempt to create a new client by connecting to a given endpoint.

Compress requests with the given encoding.

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

Enable decompressing responses.

Limits the maximum size of a decoded message.

Default: 4MB

Limits the maximum size of an encoded message.

Default: usize::MAX

Session suspension / resume (RFC-MACP-0001 §7.5)

Extension mode lifecycle

Ambient Signal observation

Session lifecycle observation (RFC-MACP-0001 §7.3)

Governance policy lifecycle (RFC-MACP-0012)

Trait Implementations§

Returns a duplicate of the value. Read more

Performs copy-assignment from source. Read more

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

🔬This is a nightly-only experimental API. (clone_to_uninit)

Performs copy-assignment from self to dest. Read more

Returns the argument unchanged.

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

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

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

Calls U::from(self).

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

Wrap the input message T in a tonic::Request

Applies the layer to a service and wraps it in Layered.

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more

Should always be Self

The resulting type after obtaining ownership.

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

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

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

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

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

Struct MacpRuntimeServiceClient Copy item path

Implementations§

impl MacpRuntimeServiceClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error>where D: TryInto<Endpoint>, D::Error: Into<StdError>,

impl<T> MacpRuntimeServiceClient<T>where T: GrpcService<Body>, 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 send_compressed(self, encoding: CompressionEncoding) -> Self

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

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

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

pub async fn initialize( &mut self, request: impl IntoRequest<InitializeRequest>, ) -> Result<Response<InitializeResponse>, Status>

pub async fn send( &mut self, request: impl IntoRequest<SendRequest>, ) -> Result<Response<SendResponse>, Status>

pub async fn stream_session( &mut self, request: impl IntoStreamingRequest<Message = StreamSessionRequest>, ) -> Result<Response<Streaming<StreamSessionResponse>>, Status>

pub async fn get_session( &mut self, request: impl IntoRequest<GetSessionRequest>, ) -> Result<Response<GetSessionResponse>, Status>

pub async fn cancel_session( &mut self, request: impl IntoRequest<CancelSessionRequest>, ) -> Result<Response<CancelSessionResponse>, Status>

pub async fn suspend_session( &mut self, request: impl IntoRequest<SuspendSessionRequest>, ) -> Result<Response<SuspendSessionResponse>, Status>

pub async fn resume_session( &mut self, request: impl IntoRequest<ResumeSessionRequest>, ) -> Result<Response<ResumeSessionResponse>, Status>

pub async fn get_manifest( &mut self, request: impl IntoRequest<GetManifestRequest>, ) -> Result<Response<GetManifestResponse>, Status>

pub async fn list_modes( &mut self, request: impl IntoRequest<ListModesRequest>, ) -> Result<Response<ListModesResponse>, Status>

pub async fn watch_mode_registry( &mut self, request: impl IntoRequest<WatchModeRegistryRequest>, ) -> Result<Response<Streaming<WatchModeRegistryResponse>>, Status>

pub async fn list_roots( &mut self, request: impl IntoRequest<ListRootsRequest>, ) -> Result<Response<ListRootsResponse>, Status>

pub async fn watch_roots( &mut self, request: impl IntoRequest<WatchRootsRequest>, ) -> Result<Response<Streaming<WatchRootsResponse>>, Status>

pub async fn list_ext_modes( &mut self, request: impl IntoRequest<ListExtModesRequest>, ) -> Result<Response<ListExtModesResponse>, Status>

pub async fn register_ext_mode( &mut self, request: impl IntoRequest<RegisterExtModeRequest>, ) -> Result<Response<RegisterExtModeResponse>, Status>

pub async fn unregister_ext_mode( &mut self, request: impl IntoRequest<UnregisterExtModeRequest>, ) -> Result<Response<UnregisterExtModeResponse>, Status>

pub async fn promote_mode( &mut self, request: impl IntoRequest<PromoteModeRequest>, ) -> Result<Response<PromoteModeResponse>, Status>

pub async fn watch_signals( &mut self, request: impl IntoRequest<WatchSignalsRequest>, ) -> Result<Response<Streaming<WatchSignalsResponse>>, Status>

pub async fn list_sessions( &mut self, request: impl IntoRequest<ListSessionsRequest>, ) -> Result<Response<ListSessionsResponse>, Status>

pub async fn watch_sessions( &mut self, request: impl IntoRequest<WatchSessionsRequest>, ) -> Result<Response<Streaming<WatchSessionsResponse>>, Status>

pub async fn register_policy( &mut self, request: impl IntoRequest<RegisterPolicyRequest>, ) -> Result<Response<RegisterPolicyResponse>, Status>

pub async fn unregister_policy( &mut self, request: impl IntoRequest<UnregisterPolicyRequest>, ) -> Result<Response<UnregisterPolicyResponse>, Status>

pub async fn get_policy( &mut self, request: impl IntoRequest<GetPolicyRequest>, ) -> Result<Response<GetPolicyResponse>, Status>

pub async fn list_policies( &mut self, request: impl IntoRequest<ListPoliciesRequest>, ) -> Result<Response<ListPoliciesResponse>, Status>

pub async fn watch_policies( &mut self, request: impl IntoRequest<WatchPoliciesRequest>, ) -> Result<Response<Streaming<WatchPoliciesResponse>>, Status>

Trait Implementations§

impl<T: Clone> Clone for MacpRuntimeServiceClient<T>

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

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

impl<T: Debug> Debug for MacpRuntimeServiceClient<T>

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

Auto Trait Implementations§

impl<T> !Freeze for MacpRuntimeServiceClient<T>

impl<T> RefUnwindSafe for MacpRuntimeServiceClient<T>where Grpc<T>: RefUnwindSafe,

impl<T> Send for MacpRuntimeServiceClient<T>where Grpc<T>: Send,

impl<T> Sync for MacpRuntimeServiceClient<T>where Grpc<T>: Sync,

impl<T> Unpin for MacpRuntimeServiceClient<T>where Grpc<T>: Unpin,

impl<T> UnsafeUnpin for MacpRuntimeServiceClient<T>where Grpc<T>: UnsafeUnpin,

impl<T> UnwindSafe for MacpRuntimeServiceClient<T>where Grpc<T>: UnwindSafe,

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

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

fn from_ref(input: &T) -> T

impl<T> Instrument for T

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

fn in_current_span(self) -> Instrumented<Self> ⓘ

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

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Same for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

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

Struct MacpRuntimeServiceClient

pub async fn connect<D>(dst: D) -> Result<Self, Error>
where D: TryInto<Endpoint>, D::Error: Into<StdError>,

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

impl<T> RefUnwindSafe for MacpRuntimeServiceClient<T>
where Grpc<T>: RefUnwindSafe,

impl<T> Send for MacpRuntimeServiceClient<T>
where Grpc<T>: Send,

impl<T> Sync for MacpRuntimeServiceClient<T>
where Grpc<T>: Sync,

impl<T> Unpin for MacpRuntimeServiceClient<T>
where Grpc<T>: Unpin,

impl<T> UnsafeUnpin for MacpRuntimeServiceClient<T>
where Grpc<T>: UnsafeUnpin,

impl<T> UnwindSafe for MacpRuntimeServiceClient<T>
where Grpc<T>: UnwindSafe,

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

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

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

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

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

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

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

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

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

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

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

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

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