Skip to content

Commit 0bdd178

Browse files
author
Devdutt Shenoi
committed
simplify RelativePathBuf construction
1 parent a266390 commit 0bdd178

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

src/storage/object_storage.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -101,7 +101,7 @@ pub trait ObjectStorage: Debug + Send + Sync + 'static {
101101
) -> Result<HashMap<RelativePathBuf, Vec<Bytes>>, ObjectStorageError> {
102102
let mut filters: HashMap<RelativePathBuf, Vec<Bytes>> = HashMap::new();
103103

104-
let users_dir = RelativePathBuf::from_iter([USERS_ROOT_DIR]);
104+
let users_dir = RelativePathBuf::from(USERS_ROOT_DIR);
105105
for user in self.list_dirs_relative(&users_dir).await? {
106106
let stream_dir = users_dir.join(&user).join("filters");
107107
for stream in self.list_dirs_relative(&stream_dir).await? {
@@ -127,7 +127,7 @@ pub trait ObjectStorage: Debug + Send + Sync + 'static {
127127
) -> Result<HashMap<RelativePathBuf, Vec<Bytes>>, ObjectStorageError> {
128128
let mut dashboards: HashMap<RelativePathBuf, Vec<Bytes>> = HashMap::new();
129129

130-
let users_dir = RelativePathBuf::from_iter([USERS_ROOT_DIR]);
130+
let users_dir = RelativePathBuf::from(USERS_ROOT_DIR);
131131
for user in self.list_dirs_relative(&users_dir).await? {
132132
let dashboards_path = users_dir.join(&user).join("dashboards");
133133
let dashboard_bytes = self
@@ -153,7 +153,7 @@ pub trait ObjectStorage: Debug + Send + Sync + 'static {
153153
) -> Result<HashMap<RelativePathBuf, Vec<Bytes>>, ObjectStorageError> {
154154
let mut correlations: HashMap<RelativePathBuf, Vec<Bytes>> = HashMap::new();
155155

156-
let users_dir = RelativePathBuf::from_iter([USERS_ROOT_DIR]);
156+
let users_dir = RelativePathBuf::from(USERS_ROOT_DIR);
157157
for user in self.list_dirs_relative(&users_dir).await? {
158158
let correlations_path = users_dir.join(&user).join("correlations");
159159
let correlation_bytes = self
@@ -376,7 +376,7 @@ pub trait ObjectStorage: Debug + Send + Sync + 'static {
376376
}
377377

378378
async fn get_alerts(&self) -> Result<Vec<AlertConfig>, ObjectStorageError> {
379-
let alerts_path = RelativePathBuf::from_iter([ALERTS_ROOT_DIRECTORY]);
379+
let alerts_path = RelativePathBuf::from(ALERTS_ROOT_DIRECTORY);
380380
let alerts = self
381381
.get_objects(
382382
Some(&alerts_path),
@@ -700,7 +700,7 @@ pub trait ObjectStorage: Debug + Send + Sync + 'static {
700700
}
701701

702702
async fn get_correlations(&self) -> Result<Vec<Bytes>, CorrelationError> {
703-
let correlation_path = RelativePathBuf::from_iter([CORRELATION_DIR]);
703+
let correlation_path = RelativePathBuf::from(CORRELATION_DIR);
704704
let correlation_bytes = self
705705
.get_objects(
706706
Some(&correlation_path),

0 commit comments

Comments
 (0)