Struct silx_core::servants::shutdown::ShutdownBuilder

pub struct ShutdownBuilder { /* private fields */ }

Structure defining Shutdown servant

• This servant await a WakeSlx message and then shut down the cluster

Implementations

impl ShutdownBuilder

pub fn new(channel_shutdown: String) -> Self

Shutdown servant builder channel_shutdown: String : channel name for awakening this servant Output: shutdown servant

pub fn default_channels() -> Self

Default shutdown servant builder Output: shutdown servant

Trait Implementations

impl Clone for ShutdownBuilder

fn clone(&self) -> ShutdownBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'de> Deserialize<'de> for ShutdownBuilder

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ShutdownBuilder

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl ServantBuilder for ShutdownBuilder

fn dyn_clone(&self) -> Box<dyn ServantBuilder>

Clone the servant builder as boxed dyn ServantBuilder

fn build( &self, servant_id: u32, servant_name: String, ch_naming: &FnvHashMap<u64, String>, recv_from_master: Receiver<(MsgFromMaster, Sender<ReplyToMaster>)>, send_2_master: SendToMaster, task_id: IdBuilder ) -> Result<Servant, String>

Build a servant instance

impl ServantBuilderParameters for ShutdownBuilder

fn max_cycle_time(&self) -> Duration

Max duration for master to servant query request

fn build_process( &self, task_id: IdBuilder, send_to_master: SendToMaster ) -> ProcessInstance

build process instance