Struct citadel_sdk::prefabs::server::internal_service::InternalServiceKernel

pub struct InternalServiceKernel<'a, F, Fut> { /* private fields */ }

Implementations

impl<'a, F, Fut> InternalServiceKernel<'a, F, Fut>

where F: Send + Copy + Sync + FnOnce(InternalServerCommunicator) -> Fut, Fut: Send + Sync + Future<Output = Result<(), NetworkError>>,

pub fn new(on_create_webserver: F) -> Self

Trait Implementations

impl<'a, F, Fut> NetKernel for InternalServiceKernel<'a, F, Fut>

fn load_remote(&mut self, node_remote: NodeRemote) -> Result<(), NetworkError>

when the kernel executes, it will be given a handle to the server

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

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

After the server remote is passed to the kernel, this function will be called once to allow the application to make any initial calls

fn on_node_event_received<'life0, 'async_trait>( &'life0 self, message: NodeResult, ) -> Pin<Box<dyn Future<Output = Result<(), NetworkError>> + Send + 'async_trait>>

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

When the server processes a valid entry, the value is sent here. Each call to ‘on_node_event_received’ is done concurrently (but NOT in parallel). This allows code inside this function to await without blocking new incoming messages

fn on_stop<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), NetworkError>> + Send + 'async_trait>>

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

When the system is ready to shutdown, this is called