Skip to content

[Jetty] Forwarded the stream notifier writes to the active cluster. - #52

Draft
moetemp wants to merge 2 commits into
moe/jetty/js3-stream-notifierfrom
moe/jetty/js4-notifier-forwarding
Draft

moetemp wants to merge 2 commits into
moe/jetty/js3-stream-notifierfrom
moe/jetty/js4-notifier-forwarding

Conversation

@moetemp

@moetemp moetemp commented Oct 14, 2026

Copy link
Copy Markdown
Owner

What changed?

This PR forwards the stream notifier's write RPCs to the active cluster, and adds the notifier tests for failover, owner checks and failed closes.

  • AttachStreamCallback, DetachStreamCallback and NotifyStream join the selected-APIs forwarding list. DescribeStreamNotifier stays local.
  • The xdc TestStreamNotifierForwardingSuite checks forwarding from a standby cluster and that an attached callback survives a namespace failover.
  • Functional tests cover a close with a failure and the owner check that leaves a just-completed owner alone for its grace.

It carries the forwarding half of moetemp/temporal#42. The System Nexus operations and their test stay in Bridge.

Why?

The notifier is an execution in the namespace, so its writes must reach the active cluster (DD-50).

How did you test it?

Link to a test plan if any -

  • Unit Tests
  • Staging
  • End to End Tests

common/rpc/interceptor unit tests, the xdc TestStreamNotifierForwardingSuite, and the functional TestStreamNotifier* tests on both caller kinds.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant