Struct ServiceHandle 

pub struct ServiceHandle { /* private fields */ }

Thread-safe handle for observing and updating service state.

Cheap to clone (Arc internals). State changes are broadcast to all subscribers via a watch channel.

Implementations

impl ServiceHandle

pub fn new(name: impl Into<String>) -> Self

Create a new service handle with the given name.

Initial state is ServiceState::Stopped.

pub fn name(&self) -> &str

Get the service name.

pub fn state(&self) -> ServiceState

Get the current service state.

pub fn set_state(&self, state: ServiceState)

Update the service state.

All subscribers are notified of the change.

pub fn subscribe(&self) -> Receiver<ServiceState>

Subscribe to state changes.

pub async fn wait_ready(&self, timeout: Duration) -> Result<(), String>

Wait until the service reaches Ready, Failed, or timeout.

pub fn elapsed(&self) -> Duration

Elapsed time since the handle was created.

Trait Implementations

impl Clone for ServiceHandle

fn clone(&self) -> ServiceHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ServiceHandle

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

Formats the value using the given formatter.