dohertj2/mxaccessgw
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Issue #14: implement event streaming and backpressure #74

Merged
dohertj2 merged 1 commits from agent-3/issue-14-implement-event-streaming-and-backpressure into main 2026-04-26 18:03:33 -04:00
Conversation 0 Commits 1 Files Changed 12
+701 -35
dohertj2 commented 2026-04-26 18:03:12 -04:00
Owner
Copy Link
Copy Source

Summary

  • add EventStreamService with one active subscriber per session and bounded public stream queue
  • fail sessions fast on public stream queue overflow and fail WorkerClient on inbound event queue overflow
  • preserve worker event order and forward only worker-reported event families
  • detach subscribers on stream cancellation and surface terminal worker faults through the stream
  • update gateway event/backpressure docs

Verification

  • dotnet build src\MxGateway.sln
  • dotnet test src\MxGateway.Tests\MxGateway.Tests.csproj --no-build --filter "FullyQualifiedNameGateway.Grpc|FullyQualifiedNameWorkerClientTests"
  • dotnet test src\MxGateway.sln --no-build
## Summary - add EventStreamService with one active subscriber per session and bounded public stream queue - fail sessions fast on public stream queue overflow and fail WorkerClient on inbound event queue overflow - preserve worker event order and forward only worker-reported event families - detach subscribers on stream cancellation and surface terminal worker faults through the stream - update gateway event/backpressure docs ## Verification - dotnet build src\MxGateway.sln - dotnet test src\MxGateway.Tests\MxGateway.Tests.csproj --no-build --filter "FullyQualifiedName~Gateway.Grpc|FullyQualifiedName~WorkerClientTests" - dotnet test src\MxGateway.sln --no-build
dohertj2 added 1 commit 2026-04-26 18:03:13 -04:00
Issue #14: implement event streaming and backpressure 77eac95f33
dohertj2 merged commit 9b3637257c into main 2026-04-26 18:03:33 -04:00
Sign in to join this conversation.
Reviewers
No Reviewers
Labels
Clear labels
area:auth
Authentication and authorization
 area:client-dotnet
.NET client library
 area:client-go
Go client library
 area:client-java
Java client library
 area:client-python
Python client library
 area:client-rust
Rust client library
 area:contracts
Protocol and generated contract work
 area:dashboard
Blazor dashboard work
 area:docs
Documentation
 area:gateway
Gateway server work
 area:tests
Automated and live tests
 area:worker
MXAccess worker process work
 blocked
Blocked by dependency
 priority:p0
Must-have / blocking
 priority:p1
High priority
 priority:p2
Normal priority
 type:docs
Documentation work
 type:feature
Feature implementation
 type:infra
Infrastructure and scaffolding
 type:test
Test work
No Label
Milestone
No items
No Milestone
Projects
Clear projects
No project
Assignees
Clear assignees
dohertj2 (dohertj2)
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: dohertj2/mxaccessgw#74
Delete Branch "agent-3/issue-14-implement-event-streaming-and-backpressure"

Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?