feat(consumergate): runtime stop/start of queue controllers#375
Draft
sbalabanov wants to merge 1 commit into
Draft
feat(consumergate): runtime stop/start of queue controllers#375sbalabanov wants to merge 1 commit into
sbalabanov wants to merge 1 commit into
Conversation
|
|
sbalabanov
commented
Jul 16, 2026
sbalabanov
force-pushed
the
consumer-gate-impl
branch
from
July 16, 2026 00:38
d04bf53 to
fb4fde8
Compare
sbalabanov
commented
Jul 16, 2026
sbalabanov
force-pushed
the
rfc-consumer-gate
branch
from
July 16, 2026 20:43
7ff27fb to
1c25eb9
Compare
sbalabanov
force-pushed
the
consumer-gate-impl
branch
from
July 16, 2026 20:43
fb4fde8 to
0b06f08
Compare
behinddwalls
force-pushed
the
consumer-gate-impl
branch
from
July 16, 2026 22:00
0b06f08 to
6b0aa49
Compare
sbalabanov
commented
Jul 16, 2026
sbalabanov
force-pushed
the
consumer-gate-impl
branch
2 times, most recently
from
July 16, 2026 22:55
4e229a3 to
2db191e
Compare
sbalabanov
commented
Jul 16, 2026
sbalabanov
force-pushed
the
consumer-gate-impl
branch
2 times, most recently
from
July 21, 2026 00:10
617595b to
8c7078c
Compare
sbalabanov
marked this pull request as ready for review
July 21, 2026 00:10
sbalabanov
marked this pull request as draft
July 21, 2026 00:11
sbalabanov
force-pushed
the
consumer-gate-impl
branch
from
July 21, 2026 00:13
8c7078c to
b17ed5a
Compare
sbalabanov
marked this pull request as ready for review
July 21, 2026 00:13
sbalabanov
marked this pull request as draft
July 21, 2026 00:13
sbalabanov
force-pushed
the
consumer-gate-impl
branch
from
July 21, 2026 00:27
b17ed5a to
40d682f
Compare
sbalabanov
marked this pull request as ready for review
July 21, 2026 00:27
sbalabanov
marked this pull request as draft
July 21, 2026 00:27
sbalabanov
force-pushed
the
consumer-gate-impl
branch
from
July 21, 2026 02:27
40d682f to
357d933
Compare
sbalabanov
marked this pull request as ready for review
July 21, 2026 16:09
sbalabanov
marked this pull request as draft
July 21, 2026 16:09
sbalabanov
force-pushed
the
consumer-gate-impl
branch
from
July 22, 2026 01:29
357d933 to
dd2a358
Compare
sbalabanov
marked this pull request as ready for review
July 22, 2026 01:30
sbalabanov
marked this pull request as draft
July 22, 2026 01:30
Implement the consumer-gate RFC with a file-backed gate shared by gateway, orchestrator, and runway consumers. - clear deliveries through a consumer-group/partition gate before controller processing while extending visibility for blocked deliveries - expose caller-owned delivery descriptors and let gate implementations stamp gate-owned parked-record fields - keep parked payload files only while deliveries are actively blocked and remove them on every terminal watch path - fail open on gate or visibility-extension failures and leave blocked deliveries unacked during shutdown for normal redelivery - run service containers with the host test UID/GID under rootful Docker while preserving rootless Docker ownership mapping - make the cancellation E2E scenario deterministic by parking the runway merge-conflict-check delivery until cancellation reaches a terminal state - consolidate consumer white-box and behavioral unit tests in the consumer package Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
sbalabanov
force-pushed
the
consumer-gate-impl
branch
from
July 22, 2026 02:47
dd2a358 to
7622a3a
Compare
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Implements the consumer-gate RFC (#374) and showcases a Request Cancellation e2e test using it.
Summary
platform/extension/consumergatewith theGate,Entry,Admin,Factory, and configuration contracts, plus generated mocks.0:0under rootless Docker so bind-mounted gate files remain readable by the host test process.Deterministic cancellation E2E coverage
TestCancel_CaughtPreBatch_NeverLandscloses the runway merge-conflict-check gate for the test queue before landing a request. The test observes the exact parked delivery, cancels the request to its terminal state, opens the gate, waits for the parked record to disappear, and uses a sentinel request to prove the stale message was consumed without reviving or landing the cancelled request.Testing
make test— passed (76/76 Bazel test targets).//test/integration/...— passed (8/8 integration targets).//test/e2e/...— passed (2/2 E2E targets).git diff --check— passed.