Struct MessageProcessor

pub struct MessageProcessor { /* private fields */ }

Implementations

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<BoxBody>, 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, ) -> (Sender<Result<Message, Status>>, Receiver<Result<Message, Status>>)

pub async fn send_msg( &self, msg: Message, out_conn: u64, ) -> Result<(), Box<dyn Error>>

pub async fn process_message( &self, msg: Message, in_connection: u64, ) -> Result<(), DataPathError>

Trait Implementations

impl Clone for MessageProcessor

fn clone(&self) -> MessageProcessor

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MessageProcessor

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

Formats the value using the given formatter.

impl PubSubService for MessageProcessor

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,