Repository navigation

Share canonical payment block and round observations - #39

Merged

j0sh merged 74 commits into

mainfrom

ja-codex/payment-31-shared-observer

Nov 6, 2026

Merged

Share canonical payment block and round observations#39
j0sh merged 74 commits into
mainfrom
ja-codex/payment-31-shared-observer

Commits on Aug 8, 2019
- eth: Port blockwatcher and tests
  yondonfu
  committed
  a9644a7
Commits on Aug 21, 2019
- eth: roundswatcher with cache
  
  Nico Vergauwen
  authored and
  yondonfu
  committed
  cf16c6b
- cmd, eth: init roundswatcher
  
  Nico Vergauwen
  authored and
  yondonfu
  committed
  f894b05
Commits on Aug 27, 2019
- eth/watchers: Return nil for unknown events in RoundsWatcher
  yondonfu
  committed
  dedca18
Commits on Aug 29, 2019
- cmd, eth: exit when watchers error
  
  Nico Vergauwen
  authored and
  Nico Vergauwen
  committed
  8540229
Commits on Sep 4, 2019
- cmd: init senderwatcher on pm.Sender
  
  Nico Vergauwen
  authored and
  Nico Vergauwen
  committed
  e20213b
Commits on Sep 11, 2019
- eth: add transcoderPoolSize to RoundsWatcher
  
  Nico Vergauwen
  authored and
  Nico Vergauwen
  committed
  6a22278
- pm: updates to Broker and SenderManager interface
  
  Nico Vergauwen
  authored and
  Nico Vergauwen
  committed
  c5cd25d
Commits on Oct 21, 2019
- cmd, eth: RoundsWatcher subscription for SenderWatcher
  
  Nico Vergauwen
  authored and
  Nico Vergauwen
  committed
  7d3e8c0
- eth/watchers: refactor RoundsWatcher Subscription mechanism
  
  Nico Vergauwen
  authored and
  Nico Vergauwen
  committed
  2e27780
Commits on Oct 28, 2019
- eth/blockwatch: remove block header not found info statement
  
  Nico Vergauwen
  authored and
  Nico Vergauwen
  committed
  69baa44
Commits on Nov 13, 2019
- eth/blockwatch: BackfillStartBlock option
  
  Nico Vergauwen
  authored and
  Nico Vergauwen
  committed
  8f8ca8b
- cmd: determine backfilling startblock based on currentround and last seen block
  
  Nico Vergauwen
  authored and
  Nico Vergauwen
  committed
  93ca42a
Commits on Nov 15, 2019
- blockwatch: Log Watcher error
  yondonfu
  committed
  91c1b8f
Commits on Jan 24, 2020
- eth/blockwatch: reduce logging level of recoverable errors and change their language to be perceived as not interfering with node operations
  
  Nico Vergauwen
  authored and
  Nico Vergauwen
  committed
  f25291e
Commits on Mar 7, 2020
- eth/watchers: extend roundsWatcher to be a more generic timeWatcher that watchers for both latest rounds and latest blocks
  
  Nico Vergauwen
  authored and
  Nico Vergauwen
  committed
  b9ebbce
- eth/watcher: cache last seen block when starting timeWatcher Watch() loop
  
  Nico Vergauwen
  authored and
  Nico Vergauwen
  committed
  bb91a19
Commits on Mar 30, 2020
- eth: prefill last seen block state in timewatcher
  
  Nico Vergauwen
  authored and
  Nico Vergauwen
  committed
  a5ac4c1
Commits on Dec 11, 2020
- eth/watchers: add CurrentRoundStartBlock to TimeWatcher
  kyriediculous
  committed
  08cd774
Commits on Mar 5, 2021
- eth: blockwatcher can process multiple blocks in a polling interval
  kyriediculous
  committed
  5d7aace
Commits on Apr 11, 2021
- blockwatch: don't log backfilling statement when no blocks have elapsed
  kyriediculous
  committed
  56fea93
Commits on Apr 12, 2021
- eth: move timewatcher state initialisation into constructor to be synchronous
  kyriediculous
  committed
  db210d1
