Struct eva_sdk::prelude::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 ) -> Initial

pub fn init(&self) -> Result<(), Error>

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

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

pub fn bus_path(&self) -> &str

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

pub async fn extend_config( &mut self, timeout: Duration, base: &Path ) -> impl Future<Output = Result<(), Error>>

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 ) -> impl Future<Output = Result<Arc<RpcClient>, Error>>where R: RpcHandlers + Send + Sync + 'static,

pub async fn init_rpc_blocking<R>( &self, handlers: R ) -> impl Future<Output = Result<Arc<RpcClient>, Error>>where R: RpcHandlers + Send + Sync + 'static,

pub async fn init_rpc_blocking_with_secondary<R>( &self, handlers: R ) -> impl Future<Output = Result<(Arc<RpcClient>, Arc<RpcClient>), Error>>where R: RpcHandlers + Send + Sync + 'static,

pub async fn init_rpc_opts<R>( &self, handlers: R, opts: Options ) -> impl Future<Output = Result<Arc<RpcClient>, Error>>where R: RpcHandlers + Send + Sync + 'static,

pub async fn init_bus_client( &self ) -> impl Future<Output = Result<Client, Error>>

pub async fn init_bus_client_sub( &self, sub_id: &str ) -> impl Future<Output = Result<Client, Error>>

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

Trait Implementations

impl Debug for Initial

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

Formats the value using the given formatter.

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

fn deserialize<__D>( __deserializer: __D ) -> Result<Initial, <__D as Deserializer<'de>>::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 as Serializer>::Ok, <__S as Serializer>::Error>where __S: Serializer,

Serialize this value into the given Serde serializer.