Struct ConsulConfig 

pub struct ConsulConfig {
    pub config: Option<Config>,
    pub watch_services: Option<Vec<WatchService>>,
}

Fields

config: Option<Config>

watch_services: Option<Vec<WatchService>>

Implementations

impl ConsulConfig

pub async fn load_config(path: &str) -> Result<()>

pub async fn new_request(&self, method: Method, path: &str) -> Result<Request>

pub async fn service_register( &self, service: &AgentServiceRegistration, ) -> Result<StatusCode>

service_register is used to register a new service with the local agent

use consul_rs::api::CONSUL_CONFIG;
use async_std::task::block_on;
use consul_rs::agent::AgentServiceRegistration;
let clone_consul = CONSUL_CONFIG.clone();
let consul = block_on(clone_consul.read());
let mut service = AgentServiceRegistration::default();
service.ID = Some(String::from("321"));
service.Name = Some(String::from("test"));
service.Port = Some(8080);
service.Address = Some(String::from("127.0.0.1"));
let s = block_on(consul.service_register(&service)).unwrap();
println!("{}", s);

pub async fn service_register_opts( &self, service: &AgentServiceRegistration, opts: &ServiceRegisterOpts, ) -> Result<StatusCode>

pub async fn service_register_self( &self, service: &AgentServiceRegistration, opts: &ServiceRegisterOpts, ) -> Result<StatusCode>

pub async fn service_deregister(&self, service_id: String) -> Result<StatusCode>

service_deregister is used to register a new service with the local agent

use consul_rs::api::CONSUL_CONFIG;
use async_std::task::block_on;
use consul_rs::ConsulTrait;
use consul_rs::agent::AgentServiceRegistration;
let clone_consul = CONSUL_CONFIG.clone();
let consul = block_on(clone_consul.read());
let service_id = String::from("321");
let s = block_on(consul.service_deregister(service_id)).unwrap();
println!("{}", s);

pub async fn watch_services() -> Result<()>

pub async fn random_policy( &self, service_name: &str, tag: &str, ) -> Result<String>

Trait Implementations

impl Clone for ConsulConfig

fn clone(&self) -> ConsulConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsulConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ConsulConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ConsulConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ConsulConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.