pub enum InternalMsg<M>{
Request(RequestMsg<M>),
Response(ResponseMsg<M>),
Error(ErrorMsg<M>),
Command(String),
Config,
Service(Arc<ServiceTable<M>>),
Shutdown,
}Expand description
Internal ProSA message that define all message type that can be received by a processor
Variants§
Request(RequestMsg<M>)
Request Data message to process
Response(ResponseMsg<M>)
Response of a data request message
Error(ErrorMsg<M>)
Response of a data request message by an error
Command(String)
Command to ask an actiion or a status to the processor
Config
Message to ask the processor to reload its configuration
Service(Arc<ServiceTable<M>>)
Message to ask the processor to reload its service table
Shutdown
Message to ask the processor to shutdown
Trait Implementations§
Auto Trait Implementations§
impl<M> Freeze for InternalMsg<M>where
M: Freeze,
impl<M> !RefUnwindSafe for InternalMsg<M>
impl<M> Send for InternalMsg<M>where
M: Send,
impl<M> Sync for InternalMsg<M>
impl<M> Unpin for InternalMsg<M>where
M: Unpin,
impl<M> !UnwindSafe for InternalMsg<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
Mutably borrows from an owned value. Read more
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