Derek Collison de851e513f Fix for #2548 ...

Replicated durable consumers that were backed by a memory store were bypassing snapshotting which also did compaction of the raft WAL.
This change adapts for memory store backed consumers by compacting the raft WAL directly on snapshot logic.

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

2021-09-21 08:02:11 -07:00

..

configs

[fixed] tls timeout now accepts units

2021-07-19 11:42:28 -04:00

pse

Remove external dependency on 'ps' for memory and cpu usage.

2021-06-06 11:13:32 -07:00

sysmem

…

accounts_test.go

Review comments

2021-07-22 11:27:34 -04:00

accounts.go

Use a better seed for a rand generator

2021-08-26 15:16:22 -06:00

auth_test.go

…

auth.go

Adding counter for number of failed logons due to pinned accounts

2021-08-23 18:56:56 -04:00

ciphersuites.go

…

client_test.go

Set defaultServerOptions port to -1 for random

2021-09-02 14:22:56 -06:00

client.go

Allow clustered JetStream to allow duplicate stream creation like single server mode.

2021-09-15 20:18:44 -07:00

closed_conns_test.go

…

config_check_test.go

[FIXED] Report config error if "token" defined for cluster{} and gateway{}

2021-09-13 10:21:00 -06:00

const.go

Bump version

2021-09-19 14:02:00 -07:00

consumer.go

Make large batch requests expire more efficiently.

2021-09-16 15:00:18 -07:00

dirstore_test.go

[FIXED] MQTT: asset placement in origin cluster

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

dirstore.go

Make sure jwt claim update does not wipe system imports

2021-08-17 10:03:30 -07:00

disk_avail_openbsd.go

with 'go fmt' applied

2021-08-26 16:52:43 +02:00

disk_avail_windows.go

…

disk_avail.go

with 'go fmt' applied

2021-08-26 16:52:43 +02:00

errors_gen.go

fix error code for JSStreamHeaderExceedsMaximumErr

2021-09-15 09:01:03 +02:00

errors_test.go

…

errors.go

richer api errors proposal

2021-05-26 08:04:50 +02:00

errors.json

[CHANGED] JetStream: flow control requires heartbeats

2021-09-15 09:50:15 -06:00

events_test.go

Allow clustered JetStream to allow duplicate stream creation like single server mode.

2021-09-15 20:18:44 -07:00

events.go

Fix for data race around c.echo

2021-09-16 11:59:52 -07:00

filestore_test.go

Fix for issue #2488.

2021-09-09 09:53:22 -07:00

filestore.go

Fix for #2548

2021-09-21 08:02:11 -07:00

fuzz.go

Change naming in server fuzzer

2021-07-23 10:19:07 +01:00

gateway_test.go

Set defaultServerOptions port to -1 for random

2021-09-02 14:22:56 -06:00

gateway.go

Remove the swapping of accounts during processing of service imports.

2021-07-26 07:57:10 -07:00

jetstream_api.go

ConsumerInfo in clustered mode would return not found if assigned but not properly setup with a leader.

2021-09-16 10:56:34 -07:00

jetstream_cluster_test.go

Test tweaks

2021-09-19 13:28:37 -07:00

jetstream_cluster.go

Fix for #2548

2021-09-21 08:02:11 -07:00

jetstream_errors_generated.go

[CHANGED] JetStream: flow control requires heartbeats

2021-09-15 09:50:15 -06:00

jetstream_errors_test.go

attempt to improve UX of the error system

2021-08-10 16:08:28 +02:00

jetstream_errors.go

attempt to improve UX of the error system

2021-08-10 16:08:28 +02:00

jetstream_events.go

add domain in JS advisories

2021-05-07 19:35:46 +02:00

jetstream_test.go

Merge pull request #2546 from ripienaar/negative_dupe_window_protection

2021-09-20 18:09:19 +02:00

jetstream.go

Exposing reserved memory in jsz/varz

2021-09-16 18:55:50 -04:00

jwt_test.go

[FIXED] Account resolver TLS configuration

2021-09-02 09:13:54 -06:00

jwt.go

[added] operator option to ensure user are signed by certain accounts

2021-08-23 13:45:11 -04:00

leafnode_test.go

Set defaultServerOptions port to -1 for random

2021-09-02 14:22:56 -06:00

leafnode.go

Fixed a condition where JetStream assets could be created in multiple leafnodes.

2021-09-14 14:17:49 -07:00

log_test.go

…

log.go

…

memstore_test.go

…

memstore.go

Fix for #2548

2021-09-21 08:02:11 -07:00

monitor_sort_opts.go

…

monitor_test.go

Exposing reserved memory in jsz/varz

2021-09-16 18:55:50 -04:00

monitor.go

Changed ClientID to MQTTClient and client_id to mqtt_client

2021-09-09 14:34:54 -06:00

mqtt_test.go

MQTT handle idempotent session stream creation.

2021-09-15 10:15:45 -06:00

mqtt.go

Allow clustered JetStream to allow duplicate stream creation like single server mode.

2021-09-15 20:18:44 -07:00

nkey_test.go

…

nkey.go

…

norace_test.go

Fix for #2548

2021-09-21 08:02:11 -07:00

ocsp.go

Set defaultServerOptions port to -1 for random

2021-09-02 14:22:56 -06:00

opts_test.go

[added] operator option to ensure user are signed by certain accounts

2021-08-23 13:45:11 -04:00

opts.go

[FIXED] Report config error if "token" defined for cluster{} and gateway{}

2021-09-13 10:21:00 -06:00

parser_test.go

…

parser.go

[adding] kind and client_type to account connect/disconnect events (#2351)

2021-07-07 17:43:50 -04:00

ping_test.go

…

raft.go

Log error on write errors

2021-09-19 12:14:31 -07:00

reload_test.go

[FIXED] Account resolver TLS configuration

2021-09-02 09:13:54 -06:00

reload.go

fix daisy chained leaf node subject propagation issue. (#2468)

2021-08-25 18:10:09 -04:00

ring_test.go

…

ring.go

…

route.go

fix daisy chained leaf node subject propagation issue. (#2468)

2021-08-25 18:10:09 -04:00

routes_test.go

Set defaultServerOptions port to -1 for random

2021-09-02 14:22:56 -06:00

sendq.go

We should not sit in place here, no measurable effect on latency in tests

2021-07-01 14:29:09 -07:00

server_test.go

Force server name to be set if mqtt{} defined

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

server.go

If we are in a simple mixed-mode setup with just global account and system account and clustered, allow pass through.

2021-08-26 09:41:01 -07: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

…

signal_windows.go

Handle SIGTERM on windows

2021-09-01 14:55:26 -07:00

signal.go

…

split_test.go

…

store.go

Fix for #2548

2021-09-21 08:02:11 -07:00

stream.go

Merge pull request #2546 from ripienaar/negative_dupe_window_protection

2021-09-20 18:09:19 +02:00

sublist_test.go

Add in DeliverGroup to consumer as optional queue group.

2021-08-13 15:07:56 -07:00

sublist.go

fixed queue group memory leak

2021-09-13 15:22:05 +03:00

test_test.go

[IMPROVED] MQTT stream per session replaced with single stream

2021-09-08 16:32:41 -06:00

trust_test.go

…

util_test.go

…

util.go

…

websocket_test.go

[FIXED] Websocket: possible panic when decoding CLOSE frame

2021-09-12 15:35:49 -06:00

websocket.go

Updates based on code review

2021-09-13 14:06:17 -06:00