run fmt

Signed-off-by: Eren Atas <[email protected]>

Author: erenatas

crates/flagd/src/resolver/in_process/resolver/file.rs

@@ -68,7 +68,7 @@ impl FileResolver {
                 return Err(EvaluationError::builder()
                     .code(EvaluationErrorCode::FlagNotFound)
                     .message(format!("Flag {} not found", flag_key))
-                    .build())
+                    .build());
             }
         };
 

crates/flagd/src/resolver/in_process/resolver/grpc.rs

@@ -3,14 +3,14 @@ use crate::resolver::in_process::targeting::Operator;
 use crate::{CacheService, FlagdOptions};
 use anyhow::Result;
 use async_trait::async_trait;
-use open_feature::provider::{FeatureProvider, ProviderMetadata, ResolutionDetails};
 use open_feature::Value as OpenFeatureValue;
+use open_feature::provider::{FeatureProvider, ProviderMetadata, ResolutionDetails};
 use open_feature::{EvaluationContext, EvaluationError, EvaluationErrorCode, StructValue, Value};
 use serde_json::Value as JsonValue;
 use std::sync::Arc;
 
-use crate::resolver::in_process::storage::connector::grpc::GrpcStreamConnector;
 use crate::resolver::in_process::storage::FlagStore;
+use crate::resolver::in_process::storage::connector::grpc::GrpcStreamConnector;
 
 pub struct InProcessResolver {
     store: Arc<FlagStore>,
@@ -134,7 +134,7 @@ impl InProcessResolver {
                 return Err(EvaluationError::builder()
                     .code(EvaluationErrorCode::FlagNotFound)
                     .message(format!("Flag {} not found", flag_key))
-                    .build())
+                    .build());
             }
         };
 
@@ -194,7 +194,7 @@ impl InProcessResolver {
                         variant: Some(variant),
                         reason: Some(open_feature::EvaluationReason::TargetingMatch),
                         flag_metadata: None,
-                    })
+                    });
                 }
             };
             cache.add(flag_key, context, cache_value).await;

crates/flagd/src/resolver/in_process/storage/connector/file.rs

@@ -1,10 +1,10 @@
 use super::{Connector, QueuePayload, QueuePayloadType};
 use anyhow::Result;
 use std::path::PathBuf;
-use std::sync::atomic::{AtomicBool, Ordering};
 use std::sync::Arc;
-use tokio::sync::mpsc::{channel, Receiver, Sender};
+use std::sync::atomic::{AtomicBool, Ordering};
 use tokio::sync::Mutex;
+use tokio::sync::mpsc::{Receiver, Sender, channel};
 use tokio::time::Duration;
 use tracing::{debug, error};
 

crates/flagd/src/resolver/in_process/storage/connector/mod.rs

@@ -3,8 +3,8 @@ pub mod grpc;
 
 use std::collections::HashMap;
 use std::sync::Arc;
-use tokio::sync::mpsc::Receiver;
 use tokio::sync::Mutex;
+use tokio::sync::mpsc::Receiver;
 
 #[derive(Debug)]
 pub struct QueuePayload {

crates/flagd/src/resolver/in_process/storage/mod.rs

@@ -6,8 +6,8 @@ use crate::resolver::in_process::model::feature_flag::FeatureFlag;
 use crate::resolver::in_process::model::flag_parser::FlagParser;
 use std::collections::HashMap;
 use std::sync::Arc;
-use tokio::sync::mpsc::{channel, Receiver, Sender};
 use tokio::sync::RwLock;
+use tokio::sync::mpsc::{Receiver, Sender, channel};
 
 #[derive(Debug, Clone, PartialEq)]
 pub enum StorageState {

crates/flagd/tests/cache_test.rs

@@ -1,4 +1,4 @@
-use common::{Flagd, FLAGD_CONFIG, FLAGD_OFREP_PORT, FLAGD_PORT, FLAGD_SYNC_PORT};
+use common::{FLAGD_CONFIG, FLAGD_OFREP_PORT, FLAGD_PORT, FLAGD_SYNC_PORT, Flagd};
 use open_feature::provider::FeatureProvider;
 use open_feature::{EvaluationContext, Value};
 use open_feature_flagd::{CacheSettings, CacheType, FlagdOptions, FlagdProvider, ResolverType};

crates/flagd/tests/color_palette_experiment_test.rs

@@ -1,4 +1,4 @@
-use common::{Flagd, FLAGD_SYNC_PORT};
+use common::{FLAGD_SYNC_PORT, Flagd};
 
 use open_feature::provider::FeatureProvider;
 use open_feature::{EvaluationContext, EvaluationReason};

crates/flagd/tests/e2e_test.rs

@@ -1,4 +1,4 @@
-use common::{Flagd, FLAGD_CONFIG, FLAGD_OFREP_PORT, FLAGD_PORT};
+use common::{FLAGD_CONFIG, FLAGD_OFREP_PORT, FLAGD_PORT, Flagd};
 use open_feature::provider::FeatureProvider;
 use open_feature::{EvaluationContext, Value};
 use open_feature_flagd::{FlagdOptions, FlagdProvider, ResolverType};

crates/flagd/tests/envoy_test.rs

@@ -1,10 +1,10 @@
-use common::{Envoy, Flagd, ENVOY_CONFIG, ENVOY_PORT, FLAGD_PORT, FLAGD_SYNC_PORT};
-use open_feature::provider::FeatureProvider;
+use common::{ENVOY_CONFIG, ENVOY_PORT, Envoy, FLAGD_PORT, FLAGD_SYNC_PORT, Flagd};
 use open_feature::EvaluationContext;
+use open_feature::provider::FeatureProvider;
 use open_feature_flagd::{FlagdOptions, FlagdProvider, ResolverType};
 use test_log::test;
-use testcontainers::runners::AsyncRunner;
 use testcontainers::ImageExt;
+use testcontainers::runners::AsyncRunner;
 
 mod common;
 

crates/flagd/tests/in_process_test.rs

@@ -1,6 +1,6 @@
 use std::time::Duration;
 
-use common::{Flagd, FLAGD_CONFIG, FLAGD_SYNC_PORT};
+use common::{FLAGD_CONFIG, FLAGD_SYNC_PORT, Flagd};
 use open_feature::provider::FeatureProvider;
 use open_feature::{EvaluationContext, Value};
 use open_feature_flagd::{FlagdOptions, FlagdProvider, ResolverType};