\n",
+ "| Connection distribution |
|---|
\n",
+ "| TCP connections | {tcp_pct:.1f}% |
\n",
+ "| QUIC connections | {quic_pct:.1f}% |
\n",
+ "| Unique peer breakdown |
|---|
\n",
+ "| TCP-only peers | {tcp_only_peers:,} ({tcp_only_peers/total_peers*100:.1f}%) |
\n",
+ "| QUIC-only peers | {quic_only_peers:,} ({quic_only_peers/total_peers*100:.1f}%) |
\n",
+ "| Dual-protocol peers | {both_peers:,} ({both_peers/total_peers*100:.1f}%) |
\n",
+ "| Total unique peers | {total_peers:,} |
\n",
+ "| Client QUIC support |
|---|
\n",
+ "| Significant QUIC support (>10%) | {\", \".join(quic_clients) or \"None\"} |
\n",
+ "| No QUIC support (<1%) | {\", \".join(no_quic_clients) or \"None\"} |
\n",
+ "
\n",
+ "'''\n",
+ "\n",
+ "display(HTML(html))"
+ ]
+ }
+ ],
+ "metadata": {
+ "kernelspec": {
+ "display_name": "Python 3",
+ "language": "python",
+ "name": "python3"
+ },
+ "language_info": {
+ "name": "python",
+ "version": "3.12.0"
+ }
+ },
+ "nbformat": 4,
+ "nbformat_minor": 5
+}
diff --git a/pipeline.yaml b/pipeline.yaml
index 128ee29..7e883dd 100644
--- a/pipeline.yaml
+++ b/pipeline.yaml
@@ -119,6 +119,36 @@ queries:
description: Block propagation by geographic region from Contributoor nodes
output_file: block_propagation_by_region_contributoor.parquet
+ transport_overall:
+ module: queries.transport_protocols
+ function: fetch_transport_overall
+ description: Overall QUIC vs TCP transport protocol distribution (7-day rolling)
+ output_file: transport_overall.parquet
+
+ transport_daily:
+ module: queries.transport_protocols
+ function: fetch_transport_daily
+ description: Daily transport protocol breakdown (7-day rolling)
+ output_file: transport_daily.parquet
+
+ transport_peers:
+ module: queries.transport_protocols
+ function: fetch_transport_peers
+ description: Unique peer breakdown by transport capability (7-day rolling)
+ output_file: transport_peers.parquet
+
+ transport_by_client:
+ module: queries.transport_protocols
+ function: fetch_transport_by_client
+ description: Transport protocol adoption by client implementation (7-day rolling)
+ output_file: transport_by_client.parquet
+
+ transport_connection_patterns:
+ module: queries.transport_protocols
+ function: fetch_transport_connection_patterns
+ description: Connection frequency patterns by transport protocol (7-day rolling)
+ output_file: transport_connection_patterns.parquet
+
# ============================================
# Notebook Registry
# ============================================
@@ -258,6 +288,24 @@ notebooks:
required: true
order: 9
+ - id: transport-protocols
+ title: Transport protocols
+ description: QUIC vs TCP transport protocol distribution across the P2P network by client
+ icon: Network
+ source: notebooks/10-transport-protocols.ipynb
+ schedule: daily
+ queries:
+ - transport_overall
+ - transport_daily
+ - transport_peers
+ - transport_by_client
+ - transport_connection_patterns
+ parameters:
+ - name: target_date
+ type: date
+ required: true
+ order: 10
+
# Schedule options: hourly, daily, weekly, manual
# - hourly: Runs every hour, accumulating data throughout the day
# - daily: Runs once per day at 1am UTC
diff --git a/queries/transport_protocols.py b/queries/transport_protocols.py
new file mode 100644
index 0000000..7adbd4c
--- /dev/null
+++ b/queries/transport_protocols.py
@@ -0,0 +1,168 @@
+"""Fetch functions for transport protocol (QUIC vs TCP) analysis.
+
+Queries the libp2p_connected table from Xatu sentries to analyze
+transport protocol distribution across the Ethereum P2P network.
+"""
+
+from __future__ import annotations
+
+
+def _get_lookback_filter(target_date: str, days: int = 7) -> str:
+ """Generate SQL filter for N days ending on target_date (inclusive)."""
+ return (
+ f"event_date_time >= '{target_date}'::date - INTERVAL {days - 1} DAY "
+ f"AND event_date_time < '{target_date}'::date + INTERVAL 1 DAY"
+ )
+
+
+def fetch_transport_overall(
+ client,
+ target_date: str,
+ network: str = "mainnet",
+) -> tuple:
+ """Fetch overall transport protocol distribution.
+
+ Returns 7-day rolling stats as of target_date.
+ """
+ date_filter = _get_lookback_filter(target_date, days=7)
+
+ query = f"""
+SELECT
+ remote_transport_protocol as transport,
+ count(*) as connections,
+ round(count(*) * 100.0 / sum(count(*)) OVER (), 2) as percentage
+FROM default.libp2p_connected
+WHERE meta_network_name = '{network}'
+ AND {date_filter}
+GROUP BY remote_transport_protocol
+ORDER BY connections DESC
+"""
+
+ df = client.query_df(query)
+ return df, query
+
+
+def fetch_transport_daily(
+ client,
+ target_date: str,
+ network: str = "mainnet",
+) -> tuple:
+ """Fetch daily transport protocol breakdown.
+
+ Returns daily stats for 7 days ending on target_date.
+ """
+ date_filter = _get_lookback_filter(target_date, days=7)
+
+ query = f"""
+SELECT
+ toDate(event_date_time) as date,
+ remote_transport_protocol as transport,
+ count(*) as connections,
+ uniqExact(remote_peer_id_unique_key) as unique_peers
+FROM default.libp2p_connected
+WHERE meta_network_name = '{network}'
+ AND {date_filter}
+GROUP BY date, transport
+ORDER BY date, transport
+"""
+
+ df = client.query_df(query)
+ return df, query
+
+
+def fetch_transport_peers(
+ client,
+ target_date: str,
+ network: str = "mainnet",
+) -> tuple:
+ """Fetch unique peer breakdown by transport protocol capability.
+
+ Categorizes peers as TCP-only, QUIC-only, or supporting both.
+ """
+ date_filter = _get_lookback_filter(target_date, days=7)
+
+ query = f"""
+WITH peer_protocols AS (
+ SELECT
+ remote_peer_id_unique_key,
+ groupUniqArray(remote_transport_protocol) as protocols
+ FROM default.libp2p_connected
+ WHERE meta_network_name = '{network}'
+ AND {date_filter}
+ GROUP BY remote_peer_id_unique_key
+)
+SELECT
+ countIf(has(protocols, 'tcp') AND NOT has(protocols, 'udp')) as tcp_only,
+ countIf(has(protocols, 'udp') AND NOT has(protocols, 'tcp')) as quic_only,
+ countIf(has(protocols, 'tcp') AND has(protocols, 'udp')) as both,
+ count(*) as total
+FROM peer_protocols
+"""
+
+ df = client.query_df(query)
+ return df, query
+
+
+def fetch_transport_by_client(
+ client,
+ target_date: str,
+ network: str = "mainnet",
+) -> tuple:
+ """Fetch transport protocol breakdown by client implementation.
+
+ Shows QUIC adoption rates per consensus client.
+ """
+ date_filter = _get_lookback_filter(target_date, days=7)
+
+ query = f"""
+WITH peer_protocols AS (
+ SELECT
+ remote_agent_implementation as client,
+ remote_peer_id_unique_key,
+ groupUniqArray(remote_transport_protocol) as protocols
+ FROM default.libp2p_connected
+ WHERE meta_network_name = '{network}'
+ AND {date_filter}
+ AND remote_agent_implementation NOT IN ('', 'unknown')
+ GROUP BY client, remote_peer_id_unique_key
+)
+SELECT
+ client,
+ countIf(has(protocols, 'tcp') AND NOT has(protocols, 'udp')) as tcp_only,
+ countIf(has(protocols, 'udp') AND NOT has(protocols, 'tcp')) as quic_only,
+ countIf(has(protocols, 'tcp') AND has(protocols, 'udp')) as both,
+ count(*) as total,
+ round(countIf(has(protocols, 'udp')) * 100.0 / count(*), 1) as quic_capable_pct
+FROM peer_protocols
+GROUP BY client
+HAVING total > 30
+ORDER BY total DESC
+"""
+
+ df = client.query_df(query)
+ return df, query
+
+
+def fetch_transport_connection_patterns(
+ client,
+ target_date: str,
+ network: str = "mainnet",
+) -> tuple:
+ """Fetch connection frequency patterns by transport protocol."""
+ date_filter = _get_lookback_filter(target_date, days=7)
+
+ query = f"""
+SELECT
+ remote_transport_protocol as transport,
+ count(*) as total_connections,
+ uniqExact(remote_peer_id_unique_key) as unique_peers,
+ round(count(*) / uniqExact(remote_peer_id_unique_key), 1) as connections_per_peer
+FROM default.libp2p_connected
+WHERE meta_network_name = '{network}'
+ AND {date_filter}
+GROUP BY transport
+ORDER BY transport
+"""
+
+ df = client.query_df(query)
+ return df, query
diff --git a/site/src/components/Icon.astro b/site/src/components/Icon.astro
index 73e8e9d..03bc72d 100644
--- a/site/src/components/Icon.astro
+++ b/site/src/components/Icon.astro
@@ -1,5 +1,5 @@
---
-import { Activity, AlertCircle, AlertTriangle, Calendar, ChevronLeft, ChevronRight, Clock, Download, Eye, FileText, Gauge, Gavel, Grid3x3, Layers, Link, List, PanelLeft, Timer, XCircle } from 'lucide-react';
+import { Activity, AlertCircle, AlertTriangle, Calendar, ChevronLeft, ChevronRight, Clock, Download, Eye, FileText, Gauge, Gavel, Grid3x3, Layers, Link, List, Network, PanelLeft, Timer, XCircle } from 'lucide-react';
interface Props {
name: string;
@@ -29,6 +29,7 @@ const icons: Record