Struct GrpcTransport 

pub struct GrpcTransport {
    endpoint: String,
    channel: Arc<RwLock<Option<Channel>>>,
    config: TransportConfig,
    connected: Arc<RwLock<bool>>,
    stats: Arc<RwLock<TransportStats>>,
}

gRPC transport for communication with Mountain and other gRPC services

Fields

endpoint: String

Connection endpoint

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

gRPC channel

config: TransportConfig

Transport configuration

connected: Arc<RwLock<bool>>

Connection state

stats: Arc<RwLock<TransportStats>>

Transport statistics

Implementations

impl GrpcTransport

pub fn new(address: &str) -> Result<Self>

Create a new gRPC transport with the given address

Arguments

• address - The gRPC server address (e.g., “127.0.0.1:50050”)

Example

use grove::Transport::GrpcTransport;

let transport = GrpcTransport::new("127.0.0.1:50050")?;

pub fn with_config(address: &str, config: TransportConfig) -> Result<Self>

Create a new gRPC transport with custom configuration

pub fn endpoint(&self) -> &str

Get the connection endpoint

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

Get the gRPC channel

pub async fn stats(&self) -> TransportStats

Get transport statistics

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

Build 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