Struct StubProc 

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

Stub processor to respond to a request

use prosa::core::main::{MainProc, MainRunnable};
use prosa::core::proc::{proc, Proc, ProcBusParam, ProcConfig};
use prosa::stub::adaptor::StubParotAdaptor;
use prosa::stub::proc::{StubProc, StubSettings};
use prosa_utils::config::observability::Observability;
use prosa_utils::msg::simple_string_tvf::SimpleStringTvf;
use prosa::core::settings::settings;
use serde::Serialize;

// Main settings
#[settings]
#[derive(Default, Debug, Serialize)]
struct Settings {}

// Create bus and main processor
let settings = Settings::default();
let (bus, main) = MainProc::<SimpleStringTvf>::create(&settings, Some(1));

// Launch a stub processor
let stub_settings = StubSettings::new(vec![String::from("STUB_TEST")]);
let stub_proc = StubProc::<SimpleStringTvf>::create(1, "STUB_PROC".to_string(), bus.clone(), stub_settings);
Proc::<StubParotAdaptor>::run(stub_proc);

// Wait on main task
//main_task.await;

Fields

settings: StubSettings

Settings of the processor

Trait Implementations

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

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

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

Main loop of the processor to implement

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) -> Result<(), Error>

where Self: Sized + 'static + Send,

Method to run the processor

impl<M> ProcBusParam for StubProc<M>

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

fn get_proc_id(&self) -> u32

Getter of the StubProc processor ID

fn name(&self) -> &str

Getter of the StubProc processor Name

impl<M> ProcConfig<M> for StubProc<M>

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

type Settings = StubSettings

Settings use for the ProSA processor

fn create( proc_id: u32, proc_name: String, 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, proc_name: String, main: Main<M>) -> Self

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

Method to create a processor with not specific configuration

impl<M> ProcEpilogue for StubProc<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