Validator Queue Consolidation Details

curl --request POST \
  --url https://beaconcha.in/api/v2/ethereum/validators/queues/consolidations \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "validator": {
    "validator_identifiers": [
      1
    ]
  },
  "chain": "mainnet",
  "cursor": "",
  "page_size": 10,
  "status_filter": "rejected",
  "role_filter": "target"
}
'

import requests

url = "https://beaconcha.in/api/v2/ethereum/validators/queues/consolidations"

payload = {
    "validator": { "validator_identifiers": [1] },
    "chain": "mainnet",
    "cursor": "",
    "page_size": 10,
    "status_filter": "rejected",
    "role_filter": "target"
}
headers = {
    "Authorization": "Bearer <token>",
    "Content-Type": "application/json"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'POST',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: JSON.stringify({
    validator: {validator_identifiers: [1]},
    chain: 'mainnet',
    cursor: '',
    page_size: 10,
    status_filter: 'rejected',
    role_filter: 'target'
  })
};

fetch('https://beaconcha.in/api/v2/ethereum/validators/queues/consolidations', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://beaconcha.in/api/v2/ethereum/validators/queues/consolidations",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_POSTFIELDS => json_encode([
    'validator' => [
        'validator_identifiers' => [
                1
        ]
    ],
    'chain' => 'mainnet',
    'cursor' => '',
    'page_size' => 10,
    'status_filter' => 'rejected',
    'role_filter' => 'target'
  ]),
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>",
    "Content-Type: application/json"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"strings"
	"net/http"
	"io"
)

func main() {

	url := "https://beaconcha.in/api/v2/ethereum/validators/queues/consolidations"

	payload := strings.NewReader("{\n  \"validator\": {\n    \"validator_identifiers\": [\n      1\n    ]\n  },\n  \"chain\": \"mainnet\",\n  \"cursor\": \"\",\n  \"page_size\": 10,\n  \"status_filter\": \"rejected\",\n  \"role_filter\": \"target\"\n}")

	req, _ := http.NewRequest("POST", url, payload)

	req.Header.Add("Authorization", "Bearer <token>")
	req.Header.Add("Content-Type", "application/json")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.post("https://beaconcha.in/api/v2/ethereum/validators/queues/consolidations")
  .header("Authorization", "Bearer <token>")
  .header("Content-Type", "application/json")
  .body("{\n  \"validator\": {\n    \"validator_identifiers\": [\n      1\n    ]\n  },\n  \"chain\": \"mainnet\",\n  \"cursor\": \"\",\n  \"page_size\": 10,\n  \"status_filter\": \"rejected\",\n  \"role_filter\": \"target\"\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://beaconcha.in/api/v2/ethereum/validators/queues/consolidations")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"validator\": {\n    \"validator_identifiers\": [\n      1\n    ]\n  },\n  \"chain\": \"mainnet\",\n  \"cursor\": \"\",\n  \"page_size\": 10,\n  \"status_filter\": \"rejected\",\n  \"role_filter\": \"target\"\n}"

response = http.request(request)
puts response.read_body

{
  "data": [
    {
      "source_validator": {
        "index": 1,
        "public_key": "<string>"
      },
      "target_validator": {
        "index": 1,
        "public_key": "<string>"
      },
      "status": "rejected",
      "execution_layer": {
        "tx_hash": "<string>",
        "from_address": "<string>"
      },
      "reject_reason": "source_inactive",
      "amount": "<string>",
      "source_exit_at": {
        "epoch": 1,
        "timestamp": 1
      },
      "estimated_processed_at": {
        "epoch": 1,
        "timestamp": 1
      },
      "processed_slot": 123
    }
  ],
  "paging": {
    "next_cursor": "<string>"
  }
}

{
  "error": "Bad request. Please check your input and try again."
}

{
  "error": "Unauthorized. Please provide a valid API key."
}

{
  "error": "endpoint not allowed for your subscription tier. upgrade your subscription at https://beaconcha.in/pricing."
}

{
  "error": "The requested resource was not found."
}

{
  "error": "method not allowed: GET. all public API endpoints use POST."
}

{
  "error": "Rate limit exceeded. Please try again later."
}

{
  "error": "internal server error. please try again later."
}

{
  "error": "An unexpected error occurred."
}

Consolidations

Validator Queue Consolidation Details

Returns a flat, paginated list of consolidation requests involving the selected validators, whether as source (balance being merged away) or as target (balance being received).

The response is not limited to requests that are still in flight: it covers the complete history of consolidations for the selected validators, back to the Pectra fork (7 May 2025). Pass status_filter: completed to retrieve only consolidations that have already settled.

Each entry pairs a source validator with a target validator. A single validator may appear in multiple entries across both roles. Use role_filter to keep only the entries where a selected validator is the source, or only those where it is the target — for example, to list every validator that was ever merged into a given target validator.

Which fields an entry carries depends on its status:

`status`	Fields set
`pending`	`execution_layer` — the submitting transaction
`queued`	`source_exit_at`, `estimated_processed_at`
`completed`	`amount`, `processed_slot`
`rejected`	`reject_reason`

A pending entry becomes queued once the consensus layer picks the request up out of the execution-layer contract, which releases at most two consolidation requests per block.

Pending and queued entries appear first, ordered by queue position (soonest processed first). Completed and rejected entries follow, ordered by submission time (most recent first).

Use status_filter to narrow the response to a single status, e.g. only rejected entries.

A rejected entry whose reject_reason is source_equals_target is not a failed consolidation — it is a failed switch to compounding credentials, which the consensus layer reports through the consolidation path because both requests share one contract and one structure. A common cause is asking a validator that already has 0x02 credentials to switch again. Use /api/v2/ethereum/validators/queues/compounding-switches to retrieve those entries as switches.

Use this endpoint in combination with the queue overview at /api/v2/ethereum/validators/queues for a complete picture.

Temporary restriction: the validator selector must resolve to no more than 50,000 validators. A larger selection returns 400. Narrow the selection — for example, select a sub-entity instead of a whole entity — or page through it with a set of validator indices. This limit will be raised.

POST

api

ethereum

validators

queues

consolidations

Validator Queue Consolidation Details

curl --request POST \
  --url https://beaconcha.in/api/v2/ethereum/validators/queues/consolidations \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "validator": {
    "validator_identifiers": [
      1
    ]
  },
  "chain": "mainnet",
  "cursor": "",
  "page_size": 10,
  "status_filter": "rejected",
  "role_filter": "target"
}
'

