Struct MessageProcessor 

pub struct MessageProcessor { /* private fields */ }

Implementations

impl MessageProcessor

pub fn new_with_service_id(service_id: String) -> Self

pub fn new_with_options( service_id: String, recovery_ttl: Option<Duration>, ) -> Self

pub fn new() -> Self

pub async fn run_server( &self, config: &ServerConfig, ) -> Result<CancellationToken, DataPathError>

Run a data plane gRPC server using this message processor’s drain watch. Returns a cancellation token that can be used to stop the server task.

pub async fn shutdown(&self) -> Result<(), DataPathError>

pub async fn connect( &self, client_config: ClientConfig, local: Option<SocketAddr>, remote: Option<SocketAddr>, ) -> Result<(JoinHandle<()>, u64), DataPathError>

pub fn disconnect(&self, conn: u64) -> Result<ClientConfig, DataPathError>

pub fn register_local_connection( &self, from_control_plane: bool, ) -> Result<(u64, Sender<Result<Message, Status>>, Receiver<Result<Message, Status>>), DataPathError>

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

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

pub fn subscription_table(&self) -> &SubscriptionTableImpl

pub fn connection_table(&self) -> &ConnectionTable<Connection>

Trait Implementations

impl Clone for MessageProcessor

fn clone(&self) -> MessageProcessor

Returns a duplicate 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 Default for MessageProcessor

fn default() -> Self

Returns the “default value” for a type.