Code

Outbound data architecture changes#680

Code

Merged

derekcollison merged 28 commits intomasternats-io/nats-server:masterfrom fanoutnats-io/nats-server:fanoutCopy head branch name to clipboardJun 12, 2018

+2,147-752

Commits

Commits on Jun 5, 2018

• Baseline order test and benchmarks

  derekcollison

  committed
  e6f200b

  Copy full SHA for e6f200b

• Changed sublist to avoid quadratic time in removal with large N

  Show description for b9c73e9
  derekcollison

  committed
  b9c73e9

  Copy full SHA for b9c73e9

• Add fast slice for large psubs for Match

  Show description for 8502fb1
  derekcollison

  committed
  8502fb1

  Copy full SHA for 8502fb1

• Change to timer setup

  Show description for e1ce792
  derekcollison

  committed
  e1ce792

  Copy full SHA for e1ce792

• Re-enable benchmark tests

  Show description for bb292d9
  derekcollison

  committed
  bb292d9

  Copy full SHA for bb292d9

• Collect pub permissions into own function

  derekcollison

  committed
  25654a4

  Copy full SHA for 25654a4

• Added large payload pub/sub benchmark

  Show description for 6443762
  derekcollison

  committed
  6443762

  Copy full SHA for 6443762

• New outbound data architecture

  Show description for 481697e
  derekcollison

  committed
  481697e

  Copy full SHA for 481697e

• Slow consumer updates and latency improvements.

  Show description for 50a9924
  derekcollison

  committed
  50a9924

  Copy full SHA for 50a9924

• Add max_pending and write_deadline to varz

  Show description for 766ef3b
  derekcollison

  committed
  766ef3b

  Copy full SHA for 766ef3b

• varz cluster empty when not defined

  Show description for df574ce
  derekcollison

  committed
  df574ce

  Copy full SHA for df574ce

• Check flushOutbound and snapshot write_deadline and max_pending

  Show description for e64ac42
  derekcollison

  committed
  e64ac42

  Copy full SHA for e64ac42

• Performance tweaks

  Show description for e9178f1
  derekcollison

  committed
  e9178f1

  Copy full SHA for e9178f1

• Test dynamic buffers, track short reads/writes

  Show description for 30e31d5
  derekcollison

  committed
  30e31d5

  Copy full SHA for 30e31d5

• Remove 1.8 support, trigger on 1.10

  Show description for 3bdab1b
  derekcollison

  committed
  3bdab1b

  Copy full SHA for 3bdab1b

• Support for queue subscriber retries over routes

  Show description for 049db6e
  derekcollison

  committed
  049db6e

  Copy full SHA for 049db6e

• Don't send route unsub with max

  Show description for 26dafe4
  derekcollison

  committed
  26dafe4

  Copy full SHA for 26dafe4

• Fix data race

  Show description for d3213df
  derekcollison

  committed
  d3213df

  Copy full SHA for d3213df

• Fixed bug reusing test sub

  Show description for 3e2e8c9
  derekcollison

  committed
  3e2e8c9

  Copy full SHA for 3e2e8c9

• require 1.9 or above, bug fix in test

  derekcollison

  committed
  955d8ee

  Copy full SHA for 955d8ee

• delivery last activity update

  derekcollison

  committed
  50bb4b9

  Copy full SHA for 50bb4b9

• new subs collector

  Show description for cc07d50
  derekcollison

  committed
  cc07d50

  Copy full SHA for cc07d50

• lock users access

  Show description for 4dd4d2b
  derekcollison

  committed
  4dd4d2b

  Copy full SHA for 4dd4d2b

• dynamic buffer updates

  Show description for 6299e03
  derekcollison

  committed
  6299e03

  Copy full SHA for 6299e03

• Big message optimizations, slow consumer updates

  Show description for d603c53
  derekcollison

  committed
  d603c53

  Copy full SHA for d603c53

Commits on Jun 11, 2018

• Performance optimizations, beta3, fixes to various tests.

  Show description for 844f376
  derekcollison

  committed
  844f376

  Copy full SHA for 844f376

Commits on Jun 12, 2018

• Avoid lock to server with client lock held

  Show description for 4fb84e2
  derekcollison

  committed
  4fb84e2

  Copy full SHA for 4fb84e2

• Optimization per @cdevienne

  Show description for f7cb616
  derekcollison

  committed
  f7cb616

  Copy full SHA for f7cb616