Struct M2mLoopback

pub struct M2mLoopback { /* private fields */ }

Loopback transport service for in-process M2M communication.

M2mLoopback provides a transport implementation that routes M2M requests to local middleware instances within the same process. It maintains a registry of middleware instances indexed by IP address and supports configurable network delay simulation.

Network Simulation

The service can simulate network latency by introducing delays before processing requests. This includes both a base delay and random jitter to simulate real network conditions.

Thread Safety

The service is thread-safe and can be safely cloned and used across multiple concurrent tasks. All internal state is protected by appropriate synchronization primitives.

Implementations

impl M2mLoopback

pub fn new(base_delay_ms: u64, jitter_max_ms: u64) -> Self

Creates a new loopback transport with the specified delay characteristics.

Arguments

• base_delay_ms - Base delay to add to all requests in milliseconds
• jitter_max_ms - Maximum random additional delay in milliseconds

pub async fn register_middleware( &self, ip: String, middleware: M2mApiDefaultStack, )

Registers a middleware instance with the specified IP address.

This allows the loopback transport to route requests to the appropriate middleware instance based on the target IP address extracted from requests.

Arguments

• ip - IP address identifier for the middleware
• middleware - The middleware service instance to register

pub async fn get_middleware( &self, ip: String, ) -> Result<M2mApiDefaultStack, TraceabilityError>

Retrieves a middleware instance for the specified IP address.

Arguments

• ip - IP address of the target middleware

Returns

The middleware service instance, or an error if not found.

Errors

Returns TransportFailedToContactRemote if no middleware is registered for the specified IP address.

Trait Implementations

impl Clone for M2mLoopback

fn clone(&self) -> M2mLoopback

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for M2mLoopback

fn default() -> Self

Returns the “default value” for a type.

impl Service<M2mRequest> for M2mLoopback

type Response = M2mResponse

Responses given by the service.

type Error = TraceabilityError

Errors produced by the service.

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

The future response value.

fn poll_ready(&mut self, cx: &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.