Struct cyfs_lib::GlobalStateRequestor

pub struct GlobalStateRequestor { /* private fields */ }

Implementations

impl GlobalStateRequestor

pub fn new_default_tcp(
    category: GlobalStateCategory,
    dec_id: Option<SharedObjectStackDecID>
) -> Self

pub fn new_tcp(
    category: GlobalStateCategory,
    dec_id: Option<SharedObjectStackDecID>,
    service_addr: &str
) -> Self

pub fn new_root_state(
    dec_id: Option<SharedObjectStackDecID>,
    requestor: HttpRequestorRef
) -> Self

pub fn new_local_cache(
    dec_id: Option<SharedObjectStackDecID>,
    requestor: HttpRequestorRef
) -> Self

pub fn new(
    category: GlobalStateCategory,
    dec_id: Option<SharedObjectStackDecID>,
    requestor: HttpRequestorRef
) -> Self

pub fn category(&self) -> &GlobalStateCategory

pub fn into_processor(self) -> GlobalStateOutputProcessorRef

pub fn clone_processor(&self) -> GlobalStateOutputProcessorRef

Trait Implementations

impl Clone for GlobalStateRequestor

fn clone(&self) -> GlobalStateRequestor

Returns a copy of the value.

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

Performs copy-assignment from source.

impl GlobalStateOutputProcessor for GlobalStateRequestor

fn get_category(&self) -> GlobalStateCategory

fn get_current_root<'life0, 'async_trait>(
    &'life0 self,
    req: RootStateGetCurrentRootOutputRequest
) -> Pin<Box<dyn Future<Output = BuckyResult<RootStateGetCurrentRootOutputResponse>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,

fn create_op_env<'life0, 'async_trait>(
    &'life0 self,
    req: RootStateCreateOpEnvOutputRequest
) -> Pin<Box<dyn Future<Output = BuckyResult<OpEnvOutputProcessorRef>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,