Struct M2mGrpc

pub struct M2mGrpc { /* private fields */ }

gRPC client service for machine-to-machine communication.

M2mGrpc provides the client-side implementation for making gRPC calls to remote trace2e middleware instances. It manages connection pooling and handles the translation between internal M2M requests and gRPC protocol.

Connection Management

The service maintains a thread-safe cache of connected clients to avoid connection overhead. Connections are established lazily when first needed and reused for subsequent requests to the same remote endpoint.

Request Routing

The service automatically determines the target remote IP address from the request payload and routes the call to the appropriate endpoint. Network failures are reported as transport errors.

Trait Implementations

impl Clone for M2mGrpc

fn clone(&self) -> M2mGrpc

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for M2mGrpc

fn default() -> M2mGrpc

Returns the “default value” for a type.

impl Service<M2mRequest> for M2mGrpc

type Response = M2mResponse

Responses given by the service.

type Error = TraceabilityError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<M2mGrpc as Service<M2mRequest>>::Response, <M2mGrpc as Service<M2mRequest>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, request: M2mRequest) -> Self::Future

Process the request and return the response asynchronously.