- eth: timewatcher code cleanup, remove fetchAndSetTranscoderPoolSize
  kyriediculous
  committed
  066a631
Commits on Dec 14, 2021
- quote errors
  darkdarkdragon
  committed
  e8f14b5
Commits on Feb 4, 2022
- eth: Handle watcher feeds asynchronously
  Rafal Leszko
  committed
  9e45b66
- eth: Refactor sink naming in the watcher feeds
  Rafal Leszko
  committed
  7dbc72d
- eth: Add locks to all feed receiver operations
  Rafal Leszko
  committed
  b8763bd
- eth: Refactor go func() {} into go
  Rafal Leszko
  committed
  e3970e3
Commits on Feb 7, 2022
- eth,pm,server: Use L1 block number for Ticket Parameters and Round Initialization
  Rafal Leszko
  committed
  e8f51fd
Commits on Feb 8, 2022
- eth,cmd: Backfill always from the back last seen in DB (instead of the last initialization round block)
  Rafal Leszko
  committed
  8f77af1
Commits on Feb 16, 2022
- Fix nil pointer in the block header logs
  Rafał Leszko
  authored
  bd5392f
Commits on Apr 13, 2022
- eth, pm: Backdate tickets by one round if the block hash for the current round is 0 (#2362)
  Rafał Leszko
  authored
  e68c8ae
Commits on Jul 11, 2022
- eth: Backfill blocks in batches (#2489)
  Rafał Leszko
  authored
  5b2c07c
Commits on Mar 23, 2023
- Reduce number of ETH RPC calls during block polling (#2775)
  Rafał Leszko
  authored
  bdf5252
Commits on Jun 6, 2023
- go.mod: Bump go and livepeer-data version (#2804)
  victorges
  authored
  13d823a
Commits on Jul 22, 2025
- refactor: use the built-in max/min to simplify the code (#3577)
  studystill
  authored
  cbb1508
Commits on Nov 6, 2026
- Share canonical payment block and round observations
  j0sh
  committed
  7c864a7
- eth: Port blockwatcher and tests
  
  yondonfu
  authored and
  j0sh
  committed
  29a179c
- eth: roundswatcher with cache
  
  Nico Vergauwen
  authored and
  j0sh
  committed
  1a8bfce
- cmd, eth: init roundswatcher
  
  Nico Vergauwen
  authored and
  j0sh
  committed
  2b93138
- eth/watchers: Return nil for unknown events in RoundsWatcher
  
  yondonfu
  authored and
  j0sh
  committed
  7397e4f
- cmd, eth: exit when watchers error
  
  Nico Vergauwen
  authored and
  j0sh
  committed
  40b9ea2
- cmd: init senderwatcher on pm.Sender
  
  Nico Vergauwen
  authored and
  j0sh
  committed
  5f98b76
- eth: add transcoderPoolSize to RoundsWatcher
  
  Nico Vergauwen
  authored and
  j0sh
  committed
  ba6f919
- pm: updates to Broker and SenderManager interface
  
  Nico Vergauwen
  authored and
  j0sh
  committed
  c7ccd72
- cmd, eth: RoundsWatcher subscription for SenderWatcher
  
  Nico Vergauwen
  authored and
  j0sh
  committed
  2ecc057
- eth/watchers: refactor RoundsWatcher Subscription mechanism
  
  Nico Vergauwen
  authored and
  j0sh
  committed
  429edbe
- eth/blockwatch: remove block header not found info statement
  
  Nico Vergauwen
  authored and
  j0sh
  committed
  3e86a18
- eth/blockwatch: BackfillStartBlock option
  
  Nico Vergauwen
  authored and
  j0sh
  committed
  ba31a78
- cmd: determine backfilling startblock based on currentround and last seen block
  
  Nico Vergauwen
  authored and
  j0sh
  committed
  ee275ca
- blockwatch: Log Watcher error
  
  yondonfu
  authored and
  j0sh
  committed
  6b750f6
- eth/blockwatch: reduce logging level of recoverable errors and change their language to be perceived as not interfering with node operations
  
  Nico Vergauwen
  authored and
  j0sh
  committed
  1662175
- eth/watchers: extend roundsWatcher to be a more generic timeWatcher that watchers for both latest rounds and latest blocks
  
  Nico Vergauwen
  authored and
  j0sh
  committed
  e8efe10
- eth/watcher: cache last seen block when starting timeWatcher Watch() loop
  
  Nico Vergauwen
  authored and
  j0sh
  committed
  0d17715
- eth: prefill last seen block state in timewatcher
  
  Nico Vergauwen
  authored and
  j0sh
  committed
  67c22d7
- eth/watchers: add CurrentRoundStartBlock to TimeWatcher
  
  kyriediculous
  authored and
  j0sh
  committed
  fac8707
- eth: blockwatcher can process multiple blocks in a polling interval
  
  kyriediculous
  authored and
  j0sh
  committed
  4016bbe
- blockwatch: don't log backfilling statement when no blocks have elapsed
  
  kyriediculous
  authored and
  j0sh
  committed
  cac59c8
- eth: move timewatcher state initialisation into constructor to be synchronous
  
  kyriediculous
  authored and
  j0sh
  committed
  6c60ee6
- eth: timewatcher code cleanup, remove fetchAndSetTranscoderPoolSize
  
  kyriediculous
  authored and
  j0sh
  committed
  61b7d16
- quote errors
  
  darkdarkdragon
  authored and
  j0sh
  committed
  8566970
- eth: Handle watcher feeds asynchronously
  
  Rafal Leszko
  authored and
  j0sh
  committed
  9d013d5
- eth: Refactor sink naming in the watcher feeds
  
  Rafal Leszko
  authored and
  j0sh
  committed
  15515d5
- eth: Add locks to all feed receiver operations
  
  Rafal Leszko
  authored and
  j0sh
  committed
  c7b4207
- eth: Refactor go func() {} into go
  
  Rafal Leszko
  authored and
  j0sh
  committed
  fc5f9bb
- eth,pm,server: Use L1 block number for Ticket Parameters and Round Initialization
  
  Rafal Leszko
  authored and
  j0sh
  committed
  26113ba
- eth,cmd: Backfill always from the back last seen in DB (instead of the last initialization round block)
  
  Rafal Leszko
  authored and
  j0sh
  committed
  bd8663e
- Fix nil pointer in the block header logs
  
  Rafał Leszko
  authored and
  j0sh
  committed
  a52452f
- eth, pm: Backdate tickets by one round if the block hash for the current round is 0 (#2362)
  
  Rafał Leszko
  authored and
  j0sh
  committed
  14dde61
- eth: Backfill blocks in batches (#2489)
  
  Rafał Leszko
  authored and
  j0sh
  committed
  a03c6a4
- Reduce number of ETH RPC calls during block polling (#2775)
  
  Rafał Leszko
  authored and
  j0sh
  committed
  907247e
- go.mod: Bump go and livepeer-data version (#2804)
  
  victorges
  authored and
  j0sh
  committed
  5d60aa8
- refactor: use the built-in max/min to simplify the code (#3577)
  
  studystill
  authored and
  j0sh
  committed
  cd1df2c
- Restore Node observer adaptation after automatic stack restack
  j0sh
  committed
  a813d7f

Commits

Commits on Aug 8, 2019

Commits on Aug 21, 2019

Commits on Aug 27, 2019

Commits on Aug 29, 2019

Commits on Sep 4, 2019

Commits on Sep 11, 2019

Commits on Oct 21, 2019

Commits on Oct 28, 2019

Commits on Nov 13, 2019

Commits on Nov 15, 2019

Commits on Jan 24, 2020

Commits on Mar 7, 2020

Commits on Mar 30, 2020

Commits on Dec 11, 2020

Commits on Mar 5, 2021

Commits on Apr 11, 2021

Commits on Apr 12, 2021

Commits on Dec 14, 2021

Commits on Feb 4, 2022

Commits on Feb 7, 2022

Commits on Feb 8, 2022

Commits on Feb 16, 2022

Commits on Apr 13, 2022

Commits on Jul 11, 2022

Commits on Mar 23, 2023

Commits on Jun 6, 2023

Commits on Jul 22, 2025

Commits on Nov 6, 2026