pub struct MessageProcessor { /* private fields */ }Implementations§
Source§impl MessageProcessor
impl MessageProcessor
pub fn new() -> (Self, Signal)
pub fn with_drain_channel(watch: Watch) -> Self
pub async fn connect<C>(
&self,
channel: C,
client_config: Option<ClientConfig>,
local: Option<SocketAddr>,
remote: Option<SocketAddr>,
) -> Result<(JoinHandle<()>, u64), DataPathError>where
C: GrpcService<Body>,
C::Error: Into<StdError>,
C::ResponseBody: Body<Data = Bytes> + Send + 'static,
<C::ResponseBody as Body>::Error: Into<StdError> + Send,
pub fn disconnect(&self, conn: u64) -> Result<(), DataPathError>
pub fn register_local_connection( &self, ) -> (u64, Sender<Result<Message, Status>>, Receiver<Result<Message, Status>>)
pub async fn send_msg( &self, msg: Message, out_conn: u64, ) -> Result<(), DataPathError>
pub async fn process_message( &self, msg: Message, in_connection: u64, ) -> Result<(), DataPathError>
Trait Implementations§
Source§impl Clone for MessageProcessor
impl Clone for MessageProcessor
Source§fn clone(&self) -> MessageProcessor
fn clone(&self) -> MessageProcessor
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 MessageProcessor
impl Debug for MessageProcessor
Source§impl PubSubService for MessageProcessor
impl PubSubService for MessageProcessor
Source§type OpenChannelStream = Pin<Box<dyn Stream<Item = Result<Message, Status>> + Send>>
type OpenChannelStream = Pin<Box<dyn Stream<Item = Result<Message, Status>> + Send>>
Server streaming response type for the OpenChannel method.
fn open_channel<'life0, 'async_trait>(
&'life0 self,
request: Request<Streaming<Message>>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::OpenChannelStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Auto Trait Implementations§
impl !RefUnwindSafe for MessageProcessor
impl !UnwindSafe for MessageProcessor
impl Freeze for MessageProcessor
impl Send for MessageProcessor
impl Sync for MessageProcessor
impl Unpin for MessageProcessor
impl UnsafeUnpin for MessageProcessor
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> ErasedDestructor for Twhere
T: 'static,
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::RequestSource§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