Derek Collison 70a2521f95 For interest or workqueue streams with ephemerals we need to not reduce replication to 1. ...

We need the consumer state on the stream leader.
Also if we can't find the store yet for a consumer fallback to calculate needsAck.

Signed-off-by: Derek Collison <derek@nats.io>

2021-05-07 12:07:27 -07:00

..

configs

Declare required JetStream resources in test

2021-04-16 15:21:35 -07:00

pse

FreeBSD fixes: %cpu scale; no-cgo for amd64

2020-11-24 23:04:50 -05:00

sysmem

…

accounts_test.go

Return not ready for connection reason

2021-04-20 11:45:08 -07:00

accounts.go

Add in formal support for multiple JetStream domains across leafnodes.

2021-05-06 18:45:27 -06:00

auth_test.go

Run gofmt -s to simplify code

2021-04-09 15:18:06 -07:00

auth.go

When detecting a jetStream domain that is extended to a leafnode or leafnode cluster

2021-04-30 15:23:12 -07:00

ciphersuites.go

…

client_test.go

put typestring to map and add tests

2021-04-05 22:03:14 +04:00

client.go

Add in formal support for multiple JetStream domains across leafnodes.

2021-05-06 18:45:27 -06:00

closed_conns_test.go

…

config_check_test.go

Check errors when removing test directories and files

2021-04-07 11:09:47 -07:00

const.go

2.2.3-beta.7

2021-05-07 06:47:34 -07:00

consumer.go

For interest or workqueue streams with ephemerals we need to not reduce replication to 1.

2021-05-07 12:07:27 -07:00

dirstore_test.go

[FIXED] MQTT: asset placement in origin cluster

2021-04-28 19:28:00 -06:00

dirstore.go

[added] disconnect of all clients and disable account on remove

2021-03-30 02:24:02 -04:00

disk_avail_windows.go

Separate out disk available for Windows

2020-10-31 12:56:27 -07:00

disk_avail.go

