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,840 Commits 30 Branches 48 Tags
ccc492bdceb8cf7812ce59a5542c2d1ea74d67e6
Commit Graph

6840 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Jean-Noël Moyne
ccc492bdce Improve checking that subject filters and destination transforms are valid subjects. 
Improve error messages when bad filters/transforms are encountered.
Cover all cases of updating an existing stream's subject transform or sources
 2023-01-27 17:54:37 -08:00
Derek Collison
11ffd69575 Merge branch 'main' into dev 2023-01-27 13:41:48 -08:00
Derek Collison
9fff931f25 Merge pull request #3825 from nats-io/source-cycle 
[FIXED] Sourced streams that do not overlap subjects reported as a cycle.
 2023-01-27 13:41:30 -08:00
Derek Collison
4eed8ba566 Merge pull request #3824 from nats-io/process-connect-fix 
Check if connection name was already set when storing it
 2023-01-27 13:41:18 -08:00
Derek Collison
64096e5ef5 Fix for flapping test 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-01-27 13:19:44 -08:00
Derek Collison
f4e6481ce7 Allow report cycles between source streams if subjects truly form a cycle. 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-01-27 13:03:24 -08:00
Waldemar Quevedo
c6e263f910 Check if connection name was already set when storing it 
Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-01-27 11:04:38 -08:00
Derek Collison
12d49a87c8 Merge branch 'main' into dev 2023-01-27 08:35:59 -08:00
Derek Collison
7682eaa389 Merge pull request #3804 from madper/dragonflybsd 
Add support for dragonfly bsd.
 2023-01-27 08:35:42 -08:00
Derek Collison
b9f220ec80 Merge pull request #3823 from ripienaar/mappings_breaking_changes 
Mappings breaking changes
 2023-01-27 07:48:04 -08:00
Tomasz Pietrek
97d788d040 Merge pull request #3797 from nats-io/jarema/add-metadata-to-streams-and-consumers 
Add metadata to StreamConfig and ConsumerConfig
 2023-01-27 12:57:54 +01:00
R.I.Pienaar
348c84a469 restore public APIs and fix breaking interface renames 
Signed-off-by: R.I.Pienaar <rip@devco.net>
 2023-01-27 12:36:15 +01:00
Tomasz Pietrek
9ab52d4ba9 Add metadata to StreamConfig and ConsumerConfig 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2023-01-27 07:27:25 +01:00
Chengjun Xie
6cbca6b783 Add support for dragonfly bsd. 
Simply copy the pse implementation for openbsd.
 2023-01-27 10:43:30 +08:00
Tomasz Pietrek
69aa55a0e7 Merge pull request #3822 from nats-io/jarema/add-batch-completed 
Add batch completed status to Pull Consumers
 2023-01-26 23:43:00 +01:00
Tomasz Pietrek
34be180875 Add batch completed status to Pull Consumers 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2023-01-26 23:23:49 +01:00
Derek Collison
c2d3d9c467 Merge pull request #3814 from nats-io/jnm/streamsourcetransform 
[ADDED] Stream subject mapping transforms
 2023-01-26 14:09:52 -08:00
Jean-Noël Moyne
ddce3ce037 Rename StreamConfig's InputSubjectTransform (and therefore StreamSource's SubjectTransform) 2023-01-26 12:26:34 -08:00
Derek Collison
7c0c85e41b Merge branch 'main' into dev 2023-01-26 10:30:55 -08:00
Derek Collison
ad0a8403bb Merge pull request #3812 from nats-io/neil/lintprintf 
Lint warnings on `fmt.Print`, `fmt.Printf`, `fmt.Println`
 2023-01-26 10:29:43 -08:00
Derek Collison
8a40326a70 Bump to 2.9.12-RC.1 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-01-26 10:07:30 -08:00
Derek Collison
dcf9f1a87f Merge pull request #3802 from nats-io/wincert 
certstore feature with windows credential manager
 2023-01-26 09:43:40 -08:00
Derek Collison
469116deae Merge branch 'main' into dev 2023-01-26 09:39:32 -08:00
Derek Collison
c7a75c5a6d Merge pull request #3817 from nats-io/force-consumer-replicas 
[FIXED] Force consumer replicas to match for interest policy streams
 2023-01-26 09:39:15 -08:00
Derek Collison
c09ea405d6 Merge pull request #3794 from nats-io/neil/rafthealthz 
Add small tolerance in stream health check
 2023-01-26 09:17:03 -08:00
