Struct ya_client::activity::ActivityRequestorControlApi

pub struct ActivityRequestorControlApi { /* private fields */ }

Bindings for Requestor Control part of the Activity API.

Implementations

impl ActivityRequestorControlApi

pub async fn create_activity(&self, agreement_id: &str) -> Result<String>

Creates new Activity based on given Agreement.

pub async fn destroy_activity(&self, activity_id: &str) -> Result<()>

Destroys given Activity.

pub async fn exec( &self, script: ExeScriptRequest, activity_id: &str ) -> Result<String>

Executes an ExeScript batch within a given Activity.

pub async fn get_exec_batch_results( &self, activity_id: &str, batch_id: &str, timeout: Option<f32>, command_index: Option<usize> ) -> Result<Vec<ExeScriptCommandResult>>

Queries for ExeScript batch results.

pub async fn stream_exec_batch_results( &self, activity_id: &str, batch_id: &str ) -> Result<impl Stream<Item = RuntimeEvent>>

Streams ExeScript batch results

Trait Implementations

impl Clone for ActivityRequestorControlApi

fn clone(&self) -> ActivityRequestorControlApi

Returns a copy of the value.

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

Performs copy-assignment from source.

impl WebInterface for ActivityRequestorControlApi

const API_URL_ENV_VAR: &'static str = crate::activity::ACTIVITY_URL_ENV_VAR

const API_SUFFIX: &'static str = ACTIVITY_API_PATH

fn from_client(client: WebClient) -> Self

fn rebase_service_url(base_url: Rc<Url>) -> Result<Rc<Url>>