Struct gRPCTransport 

pub struct gRPCTransport {
    Endpoint: String,
    Channel: Arc<RwLock<Option<Channel>>>,
    Configuration: TransportConfig,
    Connected: Arc<RwLock<bool>>,
    Statistics: Arc<RwLock<TransportStats>>,
}

gRPC transport for communication with Mountain and other gRPC services.

Fields

Endpoint: String

Connection endpoint address.

Channel: Arc<RwLock<Option<Channel>>>

gRPC channel (lazily connected).

Configuration: TransportConfig

Transport configuration.

Connected: Arc<RwLock<bool>>

Whether the transport is currently connected.

Statistics: Arc<RwLock<TransportStats>>

Transport statistics.

Implementations

impl gRPCTransport

pub fn New(Address: &str) -> Result<Self>

Creates a new gRPC transport with the given address.

pub fn WithConfiguration( Address: &str, Configuration: TransportConfig, ) -> Result<Self>

Creates a new gRPC transport with custom configuration.

pub fn Address(&self) -> &str

Returns the connection endpoint address.

pub async fn GetChannel(&self) -> Result<Channel>

Returns the active gRPC channel.

pub async fn Statistics(&self) -> TransportStats

Returns a snapshot of transport statistics.

fn BuildEndpoint(&self) -> Result<Endpoint>

Builds an endpoint from the address string.

Trait Implementations

impl Clone for gRPCTransport

fn clone(&self) -> gRPCTransport

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for gRPCTransport

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

Formats the value using the given formatter.

impl TransportStrategy for gRPCTransport

type Error = gRPCTransportError

Error type for this transport

fn connect<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connect to the transport endpoint

fn send<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a request and receive a response

fn send_no_response<'life0, 'life1, 'async_trait>( &'life0 self, data: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send data without expecting a response (fire and forget)

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Close the transport connection

fn is_connected(&self) -> bool

Check if the transport is connected

fn transport_type(&self) -> TransportType

Get the transport type identifier