Struct cyfs_lib::RouterHandlerManager

pub struct RouterHandlerManager { /* private fields */ }

Implementations

impl RouterHandlerManager

pub async fn new(
    dec_id: Option<SharedObjectStackDecID>,
    service_url: &str,
    event_type: CyfsStackEventType
) -> BuckyResult<Self>

pub fn clone_processor(&self) -> RouterHandlerManagerProcessorRef

pub fn add_handler<REQ, RESP>(
    &self,
    chain: RouterHandlerChain,
    id: &str,
    index: i32,
    filter: Option<String>,
    req_path: Option<String>,
    default_action: RouterHandlerAction,
    routine: Option<Box<dyn EventListenerAsyncRoutine<RouterHandlerRequest<REQ, RESP>, RouterHandlerResponse<REQ, RESP>>>>
) -> BuckyResult<()>where
    REQ: Send + Sync + 'static + JsonCodec<REQ> + Display,
    RESP: Send + Sync + 'static + JsonCodec<RESP> + Display,
    RouterHandlerRequest<REQ, RESP>: RouterHandlerCategoryInfo,

pub async fn remove_handler(
    &self,
    chain: RouterHandlerChain,
    category: RouterHandlerCategory,
    id: &str
) -> BuckyResult<bool>

Trait Implementations

impl Clone for RouterHandlerManager

fn clone(&self) -> RouterHandlerManager

Returns a copy of the value.

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

Performs copy-assignment from source.

impl RouterHandlerManagerProcessor for RouterHandlerManager

fn get_object(
    &self
) -> &dyn RouterHandlerProcessor<NONGetObjectInputRequest, NONGetObjectInputResponse>

fn put_object(
    &self
) -> &dyn RouterHandlerProcessor<NONPutObjectInputRequest, NONPutObjectInputResponse>

fn post_object(
    &self
) -> &dyn RouterHandlerProcessor<NONPostObjectInputRequest, NONPostObjectInputResponse>

fn select_object(
    &self
) -> &dyn RouterHandlerProcessor<NONSelectObjectInputRequest, NONSelectObjectInputResponse>

fn delete_object(
    &self
) -> &dyn RouterHandlerProcessor<NONDeleteObjectInputRequest, NONDeleteObjectInputResponse>

fn get_data(
    &self
) -> &dyn RouterHandlerProcessor<NDNGetDataInputRequest, NDNGetDataInputResponse>

fn put_data(
    &self
) -> &dyn RouterHandlerProcessor<NDNPutDataInputRequest, NDNPutDataInputResponse>

fn delete_data(
    &self
) -> &dyn RouterHandlerProcessor<NDNDeleteDataInputRequest, NDNDeleteDataInputResponse>

fn sign_object(
    &self
) -> &dyn RouterHandlerProcessor<CryptoSignObjectInputRequest, CryptoSignObjectInputResponse>

fn verify_object(
    &self
) -> &dyn RouterHandlerProcessor<CryptoVerifyObjectInputRequest, CryptoVerifyObjectInputResponse>

fn acl(
    &self
) -> &dyn RouterHandlerProcessor<AclHandlerRequest, AclHandlerResponse>

fn interest(
    &self
) -> &dyn RouterHandlerProcessor<InterestHandlerRequest, InterestHandlerResponse>

impl<REQ, RESP> RouterHandlerProcessor<REQ, RESP> for RouterHandlerManagerwhere
    REQ: Send + Sync + 'static + JsonCodec<REQ> + Display,
    RESP: Send + Sync + 'static + JsonCodec<RESP> + Display,
    RouterHandlerRequest<REQ, RESP>: RouterHandlerCategoryInfo,

fn add_handler<'life0, 'life1, 'async_trait>(
    &'life0 self,
    chain: RouterHandlerChain,
    id: &'life1 str,
    index: i32,
    filter: Option<String>,
    req_path: Option<String>,
    default_action: RouterHandlerAction,
    routine: Option<Box<dyn EventListenerAsyncRoutine<RouterHandlerRequest<REQ, RESP>, RouterHandlerResponse<REQ, RESP>>>>
) -> Pin<Box<dyn Future<Output = BuckyResult<()>> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,

fn remove_handler<'life0, 'life1, 'async_trait>(
    &'life0 self,
    chain: RouterHandlerChain,
    id: &'life1 str
) -> Pin<Box<dyn Future<Output = BuckyResult<bool>> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,