gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-15 10:40:41 -07:00
Code Issues Packages Projects Releases Wiki Activity
5,070 Commits 30 Branches 48 Tags
f254c110c48ba421ed5a1f6900a9879e736b6eb2
Commit Graph

5070 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Derek Collison
f254c110c4 Ignore the 'not filtered' shortcut if deliver last policy is set 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-10-12 06:15:40 -07:00
Derek Collison
c789ad9211 Simplified a bit 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-10-12 06:12:56 -07:00
Ivan Kozlovic
3b9c358a81 Test that reproduces the issue reported in #2611 
Issue seem to be from the fact that the filter subject is == to
the stream's subjects list and so setInitialPendingAndStart()
considers that the consumer is not filtered.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2021-10-11 13:32:04 -06:00
Derek Collison
5e1276c27e Bump version 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-10-11 08:51:28 -07:00
Derek Collison
10a96b8b02 Merge pull request #2606 from nats-io/raft-enc-dec 
Added more robust checking for decoding append entries.
 2021-10-11 08:47:42 -07:00
Derek Collison
555d2211d0 Merge pull request #2610 from dtest11/fix_doc 
fix go doc: DenyRules
 2021-10-11 08:25:03 -07:00
dtest1
0937b848cd fix go doc: DenyRules 2021-10-11 23:19:56 +08:00
Derek Collison
1a4410a3f7 Added more robust checking for decoding append entries. 
Allow a buffer to be passed in to relive GC pressure.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-10-09 09:37:03 -07:00
Derek Collison
41a9d082f8 Merge pull request #2601 from nats-io/rollup-fix-2 
Don't make consumers go backwards on purge
 2021-10-07 07:23:33 -07:00
Derek Collison
9efa11ba43 Don't make consumers go backwards on purge 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-10-07 07:06:52 -07:00
R.I.Pienaar
4e885f0b08 Merge pull request #2600 from ripienaar/rollup_requires_purge 
error when a stream requesting rollups deny purge
 2021-10-07 14:49:39 +02:00
R.I.Pienaar
e73cddc2de error when a stream requesting rollups deny purge 
Signed-off-by: R.I.Pienaar <rip@devco.net>
 2021-10-07 14:07:10 +02:00
Ivan Kozlovic
208146aade Merge pull request #2598 from nats-io/fix_2587 
[IMPROVED] MQTT: add client id to client connection string
 2021-10-06 13:12:55 -06:00
Ivan Kozlovic
25647a1fda [IMPROVED] MQTT: add client id to client connection string 
This way, any log statement for a client will include the client id,
similar to how the server now logs information about NATS clients
(such as language, version, connection name).

Also adding a debug statement once the client has successfully connected.

Here is how this will look like for a client with client id "client_0".
```
[69591] 2021/10/06 10:06:50.837977 [DBG] [::1]:57415 - mid:18 - Client connection created
[69591] 2021/10/06 10:06:50.839871 [DBG] [::1]:57415 - mid:18 - "client_0" - Client connected
[69591] 2021/10/06 10:07:00.627307 [DBG] [::1]:57415 - mid:18 - "client_0" - Client connection closed: Client Closed
```
All log statements will be affected, for instance here is an auth error:
```
[69591] 2021/10/06 10:09:48.618964 [DBG] [::1]:57424 - mid:23 - Client connection created
[69591] 2021/10/06 10:09:48.619015 [ERR] [::1]:57424 - mid:23 - "client_0" - authentication error - User "mqtt"
[69591] 2021/10/06 10:09:48.619026 [DBG] [::1]:57424 - mid:23 - "client_0" - Client connection closed: Authentication Failure
[69591] 2021/10/06 10:09:48.619038 [ERR] [::1]:57424 - mid:23 - "client_0" - unable to connect: authentication error
```

Resolves #2587

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2021-10-06 10:59:50 -06:00
Derek Collison
3f12216fcc Merge pull request #2595 from nats-io/stream-perms 
In addition to sealed we add in other stream perms to control purge, msg deletes and rollups.
 2021-10-06 07:55:08 -07:00
Derek Collison
1b7e184c9e Update rollup based on feedback 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-10-06 07:18:46 -07:00
Derek Collison
bdbe3df97a Merge pull request #2596 from nats-io/consumer-no-payload 
Allow consumers to request only headers to be delivered
 2021-10-06 07:13:31 -07:00
Derek Collison
58e5c7c681 Allow consumers to request only headers to be delivered 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-10-05 18:54:52 -07:00
Derek Collison
aff0f62106 In addition to sealed we add in other stream perms to control purge, msg deletes and rollups. 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-10-05 17:43:24 -07:00
Derek Collison
5ff751af99 Merge pull request #2593 from nats-io/rollup-fix 
Fix for rollups and filtered purge
 2021-10-04 12:54:57 -07:00
Derek Collison
df2147bc7c Fix for rollups and filtered purge 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-10-04 10:01:36 -07:00
Ivan Kozlovic
74988e68f0 Merge pull request #2590 from nats-io/fix_2588 
[FIXED] JetStream: data race on shutdown
 2021-09-30 13:48:13 -06:00
