Struct Service 

pub struct Service<S: MembershipStorage, P: ObjectPlacement> { /* private fields */ }

Service to respond to Requests from crate::client::Client

Implementations

impl<S: MembershipStorage + 'static, P: ObjectPlacement + 'static> Service<S, P>

pub async fn run(&mut self, stream: TcpStream)

Main service loop

Consumes a stream of frames, each containing a command sent from clients.

The commands might be either a request/response request or a subscription request

Trait Implementations

impl<S: Clone + MembershipStorage, P: Clone + ObjectPlacement> Clone for Service<S, P>

fn clone(&self) -> Service<S, P>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug + MembershipStorage, P: Debug + ObjectPlacement> Debug for Service<S, P>

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

Formats the value using the given formatter.

impl<S: MembershipStorage + 'static, P: ObjectPlacement + 'static> Service<RequestEnvelope> for Service<S, P>

Service implementation to handle RequestEnvelope request

fn call(&mut self, req: RequestEnvelope) -> Self::Future

Call a service locally, or return an error that will indicate whether this service is allocated somewhere else

type Response = ResponseEnvelope

Responses given by the service.

type Error = ResponseError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<Service<S, P> as Service<RequestEnvelope>>::Response, <Service<S, P> as Service<RequestEnvelope>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

impl<S, P> Service<SubscriptionRequest> for Service<S, P>

where S: MembershipStorage + 'static, P: ObjectPlacement + 'static,

Service implementation to handle SubscriptionRequest messages

type Response = SubscriptionResponseIter

Responses given by the service.

type Error = ResponseError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<Service<S, P> as Service<SubscriptionRequest>>::Response, <Service<S, P> as Service<SubscriptionRequest>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: SubscriptionRequest) -> Self::Future

Process the request and return the response asynchronously.

impl<S, C, P> TryFrom<&Server<S, C, P>> for Service<S, P>

where S: MembershipStorage + 'static, C: ClusterProvider<S> + 'static + Send + Sync, P: ObjectPlacement + 'static,

Transforms a Server into a Service

It can’t be infalible, because it needs to be bind so it can generate a Service

type Error = ServerError

The type returned in the event of a conversion error.

fn try_from(server: &Server<S, C, P>) -> Result<Self, Self::Error>

Performs the conversion.