Struct dendrite_auth::dendrite::axon_server::control::platform_service_server::PlatformServiceServer
source · pub struct PlatformServiceServer<T>where
T: PlatformService,{ /* private fields */ }
Expand description
Service describing operations for connecting to the AxonServer platform.
Clients are expected to use this service on any of the Platform’s Admin nodes to obtain connection information of the node that it should set up the actual connection with. On that second node, the clients should open an instruction stream (see OpenStream), so that AxonServer and the client application can exchange information and instructions.
Implementations§
source§impl<T> PlatformServiceServer<T>where
T: PlatformService,
impl<T> PlatformServiceServer<T>where
T: PlatformService,
pub fn new(inner: T) -> PlatformServiceServer<T>
pub fn from_arc(inner: Arc<T>) -> PlatformServiceServer<T>
pub fn with_interceptor<F>(
inner: T,
interceptor: F
) -> InterceptedService<PlatformServiceServer<T>, F>where
F: Interceptor,
sourcepub fn accept_compressed(
self,
encoding: CompressionEncoding
) -> PlatformServiceServer<T>
pub fn accept_compressed( self, encoding: CompressionEncoding ) -> PlatformServiceServer<T>
Enable decompressing requests with the given encoding.
sourcepub fn send_compressed(
self,
encoding: CompressionEncoding
) -> PlatformServiceServer<T>
pub fn send_compressed( self, encoding: CompressionEncoding ) -> PlatformServiceServer<T>
Compress responses with the given encoding, if the client supports it.
sourcepub fn max_decoding_message_size(self, limit: usize) -> PlatformServiceServer<T>
pub fn max_decoding_message_size(self, limit: usize) -> PlatformServiceServer<T>
Limits the maximum size of a decoded message.
Default: 4MB
sourcepub fn max_encoding_message_size(self, limit: usize) -> PlatformServiceServer<T>
pub fn max_encoding_message_size(self, limit: usize) -> PlatformServiceServer<T>
Limits the maximum size of an encoded message.
Default: usize::MAX
Trait Implementations§
source§impl<T> Clone for PlatformServiceServer<T>where
T: PlatformService,
impl<T> Clone for PlatformServiceServer<T>where
T: PlatformService,
source§fn clone(&self) -> PlatformServiceServer<T>
fn clone(&self) -> PlatformServiceServer<T>
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl<T> Debug for PlatformServiceServer<T>where
T: Debug + PlatformService,
impl<T> Debug for PlatformServiceServer<T>where
T: Debug + PlatformService,
source§impl<T> NamedService for PlatformServiceServer<T>where
T: PlatformService,
impl<T> NamedService for PlatformServiceServer<T>where
T: PlatformService,
source§impl<T, B> Service<Request<B>> for PlatformServiceServer<T>
impl<T, B> Service<Request<B>> for PlatformServiceServer<T>
§type Response = Response<UnsyncBoxBody<Bytes, Status>>
type Response = Response<UnsyncBoxBody<Bytes, Status>>
Responses given by the service.
§type Error = Infallible
type Error = Infallible
Errors produced by the service.
§type Future = Pin<Box<dyn Future<Output = Result<<PlatformServiceServer<T> as Service<Request<B>>>::Response, <PlatformServiceServer<T> as Service<Request<B>>>::Error>> + Send>>
type Future = Pin<Box<dyn Future<Output = Result<<PlatformServiceServer<T> as Service<Request<B>>>::Response, <PlatformServiceServer<T> as Service<Request<B>>>::Error>> + Send>>
The future response value.
source§fn poll_ready(
&mut self,
_cx: &mut Context<'_>
) -> Poll<Result<(), <PlatformServiceServer<T> as Service<Request<B>>>::Error>>
fn poll_ready( &mut self, _cx: &mut Context<'_> ) -> Poll<Result<(), <PlatformServiceServer<T> as Service<Request<B>>>::Error>>
Returns
Poll::Ready(Ok(()))
when the service is able to process requests. Read moreAuto Trait Implementations§
impl<T> RefUnwindSafe for PlatformServiceServer<T>where
T: RefUnwindSafe,
impl<T> Send for PlatformServiceServer<T>
impl<T> Sync for PlatformServiceServer<T>
impl<T> Unpin for PlatformServiceServer<T>
impl<T> UnwindSafe for PlatformServiceServer<T>where
T: RefUnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T, ReqBody, ResBody> GrpcService<ReqBody> for T
impl<T, ReqBody, ResBody> GrpcService<ReqBody> for T
§type ResponseBody = ResBody
type ResponseBody = ResBody
Responses body given by the service.
source§fn poll_ready(
&mut self,
cx: &mut Context<'_>
) -> Poll<Result<(), <T as GrpcService<ReqBody>>::Error>>
fn poll_ready( &mut self, cx: &mut Context<'_> ) -> Poll<Result<(), <T as GrpcService<ReqBody>>::Error>>
Returns
Ready
when the service is able to process requests. Read more§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
§impl<S, R> ServiceExt<R> for Swhere
S: Service<R>,
impl<S, R> ServiceExt<R> for Swhere
S: Service<R>,
§fn into_make_service(self) -> IntoMakeService<S>
fn into_make_service(self) -> IntoMakeService<S>
Convert this service into a
MakeService
, that is a [Service
] whose
response is another service. Read more§impl<T, Request> ServiceExt<Request> for Twhere
T: Service<Request> + ?Sized,
impl<T, Request> ServiceExt<Request> for Twhere
T: Service<Request> + ?Sized,
§fn ready(&mut self) -> Ready<'_, Self, Request>where
Self: Sized,
fn ready(&mut self) -> Ready<'_, Self, Request>where
Self: Sized,
Yields a mutable reference to the service when it is ready to accept a request.
§fn ready_and(&mut self) -> Ready<'_, Self, Request>where
Self: Sized,
fn ready_and(&mut self) -> Ready<'_, Self, Request>where
Self: Sized,
👎Deprecated since 0.4.6: please use the
ServiceExt::ready
method insteadYields a mutable reference to the service when it is ready to accept a request.
§fn ready_oneshot(self) -> ReadyOneshot<Self, Request>where
Self: Sized,
fn ready_oneshot(self) -> ReadyOneshot<Self, Request>where
Self: Sized,
Yields the service when it is ready to accept a request.
§fn oneshot(self, req: Request) -> Oneshot<Self, Request>where
Self: Sized,
fn oneshot(self, req: Request) -> Oneshot<Self, Request>where
Self: Sized,
Consume this
Service
, calling with the providing request once it is ready.§fn and_then<F>(self, f: F) -> AndThen<Self, F>
fn and_then<F>(self, f: F) -> AndThen<Self, F>
Executes a new future after this service’s future resolves. This does
not alter the behaviour of the
poll_ready
method. Read more§fn map_response<F, Response>(self, f: F) -> MapResponse<Self, F>
fn map_response<F, Response>(self, f: F) -> MapResponse<Self, F>
Maps this service’s response value to a different value. This does not
alter the behaviour of the
poll_ready
method. Read more§fn map_err<F, Error>(self, f: F) -> MapErr<Self, F>
fn map_err<F, Error>(self, f: F) -> MapErr<Self, F>
Maps this service’s error value to a different value. This does not
alter the behaviour of the
poll_ready
method. Read more§fn map_result<F, Response, Error>(self, f: F) -> MapResult<Self, F>
fn map_result<F, Response, Error>(self, f: F) -> MapResult<Self, F>
Maps this service’s result type (
Result<Self::Response, Self::Error>
)
to a different value, regardless of whether the future succeeds or
fails. Read more§fn map_request<F, NewRequest>(self, f: F) -> MapRequest<Self, F>
fn map_request<F, NewRequest>(self, f: F) -> MapRequest<Self, F>
Composes a function in front of the service. Read more
§fn then<F, Response, Error, Fut>(self, f: F) -> Then<Self, F>
fn then<F, Response, Error, Fut>(self, f: F) -> Then<Self, F>
Composes an asynchronous function after this service. Read more
§fn map_future<F, Fut, Response, Error>(self, f: F) -> MapFuture<Self, F>
fn map_future<F, Fut, Response, Error>(self, f: F) -> MapFuture<Self, F>
Composes a function that transforms futures produced by the service. Read more