Ivan Kozlovic
d34b8fdd7d [FIXED] JetStream: data race on shutdown 
Replaced use of eventsEnabled() with EventsEnabled() that will
check under server lock. Also found another reference when
creating templates.

Resolves #2588

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2021-09-30 11:17:12 -06:00
Derek Collison
c9eeab1d0d Merge pull request #2585 from nats-io/rollups 
Rollup functionality.
 2021-09-30 04:05:17 -07:00
Derek Collison
c062190b0a Rollup functionality. 
Messages published with the rollup header will place the new message onto the stream and purge all others based on subject, or the complete stream.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-09-29 18:59:21 -07:00
Derek Collison
1338a167e3 Merge pull request #2584 from nats-io/sealed-stream 
Allow streams to be sealed through a stream update.
 2021-09-29 16:02:58 -07:00
Derek Collison
5fc2cc5754 Allow streams to be sealed through a stream update. 
Sealed streams can not accept new messages, allow you to delete or purge messages, or have messages expire due to age.
Sealed stream can not be unsealed through an update.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-09-29 15:25:38 -07:00
R.I.Pienaar
38a853f0ff Merge pull request #2583 from ripienaar/fix_msg_get_audit 
fixes the msg get audit event
 2021-09-29 23:58:47 +02:00
R.I.Pienaar
98ef6cb03c fixes the msg get audit event 
We resused msg variable for both the request
and later the data loaded from the stream.

The data thus replaces the request and the audit
had the data as both request and response

Signed-off-by: R.I.Pienaar <rip@devco.net>
 2021-09-29 17:36:38 +02:00
Matthias Hanel
377a46eedd Merge pull request #2580 from nats-io/hdr-ping 
[fixed] missing support for header in some request handler
 2021-09-28 17:41:15 -04:00
Matthias Hanel
9c01794f5f Merge pull request #2581 from nats-io/src-mirror-ln-3way 
added unit test to test stream source/mirror cross different domains
 2021-09-28 17:41:04 -04:00
Waldemar Quevedo
31680da399 Merge pull request #2582 from nats-io/go-mod 
Update nats-io/jwt dependency
 2021-09-28 14:11:27 -07:00
Waldemar Quevedo
b96f731f1a Update nats-io/jwt dependency 
Signed-off-by: Waldemar Quevedo <wally@synadia.com>
 2021-09-28 13:24:24 -07:00
Matthias Hanel
11bf8505cf added unit test to test stream source/mirror cross different domains 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2021-09-28 16:20:37 -04:00
Derek Collison
51a6224f91 Merge pull request #2579 from nats-io/mixed-coldboot 
Adjust cluster size on cold start in mixed mode
 2021-09-28 11:29:41 -07:00
Matthias Hanel
3379b3b612 [fixed] missing support for header in some request handler 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2021-09-28 14:28:03 -04:00
Derek Collison
de83307e8d Log when we adjust the peer set size 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-09-28 11:02:53 -07:00
Derek Collison
f4177bacbc Bump version 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-09-27 19:59:05 -07:00
Derek Collison
74e2034aed Only adjust downward if we have a total >= original estimate 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-09-27 18:39:37 -07:00
Derek Collison
8223275c44 On cold start in mixed mode if the js servers were not > non-js we could stall. 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-09-27 16:59:42 -07:00
Ivan Kozlovic
c91f0fec3f Merge pull request #2571 from nats-io/release_2_6_1_bis 
Release v2.6.1
 2021-09-23 18:08:46 -06:00
Ivan Kozlovic
6400c8cabf Release v2.6.1 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2021-09-23 17:47:47 -06:00
Ivan Kozlovic
812ba157ba Merge pull request #2568 from nats-io/js-conn-cnt 
[FIXED] Internal connections were counted toward account's max connections (client or leaf)
 2021-09-23 17:45:00 -06:00
Derek Collison
15fb253c7c Revert back to old subject, don't suppress updates on non client/leaf 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-09-23 16:07:35 -07:00
Derek Collison
3740a707f6 Do not count non client or leafnode connections for account limit reporting. 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-09-23 15:43:07 -07:00
Derek Collison
77eb639b2c Merge pull request #2569 from nats-io/catchup 
Improve handling when exceeding account resources.
 2021-09-23 14:48:20 -07:00
Derek Collison
7340dde408 Improve handling when exceeding account resources and trying to catch up streams, etc. 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-09-23 14:21:14 -07:00
Ivan Kozlovic
3c537824bc Merge pull request #2567 from nats-io/fix_flapper 
Fix corrupt wal test that was flapping
 2021-09-23 10:14:39 -06:00
Ivan Kozlovic
7b25755980 Adjust timing 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2021-09-23 09:56:42 -06:00
Matthias Hanel
6fe3939ca4 NO COMMIT, demonstrate JS conn count 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2021-09-23 11:53:34 -04:00