gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-17 03:24:40 -07:00
Code Issues Packages Projects Releases Wiki Activity
6,412 Commits 30 Branches 48 Tags
ff23c217ea5ac288fc4312aba013254d310b4310
Commit Graph

6412 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Neil Alexander
ff23c217ea Add missing RUnlock in needAck 2022-10-14 11:54:06 +01:00
Ivan Kozlovic
11cc165c11 Merge pull request #3552 from nats-io/fix_3547 
[FIXED] MQTT: Subjects mapping were not handled
 2022-10-13 16:30:57 -06:00
Ivan Kozlovic
dde94987ce [FIXED] MQTT: Subjects mapping were not handled 
A simple configuration like this:
```
...
mappings = {
  foo: bar
}

mqtt {
   port: 1883
}
```
would cause an MQTT subscription on "bar" to not receive messages
published on "foo".

In otherwords, the subject transformation was not done when parsing
a PUBLISH packet.

This PR also handles the case of service imports where transformation
occurs after the initial publish parsing.

Resolves #3547

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-10-13 16:00:05 -06:00
Derek Collison
3269c506a8 Merge pull request #3544 from nats-io/readme-logo 
Updates to README
 2022-10-11 10:03:17 +09:00
Derek Collison
8415f609d7 Updated logo for better aesthetics on dark mode. 
Also added in Rethink overview video.

Signed-off-by: Derek Collison <derek@nats.io>
 2022-10-11 09:56:47 +09:00
Ivan Kozlovic
04c4cce4e9 Merge pull request #3543 from nats-io/fix_flappers_update_cov_go 
Fix some flappers and update Go version for nightly code coverage
 2022-10-10 17:28:22 -06:00
Ivan Kozlovic
a98af54d92 Fix some flappers and update Go version for nightly code coverage 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-10-10 16:42:43 -06:00
Ivan Kozlovic
ccfc818e8b Bump version to v2.9.4-beta as per release instructions 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-10-10 15:44:44 -06:00
Ivan Kozlovic
25e82d7d99 Merge pull request #3542 from nats-io/release_2_9_3 
Release v2.9.3
 2022-10-10 14:59:55 -06:00
Ivan Kozlovic
096b82271e Release v2.9.3 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-10-10 14:52:49 -06:00
Ivan Kozlovic
09b9bf272a Merge pull request #3541 from nats-io/warn_slow_icb 
Added warning if internal sub callback takes too long
 2022-10-10 14:52:25 -06:00
Ivan Kozlovic
3358247e6b Added warning if internal sub callback takes too long 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-10-10 14:39:37 -06:00
Ivan Kozlovic
ffc1797867 Merge pull request #3537 from nats-io/js_cons_name 
[FIXED] JetStream: User-defined ephemeral Name not used in cluster mode
 2022-10-10 14:01:47 -06:00
Ivan Kozlovic
9bd11580e3 [FIXED] JetStream: User-defined ephemeral Name not used in cluster mode 
If the user sends a CONSUMER.CREATE request with a configuration that
specifies the name that the user wants for the ephemeral consumer,
this would not work on cluster mode, that is, the server would still
pick a name instead of using the provided one.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-10-10 13:48:38 -06:00
Ivan Kozlovic
e42260cc80 Merge pull request #3539 from nats-io/js_handle_bad_replicas_count 
[FIXED] JetStream: return error on negative replicas count
 2022-10-10 13:44:34 -06:00
Ivan Kozlovic
cf71adb9de Merge pull request #3538 from nats-io/fix_import_own_export 
[FIXED] Stack overflow when account imports its own export
 2022-10-10 13:34:30 -06:00
Ivan Kozlovic
c3adf78702 [FIXED] Stack overflow when account imports its own export 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-10-10 13:20:26 -06:00
Ivan Kozlovic
3c7aa554f7 [FIXED] JetStream: return error on negative replicas count 
If a stream is created or updated with a negative replicas count,
and error is now returned. Same for consumers.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-10-10 12:32:41 -06:00
Ivan Kozlovic
d9bf82bbda Merge pull request #3536 from nats-io/fix_main_help 
Adjust "nats-server -h" output
 2022-10-10 12:28:43 -06:00
Ivan Kozlovic
1a278f9066 Adjust "nats-server -h" output 
Related to PR #3527

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-10-10 11:21:22 -06:00
Ivan Kozlovic
0fd2649f79 Merge pull request #3527 from ariel-zilber/patch-1 
Fix to issues  #3524 and #3521
 2022-10-10 11:01:20 -06:00
Derek Collison
cb086bcef9 Merge pull request #3530 from nats-io/dc 
Test to make sure a consumer that is deleted while a server is down recovers correctly.
 2022-10-07 17:38:42 +01:00
Derek Collison
c88784dcad Test to make sure a consumer that is deleted while a server is down recovers correctly. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-10-07 09:24:54 -07:00
Ivan Kozlovic
207195c66c Merge pull request #3529 from nats-io/js_fix_fs_filtered_purge 
[FIXED] JetStream: Purge with additional options may leave some messages
 2022-10-06 17:01:38 -06:00
Ivan Kozlovic
57a3594355 [FIXED] JetStream: Purge with additional options may leave some messages 
While going over message blocks, when some blocks were removed there
was a risk that a block is ignored, leaving some messages around.

