Struct DirectoryGrpcClient 

pub struct DirectoryGrpcClient { /* private fields */ }

gRPC client for Directory API

This client connects to a remote DirectoryService via gRPC and provides typed access to service discovery functionality. It includes:

• Configurable timeouts and retries via transport stack
• Automatic proto ↔ domain type conversions
• Distributed tracing and metrics

Implementations

impl DirectoryGrpcClient

pub async fn connect( uri: impl Into<String>, ) -> Result<DirectoryGrpcClient, Error>

Connect to a directory service using default configuration with retries.

Uses exponential backoff retry logic for reliable connection establishment. This is the recommended method for OoP modules connecting to the master host.

Errors

It will return an error when it fails

pub async fn connect_with_retry( uri: impl Into<String>, cfg: &GrpcClientConfig, ) -> Result<DirectoryGrpcClient, Error>

Connect to a directory service with custom configuration and retry logic.

Uses exponential backoff based on cfg.max_retries, cfg.base_backoff, and cfg.max_backoff settings.

Errors

It will return an error when it fails

pub async fn connect_no_retry( uri: impl Into<String>, cfg: &GrpcClientConfig, ) -> Result<DirectoryGrpcClient, Error>

Connect to a directory service without retry logic.

This method attempts a single connection. Use connect or connect_with_retry for production scenarios where the directory service may not be immediately available.

Errors

It will return an error when it fails

pub fn from_channel(channel: Channel) -> DirectoryGrpcClient

Create from an existing channel (useful for testing or custom setup)

Trait Implementations

impl DirectoryClient for DirectoryGrpcClient

fn resolve_grpc_service<'life0, 'life1, 'async_trait>( &'life0 self, service_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<ServiceEndpoint, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DirectoryGrpcClient: 'async_trait,

Resolve a gRPC service by its logical name to an endpoint

fn list_instances<'life0, 'life1, 'async_trait>( &'life0 self, module: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<ServiceInstanceInfo>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DirectoryGrpcClient: 'async_trait,

List all service instances for a given module

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

where 'life0: 'async_trait, DirectoryGrpcClient: 'async_trait,

Register a new module instance with the directory

fn deregister_instance<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, module: &'life1 str, instance_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, DirectoryGrpcClient: 'async_trait,

Deregister a module instance (for graceful shutdown)

fn send_heartbeat<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, module: &'life1 str, instance_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, DirectoryGrpcClient: 'async_trait,

Send a heartbeat for a module instance to indicate it’s still alive