gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-17 11:24:44 -07:00
Code Issues Packages Projects Releases Wiki Activity
3,288 Commits 30 Branches 48 Tags
0e9ca7614ff7b8b87496b4aa76943149dd208240
Commit Graph

3288 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
R.I.Pienaar
0e9ca7614f ensure bare AckNxt requesting >1 is supported 
Signed-off-by: R.I.Pienaar <rip@devco.net>
 2020-10-30 14:46:39 +01:00
Derek Collison
5adce5c01c Merge pull request #1679 from nats-io/si-units-go-fmt 
Run go fmt on tests
 2020-10-28 20:51:48 -07:00
Waldemar Quevedo
c9ff9c45a4 Run go fmt on tests 
Signed-off-by: Waldemar Quevedo <wally@synadia.com>
 2020-10-28 20:49:47 -07:00
Derek Collison
0f22e99601 Merge pull request #1675 from nats-io/filestore 
Stability and performance updates for filestore.
 2020-10-28 19:16:44 -07:00
Derek Collison
283c632d8b Updates based on PR feedback and fix for merge regression with pending PR 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-28 18:58:42 -07:00
Derek Collison
8fede04064 Merge pull request #1678 from nats-io/si-units 
Add support for base2 units in NATS config
 2020-10-28 18:23:58 -07:00
Waldemar Quevedo
2047ed4537 Add support for base2 units in NATS config 
Signed-off-by: Waldemar Quevedo <wally@synadia.com>
 2020-10-28 13:52:35 -07:00
Derek Collison
225e22667c Make flush channel buffered since we do non-blocking kicks 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-28 12:42:31 -07:00
Derek Collison
ad452190e3 Make sure flushLoop is running before returning from constructor. 
We had a situation in constrained events where the flusher was not
started running fast enough and flush events were missed and caches
became stale.

Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-28 11:35:57 -07:00
Derek Collison
3e5d484fc8 Merge pull request #1677 from ripienaar/rename_consumer_pending 
rename consumer pending fields for clarity
 2020-10-28 08:39:21 -07:00
Derek Collison
ebae9f452c Always return with no cache, optionally reset timer 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-28 08:30:52 -07:00
R.I.Pienaar
a88c2ee349 rename consumer pending fields for clarity 
Signed-off-by: R.I.Pienaar <rip@devco.net>
 2020-10-28 16:12:01 +01:00
Derek Collison
c38bee747d With no limits was setting blkSize to smallest which was wrong 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-28 07:58:47 -07:00
Derek Collison
e16bd843e3 Updates based on PR feedback 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-28 07:58:47 -07:00
Derek Collison
fe2b354414 Stability and performance updates. 
The original design had a shared filestore write buffer and individual message blocks had a read cache.
This presented some performance and stability issues when lots of reads and deletes were happening to a
message block that was also being written to actively.

This change eliminates the shared write buffer and uses the message block's cache as a write through as
well as read cache and handles partials correctly.

Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-28 07:58:47 -07:00
Derek Collison
778aa5e6bb Merge pull request #1676 from nats-io/pending 
Track number of stream pending for each consumer.
 2020-10-28 07:30:01 -07:00
Derek Collison
2fbff798bd Updated release version [ci skip] 2020-10-28 07:06:32 -07:00
Derek Collison
df4ee081a5 Track number of stream pending for each consumer. 
This will track the stream pending state for each consumer.
This code does account for filtered consumers.

Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-27 19:30:42 -07:00
Ivan Kozlovic
6d76156b12 Merge pull request #1673 from nats-io/fix_no_advertise_doc 
Fixed no_advertise comment in `nats-server -help`
 2020-10-26 14:25:21 -06:00
Ivan Kozlovic
c88ac568b3 Fixed no_advertise comment in nats-server -help 
Resolves #1647

[ci skip]

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-10-26 10:41:57 -06:00
Phil Pennock
773ac7fbd1 Bump version to 2.2.0-beta.27 (#1670) 
Signed-off-by: Phil Pennock <pdp@synadia.com>
 2020-10-23 15:38:44 -04:00
Derek Collison
32b6cf8145 Merge pull request #1668 from nats-io/dedupe 
Purge clears dedupe window as well
 2020-10-23 06:22:25 -07:00
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
Derek Collison
987892b260 Purge clears dedupe window as well 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-10-23 05:52:05 -07:00
Derek Collison
a89cdb6a8e Merge pull request #1667 from ripienaar/purged_always_included 
always include purged number
 2020-10-23 05:28:05 -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
98aa87fb84 Merge pull request #1665 from nats-io/fix_test 
Moved test to ones run without `-race` and cap number of conns
 2020-10-22 10:55:19 -06: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
R.I.Pienaar
59e3779b21 Merge pull request #1664 from ripienaar/nsc_nightly 
include nsc nightly binaries
 2020-10-22 18:00:10 +02: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
Ivan Kozlovic
b27655b9d3 Merge pull request #1663 from nats-io/fix-lru-timing 
Fix timing issue in unit test
 2020-10-22 09:06:39 -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
R.I.Pienaar
aafd5b9d66 include nsc nightly binaries 
Signed-off-by: R.I.Pienaar <rip@devco.net>
 2020-10-22 13:00:24 +02: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
16cb6822a7 Merge pull request #1660 from nats-io/amend_pr_1652 
Prevent panic when accepting TLS leafnode connections
 2020-10-21 15:45:42 -06: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
0adb8d149b Merge pull request #1659 from nats-io/overflow 
Do not forward service import messages to a stream export.
 2020-10-21 07:28:25 -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
Ivan Kozlovic
496d18468a Merge pull request #1655 from nats-io/remove-jwt 
Adding support and an option for removal of jwt
 2020-10-20 15:05:11 -06: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