Struct nacos_api::integration::NacosClient

pub struct NacosClient { /* fields omitted */ }

Implementations

impl NacosClient

pub fn new(nacos_config: NacosConfig, server_config: ServerConfig) -> Self

pub fn nacos_config(&self) -> &NacosConfig

pub fn service_api(&self) -> &NacosServiceApi

pub fn nacos_config_mut(&mut self) -> &mut NacosConfig

pub fn service_api_mut(&mut self) -> &mut NacosServiceApi

impl NacosClient

pub async fn register(&self, option: &Option<RegisterInstanceOption>)

注册当前实例并自动发送/回应心跳 register current instance and send/ack hart beat.

use tokio::net::TcpListener;
use nacos_api::{NacosClient,NacosConfig, ServerConfig};

// must open the port what config in ServerConfig to ack for nacos server
tokio::spawn(async {
let tcp_listen = TcpListener::bind("0.0.0.0:8080").await.unwrap();
    loop {
        let (_, b) = tcp_listen.accept().await.unwrap();
        println!(" - addr from : {:?}", b);
    }
});

// create a client
let client = NacosClient::new(
    NacosConfig::new(
        "http",
        "192.168.0.132",
        8848),
    ServerConfig::new(
        "127.0.0.1",
        8080,
        "test"),
);

// register current instance to nacos
// and new thread in background send and ack hart beat
client.register(&None).await;

pub async fn get_addr_simple(
    &self,
    server_name: &str,
    req_addr: &str
) -> Result<String, Box<dyn Error>>

随机获取一个健康实例的请求地址 get a random health instance`s request address .

use nacos_api::{NacosClient,NacosConfig, ServerConfig};

let client = NacosClient::new(
    NacosConfig::new(
        "http",
        "192.168.0.132",
        8848),
    ServerConfig::new(
        "127.0.0.1",
        8080,
        "test"),
);
let addr = client.get_addr_simple("test","/hi/friend").await?;
assert!("http://127.0.0.1:8080/hi/friend", addr.as_str());

Trait Implementations

impl Clone for NacosClient

fn clone(&self) -> NacosClient

Returns a copy of the value.

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

Performs copy-assignment from source.