Resolves #3528

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-10-06 13:21:20 -06:00
ariel-zilber
8fd30ff5c3 Update main.go 2022-10-06 12:40:21 +03:00
Ivan Kozlovic
b7a5163d5d Merge pull request #3523 from ariel-zilber/main 
fix to  bug  #3522 - update usage guide message in main.go
 2022-10-05 09:45:47 -06:00
ariel-zilber
6ef5c520b2 Update main.go 2022-10-05 18:30:52 +03:00
ariel-zilber
04a5c0be3c fix to bug #3522 - update usage guide message in main.go 2022-10-05 17:14:41 +03:00
Ivan Kozlovic
37ca972251 Bump version to 2.9.3-beta.1 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-10-05 07:14:01 -06:00
Ivan Kozlovic
348b3d4068 Merge pull request #3519 from nats-io/fix_3516 
[FIXED] JetStream: unresponsiveness while creating raft group
 2022-10-05 07:12:27 -06:00
Ivan Kozlovic
3472f6aec2 [FIXED] JetStream: unresponsiveness while creating raft group 
Originally, createRaftGroup() would not hold the jetstream's lock
for the whole duration. But some race reports made us change
this function to keep the lock for the whole duration. A test
called TestJetStreamClusterRaceOnRAFTCreate() was demonstrating
the race between "consumer info" request handling and createRaftGroup
code. Since then, the race has been fixed, so this PR restores
the more fine-grained locking inside createRaftGroup.

Resolves #3516

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-10-04 17:27:36 -06:00
Ivan Kozlovic
9f4513c9f7 Bump version to v2.9.3-beta as part of release process 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-09-30 10:27:58 -06:00
Ivan Kozlovic
6d81dde81b Merge pull request #3513 from nats-io/release_2_9_2 
Release v2.9.2
 2022-09-29 15:23:16 -06:00
Ivan Kozlovic
34851bfeae Release v2.9.2 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-09-29 15:21:53 -06:00
Ivan Kozlovic
521bfd287a Merge pull request #3512 from nats-io/update_deps 
[UPDATED] Dependencies
 2022-09-29 15:21:04 -06:00
Ivan Kozlovic
1039df088c [UPDATED] Dependencies 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-09-29 15:00:44 -06:00
Ivan Kozlovic
9cd2b7fa70 Merge pull request #3511 from nats-io/js_last_per_subject_redeliveries 
[FIXED] JetStream: redeliveries for LastPerSubject delivery policy
 2022-09-29 14:39:13 -06:00
Ivan Kozlovic
46aec649e4 [FIXED] JetStream: redeliveries for LastPerSubject delivery policy 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-09-29 14:00:18 -06:00
Ivan Kozlovic
0841786d6c Bump to 2.9.2-beta.1 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-09-29 09:26:09 -06:00
Ivan Kozlovic
44d4c1cbb5 Merge pull request #3508 from nats-io/meta-snap 
Allow meta layer to snapshot on a clean shutdown.
 2022-09-29 09:22:59 -06:00
Derek Collison
91edd1a8d0 With snapshots both streams are present on restart so sources or mirrors that have a subject change from the origin would not recover. 
We now suppress that if we know we are recovering an existing stream.

Signed-off-by: Derek Collison <derek@nats.io>
 2022-09-29 09:17:15 -06:00
Derek Collison
52b5cd12bb Allow meta layer to snapshot on a clean shutdown. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-09-29 09:17:12 -06:00
Derek Collison
0d14ec200f Merge pull request #3510 from nats-io/consumer-names-paging-bug 
[FIXED] bug in consumer names paging, did not honor limits and returned duplicate results.
 2022-09-29 06:33:52 -07:00
Derek Collison
fef702a688 [FIXED] bug in consumer names paging, did not honor limits and returned duplicate results. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-09-29 06:14:00 -07:00
Ivan Kozlovic
98de9136ce Merge pull request #3504 from nats-io/fanout_perf 
[IMPROVED] Fan-out performance
 2022-09-28 09:33:10 -06:00
Ivan Kozlovic
8d9c57ad44 [IMPROVED] Fan-out performance 
There was an observed degradation (around 5%) for large fan out in
v2.9.0 compared to earlier release. This is because we added
accounting of the in/out messages for the account, which result
in 4 atomic operations, 2 for in and 2 for out, however, it means
that for a fan-out of say 100 matching subscriptions, it is now
2 + 2 * 100 = 202.

This PR rework how the stats accounting is done which removes
the regression and even boost a bit the numbers since we are
doing the server stats update as an aggregate too.

There are still degradation for queues and no-sub at all that
need to be looked at.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-09-27 19:43:32 -06:00
Ivan Kozlovic
8247ecbf20 Merge pull request #3502 from nats-io/fix_3493 
[FIXED] JetStream: Scale down of consumer to R1 would not get a response
 2022-09-27 15:33:38 -06:00
Ivan Kozlovic
c93c2648af Merge pull request #3501 from nats-io/js_filestore_mem 
[FIXED] JetStream: File store memory usage
 2022-09-27 10:10:49 -06:00
Ivan Kozlovic
e151cfcd57 [FIXED] JetStream: Scale down of consumer to R1 would not get a response 
Updating a consumer configuration from say R3 to R1 would work
but no response was received by the client sending the request.

Resolves #3493

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-09-27 10:02:31 -06:00