Unbreak FreeBSD compilation (syscall.Statfs_t) (#1734)

2020-11-22 20:00:37 -05:00

errors_test.go

…

errors.go

[FIXED] Under certain conditions with messages being auto-deleted we would not honor blk size properly.

2021-05-05 08:27:22 -07:00

events_test.go

Do not propagate service import interest across GW and ROUTES

2021-04-15 11:34:36 -06:00

events.go

Mixed mode improvements.

2021-04-09 14:58:35 -07:00

filestore_test.go

[FIXED] Under certain conditions with messages being auto-deleted we would not honor blk size properly.

2021-05-05 08:27:22 -07:00

filestore.go

Add in comments to help with usage

2021-05-05 08:58:14 -07:00

fuzz.go

Updated fuzzer

2020-11-17 18:57:45 +00:00

gateway_test.go

[FIXED] MQTT fixes and improvements

2021-05-04 20:48:14 -06:00

gateway.go

[FIXED] MQTT fixes and improvements

2021-05-04 20:48:14 -06:00

jetstream_api.go

Add in support for JetStream domains.

2021-05-06 18:46:32 -06:00

jetstream_cluster_test.go

Tweak timing

2021-05-07 12:07:27 -07:00

jetstream_cluster.go

For interest or workqueue streams with ephemerals we need to not reduce replication to 1.

2021-05-07 12:07:27 -07:00

jetstream_events.go

[Changed] all times exposed will be computed in UTC (#1943)

2021-03-02 21:37:42 -05:00

jetstream_test.go

remove . from domain names

2021-05-07 14:46:22 +02:00

jetstream.go

remove . from domain names

2021-05-07 14:46:22 +02:00

jwt_test.go

Fixed some tests to manually close account resolver

2021-05-06 18:46:32 -06:00

jwt.go

[fixed] decorated jwt parsing issue by using same functionality of jwt

2021-05-04 23:04:51 -04:00

leafnode_test.go

Fix test

2021-05-06 18:46:32 -06:00

leafnode.go

Moved the JetStream logic for solicited leafnodes to after we receive first info.

2021-05-06 18:46:32 -06:00

log_test.go

Check errors when removing test directories and files

2021-04-07 11:09:47 -07:00

log.go

JetStream Clustering WIP

2021-01-14 01:14:52 -08:00

memstore_test.go

JetStream Clustering WIP

2021-01-14 01:14:52 -08:00

memstore.go

Change to report total deleted by default for stream info.

2021-04-12 18:10:11 -07:00

monitor_sort_opts.go

…

monitor_test.go

[FIXED] Getting varz from the http endoint saw Subscriptions always double for each fetch.

2021-05-03 18:43:07 -07:00

monitor.go

[FIXED] Getting varz from the http endoint saw Subscriptions always double for each fetch.

2021-05-03 18:43:07 -07:00

mqtt_test.go

MQTT make session streams domain aware

2021-05-06 20:02:00 -06:00

mqtt.go

MQTT make session streams domain aware

2021-05-06 20:02:00 -06:00

nkey_test.go

Check errors when removing test directories and files

2021-04-07 11:09:47 -07:00

nkey.go

[added] support for StrictSigningKeyUsage and updated jwt library (#1845)

2021-01-26 17:49:58 -05:00

norace_test.go

Fix flapper

2021-04-19 11:43:43 -07:00

opts_test.go

[FIXED] TLS: default ciphers not set when tls enabled from command line

2021-04-29 12:50:23 -06:00

opts.go

Detect if perm subjects have queue group qualifiers.

2021-05-07 06:27:43 -07:00

parser_test.go

[CHANGED] Enforce max_control_line for client connections only

2021-01-26 15:33:39 -07:00

parser.go

Add in formal support for multiple JetStream domains across leafnodes.

2021-05-06 18:45:27 -06:00

ping_test.go

…

raft.go

Fixed bug that could cause raft group to spin trying to catchup.

2021-05-07 09:13:18 -07:00

reload_test.go

Check errors when removing test directories and files

2021-04-07 11:09:47 -07:00

reload.go

[fixed] issue with concurrent account fetch when account was incomplete (#2067)

2021-04-06 12:43:10 -04:00

ring_test.go

…

ring.go

…

route.go

[FIXED] Message loop with cluster, leaf nodes and queue subs

2021-04-28 17:11:51 -06:00

routes_test.go

Return not ready for connection reason

2021-04-20 11:45:08 -07:00

sendq.go

Changed stream sendq to linked list outq.

2021-03-04 17:19:50 -08:00

server_test.go

Force server name to be set if mqtt{} defined

2021-05-05 13:17:53 -06:00

server.go

Add in support for JetStream domains.

2021-05-06 18:46:32 -06:00

service_test.go

Return not ready for connection reason

2021-04-20 11:45:08 -07:00

service_windows.go

…

service.go

…

signal_test.go

Check errors when removing test directories and files

2021-04-07 11:09:47 -07:00

signal_windows.go

…

signal.go

Make SIGTERM exit 1

2021-04-12 10:17:13 -07:00

split_test.go

…

store.go

Change to report total deleted by default for stream info.

2021-04-12 18:10:11 -07:00

stream.go

Fixed mirror/source streams from work queues.

2021-05-07 06:01:52 -07:00

sublist_test.go

[FIXED] Return no match result if subject contains empty token

2021-01-28 17:43:22 -07:00

sublist.go

Check for bad domain names

2021-05-06 19:41:43 -07:00

test_test.go

Add in support for JetStream domains.

2021-05-06 18:46:32 -06:00

trust_test.go

Check errors when removing test directories and files

2021-04-07 11:09:47 -07:00

util_test.go

…

util.go

…

websocket_test.go

Run gofmt -s to simplify code

2021-04-09 15:18:06 -07:00

websocket.go

Return not ready for connection reason

2021-04-20 11:45:08 -07:00