Skip to content

Commit 9f8ef50

Browse files
authored
refactor(blobindexer): allow multiple indexers running concurrently, handle pruned node (#857)
BEDS-451
1 parent 267a0f9 commit 9f8ef50

File tree

9 files changed

+518
-346
lines changed

9 files changed

+518
-346
lines changed

backend/cmd/blobindexer/main.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ import (
1616
func Run() {
1717
fs := flag.NewFlagSet("fs", flag.ExitOnError)
1818

19-
configFlag := fs.String("config", "config.yml", "path to config")
19+
configFlag := fs.String("config", "", "path to config")
2020
versionFlag := fs.Bool("version", false, "print version and exit")
2121
_ = fs.Parse(os.Args[2:])
2222
if *versionFlag {

backend/go.mod

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@ require (
1414
github.com/attestantio/go-eth2-client v0.19.10
1515
github.com/awa/go-iap v1.26.5
1616
github.com/aws/aws-sdk-go-v2 v1.25.0
17+
github.com/aws/aws-sdk-go-v2/config v1.18.45
1718
github.com/aws/aws-sdk-go-v2/credentials v1.13.43
1819
github.com/aws/aws-sdk-go-v2/service/s3 v1.49.0
1920
github.com/bwmarrin/snowflake v0.3.0
@@ -99,13 +100,18 @@ require (
99100
github.com/alessio/shellescape v1.4.1 // indirect
100101
github.com/andybalholm/brotli v1.0.6 // indirect
101102
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.0 // indirect
103+
github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.13.13 // indirect
102104
github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.0 // indirect
103105
github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.0 // indirect
106+
github.com/aws/aws-sdk-go-v2/internal/ini v1.3.45 // indirect
104107
github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.0 // indirect
105108
github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.11.0 // indirect
106109
github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.3.0 // indirect
107110
github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.11.0 // indirect
108111
github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.17.0 // indirect
112+
github.com/aws/aws-sdk-go-v2/service/sso v1.15.2 // indirect
113+
github.com/aws/aws-sdk-go-v2/service/ssooidc v1.17.3 // indirect
114+
github.com/aws/aws-sdk-go-v2/service/sts v1.23.2 // indirect
109115
github.com/aws/smithy-go v1.20.0 // indirect
110116
github.com/bahlo/generic-list-go v0.2.0 // indirect
111117
github.com/beorn7/perks v1.0.1 // indirect
@@ -158,6 +164,7 @@ require (
158164
github.com/googleapis/gax-go/v2 v2.12.3 // indirect
159165
github.com/gorilla/securecookie v1.1.2 // indirect
160166
github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.1 // indirect
167+
github.com/hashicorp/golang-lru/v2 v2.0.7 // indirect
161168
github.com/herumi/bls-eth-go-binary v1.31.0 // indirect
162169
github.com/holiman/uint256 v1.2.4 // indirect
163170
github.com/huandu/go-clone v1.6.0 // indirect

backend/go.sum

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -73,15 +73,20 @@ github.com/aws/aws-sdk-go-v2 v1.25.0 h1:sv7+1JVJxOu/dD/sz/csHX7jFqmP001TIY7aytBW
7373
github.com/aws/aws-sdk-go-v2 v1.25.0/go.mod h1:G104G1Aho5WqF+SR3mDIobTABQzpYV0WxMsKxlMggOA=
7474
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.0 h1:2UO6/nT1lCZq1LqM67Oa4tdgP1CvL1sLSxvuD+VrOeE=
7575
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.0/go.mod h1:5zGj2eA85ClyedTDK+Whsu+w9yimnVIZvhvBKrDquM8=
76+
github.com/aws/aws-sdk-go-v2/config v1.18.45 h1:Aka9bI7n8ysuwPeFdm77nfbyHCAKQ3z9ghB3S/38zes=
77+
github.com/aws/aws-sdk-go-v2/config v1.18.45/go.mod h1:ZwDUgFnQgsazQTnWfeLWk5GjeqTQTL8lMkoE1UXzxdE=
7678
github.com/aws/aws-sdk-go-v2/credentials v1.13.43 h1:LU8vo40zBlo3R7bAvBVy/ku4nxGEyZe9N8MqAeFTzF8=
7779
github.com/aws/aws-sdk-go-v2/credentials v1.13.43/go.mod h1:zWJBz1Yf1ZtX5NGax9ZdNjhhI4rgjfgsyk6vTY1yfVg=
80+
github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.13.13 h1:PIktER+hwIG286DqXyvVENjgLTAwGgoeriLDD5C+YlQ=
7881
github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.13.13/go.mod h1:f/Ib/qYjhV2/qdsf79H3QP/eRE4AkVyEf6sk7XfZ1tg=
7982
github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.43/go.mod h1:auo+PiyLl0n1l8A0e8RIeR8tOzYPfZZH/JNlrJ8igTQ=
8083
github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.0 h1:NPs/EqVO+ajwOoq56EfcGKa3L3ruWuazkIw1BqxwOPw=
8184
github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.0/go.mod h1:D+duLy2ylgatV+yTlQ8JTuLfDD0BnFvnQRc+o6tbZ4M=
8285
github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.37/go.mod h1:Qe+2KtKml+FEsQF/DHmDV+xjtche/hwoF75EG4UlHW8=
8386
github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.0 h1:ks7KGMVUMoDzcxNWUlEdI+/lokMFD136EL6DWmUOV80=
8487
github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.0/go.mod h1:hL6BWM/d/qz113fVitZjbXR0E+RCTU1+x+1Idyn5NgE=
88+
github.com/aws/aws-sdk-go-v2/internal/ini v1.3.45 h1:hze8YsjSh8Wl1rYa1CJpRmXP21BvOBuc76YhW0HsuQ4=
89+
github.com/aws/aws-sdk-go-v2/internal/ini v1.3.45/go.mod h1:lD5M20o09/LCuQ2mE62Mb/iSdSlCNuj6H5ci7tW7OsE=
8590
github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.0 h1:TkbRExyKSVHELwG9gz2+gql37jjec2R5vus9faTomwE=
8691
github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.0/go.mod h1:T3/9xMKudHhnj8it5EqIrhvv11tVZqWYkKcot+BFStc=
8792
github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.11.0 h1:a33HuFlO0KsveiP90IUJh8Xr/cx9US2PqkSroaLc+o8=
@@ -95,8 +100,11 @@ github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.17.0 h1:l5puwOHr7IxECu
95100
github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.17.0/go.mod h1:Oov79flWa/n7Ni+lQC3z+VM7PoRM47omRqbJU9B5Y7E=
96101
github.com/aws/aws-sdk-go-v2/service/s3 v1.49.0 h1:VfU15izXQjz4m9y1DkbY79iylIiuPwWtrram4cSpWEI=
97102
github.com/aws/aws-sdk-go-v2/service/s3 v1.49.0/go.mod h1:1o/W6JFUuREj2ExoQ21vHJgO7wakvjhol91M9eknFgs=
103+
github.com/aws/aws-sdk-go-v2/service/sso v1.15.2 h1:JuPGc7IkOP4AaqcZSIcyqLpFSqBWK32rM9+a1g6u73k=
98104
github.com/aws/aws-sdk-go-v2/service/sso v1.15.2/go.mod h1:gsL4keucRCgW+xA85ALBpRFfdSLH4kHOVSnLMSuBECo=
105+
github.com/aws/aws-sdk-go-v2/service/ssooidc v1.17.3 h1:HFiiRkf1SdaAmV3/BHOFZ9DjFynPHj8G/UIO1lQS+fk=
99106
github.com/aws/aws-sdk-go-v2/service/ssooidc v1.17.3/go.mod h1:a7bHA82fyUXOm+ZSWKU6PIoBxrjSprdLoM8xPYvzYVg=
107+
github.com/aws/aws-sdk-go-v2/service/sts v1.23.2 h1:0BkLfgeDjfZnZ+MhB3ONb01u9pwFYTCZVhlsSSBvlbU=
100108
github.com/aws/aws-sdk-go-v2/service/sts v1.23.2/go.mod h1:Eows6e1uQEsc4ZaHANmsPRzAKcVDrcmjjWiih2+HUUQ=
101109
github.com/aws/smithy-go v1.15.0/go.mod h1:Tg+OJXh4MB2R/uN61Ko2f6hTZwB/ZYGOtib8J3gBHzA=
102110
github.com/aws/smithy-go v1.20.0 h1:6+kZsCXZwKxZS9RfISnPc4EXlHoyAkm2hPuM8X2BrrQ=
@@ -433,6 +441,8 @@ github.com/hashicorp/go-version v1.6.0 h1:feTTfFNnjP967rlCxM/I9g701jU+RN74YKx2mO
433441
github.com/hashicorp/go-version v1.6.0/go.mod h1:fltr4n8CU8Ke44wwGCBoEymUuxUHl09ZGVZPK5anwXA=
434442
github.com/hashicorp/golang-lru v1.0.2 h1:dV3g9Z/unq5DpblPpw+Oqcv4dU/1omnb4Ok8iPY6p1c=
435443
github.com/hashicorp/golang-lru v1.0.2/go.mod h1:iADmTwqILo4mZ8BN3D2Q6+9jd8WM5uGBxy+E8yxSoD4=
444+
github.com/hashicorp/golang-lru/v2 v2.0.7 h1:a+bsQ5rvGLjzHuww6tVxozPZFVghXaHOwFs4luLUK2k=
445+
github.com/hashicorp/golang-lru/v2 v2.0.7/go.mod h1:QeFd9opnmA6QUJc5vARoKUSoFhyfM2/ZepoAG6RGpeM=
436446
github.com/herumi/bls-eth-go-binary v1.31.0 h1:9eeW3EA4epCb7FIHt2luENpAW69MvKGL5jieHlBiP+w=
437447
github.com/herumi/bls-eth-go-binary v1.31.0/go.mod h1:luAnRm3OsMQeokhGzpYmc0ZKwawY7o87PUEP11Z7r7U=
438448
github.com/hokaccha/go-prettyjson v0.0.0-20211117102719-0474bc63780f h1:7LYC+Yfkj3CTRcShK0KOL/w6iTiKyqqBA9a41Wnggw8=

0 commit comments

Comments
 (0)