Struct WaitUntilGrpcServer 

pub struct WaitUntilGrpcServer { /* private fields */ }

Implementations

impl WaitUntilGrpcServer

pub fn new(provider: Arc<dyn BindingsProviderApi>) -> Self

pub fn into_service(self) -> WaitUntilServiceServer<Self>

pub async fn trigger_drain_all( &self, reason: &str, timeout_secs: u64, ) -> Result<(), AlienError>

Trigger drain for all registered applications. This is called by the runtime when it’s time to drain (e.g., on SIGTERM or Lambda INVOKE end).

pub async fn get_total_task_count(&self) -> u32

Get total number of tasks across all applications.

Trait Implementations

impl Clone for WaitUntilGrpcServer

fn clone(&self) -> WaitUntilGrpcServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl WaitUntilService for WaitUntilGrpcServer

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

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

Application notifies runtime that it has registered a new task.

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

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

Application calls this to wait for a drain signal from runtime. This is a blocking call that returns when runtime decides it’s time to drain.

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

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

Application notifies runtime that it has completed draining all tasks.

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

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

Runtime can query how many tasks are currently registered (for monitoring).