import requests

url = "https://beaconcha.in/api/v2/ethereum/validators/queues/consolidations"

payload = {
    "validator": { "validator_identifiers": [1] },
    "chain": "mainnet",
    "cursor": "",
    "page_size": 10,
    "status_filter": "rejected",
    "role_filter": "target"
}
headers = {
    "Authorization": "Bearer <token>",
    "Content-Type": "application/json"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'POST',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: JSON.stringify({
    validator: {validator_identifiers: [1]},
    chain: 'mainnet',
    cursor: '',
    page_size: 10,
    status_filter: 'rejected',
    role_filter: 'target'
  })
};

fetch('https://beaconcha.in/api/v2/ethereum/validators/queues/consolidations', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://beaconcha.in/api/v2/ethereum/validators/queues/consolidations",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_POSTFIELDS => json_encode([
    'validator' => [
        'validator_identifiers' => [
                1
        ]
    ],
    'chain' => 'mainnet',
    'cursor' => '',
    'page_size' => 10,
    'status_filter' => 'rejected',
    'role_filter' => 'target'
  ]),
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>",
    "Content-Type: application/json"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"strings"
	"net/http"
	"io"
)

func main() {

	url := "https://beaconcha.in/api/v2/ethereum/validators/queues/consolidations"

	payload := strings.NewReader("{\n  \"validator\": {\n    \"validator_identifiers\": [\n      1\n    ]\n  },\n  \"chain\": \"mainnet\",\n  \"cursor\": \"\",\n  \"page_size\": 10,\n  \"status_filter\": \"rejected\",\n  \"role_filter\": \"target\"\n}")

	req, _ := http.NewRequest("POST", url, payload)

	req.Header.Add("Authorization", "Bearer <token>")
	req.Header.Add("Content-Type", "application/json")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.post("https://beaconcha.in/api/v2/ethereum/validators/queues/consolidations")
  .header("Authorization", "Bearer <token>")
  .header("Content-Type", "application/json")
  .body("{\n  \"validator\": {\n    \"validator_identifiers\": [\n      1\n    ]\n  },\n  \"chain\": \"mainnet\",\n  \"cursor\": \"\",\n  \"page_size\": 10,\n  \"status_filter\": \"rejected\",\n  \"role_filter\": \"target\"\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://beaconcha.in/api/v2/ethereum/validators/queues/consolidations")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"validator\": {\n    \"validator_identifiers\": [\n      1\n    ]\n  },\n  \"chain\": \"mainnet\",\n  \"cursor\": \"\",\n  \"page_size\": 10,\n  \"status_filter\": \"rejected\",\n  \"role_filter\": \"target\"\n}"

response = http.request(request)
puts response.read_body

{
  "data": [
    {
      "source_validator": {
        "index": 1,
        "public_key": "<string>"
      },
      "target_validator": {
        "index": 1,
        "public_key": "<string>"
      },
      "status": "rejected",
      "execution_layer": {
        "tx_hash": "<string>",
        "from_address": "<string>"
      },
      "reject_reason": "source_inactive",
      "amount": "<string>",
      "source_exit_at": {
        "epoch": 1,
        "timestamp": 1
      },
      "estimated_processed_at": {
        "epoch": 1,
        "timestamp": 1
      },
      "processed_slot": 123
    }
  ],
  "paging": {
    "next_cursor": "<string>"
  }
}

{
  "error": "Bad request. Please check your input and try again."
}

{
  "error": "Unauthorized. Please provide a valid API key."
}

{
  "error": "endpoint not allowed for your subscription tier. upgrade your subscription at https://beaconcha.in/pricing."
}

{
  "error": "The requested resource was not found."
}

{
  "error": "method not allowed: GET. all public API endpoints use POST."
}

{
  "error": "Rate limit exceeded. Please try again later."
}

{
  "error": "internal server error. please try again later."
}

{
  "error": "An unexpected error occurred."
}

Authorizations

Authorization

string

header

required

Authorization header with value: Bearer YOUR_TOKEN. Refer to the API Keys section to create your API key.

Body

application/json

validator

Indices/Pubkeys · object

required

Free selectors available to all users:

validator_identifiers: One or more validator indices or public keys to filter by.
dashboard_id: Your beaconcha.in dashboard ID (requires a free account).

Premium selectors for Scale & Enterprise plans (https://beaconcha.in/pricing):

withdrawal: The validator's withdrawal credential or the Ethereum wallet address used for withdrawals.
deposit_address: The Ethereum wallet address used for the validator's deposit.
entity: The name of the assigned entity (e.g., "Lido", "Coinbase"). Optionally include sub_entity for more specific filtering. Matching is case-sensitive.

Note: The set of validators matched by deposit_address and withdrawal selectors is updated once per epoch (~6.4 minutes). Newly deposited validators may take up to one epoch to appear in query results.

Note: The set of validators matched by entity selector is updated once per day.

Indices/Pubkeys
Dashboard
💎 Deposit
💎 Withdrawal
💎 Entity

Show child attributes

chain

enum<string>

default:mainnet

The Ethereum chain to query.

Available options:

mainnet,

hoodi

cursor

string

default:""

Cursor value for pagination. See our pagination guide for more details.

page_size

integer

default:10

The number of items to return per page.

Required range: 1 <= x <= 10

status_filter

enum<string> | null

Filter results to a single consolidation status. If not specified, results include all statuses.

pending: recorded on the execution layer; not yet picked up by the consensus layer.
queued: included by the consensus layer; the source validator is exiting.
completed: balance sweep finalized.
rejected: rejected at consensus-layer inclusion.

Available options:

pending,

queued,

completed,

rejected

Example:

"rejected"

role_filter

enum<string> | null

Restrict results to the role the selected validators play in the consolidation. If not specified, a validator matches in either role.

source: only requests where a selected validator is the source — the validator that exits and whose balance is merged away.
target: only requests where a selected validator is the target — the validator that stays active and receives the balance.

A validator is usually only ever one or the other, because a source validator exits as part of the consolidation. Use this filter when you want that guarantee rather than checking source_validator and target_validator yourself, or to avoid paging through the other role's entries for a validator that has served in both.

Available options:

source,

target

Example:

"target"

Response

Successful response.

data

object[]

required

Show child attributes

paging

object

required

Show child attributes

Introduction

V2 API Docs

V1 API Docs

Validator Queue Consolidation Details

Authorizations

Body

Response