Trait fbthrift_git::processor::ThriftService

pub trait ThriftService<F>: Send + Sync + 'staticwhere
    F: Framing + Send + 'static,{
    type Handler;
    type RequestContext;
    type ReplyState;

    fn call<'life0, 'life1, 'async_trait>(
        &'life0 self,
        req: FramingDecoded<F>,
        req_ctxt: &'life1 Self::RequestContext,
        reply_state: Arc<Mutex<Self::ReplyState>>
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
    where
        Self: 'async_trait,
        'life0: 'async_trait,
        'life1: 'async_trait;
    fn get_method_names(&self) -> &'static [&'static str];

    fn create_interaction(
        &self,
        _name: &str
    ) -> Result<Arc<dyn ThriftService<F, Handler = (), RequestContext = Self::RequestContext, ReplyState = Self::ReplyState> + Send + 'static>> { ... }
}

Required Associated Types

type Handler

type RequestContext

type ReplyState

Required Methods

fn call<'life0, 'life1, 'async_trait>(
    &'life0 self,
    req: FramingDecoded<F>,
    req_ctxt: &'life1 Self::RequestContext,
    reply_state: Arc<Mutex<Self::ReplyState>>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

fn get_method_names(&self) -> &'static [&'static str]

Returns function names this thrift service is able to handle, similar to the keys of C++’s createMethodMetadata().

Return value includes inherited functions from parent thrift services, and interactions’ functions.

Provided Methods

fn create_interaction(
    &self,
    _name: &str
) -> Result<Arc<dyn ThriftService<F, Handler = (), RequestContext = Self::RequestContext, ReplyState = Self::ReplyState> + Send + 'static>>

Implementations on Foreign Types

impl<F, T> ThriftService<F> for Box<T>where
    T: ThriftService<F> + Send + Sync + ?Sized,
    F: Framing + Send + 'static,
    T::RequestContext: Send + Sync + 'static,
    T::ReplyState: Send + Sync + 'static,

type Handler = <T as ThriftService<F>>::Handler

type RequestContext = <T as ThriftService<F>>::RequestContext

type ReplyState = <T as ThriftService<F>>::ReplyState

fn call<'life0, 'life1, 'async_trait>(
    &'life0 self,
    req: FramingDecoded<F>,
    req_ctxt: &'life1 Self::RequestContext,
    reply_state: Arc<Mutex<Self::ReplyState>>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

fn create_interaction(
    &self,
    name: &str
) -> Result<Arc<dyn ThriftService<F, Handler = (), RequestContext = Self::RequestContext, ReplyState = Self::ReplyState> + Send + 'static>>

fn get_method_names(&self) -> &'static [&'static str]

impl<F, T> ThriftService<F> for Arc<T>where
    T: ThriftService<F> + Send + Sync + ?Sized,
    F: Framing + Send + 'static,
    T::RequestContext: Send + Sync + 'static,
    T::ReplyState: Send + Sync + 'static,

type Handler = <T as ThriftService<F>>::Handler

type RequestContext = <T as ThriftService<F>>::RequestContext

type ReplyState = <T as ThriftService<F>>::ReplyState

fn call<'life0, 'life1, 'async_trait>(
    &'life0 self,
    req: FramingDecoded<F>,
    req_ctxt: &'life1 Self::RequestContext,
    reply_state: Arc<Mutex<Self::ReplyState>>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

fn create_interaction(
    &self,
    name: &str
) -> Result<Arc<dyn ThriftService<F, Handler = (), RequestContext = Self::RequestContext, ReplyState = Self::ReplyState> + Send + 'static>>

fn get_method_names(&self) -> &'static [&'static str]

Implementors

impl<P, R, RS> ThriftService<<P as Protocol>::Frame> for NullServiceProcessor<P, R, RS>where
    P: Protocol + Send + Sync + 'static,
    P::Frame: Send + 'static,
    R: RequestContext<Name = CStr> + Send + Sync + 'static,
    R::ContextStack: ContextStack<Name = CStr>,
    RS: ReplyState<P::Frame> + Send + Sync + 'static,

type Handler = ()

type RequestContext = R

type ReplyState = RS