Struct SystemLifecycleDriver 

pub(crate) struct SystemLifecycleDriver {
    pub(crate) atlas: AtlasClient,
    pub(crate) provider_id: String,
    pub(crate) shutdown_tx: Sender<bool>,
}

Fields

atlas: AtlasClient

provider_id: String

shutdown_tx: Sender<bool>

Implementations

impl SystemLifecycleDriver

pub(crate) fn new(atlas: AtlasClient, provider_id: String) -> Self

pub(crate) async fn transition(&self, command: u32) -> Result<&'static str>

Apply one no-op lifecycle callback and publish its authoritative state to Atlas. Unknown commands and rejected Atlas transitions are errors.

pub(crate) fn subscribe_shutdown(&self) -> Receiver<bool>

Trait Implementations

impl Clone for SystemLifecycleDriver

fn clone(&self) -> SystemLifecycleDriver

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl RobonixLifecycleDriver for SystemLifecycleDriver

fn driver<'life0, 'async_trait>( &'life0 self, request: Request<DriverRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DriverResponse>, Status>> + Send + 'async_trait>>

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

Serve the shared Driver RPC and report callback/transition failures in the stable DriverResponse envelope used by launchers.