Trait crows_utils::services::Worker

pub trait Worker {
    // Required methods
    fn upload_scenario(
        &self,
        client: WorkerToCoordinatorClient,
        name: String,
        content: Vec<u8>
    ) -> impl Future<Output = ()> + Send;
    fn ping(
        &self,
        client: WorkerToCoordinatorClient
    ) -> impl Future<Output = String> + Send;
    fn start(
        &self,
        client: WorkerToCoordinatorClient,
        name: String,
        config: Config,
        run_id: RunId
    ) -> impl Future<Output = Result<(), WorkerError>> + Send;
    fn get_data(
        &self,
        client: WorkerToCoordinatorClient
    ) -> impl Future<Output = WorkerData> + Send;
    fn get_run_status(
        &self,
        client: WorkerToCoordinatorClient,
        id: RunId
    ) -> impl Future<Output = RunInfo> + Send;
}

Required Methods

fn upload_scenario( &self, client: WorkerToCoordinatorClient, name: String, content: Vec<u8> ) -> impl Future<Output = ()> + Send

fn ping( &self, client: WorkerToCoordinatorClient ) -> impl Future<Output = String> + Send

fn start( &self, client: WorkerToCoordinatorClient, name: String, config: Config, run_id: RunId ) -> impl Future<Output = Result<(), WorkerError>> + Send

fn get_data( &self, client: WorkerToCoordinatorClient ) -> impl Future<Output = WorkerData> + Send

fn get_run_status( &self, client: WorkerToCoordinatorClient, id: RunId ) -> impl Future<Output = RunInfo> + Send

Object Safety

This trait is not object safe.

Implementors