Struct ibc_relayer::worker::WorkerHandle

pub struct WorkerHandle { /* private fields */ }

Implementations

impl WorkerHandle

pub fn new( id: WorkerId, object: Object, data: Option<WorkerData>, tx: Option<Sender<WorkerCmd>>, task_handles: Vec<TaskHandle> ) -> Self

pub fn try_send_command(&self, cmd: WorkerCmd)

pub fn send_events( &self, height: Height, events: Vec<IbcEventWithHeight>, chain_id: ChainId, tracking_id: TrackingId )

Send a batch of events to the worker.

pub fn send_new_block(&self, height: Height, new_block: NewBlock)

Send a batch of NewBlock event to the worker.

pub fn clear_pending_packets(&self)

Instruct the worker to clear pending packets.

pub fn shutdown(&self)

Shutdown all worker tasks without waiting for them to terminate.

pub fn shutdown_and_wait(self)

Shutdown all worker tasks and wait for them to terminate

pub fn is_stopped(&self) -> bool

pub fn shutdown_stopped_tasks(&self) -> bool

Verify if at least one task of the WorkerHandle is stopped. If it is the case, shutdown all remaining tasks.

pub fn join(self)

Wait for the worker thread to finish.

pub fn id(&self) -> WorkerId

Get the worker’s id.

pub fn object(&self) -> &Object

Get a reference to the worker’s object.

pub fn data(&self) -> Option<&WorkerData>

Get a reference to the worker handle’s data.

Trait Implementations

impl Debug for WorkerHandle

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

Formats the value using the given formatter.

impl Drop for WorkerHandle

fn drop(&mut self)

Executes the destructor for this type.