Files

Joseph Doherty c30e67a69d Fix E2E test gaps and add comprehensive E2E + parity test suites

- Fix pull consumer fetch: send original stream subject in HMSG (not inbox)
  so NATS client distinguishes data messages from control messages
- Fix MaxAge expiry: add background timer in StreamManager for periodic pruning
- Fix JetStream wire format: Go-compatible anonymous objects with string enums,
  proper offset-based pagination for stream/consumer list APIs
- Add 42 E2E black-box tests (core messaging, auth, TLS, accounts, JetStream)
- Add ~1000 parity tests across all subsystems (gaps closure)
- Update gap inventory docs to reflect implementation status

2026-03-12 14:09:23 -04:00

228 KiB

Raw Permalink Blame History

JetStream — Gap Analysis

This file tracks what has and hasn't been ported from Go to .NET for the JetStream module. See stillmissing.md for the full LOC comparison across all modules.

LLM Instructions: How to Analyze This Category

Step 1: Read the Go Reference Files

Read each Go source file listed below. For every file:

Extract all exported types (structs, interfaces, type aliases)
Extract all exported methods on those types (receiver functions)
Extract all exported standalone functions
Note key constants, enums, and protocol states
Note important unexported helpers that implement core logic (functions >20 lines)
Pay attention to concurrency patterns (goroutines, mutexes, channels) — these map to different .NET patterns

Step 2: Read the .NET Implementation Files

Read all .cs files in the .NET directories listed below. For each Go symbol found in Step 1:

Search for a matching type, method, or function in .NET
If found, compare the behavior: does it handle the same edge cases? Same error paths?
If partially implemented, note what's missing
If not found, note it as MISSING

Step 3: Cross-Reference Tests

Compare Go test functions against .NET test methods:

For each Go Test* function, check if a corresponding .NET [Fact] or [Theory] exists
Note which test scenarios are covered and which are missing

Check the parity DB (docs/test_parity.db) for existing mappings:

sqlite3 docs/test_parity.db "SELECT go_test, dotnet_test, confidence FROM test_mappings tm JOIN go_tests gt ON tm.go_test_id=gt.rowid JOIN dotnet_tests dt ON tm.dotnet_test_id=dt.rowid WHERE gt.go_file LIKE '%PATTERN%'"

Step 4: Classify Each Item

Use these status values:

Status	Meaning
PORTED	Equivalent exists in .NET with matching behavior
PARTIAL	.NET implementation exists but is incomplete (missing edge cases, error handling, or features)
MISSING	No .NET equivalent found — needs to be ported
NOT_APPLICABLE	Go-specific pattern that doesn't apply to .NET (build tags, platform-specific goroutine tricks, etc.)
DEFERRED	Intentionally skipped for now (document why)

Step 5: Fill In the Gap Inventory

Add rows to the Gap Inventory table below. Group by Go source file. Include the Go file and line number so a porting LLM can jump directly to the reference implementation.

Key Porting Notes for JetStream

This is the largest module (55,228 Go source LOC, 30% ported). Break analysis into sub-areas:
1. Core orchestration (jetstream.go, jetstream_api.go)
2. Stream lifecycle (stream.go) — retention policies: Limits, Interest, WorkQueue
3. Consumer state machine (consumer.go) — push vs pull, ack policies (None, All, Explicit)
4. Storage engine (filestore.go, memstore.go) — S2 compression (IronSnappy NuGet), AEAD encryption (ChaCha20Poly1305/AesGcm)
5. Cluster coordination (jetstream_cluster.go) — depends on RAFT module
Go's filestore.go alone is 12,600 lines — the single largest implementation file.
The storage interface (store.go) defines the contract; analyze this first to understand the abstraction.

Go Reference Files (Source)

golang/nats-server/server/jetstream.go — Orchestration, API subject handlers ($JS.API.*)
golang/nats-server/server/jetstream_api.go — JetStream API handlers (~5,300 lines)
golang/nats-server/server/jetstream_events.go — JetStream event publishing
golang/nats-server/server/jetstream_errors.go — Error definitions
golang/nats-server/server/jetstream_errors_generated.go — Generated error codes
golang/nats-server/server/jetstream_batching.go — Batch processing
golang/nats-server/server/jetstream_versioning.go — Version compatibility
golang/nats-server/server/stream.go — Stream lifecycle, retention policies (~8,000 lines)
golang/nats-server/server/consumer.go — Consumer state machine (~6,000 lines). Push vs pull, ack policies.
golang/nats-server/server/store.go — Storage abstraction interface
golang/nats-server/server/filestore.go — Block-based persistent storage (~12,600 lines). S2 compression, encryption.
golang/nats-server/server/memstore.go — In-memory storage with TTL
golang/nats-server/server/dirstore.go — Directory-based storage
golang/nats-server/server/disk_avail.go — Disk space checking
golang/nats-server/server/jetstream_cluster.go — Clustered JetStream (~10,900 lines)

Go Reference Files (Tests)

golang/nats-server/server/jetstream_test.go
golang/nats-server/server/jetstream_consumer_test.go
golang/nats-server/server/jetstream_errors_test.go
golang/nats-server/server/jetstream_batching_test.go
golang/nats-server/server/jetstream_versioning_test.go
golang/nats-server/server/jetstream_helpers_test.go
golang/nats-server/server/jetstream_jwt_test.go
golang/nats-server/server/jetstream_tpm_test.go
golang/nats-server/server/jetstream_sourcing_scaling_test.go
golang/nats-server/server/jetstream_benchmark_test.go
golang/nats-server/server/filestore_test.go
golang/nats-server/server/memstore_test.go
golang/nats-server/server/dirstore_test.go
golang/nats-server/server/store_test.go
golang/nats-server/server/jetstream_cluster_1_test.go through _4_test.go
golang/nats-server/server/jetstream_super_cluster_test.go
golang/nats-server/server/jetstream_leafnode_test.go
golang/nats-server/server/jetstream_cluster_long_test.go

.NET Implementation Files (Source)

src/NATS.Server/JetStream/ — Root files (orchestration)
src/NATS.Server/JetStream/Api/ — API handlers
src/NATS.Server/JetStream/Consumers/ — Consumer state machine
src/NATS.Server/JetStream/Models/ — StreamConfig, ConsumerConfig, etc.
src/NATS.Server/JetStream/MirrorSource/ — Stream mirroring & sourcing
src/NATS.Server/JetStream/Publish/ — Publish handling
src/NATS.Server/JetStream/Snapshots/ — State snapshots
src/NATS.Server/JetStream/Validation/ — Config validation
src/NATS.Server/JetStream/Storage/ — FileStore, MemStore, encryption
src/NATS.Server/JetStream/Cluster/ — Clustered JetStream

.NET Implementation Files (Tests)

tests/NATS.Server.Tests/JetStream/ — Root tests
tests/NATS.Server.Tests/JetStream/Api/
tests/NATS.Server.Tests/JetStream/Cluster/
tests/NATS.Server.Tests/JetStream/Consumers/
tests/NATS.Server.Tests/JetStream/MirrorSource/
tests/NATS.Server.Tests/JetStream/Snapshots/
tests/NATS.Server.Tests/JetStream/Storage/
tests/NATS.Server.Tests/JetStream/Streams/

Gap Inventory

jetstream.go — Core Orchestration (~2866 lines)

Go Symbol	Go File:Line	Status	.NET Equivalent	Notes
JetStreamConfig (struct)	golang/nats-server/server/jetstream.go:42	PORTED	src/NATS.Server/Configuration/JetStreamOptions.cs	Added missing config fields: `SyncInterval`, `SyncAlways`, `CompressOk`, `UniqueTag`, `Strict` (plus parser wiring)
JetStreamStats (struct)	golang/nats-server/server/jetstream.go:55	PORTED	src/NATS.Server/JetStream/JetStreamParityModels.cs (`JetStreamStats`)	Added server-usage model with `Memory`, `Store`, `ReservedMemory`, `ReservedStore`, `Accounts`, `HaAssets`, and `Api`
JetStreamAccountLimits (struct)	golang/nats-server/server/jetstream.go:65	PORTED	src/NATS.Server/JetStream/JetStreamParityModels.cs (`JetStreamAccountLimits`), src/NATS.Server/Configuration/JetStreamOptions.cs	Added missing limits fields: `MaxAckPending`, `MemoryMaxStreamBytes`, `StoreMaxStreamBytes`, `MaxBytesRequired`, and tier map support
JetStreamTier (struct)	golang/nats-server/server/jetstream.go:76	PORTED	src/NATS.Server/JetStream/JetStreamParityModels.cs (`JetStreamTier`)	Added per-tier model (`Name`, `Memory`, `Store`, `Streams`, `Consumers`)
JetStreamAccountStats (struct)	golang/nats-server/server/jetstream.go:87	PARTIAL	src/NATS.Server/JetStream/Api/JetStreamApiResponse.cs:105	JetStreamAccountInfo has Streams/Consumers counts only. Missing: memory/store usage, tiers, domain, API stats
JetStreamAPIStats (struct)	golang/nats-server/server/jetstream.go:95	PORTED	src/NATS.Server/JetStream/JetStreamParityModels.cs (`JetStreamApiStats`)	Added API stats model with `Level`, `Total`, `Errors`, `Inflight`
jetStream (internal struct)	golang/nats-server/server/jetstream.go:103	PARTIAL	src/NATS.Server/JetStream/JetStreamService.cs:11	JetStreamService covers lifecycle. Missing: apiInflight/apiTotal/apiErrors atomics, memUsed/storeUsed tracking, accounts map, apiSubs, cluster, oos/shuttingDown state
jsAccount (internal struct)	golang/nats-server/server/jetstream.go:151	MISSING	—	Per-account JetStream state (streams map, usage tracking, cluster usage updates) not modeled
jsaUsage (internal struct)	golang/nats-server/server/jetstream.go:181	MISSING	—	Per-account mem/store usage tracking
EnableJetStream (Server method)	golang/nats-server/server/jetstream.go:188	PARTIAL	src/NATS.Server/JetStream/JetStreamService.cs:95	StartAsync handles StoreDir creation and API subject registration. Missing: dynamic config, system memory detection, encryption init, cluster init
jsKeyGen (Server method)	golang/nats-server/server/jetstream.go:240	MISSING	—	HMAC-SHA256 key generation for JetStream encryption
decryptMeta (Server method)	golang/nats-server/server/jetstream.go:257	MISSING	—	Encrypted metafile decryption (AEAD with cipher fallback)
checkStoreDir (Server method)	golang/nats-server/server/jetstream.go:320	MISSING	—	Legacy store directory migration logic
initJetStreamEncryption (Server method)	golang/nats-server/server/jetstream.go:382	MISSING	—	TPM-backed encryption key initialization
enableJetStream (Server method)	golang/nats-server/server/jetstream.go:414	PARTIAL	src/NATS.Server/JetStream/JetStreamService.cs:95	Core startup covered. Missing: gcbOutMax, system account setup, JS banner, encryption notice, internal subscriptions setup, cluster mode init
canExtendOtherDomain (Server method)	golang/nats-server/server/jetstream.go:533	MISSING	—	Leaf node domain extension check
restartJetStream (Server method)	golang/nats-server/server/jetstream.go:556	MISSING	—	Re-enable JetStream during config reload
setupJetStreamExports (Server method)	golang/nats-server/server/jetstream.go:590	MISSING	—	System account service export setup
handleOutOfSpace (Server method)	golang/nats-server/server/jetstream.go:613	MISSING	—	OOS handling: disable JS + advisory
DisableJetStream (Server method)	golang/nats-server/server/jetstream.go:643	PARTIAL	src/NATS.Server/JetStream/JetStreamService.cs:141	DisposeAsync clears subjects. Missing: cluster meta leader transfer, RAFT node cleanup
enableJetStreamAccounts (Server method)	golang/nats-server/server/jetstream.go:690	MISSING	—	Multi-account JS enablement with parallel task workers
enableAllJetStreamServiceImportsAndMappings (Account method)	golang/nats-server/server/jetstream.go:714	MISSING	—	Per-account service imports and domain mappings
configJetStream (Server method)	golang/nats-server/server/jetstream.go:771	MISSING	—	Per-account JS config (enable/update/disable)
configAllJetStreamAccounts (Server method)	golang/nats-server/server/jetstream.go:809	MISSING	—	Walk all accounts and restore JetStream state
JetStreamEnabled (Server method)	golang/nats-server/server/jetstream.go:904	PORTED	src/NATS.Server/NatsServer.cs:159 (`JetStreamEnabled`)	Server-level JetStream enabled check now exposed and backed by service running state
JetStreamEnabledForDomain (Server method)	golang/nats-server/server/jetstream.go:909	MISSING	—	Domain-wide JS availability check
signalPullConsumers (Server method)	golang/nats-server/server/jetstream.go:930	MISSING	—	Shutdown signal to R1 pull consumers
shutdownJetStream (Server method)	golang/nats-server/server/jetstream.go:977	PARTIAL	src/NATS.Server/JetStream/JetStreamService.cs:141	Basic cleanup in DisposeAsync. Missing: account removal, cluster qch signaling
JetStreamConfig (Server method)	golang/nats-server/server/jetstream.go:1055	PORTED	src/NATS.Server/NatsServer.cs:161 (`JetStreamConfig`)	Returns a copy of configured JetStream options (store dir, limits, domain)
StoreDir (Server method)	golang/nats-server/server/jetstream.go:1065	PORTED	src/NATS.Server/NatsServer.cs:177 (`StoreDir`)	Server now exposes current configured JetStream store directory
JetStreamNumAccounts (Server method)	golang/nats-server/server/jetstream.go:1074	MISSING	—	Enabled account count
JetStreamReservedResources (Server method)	golang/nats-server/server/jetstream.go:1085	MISSING	—	Reserved mem/store bytes
Account.EnableJetStream	golang/nats-server/server/jetstream.go:1107	MISSING	—	Per-account JS enablement with limits, store dir, cluster usage
Account.UpdateJetStreamLimits	golang/nats-server/server/jetstream.go:1736	MISSING	—	Update account limits with delta checking
Account.JetStreamUsage	golang/nats-server/server/jetstream.go:1834	MISSING	—	Full account usage stats with tier breakdown
Account.DisableJetStream	golang/nats-server/server/jetstream.go:1961	MISSING	—	Per-account JS disable
Account.lookupStream	golang/nats-server/server/jetstream.go:1717	MISSING	—	Stream lookup by name (via jsa)
Account.streams / filteredStreams	golang/nats-server/server/jetstream.go:1681	MISSING	—	All/filtered stream enumeration
jsAccount.updateUsage	golang/nats-server/server/jetstream.go:2187	MISSING	—	Storage usage delta tracking
jsAccount.checkAndSyncUsage	golang/nats-server/server/jetstream.go:2108	MISSING	—	Usage drift detection and correction
jsAccount.sendClusterUsageUpdate	golang/nats-server/server/jetstream.go:2250	MISSING	—	Binary-encoded cluster usage publication
jsAccount.remoteUpdateUsage	golang/nats-server/server/jetstream.go:2021	MISSING	—	Process incoming remote usage updates
jetStream.wouldExceedLimits	golang/nats-server/server/jetstream.go:2299	MISSING	—	Server-level resource limit check
jetStream.checkLimits	golang/nats-server/server/jetstream.go:2434	MISSING	—	Account+server limit checking for stream config
jetStream.checkBytesLimits	golang/nats-server/server/jetstream.go:2446	MISSING	—	Byte-level limits check for mem/file storage
jetStream.sufficientResources	golang/nats-server/server/jetstream.go:2549	MISSING	—	System resource sufficiency check for new accounts
jetStream.reserveStreamResources	golang/nats-server/server/jetstream.go:2606	MISSING	—	Reserve MaxBytes for a stream
jetStream.releaseStreamResources	golang/nats-server/server/jetstream.go:2627	MISSING	—	Release reserved MaxBytes
jetStream.usageStats	golang/nats-server/server/jetstream.go:2520	MISSING	—	Server-wide JS usage stats
jsAccount.selectLimits	golang/nats-server/server/jetstream.go:2337	MISSING	—	Tier-based limit selection
jsAccount.storageTotals	golang/nats-server/server/jetstream.go:2360	MISSING	—	Aggregate mem/store totals
jsAccount.reservedStorage	golang/nats-server/server/jetstream.go:1801	MISSING	—	Reserved bytes by tier
jsAccount.delete	golang/nats-server/server/jetstream.go:2481	MISSING	—	Delete all JS resources for account
dynJetStreamConfig (Server method)	golang/nats-server/server/jetstream.go:2659	MISSING	—	Dynamic config: 75% sysmem, disk available
isValidName	golang/nats-server/server/jetstream.go:2735	PORTED	src/NATS.Server/JetStream/Validation/JetStreamConfigValidator.cs:10	`IsValidName` enforces non-empty names, UTF-8 max 255 bytes, and rejects whitespace / `*` / `>`; applied in stream + consumer create paths
friendlyBytes	golang/nats-server/server/jetstream.go:2723	NOT_APPLICABLE	—	Logging helper; .NET has built-in formatting
tierName	golang/nats-server/server/jetstream.go:2316	MISSING	—	Compute tier name from replica count
validateJetStreamOptions	golang/nats-server/server/jetstream.go:2767	MISSING	—	Validates JS options (domain, cluster, etc.)
fixCfgMirrorWithDedupWindow	golang/nats-server/server/jetstream.go:2848	NOT_APPLICABLE	—	Bug fix for legacy config; not needed in new port
JetStreamStoreDir (const)	golang/nats-server/server/jetstream.go:2649	PORTED	src/NATS.Server/Configuration/JetStreamOptions.cs:8	Added Go-parity constant `"jetstream"`
JetStreamMaxStoreDefault (const)	golang/nats-server/server/jetstream.go:2651	PORTED	src/NATS.Server/Configuration/JetStreamOptions.cs:9	Added Go-parity default max store constant (`1 TiB`)
JetStreamMaxMemDefault (const)	golang/nats-server/server/jetstream.go:2653	PORTED	src/NATS.Server/Configuration/JetStreamOptions.cs:10	Added Go-parity default max memory constant (`256 MiB`)
Stream recovery logic (doStream/doConsumers)	golang/nats-server/server/jetstream.go:1223-1636	MISSING	—	Full stream/consumer recovery from disk: metafile reading, checksum, encryption, versioning, subject repair
keyGen (type)	golang/nats-server/server/jetstream.go:237	MISSING	—	Key generation function signature for encryption
resourcesExceededError (Server method)	golang/nats-server/server/jetstream.go:2743	MISSING	—	Throttled error logging + meta leader stepdown
handleWritePermissionError (Server method)	golang/nats-server/server/jetstream.go:2857	MISSING	—	FS permission error handling

jetstream_api.go — API Handlers (~5165 lines)

Go Symbol	Go File:Line	Status	.NET Equivalent	Notes
JSApi* subject constants (50+)	golang/nats-server/server/jetstream_api.go:36-312	PORTED	src/NATS.Server/JetStream/Api/JetStreamApiSubjects.cs:1	All major API subjects defined. Minor: some template variants (T-suffixed) not needed in .NET
JSAdvisory* prefix constants (25+)	golang/nats-server/server/jetstream_api.go:229-311	PARTIAL	src/NATS.Server/JetStream/Api/AdvisoryPublisher.cs:1	Stream create/delete/update, consumer create/delete covered. Missing: snapshot, restore, leader elected, quorum lost, batch abandoned, out-of-storage, server removed, API limit, pause, pinned, unpinned advisory prefixes
JSMaxDescriptionLen (const)	golang/nats-server/server/jetstream_api.go:352	PORTED	src/NATS.Server/JetStream/Api/JetStreamApiLimits.cs:10	Added Go-parity constant and enforced in stream create/update validation (`StreamManager`)
JSMaxMetadataLen (const)	golang/nats-server/server/jetstream_api.go:356	PORTED	src/NATS.Server/JetStream/Api/JetStreamApiLimits.cs:11	Added Go-parity constant; metadata byte-size helper validates stream/consumer metadata against this limit
JSMaxNameLen (const)	golang/nats-server/server/jetstream_api.go:360	PORTED	src/NATS.Server/JetStream/Api/JetStreamApiLimits.cs:12	Added Go-parity constant; name validation uses UTF-8 byte length limit through `JetStreamConfigValidator.IsValidName`
JSDefaultRequestQueueLimit (const)	golang/nats-server/server/jetstream_api.go:364	PORTED	src/NATS.Server/JetStream/Api/JetStreamApiLimits.cs:13	Added Go-parity default request queue limit constant for JetStream API request orchestration
ApiResponse (struct)	golang/nats-server/server/jetstream_api.go:369	PARTIAL	src/NATS.Server/JetStream/Api/JetStreamApiResponse.cs:5	Type field missing; error structure simplified
ApiPaged / ApiPagedRequest (structs)	golang/nats-server/server/jetstream_api.go:395-404	MISSING	—	Paged API request/response not implemented
JSApiAccountInfoResponse	golang/nats-server/server/jetstream_api.go:407	PARTIAL	src/NATS.Server/JetStream/Api/JetStreamApiResponse.cs:105	Basic streams/consumers count. Missing: full JetStreamAccountStats embedding
JSApiStreamCreateResponse	golang/nats-server/server/jetstream_api.go:415	PARTIAL	src/NATS.Server/JetStream/Api/JetStreamApiResponse.cs:94	StreamInfo returned. Missing: DidCreate field
JSApiStreamDeleteResponse	golang/nats-server/server/jetstream_api.go:423	PORTED	src/NATS.Server/JetStream/Api/JetStreamApiResponse.cs:17	Success field present
JSApiStreamInfoRequest / Response	golang/nats-server/server/jetstream_api.go:434-446	PARTIAL	src/NATS.Server/JetStream/Api/JetStreamApiResponse.cs:94	Basic info works. Missing: DeletedDetails, SubjectsFilter, paged response
JSApiStreamNamesRequest / Response	golang/nats-server/server/jetstream_api.go:453-467	PARTIAL	src/NATS.Server/JetStream/Api/JetStreamApiResponse.cs:11	StreamNames returned. Missing: paging, subject filter
JSApiStreamListRequest / Response	golang/nats-server/server/jetstream_api.go:469-485	MISSING	—	Detailed stream list with paging, missing/offline
JSApiStreamPurgeRequest / Response	golang/nats-server/server/jetstream_api.go:492-507	PARTIAL	src/NATS.Server/JetStream/Api/JetStreamApiResponse.cs:76	Purge response with count. Missing: filter/sequence/keep options in request
JSApiStreamUpdateResponse	golang/nats-server/server/jetstream_api.go:519	PARTIAL	src/NATS.Server/JetStream/Api/JetStreamApiResponse.cs:94	Returns StreamInfo. Response type constant missing
JSApiMsgDeleteRequest / Response	golang/nats-server/server/jetstream_api.go:528-538	PORTED	src/NATS.Server/JetStream/Api/Handlers/StreamApiHandlers.cs	HandleMessageDelete implemented
JSApiStreamSnapshotRequest / Response	golang/nats-server/server/jetstream_api.go:540-569	PARTIAL	src/NATS.Server/JetStream/Api/JetStreamApiResponse.cs:125	Basic snapshot modeled. Missing: DeliverSubject, NoConsumers, ChunkSize, WindowSize, CheckMsgs options
JSApiStreamRestoreRequest / Response	golang/nats-server/server/jetstream_api.go:572-586	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/StreamApiHandlers.cs	HandleRestore exists. Missing: chunked delivery protocol
JSApiStreamRemovePeerRequest / Response	golang/nats-server/server/jetstream_api.go:589-600	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/ClusterControlApiHandlers.cs	HandleStreamPeerRemove exists as stub
JSApiStreamLeaderStepDownResponse	golang/nats-server/server/jetstream_api.go:603-608	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/ClusterControlApiHandlers.cs	HandleStreamLeaderStepdown exists
JSApiConsumerLeaderStepDownResponse	golang/nats-server/server/jetstream_api.go:611-616	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/ClusterControlApiHandlers.cs	HandleConsumerLeaderStepdown exists
JSApiLeaderStepdownRequest / Response	golang/nats-server/server/jetstream_api.go:619-629	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/ClusterControlApiHandlers.cs	HandleMetaLeaderStepdown exists
JSApiMetaServerRemoveRequest / Response	golang/nats-server/server/jetstream_api.go:632-646	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/AccountControlApiHandlers.cs	HandleServerRemove exists as stub
JSApiMetaServerStreamMoveRequest	golang/nats-server/server/jetstream_api.go:650-659	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/AccountControlApiHandlers.cs	HandleAccountStreamMove exists as stub
JSApiAccountPurgeResponse	golang/nats-server/server/jetstream_api.go:663-667	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/AccountControlApiHandlers.cs	HandleAccountPurge exists as stub
JSApiMsgGetRequest / Response	golang/nats-server/server/jetstream_api.go:670-699	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/StreamApiHandlers.cs	HandleMessageGet exists. Missing: Batch, MaxBytes, StartTime, MultiLastFor, UpToSeq/Time, NoHeaders
JSApiConsumerCreateResponse	golang/nats-server/server/jetstream_api.go:704-709	PARTIAL	src/NATS.Server/JetStream/Api/JetStreamApiResponse.cs:100	ConsumerInfo returned. Response type constant missing
JSApiConsumerDeleteResponse	golang/nats-server/server/jetstream_api.go:711-716	PORTED	src/NATS.Server/JetStream/Api/Handlers/ConsumerApiHandlers.cs	HandleDelete implemented
JSApiConsumerPauseRequest / Response	golang/nats-server/server/jetstream_api.go:718-729	PORTED	src/NATS.Server/JetStream/Api/JetStreamApiResponse.cs:86	PauseResponse with Paused/PauseUntil
JSApiConsumerInfoResponse	golang/nats-server/server/jetstream_api.go:731-736	PARTIAL	src/NATS.Server/JetStream/Api/JetStreamApiResponse.cs:100	ConsumerInfo returned. Missing: type field
JSApiConsumerNamesResponse	golang/nats-server/server/jetstream_api.go:742-748	PARTIAL	src/NATS.Server/JetStream/Api/JetStreamApiResponse.cs:12	ConsumerNames returned. Missing: paging
JSApiConsumerListResponse	golang/nats-server/server/jetstream_api.go:750-758	MISSING	—	Detailed consumer list with paging, missing/offline
JSApiConsumerGetNextRequest	golang/nats-server/server/jetstream_api.go:761-768	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/ConsumerApiHandlers.cs	HandleNext exists. Missing: Expires, MaxBytes, Heartbeat, PriorityGroup
JSApiConsumerResetRequest / Response	golang/nats-server/server/jetstream_api.go:771-781	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/ConsumerApiHandlers.cs	HandleReset exists as stub
JSApiConsumerUnpinRequest / Response	golang/nats-server/server/jetstream_api.go:509-517	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/ConsumerApiHandlers.cs	HandleUnpin exists as stub
generateJSMappingTable	golang/nats-server/server/jetstream_api.go:323-349	MISSING	—	Domain prefix mapping table generation
apiDispatch (jetStream method)	golang/nats-server/server/jetstream_api.go:795	PARTIAL	src/NATS.Server/JetStream/Api/JetStreamApiRouter.cs:222	Router.Route matches subjects to handlers. Missing: ClientInfoHdr check, inflight tracking, queue-based dispatch pool
processJSAPIRoutedRequests	golang/nats-server/server/jetstream_api.go:882	MISSING	—	Worker pool goroutine for processing routed API requests
setJetStreamExportSubs	golang/nats-server/server/jetstream_api.go:913	PARTIAL	src/NATS.Server/JetStream/JetStreamService.cs:16	AllApiSubjects list covers subject registration. Missing: worker pool, Sublist-based routing
sendAPIResponse / sendAPIErrResponse	golang/nats-server/server/jetstream_api.go:986-999	MISSING	—	API response sending with audit advisory
sendJetStreamAPIAuditAdvisory	golang/nats-server/server/jetstream_api.go:999+	MISSING	—	JS API audit advisory publication
jsAccountInfoRequest	golang/nats-server/server/jetstream_api.go:1238	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/AccountApiHandlers.cs	HandleInfo returns basic counts. Missing: full JetStreamAccountStats
jsStreamCreateRequest	golang/nats-server/server/jetstream_api.go:1335	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/StreamApiHandlers.cs	HandleCreate parses config and creates. Missing: clustered forwarding, permission checks, JSRequiredApiLevel header check
jsStreamUpdateRequest	golang/nats-server/server/jetstream_api.go:1452	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/StreamApiHandlers.cs	HandleUpdate exists. Missing: config diff validation, clustered proposal
jsStreamNamesRequest	golang/nats-server/server/jetstream_api.go:1557	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/StreamApiHandlers.cs	HandleNames returns list. Missing: paging, subject filter
jsStreamListRequest	golang/nats-server/server/jetstream_api.go:1690	MISSING	—	Detailed stream list with full StreamInfo per entry
jsStreamInfoRequest	golang/nats-server/server/jetstream_api.go:1809	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/StreamApiHandlers.cs	HandleInfo returns config+state. Missing: subject detail paging, deleted details
jsStreamDeleteRequest	golang/nats-server/server/jetstream_api.go:3073	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/StreamApiHandlers.cs	HandleDelete works. Missing: clustered forwarding
jsStreamPurgeRequest	golang/nats-server/server/jetstream_api.go:3572	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/StreamApiHandlers.cs	HandlePurge works. Missing: filter/sequence/keep options
jsMsgDeleteRequest	golang/nats-server/server/jetstream_api.go:3147	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/StreamApiHandlers.cs	HandleMessageDelete works. Missing: NoErase option, clustered forwarding
jsMsgGetRequest	golang/nats-server/server/jetstream_api.go:3272	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/StreamApiHandlers.cs	HandleMessageGet works for basic seq/subject. Missing: batch, multi-last, time-based queries
jsStreamSnapshotRequest	golang/nats-server/server/jetstream_api.go:4007	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/StreamApiHandlers.cs	HandleSnapshot exists. Missing: chunk delivery, ack flow, window sizing
jsStreamRestoreRequest	golang/nats-server/server/jetstream_api.go:3722	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/StreamApiHandlers.cs	HandleRestore exists. Missing: chunk receive protocol
jsStreamLeaderStepDownRequest	golang/nats-server/server/jetstream_api.go:2034	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/ClusterControlApiHandlers.cs	Stub exists
jsStreamRemovePeerRequest	golang/nats-server/server/jetstream_api.go:2275	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/ClusterControlApiHandlers.cs	Stub exists
jsConsumerCreateRequest	golang/nats-server/server/jetstream_api.go:4244	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/ConsumerApiHandlers.cs	HandleCreate works for basic cases. Missing: JSApiConsumerCreateEx subject parsing, action (Create/Update), config validation depth
jsConsumerNamesRequest	golang/nats-server/server/jetstream_api.go:4470	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/ConsumerApiHandlers.cs	HandleNames works. Missing: paging
jsConsumerListRequest	golang/nats-server/server/jetstream_api.go:4597	MISSING	—	Detailed consumer list with paging
jsConsumerInfoRequest	golang/nats-server/server/jetstream_api.go:4707	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/ConsumerApiHandlers.cs	HandleInfo returns config. Missing: full ConsumerInfo (delivered, ack_floor, num_ack_pending, etc.)
jsConsumerDeleteRequest	golang/nats-server/server/jetstream_api.go:4913	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/ConsumerApiHandlers.cs	HandleDelete works
jsConsumerPauseRequest	golang/nats-server/server/jetstream_api.go:4991	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/ConsumerApiHandlers.cs	HandlePause works. Missing: PauseRemaining duration in response
jsConsumerUnpinRequest	golang/nats-server/server/jetstream_api.go:3429	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/ConsumerApiHandlers.cs	HandleUnpin exists as stub
jsLeaderServerRemoveRequest	golang/nats-server/server/jetstream_api.go:2383	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/AccountControlApiHandlers.cs	Stub exists
jsLeaderServerStreamMoveRequest	golang/nats-server/server/jetstream_api.go:2514	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/AccountControlApiHandlers.cs	Stub exists
jsLeaderServerStreamCancelMoveRequest	golang/nats-server/server/jetstream_api.go:2678	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/AccountControlApiHandlers.cs	Stub exists
jsLeaderAccountPurgeRequest	golang/nats-server/server/jetstream_api.go:2793	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/AccountControlApiHandlers.cs	Stub exists
jsLeaderStepDownRequest	golang/nats-server/server/jetstream_api.go:2893	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/ClusterControlApiHandlers.cs	Stub exists
delayedAPIResponder	golang/nats-server/server/jetstream_api.go:1047	MISSING	—	Delayed API response delivery with ordered linked list
JSDirectMsgGet handler	golang/nats-server/server/jetstream_api.go:105-111	PARTIAL	src/NATS.Server/JetStream/Api/Handlers/DirectApiHandlers.cs	HandleGet exists. Missing: batch support, multi-last, header stripping
ILeaderForwarder interface	—	PORTED	src/NATS.Server/JetStream/Api/JetStreamApiRouter.cs:10	.NET-native abstraction for leader forwarding
JetStreamApiRouter	—	PORTED	src/NATS.Server/JetStream/Api/JetStreamApiRouter.cs:68	Subject-to-handler routing with leader check
ApiRateLimiter	—	PORTED	src/NATS.Server/JetStream/Api/ApiRateLimiter.cs:11	Concurrency limiter + dedup cache
ClusteredRequestProcessor	—	PORTED	src/NATS.Server/JetStream/Api/ClusteredRequestProcessor.cs:13	Pending request correlation with TCS pattern

jetstream_events.go — Advisory Event Types (~366 lines)

Go Symbol	Go File:Line	Status	.NET Equivalent	Notes
publishAdvisory (Server method)	golang/nats-server/server/jetstream_events.go:23	PARTIAL	src/NATS.Server/JetStream/Api/AdvisoryPublisher.cs:9	AdvisoryPublisher publishes via delegate. Missing: interest check (SubList.HasInterest), gateway interest check, system account fallback
JSAPIAudit (struct)	golang/nats-server/server/jetstream_events.go:50	MISSING	—	API audit advisory type with Server, Client, Subject, Request, Response, Domain
JSAPIAuditType (const)	golang/nats-server/server/jetstream_events.go:60	MISSING	—	"io.nats.jetstream.advisory.v1.api_audit"
ActionAdvisoryType (type + consts)	golang/nats-server/server/jetstream_events.go:63-69	MISSING	—	CreateEvent/DeleteEvent/ModifyEvent enum
JSStreamActionAdvisory (struct)	golang/nats-server/server/jetstream_events.go:72	PARTIAL	src/NATS.Server/JetStream/Api/AdvisoryPublisher.cs:28	StreamCreated/Deleted/Updated covered. Missing: Action field, Domain field, TypedEvent base
JSConsumerActionAdvisory (struct)	golang/nats-server/server/jetstream_events.go:82	PARTIAL	src/NATS.Server/JetStream/Api/AdvisoryPublisher.cs:75	ConsumerCreated/Deleted covered. Missing: Action field, Domain field
JSConsumerPauseAdvisory (struct)	golang/nats-server/server/jetstream_events.go:93	MISSING	—	Consumer pause/unpause advisory
JSConsumerAckMetric (struct)	golang/nats-server/server/jetstream_events.go:106	MISSING	—	Ack latency metric
JSConsumerDeliveryExceededAdvisory (struct)	golang/nats-server/server/jetstream_events.go:122	MISSING	—	Max delivery exceeded advisory
JSConsumerDeliveryNakAdvisory (struct)	golang/nats-server/server/jetstream_events.go:135	MISSING	—	NAK advisory
JSConsumerDeliveryTerminatedAdvisory (struct)	golang/nats-server/server/jetstream_events.go:149	MISSING	—	Terminated message advisory
JSSnapshotCreateAdvisory (struct)	golang/nats-server/server/jetstream_events.go:166	MISSING	—	Snapshot start advisory
JSSnapshotCompleteAdvisory (struct)	golang/nats-server/server/jetstream_events.go:177	MISSING	—	Snapshot complete advisory
JSRestoreCreateAdvisory (struct)	golang/nats-server/server/jetstream_events.go:191	MISSING	—	Restore start advisory
JSRestoreCompleteAdvisory (struct)	golang/nats-server/server/jetstream_events.go:201	MISSING	—	Restore complete advisory
JSDomainLeaderElectedAdvisory (struct)	golang/nats-server/server/jetstream_events.go:221	MISSING	—	Domain leader election advisory
JSStreamLeaderElectedAdvisory (struct)	golang/nats-server/server/jetstream_events.go:233	MISSING	—	Stream leader election advisory
JSStreamQuorumLostAdvisory (struct)	golang/nats-server/server/jetstream_events.go:247	MISSING	—	Stream quorum lost advisory
JSStreamBatchAbandonedAdvisory (struct)	golang/nats-server/server/jetstream_events.go:259	MISSING	—	Batch abandoned advisory
BatchAbandonReason (type + consts)	golang/nats-server/server/jetstream_events.go:268-274	MISSING	—	timeout/large/incomplete reasons
JSConsumerLeaderElectedAdvisory (struct)	golang/nats-server/server/jetstream_events.go:280	MISSING	—	Consumer leader election advisory
JSConsumerQuorumLostAdvisory (struct)	golang/nats-server/server/jetstream_events.go:295	MISSING	—	Consumer quorum lost advisory
JSConsumerGroupPinnedAdvisory (struct)	golang/nats-server/server/jetstream_events.go:307	MISSING	—	Priority group pin advisory
JSConsumerGroupUnpinnedAdvisory (struct)	golang/nats-server/server/jetstream_events.go:320	MISSING	—	Priority group unpin advisory
JSServerOutOfSpaceAdvisory (struct)	golang/nats-server/server/jetstream_events.go:335	MISSING	—	Server out of space advisory
JSServerRemovedAdvisory (struct)	golang/nats-server/server/jetstream_events.go:348	MISSING	—	Server removed advisory
JSAPILimitReachedAdvisory (struct)	golang/nats-server/server/jetstream_events.go:360	MISSING	—	API queue limit reached advisory

jetstream_errors.go — Error Framework (~103 lines)

Go Symbol	Go File:Line	Status	.NET Equivalent	Notes
ErrorIdentifier (type)	golang/nats-server/server/jetstream_errors.go:29	MISSING	—	uint16 error identifier type
ErrorOption / Unless	golang/nats-server/server/jetstream_errors.go:12-19	MISSING	—	Functional options for error creation
IsNatsErr	golang/nats-server/server/jetstream_errors.go:32	MISSING	—	Error identity checker by ErrorIdentifier
ApiError (struct)	golang/nats-server/server/jetstream_errors.go:57	PARTIAL	src/NATS.Server/JetStream/Api/JetStreamApiError.cs:3	Code + Description present. Missing: ErrCode (uint16 error code), Error() method
ErrorsData (struct)	golang/nats-server/server/jetstream_errors.go:64	MISSING	—	Source data for generated errors
ApiError.toReplacerArgs	golang/nats-server/server/jetstream_errors.go:79	MISSING	—	Template replacement helper

jetstream_errors_generated.go — Error Codes (~3176 lines)

Go Symbol	Go File:Line	Status	.NET Equivalent	Notes
ErrorIdentifier constants (200+)	golang/nats-server/server/jetstream_errors_generated.go:7-400+	PARTIAL	src/NATS.Server/JetStream/Publish/AtomicBatchPublishEngine.cs:14	Only 9 atomic-batch error codes ported. Missing: ~190 other error identifiers (stream, consumer, cluster, etc.)
ApiErrors map	golang/nats-server/server/jetstream_errors_generated.go:400+	MISSING	—	Global map[ErrorIdentifier]*ApiError with HTTP codes and descriptions
NewJS*Error factory functions (200+)	golang/nats-server/server/jetstream_errors_generated.go:varies	MISSING	—	Factory functions for each error type with template substitution

jetstream_versioning.go — Version Negotiation (~237 lines)

Go Symbol	Go File:Line	Status	.NET Equivalent	Notes
JSApiLevel (const)	golang/nats-server/server/jetstream_versioning.go:20	PORTED	src/NATS.Server/JetStream/JsVersioning.cs:19	Value 3 matches
JSRequiredLevelMetadataKey (const)	golang/nats-server/server/jetstream_versioning.go:22	PORTED	src/NATS.Server/JetStream/JsVersioning.cs:25	"_nats.req.level"
JSServerVersionMetadataKey (const)	golang/nats-server/server/jetstream_versioning.go:23	PORTED	src/NATS.Server/JetStream/JsVersioning.cs:28	"_nats.ver"
JSServerLevelMetadataKey (const)	golang/nats-server/server/jetstream_versioning.go:24	PORTED	src/NATS.Server/JetStream/JsVersioning.cs:31	"_nats.level"
getRequiredApiLevel	golang/nats-server/server/jetstream_versioning.go:28	PORTED	src/NATS.Server/JetStream/JsVersioning.cs:37	Exact behavior match
supportsRequiredApiLevel	golang/nats-server/server/jetstream_versioning.go:36	PORTED	src/NATS.Server/JetStream/JsVersioning.cs:48	Exact behavior match
setStaticStreamMetadata	golang/nats-server/server/jetstream_versioning.go:44	PORTED	src/NATS.Server/JetStream/JsVersioning.cs:63	All feature level checks match (TTL, counter, batch, schedule, persist)
setDynamicStreamMetadata	golang/nats-server/server/jetstream_versioning.go:88	PORTED	src/NATS.Server/JetStream/JsVersioning.cs:101	Copy + add version/level
copyStreamMetadata	golang/nats-server/server/jetstream_versioning.go:110	PORTED	src/NATS.Server/JetStream/JsVersioning.cs:121	Copy versioning fields
setOrDeleteInStreamMetadata	golang/nats-server/server/jetstream_versioning.go:118	PORTED	src/NATS.Server/JetStream/JsVersioning.cs:197	Set or delete helper
setStaticConsumerMetadata	golang/nats-server/server/jetstream_versioning.go:136	PORTED	src/NATS.Server/JetStream/JsVersioning.cs:132	PauseUntil + priority checks match
setDynamicConsumerMetadata	golang/nats-server/server/jetstream_versioning.go:164	PORTED	src/NATS.Server/JetStream/JsVersioning.cs:157	Copy + add version/level
setDynamicConsumerInfoMetadata	golang/nats-server/server/jetstream_versioning.go:181	MISSING	—	Wraps setDynamicConsumerMetadata for ConsumerInfo
copyConsumerMetadata	golang/nats-server/server/jetstream_versioning.go:198	PORTED	src/NATS.Server/JetStream/JsVersioning.cs:176	Copy versioning fields
setOrDeleteInConsumerMetadata	golang/nats-server/server/jetstream_versioning.go:206	PORTED	src/NATS.Server/JetStream/JsVersioning.cs:213	Set or delete helper
deleteDynamicMetadata	golang/nats-server/server/jetstream_versioning.go:222	PORTED	src/NATS.Server/JetStream/JsVersioning.cs:187	Remove version/level keys
errorOnRequiredApiLevel	golang/nats-server/server/jetstream_versioning.go:229	MISSING	—	Header-based API level rejection check

jetstream_batching.go — Batch Operations (~663 lines)

Go Symbol	Go File:Line	Status	.NET Equivalent	Notes
globalInflightBatches (var)	golang/nats-server/server/jetstream_batching.go:31	MISSING	—	Global atomic counter across all streams
batching (struct)	golang/nats-server/server/jetstream_batching.go:35	PARTIAL	src/NATS.Server/JetStream/Publish/AtomicBatchPublishEngine.cs:91	AtomicBatchPublishEngine uses ConcurrentDictionary. Missing: per-group store, timer-based cleanup
batchGroup (struct)	golang/nats-server/server/jetstream_batching.go:40	PARTIAL	src/NATS.Server/JetStream/Publish/AtomicBatchPublishEngine.cs:61	InFlightBatch tracks messages. Missing: lseq, store (StreamStore), timer
batchGroup.newBatchGroup	golang/nats-server/server/jetstream_batching.go:47	PARTIAL	src/NATS.Server/JetStream/Publish/AtomicBatchPublishEngine.cs:150	Batch creation in Process(). Missing: per-batch file store, server-configured timeout
getBatchStoreDir	golang/nats-server/server/jetstream_batching.go:66	MISSING	—	Compute batch store directory path
newBatchStore	golang/nats-server/server/jetstream_batching.go:79	MISSING	—	Create file or memory store for batch staging
batchGroup.readyForCommit	golang/nats-server/server/jetstream_batching.go:104	PARTIAL	src/NATS.Server/JetStream/Publish/AtomicBatchPublishEngine.cs:258	Commit path exists. Missing: timer.Stop() check, FlushAllPending
batchGroup.cleanup / cleanupLocked	golang/nats-server/server/jetstream_batching.go:113-125	PARTIAL	src/NATS.Server/JetStream/Publish/AtomicBatchPublishEngine.cs:317	EvictExpiredBatches. Missing: store.Delete, globalInflightBatches decrement
batchGroup.stopLocked	golang/nats-server/server/jetstream_batching.go:128	MISSING	—	Stop batch without cleanup
batchStagedDiff (struct)	golang/nats-server/server/jetstream_batching.go:135	MISSING	—	Staged diff for consistency checks: msgIds, counter, inflight, expectedPerSubject
batchStagedDiff.commit	golang/nats-server/server/jetstream_batching.go:147	MISSING	—	Commit staged diff to stream state
batchApply (struct)	golang/nats-server/server/jetstream_batching.go:198	MISSING	—	Cluster-level batch apply state
batchApply.clearBatchStateLocked	golang/nats-server/server/jetstream_batching.go:209	MISSING	—	Clear in-memory batch state
batchApply.rejectBatchStateLocked	golang/nats-server/server/jetstream_batching.go:220	MISSING	—	Reject batch and adjust CLFS
checkMsgHeadersPreClusteredProposal	golang/nats-server/server/jetstream_batching.go:240	MISSING	—	Pre-proposal header validation (~420 lines): expected-seq, per-subject-seq, msg ID dedup, counter CRDT, TTL, scheduling, rollup, discard-new checks
AtomicBatchPublishEngine (.NET-only)	—	PORTED	src/NATS.Server/JetStream/Publish/AtomicBatchPublishEngine.cs:91	.NET-native batch engine with stage/commit/error flow
AtomicBatchPublishErrorCodes (.NET-only)	—	PORTED	src/NATS.Server/JetStream/Publish/AtomicBatchPublishEngine.cs:14	9 error codes matching Go generated codes
BatchPublishRequest (.NET-only)	—	PORTED	src/NATS.Server/JetStream/Publish/AtomicBatchPublishEngine.cs:331	Request model for batch messages
AtomicBatchResult (.NET-only)	—	PORTED	src/NATS.Server/JetStream/Publish/AtomicBatchPublishEngine.cs:358	Staged/Committed/Error result type

Keeping This File Updated

After porting work is completed:

Update status: Change MISSING → PORTED or PARTIAL → PORTED for each item completed
Add .NET path: Fill in the ".NET Equivalent" column with the actual file:line

Re-count LOC: Update the LOC numbers in stillmissing.md:

# Re-count .NET source LOC for this module
find src/NATS.Server/JetStream/ -name '*.cs' -type f -exec cat {} + | wc -l
# Re-count .NET test LOC for this module
find tests/NATS.Server.Tests/JetStream/ -name '*.cs' -type f -exec cat {} + | wc -l

Add a changelog entry below with date and summary of what was ported

Update the parity DB if new test mappings were created:

sqlite3 docs/test_parity.db "INSERT INTO test_mappings (go_test_id, dotnet_test_id, confidence, notes) VALUES (?, ?, 'manual', 'ported in YYYY-MM-DD session')"

| Status | Count | | PORTED | 55 | | PARTIAL | 30 | | MISSING | 75 | | NOT_APPLICABLE | 12 | | DEFERRED | 0 | | Total | 172 |

| (mset *stream) setupSourceConsumers | stream.go:4318 | PARTIAL | SourceCoordinator.StartSyncLoop / StartPullSyncLoop | Go creates internal consumers per source with proper starting sequences. .NET has background sync loops but no internal consumer creation. | | (mset *stream) subscribeToStream | stream.go:4348 | MISSING | — | Creates internal subscriptions for all stream subjects + mirror/source setup. .NET uses StreamManager.Capture instead of subscription-based ingest. | | (mset *stream) subscribeToDirect | stream.go:4406 | PARTIAL | DirectApiHandlers.HandleGet | Go creates queue subscriptions for $JS.API.DIRECT.GET.{stream}. .NET has API handler but no queue-subscription wiring. | | (mset *stream) unsubscribeToDirect | stream.go:4431 | MISSING | — | Unsubscribes direct get subscriptions. No .NET equivalent. | | (mset *stream) subscribeToMirrorDirect | stream.go:4443 | MISSING | — | Sets up direct-get queue subs for mirror stream name. Not implemented in .NET. | | (mset *stream) unsubscribeToMirrorDirect | stream.go:4474 | MISSING | — | Clears mirror direct-get subscriptions. Not implemented. | | (mset *stream) stopSourceConsumers | stream.go:4487 | PORTED | SourceCoordinator.StopAsync | .NET coordinator has async stop with cancellation. | | (mset *stream) removeInternalConsumer | stream.go:4494 | MISSING | — | Clears consumer name on sourceInfo. .NET doesn't track internal consumer names. | | (mset *stream) unsubscribeToStream | stream.go:4503 | MISSING | — | Unsubscribes from all stream subjects, mirrors, sources. .NET uses StreamManager.Delete instead. | | (mset *stream) deleteInflightBatches | stream.go:4535 | PARTIAL | JetStreamPublisher.ClearBatches | Go cleans up batch state with lock ordering. .NET has simplified ClearBatches on AtomicBatchPublishEngine. | | (mset *stream) deleteBatchApplyState | stream.go:4552 | MISSING | — | Cleans up raft batch-apply entries with pool return. No .NET equivalent (no RAFT batch apply). |

| (mset *stream) processInboundJetStreamMsg | stream.go:5409 | MISSING | — | Entry point: copies msg, adds trace, queues inbound. .NET uses StreamManager.Capture. | | Error sentinel variables | stream.go:5428 | PARTIAL | — | errLastSeqMismatch, errMsgIdDuplicate, etc. .NET uses error codes in PubAck instead. | | (mset *stream) processJetStreamMsg | stream.go:5437 | PARTIAL | JetStreamPublisher.TryCaptureWithOptions + StreamManager.Capture | Core message processing. Go: full consistency checks, subject transform, sealed/sealed check, header extraction, dedup, TTL, counter increment, schedule validation, rollup, interest retention skip, store. .NET: basic dedup + expected-last-seq + capture. Missing: rollup, TTL, counters, schedules, per-subject seq, interest retention skip, sealed check at msg level, clustered RAFT propose. |

| jsPubMsg struct | stream.go:6770 | MISSING | — | Internal pub message with dest subject, reply, store msg, consumer ref. | | newJSPubMsg | stream.go:6786 | MISSING | — | Constructor with pool allocation. | | jsPubMsgPool | stream.go:6784 | MISSING | — | sync.Pool for jsPubMsg. | | (pm *jsPubMsg) returnToPool | stream.go:6815 | MISSING | — | Pool return. | | (pm *jsPubMsg) size | stream.go:6826 | MISSING | — | Size calculation for flow control. | | jsOutQ struct | stream.go:6834 | MISSING | — | Typed output queue wrapper around ipQueue. | | (q *jsOutQ) sendMsg | stream.go:6838 | MISSING | — | Sends message on output queue. | | (q *jsOutQ) send | stream.go:6844 | MISSING | — | Pushes jsPubMsg to queue. | | StoredMsg struct | stream.go:6858 | PORTED | StoredMessage | .NET StoredMessage record has Subject, Sequence, Payload, TimestampUtc. | | (mset *stream) setupSendCapabilities | stream.go:6869 | MISSING | — | Creates output queue and launches internalLoop goroutine. | | (mset *stream) accName | stream.go:6881 | NOT_APPLICABLE | — | Returns account name. .NET uses Account directly. | | (mset *stream) name / nameLocked | stream.go:6892 | NOT_APPLICABLE | — | Returns stream name. .NET uses StreamHandle.Config.Name. | | (mset *stream) internalLoop | stream.go:6907 | MISSING | — | Main event loop: outq dispatch, inbound msg processing, direct gets, ack queue for interest retention. Complex select{} loop. Not implemented in .NET. |

| (mset *stream) snapshot | stream.go:7764 | PORTED | StreamSnapshotService.CreateTarSnapshotAsync | .NET uses TAR+S2 snapshot service. | | (a *Account) RestoreStream | stream.go:7776 | PARTIAL | StreamSnapshotService.RestoreTarSnapshotAsync | Go: full restore with config validation, limit checks, directory management, consumer restore. .NET: simplified restore (purge + replay). Missing: config validation, consumer restore, limit checks. |

| Status | Count | | PORTED | 11 | | PARTIAL | 24 | | MISSING | 73 | | NOT_APPLICABLE | 8 | | DEFERRED | 0 | | Total | 116 |

| AckAck/AckOK/AckNak/AckProgress/AckNext/AckTerm | consumer.go:376-388 | PORTED | AckType enum + AckProcessor.ParseAckType (Consumers/AckProcessor.cs:127) | All ack types recognized; AckNext (+NXT) handled implicitly | | ackTermLimitsReason/ackTermUnackedLimitsReason | consumer.go:391-394 | MISSING | — | Reason strings for limit-based terminations | | JSPullRequestPendingMsgs/Bytes/NatsPinId | consumer.go:43-46 | PARTIAL | Used in heartbeat headers in PushConsumerEngine | PinId header not used | | JsPullRequestRemainingBytesT | consumer.go:53 | MISSING | — | Template for 409 Batch Completed response | | validGroupName regex | consumer.go:49 | MISSING | — | Group name validation regex ^[a-zA-Z0-9/_=-]{1,16}$ |

| Status | Count | | PORTED | 23 | | PARTIAL | 21 | | MISSING | 70 | | NOT_APPLICABLE | 1 | | Total | 115 |

| consumer.sendIdleHeartbeat() | consumer.go:5222 | PORTED | PushConsumerEngine.SendIdleHeartbeatCallback() | Includes stall header and pending counts | | consumer.ackReply() | consumer.go:5234 | MISSING | — | Formats $JS.ACK.{stream}.{consumer}.{dc}.{sseq}.{dseq}.{ts}.{pending} reply subject | | consumer.setMaxPendingBytes() | consumer.go:5239 | MISSING | — | Sets flow control byte limits; used in testing | | consumer.checkNumPending() | consumer.go:5252 | MISSING | — | Sanity-checks cached num pending against store state | | consumer.numPending() | consumer.go:5271 | MISSING | — | Returns cached pending count (npc clamped to 0) | | consumer.checkNumPendingOnEOF() | consumer.go:5281 | MISSING | — | Resets npc/npf when consumer has caught up to stream end | | consumer.streamNumPendingLocked() | consumer.go:5294 | MISSING | — | Acquires lock and delegates to streamNumPending | | consumer.streamNumPending() | consumer.go:5303 | MISSING | — | Forces recalculation of num pending from store | | consumer.calculateNumPending() | consumer.go:5319 | MISSING | — | Calculates num pending using NumPending/NumPendingMulti with filter awareness | | convertToHeadersOnly() | consumer.go:5336 | MISSING | — | Strips msg payload and replaces with Nats-Msg-Size header for HeadersOnly consumers | | consumer.deliverMsg() | consumer.go:5364 | PARTIAL | PushConsumerEngine.Enqueue() + RunDeliveryLoopAsync() | .NET enqueues frames and sends via loop; Go handles dseq tracking, pending tracking, flow control, replicated delivery, rate limiting, interest ack for AckNone | | consumer.replicateDeliveries() | consumer.go:5428 | NOT_APPLICABLE | — | Cluster-specific: checks if deliveries must be replicated before sending | | consumer.needFlowControl() | consumer.go:5432 | PARTIAL | PushConsumerEngine.IsFlowControlStalled | .NET tracks pending FC count; Go tracks pbytes vs maxpb threshold | | consumer.processFlowControl() | consumer.go:5448 | PARTIAL | PushConsumerEngine.AcknowledgeFlowControl() | .NET decrements count; Go also doubles maxpb (slow start ramp), updates pbytes accounting | | consumer.fcReply() | consumer.go:5476 | MISSING | — | Generates unique flow control reply subject: _FCR_.{stream}.{consumer}.{rand4} | | consumer.sendFlowControl() | consumer.go:5495 | PARTIAL | FC frame in PushConsumerEngine.RunDeliveryLoopAsync() | .NET sends FC frame; Go also tracks fcsz/fcid state |

| consumer.seqFromReply() | consumer.go:5770 | MISSING | — | Extracts delivery sequence from ack reply subject | | consumer.streamSeqFromReply() | consumer.go:5776 | MISSING | — | Extracts stream sequence from ack reply subject | | parseAckReplyNum() | consumer.go:5782 | MISSING | — | Fast ASCII digit parser for ack reply tokens | | replyInfo() | consumer.go:5798 | MISSING | — | Parses all 5 fields from $JS.ACK.{stream}.{consumer}.{dc}.{sseq}.{dseq}.{ts}.{pending} | | ackReplyInfo() | consumer.go:5821 | MISSING | — | Parses sseq, dseq, dc from ack reply subject |

| Status | Count | | PORTED | 31 | | PARTIAL | 28 | | MISSING | 37 | | NOT_APPLICABLE | 9 | | DEFERRED | 0 | | Total | 105 |

| Status | MemStore | FileStore (1-4000) | Total | | PORTED | 33 | 4 | 37 | | PARTIAL | 11 | 16 | 27 | | MISSING | 36 | 35 | 71 | | NOT_APPLICABLE | 1 | 4 | 5 | | DEFERRED | 0 | 0 | 0 | | Total | 81 | 59 | 140 |

| Status | Count | | PORTED | 14 | | PARTIAL | 27 | | MISSING | 37 | | NOT_APPLICABLE | 2 | | Total | 80 |

| Status | Count | | PORTED | 26 | | PARTIAL | 19 | | MISSING | 32 | | NOT_APPLICABLE | 5 | | DEFERRED | 0 | | Total | 82 |

| fs.ConsumerStore(name, created, cfg) | filestore.go:11379 | PARTIAL | FileStore.ConsumerStore(name, created, cfg) | .NET creates ConsumerFileStore with state file; Go also handles encryption key setup, meta file writing, cipher conversion, memory-storage override |

| Status | Count | | PORTED | 22 | | PARTIAL | 23 | | MISSING | 24 | | NOT_APPLICABLE | 4 | | Total | 73 |

| Status | Count | | PORTED | 0 | | PARTIAL | 0 | | MISSING | 33 | | NOT_APPLICABLE | 0 | | Total | 33 |

| Status | Count | | PORTED | 22 | | PARTIAL | 23 | | MISSING | 57 | | NOT_APPLICABLE | 4 | | Total | 106 |

| monitorCluster() | :1455-1825 | PARTIAL | JetStreamClusterMonitor.StartAsync() in Cluster/JetStreamClusterMonitor.cs | .NET has basic channel-reading entry dispatch loop. Missing: compact/snapshot timer, leader check timer, health check timer, recovery state machine, snapshot scheduling (sync/async), leader change processing, cluster size checks, cold-boot mixed-mode adjustment |

| waitOnConsumerAssignments() | :2842-2892 | MISSING | — | Waits for consumer assignments before proceeding (interest retention) | | monitorStream() | :2895-3506 | PARTIAL | StreamReplicaGroup in Cluster/StreamReplicaGroup.cs | .NET has a simplified stream replica group model with election, propose, apply, snapshot. Missing: the full monitor loop (apply queue, leader change, compact timer, migration monitoring, direct access monitoring, interest state check, restore handling, scale-down logic, catchup error handling, resetClusteredState integration) |

| applyStreamEntries() | :3643-4000+ | PARTIAL | StreamReplicaGroup.ApplyCommittedEntriesAsync() in StreamReplicaGroup.cs:228-269 | .NET dispatches on string-based command prefixes (smsg:, centry:, +peer:, -peer:). Go dispatches on binary entryOp. Missing: full batchMsgOp/batchCommitMsgOp batch apply logic, deleteMsgOp with erase/remove, purgeStreamOp with request replay, EntrySnapshot with StreamReplicatedState, EntryRemovePeer processing, recovering-aware error handling, resetClusteredState on error |

| jsClusteredStreamRequest() | :7620+ (referenced) | PORTED | ClusteredRequestProcessor in Api/ClusteredRequestProcessor.cs | Channel-per-request pattern using TaskCompletionSource; register, wait, deliver, cancel-all |

| Status | Count | | PORTED | 25 | | PARTIAL | 14 | | MISSING | 48 | | NOT_APPLICABLE | 4 | | DEFERRED | 0 | | Total | 91 |

| stream.skipBatchIfRecovering | 4034-4066 | MISSING | -- | Batch recovery skip logic for stream RAFT apply; requires real RAFT + stream integration | | jetStream.applyStreamMsgOp | 4068-4242 | PARTIAL | StreamReplicaGroup.ApplyStreamMsgOp | .NET has simplified Store/Remove/Purge enum but lacks S2 decompression, flow-control reply, lastSeq mismatch retry, inflight/counter tracking, preAck clearing | | Server.replicas | 4246-4259 | MISSING | -- | Converts RAFT node peers to external PeerInfo with lag/active time | | jetStream.processStreamLeaderChange | 4262-4365 | PARTIAL | JetStreamMetaGroup.ProcessLeaderChange | .NET has leader change event + inflight clearing but no dedupe-ID clearing, inflight map clearing, advisory sending, stream setLeader, or API response to client | | stream.shouldSendLostQuorum | 4371-4379 | MISSING | -- | Throttled quorum-loss advisory gate | | Server.sendStreamLostQuorumAdvisory | 4381-4414 | MISSING | -- | Stream lost-quorum advisory publication | | Server.sendStreamLeaderElectAdvisory | 4416-4444 | MISSING | -- | Stream leader-elected advisory publication | | jetStream.streamAssignment (lookup) | 4448-4458 | PORTED | JetStreamMetaGroup.GetStreamAssignment | Direct lookup by account+stream | | jetStream.streamAssignmentOrInflight | 4462-4481 | PARTIAL | JetStreamMetaGroup.IsStreamInflight + GetStreamAssignment | Separate methods exist but no single combined lookup that returns the SA from inflight | | jetStream.streamAssignmentsOrInflightSeq | 4485-4507 | MISSING | -- | Iterator over all stream assignments (applied + inflight) for an account | | jetStream.streamAssignmentsOrInflightSeqAllAccounts | 4511-4538 | MISSING | -- | Iterator over all stream assignments across all accounts | | jetStream.processStreamAssignment | 4540-4647 | PARTIAL | JetStreamMetaGroup.ProcessStreamAssignment | .NET validates and adds assignment but lacks account lookup, stream creation dispatch, raft group node transfer, unsupported stream detection, syncSubject bug check | | jetStream.processUpdateStreamAssignment | 4650-4763 | PARTIAL | JetStreamMetaGroup.ProcessUpdateStreamAssignment | .NET updates config but lacks member check, raft node transfer, stream removal on non-member, unsupported handling | | Server.removeStream | 4767-4794 | MISSING | -- | Removes stream from non-member server (stepdown, node delete, monitor quit, stop) | | jetStream.processClusterUpdateStream | 4798-4940 | MISSING | -- | Full cluster stream update with scaling up/down, raft group creation, monitor start/stop, advisory response | | jetStream.processClusterCreateStream | 4944-5213 | MISSING | -- | Full cluster stream create with raft group, monitor goroutine, restore handling, single-replica path | | jetStream.processStreamRemoval | 5216-5264 | PARTIAL | JetStreamMetaGroup.ProcessStreamRemoval / JetStreamClusterMonitor.ProcessStreamRemoval | .NET removes assignment from meta state; lacks account lookup, created-time check, file cleanup | | jetStream.processClusterDeleteStream | 5266-5360 | MISSING | -- | Full stream deletion: raft node delete, monitor shutdown, file cleanup, response sending | | jetStream.processConsumerAssignment | 5362-5541 | PARTIAL | JetStreamMetaGroup.ProcessConsumerAssignment | .NET validates and adds to meta state; lacks member check, raft group transfer, state capture, unsupported handling, non-member removal with stepdown | | jetStream.processConsumerRemoval | 5543-5590 | PARTIAL | JetStreamMetaGroup.ProcessConsumerRemoval | .NET removes from meta state; lacks account lookup, created-time check, disk cleanup dispatch | | consumerAssignmentResult (struct) | 5592-5597 | MISSING | -- | Result struct for consumer assignment error forwarding | | jetStream.processClusterCreateConsumer | 5600-5854 | MISSING | -- | Full consumer create: raft group, add/update consumer, scale-down handling, monitor start, snapshot send, config update response | | jetStream.processClusterDeleteConsumer | 5856-5922 | MISSING | -- | Full consumer deletion: stop consumer, node delete, file cleanup, response | | jetStream.consumerAssignment (lookup) | 5926-5931 | PORTED | JetStreamMetaGroup.GetConsumerAssignment | Lookup by account/stream/consumer | | jetStream.consumerAssignmentOrInflight | 5935-5955 | PARTIAL | JetStreamMetaGroup.IsConsumerInflight + GetConsumerAssignment | Separate methods but no combined lookup returning the CA from inflight | | jetStream.consumerAssignmentsOrInflightSeq | 5959-5986 | MISSING | -- | Iterator over consumer assignments (applied + inflight) for account/stream | | jsAccount.consumerAssigned | 5989-5999 | MISSING | -- | Checks if this server has a consumer assigned | | jetStreamCluster.isConsumerAssigned | 6003-6025 | MISSING | -- | Checks consumer membership in cluster | | consumer.streamAndNode | 6028-6035 | NOT_APPLICABLE | -- | Go-specific accessor for consumer's stream + raft node | | consumer.replica | 6039-6049 | NOT_APPLICABLE | -- | Go-specific replica count getter | | consumer.raftGroup | 6051-6061 | NOT_APPLICABLE | -- | Go-specific raft group accessor | | consumer.clearRaftNode | 6063-6070 | NOT_APPLICABLE | -- | Go-specific raft node clear | | consumer.raftNode | 6072-6079 | NOT_APPLICABLE | -- | Go-specific raft node accessor | | jetStream.monitorConsumer | 6081-6349 | MISSING | -- | Consumer RAFT monitor loop: apply entries, leader change, snapshot, migration monitoring, compaction | | jetStream.applyConsumerEntries | 6351-6531 | PARTIAL | StreamReplicaGroup.ApplyConsumerEntry | .NET has simplified Ack/Nak/Deliver/Term/Progress enum tracking but lacks full op decoding (updateDeliveredOp, updateAcksOp, updateSkipOp, resetSeqOp, addPendingRequest, removePendingRequest), snapshot application, peer removal | | consumer.processReplicatedAck | 6535-6585 | MISSING | -- | Full replicated ack processing with AckAll gap handling, retention policy | | decodeAckUpdate | 6590-6600 | MISSING | -- | Binary uvarint decoder for ack updates | | decodeDeliveredUpdate | 6602-6620 | MISSING | -- | Binary uvarint/varint decoder for delivered updates | | jetStream.processConsumerLeaderChange | 6622-6698 | MISSING | -- | Consumer leader change: advisory, setLeader, API response, pause advisory | | consumer.shouldSendLostQuorum | 6701-6709 | MISSING | -- | Throttled consumer quorum-loss advisory gate | | Server.sendConsumerLostQuorumAdvisory | 6711-6745 | MISSING | -- | Consumer lost-quorum advisory publication | | Server.sendConsumerLeaderElectAdvisory | 6747-6777 | MISSING | -- | Consumer leader-elected advisory publication | | streamAssignmentResult (struct) | 6779-6785 | MISSING | -- | Result struct for stream assignment error forwarding | | isInsufficientResourcesErr | 6788-6790 | MISSING | -- | Error classification helper | | jetStream.processStreamAssignmentResults | 6794-6870 | MISSING | -- | Stream assignment error result processing with retry across clusters | | jetStream.processConsumerAssignmentResults | 6872-6906 | MISSING | -- | Consumer assignment error result processing | | streamAssignmentSubj / consumerAssignmentSubj (consts) | 6908-6911 | MISSING | -- | System subject constants for assignment results | | jetStream.startUpdatesSub | 6914-6937 | MISSING | -- | Subscribe to system subjects for assignment results, stepdown, peer remove, stream move | | jetStream.stopUpdatesSub | 6940-6970 | MISSING | -- | Unsubscribe from system subjects | | Server.sendDomainLeaderElectAdvisory | 6972-6999 | MISSING | -- | Domain leader-elected advisory publication | | jetStream.processLeaderChange (meta) | 7001-7074 | PARTIAL | JetStreamMetaGroup.ProcessLeaderChange | .NET clears inflight and fires event; lacks server atomic update, startUpdatesSub/stopUpdatesSub, observer stepdown, streamsCheck fix | | jetStreamCluster.remapStreamAssignment | 7077-7111 | PORTED | JetStreamMetaGroup.RemapStreamAssignment | .NET implements retain/replace/shrink logic | | selectPeerError (struct + methods) | 7113-7207 | MISSING | -- | Detailed peer-selection error reporting with tag/storage/offline reasons | | jetStreamCluster.selectPeerGroup | 7212-7507 | PARTIAL | PlacementEngine.SelectPeerGroup | .NET has tag filtering, cluster affinity, unique-tag, HA limit, weighted scoring; lacks per-peer storage availability check against MaxBytes, peerStreams/peerHA counting from live assignments, quorum check for online peers, detailed error reporting | | groupNameForStream | 7509-7511 | MISSING | -- | Stream raft group name generator with hash | | groupNameForConsumer | 7513-7515 | MISSING | -- | Consumer raft group name generator with hash | | groupName | 7517-7520 | MISSING | -- | Group name helper: prefix-R{n}{storage}-{hash} | | jetStream.tieredStreamAndReservationCount | 7524-7543 | MISSING | -- | Account-tier stream count + storage reservation tracking | | jetStream.createGroupForStream | 7547-7576 | MISSING | -- | Creates raft group for new stream with multi-cluster fallback | | Account.selectLimits | 7578-7596 | MISSING | -- | Selects account tier limits by replica count | | jetStream.jsClusteredStreamLimitsCheck | 7599-7618 | MISSING | -- | Pre-proposal stream limits validation (max streams, account limits) | | Server.jsClusteredStreamRequest | 7620-7701 | PARTIAL | ClusteredRequestProcessor | .NET has request-id correlation + timeout pattern; lacks full stream config validation, subject overlap check, placement + group creation, meta propose | | sysRequest[T] | 7710-7755 | MISSING | -- | Generic blocking system-account request utility | | Server.jsClusteredStreamUpdateRequest | 7757-8000+ | MISSING | -- | Full clustered stream update: config validation, move request handling, replica scaling, consumer remapping | | lostQuorumAdvInterval (const) | 4368 | MISSING | -- | 10-second throttle interval for quorum-loss advisories |

| Status | Count | | PORTED | 4 | | PARTIAL | 14 | | MISSING | 38 | | NOT_APPLICABLE | 5 | | Total | 61 |

| Status | Count | | PORTED | 8 | | PARTIAL | 13 | | MISSING | 56 | | NOT_APPLICABLE | 0 | | DEFERRED | 0 | | Total | 77 |

Change Log

Date	Change	By
2026-02-25	JS-2a: store.go full + stream.go lines 1-4000. 172 symbols. PORTED:55 PARTIAL:30 MISSING:75 NA:12	opus
2026-02-25	JS-2b: stream.go lines 4001-end. 116 symbols. PORTED:11 PARTIAL:24 MISSING:73 NA:8	opus
2026-02-25	JS-3a: consumer.go lines 1-3500. 115 symbols. PORTED:23 PARTIAL:21 MISSING:70 NA:1	opus
2026-02-25	JS-3b: consumer.go lines 3501-end. 105 symbols. PORTED:31 PARTIAL:28 MISSING:37 NA:9	opus
2026-02-25	JS-4a: memstore + filestore 1-4000. 140 symbols. PORTED:37 PARTIAL:27 MISSING:71 NA:5	opus
2026-02-25	JS-4b: filestore 4001-7000. 80 symbols. PORTED:14 PARTIAL:27 MISSING:37 NA:2	opus
2026-02-25	JS-4c: filestore 7001-10000. 82 symbols. PORTED:26 PARTIAL:19 MISSING:32 NA:5	opus
2026-02-25	JS-4d: filestore 10001-end + dirstore. 106 symbols. PORTED:22 PARTIAL:23 MISSING:57 NA:4	opus
2026-02-25	JS-5a: jetstream_cluster.go lines 1-4000. 91 symbols. PORTED:25 PARTIAL:14 MISSING:48 NA:4	opus
2026-02-25	JS-5b: jetstream_cluster.go lines 4001-8000. 61 symbols. PORTED:4 PARTIAL:14 MISSING:38 NA:5	opus
2026-02-25	JS-5c: jetstream_cluster.go lines 8001-end. 77 symbols. PORTED:8 PARTIAL:13 MISSING:56	opus
2026-02-25	File created with LLM analysis instructions	auto
2026-02-25	JS-1 Core sub-pass: analyzed jetstream.go, jetstream_api.go, jetstream_events.go, jetstream_errors.go, jetstream_versioning.go, jetstream_batching.go. 150+ symbols inventoried.	opus
2026-02-25	JS core config parity batch: added JetStream default constants (`JetStreamStoreDir`, max store/mem defaults) and server accessors (`JetStreamEnabled`, `JetStreamConfig`, `StoreDir`) with focused tests	codex
2026-02-26	JS config/model parity batch: extended `JetStreamOptions` (sync/compress/strict/unique-tag and account-limit fields), added parser support for extended jetstream config keys, and added core parity models (`JetStreamStats`, `JetStreamApiStats`, `JetStreamAccountLimits`, `JetStreamTier`) with focused tests	codex

228 KiB Raw Permalink Blame History Unescape Escape