rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-20 15:00:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix compile

Browse Source 
Signed-off-by: tison <wander4096@gmail.com>
This commit is contained in:
tison
2024-03-26 14:43:53 +08:00
parent 704ac44c23
commit e6ed9ca43e
4 changed files with 9 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/auth/src/error.rs
View File

@@ -66,7 +66,7 @@ pub enum Error {
#[snafu(display("Failed to initialize a watcher for file {}", path))]
FileWatch {
path: Option<String>,
path: String,
#[snafu(source)]
error: notify::Error,
},

6
src/auth/src/user_provider/watch_file_user_provider.rs
View File

@@ -45,13 +45,11 @@ impl WatchFileUserProvider {
let (tx, rx) = channel::<DebounceEventResult>();
let mut debouncer = new_debouncer(Duration::from_secs(1), None, tx)
.context(FileWatchSnafu { path: None })?;
.context(FileWatchSnafu { path: "<none>" })?;
debouncer
.watcher()
.watch(Path::new(filepath), RecursiveMode::NonRecursive)
.context(FileWatchSnafu {
path: Some(filepath),
})?;
.context(FileWatchSnafu { path: filepath })?;
let filepath = filepath.to_string();
std::thread::spawn(move || {

2
src/servers/src/error.rs
View File

@@ -451,7 +451,7 @@ pub enum Error {
#[snafu(display("Failed to initialize a watcher for file {}", path))]
FileWatch {
path: Option<String>,
path: String,
#[snafu(source)]
error: notify::Error,
},

10
src/servers/src/tls.rs
View File

@@ -200,20 +200,20 @@ pub fn maybe_watch_tls_config(tls_server_config: Arc<ReloadableTlsServerConfig>)
let tls_server_config_for_watcher = tls_server_config.clone();
let (tx, rx) = channel::<notify::Result<notify::Event>>();
let mut watcher = notify::recommended_watcher(tx).context(FileWatchSnafu { path: None })?;
let mut watcher = notify::recommended_watcher(tx).context(FileWatchSnafu { path: "<none>" })?;
let cert_path = tls_server_config.get_tls_option().cert_path();
watcher
.watch(cert_path, RecursiveMode::NonRecursive)
.context(FileWatchSnafu {
path: Some(cert_path),
.with_context(|_| FileWatchSnafu {
path: cert_path.display().to_string(),
})?;
let key_path = tls_server_config.get_tls_option().key_path();
watcher
.watch(key_path, RecursiveMode::NonRecursive)
.context(FileWatchSnafu {
path: Some(key_path),
.with_context(|_| FileWatchSnafu {
path: key_path.display().to_string(),
})?;
std::thread::spawn(move || {