Commit Graph

  • 64b22011dc Better use of LoadAndStore based on review feedback Derek Collison 2023-04-02 14:50:22 -07:00
  • 1fb1efd748 Make sure to remove any inflight entries when done Derek Collison 2023-04-02 14:41:49 -07:00
  • e6447c982a Protect against concurrent creation of streams and consumers. Also make sure we have exited monotoring routines when doing resets for both streams and consumers. Derek Collison 2023-04-02 14:27:23 -07:00
  • f3cab83ccf Bump to 2.9.16-RC.3 Derek Collison 2023-04-02 04:24:21 -07:00
  • 48a5d270b2 Merge branch 'main' into dev Derek Collison 2023-04-02 04:23:52 -07:00
  • d62dbb7635 [FIXED] Concurrent map access for preAcks. (#4012) Derek Collison 2023-04-02 04:23:25 -07:00
  • 299d9b28a9 Add original message timestamp to republished message headers (#3933) Derek Collison 2023-04-02 04:05:53 -07:00
  • 58ca525b3b Process replicated ack regardless of store update. Delay but still stepdown Derek Collison 2023-04-02 03:35:37 -07:00
  • a8bd2793d5 Fix concurrent map bug on preAcks. Use monitor check for streams like consumers. Make sure to stop raft layer if exiting monitorConsumer early. Allow consumers to force a snapshot on leadership change. Derek Collison 2023-04-02 02:45:24 -07:00
  • 874b2b2e02 Hold the lock while checking health since we could update catchup state. Do not stepdown right away when executing leadership transfer, wait for the commit. Derek Collison 2023-04-02 02:43:03 -07:00
  • b5358fa4b3 Wait for shutdown and sleep to let state build up Derek Collison 2023-04-02 02:41:09 -07:00
  • b752b8b30d Snapshot on clean shutdown if needed or interest based retention Derek Collison 2023-04-02 02:39:27 -07:00
  • e54019f87f All should be lowercase Derek Collison 2023-04-02 01:23:11 -07:00
  • 872a9e7927 Add in monitor status similar to consumer Derek Collison 2023-04-02 01:22:38 -07:00
  • df4982948c Gate remove calls, disqualify delivered and ack updates quicker Derek Collison 2023-04-02 01:19:59 -07:00
  • 4b8229ee42 Do not hold js lock for health check, use healthy not current for meta Derek Collison 2023-04-02 01:09:10 -07:00
  • e2839e9ec1 Fix for flapper Derek Collison 2023-04-02 01:09:02 -07:00
  • 11d88ef157 Implement comments Jean-Noël Moyne 2023-04-01 12:24:54 -07:00
  • b454a577e4 Removes the check on the republish filter needing to have an overlap with the listened subjects, as with the new stream subject transformation changes we do not assume anymore that the subjects in a stream must match the subjects being listened to. Jean-Noël Moyne 2023-03-31 16:10:23 -07:00
  • ac96d75c9c Fix bug in needAck (#4008) Derek Collison 2023-03-31 15:56:33 -07:00
  • 0420c6e317 - Improve and fix stream source consumer sequence number finding on leadership change or stream config update to work with the new stream sourcing - Updates source index name format and adds two fields (source's filter and transform) to the "Nats-Stream-Source" message header - Backwards compatibility for streams containing previous (2.9) message headers for seamless upgrade - Update TestJetStreamSourceBasics as it could flap sometimes Jean-Noël Moyne 2023-03-31 15:49:10 -07:00
  • 93c49c354e Fix bug in needAck Tomasz Pietrek 2023-03-31 22:36:29 +02:00
  • d057889b13 Merge branch 'main' into dev Derek Collison 2023-03-31 11:36:35 -07:00
  • fbaeaf905f Updates to preacks when multiple consumers are mutually exclusive (#4007) Derek Collison 2023-03-31 11:35:29 -07:00
  • ad5bb366a0 Updates to preacks when multiple consumers are present but mutually exlusive (filtered). Derek Collison 2023-03-31 10:43:28 -07:00
  • c194047caf Bump to 2.9.16-RC.2 Derek Collison 2023-03-30 21:23:51 -07:00
  • 6ced966776 Merge branch 'main' into dev Derek Collison 2023-03-30 21:09:45 -07:00
  • 5e85889790 [IMPROVED] Improvements to preAcks. (#4006) Derek Collison 2023-03-30 21:08:34 -07:00
  • 8c0a45edf9 Make sure to lock on clearing if not removing. Derek Collison 2023-03-30 20:42:28 -07:00
  • 937ef0d2a6 Improvements to preAcks. Derek Collison 2023-03-30 20:29:15 -07:00
  • db599ac875 Merge branch 'main' into dev Ivan Kozlovic 2023-03-30 15:45:51 -06:00
  • 7862881351 Fixed some tests (#4005) Ivan Kozlovic 2023-03-30 15:45:16 -06:00
  • a4df4f8727 Fixed some tests Ivan Kozlovic 2023-03-26 15:01:11 -06:00
  • 3e2e2bfad9 Merge branch 'main' into dev Derek Collison 2023-03-29 20:34:33 -07:00
  • 5359d2323a [FIXED] Do not allow JetStream leaders to be placed on a lameduck server. (#4002) Derek Collison 2023-03-29 20:32:44 -07:00
  • 4646f4af5d Do not allow any JetStream leaders to be placed on a lameduck server Derek Collison 2023-03-29 20:15:41 -07:00
  • 873ab0f6b9 Fix for flapping test Derek Collison 2023-03-29 18:55:41 -07:00
  • fbc90adf93 Bump to 2.9.16-RC.1 Derek Collison 2023-03-29 17:21:57 -07:00
  • cba0976926 Bump to 2.10.0-beta.30 Derek Collison 2023-03-29 17:20:53 -07:00
  • 625ffa8685 Merge branch 'main' into dev Derek Collison 2023-03-29 17:19:45 -07:00
  • 02702e4620 [IMPROVEMENT] General stability and bug fixes. (#3999) Derek Collison 2023-03-29 17:09:44 -07:00
  • c546828359 Moved log running test to NoRace suite Derek Collison 2023-03-29 16:56:04 -07:00
  • ade0e9d295 Snapshot meta for this function to use in case it gets removed out from underneath of us. Derek Collison 2023-03-29 16:51:17 -07:00
  • 9a714e7d7d Update based on review feedback Derek Collison 2023-03-29 15:47:54 -07:00
  • 152b25c314 Update server/stream.go Derek Collison 2023-03-29 15:29:51 -07:00
  • c77872b519 Update server/jetstream_cluster.go Derek Collison 2023-03-29 15:29:38 -07:00
  • 2b89fea9b0 Double check here if the jetstream cluster was shutdown when we released the lock Derek Collison 2023-03-29 14:46:49 -07:00
  • e274693490 On bad or corrupt message load during commit, reset WAL vs mark write error Derek Collison 2023-03-29 14:07:14 -07:00
  • 6c3e64b83b Always make sure cluster and meta raft node available when needed Derek Collison 2023-03-29 13:56:04 -07:00
  • ddfa5cdfec Additional protection for bad state when rebuilding a message block Derek Collison 2023-03-29 11:05:47 -07:00
  • a9a4df859f Fix for flapping test Derek Collison 2023-03-29 11:01:51 -07:00
  • 35d1a7747a Snapshots of no length can hold state as well Derek Collison 2023-03-29 07:59:41 -07:00
  • c4da37ecc7 Make sure consumer is valid and state was returned Derek Collison 2023-03-29 07:35:00 -07:00
  • e97ddcd14f Tweak tests due to changes, make test timeouts uniform. Derek Collison 2023-03-28 23:40:54 -07:00
  • 52fbac644c Since we no longer store leaderTransfers, which is proper, some tests were getting and advantage on that after server restart. This change speeds up raft layer more to avoid timeouts. Derek Collison 2023-03-28 23:07:38 -07:00
  • 0d9f707b4b Additional tests to stress interest based streams with pull subscribers during rolling restarts. Derek Collison 2023-03-28 21:50:49 -07:00
  • 71af150448 General improvements to interest based stream processing when acks arrive before the actual msgs. Derek Collison 2023-03-28 21:37:41 -07:00
  • 5cabc365df General improvements around handling interest retention. Derek Collison 2023-03-28 21:25:10 -07:00
  • e516c47a4b Improvements to consumers attached to an interest retention stream. Derek Collison 2023-03-28 21:16:04 -07:00
  • 182bf6cbae Bug fixes and general stability improvements. Derek Collison 2023-03-28 21:00:49 -07:00
  • 6d4304146f Bug fixes and general stability improvements. Derek Collison 2023-03-28 20:43:02 -07:00
  • 9cc66c0f32 Add vcsinfo when building with goreleaser (#3993) Waldemar Quevedo 2023-03-28 09:00:59 -07:00
  • 1281ca690c Remove gomod proxy, build by installing package instead Waldemar Quevedo 2023-03-28 08:16:33 -07:00
  • 7d22e853b9 Update goreleaser to include vcsinfo in nightly (#3995) Waldemar Quevedo 2023-03-27 15:09:43 -07:00
  • 41cd3b2124 Update goreleaser to include vcsinfo in nightly Waldemar Quevedo 2023-03-27 10:48:09 -07:00
  • f537b3e667 Use go mod proxy when building the release Waldemar Quevedo 2023-03-27 08:47:43 -07:00
  • 0033f3309b [FIX] referenced JWT constant for AnyAccount (#3988) Alberto Ricart 2023-03-24 15:23:34 -05:00
  • 7fe05aaea2 Merge branch 'main' into dev Derek Collison 2023-03-23 17:28:44 -07:00
  • 03c54750a4 [FEAT] allow callout account configuration to generate users for any account (#3987) Derek Collison 2023-03-23 17:28:22 -07:00
  • 30afb48c2a [FEAT] enable callout service to generate users for any account Alberto Ricart 2023-03-23 16:01:18 -05:00
  • 57daedafa8 Merge pull request #3986 from nats-io/neil/shutdownraftgroups Derek Collison 2023-03-23 11:09:35 -07:00
  • 8d5519356e Shut down RAFT groups when disabling JetStream Neil Twigg 2023-03-23 16:49:35 +00:00
  • 61556d90bd Merge pull request #3985 from nats-io/oor-raft Derek Collison 2023-03-23 08:39:15 -07:00
  • ec89823e1c Only process out of resources condition from raft layer if err matches condition Derek Collison 2023-03-23 08:13:22 -07:00
  • cec1e15c4b Merge pull request #3983 from nats-io/pre-acks-test Derek Collison 2023-03-21 13:16:09 -07:00
  • 9ccd7abdf8 Test for preAcks Derek Collison 2023-03-21 12:08:24 -07:00
  • 2eaede8b1d Merge branch 'main' into dev Derek Collison 2023-03-20 21:35:15 -07:00
  • 2551e6f6a8 Merge pull request #3981 from nats-io/f3-2 Derek Collison 2023-03-20 21:32:30 -07:00
  • ed9de4b0a1 Improved publisher performance under some instances of asymmetric network latency clusters on interest based streams. Derek Collison 2023-03-20 20:53:45 -07:00
  • 6dd0f5a660 Merge branch 'main' into dev Derek Collison 2023-03-19 11:55:45 -07:00
  • 3e0ce6e639 Merge pull request #3980 from nats-io/f3 Derek Collison 2023-03-19 11:55:26 -07:00
  • 0c1301ec14 Fix for data race Derek Collison 2023-03-19 10:52:52 -07:00
  • 5a16f98427 Fixed an off by one bug that under certain circumstances could cause large consumer replica states. This could lead to instability in the system. Derek Collison 2023-03-19 10:21:36 -07:00
  • 3e8e0ea44a Merge pull request #3979 from nats-io/cores-snap Derek Collison 2023-03-18 08:18:24 -07:00
  • 027f2e42c8 Remove snapshot of cores and maxprocs Derek Collison 2023-03-17 15:09:50 -07:00
  • 5e16b7c055 Merge branch 'main' into dev Derek Collison 2023-03-17 13:14:59 -07:00
  • f0e1585490 Fix flapping test Derek Collison 2023-03-17 13:14:43 -07:00
  • d8ad66756c Merge pull request #3864 from nats-io/simplify-authresponse Derek Collison 2023-03-17 11:33:44 -07:00
  • 5877f5558a Merge branch 'main' into dev Neil Twigg 2023-03-17 10:09:54 +00:00
  • 1cfb1b0c3c Merge pull request #3978 from nats-io/neil/encfix Neil 2023-03-17 09:42:19 +00:00
  • 4647e14b3e Don't recycle buffer more than once Neil Twigg 2023-03-17 09:25:17 +00:00
  • bb2627bf6b Merge branch 'dev' into simplify-authresponse Alberto Ricart 2023-03-16 17:30:20 -05:00
  • 52b023d993 bumped to latest version of jwt branch removed server_key as name/id are already the right values Alberto Ricart 2023-03-06 13:50:07 -06:00
  • 86f78b49a7 Merge branch 'main' into dev Derek Collison 2023-03-16 12:10:21 -07:00
  • 5c437a233a Merge pull request #3975 from nats-io/neil/encbuffer Neil 2023-03-16 18:09:51 +00:00
  • 9f99efad03 Use pooled buffer for flushing encrypted message blocks Neil Twigg 2023-03-16 17:39:26 +00:00
  • 33c0f8e613 Merge pull request #3972 from ripienaar/nightly_rc_docker.4 R.I.Pienaar 2023-03-16 12:25:23 +01:00
  • 447a174065 move dev nightly to same shared action R.I.Pienaar 2023-03-16 11:23:24 +01:00
  • 80d0adede4 Merge branch 'main' into dev Derek Collison 2023-03-15 20:26:13 -07:00
  • c4075ddac4 Merge pull request #3970 from nats-io/ackfloor-fseq Derek Collison 2023-03-15 20:25:33 -07:00