Struct LocalWorkerClient 

pub struct LocalWorkerClient { /* private fields */ }

Implementations

impl LocalWorkerClient

pub fn init() -> (Self, LocalWorkerClientChannels)

Creates a new local worker client.

pub async fn update_task_status( &self, task_id: TaskId, status: TaskStatus, ) -> Result<()>

Trait Implementations

impl Clone for LocalWorkerClient

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl WorkerClient for LocalWorkerClient

async fn submit_task( &self, kind: TaskType, task: RawTaskRequest, ) -> Result<TaskId>

async fn complete_task( &self, _proof_id: ProofId, task_id: TaskId, _metadata: TaskMetadata, ) -> Result<()>

async fn complete_proof( &self, proof_id: ProofId, _task_id: Option<TaskId>, _status: ProofRequestStatus, _extra_data: impl Into<String> + Send, ) -> Result<()>

async fn subscriber( &self, _proof_id: ProofId, ) -> Result<SubscriberBuilder<Self>>

async fn subscribe_task_messages( &self, task_id: &TaskId, ) -> Result<UnboundedReceiver<Vec<u8>>>

Subscribe to the message stream for a task. The returned receiver’s stream ends when the producer task completes or fails.

async fn send_task_message( &self, task_id: &TaskId, payload: Vec<u8>, ) -> Result<()>

Send a payload on the message channel for this task. Lazily creates the channel entry if it does not yet exist.

fn submit_tasks( &self, kind: TaskType, tasks: impl IntoIterator<Item = RawTaskRequest> + Send, ) -> impl Future<Output = Result<Vec<TaskId>>> + Send

fn submit_all( &self, kind: TaskType, tasks: impl Stream<Item = RawTaskRequest> + Send, ) -> impl Future<Output = Result<Vec<TaskId>>> + Send