diff options
Diffstat (limited to 'telemetry/test/integration.go')
| -rw-r--r-- | telemetry/test/integration.go | 44 |
1 files changed, 22 insertions, 22 deletions
diff --git a/telemetry/test/integration.go b/telemetry/test/integration.go index c63ce82cb..2b79bdbc6 100644 --- a/telemetry/test/integration.go +++ b/telemetry/test/integration.go @@ -24,58 +24,58 @@ const ( ) func main() { - fmt.Println("๐งช Starting SeaweedFS Telemetry Integration Test") + fmt.Println("Starting SeaweedFS Telemetry Integration Test") // Start telemetry server - fmt.Println("๐ก Starting telemetry server...") + fmt.Println("Starting telemetry server...") serverCmd, err := startTelemetryServer() if err != nil { - log.Fatalf("โ Failed to start telemetry server: %v", err) + log.Fatalf("Failed to start telemetry server: %v", err) } defer stopServer(serverCmd) // Wait for server to start if !waitForServer(serverURL+"/health", 15*time.Second) { - log.Fatal("โ Telemetry server failed to start") + log.Fatal("Telemetry server failed to start") } - fmt.Println("โ
Telemetry server started successfully") + fmt.Println("Telemetry server started successfully") // Test protobuf marshaling first - fmt.Println("๐ง Testing protobuf marshaling...") + fmt.Println("Testing protobuf marshaling...") if err := testProtobufMarshaling(); err != nil { - log.Fatalf("โ Protobuf marshaling test failed: %v", err) + log.Fatalf("Protobuf marshaling test failed: %v", err) } - fmt.Println("โ
Protobuf marshaling test passed") + fmt.Println("Protobuf marshaling test passed") // Test protobuf client - fmt.Println("๐ Testing protobuf telemetry client...") + fmt.Println("Testing protobuf telemetry client...") if err := testTelemetryClient(); err != nil { - log.Fatalf("โ Telemetry client test failed: %v", err) + log.Fatalf("Telemetry client test failed: %v", err) } - fmt.Println("โ
Telemetry client test passed") + fmt.Println("Telemetry client test passed") // Test server metrics endpoint - fmt.Println("๐ Testing Prometheus metrics endpoint...") + fmt.Println("Testing Prometheus metrics endpoint...") if err := testMetricsEndpoint(); err != nil { - log.Fatalf("โ Metrics endpoint test failed: %v", err) + log.Fatalf("Metrics endpoint test failed: %v", err) } - fmt.Println("โ
Metrics endpoint test passed") + fmt.Println("Metrics endpoint test passed") // Test stats API - fmt.Println("๐ Testing stats API...") + fmt.Println("Testing stats API...") if err := testStatsAPI(); err != nil { - log.Fatalf("โ Stats API test failed: %v", err) + log.Fatalf("Stats API test failed: %v", err) } - fmt.Println("โ
Stats API test passed") + fmt.Println("Stats API test passed") // Test instances API - fmt.Println("๐ Testing instances API...") + fmt.Println("Testing instances API...") if err := testInstancesAPI(); err != nil { - log.Fatalf("โ Instances API test failed: %v", err) + log.Fatalf("Instances API test failed: %v", err) } - fmt.Println("โ
Instances API test passed") + fmt.Println("Instances API test passed") - fmt.Println("๐ All telemetry integration tests passed!") + fmt.Println("All telemetry integration tests passed!") } func startTelemetryServer() (*exec.Cmd, error) { @@ -126,7 +126,7 @@ func waitForServer(url string, timeout time.Duration) bool { ctx, cancel := context.WithTimeout(context.Background(), timeout) defer cancel() - fmt.Printf("โณ Waiting for server at %s...\n", url) + fmt.Printf("Waiting for server at %s...\n", url) for { select { |