Struct MeshService 

pub struct MeshService { /* private fields */ }

SystemService adapter for the K6 mesh transport.

The accept/connect loops are spawned by kernel boot (phase 5d) and handed to this service (MeshService::adopt_tasks), which stops them on stop; it owns the lifecycle surface: marking the mesh live, disconnecting peers on stop, and aggregating peer-health into HealthStatus for the weaver service registry.

Implementations

impl MeshService

pub fn adopt_tasks(&self, handles: Vec<JoinHandle<()>>)

Take ownership of the mesh loops so stop can end them. stop is terminal for these loops: start after stop does not respawn them.

pub fn new(runtime: Arc<MeshRuntime>) -> Self

Wrap an existing mesh runtime (listen endpoint unknown).

pub fn with_endpoints( runtime: Arc<MeshRuntime>, listen_addr: impl Into<String>, transport: impl Into<String>, ) -> Self

Wrap a runtime with endpoint metadata from kernel mesh config.

pub fn runtime(&self) -> &Arc<MeshRuntime>

Shared handle to the underlying mesh runtime.

pub fn is_started(&self) -> bool

Whether SystemService::start has been called more recently than SystemService::stop.

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

Configured listen address, if provided at construction.

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

Configured transport name, if provided at construction.

Trait Implementations

impl Drop for MeshService

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.

impl SystemService for MeshService

fn name(&self) -> &str

Human-readable service name.

fn service_type(&self) -> ServiceType

Service type category.

fn start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start the service.

fn stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stop the service.

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = HealthStatus> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Perform a health check.

fn liveness_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ProbeResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Liveness probe (K2b-G2, os-patterns).

fn readiness_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ProbeResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Readiness probe (K2b-G2, os-patterns).

fn health_detail(&self) -> Option<String>

Optional operator-facing detail (metrics, endpoints, …).