pub struct ServiceTable<M>{ /* private fields */ }Expand description
Strucure that define the service table which contain information to how contact a processor for a given service name
Implementations§
Source§impl<M> ServiceTable<M>
impl<M> ServiceTable<M>
Sourcepub fn exist_proc_service(&self, name: &str) -> bool
pub fn exist_proc_service(&self, name: &str) -> bool
Method to know if the service is available from a processor
Call by the processor to know if a service is available (service test)
Sourcepub fn get_proc_service(&self, name: &str) -> Option<&ProcService<M>>
pub fn get_proc_service(&self, name: &str) -> Option<&ProcService<M>>
Method to get a processor that respond to the service
Call by the processor to send a transaction to a processor that give the corresponding service
Sourcepub fn add_service(&mut self, name: &str, proc_service: ProcService<M>)
pub fn add_service(&mut self, name: &str, proc_service: ProcService<M>)
Method to add a service to the table
Can be call only by the main task to modify the service table
Sourcepub fn remove_service_proc(&mut self, name: &str, proc_id: u32)
pub fn remove_service_proc(&mut self, name: &str, proc_id: u32)
Method to remove whole processor service from the table
Can be call only by the main task to modify the service table
Sourcepub fn remove_service(&mut self, name: &str, proc_id: u32, queue_id: u32)
pub fn remove_service(&mut self, name: &str, proc_id: u32, queue_id: u32)
Method to remove a service from the table
Can be call only by the main task to modify the service table
Sourcepub fn remove_proc_services(&mut self, proc_id: u32)
pub fn remove_proc_services(&mut self, proc_id: u32)
Method to remove all services from a given processor from the table
Can be call only by the main task to modify the service table
Sourcepub fn remove_proc_queue_services(&mut self, proc_id: u32, queue_id: u32)
pub fn remove_proc_queue_services(&mut self, proc_id: u32, queue_id: u32)
Method to remove all services from a given processor queue from the table
Can be call only by the main task to modify the service table
Trait Implementations§
Source§impl<M> Clone for ServiceTable<M>
impl<M> Clone for ServiceTable<M>
Source§impl<M> Debug for ServiceTable<M>
impl<M> Debug for ServiceTable<M>
Source§impl<M> Default for ServiceTable<M>
impl<M> Default for ServiceTable<M>
Source§fn default() -> ServiceTable<M>
fn default() -> ServiceTable<M>
Auto Trait Implementations§
impl<M> Freeze for ServiceTable<M>
impl<M> RefUnwindSafe for ServiceTable<M>
impl<M> Send for ServiceTable<M>where
M: Send,
impl<M> Sync for ServiceTable<M>where
M: Send,
impl<M> Unpin for ServiceTable<M>
impl<M> UnsafeUnpin for ServiceTable<M>
impl<M> UnwindSafe for ServiceTable<M>
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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>
T in a tonic::RequestSource§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T> ToStringFallible for Twhere
T: Display,
impl<T> ToStringFallible for Twhere
T: Display,
Source§fn try_to_string(&self) -> Result<String, TryReserveError>
fn try_to_string(&self) -> Result<String, TryReserveError>
ToString::to_string, but without panic on OOM.