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
3,265 Commits 30 Branches 48 Tags
e116fc2a78379b25a9741d8ae4f0635dfd20b3d9
Commit Graph

1975 Commits

Author SHA1 Message Date
Derek Collison
e116fc2a78 Merge pull request #1666 from nats-io/nointerest 
Add store.SkipMsg() and update no interest retention streams
 2020-10-23 05:54:32 -07:00
R.I.Pienaar
b337edb447 always include purged number 
When purging an empty stream success is true but the
purged is then omitted since its, correctly, 0. It's
better to include it even when zero so it's not weirdly
inconsistent between succesful purges.

Also helps with validation of payloads

Signed-off-by: R.I.Pienaar <rip@devco.net>
 2020-10-23 12:58:42 +02:00
Derek Collison
ad247d1853 Add store.SkipMsg() and update no interest retention streams 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-22 19:35:28 -07:00
Derek Collison
63477acb61 Merge pull request #1658 from nats-io/waitq 
[JetStream] Upgrade for wait queues for pull based consumers
 2020-10-22 09:59:57 -07:00
Ivan Kozlovic
46a4969813 Moved test to ones run without -race and cap number of conns 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-10-22 10:11:16 -06:00
Ivan Kozlovic
1dca361d01 Merge pull request #1661 from nats-io/accz 
Adding more debugging information to accountz
 2020-10-22 09:45:24 -06:00
Ivan Kozlovic
24eed934af Merge pull request #1662 from nats-io/latency 
[FIXED] Do not report bad latency results on auto-unsubscribe triggers
 2020-10-22 09:08:06 -06:00
Derek Collison
511cdaa5ac Do not report bad latency on auto-unsubscribe triggers 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-22 05:41:33 -07:00
Matthias Hanel
c2c04b6cf9 Fix timing issue in unit test 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-10-22 02:23:15 -04:00
Matthias Hanel
c907245bfc Adding more debugging information to accountz 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-10-21 18:29:22 -04:00
Ivan Kozlovic
bea9fca24c Prevent panic when accepting TLS leafnode connections 
This is an addition to PR #1652. I have simply added a check but
at this point in time there is no risk that connection is closed
this early.
I also renamed the small helper function and fixed a test that
had an improper `s.mu.Unlock()` in an error condition.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-10-21 14:53:03 -06:00
Derek Collison
df29f1fb50 Add detailed info on error for NextMsg() request 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-21 11:26:22 -07:00
Derek Collison
3b18f188ed Switched behavior to never refuse new request, and to alert when expiring ones with interest 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-21 10:35:29 -07:00
Derek Collison
705f8b6ed7 Do not forward service import messages to a stream export. 
Addresses stack overflow issue wally was seeing with configs
that mix and match streams and services between each other.

Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-20 19:20:44 -07:00
Derek Collison
7fb22206f5 Allow AckNxt to also process a next request struct 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-20 16:45:54 -07:00
Derek Collison
c2b8de377c Formalize requests for next msg, support NoWait and Expires 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-20 16:25:19 -07:00
Matthias Hanel
2144f01f21 Adding support and an option for removal of jwt 
To enable in full mode configure allow_delete: true
When enabled the file will be renamed to allow for manual restore.

In cache mode it will be enabled by default.
When enabled files will be deleted.

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-10-20 16:45:11 -04:00
Derek Collison
a37f53e236 Updated tests for addition of ErrNoResponders 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-19 20:11:52 -07:00
Derek Collison
610d2d21b7 More robust waiting queue for pull mode consumers 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-19 19:51:46 -07:00
Ivan Kozlovic
ced31507a4 Bump version to 2.2.0-beta.26 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-10-19 17:07:51 -06:00
Matthias Hanel
f83280ccaf Fixed account update issue where signing key (and thus issuer) changes 
Fix error and remove print from test.

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-10-19 18:42:10 -04:00
Matthias Hanel
243361ac9a Incorporating readability suggestions 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-10-19 17:33:02 -04:00
Matthias Hanel
5a5dbb9dcd Fix nil deref when account is in bad/incomplete state 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-10-19 16:38:42 -04:00
Ivan Kozlovic
d6e420a996 Merge pull request #1652 from nats-io/fix_leafnode_accept_panic 
[FIXED] Possible panic when server accepts TLS leafnode connection
 2020-10-19 11:09:46 -06:00
