Struct WorkerRegistration 

pub struct WorkerRegistration { /* private fields */ }

Registration token owned by the worker stream task.

Dropping the token performs best-effort cleanup for disconnect paths. Call WorkerRegistration::deregister when the caller needs a typed poison error.

Implementations

impl WorkerRegistration

pub fn worker_id(&self) -> Option<WorkerId>

Worker id assigned to this registration.

pub fn namespaces(&self) -> Option<&BTreeSet<String>>

Authorized namespace set for this registration.

pub fn task_queue(&self) -> Option<&str>

Task queue (pool/flavour) this registration serves within each namespace.

pub fn activity_types(&self) -> Option<&BTreeSet<String>>

Activity types advertised by this registration.

pub fn deregister(self) -> Result<(), ServerError>

Explicitly remove this worker from the registry.

Errors

Returns ServerError::LockPoisoned if the registry lock is poisoned.

Trait Implementations

impl Debug for WorkerRegistration

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

Formats the value using the given formatter.

impl Drop for WorkerRegistration

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.