Repository navigation
Conversation
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 0acd88bbd8c555bebbfc4be9775ba32ed6619cf2 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: eb28eb338ab84d4eae7611b4d530a0ea5be98797 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 84c13f8b82cf4103ea55e7088304e1ead78c6156 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 7fefbe878d4540f52c02177ae7b303dae96cf74c Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: e2e86f042034e50c378c5167f3bd36452b6c9da1 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: a0465f78ade5bc4ccbb6afda847d145df6d3dc04 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 5cc2e35221b1fbf1d994d17d6e6a0a128b010d81 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 5b74602591c67645a422b5414d0fb052158248e4 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 30942f652de14e5ac1eea7a7ea7e0ff7c6cc7f7d Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 1799b33eafcb50fa48171dd5509a50d05fb8fab4 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 894b8db2cf0a98a4ed9175e6063dd0dce1114e7a Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 74fc8f4cf6996533392f36b2ab17df320a958849 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
…seen block Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 7d21c328e49e0afc2929c7dbb8d42e31ebd6de04 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 2fb674c587760f121695bffb9415fa99b89ec85d Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
… their language to be perceived as not interfering with node operations Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: d857c1b926b38b2a749aa413e382a8abca1bc91d Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
…hat watchers for both latest rounds and latest blocks Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: b4605f705bcad5e355bb0c738d784e4503089900 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
…loop Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 466185d0f90a1ed6179db8d9ea25834a5f9ec0a5 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 06cdd9176cb4854d4134d9b424647556fa3b4045 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 1b5f53fe907088672522c72a5a1d76634088bc30 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 003029a6cfba61cef7b4222941287fecdc8084e3 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 55b14ac81132831fb85dabfe4493cc72a82aa7c6 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
…chronous Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 3aec3aa1628af8307315bd80123632714f9a4044 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 3719aeed2f9dbf05cbba0c0d2873861f160cca73 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: c2c73fa6f24473311766baee83e2762c87ef708d Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 87c6e404c7a8bd5552e66e346d3659d696e17f4f Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: f30819e43a6b0d9272301a402220d7df64d70063 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 39585360f2cd0c0626ad483e9dd677efb6d09387 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 754c1ed203539275332363eb2cd2940a7fa6c72a Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
…itialization Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 4b6ede31f040a084ff9e55bd798a0d6fffee1e1b Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
…e last initialization round block) Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: a75e8e26d8e3880724c80f212a2568febd243d52 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 17a93a67b9cf3409b47e4e01797b2416cb6d234c Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
…ent round is 0 (#2362) Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 11b0600fc76595799205a1229614a1dce954d787 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 159deaa162065f933ac472d11b05510f829d1692 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 8c7ec0155c5ba040f7066ab0a30045c37f15be2a Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
* go.mod: Update livepeer-data lib * server: Fix MetadataQueue type Type changed on livepeer-data version * go.mod: Bump go to 1.20 The upgrade indirectly added a module that requires 1.19 * changelog: Change changelog * Go 1.20 -> 1.20.4 * Get rid of go-version-file * Bump lint version * Set go version in another place * go fmt * Add glog goroutine to ignored leak ones * Change order of go mod command * Bump linter version --------- Co-authored-by: Thom Shutt <thomshutt@users.noreply.github.com> Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 1b9da7f25fa8c6261e8c465ea7e5c75166d220b6 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
Signed-off-by: studystill <chenghuiyue@outlook.com> Source-Repository: https://github.com/livepeer/go-livepeer Original-Commit: 3a69e439b60acbcfb8edfda15896fb1c25039958 Source-Scope: eth/watchers/roundswatcher.go; eth/watchers/roundswatcher_test.go; eth/watchers/timewatcher.go; eth/watchers/timewatcher_test.go; eth/blockwatch/block_watcher.go; eth/blockwatch/block_watcher_test.go
j0sh
force-pushed
the
ja-codex/payment-34-single-observation
branch
from
November 4, 2026 00:03
9b6cd0e to
574431e
Compare
j0sh
force-pushed
the
ja-codex/payment-31-shared-observer
branch
from
November 4, 2026 00:03
9c32c1c to
5ac3b11
Compare
Adapt go-livepeer time/block watcher initialization and lifecycle into one bounded payment observer. Keep direct redemption reads, distinguish protocol L1 progress from L2 identity, and refuse expired or invalidated observations. Source authors, commits, and MIT provenance are retained inline. Retain the scoped go-livepeer source history as an additional parent. Its original authors, committers, dates, and messages are preserved; Original-Commit records upstream identities. This commit owns the Node adaptation and integration. Source-Repository: https://github.com/livepeer/go-livepeer Source-Revision: 597f882cb9f4d42ad8430b0f592afd5929af4a6b Source-History: cbb1508
j0sh
force-pushed
the
ja-codex/payment-31-shared-observer
branch
from
November 4, 2026 00:21
5ac3b11 to
08dc2e0
Compare
This branch has not been deployed
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Depends on #38. Merge after that PR.
Paid signer and orchestrator processes share an immutable, canonical block/round observation across requests and readiness. Warm metadata reads use memory; independent redemption and finality reads continue through the direct chain adapter.
Separates the protocol L1 clock, chain block identity, current round, and initialized round. Freshness checks distinguish contact from head/L1 progress, preserve valid state across verified polling gaps, and invalidate proven reorgs before further reads. Admission and retained-snapshot consumers revalidate locally at their commit boundaries.
Corrects the existing readiness description because its previous expiry wording becomes inaccurate. Source attribution is retained.
Validation: full race suite, vet, Staticcheck, formatting, and diff checks passed; regressions cover stale providers, reorgs, L1 rollback, delayed signing/commit, and readiness recovery.
Closes #31.