Merge pull request #10 from rohas-dev/feat/workbench-enhancement

feat(workbench): enhance telemetry and tracing features

Author: sophatvathana

.cargo/config.toml

@@ -0,0 +1,6 @@
+# C++ runtime (libcmt) to force use of the dynamic runtime (msvcrt).
+[target.x86_64-pc-windows-msvc]
+rustflags = [
+    "-C", "link-arg=/NODEFAULTLIB:libcmt",
+    "-C", "link-arg=/FORCE:MULTIPLE",
+]

examples/hello-world/.gitignore

@@ -49,3 +49,4 @@ coverage/
 
 # Rohas compiled output
 .rohas/
+src/generated/

examples/hello-world/README.md

@@ -11,7 +11,7 @@ Rohas project initialized with python handlers.
 
 2. Start development server:
    ```bash
-   rohas dev
+   rohas dev --workbench
    ```
 
 3. Validate schema:

examples/hello-world/config/rohas.toml

@@ -12,6 +12,22 @@ enable_cors = true
 type = "memory"
 buffer_size = 1000
 
+[telemetry]
+# Telemetry adapter type: rocksdb (default), prometheus, influxdb, timescaledb
+type = "rocksdb"
+# Path to telemetry storage (relative to project root or absolute)
+path = ".rohas/telemetry"
+# Retention period for traces in days (0 = keep forever)
+retention_days = 30
+# Maximum number of traces to keep in memory cache
+max_cache_size = 1000
+# Enable metrics collection
+enable_metrics = true
+# Enable logs collection
+enable_logs = true
+# Enable traces collection
+enable_traces = true
+
 [workbench]
 allowed_origins = []
 api_key = "FRmz/+AjTYCUFlBMio479A=="

examples/hello-world/schema/api/timeline_test.ro

@@ -0,0 +1,44 @@
+input TimelineTestFastInput {
+  test: String
+}
+
+api TimelineTestFast {
+  method: GET
+  path: "/timeline/fast"
+  response: String
+  triggers: [FastCompleted]
+}
+
+input TimelineTestSlowInput {
+  test: String
+}
+
+api TimelineTestSlow {
+  method: GET
+  path: "/timeline/slow"
+  response: String
+  triggers: [SlowCompleted, BottleneckDetected]
+}
+
+input TimelineTestVerySlowInput {
+  test: String
+}
+
+api TimelineTestVerySlow {
+  method: GET
+  path: "/timeline/very-slow"
+  response: String
+  triggers: [VerySlowCompleted, MajorBottleneckDetected]
+}
+
+input TimelineTestMultiStepInput {
+  test: String
+}
+
+api TimelineTestMultiStep {
+  method: GET
+  path: "/timeline/multi-step"
+  response: String
+  triggers: [ValidationComplete, ProcessingComplete, ExternalCallComplete, FinalizationComplete]
+}
+

examples/hello-world/schema/cron/cron.ro

@@ -1,3 +1,4 @@
 cron DailyCleanup {
- schedule: "*/2 * * * * *"
+ schedule: "0 */5 * * * *"
+ triggers: [CleanupStep1, CleanupStep2]
 }

examples/hello-world/schema/events/timeline_events.ro

@@ -0,0 +1,57 @@
+event FastCompleted {
+  payload: Json
+  handler: [fast_completed]
+}
+
+event SlowCompleted {
+  payload: Json
+  handler: [slow_completed]
+}
+
+event VerySlowCompleted {
+  payload: Json
+  handler: [slow_completed]
+}
+
+event BottleneckDetected {
+  payload: Json
+  handler: [bottleneck_detected]
+}
+
+event MajorBottleneckDetected {
+  payload: Json
+  handler: [bottleneck_detected]
+}
+
+event ValidationComplete {
+  payload: Json
+}
+
+event ProcessingComplete {
+  payload: Json
+}
+
+event ExternalCallComplete {
+  payload: Json
+}
+
+event FinalizationComplete {
+  payload: Json
+}
+
+event CleanupStep1 {
+  payload: Json
+}
+
+event CleanupStep2 {
+  payload: Json
+}
+
+event BottleneckLogged {
+  payload: Json
+}
+
+event WelcomeEmailSent {
+  payload: Json
+}
+