Struct eva_common::services::Initial

pub struct Initial { /* private fields */ }

Initial properties for services

Implementations

impl Initial

pub fn new( id: &str, system_name: &str, command: &str, prepare_command: Option<&str>, data_path: &str, timeout: &Timeout, core_info: CoreInfo, bus: BusConfig, config: Option<&Value>, workers: u32, user: Option<&str>, react_to_fail: bool, fips: bool, call_tracing: bool ) -> Self

pub fn init(&self) -> EResult<()>

pub fn config_version(&self) -> u16

pub fn system_name(&self) -> &str

pub fn id(&self) -> &str

pub fn command(&self) -> &str

pub fn prepare_command(&self) -> Option<&str>

pub fn user(&self) -> Option<&str>

pub fn data_path(&self) -> Option<&str>

pub fn planned_data_path(&self) -> &str

pub fn timeout(&self) -> Duration

pub fn startup_timeout(&self) -> Duration

pub fn shutdown_timeout(&self) -> Duration

pub fn bus_timeout(&self) -> Duration

pub fn eva_build(&self) -> u64

pub fn eva_version(&self) -> &str

pub fn eapi_version(&self) -> u16

pub fn eva_dir(&self) -> &str

pub fn eva_log_level(&self) -> u8

pub fn core_active(&self) -> bool

pub fn call_tracing(&self) -> bool

pub fn eva_log_level_filter(&self) -> LevelFilter

pub fn bus_config(&self) -> EResult<Config>

pub fn bus_config_for_sub(&self, sub_id: &str) -> EResult<Config>

pub fn bus_path(&self) -> &str

pub fn config(&self) -> Option<&Value>

pub async fn extend_config( &mut self, timeout: Duration, base: &Path ) -> EResult<()>

pub fn workers(&self) -> u32

pub fn bus_queue_size(&self) -> usize

pub fn take_config(&mut self) -> Option<Value>

pub async fn init_rpc<R>(&self, handlers: R) -> EResult<Arc<RpcClient>>

where R: RpcHandlers + Send + Sync + 'static,

pub async fn init_rpc_blocking<R>(&self, handlers: R) -> EResult<Arc<RpcClient>>

where R: RpcHandlers + Send + Sync + 'static,

pub async fn init_rpc_blocking_with_secondary<R>( &self, handlers: R ) -> EResult<(Arc<RpcClient>, Arc<RpcClient>)>

where R: RpcHandlers + Send + Sync + 'static,

pub async fn init_rpc_opts<R>( &self, handlers: R, opts: Options ) -> EResult<Arc<RpcClient>>

where R: RpcHandlers + Send + Sync + 'static,

pub async fn init_bus_client(&self) -> EResult<Client>

pub async fn init_bus_client_sub(&self, sub_id: &str) -> EResult<Client>

pub fn init_registry(&self, rpc: &Arc<RpcClient>) -> Registry

pub fn can_rtf(&self) -> bool

pub fn is_mode_normal(&self) -> bool

pub fn is_mode_rtf(&self) -> bool

pub fn set_fail_mode(&self, mode: bool)

pub fn drop_privileges(&self) -> EResult<()>

pub fn into_legacy_compat(self) -> Self

Trait Implementations

impl Debug for Initial

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Initial

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Initial

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

where __S: Serializer,

Serialize this value into the given Serde serializer.