Skip to content

feat: High availabilty via RAFT #2987

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
alpe merged 57 commits into from
Jan 28, 2026
Merged

feat: High availabilty via RAFT #2987

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
57 commits
Select commit Hold shift + click to select a range
d4c7e7d
Add high availabiliy via raft
alpe Nov 12, 2025
820b9a3
Prefent duplicate peers
alpe Nov 12, 2025
35cf0c8
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 17, 2025
45a6e27
Go mod tidy
alpe Nov 17, 2025
3111158
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 17, 2025
4562ded
Minor updates
alpe Nov 17, 2025
4d47754
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 18, 2025
0804346
Fix test
alpe Nov 18, 2025
1c2e3f1
Leadership fix
alpe Nov 18, 2025
c320a7a
Fix test
alpe Nov 18, 2025
72ec5fe
Remove sleep
alpe Nov 19, 2025
b34d7a0
Increase buffer size for raft msgs
alpe Nov 19, 2025
7af5d1a
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 20, 2025
406377e
Review feedback
alpe Nov 20, 2025
0ff25b8
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 20, 2025
b92a67f
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 21, 2025
406ad8b
Add replace to go.mod
alpe Nov 21, 2025
1337bc6
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 24, 2025
abfa8d3
Fix merge conflicts
alpe Nov 24, 2025
aebbdff
Linter fix
alpe Nov 24, 2025
50d7caf
Minor test update
alpe Nov 24, 2025
5de9f0e
Remove store.Sync
alpe Nov 25, 2025
30094b2
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Dec 3, 2025
695324e
Merge
alpe Dec 3, 2025
2463919
Add last submitted da heights to raft
alpe Dec 3, 2025
3e1cbca
Make test compile again
alpe Dec 4, 2025
567092f
Merge branch 'main' into alex/adr023_ha-failover_raft8
alpe Jan 6, 2026
640924b
Complete merge
alpe Jan 6, 2026
11038cd
Merge branch 'main' into alex/adr023_ha-failover_raft8
alpe Jan 7, 2026
095f882
Fix integration test
alpe Jan 7, 2026
99afdad
Review feedback and linting
alpe Jan 7, 2026
3f7f431
Convert raft state into proto type
alpe Jan 7, 2026
25a6185
Fix import and e2e tests
alpe Jan 8, 2026
adc05ed
Cufigurable leader_lease_timeout
alpe Jan 8, 2026
9b0bff4
Merge branch 'main' into alex/adr023_ha-failover_raft8
alpe Jan 9, 2026
49ba50f
Log raft state height when passing leadership
alpe Jan 9, 2026
00ae050
Recover with raft state
alpe Jan 12, 2026
490b286
Ensure block hash in state check
alpe Jan 12, 2026
d7fbf79
Merge branch 'main' into alex/adr023_ha-failover_raft8
alpe Jan 12, 2026
dfa2204
Merge branch 'main' into alex/adr023_ha-failover_raft8
alpe Jan 15, 2026
7edca17
x
alpe Jan 14, 2026
6502a47
More safety features, including db.sync
alpe Jan 14, 2026
a52d538
Ensure safe restart
alpe Jan 15, 2026
3203ce6
x
alpe Jan 15, 2026
1cf1167
Merge branch 'main' into alex/adr023_ha-failover_raft11
alpe Jan 16, 2026
e4e94f2
Resolve conflicts
alpe Jan 16, 2026
e444215
Fix test setup
alpe Jan 18, 2026
3b4fe3f
Fix dummyDA
alpe Jan 19, 2026
9b80c74
Merge branch 'main' into alex/adr023_ha-failover_raft11
alpe Jan 19, 2026
67d1ce7
Merge branch 'main' into alex/adr023_ha-failover_raft11
alpe Jan 26, 2026
51edca8
Review feedback
alpe Jan 26, 2026
5fc0b6b
Add grace period for test
alpe Jan 26, 2026
e8f9db0
Add raft doc
alpe Jan 27, 2026
c9b8166
Available ports for e2e tests
alpe Jan 27, 2026
acce8e4
Review feedback
alpe Jan 27, 2026
c1ef1d5
Merge branch 'main' into alex/adr023_ha-failover_raft11
alpe Jan 27, 2026
938f908
Fix integration test
alpe Jan 27, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Fix merge conflicts
  • Loading branch information
@alpe
alpe committed Nov 24, 2025
commit abfa8d38f24839de355e7396df1fc07dc720ea7f
3 changes: 0 additions & 3 deletions node/full_node_integration_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -278,9 +278,6 @@ func TestDataExchange(t *testing.T) {
t.Run("SingleSequencerTwoFullNodes", func(t *testing.T) {
testSingleSequencerTwoFullNodes(t, Data)
})
t.Run("SingleSequencerSingleFullNodeTrustedHash", func(t *testing.T) {
testSingleSequencerSingleFullNodeTrustedHash(t, Data)
})
}

// TestHeaderExchange verifies header exchange and synchronization between nodes in various network topologies.
Expand Down
6 changes: 4 additions & 2 deletions test/e2e/failover_e2e_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -268,7 +268,7 @@ func verifyNoDoubleSigning(t *testing.T, clusterNodes *raftClusterNodes, genesis
// verifyBlocks checks that DA block heights form a continuous sequence without gaps
func verifyBlocks(t *testing.T, daStartHeight, lastDABlock uint64, jwtSecret string, daAddress string, genesisHeight, lastEVBlock uint64) {
t.Helper()
client, err := jsonrpc.NewClient(t.Context(), zerolog.Nop(), daAddress, jwtSecret, 0, 1, 0)
client, err := jsonrpc.NewClient(t.Context(), zerolog.Nop(), daAddress, jwtSecret, defaultMaxBlobSize)
require.NoError(t, err)
defer client.Close()

Expand Down Expand Up @@ -448,13 +448,15 @@ func submitTxToURL(t *testing.T, client *ethclient.Client) (common.Hash, uint64)
return tx.Hash(), blk
}

const defaultMaxBlobSize = 2 * 1024 * 1024 // 2MB

func queryLastDAHeight(t *testing.T, startHeight uint64, jwtSecret string, daAddress string) uint64 {
t.Helper()
logger := zerolog.Nop()
if testing.Verbose() {
logger = zerolog.New(zerolog.NewTestWriter(t)).Level(zerolog.DebugLevel)
}
client, err := jsonrpc.NewClient(t.Context(), logger, daAddress, jwtSecret, 0, 1, 0)
client, err := jsonrpc.NewClient(t.Context(), logger, daAddress, jwtSecret, defaultMaxBlobSize)
require.NoError(t, err)
defer client.Close()
var lastDABlock = startHeight
Expand Down
3 changes: 2 additions & 1 deletion test/e2e/go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,7 @@ require (

replace (
github.com/evstack/ev-node => ../../
github.com/evstack/ev-node/da => ../../da
github.com/evstack/ev-node/execution/evm => ../../execution/evm
github.com/evstack/ev-node/execution/evm/test => ../../execution/evm/test
)
Expand Down Expand Up @@ -88,7 +89,7 @@ require (
github.com/ethereum/go-verkle v0.2.2 // indirect
github.com/felixge/httpsnoop v1.0.4 // indirect
github.com/ferranbt/fastssz v0.1.4 // indirect
github.com/filecoin-project/go-jsonrpc v0.8.0 // indirect
github.com/filecoin-project/go-jsonrpc v0.9.0 // indirect
github.com/fsnotify/fsnotify v1.9.0 // indirect
github.com/getsentry/sentry-go v0.27.0 // indirect
github.com/go-kit/kit v0.13.0 // indirect
Expand Down
6 changes: 2 additions & 4 deletions test/e2e/go.sum
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -200,8 +200,6 @@ github.com/ethereum/go-verkle v0.2.2 h1:I2W0WjnrFUIzzVPwm8ykY+7pL2d4VhlsePn4j7cn
github.com/ethereum/go-verkle v0.2.2/go.mod h1:M3b90YRnzqKyyzBEWJGqj8Qff4IDeXnzFw0P9bFw3uk=
github.com/evstack/ev-node/core v1.0.0-beta.5 h1:lgxE8XiF3U9pcFgh7xuKMgsOGvLBGRyd9kc9MR4WL0o=
github.com/evstack/ev-node/core v1.0.0-beta.5/go.mod h1:n2w/LhYQTPsi48m6lMj16YiIqsaQw6gxwjyJvR+B3sY=
github.com/evstack/ev-node/da v1.0.0-beta.4 h1:6W+UsQrsEdBbAnyy8j+lYNo2VQvJUaoSNkToMFThtVU=
github.com/evstack/ev-node/da v1.0.0-beta.4/go.mod h1:O3Lbx4/WFN0DIUOHdTihmyRnGmQwVXdswH19RW/KyG4=
github.com/fatih/color v1.16.0 h1:zmkK9Ngbjj+K0yRhTVONQh1p/HknKYSlNT+vZCzyokM=
github.com/fatih/color v1.16.0/go.mod h1:fL2Sau1YI5c0pdGEVCbKQbLXB6edEj1ZgiY4NijnWvE=
github.com/felixge/httpsnoop v1.0.4 h1:NFTV2Zj1bL4mc9sqWACXbQFVBBg2W3GPvqp8/ESS2Wg=
Expand All @@ -210,8 +208,8 @@ github.com/ferranbt/fastssz v0.1.4 h1:OCDB+dYDEQDvAgtAGnTSidK1Pe2tW3nFV40XyMkTeD
github.com/ferranbt/fastssz v0.1.4/go.mod h1:Ea3+oeoRGGLGm5shYAeDgu6PGUlcvQhE2fILyD9+tGg=
github.com/filecoin-project/go-clock v0.1.0 h1:SFbYIM75M8NnFm1yMHhN9Ahy3W5bEZV9gd6MPfXbKVU=
github.com/filecoin-project/go-clock v0.1.0/go.mod h1:4uB/O4PvOjlx1VCMdZ9MyDZXRm//gkj1ELEbxfI1AZs=
github.com/filecoin-project/go-jsonrpc v0.8.0 h1:2yqlN3Vd8Gx5UtA3fib7tQu2aW1cSOJt253LEBWExo4=
github.com/filecoin-project/go-jsonrpc v0.8.0/go.mod h1:p8WGOwQGYbFugSdK7qKIGhhb1VVcQ2rtBLdEiik1QWI=
github.com/filecoin-project/go-jsonrpc v0.9.0 h1:G47qEF52w7GholpI21vPSTVBFvsrip6geIoqNiqyZtQ=
github.com/filecoin-project/go-jsonrpc v0.9.0/go.mod h1:OG7kVBVh/AbDFHIwx7Kw0l9ARmKOS6gGOr0LbdBpbLc=
github.com/flynn/noise v1.1.0 h1:KjPQoQCEFdZDiP03phOvGi11+SVVhBG2wOWAorLsstg=
github.com/flynn/noise v1.1.0/go.mod h1:xbMo+0i6+IGbYdJhF31t2eR1BIU0CYc12+BNAKwUTag=
github.com/fortytw2/leaktest v1.3.0 h1:u8491cBMTQ8ft8aeV+adlcytMZylmA5nnwwkRZjI8vw=
Expand Down
Loading