Struct cyfs_lib::TransRequestor

pub struct TransRequestor { /* private fields */ }

Implementations

impl TransRequestor

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

pub fn clone_processor(&self) -> TransOutputProcessorRef

pub async fn get_context( &self, req: TransGetContextOutputRequest ) -> BuckyResult<TransGetContextOutputResponse>

pub async fn put_context( &self, req: TransPutContextOutputRequest ) -> BuckyResult<()>

pub async fn create_task( &self, req: TransCreateTaskOutputRequest ) -> BuckyResult<TransCreateTaskOutputResponse>

pub async fn control_task( &self, req: TransControlTaskOutputRequest ) -> BuckyResult<()>

pub async fn start_task(&self, req: TransTaskOutputRequest) -> BuckyResult<()>

pub async fn stop_task(&self, req: TransTaskOutputRequest) -> BuckyResult<()>

pub async fn delete_task(&self, req: TransTaskOutputRequest) -> BuckyResult<()>

pub async fn get_task_state( &self, req: TransGetTaskStateOutputRequest ) -> BuckyResult<TransGetTaskStateOutputResponse>

pub async fn query_tasks( &self, req: TransQueryTasksOutputRequest ) -> BuckyResult<TransQueryTasksOutputResponse>

pub async fn publish_file( &self, req: TransPublishFileOutputRequest ) -> BuckyResult<TransPublishFileOutputResponse>

pub async fn get_task_group_state( &self, req: TransGetTaskGroupStateOutputRequest ) -> BuckyResult<TransGetTaskGroupStateOutputResponse>

pub async fn control_task_group( &self, req: TransControlTaskGroupOutputRequest ) -> BuckyResult<TransControlTaskGroupOutputResponse>

Trait Implementations

impl Clone for TransRequestor

fn clone(&self) -> TransRequestor

Returns a copy of the value.

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

Performs copy-assignment from source.

impl TransOutputProcessor for TransRequestor

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

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

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

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

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

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

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

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

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