Struct nebula_graph_fbthrift_storage_v2::server::StorageAdminServiceProcessor

pub struct StorageAdminServiceProcessor<P, H, R> { /* fields omitted */ }

Implementations

impl<P, H, R> StorageAdminServiceProcessor<P, H, R> where
    P: Protocol + Send + Sync + 'static,
    P::Deserializer: Send,
    H: StorageAdminService, 

pub fn new(service: H) -> Self

pub fn into_inner(self) -> H

Trait Implementations

impl<P: Clone, H: Clone, R: Clone> Clone for StorageAdminServiceProcessor<P, H, R>

fn clone(&self) -> StorageAdminServiceProcessor<P, H, R>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<P: Debug, H: Debug, R: Debug> Debug for StorageAdminServiceProcessor<P, H, R>

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

Formats the value using the given formatter.

impl<P, H, R> ServiceProcessor<P> for StorageAdminServiceProcessor<P, H, R> where
    P: Protocol + Send + Sync + 'static,
    P::Deserializer: Send,
    H: StorageAdminService,
    R: Send + Sync + 'static, 

type RequestContext = R

fn method_idx(&self, name: &[u8]) -> Result<usize, ApplicationException>

Given a method name, return a reference to the processor for that index.

fn handle_method<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 self,
    idx: usize,
    _p: &'life1 mut P::Deserializer,
    _r: &'life2 R,
    _seqid: u32
) -> Pin<Box<dyn Future<Output = Result<ProtocolEncodedFinal<P>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    Self: 'async_trait, 

Given a method index and the remains of the message input, get a future for the result of the method. This will only be called if the corresponding method_idx() returns an (index, ServiceProcessor) tuple. frame is a reference to the frame containing the request. request is a deserializer instance set up to decode the request.

impl<P, H, R> ThriftService<<P as Protocol>::Frame> for StorageAdminServiceProcessor<P, H, R> where
    P: Protocol + Send + Sync + 'static,
    P::Deserializer: Send,
    P::Frame: Send + 'static,
    H: StorageAdminService,
    R: Send + Sync + 'static, 

type Handler = H

type RequestContext = R

fn call<'life0, 'life1, 'async_trait>(
    &'life0 self,
    req: ProtocolDecoded<P>,
    req_ctxt: &'life1 R
) -> Pin<Box<dyn Future<Output = Result<ProtocolEncodedFinal<P>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,