improve code for global.rs

crates/event-notifier/examples/.env-zh.example

@@ -5,7 +5,7 @@ NOTIFIER__CHANNEL_CAPACITY=5000
 # ===== 适配器配置（数组格式） =====
 # Webhook 适配器（索引 0）
 NOTIFIER__ADAPTERS_0__type=Webhook
-NOTIFIER__ADAPTERS_0__endpoint=http://127.0.0.1:3000/webhook
+NOTIFIER__ADAPTERS_0__endpoint=http://127.0.0.1:3020/webhook
 NOTIFIER__ADAPTERS_0__auth_token=your-auth-token
 NOTIFIER__ADAPTERS_0__max_retries=3
 NOTIFIER__ADAPTERS_0__timeout=50

crates/event-notifier/examples/.env.example

@@ -5,7 +5,7 @@ NOTIFIER__CHANNEL_CAPACITY=5000
 # ===== adapter configuration array format =====
 # webhook adapter index 0
 NOTIFIER__ADAPTERS_0__type=Webhook
-NOTIFIER__ADAPTERS_0__endpoint=http://127.0.0.1:3000/webhook
+NOTIFIER__ADAPTERS_0__endpoint=http://127.0.0.1:3020/webhook
 NOTIFIER__ADAPTERS_0__auth_token=your-auth-token
 NOTIFIER__ADAPTERS_0__max_retries=3
 NOTIFIER__ADAPTERS_0__timeout=50

crates/event-notifier/examples/event.toml

@@ -4,7 +4,7 @@ channel_capacity = 5000
 
 [[adapters]]
 type = "Webhook"
-endpoint = "http://127.0.0.1:3000/webhook"
+endpoint = "http://127.0.0.1:3020/webhook"
 auth_token = "your-auth-token"
 max_retries = 3
 timeout = 50

crates/event-notifier/examples/webhook.rs

@@ -7,8 +7,8 @@ async fn main() {
     // 构建应用
     let app = Router::new().route("/webhook", post(receive_webhook));
     // 启动服务器
-    let listener = tokio::net::TcpListener::bind("0.0.0.0:3000").await.unwrap();
+    let listener = tokio::net::TcpListener::bind("0.0.0.0:3020").await.unwrap();
-    println!("Server running on http://0.0.0.0:3000");
+    println!("Server running on http://0.0.0.0:3020");
 
     // 创建关闭信号处理
     tokio::select! {

crates/event-notifier/src/global.rs

@@ -178,9 +178,9 @@ mod tests {
         tracing_subscriber::fmt::init();
         let config = NotifierConfig::default(); // assume there is a default configuration
         let result = initialize(config).await;
-        assert!(!result.is_ok(), "Initialization should succeed");
+        assert!(result.is_err(), "Initialization should not succeed");
-        assert!(!is_initialized(), "System should be marked as initialized");
+        assert!(!is_initialized(), "System should not be marked as initialized");
-        assert!(!is_ready(), "System should be marked as ready");
+        assert!(!is_ready(), "System should not be marked as ready");
     }
 
     #[tokio::test]

deploy/config/event.example.toml

@@ -4,7 +4,7 @@ channel_capacity = 5000
 
 [[adapters]]
 type = "Webhook"
-endpoint = "http://127.0.0.1:3000/webhook"
+endpoint = "http://127.0.0.1:3020/webhook"
 auth_token = "your-auth-token"
 max_retries = 3
 timeout = 50

deploy/config/obs.example.toml

@@ -6,7 +6,7 @@ meter_interval = 30
 service_name = "rustfs"
 service_version = "0.1.0"
 environment = "develop"
-logger_level = "info"
+logger_level = "error"
 
 [sinks]
 [sinks.kafka] # Kafka sink is disabled by default