Struct dendrite_auth::dendrite::axon_server::control::platform_service_server::PlatformServiceServer

pub struct PlatformServiceServer<T>
where
    T: PlatformService,
{ /* private fields */ }

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

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,

pub fn accept_compressed( self, encoding: CompressionEncoding ) -> PlatformServiceServer<T>

Enable decompressing requests with the given encoding.

pub fn send_compressed( self, encoding: CompressionEncoding ) -> PlatformServiceServer<T>

Compress responses with the given encoding, if the client supports it.

pub fn max_decoding_message_size(self, limit: usize) -> PlatformServiceServer<T>

Limits the maximum size of a decoded message.

Default: 4MB

pub fn max_encoding_message_size(self, limit: usize) -> PlatformServiceServer<T>

Limits the maximum size of an encoded message.

Default: usize::MAX

Trait Implementations

impl<T> Clone for PlatformServiceServer<T>

where T: PlatformService,

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Debug for PlatformServiceServer<T>

where T: Debug + PlatformService,

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

Formats the value using the given formatter.

impl<T> NamedService for PlatformServiceServer<T>

where T: PlatformService,

const NAME: &'static str = "io.axoniq.axonserver.grpc.control.PlatformService"

The Service-Name as described here.

impl<T, B> Service<Request<B>> for PlatformServiceServer<T>

where T: PlatformService, B: Body + Send + 'static, <B as Body>::Error: Into<Box<dyn Error + Sync + Send>> + Send + 'static,

type Response = Response<UnsyncBoxBody<Bytes, Status>>

Responses given by the service.

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>>

The future response value.

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.

fn call( &mut self, req: Request<B> ) -> <PlatformServiceServer<T> as Service<Request<B>>>::Future

Process the request and return the response asynchronously.