pub struct ProsaConfig { /* private fields */ }Expand description
Loaded ProSA configuration.
Implementations§
Source§impl ProsaConfig
impl ProsaConfig
Sourcepub fn from_path(config_path: &str) -> Result<Self, ConfigError>
pub fn from_path(config_path: &str) -> Result<Self, ConfigError>
Load a ProSA configuration from a file or directory path.
Sourcepub fn from_config(config: Config) -> Result<Self, ConfigError>
pub fn from_config(config: Config) -> Result<Self, ConfigError>
Create a ProSA configuration wrapper and load all processor adaptor configs.
Sourcepub fn try_deserialize<C>(&self) -> Result<C, ConfigError>where
C: DeserializeOwned,
pub fn try_deserialize<C>(&self) -> Result<C, ConfigError>where
C: DeserializeOwned,
Deserialize the full configuration.
Sourcepub fn get_proc<C>(&self, proc: &impl ProcBusParam) -> Result<C, ConfigError>where
C: DeserializeOwned,
pub fn get_proc<C>(&self, proc: &impl ProcBusParam) -> Result<C, ConfigError>where
C: DeserializeOwned,
Deserialize a processor configuration from its processor name.
Sourcepub fn get_adaptor_config(&self, proc: &impl ProcBusParam) -> Option<&Config>
pub fn get_adaptor_config(&self, proc: &impl ProcBusParam) -> Option<&Config>
Access a processor adaptor configuration from its processor name.
Sourcepub fn watch_paths(&self, config_path: &str) -> Vec<PathBuf>
pub fn watch_paths(&self, config_path: &str) -> Vec<PathBuf>
Return every configuration path watched to maintain this configuration.
Sourcepub fn has_proc_changed(&self, new: &Self, proc_config_key: &str) -> bool
pub fn has_proc_changed(&self, new: &Self, proc_config_key: &str) -> bool
Check if one processor configuration differs from another loaded configuration.
Trait Implementations§
Source§impl Clone for ProsaConfig
impl Clone for ProsaConfig
Source§fn clone(&self) -> ProsaConfig
fn clone(&self) -> ProsaConfig
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for ProsaConfig
impl Debug for ProsaConfig
impl Eq for ProsaConfig
Source§impl From<ProsaConfig> for Config
impl From<ProsaConfig> for Config
Source§fn from(prosa_config: ProsaConfig) -> Self
fn from(prosa_config: ProsaConfig) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
impl !RefUnwindSafe for ProsaConfig
impl !UnwindSafe for ProsaConfig
impl Freeze for ProsaConfig
impl Send for ProsaConfig
impl Sync for ProsaConfig
impl Unpin for ProsaConfig
impl UnsafeUnpin for ProsaConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request