Skip to content

feat(coderd/x/nats): add experimental package skeleton #25631

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
sreya wants to merge 97 commits into from
Closed

feat(coderd/x/nats): add experimental package skeleton #25631

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
97 commits
Select commit Hold shift + click to select a range
7144eaf
feat(coderd/x/nats): add experimental package skeleton
sreya Apr 29, 2026
2c69449
feat(coderd/x/nats): implement subject mapping and validation
sreya Apr 29, 2026
449f8c4
feat(coderd/x/nats): implement standalone embedded NATS pubsub
sreya Apr 29, 2026
74c0d79
feat(coderd/x/nats): add slow-consumer drop accounting and prometheus…
sreya Apr 29, 2026
d4309d0
feat(coderd/x/nats): add embedded NATS clustering
sreya Apr 29, 2026
7da427c
feat(coderd/x/nats): add concurrency stress tests and package docs
sreya Apr 29, 2026
a54048a
docs(docs/internal): add xreplicasync PeerProvider design plan
sreya Apr 29, 2026
9b06e13
docs(docs/internal): add xreplicasync and nats refresh plan
sreya Apr 29, 2026
883411b
test(coderd/x/nats): cover peer refresh route reloads
sreya Apr 29, 2026
de7eb85
feat(coderd/x/nats): refresh embedded nats peer routes
sreya Apr 29, 2026
955b3a0
feat(enterprise/coderd/x/xreplicasync): add nats peer provider for re…
sreya Apr 29, 2026
1339ffa
feat(coderd/x/nats): collapse standalone into cluster-of-1
sreya Apr 29, 2026
2da01f8
docs(docs/internal): update nats refresh plan for cluster-of-1
sreya Apr 29, 2026
beaf94b
feat(enterprise/replicasync): replace SetCallback with AddCallback
sreya Apr 29, 2026
9517921
test(coderd/x/nats): add 512 KiB fan-out throughput benchmarks
sreya May 12, 2026
3214c04
chore(coderd/database/dbmock): regenerate with mockgen v0.6
sreya May 12, 2026
51a2dab
test(coderd/x/nats): rework fan-out benches as fire-and-forget, add 4…
sreya May 12, 2026
4d94676
test(coderd/x/nats): fix bench cross-pass contamination, drops semant…
sreya May 12, 2026
ebc8523
test(coderd/x/nats): add PublishMode sweep axis and bump drain to 5 m…
sreya May 12, 2026
d00f214
feat(coderd/x/nats): mirror upstream Publish semantics, drop PublishMode
sreya May 12, 2026
276bbfb
test(coderd/x/nats): add raw NATS Core TCP fan-out benchmark for upst…
sreya May 12, 2026
d8479e1
feat(coderd/x/nats): use TCP loopback for client→local-server connection
sreya May 13, 2026
23384c3
test(coderd/x/nats): redesign fanout benchmarks around upstream nats …
sreya May 13, 2026
00ade95
remove poor benchmarking implementation
sreya May 13, 2026
27aae5a
test(coderd/x/nats): add capacity-planning pubsub throughput benchmarks
sreya May 13, 2026
8d3665c
test(coderd/x/nats): add high-cardinality and concentrated-fan-out be…
sreya May 13, 2026
07b808f
test(coderd/x/nats): add -bench.type flag and thin-fanout benchmark
sreya May 13, 2026
7cad797
docs(docs/internal): add client-side conn-pool plan for coderd/x/nats…
sreya May 13, 2026
4c55483
docs(docs/internal): rewrite wrapper-conn-pool plan for per-sub conns
sreya May 13, 2026
e2397ef
feat(coderd/x/nats): per-subscription in-memory connections, drop NoEcho
sreya May 13, 2026
772f850
test(coderd/x/nats): split publisher vs delivery throughput in bench …
sreya May 13, 2026
ecab8be
test(coderd/x/nats): add BenchmarkPubsubAllRemote for route-only fan-out
sreya May 13, 2026
e17e712
docs(docs/internal): rewrite wrapper-conn-pool plan for dual-TCP-conn…
sreya May 13, 2026
cc4e1da
refactor(coderd/x/nats): dual TCP conn design, drop per-subscription …
sreya May 13, 2026
319ed4b
feat(coderd/x/nats): raise embedded server MaxPending to 1 GiB
sreya May 13, 2026
859ba51
test(coderd/x/nats): add BenchmarkPubsubUpstreamNxM apples-to-apples …
sreya May 13, 2026
101a8c5
test(coderd/x/nats): add BenchmarkPubsubUpstream1x1_16KiB reference test
sreya May 13, 2026
c86c370
feat(coderd/x/nats): add in-process client option to connectClient
sreya May 13, 2026
98b7f3b
feat(coderd/x/nats/cmd/natsbench): add standalone bench harness
sreya May 13, 2026
b919ae6
feat(coderd/x/nats/cmd/natsbench): add pub-only mode and aggregate rate
sreya May 13, 2026
33512e3
refactor(coderd/x/nats): remove prometheus metrics from pubsub
sreya May 13, 2026
67616cd
fix(coderd/x/nats/cmd/natsbench): measure loopback hot window after w…
sreya May 13, 2026
20fafc0
feat(coderd/x/nats): add Pubsub.Flush method
sreya May 13, 2026
ef3afed
feat(coderd/x/nats/cmd/natsbench): split publish and delivery measure…
sreya May 13, 2026
c5dcd6f
fix(coderd/x/nats/cmd/natsbench): correct aggregate formula, add star…
sreya May 13, 2026
89fe5b4
feat(coderd/x/nats/cmd/natsbench): add cluster topology helpers
sreya May 13, 2026
147d528
feat(coderd/x/nats/cmd/natsbench): add coder-cluster and native-clust…
sreya May 13, 2026
a0c4c51
perf(coderd/x/nats): use context for closed-state check on hot path
sreya May 13, 2026
8e2a9e7
perf(coderd/x/nats): single-pass LegacyEventSubject builder
sreya May 13, 2026
94bed37
perf(coderd/x/nats): skip duplicate subject validation on owned nats …
sreya May 13, 2026
c0da057
feat(coderd/x/nats/cmd/natsbench): add cpu/mem profile flags and runt…
sreya May 13, 2026
d32f7de
feat(coderd/x/nats/cmd/natsbench): plumb max-pending through cluster …
sreya May 13, 2026
4ac581c
feat(coderd/x/nats/cmd/natsbench): add symmetric cluster modes
sreya May 13, 2026
9d1cf20
feat(coderd/x/nats): coalesce same-subject local subscribers onto one…
sreya May 14, 2026
8b133f1
fix(coderd/x/nats): harden coalescing readiness and Close lifecycle
sreya May 14, 2026
3ed6108
feat(coderd/x/nats): configurable publisher connection pool
sreya May 14, 2026
ccffaf0
fix(coderd/x/nats): clean up readiness test lint
sreya May 14, 2026
2fcf360
feat(coderd/x/nats): add configurable subscriber connection pool
sreya May 14, 2026
968e569
feat(coderd/x/nats): pin 3/3 pools and add multi-subject natsbench su…
sreya May 14, 2026
d2bee14
fix(coderd/x/nats/cmd/natsbench): surface drops and size local queue …
sreya May 14, 2026
b9452f8
feat(coderd/x/nats): tune NATS Go client write buffer size
sreya May 14, 2026
37419ca
feat(coderd/x/nats/cmd/natsbench): bound phases, restructure flushing…
sreya May 14, 2026
66eefbc
feat(coderd/x/nats/cmd/natsbench): workload-derived MaxPending + clus…
sreya May 14, 2026
4cb7f52
fix gen
sreya May 20, 2026
a2ce53b
rm natsbench
sreya May 20, 2026
0248a28
chore(coderd/x/nats): narrow core review scope
sreya May 20, 2026
9798e37
chore(coderd/x/nats): step-5 cleanup (drop NoServerLog/ConnectTimeout…
sreya May 20, 2026
19df772
chore(coderd/x/nats): remove bench_test.go
sreya May 20, 2026
57d01cb
chore(coderd/x/nats): remove clustering support
sreya May 20, 2026
5c682a9
refactor(coderd/x/nats): rename pools and drop NewFromConn
sreya May 20, 2026
1956321
refactor(coderd/x/nats): drop ServerStats, WriteBufferSize, stress te…
sreya May 20, 2026
f767467
refactor(coderd/x/nats): use event names directly as NATS subjects
sreya May 20, 2026
f55506e
refactor(coderd/x/nats): trim verbose comments
sreya May 21, 2026
0c150b2
refactor(coderd/x/nats): merge options.go into pubsub.go
sreya May 21, 2026
cca3e07
test(coderd/x/nats): slim pool foundation tests
sreya May 21, 2026
d03cc02
test(coderd/x/nats): slim foundation coverage
sreya May 21, 2026
9eba64c
test(coderd/x/nats): consolidate pubsub tests
sreya May 22, 2026
76c30d8
test(coderd/x/nats): reorganize pubsub tests
sreya May 22, 2026
0cfb60c
fix(coderd/x/nats): address pubsub review feedback
sreya May 22, 2026
c7bb841
refactor(coderd/x/nats): address pubsub review feedback
sreya May 22, 2026
341d94d
refactor(coderd/x/nats): simplify pubsub options
sreya May 22, 2026
2f61e67
fix(coderd/x/nats): cancel pubsub close under lock
sreya May 22, 2026
3e3f9e1
fix(coderd/x/nats): serialize local subscriber callbacks
sreya May 22, 2026
c2aade4
refactor(coderd/x/nats): simplify local subscriber setup
sreya May 22, 2026
a3e8516
fix(coderd/x/nats): address pubsub review comments
sreya May 22, 2026
1febc8d
fix(coderd/x/nats): address pubsub review comments
sreya May 22, 2026
e78e4cc
refactor(coderd/x/nats): remove local subscription back-reference
sreya May 22, 2026
29afbf8
fix(coderd/x/nats): narrow pubsub listener locking
sreya May 22, 2026
96e5aac
fix(coderd/x/nats): address pubsub review comments
sreya May 22, 2026
8e55376
fix(coderd/x/nats): make close stop local delivery without waiting
sreya May 22, 2026
bbdd2cc
fix(coderd/x/nats): simplify pubsub shutdown handling
sreya May 22, 2026
d5b6a61
fix(coderd/x/nats): normalize pending limits
sreya May 22, 2026
c9381cf
fix(coderd/x/nats): simplify local subscriber select
sreya May 22, 2026
2494d78
fix(coderd/x/nats): simplify local subscriber handling
sreya May 22, 2026
54d2cd1
fix(coderd/x/nats): update pending comment
sreya May 22, 2026
97251e5
fix(coderd/x/nats): signal drops on disconnect
sreya May 26, 2026
797d2ad
fix(coderd/x/nats): scope disconnect drops by conn
sreya May 26, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Loading
Loading