Struct WorkerClient

pub struct WorkerClient { /* private fields */ }

Client for managing workers in the Gevulot system.

Implementations

impl WorkerClient

pub fn new(base_client: Arc<RwLock<BaseClient>>) -> Self

Creates a new instance of WorkerClient.

Arguments

• base_client - An Arc-wrapped RwLock of the BaseClient.

Returns

A new instance of WorkerClient.

pub async fn list(&mut self) -> Result<Vec<Worker>>

Lists all workers.

Returns

A Result containing a vector of workers or an error.

Errors

This function will return an error if the request to the Gevulot client fails.

pub async fn get(&mut self, id: &str) -> Result<Worker>

Gets a worker by its ID.

Arguments

• id - The ID of the worker to retrieve.

Returns

A Result containing the worker or an error.

Errors

This function will return an error if the worker is not found or if the request to the Gevulot client fails.

pub async fn create( &mut self, msg: MsgCreateWorker, ) -> Result<MsgCreateWorkerResponse>

Creates a new worker.

Arguments

• msg - The message containing the worker details.

Returns

A Result containing the response or an error.

Errors

This function will return an error if the request to the Gevulot client fails.

pub async fn update( &mut self, msg: MsgUpdateWorker, ) -> Result<MsgUpdateWorkerResponse>

Updates a worker.

Arguments

• msg - The message containing the worker details to update.

Returns

A Result containing the response or an error.

Errors

This function will return an error if the request to the Gevulot client fails.

pub async fn delete( &mut self, msg: MsgDeleteWorker, ) -> Result<MsgDeleteWorkerResponse>

Deletes a worker.

Arguments

• msg - The message containing the worker ID to delete.

Returns

A Result containing the response or an error.

Errors

This function will return an error if the request to the Gevulot client fails.

pub async fn announce_exit( &mut self, msg: MsgAnnounceWorkerExit, ) -> Result<MsgAnnounceWorkerExitResponse>

Announces a worker’s exit.

Arguments

• msg - The message containing the worker ID to announce exit.

Returns

A Result containing the response or an error.

Errors

This function will return an error if the request to the Gevulot client fails.

Trait Implementations

impl Clone for WorkerClient

fn clone(&self) -> WorkerClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.