Derek Collison
3d78459ad1 Fixup for bad merge 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-01-26 09:09:30 -08:00
Neil Twigg
83932b4be6 Don't mark a clustered stream as unhealthy if making forward progress, add TestJetStreamClusterCurrentVsHealth 2023-01-26 16:57:34 +00:00
Derek Collison
d0a7a8169a Merge branch 'main' into force-consumer-replicas 2023-01-26 08:35:49 -08:00
Derek Collison
cea6fc5957 Merge branch 'main' into dev 2023-01-26 08:28:27 -08:00
Derek Collison
461aad17a5 Merge pull request #3820 from nats-io/issue-3791 
[FIXED] Select consumer peer(s) from active peers only.
 2023-01-26 08:27:11 -08:00
Derek Collison
b238323b0c Merge pull request #3818 from nats-io/issue-3636-2 
[FIXED] Properly process updates on a stream on restart.
 2023-01-26 08:26:07 -08:00
Jean-Noël Moyne
4fbe13ec1b Change test to use require_NoError instead of explicitly checking err and calling Fatalf throughout all the tests in the file 
Improvements to readability
 2023-01-26 00:31:17 -08:00
Todd Beets
e1fd61778f certstore feature with windows credential manager 2023-01-25 21:22:20 -08:00
Derek Collison
e15eb22ca6 When we create a consumer with less replicas then the stream, make sure to select from online peers. 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-01-25 20:08:04 -08:00
Derek Collison
a5cbd0b029 Fixed a bug that would not properly process updates on a stream on restart. 
During restart if the stream existed but was also in a meta-snapshot delivered by the leader we would not process the update properly.

Signed-off-by: Derek Collison <derek@nats.io>
 2023-01-25 18:16:33 -08:00
Derek Collison
4a3c27a251 Fix MQTT test for consumer replica override. 
This was ill-advised by me, not understanding that the messages stream for MQTT was interested policy based.
Interest policy based streams require consumers to match the replica count.

Signed-off-by: Derek Collison <derek@nats.io>
 2023-01-25 17:58:57 -08:00
Jean-Noël Moyne
e2561a6d54 rebase fix 2023-01-25 12:30:26 -08:00
Jean-Noël Moyne
a953e84437 Add stream input subject transform functionality 
Extract subject transformation code out of accounts.go
Stream sources can now have a subject mapping transform
You can source the same stream more than once
Remove limitation that the subject filter for a source, mirror or consumer must have an overlap with the sourced/mirrored's stream or the stream's subjects
 2023-01-25 12:25:51 -08:00
Derek Collison
a929f86fae Merge pull request #3811 from nats-io/neil/cfgrepublish 
Allow editing `RePublish` on an existing stream
 2023-01-25 09:11:03 -08:00
Neil Twigg
4f45df6186 Allow editing of RePublish on an existing stream 2023-01-25 09:57:02 +00:00
Neil Twigg
7ae243352a Lint warnings on fmt.Print, fmt.Printf, fmt.Println 2023-01-24 16:10:13 +00:00
Derek Collison
9e1a25dc94 Merge branch 'main' into dev 2023-01-24 07:13:35 -08:00
Derek Collison
bcd53ba53a Merge pull request #3808 from nats-io/jarema/fix-not-assigning-sig-sub 
Assign signal subscription to consumer when created
 2023-01-24 07:12:53 -08:00
Tomasz Pietrek
c89883b6aa Fix assigning signal subscription to consumer 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2023-01-24 12:26:22 +01:00
Derek Collison
f62d929018 Consumer must match replica of parent stream if interest based policy. 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-01-23 20:16:42 -08:00
Derek Collison
a3365abef0 Merge branch 'main' into dev 2023-01-23 17:30:08 -08:00
Derek Collison
3380fe1c74 Merge pull request #3806 from nats-io/direct-gets 
[FIXED] Updating a stream to direct gets would fail direct gets.
 2023-01-23 17:29:36 -08:00
Derek Collison
f4ee6530a0 When updating a stream to Direct Gets we were not spinning up subscription endpoint properly. 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-01-23 16:51:07 -08:00
Derek Collison
efeb838f77 Merge branch 'main' into dev 2023-01-23 16:31:50 -08:00
Derek Collison
185a1f373c Merge pull request #3805 from nats-io/move_test_to_no_race 
Move test to "norace_test.go"
 2023-01-23 16:31:21 -08:00