Struct NamingService 

pub struct NamingService { /* private fields */ }

Naming service for service discovery and registration

Implementations

impl NamingService

pub fn new( rpc_client: Arc<RpcClient>, namespace: &str, cache_config: CacheConfig, ) -> Self

Create a new NamingService with default WRR load balancer

pub fn with_balancer( rpc_client: Arc<RpcClient>, namespace: &str, cache_config: CacheConfig, balancer: Arc<dyn LoadBalancer>, ) -> Self

Create a new NamingService with custom load balancer

pub fn with_group(self, group_name: &str) -> Self

Set default group name

pub async fn start(&self) -> Result<()>

Start the naming service

pub async fn stop(&self)

Stop the naming service

pub async fn register_instance( &self, service_name: &str, group_name: &str, instance: Instance, ) -> Result<()>

Register a service instance

pub async fn register_instance_simple( &self, service_name: &str, ip: &str, port: i32, ) -> Result<()>

Register a service instance with simplified parameters

pub async fn deregister_instance( &self, service_name: &str, group_name: &str, instance: Instance, ) -> Result<()>

Deregister a service instance

pub async fn deregister_instance_simple( &self, service_name: &str, ip: &str, port: i32, ) -> Result<()>

Deregister a service instance with simplified parameters

pub async fn update_instance( &self, service_name: &str, group_name: &str, instance: Instance, ) -> Result<()>

Update a service instance

pub async fn update_instance_simple( &self, service_name: &str, ip: &str, port: i32, weight: f64, enabled: bool, ) -> Result<()>

Update a service instance with simplified parameters

pub async fn get_service( &self, service_name: &str, group_name: &str, clusters: &[String], ) -> Result<Service>

Get service information with cluster filtering

pub async fn get_all_instances( &self, service_name: &str, group_name: &str, ) -> Result<Vec<Instance>>

Get all instances of a service

pub async fn select_instances( &self, service_name: &str, group_name: &str, healthy_only: bool, ) -> Result<Vec<Instance>>

Select healthy instances of a service

pub async fn select_one_healthy_instance( &self, service_name: &str, group_name: &str, ) -> Result<Instance>

Select one healthy instance using the configured load balancer

By default, uses Weighted Round Robin (WRR) algorithm which distributes traffic proportionally to instance weights.

pub async fn get_services_of_server( &self, group_name: &str, page_no: i32, page_size: i32, ) -> Result<(i32, Vec<String>)>

Get list of services

pub async fn subscribe<L>( &self, service_name: &str, group_name: &str, listener: L, ) -> Result<()>

where L: ServiceListener + 'static,

Subscribe to service changes

pub async fn subscribe_callback<F>( &self, service_name: &str, group_name: &str, callback: F, ) -> Result<()>

where F: Fn(ServiceChangeEvent) + Send + Sync + 'static,

Subscribe with callback

pub async fn unsubscribe( &self, service_name: &str, group_name: &str, ) -> Result<()>

Unsubscribe from service changes

pub async fn get_server_status(&self) -> Result<String>

Get server status

Trait Implementations

impl Drop for NamingService

fn drop(&mut self)

Executes the destructor for this type.