Struct CoordinatorClient

pub struct CoordinatorClient { /* private fields */ }

Implementations

impl CoordinatorClient

pub async fn wait(&self)

pub async fn get_close_receiver(&self) -> Option<Receiver<()>>

pub async fn upload_scenario( &self, name: String, content: Vec<u8>, ) -> Result<Result<(), CoordinatorError>>

pub async fn start( &self, name: String, workers_number: usize, ) -> Result<Result<(RunId, Vec<String>), CoordinatorError>>

pub async fn list_workers(&self) -> Result<Vec<String>>

pub async fn get_run_status( &self, id: RunId, ) -> Result<Option<HashMap<String, RunInfo>>>

Trait Implementations

impl ClientTrait for CoordinatorClient

fn new(client: Client) -> Self

impl Clone for CoordinatorClient

fn clone(&self) -> CoordinatorClient

Returns a copy of the value.

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

Performs copy-assignment from source.