Commit Graph
5 Commits
Author SHA1 Message Date
Admin Bot a4fbd5cf2f feat: add SSE streaming endpoint for workflow events (#33)
- New internal/temporal/sse.go: StreamWorkflowEvents handler
- Polls Temporal GetWorkflowExecutionHistory every 2s
- Maps Temporal event types to semantic SSE events
  (activity_started/completed/failed, workflow_completed, etc.)
- Heartbeat every 15s, clean close on workflow completion
- Route: GET /workflow/stream?workflow_id=X&namespace=default
- Added stream resource to workflow ServiceAdapter spec

Closes #33
2026-09-26 18:44:42 +08:00
Admin Bot 3c6c855761 fix: require namespace for workflow operations, return 400 if missing
CI / CI (push) Failing after 7m51s
Temporal handler was defaulting to 'default' namespace when not provided.
CI test expects 400 for missing namespace. Validate before forwarding.
2026-09-15 21:27:05 +09:00
Admin Bot f18e6331ea fix: workflow auth.required=false to match gateway config
CI / CI (push) Failing after 7m52s
Config says auth required: false for workflow service. Code-registered
Spec had Required: true, causing 401 for unauthenticated CI tests.
Match config intent.
2026-09-15 18:07:22 +09:00
rockandpoimen d439536ca9 Add TTFT & ITL Metrics for LLM Inference (#28)
CI / CI (push) Successful in 4m7s
Time-to-First-Token (TTFT) and Inter-Token Latency (ITL) metrics for LLM inference observability

Metrics: llm_ttft_seconds, llm_itl_seconds, llm_tokens_total

Closes #31 #32 #33

---------

Co-authored-by: poimen <[email protected]>
Reviewed-on: #28
2026-09-15 08:53:58 +00:00
30e0a83a50 feat(network): SSE optimization for local LLM streaming (#31 #32 #33) (#26)
CI / CI (push) Successful in 3m35s
Addresses three critical network issues for LLM streaming performance:

**#33 Disable proxy buffering for SSE**
- Add X-Accel-Buffering: no header to response
- Tells nginx/Ingress to stream events immediately instead of buffering

**#32 HTTP/2 multiplexing for concurrent streams**
- Enable HTTP/2 in server config via http2.ConfigureServer()
- Increase MaxConnsPerHost to 10 for better concurrency
- Allows multiple concurrent LLM requests without blocking

**#31 TCP backpressure for streaming LLM responses**
- Set TCP_NODELAY on dialer to disable Nagle's algorithm
- Reduces latency by sending small packets immediately
- Critical for low TTFT (time-to-first-token) under load

**Tests added:**
- TestTCPBackpressure: Verifies TCP backpressure handling with slow client
- TestConcurrentSSEStreams: Confirms HTTP/2 multiplexing works correctly

---------

Co-authored-by: poison <[email protected]>
Reviewed-on: #26
Co-authored-by: poimen <[email protected]>
2026-09-13 23:37:33 +00:00