[codex] improve execution mimicry peering (#811)

* improve execution mimicry peering

* fix sentry smoke vector readiness

* tighten execution mimicry bootstrap config

* fix sentry smoke event assertions

* stabilize clickhouse smoke startup

* fix clickhouse smoke healthcheck

Author: samcm

.github/sentry/seeding.yaml

@@ -3,9 +3,10 @@
 # This config defines which event types to test in the sentry smoke test.
 # The test connects to a live beacon node and subscribes to real-time events.
 #
-# Only event types that fire frequently enough for CI assertions are included.
-# Events like finalized_checkpoint (~13 min interval) are subscribed to but
-# not gated on, since they're too slow for a smoke test.
+# Only event types that fire frequently and reliably enough for CI assertions
+# are included. Events like finalized_checkpoint and contribution_and_proof can
+# be observed by sentry, but are not gated on because their cadence/source is
+# too variable for a pull-request smoke test.
 #
 # The assertions verify that data flows through the entire pipeline:
 # Beacon Node -> Sentry -> Xatu Server -> Kafka -> Vector -> ClickHouse
@@ -22,10 +23,6 @@ event_types:
     table: beacon_api_eth_v1_events_block
     description: "Block events - most slots"
 
-  - name: BEACON_API_ETH_V1_EVENTS_ATTESTATION
+  - name: BEACON_API_ETH_V1_EVENTS_ATTESTATION_V2
     table: beacon_api_eth_v1_events_attestation
-    description: "Attestation events - many per slot"
-
-  - name: BEACON_API_ETH_V1_EVENTS_CONTRIBUTION_AND_PROOF
-    table: beacon_api_eth_v1_events_contribution_and_proof
-    description: "Sync committee contributions - multiple per slot"
+    description: "Single attestation events - many per slot"

.github/workflows/sentry-smoke-test.yaml

@@ -19,7 +19,7 @@ concurrency:
   cancel-in-progress: true
 jobs:
   sentry-smoke-test:
-    timeout-minutes: 15
+    timeout-minutes: 20
     runs-on: ubuntu-latest
     steps:
     - name: Checkout repository
@@ -90,7 +90,7 @@ jobs:
         chmod 666 deploy/local/docker-compose/sentry-logs/logs/geth.log
     - name: Run Xatu stack
       if: steps.canary.outputs.skip != 'true'
-      timeout-minutes: 7
+      timeout-minutes: 10
       run: |
         docker compose up --detach --quiet-pull
     - name: Wait for Xatu stack to be ready
@@ -117,15 +117,20 @@ jobs:
         # xatu-server forwards sentry-logs events to xatu-vector-http-kafka:9005.
         # Compose returns once the container is "Started", but Vector binds the
         # HTTP source ~1s later, racing with the inject step below.
-        # Probe via the host-mapped port (vector image is busybox, no /dev/tcp).
+        # Probe the actual HTTP source. The Docker port can accept TCP before
+        # Vector has finished binding the source, which drops the one-shot
+        # sentry-logs test batch.
         echo "Waiting for xatu-vector-http-kafka to accept HTTP on host :9055..."
         for i in $(seq 1 30); do
-          if bash -c 'echo > /dev/tcp/localhost/9055' 2>/dev/null; then
+          if printf '{"event":{"name":"XATU_SMOKE_READY_PROBE"}}\n' | curl --fail --silent --show-error --max-time 2 \
+            -H 'Content-Type: application/x-ndjson' \
+            --data-binary @- \
+            http://127.0.0.1:9055 >/dev/null; then
             echo "xatu-vector-http-kafka is listening."
             break
           fi
           if [ "$i" -eq 30 ]; then
-            echo "::error::xatu-vector-http-kafka failed to bind :9005"
+            echo "::error::xatu-vector-http-kafka failed to accept HTTP on host :9055"
             docker logs xatu-vector-http-kafka 2>&1 | tail -50
             exit 1
           fi
@@ -178,8 +183,7 @@ jobs:
           beaconSubscriptions:
           - head
           - block
-          - attestation
-          - contribution_and_proof
+          - single_attestation
           - finalized_checkpoint
 
         beaconCommittees:

docker-compose.yml

@@ -28,12 +28,12 @@ services:
       test:
         [
           "CMD-SHELL",
-          "set -x; wget --spider --quiet http://xatu-clickhouse-01:9000 || exit 1; wget --spider --quiet --header 'Host: localhost' --post-data 'query=SELECT 1' http://localhost:8123 || exit 1",
+          "set -x; clickhouse client --host xatu-clickhouse-01 --port 9000 --query 'SELECT 1' || exit 1; wget --quiet --output-document=/dev/null http://xatu-clickhouse-01:8123/ping || exit 1",
         ]
       interval: 5s
       timeout: 10s
-      retries: 15
-      start_period: 15s
+      retries: 30
+      start_period: 120s
     environment:
       - CLICKHOUSE_DEFAULT_ACCESS_MANAGEMENT=1
       - CLICKHOUSE_USER=default
@@ -68,12 +68,12 @@ services:
       test:
         [
           "CMD-SHELL",
-          "set -x; wget --spider --quiet http://xatu-clickhouse-02:9000 || exit 1; wget --spider --quiet --header 'Host: localhost' --post-data 'query=SELECT 1' http://localhost:8123 || exit 1",
+          "set -x; clickhouse client --host xatu-clickhouse-02 --port 9000 --query 'SELECT 1' || exit 1; wget --quiet --output-document=/dev/null http://xatu-clickhouse-02:8123/ping || exit 1",
         ]
       interval: 5s
       timeout: 10s
-      retries: 15
-      start_period: 15s
+      retries: 30
+      start_period: 120s
     environment:
       - CLICKHOUSE_DEFAULT_ACCESS_MANAGEMENT=1
       - CLICKHOUSE_USER=default

docs/mimicry.md

@@ -46,6 +46,10 @@ Mimicry requires a single `yaml` config file. An example file can be found [here
 | labels | object |  | A key value map of labels to append to every mimicry event                                                                         |
 | ntpServer | string | `pool.ntp.org` | NTP server to calculate clock drift for events                                                                                     |
 | captureDelay | string | `3m` | Delay before starting to capture transactions                                                                                      |
+| ethereum.bootstrapRpcUrl | string |  | Optional mainnet, Sepolia, or Holesky execution JSON-RPC endpoint used to build local `eth` Status and answer block data requests  |
+| ethereum.privateKey | string |  | Optional hex devp2p node private key. If omitted, mimicry reuses one generated process-local identity for all execution peers       |
+| ethereum.blobTransactionBatchSize | int | `1` | Number of blob transactions to request at a time via `GetPooledTransactions`                                                       |
+| ethereum.transactionBatchSize | int | `10` | Number of non-blob transactions to request at a time via `GetPooledTransactions`                                                   |
 | coordinator.type | string |  | Type of output (`xatu`, `static`)                                                                                                  |
 | coordinator.config | object |  | Coordinator type configuration [`xatu`](#coordinator-xatu-configuration)/[`static`](#coordinator-static-configuration)             |
 | outputs | array<object> |  | List of outputs for the mimicry to send data to                                                                                    |
@@ -74,6 +78,7 @@ Coordinator configuration to statically specify peers to connect to.
 | Name| Type | Default | Description |
 | --- | --- | --- | --- |
 | coordinator.config.retryInterval | string |  | Interval between trying to connect to a peer |
+| coordinator.config.maxConcurrentPeers | int | `0` | Maximum number of in-flight and active peer connections. `0` means unlimited |
 | coordinator.config.nodeRecords | array<string> |  | List of ENR/ENode peers to connect to |
 
 ### Output `xatu` configuration
@@ -150,6 +155,7 @@ coordinator:
   type: static
   config:
     retryInterval: 60s
+    maxConcurrentPeers: 100
     nodeRecords:
       - enr:-IS4QHCYrYZbAKWCBRlAy5zzaDZXJBGkcnh4MHcBFZntXNFrdvJjX04jRzjzCBOonrkTfj499SZuOh8R33Ls8RRcy5wBgmlkgnY0gmlwhH8AAAGJc2VjcDI1NmsxoQPKY0yuDUmstAHYpMa2_oxVtw0RW_QAdpzBQA8yWM0xOIN1ZHCCdl8
 

example_mimicry.yaml

@@ -22,13 +22,16 @@ captureDelay: 3m
 
 # ethereum:
 #   overrideNetworkName: devnet
+#   bootstrapRpcUrl: http://localhost:8545 # Optional mainnet/Sepolia/Holesky EL RPC used to build Status and answer block data requests.
+#   privateKey: "" # Optional hex devp2p node key. If omitted, one process-local identity is reused.
 #   blobTransactionBatchSize: 1  # Number of blob txns to request at a time (default: 1)
 #   transactionBatchSize: 10     # Number of other txns to request at a time (default: 10)
 
 coordinator:
   type: static
   config:
     retryInterval: 60s
+    maxConcurrentPeers: 0 # Optional. 0 means unlimited.
     # can be ENR or ENODE format
     nodeRecords:
       - enr:-IS4QHCYrYZbAKWCBRlAy5zzaDZXJBGkcnh4MHcBFZntXNFrdvJjX04jRzjzCBOonrkTfj499SZuOh8R33Ls8RRcy5wBgmlkgnY0gmlwhH8AAAGJc2VjcDI1NmsxoQPKY0yuDUmstAHYpMa2_oxVtw0RW_QAdpzBQA8yWM0xOIN1ZHCCdl8

go.mod

@@ -17,9 +17,9 @@ require (
 	github.com/cenkalti/backoff/v5 v5.0.3
 	github.com/chuckpreslar/emission v0.0.0-20170206194824-a7ddd980baf9
 	github.com/creasty/defaults v1.8.0
-	github.com/ethereum/go-ethereum v1.17.0
+	github.com/ethereum/go-ethereum v1.17.1
 	github.com/ethpandaops/beacon v0.65.0
-	github.com/ethpandaops/ethcore v0.0.0-20260225041126-afac0c250cdf
+	github.com/ethpandaops/ethcore v0.0.0-20260506100832-68848ea0ddaa
 	github.com/ethpandaops/ethwallclock v0.4.0
 	github.com/failsafe-go/failsafe-go v0.9.6
 	github.com/ferranbt/fastssz v1.0.0
@@ -114,7 +114,7 @@ require (
 	github.com/eapache/queue v1.1.0 // indirect
 	github.com/ebitengine/purego v0.8.4 // indirect
 	github.com/emicklei/dot v1.9.0 // indirect
-	github.com/ethereum/c-kzg-4844/v2 v2.1.5 // indirect
+	github.com/ethereum/c-kzg-4844/v2 v2.1.6 // indirect
 	github.com/ethereum/go-bigmodexpfix v0.0.0-20250911101455-f9e208c548ab // indirect
 	github.com/fatih/color v1.18.0 // indirect
 	github.com/felixge/httpsnoop v1.0.4 // indirect
@@ -268,7 +268,7 @@ require (
 	github.com/spaolacci/murmur3 v1.1.0 // indirect
 	github.com/spf13/cast v1.10.0 // indirect
 	github.com/spf13/pflag v1.0.10 // indirect
-	github.com/supranational/blst v0.3.16-0.20250831170142-f48500c1fdbe // indirect
+	github.com/supranational/blst v0.3.16 // indirect
 	github.com/syndtr/goleveldb v1.0.1-0.20220721030215-126854af5e6d // indirect
 	github.com/thomaso-mirodin/intmath v0.0.0-20160323211736-5dc6d854e46e // indirect
 	github.com/tilinna/z85 v1.0.0 // indirect

go.sum

@@ -133,6 +133,8 @@ github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1
 github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davidlazar/go-crypto v0.0.0-20200604182044-b73af7476f6c h1:pFUpOrbxDR6AkioZ1ySsx5yxlDQZ8stG2b88gTPxgJU=
 github.com/davidlazar/go-crypto v0.0.0-20200604182044-b73af7476f6c/go.mod h1:6UhI8N9EjYm1c2odKpFpAYeR8dsBeM7PtzQhRgxRr9U=
+github.com/dchest/siphash v1.2.3 h1:QXwFc8cFOR2dSa/gE6o/HokBMWtLUaNDVd+22aKHeEA=
+github.com/dchest/siphash v1.2.3/go.mod h1:0NvQU092bT0ipiFN++/rXm69QG9tVxLAlQHIXMPAkHc=
 github.com/deckarep/golang-set/v2 v2.8.0 h1:swm0rlPCmdWn9mESxKOjWk8hXSqoxOp+ZlfuyaAdFlQ=
 github.com/deckarep/golang-set/v2 v2.8.0/go.mod h1:VAky9rY/yGXJOLEDv3OMci+7wtDpOF4IN+y82NBOac4=
 github.com/decred/dcrd/crypto/blake256 v1.1.0 h1:zPMNGQCm0g4QTY27fOCorQW7EryeQ/U0x++OzVrdms8=
@@ -171,16 +173,16 @@ github.com/emicklei/dot v1.9.0 h1:FyaJNctdMfaEIbTQ1FkKZ1UCZyJJSkyvkrXOVoNZPKU=
 github.com/emicklei/dot v1.9.0/go.mod h1:DeV7GvQtIw4h2u73RKBkkFdvVAz0D9fzeJrgPW6gy/s=
 github.com/emicklei/proto v1.14.2 h1:wJPxPy2Xifja9cEMrcA/g08art5+7CGJNFNk35iXC1I=
 github.com/emicklei/proto v1.14.2/go.mod h1:rn1FgRS/FANiZdD2djyH7TMA9jdRDcYQ9IEN9yvjX0A=
-github.com/ethereum/c-kzg-4844/v2 v2.1.5 h1:aVtoLK5xwJ6c5RiqO8g8ptJ5KU+2Hdquf6G3aXiHh5s=
-github.com/ethereum/c-kzg-4844/v2 v2.1.5/go.mod h1:u59hRTTah4Co6i9fDWtiCjTrblJv0UwsqZKCc0GfgUs=
+github.com/ethereum/c-kzg-4844/v2 v2.1.6 h1:xQymkKCT5E2Jiaoqf3v4wsNgjZLY0lRSkZn27fRjSls=
+github.com/ethereum/c-kzg-4844/v2 v2.1.6/go.mod h1:8HMkUZ5JRv4hpw/XUrYWSQNAUzhHMg2UDb/U+5m+XNw=
 github.com/ethereum/go-bigmodexpfix v0.0.0-20250911101455-f9e208c548ab h1:rvv6MJhy07IMfEKuARQ9TKojGqLVNxQajaXEp/BoqSk=
 github.com/ethereum/go-bigmodexpfix v0.0.0-20250911101455-f9e208c548ab/go.mod h1:IuLm4IsPipXKF7CW5Lzf68PIbZ5yl7FFd74l/E0o9A8=
-github.com/ethereum/go-ethereum v1.17.0 h1:2D+1Fe23CwZ5tQoAS5DfwKFNI1HGcTwi65/kRlAVxes=
-github.com/ethereum/go-ethereum v1.17.0/go.mod h1:2W3msvdosS/MCWytpqTcqgFiRYbTH59FxDJzqah120o=
+github.com/ethereum/go-ethereum v1.17.1 h1:IjlQDjgxg2uL+GzPRkygGULPMLzcYWncEI7wbaizvho=
+github.com/ethereum/go-ethereum v1.17.1/go.mod h1:7UWOVHL7K3b8RfVRea022btnzLCaanwHtBuH1jUCH/I=
 github.com/ethpandaops/beacon v0.65.0 h1:ssnab73uiuzhmhtU56q9D3ecVrEYv5n+tuqrXRK4YAg=
 github.com/ethpandaops/beacon v0.65.0/go.mod h1:lgzrJjQVV77wZ+PJymsY3bQbAK4jrtP8n3WOwMf1Pcs=
-github.com/ethpandaops/ethcore v0.0.0-20260225041126-afac0c250cdf h1:8tgE9iUsf9TyruUT3MXVjUlMy5aEc+fuzraRyPlUbBU=
-github.com/ethpandaops/ethcore v0.0.0-20260225041126-afac0c250cdf/go.mod h1:NblaW7ZBfBA85g9SsJyiDzeecTgvxMnFZTWUAj40vg8=
+github.com/ethpandaops/ethcore v0.0.0-20260506100832-68848ea0ddaa h1:DBdUJ+zYX7wgH5auHX8uJu/7f5NS+YkKRBA3TWaT4KY=
+github.com/ethpandaops/ethcore v0.0.0-20260506100832-68848ea0ddaa/go.mod h1:QsmYTdesob+vQ6pW4KtRVvxLZUNop3cdtd/DgD30hJU=
 github.com/ethpandaops/ethereum-package-go v0.8.1 h1:VN5l8UXveyw7gp0Glj8BRzS/D5RKyvhLeaoi/C5Jy5M=
 github.com/ethpandaops/ethereum-package-go v0.8.1/go.mod h1:LQThCwlCeeNBTdXOFV+xSwudoced53x+o/Orya3Y+oo=
 github.com/ethpandaops/ethwallclock v0.4.0 h1:+sgnhf4pk6hLPukP076VxkiLloE4L0Yk1yat+ZyHh1g=
@@ -252,6 +254,8 @@ github.com/gofrs/uuid/v5 v5.4.0 h1:EfbpCTjqMuGyq5ZJwxqzn3Cbr2d0rUZU7v5ycAk/e/0=
 github.com/gofrs/uuid/v5 v5.4.0/go.mod h1:CDOjlDMVAtN56jqyRUZh58JT31Tiw7/oQyEXZV+9bD8=
 github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q=
 github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q=
+github.com/golang-jwt/jwt/v4 v4.5.2 h1:YtQM7lnr8iZ+j5q71MGKkNw9Mn7AjHM68uc9g5fXeUI=
+github.com/golang-jwt/jwt/v4 v4.5.2/go.mod h1:m21LjoU+eqJr34lmDMbreY2eSTRJ1cv77w39/MY0Ch0=
 github.com/golang-jwt/jwt/v5 v5.3.0 h1:pv4AsKCKKZuqlgs5sUmn4x8UlGa0kEVt/puTpKx9vvo=
 github.com/golang-jwt/jwt/v5 v5.3.0/go.mod h1:fxCRLWMO43lRc8nhHWY6LGqRcf+1gQWArsqaEUEa5bE=
 github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
@@ -295,6 +299,10 @@ github.com/gorilla/websocket v1.5.4-0.20250319132907-e064f32e3674 h1:JeSE6pjso5T
 github.com/gorilla/websocket v1.5.4-0.20250319132907-e064f32e3674/go.mod h1:r4w70xmWCQKmi1ONH4KIaBptdivuRPyosB9RmPlGEwA=
 github.com/govalues/decimal v0.1.36 h1:dojDpsSvrk0ndAx8+saW5h9WDIHdWpIwrH/yhl9olyU=
 github.com/govalues/decimal v0.1.36/go.mod h1:Ee7eI3Llf7hfqDZtpj8Q6NCIgJy1iY3kH1pSwDrNqlM=
+github.com/grafana/pyroscope-go v1.2.7 h1:VWBBlqxjyR0Cwk2W6UrE8CdcdD80GOFNutj0Kb1T8ac=
+github.com/grafana/pyroscope-go v1.2.7/go.mod h1:o/bpSLiJYYP6HQtvcoVKiE9s5RiNgjYTj1DhiddP2Pc=
+github.com/grafana/pyroscope-go/godeltaprof v0.1.9 h1:c1Us8i6eSmkW+Ez05d3co8kasnuOY813tbMN8i/a3Og=
+github.com/grafana/pyroscope-go/godeltaprof v0.1.9/go.mod h1:2+l7K7twW49Ct4wFluZD3tZ6e0SjanjcUUBPVD/UuGU=
 github.com/grpc-ecosystem/go-grpc-middleware/v2 v2.3.2 h1:sGm2vDRFUrQJO/Veii4h4zG2vvqG6uWNkBHSTqXOZk0=
 github.com/grpc-ecosystem/go-grpc-middleware/v2 v2.3.2/go.mod h1:wd1YpapPLivG6nQgbf7ZkG1hhSOXDhhn4MLTknx2aAc=
 github.com/grpc-ecosystem/go-grpc-prometheus v1.2.0 h1:Ovs26xHkKqVztRpIrF/92BcuyuQ/YW4NSIpoGtfXNho=
@@ -306,6 +314,8 @@ github.com/hamba/avro/v2 v2.30.0/go.mod h1:X6gDhYv6DQVAT56VqOKuW+PLnQrEQqGB9l1nh
 github.com/hashicorp/errwrap v1.0.0/go.mod h1:YH+1FKiLXxHSkmPseP+kNlulaMuP3n2brvKWEqk/Jc4=
 github.com/hashicorp/errwrap v1.1.0 h1:OxrOeh75EUXMY8TBjag2fzXGZ40LB6IKw45YeGUDY2I=
 github.com/hashicorp/errwrap v1.1.0/go.mod h1:YH+1FKiLXxHSkmPseP+kNlulaMuP3n2brvKWEqk/Jc4=
+github.com/hashicorp/go-bexpr v0.1.10 h1:9kuI5PFotCboP3dkDYFr/wi0gg0QVbSNz5oFRpxn4uE=
+github.com/hashicorp/go-bexpr v0.1.10/go.mod h1:oxlubA2vC/gFVfX1A6JGp7ls7uCDlfJn732ehYYg+g0=
 github.com/hashicorp/go-multierror v1.1.1 h1:H5DkEtf6CXdFp0N0Em5UCwQpXMWke8IA0+lD48awMYo=
 github.com/hashicorp/go-multierror v1.1.1/go.mod h1:iw975J/qwKPdAO1clOe2L8331t/9/fmwbPZ6JB6eMoM=
 github.com/hashicorp/go-uuid v1.0.2/go.mod h1:6SBZvOh/SIDV7/2o3Jml5SYk/TvGqwFJ/bN7x4byOro=
@@ -500,6 +510,8 @@ github.com/mitchellh/hashstructure/v2 v2.0.2 h1:vGKWl0YJqUNxE8d+h8f6NJLcCJrgbhC4
 github.com/mitchellh/hashstructure/v2 v2.0.2/go.mod h1:MG3aRVU/N29oo/V/IhBX8GR/zz4kQkprJgF2EVszyDE=
 github.com/mitchellh/mapstructure v1.5.0 h1:jeMsZIYE/09sWLaz43PL7Gy6RuMjD2eJVyuac5Z2hdY=
 github.com/mitchellh/mapstructure v1.5.0/go.mod h1:bFUtVrKA4DC2yAKiSyO/QUcy7e+RRV2QTWOzhPopBRo=
+github.com/mitchellh/pointerstructure v1.2.0 h1:O+i9nHnXS3l/9Wu7r4NrEdwA2VFTicjUEN1uBnDo34A=
+github.com/mitchellh/pointerstructure v1.2.0/go.mod h1:BRAsLI5zgXmw97Lf6s25bs8ohIXc3tViBH44KcwB2g4=
 github.com/moby/docker-image-spec v1.3.1 h1:jMKff3w6PgbfSa69GfNg+zN/XLhfXJGnEx3Nl2EsFP0=
 github.com/moby/docker-image-spec v1.3.1/go.mod h1:eKmb5VW8vQEh/BAr2yvVNvuiJuY6UIocYsFu/DxxRpo=
 github.com/moby/go-archive v0.1.0 h1:Kk/5rdW/g+H8NHdJW2gsXyZ7UnzvJNOy6VKJqueWdcQ=
@@ -707,6 +719,8 @@ github.com/rogpeppe/go-internal v1.6.1/go.mod h1:xXDCJY+GAPziupqXw64V24skbSoqbTE
 github.com/rogpeppe/go-internal v1.8.1/go.mod h1:JeRgkft04UBgHMgCIwADu4Pn6Mtm5d4nPKWu0nJ5d+o=
 github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ=
 github.com/rogpeppe/go-internal v1.14.1/go.mod h1:MaRKkUm5W0goXpeCfT7UZI6fk/L7L7so1lCWt35ZSgc=
+github.com/rs/cors v1.7.0 h1:+88SsELBHx5r+hZ8TCkggzSstaWNbDvThkVK8H6f9ik=
+github.com/rs/cors v1.7.0/go.mod h1:gFx+x8UowdsKA9AchylcLynDq+nNFfI8FkUZdN/jGCU=
 github.com/rs/xid v1.6.0/go.mod h1:7XoLgs4eV+QndskICGsho+ADou8ySMSjJKDIan90Nz0=
 github.com/rs/zerolog v1.34.0 h1:k43nTLIwcTVQAncfCw4KZ2VY6ukYoZaBPNOE8txlOeY=
 github.com/rs/zerolog v1.34.0/go.mod h1:bJsvje4Z08ROH4Nhs5iH600c3IkWhwp44iRc54W6wYQ=
@@ -754,8 +768,8 @@ github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu
 github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
 github.com/stvp/tempredis v0.0.0-20181119212430-b82af8480203 h1:QVqDTf3h2WHt08YuiTGPZLls0Wq99X9bWd0Q5ZSBesM=
 github.com/stvp/tempredis v0.0.0-20181119212430-b82af8480203/go.mod h1:oqN97ltKNihBbwlX8dLpwxCl3+HnXKV/R0e+sRLd9C8=
-github.com/supranational/blst v0.3.16-0.20250831170142-f48500c1fdbe h1:nbdqkIGOGfUAD54q1s2YBcBz/WcsxCO9HUQ4aGV5hUw=
-github.com/supranational/blst v0.3.16-0.20250831170142-f48500c1fdbe/go.mod h1:jZJtfjgudtNl4en1tzwPIV3KjUnQUvG3/j+w+fVonLw=
+github.com/supranational/blst v0.3.16 h1:bTDadT+3fK497EvLdWRQEjiGnUtzJ7jjIUMF0jqwYhE=
+github.com/supranational/blst v0.3.16/go.mod h1:jZJtfjgudtNl4en1tzwPIV3KjUnQUvG3/j+w+fVonLw=
 github.com/syndtr/goleveldb v1.0.1-0.20220721030215-126854af5e6d h1:vfofYNRScrDdvS342BElfbETmL1Aiz3i2t0zfRj16Hs=
 github.com/syndtr/goleveldb v1.0.1-0.20220721030215-126854af5e6d/go.mod h1:RRCYJbIwD5jmqPI9XoAFR0OcDxqUctll6zUj/+B4S48=
 github.com/testcontainers/testcontainers-go v0.40.0 h1:pSdJYLOVgLE8YdUY2FHQ1Fxu+aMnb6JfVz1mxk7OeMU=

pkg/mimicry/coordinator/static/config.go

@@ -6,14 +6,19 @@ import (
 )
 
 type Config struct {
-	RetryInterval time.Duration `yaml:"retryInterval" default:"60s"`
-	NodeRecords   []string      `yaml:"nodeRecords"`
+	RetryInterval      time.Duration `yaml:"retryInterval" default:"60s"`
+	MaxConcurrentPeers int           `yaml:"maxConcurrentPeers" default:"0"`
+	NodeRecords        []string      `yaml:"nodeRecords"`
 }
 
 func (c *Config) Validate() error {
 	if len(c.NodeRecords) == 0 {
 		return errors.New("nodeRecords is required")
 	}
 
+	if c.MaxConcurrentPeers < 0 {
+		return errors.New("maxConcurrentPeers cannot be negative")
+	}
+
 	return nil
 }

pkg/mimicry/coordinator/static/config_test.go

@@ -0,0 +1,16 @@
+package static
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/require"
+)
+
+func TestConfigValidateRejectsNegativeMaxConcurrentPeers(t *testing.T) {
+	cfg := &Config{
+		NodeRecords:        []string{"enr:test"},
+		MaxConcurrentPeers: -1,
+	}
+
+	require.ErrorContains(t, cfg.Validate(), "maxConcurrentPeers")
+}