Code

Remove message status dropped#487

Code

Merged

lovromazgon merged 40 commits intolovro/stabilityConduitIO/conduit:lovro/stabilityfrom lovro/remove-message-droppedConduitIO/conduit:lovro/remove-message-droppedCopy head branch name to clipboardJul 13, 2022

+119-367

Commits

Commits on Jun 13, 2022

• implement ticket queue

  lovromazgon

  committed
  1c57687

  Copy full SHA for 1c57687

Commits on Jun 14, 2022

• experiment with ordered semaphore

  lovromazgon

  committed
  8bf3f66

  Copy full SHA for 8bf3f66

• ticketqueue benchmarks

  lovromazgon

  committed
  424d889

  Copy full SHA for 424d889

Commits on Jun 17, 2022

• reduce allocations

  lovromazgon

  committed
  8a852db

  Copy full SHA for 8a852db

Commits on Jun 21, 2022

• remove ticketqueue (semaphore implementation is more performant)

  lovromazgon

  committed
  ec7249e

  Copy full SHA for ec7249e

• optimize semaphore for our use case

  lovromazgon

  committed
  b288e21

  Copy full SHA for b288e21

• fix linter warnings, better benchmarks

  lovromazgon

  committed
  0471fbe

  Copy full SHA for 0471fbe

• better docs

  lovromazgon

  committed
  83f8184

  Copy full SHA for 83f8184

• Merge branch 'main' into lovro/ticketqueue

  lovromazgon

  committed
  f4cfe81

  Copy full SHA for f4cfe81

• go mod tidy

  lovromazgon

  committed
  83c97e0

  Copy full SHA for 83c97e0

Commits on Jun 22, 2022

• rename AckerNode to DestinationAckerNode

  lovromazgon

  committed
  c0ded08

  Copy full SHA for c0ded08

• remove message status change middleware to ensure all message handlers are called

  lovromazgon

  committed
  c66c273

  Copy full SHA for c66c273

• implement SourceAckerNode

  lovromazgon

  committed
  68cd7c7

  Copy full SHA for 68cd7c7

Commits on Jun 23, 2022

• add todo note about possible deadlock

  lovromazgon

  committed
  6bdc893

  Copy full SHA for 6bdc893

• source acker node test

  lovromazgon

  committed
  8b6dc73

  Copy full SHA for 8b6dc73

• remove message status dropped

  lovromazgon

  committed
  d6c9641

  Copy full SHA for d6c9641

Commits on Jun 24, 2022

• document behavior, fanout node return nacked message error

  lovromazgon

  committed
  f3273f3

  Copy full SHA for f3273f3

Commits on Jun 28, 2022

• Merge branch 'main' into lovro/ticketqueue

  lovromazgon

  authored
  c6be9e8

  Copy full SHA for c6be9e8

• don't forward acks after a failed ack/nack

  lovromazgon

  committed
  94b4f43

  Copy full SHA for 94b4f43

• Merge branch 'lovro/ticketqueue' into lovro/source-acker-node

  lovromazgon

  committed
  7d3749b

  Copy full SHA for 7d3749b

• use cerrors

  lovromazgon

  committed
  3e283dd

  Copy full SHA for 3e283dd

Commits on Jun 29, 2022

• Merge branch 'lovro/source-acker-node' into lovro/remove-message-dropped

  lovromazgon

  committed
  cb70142

  Copy full SHA for cb70142

Commits on Jul 5, 2022

• Merge branch 'main' into lovro/ticketqueue

  lovromazgon

  authored
  aa5f17b

  Copy full SHA for aa5f17b

Commits on Jul 6, 2022

• Merge branch 'main' into lovro/ticketqueue

  lovromazgon

  authored
  1bf9a7b

  Copy full SHA for 1bf9a7b

Commits on Jul 7, 2022

• use cerrors.New

  lovromazgon

  committed
  f43fe35

  Copy full SHA for f43fe35

• Merge branch 'lovro/stability' into lovro/ticketqueue

  lovromazgon

  committed
  19d6123

  Copy full SHA for 19d6123

• Merge branch 'lovro/ticketqueue' into lovro/source-acker-node

  lovromazgon

  committed
  c36b19a

  Copy full SHA for c36b19a

• use LogOrReplace

  lovromazgon

  committed
  befaf44

  Copy full SHA for befaf44

• Merge branch 'lovro/source-acker-node' into lovro/remove-message-dropped

  lovromazgon

  committed
  874bb86

  Copy full SHA for 874bb86

Commits on Jul 11, 2022

• improve benchmarks

  lovromazgon

  committed
  64b7d25

  Copy full SHA for 64b7d25

• fix linter error

  lovromazgon

  committed
  24c3386

  Copy full SHA for 24c3386

• add comments

  lovromazgon

  committed
  d4dd111

  Copy full SHA for d4dd111

• simplify implementation

  lovromazgon

  committed
  3ebb744

  Copy full SHA for 3ebb744

• Merge branch 'lovro/ticketqueue' into lovro/source-acker-node

  lovromazgon

  committed
  b628a7b

  Copy full SHA for b628a7b

• update semaphore

  lovromazgon

  committed
  dc31319

  Copy full SHA for dc31319

• update param name

  lovromazgon

  committed
  5a6e8a3

  Copy full SHA for 5a6e8a3

• remove redundant if clause

  lovromazgon

  committed
  54a65d1

  Copy full SHA for 54a65d1

• Merge branch 'lovro/stability' into lovro/source-acker-node

  lovromazgon

  committed
  a668a02

  Copy full SHA for a668a02

• Merge branch 'lovro/source-acker-node' into lovro/remove-message-dropped

  lovromazgon

  committed
  25c75bc

  Copy full SHA for 25c75bc

• Merge branch 'lovro/stability' into lovro/remove-message-dropped

  lovromazgon

  committed
  9bf1b74

  Copy full SHA for 9bf1b74