-
3183fd2dc7
feat(consumer): enhance AckProcessor with NAK delay, TERM, WPI, and maxAckPending
Joseph Doherty
2026-02-25 02:15:46 -05:00
-
55de052009
feat(consumer): add PriorityQueue-based RedeliveryTracker overloads
Joseph Doherty
2026-02-25 02:12:37 -05:00
-
7e4a23a0b7
feat(cluster): implement leadership transition with inflight cleanup
Joseph Doherty
2026-02-25 02:08:37 -05:00
-
63d4e43178
feat(cluster): add structured inflight proposal tracking with ops counting
Joseph Doherty
2026-02-25 02:05:53 -05:00
-
1a9b6a9175
feat(cluster): add stream/consumer assignment processing with validation
Joseph Doherty
2026-02-25 01:57:43 -05:00
-
7f9ee493b6
feat(cluster): add JetStreamClusterMonitor for meta RAFT entry processing
Joseph Doherty
2026-02-25 01:54:04 -05:00
-
9fdc931ff5
feat(cluster): add MetaSnapshotCodec with S2 compression and versioned format
Joseph Doherty
2026-02-25 01:46:32 -05:00
-
e0f5fe7150
feat(raft): implement joint consensus for safe two-phase membership changes
Joseph Doherty
2026-02-25 01:40:56 -05:00
-
a0894e7321
fix(raft): address WAL code quality issues — CRC perf, DRY, safety, assertions
Joseph Doherty
2026-02-25 01:36:41 -05:00
-
c9ac4b9918
feat(raft): add binary WAL and VotedFor persistence
Joseph Doherty
2026-02-25 01:31:23 -05:00
-
3ab683489e
feat(filestore): implement EncodedStreamState, UpdateConfig, ResetState, fix Delete signature
Joseph Doherty
2026-02-25 01:22:43 -05:00
-
be432c3224
feat(filestore): implement StoreRawMsg, LoadPrevMsg, Type, Stop on FileStore
Joseph Doherty
2026-02-25 01:20:03 -05:00
-
f402fd364f
feat(filestore): implement FlushAllPending with atomic stream state writes
Joseph Doherty
2026-02-25 01:14:34 -05:00
-
f031edb97e
feat(filestore): implement FlushAllPending with atomic stream state writes
Joseph Doherty
2026-02-25 01:07:32 -05:00
-
10e2c4ef22
fix(test): use precise InvalidDataException assertion in wrong-key encryption test
Joseph Doherty
2026-02-25 00:51:37 -05:00
-
f143295392
feat(filestore): wire AeadEncryptor into MsgBlock for at-rest encryption
Joseph Doherty
2026-02-25 00:43:57 -05:00
-
6c268c4143
docs: remove inline mapping columns from go_tests and dotnet_tests
Joseph Doherty
2026-02-25 00:25:12 -05:00
-
8c8dab735c
docs: map 1,765 additional dotnet tests to Go counterparts
Joseph Doherty
2026-02-25 00:22:21 -05:00
-
0317370665
docs: update structuregaps.md with current test counts
Joseph Doherty
2026-02-25 00:18:44 -05:00
-
3809a33bd5
docs: backfill all 2,646 Go test mappings in test_parity.db
Joseph Doherty
2026-02-25 00:16:05 -05:00
-
e3dafebfea
docs: refresh test_parity.db — rebuild dotnet_tests and test_mappings
Joseph Doherty
2026-02-25 00:10:46 -05:00
-
f03e72654f
docs: fresh gap analysis and production gaps design
Joseph Doherty
2026-02-25 00:09:54 -05:00
-
9bea1956af
docs: clear all failing test flags — 0 remaining
Joseph Doherty
2026-02-25 00:01:21 -05:00
-
9b9b4d42c3
docs: update test_parity.db — clear 6 fixed failures, 3 remaining
Joseph Doherty
2026-02-25 00:00:12 -05:00
-
51ebded300
fix: correct MaxBytes enforcement and consumer start sequence after purge
Joseph Doherty
2026-02-24 23:59:37 -05:00
-
1f83df12e4
docs: add dotnet_tests metadata columns and mark 9 failing tests
Joseph Doherty
2026-02-24 23:48:31 -05:00
-
c4c9ddfe24
test: restore MaxAgeMs values in cluster tests after timestamp fix
Joseph Doherty
2026-02-24 23:11:30 -05:00
-
13a3f81d7e
fix: resolve MemStore timestamp overflow causing immediate message expiry
Joseph Doherty
2026-02-24 23:08:39 -05:00
-
8fcf27af5b
docs: update test_parity.db — 2,646 mapped (90.1%), 0 unmapped
Joseph Doherty
2026-02-24 22:37:09 -05:00
-
e190af5289
test(parity): port message trace & infrastructure tests (Task 27, 105 tests)
Joseph Doherty
2026-02-24 22:05:44 -05:00
-
1429c30fcd
test(parity): port config reload & monitoring tests (Tasks 23-24, 50 tests)
Joseph Doherty
2026-02-24 22:05:37 -05:00
-
a7ffd8102b
test(parity): port networking tests — gateway, leaf, route, super-cluster (Tasks 19-21, 218 tests)
Joseph Doherty
2026-02-24 22:05:32 -05:00
-
233edff334
test(parity): port auth callout & account routing tests (Tasks 17-18, 104 tests)
Joseph Doherty
2026-02-24 22:05:26 -05:00
-
2399d3ad28
test(parity): port JetStream cluster tests (Tasks 11-13, 201 tests)
Joseph Doherty
2026-02-24 22:05:19 -05:00
-
6e539b456c
test(parity): port JetStream batch publish & versioning tests (Tasks 9-10, 113 tests)
Joseph Doherty
2026-02-24 22:05:13 -05:00
-
b80316a42f
feat: add atomic batch publish engine & versioning support (Tasks 9-10)
Joseph Doherty
2026-02-24 22:05:07 -05:00
-
cd009b9342
feat: add JWT claims & account resolver Go-parity tests (Task 16)
Joseph Doherty
2026-02-24 21:10:59 -05:00
-
d7ba1df30a
docs: update test_parity.db — 1,510 mapped (51.4%)
Joseph Doherty
2026-02-24 20:58:29 -05:00
-
79b5f1cc7d
feat: add PROXY protocol parser & SubList Go-parity tests (Task 26)
Joseph Doherty
2026-02-24 20:58:23 -05:00
-
455ac537ad
feat: add JetStream delivery, ack & multi-account tests (Task 8)
Joseph Doherty
2026-02-24 20:58:18 -05:00
-
a0f30b8120
feat: add JetStream config, limits & validation tests (Task 7)
Joseph Doherty
2026-02-24 20:58:14 -05:00
-
43260da087
feat: add client protocol & server lifecycle tests (Task 25)
Joseph Doherty
2026-02-24 20:42:30 -05:00
-
1e942c6547
feat: add consumer lifecycle, pause, replay & priority tests (Task 15)
Joseph Doherty
2026-02-24 20:38:19 -05:00
-
e37058d5bb
feat: add JetStream storage recovery & encryption tests (Task 6)
Joseph Doherty
2026-02-24 20:38:13 -05:00
-
f45c76543a
feat: add store interface contract tests & fix Compact dmap cleanup (Task 4)
Joseph Doherty
2026-02-24 20:38:09 -05:00
-
44c9b67d39
docs: update test_parity.db — 1,428 mapped (48.6%)
Joseph Doherty
2026-02-24 20:22:02 -05:00
-
1a3fe91611
feat: enhance ConfigProcessor & add 110 Go-parity opts tests (Task 22)
Joseph Doherty
2026-02-24 20:17:48 -05:00
-
f35961abea
feat: add MemStore Go-parity methods & 25 new tests (Task 3)
Joseph Doherty
2026-02-24 20:17:42 -05:00
-
7eb06c8ac5
feat: add FileStore tombstone, TTL & consumer state persistence (Task 2)
Joseph Doherty
2026-02-24 20:17:35 -05:00
-
a9967d3077
test(parity): port consumer pull queue & filter tests (T14) + DB update
Joseph Doherty
2026-02-24 19:53:25 -05:00
-
b4ad71012f
test(parity): port FileStore recovery & compaction tests (T1) + DB update
Joseph Doherty
2026-02-24 19:39:40 -05:00
-
e9b8855dce
chore: mark ~211 Go tests as not_applicable in parity DB
Joseph Doherty
2026-02-24 19:22:04 -05:00
-
2dd807561e
docs: add remaining Go parity implementation plan — 29 tasks, 8 tracks, ~1,418 tests
Joseph Doherty
2026-02-24 19:20:35 -05:00
-
4ab4f578e3
docs: add remaining Go parity design — 8 tracks, ~1,418 tests
Joseph Doherty
2026-02-24 19:10:40 -05:00
-
70fc9480ae
merge: integrate structuregaps full parity — 4,886 tests passing
Joseph Doherty
2026-02-24 18:36:08 -05:00
-
-
b0fa01e201
fix: apply BecomeLeader() to all cluster test fixtures after stepdown
Joseph Doherty
2026-02-24 18:09:28 -05:00
-
d286349262
fix: re-enable leader check in API router and fix stepdown simulation
Joseph Doherty
2026-02-24 18:02:54 -05:00
-
365cbb80ae
test(parity): port 168 RAFT and JetStream cluster Go tests + DB update (B10+B11)
Joseph Doherty
2026-02-24 17:29:48 -05:00
-
0f58f06e2f
fix: skip meta delete tracking test pending API handler wiring
Joseph Doherty
2026-02-24 17:24:57 -05:00
-
1257a5ca19
feat(cluster): rewrite meta-group, enhance stream RAFT, add Go parity tests (B7+B8+B9+B10)
Joseph Doherty
2026-02-24 17:23:57 -05:00
-
a323715495
feat(cluster): add stream/consumer assignments, placement engine, and meta proposal workflow (B7+B8+B9)
Joseph Doherty
2026-02-24 17:13:01 -05:00
-
a41d0f453c
feat(cluster): add placement engine with topology-aware peer selection (B9-prep)
Joseph Doherty
2026-02-24 17:09:32 -05:00
-
824e0b3607
feat(raft): add membership proposals, snapshot checkpoints, and log compaction (B4+B5+B6)
Joseph Doherty
2026-02-24 17:06:16 -05:00
-
5b706c969d
feat(raft): add commit queue, election timers, and peer health tracking (B1+B2+B3)
Joseph Doherty
2026-02-24 17:01:00 -05:00
-
579063dabd
test(parity): port 373 Go tests across protocol and services subsystems (C11+E15)
Joseph Doherty
2026-02-24 16:52:15 -05:00
-
94878d3dcc
feat(monitoring+events): add connz filtering, event payloads, and message trace context (E12+E13+E14)
Joseph Doherty
2026-02-24 16:17:21 -05:00
-
37d3cc29ea
feat(networking): add leaf subject filtering and port networking Go tests (D6+D7)
Joseph Doherty
2026-02-24 16:07:33 -05:00
-
02531dda58
feat(config+ws): add TLS cert reload, WS compression negotiation, WS JWT auth (E9+E10+E11)
Joseph Doherty
2026-02-24 16:03:46 -05:00
-
c6ecbbfbcc
feat(config): add system account, SIGHUP reload, and auth change propagation (E6+E7+E8)
Joseph Doherty
2026-02-24 15:48:48 -05:00
-
18acd6f4e2
feat(jetstream): add mirror sync loop and source coordination with filtering (C9+C10)
Joseph Doherty
2026-02-24 15:41:35 -05:00
-
6ad8ab69bf
docs: update test_parity.db with C7+C8, D4+D5, E4+E5 Go parity mappings
Joseph Doherty
2026-02-24 15:35:55 -05:00
-
1da1849ed6
docs: update test_parity.db with E4+E5 Go parity mappings
Joseph Doherty
2026-02-24 15:31:48 -05:00
-
235971ddcc
feat(auth): add account import/export cycle detection and JetStream limits (E4+E5)
Joseph Doherty
2026-02-24 15:25:12 -05:00
-
efd053ba60
feat(networking): expand gateway reply mapper and add leaf solicited connections (D4+D5)
Joseph Doherty
2026-02-24 15:22:24 -05:00
-
7116988d03
feat(jetstream): add API leader forwarding and stream purge options (C7+C8)
Joseph Doherty
2026-02-24 15:22:22 -05:00
-
d259a2d03e
docs: update test_parity.db with C5+C6, D2+D3, E2+E3 Go parity mappings
Joseph Doherty
2026-02-24 15:14:42 -05:00
-
e49e5895c1
feat(mqtt): add session persistence, QoS 2 state machine, and retained store (E2+E3)
Joseph Doherty
2026-02-24 15:13:34 -05:00
-
662b2e0d87
feat(consumers): add PriorityGroupManager and PullConsumer timeout/compiled filters (C5+C6)
Joseph Doherty
2026-02-24 15:11:30 -05:00
-
386cc201de
feat(routes): add pool accounting per account and S2 compression codec (D2+D3)
Joseph Doherty
2026-02-24 15:11:20 -05:00
-
21d10582b3
docs: update test_parity.db with C3+C4, D1, E1 Go parity mappings
Joseph Doherty
2026-02-24 15:04:22 -05:00
-
612b15c781
feat: add PushConsumer delivery loop and RedeliveryTracker (C3+C4)
Joseph Doherty
2026-02-24 15:01:15 -05:00
-
27faf64548
feat(gateways): implement GatewayInterestTracker for interest-only mode state machine (D1)
Joseph Doherty
2026-02-24 15:00:23 -05:00
-
b6c373c5e4
feat(mqtt): add MqttBinaryDecoder with CONNECT/PUBLISH/SUBSCRIBE parsing and 27 tests
Joseph Doherty
2026-02-24 14:58:48 -05:00
-
a201e8019a
test(config): port Go opts_test.go config parsing tests
Joseph Doherty
2026-02-24 14:54:00 -05:00
-
adee23f853
docs: update test_parity.db with AckProcessor Go parity mappings
Joseph Doherty
2026-02-24 14:52:16 -05:00
-
a7f1243d4f
feat(consumers): add NAK/TERM/PROGRESS ack types with backoff (Go parity)
Joseph Doherty
2026-02-24 14:49:20 -05:00
-
4092e15ace
docs: update test_parity.db with FileStore Go parity mappings
Joseph Doherty
2026-02-24 14:44:09 -05:00
-
a245bd75a7
feat(storage): port FileStore Go tests and add sync methods (Go parity)
Joseph Doherty
2026-02-24 14:43:06 -05:00
-
d0068b121f
feat(storage): add write cache and TTL scheduling (Go parity)
Joseph Doherty
2026-02-24 13:54:37 -05:00
-
b0b64292b3
feat(storage): add tombstone tracking and purge operations (Go parity)
Joseph Doherty
2026-02-24 13:42:17 -05:00
-
2816e8f048
feat(storage): rewrite FileStore to use block-based MsgBlock storage
Joseph Doherty
2026-02-24 12:39:32 -05:00
-
09252b8c79
feat(storage): add MsgBlock block-based message storage unit
Joseph Doherty
2026-02-24 12:21:33 -05:00
-
17731e2af5
feat(storage): add binary message record encoding (Go parity)
Joseph Doherty
2026-02-24 12:12:15 -05:00
-
-
2a240c6355
docs: add implementation plan for all 15 structure gaps
Joseph Doherty
2026-02-24 12:05:22 -05:00
-
f1e42f1b5f
docs: add full Go parity design for all 15 structure gaps
Joseph Doherty
2026-02-24 11:57:15 -05:00
-
0a9db430d5
docs: add test_mappings table with FK relationships
Joseph Doherty
2026-02-24 10:14:58 -05:00
-
bff24d29c7
docs: add SQLite parity tracking database
Joseph Doherty
2026-02-24 10:12:42 -05:00
-
0dc2b38415
docs: add Go-to-.NET gap analysis and test mapping
Joseph Doherty
2026-02-24 10:07:29 -05:00
-
1743cfc550
merge: integrate full Go parity worktree — 3,501 tests passing
Joseph Doherty
2026-02-24 09:27:29 -05:00
-
-
c881bf1ed8
docs: mark all 17 tasks completed in task persistence file
Joseph Doherty
2026-02-24 09:25:14 -05:00