Struct HyperServerProc

pub struct HyperServerProc<M>
where
    M: 'static + Send + Sync + Sized + Clone + Debug + Tvf + Default,
{
    pub settings: HyperServerSettings,
    /* private fields */
}

Hyper server processor

Fields

settings: HyperServerSettings

Settings of the processor

Trait Implementations

impl<M, A> Proc<A> for HyperServerProc<M>

where M: 'static + Send + Sync + Sized + Clone + Debug + Tvf + Default, A: 'static + Adaptor + HyperServerAdaptor<M> + Clone + Send + Sync,

async fn internal_run( &mut self, name: String, ) -> Result<(), Box<dyn ProcError + Send + Sync>>

Main loop of the processor

fn get_proc_threads(&self) -> usize

Get the number of processor threads the Processors’s Runtime will use. Must be implemented by the processor if more than one thread is to be used

fn run(self, proc_name: String)

where Self: Sized + 'static + Send,

Method to run the processor

impl<M> ProcBusParam for HyperServerProc<M>

where M: 'static + Send + Sync + Sized + Clone + Debug + Tvf + Default,

fn get_proc_id(&self) -> u32

Getter of the HyperServerProc processor ID

fn name(&self) -> &str

Getter of the HyperServerProc processor Name

impl<M> ProcConfig<M> for HyperServerProc<M>

where M: 'static + Send + Sync + Sized + Clone + Debug + Tvf + Default,

type Settings = HyperServerSettings

Settings use for the ProSA processor

fn create(proc_id: u32, main: Main<M>, settings: Self::Settings) -> Self

Method to create a processor out of it’s configuration

fn get_proc_param(&self) -> &ProcParam<M>

Getter of the processor parameters

fn create_raw(proc_id: u32, main: Main<M>) -> Self

where Self: Sized, Self::Settings: Default,

Method to create a processor with not specific configuration

impl<M> ProcEpilogue for HyperServerProc<M>

where M: 'static + Send + Sync + Sized + Clone + Debug + Tvf + Default,

fn get_proc_restart_delay(&self) -> (Duration, u32)

Getter to know timer for processor restart in case of error

async fn remove_proc( &self, err: Option<Box<dyn ProcError + Send + Sync>>, ) -> Result<(), BusError>

Method to remove the processor with a signal queue to the main task

fn is_stopping(&self) -> bool

Indicates whether ProSA is stopping Prevents the rebooting of processors