Struct ServiceLifecycleConfig 

pub struct ServiceLifecycleConfig {
    pub service_name: Arc<str>,
    pub probe_bind_addr: Option<SocketAddr>,
    pub shutdown_timeout: Duration,
    pub liveness_stale_after: Duration,
    pub drain_request_methods: DrainRequestMethods,
}

Versioned runtime configuration for the process lifecycle boundary.

Fields

service_name: Arc<str>

The service name value.

probe_bind_addr: Option<SocketAddr>

The probe bind addr value.

shutdown_timeout: Duration

Process shutdown budget.

The first shutdown request fixes a ShutdownDeadline this far ahead. That deadline is the single source for component shutdown and the owner’s final shutdown; repeated requests never extend it.

liveness_stale_after: Duration

The liveness stale after value.

drain_request_methods: DrainRequestMethods

HTTP methods that /drainz accepts.

Implementations

impl ServiceLifecycleConfig

pub fn from_env(service_name: impl Into<Arc<str>>) -> RuntimeResult<Self>

Reads the optional probe address and bounded lifecycle budgets from the environment.

The probe server is disabled when ROCKETMQ_HEALTH_BIND_ADDR is absent, preserving non-Kubernetes entrypoint behavior. Shutdown coordination remains active.

Errors

Returns a configuration runtime failure for a malformed address, non-UTF-8 input, zero timeout, a liveness window shorter than two progress intervals, or a drain method list other than POST or GET,POST.

Trait Implementations

impl Clone for ServiceLifecycleConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ServiceLifecycleConfig

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

Formats the value using the given formatter.

impl Eq for ServiceLifecycleConfig

impl PartialEq for ServiceLifecycleConfig

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ServiceLifecycleConfig