Struct ConfigService 

pub struct ConfigService { /* private fields */ }

Configuration service for managing configurations

Implementations

impl ConfigService

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

Create a new ConfigService

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

Start the config service

pub async fn stop(&self)

Stop the config service

pub async fn get_config(&self, data_id: &str, group: &str) -> Result<String>

Get configuration

pub async fn get_config_with_timeout( &self, data_id: &str, group: &str, _timeout_ms: u64, ) -> Result<String>

Get configuration with timeout

pub async fn get_config_and_sign_listener<L>( &self, data_id: &str, group: &str, listener: L, ) -> Result<String>

where L: ConfigListener + 'static,

Get configuration and sign listener

pub async fn publish_config( &self, data_id: &str, group: &str, content: &str, ) -> Result<bool>

Publish configuration

pub async fn publish_config_with_type( &self, data_id: &str, group: &str, content: &str, config_type: Option<&str>, ) -> Result<bool>

Publish configuration with type

pub async fn remove_config(&self, data_id: &str, group: &str) -> Result<bool>

Remove configuration

pub fn add_listener<L>(&self, data_id: &str, group: &str, listener: L)

where L: ConfigListener + 'static,

Add listener for configuration changes

pub fn add_callback_listener<F>(&self, data_id: &str, group: &str, callback: F)

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

Add callback listener

pub fn remove_listener(&self, data_id: &str, group: &str)

Remove listener

pub async fn search_config( &self, data_id_pattern: &str, group_pattern: &str, page_no: i32, page_size: i32, ) -> Result<(i32, Vec<ConfigSearchItem>)>

Search configurations with pagination

pub async fn search_config_blur( &self, data_id_pattern: &str, group_pattern: &str, ) -> Result<Vec<ConfigSearchItem>>

Search configurations with blur matching

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

Get server status

Trait Implementations

impl Drop for ConfigService

fn drop(&mut self)

Executes the destructor for this type.