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<IbcEvent>,
    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 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.