Code

Replication lag improvement#652

Code

Merged

spuun merged 14 commits intomaincloudamqp/lavinmq:mainfrom replication-lag-improvementcloudamqp/lavinmq:replication-lag-improvementCopy head branch name to clipboardMay 10, 2024

Commits

Commits on May 10, 2024

• Count bytes added to action queue as sent

  spuun

  committed
  2c8cc69

  Copy full SHA for 2c8cc69

• Ack all bytes not only data

  spuun

  committed
  a65d730

  Copy full SHA for a65d730

• Count bytes in one place

  spuun

  committed
  cd00296

  Copy full SHA for cd00296

• Make it possible to read single acks (for specs)

  spuun

  committed
  d416d1d

  Copy full SHA for d416d1d

• Return the size of the sent action

  spuun

  committed
  3a499fc

  Copy full SHA for 3a499fc

• Make Action#bytesize Int64

  spuun

  committed
  46c748d

  Copy full SHA for 46c748d

• Add specs for Action#bytesize

  spuun

  committed
  4c4c54d

  Copy full SHA for 4c4c54d

• Add specs for Follower#lag

  spuun

  committed
  34e1d81

  Copy full SHA for 34e1d81

• Rename Action#bytesize to #lag_size

  Show description for da8cfa6
  spuun

  committed
  da8cfa6

  Copy full SHA for da8cfa6

• Only count bytes when actions are added to queue

  spuun

  committed
  4451096

  Copy full SHA for 4451096

• Type ack value as int64

  spuun

  committed
  202eca8

  Copy full SHA for 202eca8

• All data is counted in lag

  spuun

  committed
  8f30d5e

  Copy full SHA for 8f30d5e

• fixup! Type ack value as int64

  spuun

  committed
  805eba3

  Copy full SHA for 805eba3

• Update changelog

  spuun

  committed
  7d5c752

  Copy full SHA for 7d5c752