Commit 26fea619 authored by Barnabas Busa's avatar Barnabas Busa Committed by GitHub

feat: add ws_url to el_context (#696)

parent 2711cff6
...@@ -147,6 +147,7 @@ def launch( ...@@ -147,6 +147,7 @@ def launch(
service_name, METRICS_PATH, metrics_url service_name, METRICS_PATH, metrics_url
) )
http_url = "http://{0}:{1}".format(service.ip_address, RPC_PORT_NUM) http_url = "http://{0}:{1}".format(service.ip_address, RPC_PORT_NUM)
ws_url = "ws://{0}:{1}".format(service.ip_address, WS_PORT_NUM)
return el_context.new_el_context( return el_context.new_el_context(
"besu", "besu",
...@@ -157,6 +158,7 @@ def launch( ...@@ -157,6 +158,7 @@ def launch(
WS_PORT_NUM, WS_PORT_NUM,
ENGINE_HTTP_RPC_PORT_NUM, ENGINE_HTTP_RPC_PORT_NUM,
http_url, http_url,
ws_url,
service_name, service_name,
[besu_metrics_info], [besu_metrics_info],
) )
......
...@@ -7,6 +7,7 @@ def new_el_context( ...@@ -7,6 +7,7 @@ def new_el_context(
ws_port_num, ws_port_num,
engine_rpc_port_num, engine_rpc_port_num,
rpc_http_url, rpc_http_url,
ws_url,
service_name="", service_name="",
el_metrics_info=None, el_metrics_info=None,
): ):
...@@ -20,5 +21,6 @@ def new_el_context( ...@@ -20,5 +21,6 @@ def new_el_context(
ws_port_num=ws_port_num, ws_port_num=ws_port_num,
engine_rpc_port_num=engine_rpc_port_num, engine_rpc_port_num=engine_rpc_port_num,
rpc_http_url=rpc_http_url, rpc_http_url=rpc_http_url,
ws_url=ws_url,
el_metrics_info=el_metrics_info, el_metrics_info=el_metrics_info,
) )
...@@ -148,6 +148,7 @@ def launch( ...@@ -148,6 +148,7 @@ def launch(
) )
http_url = "http://{0}:{1}".format(service.ip_address, WS_RPC_PORT_NUM) http_url = "http://{0}:{1}".format(service.ip_address, WS_RPC_PORT_NUM)
ws_url = "ws://{0}:{1}".format(service.ip_address, WS_RPC_PORT_NUM)
return el_context.new_el_context( return el_context.new_el_context(
"erigon", "erigon",
...@@ -158,6 +159,7 @@ def launch( ...@@ -158,6 +159,7 @@ def launch(
WS_RPC_PORT_NUM, WS_RPC_PORT_NUM,
ENGINE_RPC_PORT_NUM, ENGINE_RPC_PORT_NUM,
http_url, http_url,
ws_url,
service_name, service_name,
[erigon_metrics_info], [erigon_metrics_info],
) )
......
...@@ -148,6 +148,7 @@ def launch( ...@@ -148,6 +148,7 @@ def launch(
ethjs_metrics_info = None ethjs_metrics_info = None
http_url = "http://{0}:{1}".format(service.ip_address, RPC_PORT_NUM) http_url = "http://{0}:{1}".format(service.ip_address, RPC_PORT_NUM)
ws_url = "ws://{0}:{1}".format(service.ip_address, WS_PORT_NUM)
return el_context.new_el_context( return el_context.new_el_context(
"ethereumjs", "ethereumjs",
...@@ -158,6 +159,7 @@ def launch( ...@@ -158,6 +159,7 @@ def launch(
WS_PORT_NUM, WS_PORT_NUM,
ENGINE_RPC_PORT_NUM, ENGINE_RPC_PORT_NUM,
http_url, http_url,
ws_url,
service_name, service_name,
[ethjs_metrics_info], [ethjs_metrics_info],
) )
......
...@@ -163,6 +163,7 @@ def launch( ...@@ -163,6 +163,7 @@ def launch(
) )
http_url = "http://{0}:{1}".format(service.ip_address, RPC_PORT_NUM) http_url = "http://{0}:{1}".format(service.ip_address, RPC_PORT_NUM)
ws_url = "ws://{0}:{1}".format(service.ip_address, WS_PORT_NUM)
return el_context.new_el_context( return el_context.new_el_context(
"geth", "geth",
...@@ -173,6 +174,7 @@ def launch( ...@@ -173,6 +174,7 @@ def launch(
WS_PORT_NUM, WS_PORT_NUM,
ENGINE_RPC_PORT_NUM, ENGINE_RPC_PORT_NUM,
http_url, http_url,
ws_url,
service_name, service_name,
[geth_metrics_info], [geth_metrics_info],
) )
......
...@@ -145,6 +145,7 @@ def launch( ...@@ -145,6 +145,7 @@ def launch(
) )
http_url = "http://{0}:{1}".format(service.ip_address, RPC_PORT_NUM) http_url = "http://{0}:{1}".format(service.ip_address, RPC_PORT_NUM)
ws_url = "ws://{0}:{1}".format(service.ip_address, WS_PORT_NUM)
return el_context.new_el_context( return el_context.new_el_context(
"nethermind", "nethermind",
...@@ -156,6 +157,7 @@ def launch( ...@@ -156,6 +157,7 @@ def launch(
WS_PORT_NUM, WS_PORT_NUM,
ENGINE_RPC_PORT_NUM, ENGINE_RPC_PORT_NUM,
http_url, http_url,
ws_url,
service_name, service_name,
[nethermind_metrics_info], [nethermind_metrics_info],
) )
......
...@@ -147,6 +147,7 @@ def launch( ...@@ -147,6 +147,7 @@ def launch(
) )
http_url = "http://{0}:{1}".format(service.ip_address, WS_RPC_PORT_NUM) http_url = "http://{0}:{1}".format(service.ip_address, WS_RPC_PORT_NUM)
ws_url = "ws://{0}:{1}".format(service.ip_address, WS_RPC_PORT_NUM)
return el_context.new_el_context( return el_context.new_el_context(
"nimbus", "nimbus",
...@@ -157,6 +158,7 @@ def launch( ...@@ -157,6 +158,7 @@ def launch(
WS_RPC_PORT_NUM, WS_RPC_PORT_NUM,
ENGINE_RPC_PORT_NUM, ENGINE_RPC_PORT_NUM,
http_url, http_url,
ws_url,
service_name, service_name,
[nimbus_metrics_info], [nimbus_metrics_info],
) )
......
...@@ -150,6 +150,7 @@ def launch( ...@@ -150,6 +150,7 @@ def launch(
) )
http_url = "http://{0}:{1}".format(service.ip_address, RPC_PORT_NUM) http_url = "http://{0}:{1}".format(service.ip_address, RPC_PORT_NUM)
ws_url = "ws://{0}:{1}".format(service.ip_address, WS_PORT_NUM)
return el_context.new_el_context( return el_context.new_el_context(
"reth", "reth",
...@@ -160,6 +161,7 @@ def launch( ...@@ -160,6 +161,7 @@ def launch(
WS_PORT_NUM, WS_PORT_NUM,
ENGINE_RPC_PORT_NUM, ENGINE_RPC_PORT_NUM,
http_url, http_url,
ws_url,
service_name, service_name,
[reth_metrics_info], [reth_metrics_info],
) )
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment