Files

T

History

zeekay 97cdcb9b2a pubsub: bump consensus, Corona→Corona field, fix raft

- Bump github.com/luxfi/consensus v1.22.84 → v1.25.17 (go mod tidy clean).
- Migrate internal/consensus to current quasar API: QuasarHybridConsensus→Quasar,
  HybridSignature→QuasarSig, NewQuasarHybridConsensus→NewQuasar,
  VerifyHybridSignature→VerifyQuasarSig. Signature field is .Corona (no Corona).
  Route threshold<2 (single-node/dev) to NewTestQuasar, >=2 to NewQuasar (BFT),
  matching upstream's two-constructor production-vs-test split.
- Repair botched upstream merge in server/: restore corrupted files from the
  upstream merge parent with Hanzo import paths preserved. Fixes RaftNodeCheckpoint
  redeclaration, undefined gsl/standalone/numLimitableConsumers, dropped consumer
  ack-format fields, resetStartingSeq arity, filestore IntersectGSL bool callbacks
  and fetchMsgNoCopyLocked, jetstream_cluster creatingRaftGroups/wca.State.

go build ./... green; internal tests pass.

2026-06-11 13:08:07 -07:00

ats

[FIXED] Parallel stream restore panic

2025-11-03 11:32:02 +01:00

avl

(2.14) [IMPROVED] Filestore error handling

2026-03-02 15:20:02 +01:00

certidp

Update copyright notices

2026-01-09 17:45:15 +00:00

certstore

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

configs

(2.14) Feature flags

2026-04-08 11:01:19 +02:00

elastic

Elastic pointers in the filestore write-through cache

2025-08-20 09:41:52 +01:00

gsl

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

pse

Split TestPSEmulation into memory and CPU tests

2025-09-04 13:52:37 +02:00

stree

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

sysmem

illumos build fix

2025-08-10 22:25:30 +09:00

thw

(2.14) [FIXED] Clear inflight on schedule removal

2026-04-21 12:12:02 +02:00

tpm

…

accounts_test.go

[FIXED] LDM results in max connections exceeded errors

2025-11-07 13:36:47 +01:00

accounts.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

auth_callout_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

auth_callout.go

Send JWT to auth callout from MQTT clients

2026-03-31 11:25:29 +01:00

auth_test.go

Fixed tests using DefaultTestOptions

2026-05-28 13:15:18 -06:00

auth.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

benchmark_publish_test.go

…

certstore_windows_test.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

ciphersuites.go

FIPS 140-3 mode support

2025-10-09 12:48:13 +01:00

client_proxyproto_test.go

[FIXED] PROXY protocol with required TLS listener

2026-05-11 15:30:58 -07:00

client_proxyproto.go

[FIXED] PROXY v1 parsing may discard client bytes

2026-03-17 16:19:55 +01:00

client_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

client.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

closed_conns_test.go

Fix hostport lint errors

2026-02-22 00:55:09 -08:00

config_check_test.go

(2.14) [ADDED] Config reload: add/remove remote leafnodes

2026-04-10 07:52:47 -06:00

const.go

Bump main branch to v2.15.0-dev

2026-04-30 13:02:29 +01:00

consumer.go

pubsub: bump consensus, Corona→Corona field, fix raft

2026-06-11 13:08:07 -07:00

core_benchmarks_test.go

deps: luxfi/zapdb v4 → v1.0.0 (module path reset)

2026-04-11 00:05:22 -07:00

cron.go

(2.14) [IMPROVED] Invalid schedule time zone returns a specific error

2026-04-29 15:43:18 +02:00

dirstore_test.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

dirstore.go

server: fix nil pointer dereference in DirJWTStore.Pack filepath.Walk callback

2026-05-17 13:50:46 -07:00

disk_avail_netbsd.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

disk_avail_openbsd.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

disk_avail_solaris.go

illumos build fix

2025-08-10 22:25:30 +09:00

disk_avail_wasm.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

disk_avail_windows.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

disk_avail.go

illumos build fix

2025-08-10 22:25:30 +09:00

errors_gen.go

deps: luxfi/zapdb v4 → v1.0.0 (module path reset)

2026-04-11 00:05:22 -07:00

errors_test.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

errors.go

[FIXED] Avoid stalling read loop on leafnode ErrMinimumVersionRequired (#7970 )

2026-03-19 15:17:25 +00:00

errors.json

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

events_test.go

add outClientMsgs and Bytes

2026-05-11 15:21:48 -07:00

events.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

feature_flags_test.go

(2.14) [IMPROVED] Feature flags: parse non-bool value

2026-04-22 14:00:19 +02:00

feature_flags.go

(2.14) [IMPROVED] Propose stream skip ranges as single deleteRangeOp

2026-04-28 18:28:56 +02:00

filestore_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

filestore.go

pubsub: bump consensus, Corona→Corona field, fix raft

2026-06-11 13:08:07 -07:00

gateway_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

gateway.go

Don't use sublist caches when disabled

2026-04-28 15:27:21 +01:00

ipqueue_test.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

ipqueue.go

Correct copyrights in .go files

2025-02-06 11:22:06 +00:00

jetstream_api.go

pubsub: bump consensus, Corona→Corona field, fix raft

2026-06-11 13:08:07 -07:00

jetstream_batching_test.go

(2.14) [FIXED] Don't allow purging schedule if not a schedule

2026-05-12 11:21:12 +02:00

jetstream_batching.go

(2.14) [FIXED] Don't allow purging schedule if not a schedule

2026-05-12 11:21:12 +02:00

jetstream_benchmark_test.go

deps: luxfi/zapdb v4 → v1.0.0 (module path reset)

2026-04-11 00:05:22 -07:00

jetstream_cluster_1_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

jetstream_cluster_2_test.go

[FIXED] Stream cannot re-materialize on peer when account is over-limit

2026-05-15 11:12:50 +02:00

jetstream_cluster_3_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

jetstream_cluster_4_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

jetstream_cluster_long_test.go

Optimise enforceMsgPerSubjectLimit

2025-05-08 14:41:05 +01:00

jetstream_cluster.go

pubsub: bump consensus, Corona→Corona field, fix raft

2026-06-11 13:08:07 -07:00

jetstream_consumer_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

jetstream_errors_generated.go

pubsub: bump consensus, Corona→Corona field, fix raft

2026-06-11 13:08:07 -07:00

jetstream_errors_test.go

…

jetstream_errors.go

…

jetstream_events.go

(2.12) [FIXED] Atomic batch 'unsupported' advisory

2026-04-28 16:31:39 +02:00

jetstream_helpers_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

jetstream_jwt_test.go

De-flake TestJetStreamJWTClusterAccountNRG

2026-05-26 11:58:10 +02:00

jetstream_leafnode_test.go

[FIXED] Source consumer reschedule storm on leafnode reconnect

2026-05-08 12:31:15 +02:00

jetstream_meta_benchmark_test.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

jetstream_sourcing_scaling_test.go

…

jetstream_super_cluster_test.go

(2.14) [FIXED] Cross-domain/account consumer acks and flow control

2026-04-08 11:28:37 +02:00

jetstream_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

jetstream_tpm_test.go

…

jetstream_versioning_test.go

(2.14) Support reliable WQ/Interest stream sourcing and mirroring

2026-04-14 09:32:02 +02:00

jetstream_versioning.go

pubsub: bump consensus, Corona→Corona field, fix raft

2026-06-11 13:08:07 -07:00

jetstream.go

pubsub: bump consensus, Corona→Corona field, fix raft

2026-06-11 13:08:07 -07:00

jwt_test.go

[FIXED] validateTimes mishandles time ranges that cross midnight

2026-04-27 17:22:37 +01:00

jwt.go

[FIXED] validateTimes mishandles time ranges that cross midnight

2026-04-27 17:22:37 +01:00

leafnode_proxy_test.go

[IMPROVED] Support HTTP proxy connection from leaf nodes also for TCP

2026-03-19 07:05:23 +01:00

leafnode_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

leafnode.go

Don't negotiate leafnode compression over WebSockets

2026-05-15 14:13:55 +01:00

log_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

log.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

memstore_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

memstore.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

monitor_sort_opts.go

Make sort by monitoring structs public

2025-12-11 16:28:03 -07:00

monitor_test.go

[FIXED] AccountStatz omits accounts with only leaf connections

2026-06-01 17:41:16 +02:00

monitor.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

mqtt_ex_bench_test.go

[IMPROVED] MQTT: Retained msgs handling with cross account and transform

2025-12-11 13:56:36 -07:00

mqtt_ex_test_test.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

mqtt_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

mqtt.go

MQTT: Return errMQTTUnsupportedCharacters for control characters on both sub and pub

2026-05-08 13:37:27 +01:00

msgtrace_test.go

Message tracing requires client publish permission for Nats-Trace-Dest

2026-03-24 12:20:26 +00:00

msgtrace.go

Message tracing requires client publish permission for Nats-Trace-Dest

2026-03-24 12:20:26 +00:00

nkey_test.go

…

nkey.go

(2.12) [ADDED] Trusted proxies support

2025-08-08 08:21:15 -06:00

norace_1_test.go

(2.14) [IMPROVED] Filestore error handling

2026-03-02 15:20:02 +01:00

norace_2_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

ocsp_peer.go

deps: luxfi/zapdb v4 → v1.0.0 (module path reset)

2026-04-11 00:05:22 -07:00

ocsp_responsecache.go

deps: luxfi/zapdb v4 → v1.0.0 (module path reset)

2026-04-11 00:05:22 -07:00

ocsp.go

deps: luxfi/zapdb v4 → v1.0.0 (module path reset)

2026-04-11 00:05:22 -07:00

opts_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

opts.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

parser_fuzz_test.go

Fix auth needed in leafnode compression handshakes

2026-04-14 14:48:14 +01:00

parser_test.go

[FIXED] Max control line for non-clients

2026-04-27 17:23:05 +01:00

parser.go

[FIXED] Max control line for non-clients

2026-04-27 17:23:05 +01:00

ping_test.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

proto.go

[FIXED] Panic on malformed fixed32/fixed64 fields

2026-03-11 17:39:54 +01:00

raft_benchmark_test.go

Add a benchmark for WriteTermVote

2026-05-18 09:40:54 +02:00

raft_chain_of_blocks_helpers_test.go

[IMPROVED] Eventually force snapshots if blocked due to catchups

2026-02-22 00:55:10 -08:00

raft_helpers_test.go

NRG: Fix cluster size drop to 1 on replaying EntryAddPeer after restart

2026-02-22 00:55:10 -08:00

raft_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

raft.go

pubsub: bump consensus, Corona→Corona field, fix raft

2026-06-11 13:08:07 -07:00

rate_counter_test.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

rate_counter.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

README-MQTT.md

Fixed spelling.

2025-05-21 19:11:12 -04:00

README.md

…

reload_test.go

Include Nkey in remote identity matching

2026-04-10 07:52:54 -06:00

reload.go

[FIXED] Gateway pinned_certs reload config logic inverted

2026-04-27 17:21:27 +01:00

ring_test.go

…

ring.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

route.go

[FIXED] Route interest subscription race

2026-05-26 10:54:34 +02:00

routes_test.go

[FIXED] Route interest subscription race

2026-05-26 10:54:34 +02:00

scheduler.go

pubsub: bump consensus, Corona→Corona field, fix raft

2026-06-11 13:08:07 -07:00

sdm.go

[IMPROVED] Don't load messages while looping through THW

2025-09-22 12:30:19 +02:00

sendq.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

server_fuzz_test.go

Fuzz tests minor improvements

2025-08-04 11:34:10 +03:00

server_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

server.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

service_test.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

service_windows_test.go

[FIXED] Windows Service: LameDuckMode doesn't exit the process

2026-03-16 19:31:40 -06:00

service_windows.go

[FIXED] Windows Service: LameDuckMode doesn't exit the process

2026-03-16 19:31:40 -06:00

service.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

signal_test.go

deps: luxfi/zapdb v4 → v1.0.0 (module path reset)

2026-04-11 00:05:22 -07:00

signal_wasm.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

signal_windows.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

signal.go

Print Trapped signal as Notice level message (#6800 )

2025-04-23 17:55:59 +01:00

split_test.go

[FIXED] Max control line for non-clients

2026-04-27 17:23:05 +01:00

store_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

store.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

stream.go

pubsub: bump consensus, Corona→Corona field, fix raft

2026-06-11 13:08:07 -07:00

subject_fuzz_test.go

Fuzz tests minor improvements

2025-08-04 11:34:10 +03:00

subject_transform_test.go

Fix validation and cases for non-wildcard sources

2025-07-08 10:34:24 +01:00

subject_transform.go

Reduce allocations in sublist and subject transforms

2025-11-06 09:55:28 +00:00

sublist_test.go

[IMPROVED] Use negative sublist cache resutls in numInterest

2026-05-11 11:13:25 +02:00

sublist.go

[IMPROVED] Use negative sublist cache resutls in numInterest

2026-05-11 11:13:25 +02:00

test_test.go

merge: upstream/main (preserve Hanzo brand, 753 commits)

2026-06-02 10:00:33 -07:00

trust_test.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

util_test.go

Correct copyrights in .go files

2025-06-04 10:18:55 +01:00

util.go

(2.14) [FIXED] Fast batch: parse batch seq as uint64

2026-05-01 10:13:46 +02:00

websocket_go125.go

Allow WebSockets on FIPS-enforced builds when built with Go 1.26 or later

2026-05-13 09:56:16 +01:00

websocket_go126.go

Allow WebSockets on FIPS-enforced builds when built with Go 1.26 or later

2026-05-13 09:56:16 +01:00

websocket_test.go

Fix potential pooled buffer reuse in compressed WebSocket connections

2026-05-29 09:54:40 +01:00

websocket.go

Fix potential pooled buffer reuse in compressed WebSocket connections

2026-05-29 09:54:40 +01:00

README.md

Tests

Tests that run on Travis have been split into jobs that run in their own VM in parallel. This reduces the overall running time but also is allowing recycling of a job when we get a flapper as opposed to have to recycle the whole test suite.

JetStream Tests

For JetStream tests, we need to observe a naming convention so that no tests are omitted when running on Travis.

The script runTestsOnTravis.sh will run a given job based on the definition found in ".travis.yml".

As for the naming convention:

All JetStream test name should start with TestJetStream
Cluster tests should go into jetstream_cluster_test.go and start with TestJetStreamCluster
Super-cluster tests should go into jetstream_super_cluster_test.go and start with TestJetStreamSuperCluster

Not following this convention means that some tests may not be executed on Travis.