Code

Last position handling#504

Code

Merged

lovromazgon merged 62 commits intolovro/stabilityConduitIO/conduit:lovro/stabilityfrom lovro/last-positionConduitIO/conduit:lovro/last-positionCopy head branch name to clipboardJul 26, 2022

+1,041-903

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

• update plugin interface

  lovromazgon

  committed
  ce14149

  Copy full SHA for ce14149

• update standalone plugin implementation

  lovromazgon

  committed
  3bdec6c

  Copy full SHA for 3bdec6c

• update builtin plugin implementation

  lovromazgon

  committed
  6ab51fc

  Copy full SHA for 6ab51fc

• update connector

  lovromazgon

  committed
  08115fe

  Copy full SHA for 08115fe

• update nodes

  lovromazgon

  committed
  65e087a

  Copy full SHA for 65e087a

• change plugin semantics, close stream on teardown

  lovromazgon

  committed
  ffd3637

  Copy full SHA for ffd3637

• refactor stream, reuse it in source and destination

  lovromazgon

  committed
  03cbb0c

  Copy full SHA for 03cbb0c

• lock stream when stopping

  lovromazgon

  committed
  eb69500

  Copy full SHA for eb69500

Commits on Jun 30, 2022

• create control message for source stop

  lovromazgon

  committed
  ef06990

  Copy full SHA for ef06990

• forward last position to destination

  lovromazgon

  committed
  9e50b1f

  Copy full SHA for 9e50b1f

• update connector SDK, fix race condition in source node

  lovromazgon

  committed
  c46310d

  Copy full SHA for c46310d

Commits on Jul 1, 2022

• make Conduit in charge of closing connector streams

  Show description for a6a898b
  lovromazgon

  committed
  a6a898b

  Copy full SHA for a6a898b

Commits on Jul 4, 2022

• destination acker tests

  lovromazgon

  committed
  8c534b1

  Copy full SHA for 8c534b1

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

• Merge branch 'lovro/remove-message-dropped' into lovro/last-position

  lovromazgon

  committed
  054d6c7

  Copy full SHA for 054d6c7

• use LogOrReplace

  lovromazgon

  committed
  297f553

  Copy full SHA for 297f553

Commits on Jul 8, 2022

• make signal channel buffered

  lovromazgon

  committed
  f18f96c

  Copy full SHA for f18f96c

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

Commits on Jul 22, 2022

• Merge branch 'lovro/remove-message-dropped' into lovro/last-position

  lovromazgon

  committed
  540cc66

  Copy full SHA for 540cc66

• Merge branch 'lovro/stability' into lovro/last-position

  lovromazgon

  committed
  8ad3b02

  Copy full SHA for 8ad3b02

Commits on Jul 25, 2022

• make it possible only to inject control messages

  lovromazgon

  committed
  e9b8c3b

  Copy full SHA for e9b8c3b

• improve destination acker caching test

  lovromazgon

  committed
  7d088d6

  Copy full SHA for 7d088d6

• remove TODO comment

  lovromazgon

  committed
  d9a0087

  Copy full SHA for d9a0087

Commits on Jul 26, 2022

• update comment

  lovromazgon

  committed
  6099542

  Copy full SHA for 6099542