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_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 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<()>

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.