Ivan Kozlovic
9bd088e0b9 Make it a small function 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-10-19 10:50:20 -06:00
Ivan Kozlovic
3b8d00e046 [FIXED] Possible panic when server accepts TLS leafnode connection 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-10-19 10:29:32 -06:00
R.I.Pienaar
ec606ebed2 add type hints num accounts message 
Signed-off-by: R.I.Pienaar <rip@devco.net>
 2020-10-19 12:01:11 +02:00
Derek Collison
923335e52d Merge pull request #1644 from nats-io/map 
Traffic shaping and full wildcard support for streams and services exports/imports
 2020-10-17 16:19:15 -07:00
Derek Collison
4af434e586 Allow mapping destinations to be parsed as singles and not force array syntax 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-17 08:21:02 -07:00
Derek Collison
cea8a0113d Use separate lock to pull cluster name for mapping 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-17 07:46:48 -07:00
Derek Collison
5f5ceb4668 Allow cluster filters for mappings, changed accountz for mappings 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-16 16:53:14 -07:00
Derek Collison
047600750a Make sure mappings to 0% turn off all traffic 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-16 14:23:47 -07:00
Derek Collison
04ffe3b00e Allow mapping destinations that introduce message loss (debugging, chaos monkey) 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-15 20:03:44 -07:00
Derek Collison
d0201d8b15 Added support for mappings in Accountz 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-15 19:14:58 -07:00
Derek Collison
4402a9cca0 Snapshot account but update at end of each readloop 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-15 15:52:43 -07:00
Derek Collison
e225acd179 Fix race accessing c.acc checking for mappings 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-15 14:02:39 -07:00
Waldemar Quevedo
33a9391519 Fix typo in websocket err message 
Signed-off-by: Waldemar Quevedo <wally@synadia.com>
 2020-10-15 13:42:22 -07:00
Derek Collison
96bf818558 Updates based on PR feedback 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-15 13:04:04 -07:00
Matthias Hanel
2bfb8b1227 [Fixed] revocation check for activations used current time instead of jwt issue time 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-10-15 15:36:50 -04:00
Derek Collison
6faf07d583 Account subject mappings and full wildcard support for exports/imports 
The mappings enable traffic shaping functionality.
Also added a subject transform which can match any subject and transform to a new one, even re-ordering partial wildcards.

Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-15 10:26:25 -07:00
R.I.Pienaar
f2106ab9e4 fix npe for offsets larger than items 
Signed-off-by: R.I.Pienaar <rip@devco.net>
 2020-10-15 11:27:31 +02:00
Ivan Kozlovic
26cd1f99ab [FIXED] Stream's subscription propagation issue with gateways 
When creating shadow subscriptions for import streams, we were
not invoking code for gateway subscription accounting, which means
that when the account (for leafnodes) was switched to interest
only, those shadow subscriptions were not sent.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-10-13 18:10:27 -06:00
Matthias Hanel
60c8cbd1f2 Fixed crash on non existing directory 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-10-13 01:30:03 -04:00
Matthias Hanel
8d8f6480d7 Incorporating comments 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-10-12 19:21:32 -04:00
Matthias Hanel
bb63fd5f40 Adding list/delete/update operations for jwt stored by nats-resolver 
Update already existed scoped by account, this exposes update without account.
List returns a list of all stored accounts.
Delete deletes accounts.
Fix a crash on startup with non existing directory.

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-10-12 18:07:07 -04:00
Matthias Hanel
db44b589fc Skip revocation check if the client has no jwt and is therefore internal 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-10-09 14:41:32 -04:00
Ivan Kozlovic
13df1a55fd Changed warning message 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-10-09 09:36:30 -06:00
Ivan Kozlovic
df9d5f5fd9 Accepting route warns if remote server has same name 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-10-08 17:59:33 -06:00
Ivan Kozlovic
9b6385d6e7 [CHANGED] Default TLS and Auth timeout 
The default TLS timeout has been bumped to 2 seconds.
The default Auth timeout is now 2 seconds, but if TLS config
is present, it is equal to TLS timeout (possibly default value) + 1s.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-10-08 16:15:30 -06:00
Matthias Hanel
387e1e1ee4 [Fixed] revocation check used current time instead of jwt issue time 
Also empty revoked keys once account jwt has no revocations.

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-10-06 21:45:34 -04:00