Struct ServiceGroup 

pub struct ServiceGroup { /* private fields */ }

A group of async services that start together and stop together.

Services are started concurrently. Like go-zero’s service group, startup order must not be relied on. When a process shutdown signal, explicit handle stop, or service error occurs, the group broadcasts a shutdown token, runs stop hooks, waits for tasks and returns aggregated errors if any.

Implementations

impl ServiceGroup

pub fn new() -> Self

Creates an empty service group with default controls.

pub fn with_config(config: ServiceGroupConfig) -> Self

Creates an empty service group with custom controls.

pub fn add<S>(&mut self, service: S) -> &mut Self

where S: Service,

Adds a service to the group.

pub fn add_arc<S>(&mut self, service: Arc<S>) -> &mut Self

where S: Service,

Adds an already shared service to the group.

pub fn add_fn<F, Fut>(&mut self, name: impl Into<String>, start: F) -> &mut Self

where F: Fn(ShutdownToken) -> Fut + Send + Sync + 'static, Fut: Future<Output = CoreResult<()>> + Send + 'static,

Adds a service backed by an async start function.

pub fn handle(&self) -> ServiceGroupHandle

Returns a handle that can stop the group while it is running.

pub async fn start(self) -> CoreResult<()>

Starts all services and waits for Ctrl-C or explicit stop.

pub async fn start_with_shutdown<F>(self, shutdown: F) -> CoreResult<()>

where F: Future<Output = ()> + Send,

Starts all services and waits for the supplied shutdown future.

Trait Implementations

impl Default for ServiceGroup

fn default() -> Self

Returns the “default value” for a type.