Commit 3133ada0 authored by Gyanendra Mishra's avatar Gyanendra Mishra

module -> package

parent ea410a7d
participant_network = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/participant_network.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/module_io/parse_input.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/package_io/parse_input.star")
static_files = import_module("github.com/kurtosis-tech/eth2-module/src/static_files/static_files.star")
genesis_constants = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/prelaunch_data_generator/genesis_constants/genesis_constants.star")
......@@ -10,7 +10,7 @@ prometheus = import_module("github.com/kurtosis-tech/eth2-module/src/prometheus/
grafana =import_module("github.com/kurtosis-tech/eth2-module/src/grafana/grafana_launcher.star")
testnet_verifier = import_module("github.com/kurtosis-tech/eth2-module/src/testnet_verifier/testnet_verifier.star")
module_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
package_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
GRAFANA_USER = "admin"
GRAFANA_PASSWORD = "admin"
......@@ -20,7 +20,7 @@ FIRST_NODE_FINALIZATION_FACT = "cl-boot-finalization-fact"
HTTP_PORT_ID_FOR_FACT = "http"
def main(input_args):
input_args_with_right_defaults = module_io.ModuleInput(parse_input.parse_input(input_args))
input_args_with_right_defaults = package_io.ModuleInput(parse_input.parse_input(input_args))
num_participants = len(input_args_with_right_defaults.participants)
network_params = input_args_with_right_defaults.network_params
......@@ -84,12 +84,12 @@ def main(input_args):
print("First finalized epoch occurred successfully")
grafana_info = module_io.GrafanaInfo(
grafana_info = package_io.GrafanaInfo(
dashboard_path = GRAFANA_DASHBOARD_PATH_URL,
user = GRAFANA_USER,
password = GRAFANA_PASSWORD
)
output = module_io.ModuleOutput(grafana_info = grafana_info)
output = package_io.ModuleOutput(grafana_info = grafana_info)
print(output)
return output
......
shared_utils = import_module("github.com/kurtosis-tech/eth2-module/src/shared_utils/shared_utils.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/module_io/parse_input.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/package_io/parse_input.star")
cl_client_context = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/cl/cl_client_context.star")
cl_node_metrics = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/cl/cl_node_metrics_info.star")
mev_boost_context_module = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/mev_boost/mev_boost_context.star")
module_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
package_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
LIGHTHOUSE_BINARY_COMMAND = "lighthouse"
......@@ -57,11 +57,11 @@ VALIDATOR_USED_PORTS = {
}
LIGHTHOUSE_LOG_LEVELS = {
module_io.GlobalClientLogLevel.error: "error",
module_io.GlobalClientLogLevel.warn: "warn",
module_io.GlobalClientLogLevel.info: "info",
module_io.GlobalClientLogLevel.debug: "debug",
module_io.GlobalClientLogLevel.trace: "trace",
package_io.GlobalClientLogLevel.error: "error",
package_io.GlobalClientLogLevel.warn: "warn",
package_io.GlobalClientLogLevel.info: "info",
package_io.GlobalClientLogLevel.debug: "debug",
package_io.GlobalClientLogLevel.trace: "trace",
}
BEACON_ENR_FACT_NAME = "beacon-enr-fact"
......
shared_utils = import_module("github.com/kurtosis-tech/eth2-module/src/shared_utils/shared_utils.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/module_io/parse_input.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/package_io/parse_input.star")
cl_client_context = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/cl/cl_client_context.star")
cl_node_metrics = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/cl/cl_node_metrics_info.star")
mev_boost_context_module = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/mev_boost/mev_boost_context.star")
module_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
package_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
CONSENSUS_DATA_DIRPATH_ON_SERVICE_CONTAINER = "/consensus-data"
GENESIS_DATA_MOUNT_DIRPATH_ON_SERVICE_CONTAINER = "/genesis"
......@@ -44,11 +44,11 @@ USED_PORTS = {
LODESTAR_LOG_LEVELS = {
module_io.GlobalClientLogLevel.error: "error",
module_io.GlobalClientLogLevel.warn: "warn",
module_io.GlobalClientLogLevel.info: "info",
module_io.GlobalClientLogLevel.debug: "debug",
module_io.GlobalClientLogLevel.trace: "trace",
package_io.GlobalClientLogLevel.error: "error",
package_io.GlobalClientLogLevel.warn: "warn",
package_io.GlobalClientLogLevel.info: "info",
package_io.GlobalClientLogLevel.debug: "debug",
package_io.GlobalClientLogLevel.trace: "trace",
}
......
shared_utils = import_module("github.com/kurtosis-tech/eth2-module/src/shared_utils/shared_utils.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/module_io/parse_input.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/package_io/parse_input.star")
cl_client_context = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/cl/cl_client_context.star")
cl_node_metrics = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/cl/cl_node_metrics_info.star")
module_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
package_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
GENESIS_DATA_MOUNTPOINT_ON_CLIENT = "/genesis-data"
......@@ -49,11 +49,11 @@ USED_PORTS = {
}
NIMBUS_LOG_LEVELS = {
module_io.GlobalClientLogLevel.error: "ERROR",
module_io.GlobalClientLogLevel.warn: "WARN",
module_io.GlobalClientLogLevel.info: "INFO",
module_io.GlobalClientLogLevel.debug: "DEBUG",
module_io.GlobalClientLogLevel.trace: "TRACE",
package_io.GlobalClientLogLevel.error: "ERROR",
package_io.GlobalClientLogLevel.warn: "WARN",
package_io.GlobalClientLogLevel.info: "INFO",
package_io.GlobalClientLogLevel.debug: "DEBUG",
package_io.GlobalClientLogLevel.trace: "TRACE",
}
ENR_FACT_NAME = "enr-fact"
......
shared_utils = import_module("github.com/kurtosis-tech/eth2-module/src/shared_utils/shared_utils.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/module_io/parse_input.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/package_io/parse_input.star")
cl_client_context = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/cl/cl_client_context.star")
cl_node_metrics = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/cl/cl_node_metrics_info.star")
mev_boost_context_module = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/mev_boost/mev_boost_context.star")
module_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
package_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
IMAGE_SEPARATOR_DELIMITER = ","
EXPECTED_NUM_IMAGES = 2
......@@ -52,11 +52,11 @@ VALIDATOR_NODE_USED_PORTS = {
}
PRYSM_LOG_LEVELS = {
module_io.GlobalClientLogLevel.error: "error",
module_io.GlobalClientLogLevel.warn: "warn",
module_io.GlobalClientLogLevel.info: "info",
module_io.GlobalClientLogLevel.debug: "debug",
module_io.GlobalClientLogLevel.trace: "trace",
package_io.GlobalClientLogLevel.error: "error",
package_io.GlobalClientLogLevel.warn: "warn",
package_io.GlobalClientLogLevel.info: "info",
package_io.GlobalClientLogLevel.debug: "debug",
package_io.GlobalClientLogLevel.trace: "trace",
}
BEACON_ENR_FACT_NAME = "beacon-enr-fact"
......
shared_utils = import_module("github.com/kurtosis-tech/eth2-module/src/shared_utils/shared_utils.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/module_io/parse_input.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/package_io/parse_input.star")
cl_client_context = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/cl/cl_client_context.star")
cl_node_metrics = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/cl/cl_node_metrics_info.star")
mev_boost_context_module = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/mev_boost/mev_boost_context.star")
module_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
package_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
TEKU_BINARY_FILEPATH_IN_IMAGE = "/opt/teku/bin/teku"
......@@ -58,11 +58,11 @@ ENTRYPOINT_ARGS = ["sh", "-c"]
TEKU_LOG_LEVELS = {
module_io.GlobalClientLogLevel.error: "ERROR",
module_io.GlobalClientLogLevel.warn: "WARN",
module_io.GlobalClientLogLevel.info: "INFO",
module_io.GlobalClientLogLevel.debug: "DEBUG",
module_io.GlobalClientLogLevel.trace: "TRACE",
package_io.GlobalClientLogLevel.error: "ERROR",
package_io.GlobalClientLogLevel.warn: "WARN",
package_io.GlobalClientLogLevel.info: "INFO",
package_io.GlobalClientLogLevel.debug: "DEBUG",
package_io.GlobalClientLogLevel.trace: "TRACE",
}
......
shared_utils = import_module("github.com/kurtosis-tech/eth2-module/src/shared_utils/shared_utils.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/module_io/parse_input.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/package_io/parse_input.star")
el_client_context = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/el/el_client_context.star")
module_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
package_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
# The dirpath of the execution data directory on the client container
EXECUTION_DATA_DIRPATH_ON_CLIENT_CONTAINER = "/opt/besu/execution-data"
......@@ -37,11 +37,11 @@ USED_PORTS = {
ENTRYPOINT_ARGS = ["sh", "-c"]
BESU_LOG_LEVELS = {
module_io.GlobalClientLogLevel.error: "ERROR",
module_io.GlobalClientLogLevel.warn: "WARN",
module_io.GlobalClientLogLevel.info: "INFO",
module_io.GlobalClientLogLevel.debug: "DEBUG",
module_io.GlobalClientLogLevel.trace: "TRACE",
package_io.GlobalClientLogLevel.error: "ERROR",
package_io.GlobalClientLogLevel.warn: "WARN",
package_io.GlobalClientLogLevel.info: "INFO",
package_io.GlobalClientLogLevel.debug: "DEBUG",
package_io.GlobalClientLogLevel.trace: "TRACE",
}
ENODE_FACT_NAME = "enode-fact"
......
shared_utils = import_module("github.com/kurtosis-tech/eth2-module/src/shared_utils/shared_utils.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/module_io/parse_input.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/package_io/parse_input.star")
el_client_context = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/el/el_client_context.star")
module_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
package_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
# The dirpath of the execution data directory on the client container
EXECUTION_DATA_DIRPATH_ON_CLIENT_CONTAINER = "/home/erigon/execution-data"
......@@ -34,11 +34,11 @@ USED_PORTS = {
ENTRYPOINT_ARGS = ["sh", "-c"]
ERIGON_LOG_LEVELS = {
module_io.GlobalClientLogLevel.error: "1",
module_io.GlobalClientLogLevel.warn: "2",
module_io.GlobalClientLogLevel.info: "3",
module_io.GlobalClientLogLevel.debug: "4",
module_io.GlobalClientLogLevel.trace: "5",
package_io.GlobalClientLogLevel.error: "1",
package_io.GlobalClientLogLevel.warn: "2",
package_io.GlobalClientLogLevel.info: "3",
package_io.GlobalClientLogLevel.debug: "4",
package_io.GlobalClientLogLevel.trace: "5",
}
ENR_FACT_NAME = "enr-fact"
......
shared_utils = import_module("github.com/kurtosis-tech/eth2-module/src/shared_utils/shared_utils.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/module_io/parse_input.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/package_io/parse_input.star")
el_client_context = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/el/el_client_context.star")
module_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
package_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
RPC_PORT_NUM = 8545
......@@ -48,11 +48,11 @@ ENR_FACT_NAME = "enr-fact"
ENODE_FACT_NAME = "enode-fact"
VERBOSITY_LEVELS = {
module_io.GlobalClientLogLevel.error: "1",
module_io.GlobalClientLogLevel.warn: "2",
module_io.GlobalClientLogLevel.info: "3",
module_io.GlobalClientLogLevel.debug: "4",
module_io.GlobalClientLogLevel.trace: "5",
package_io.GlobalClientLogLevel.error: "1",
package_io.GlobalClientLogLevel.warn: "2",
package_io.GlobalClientLogLevel.info: "3",
package_io.GlobalClientLogLevel.debug: "4",
package_io.GlobalClientLogLevel.trace: "5",
}
def launch(
......
shared_utils = import_module("github.com/kurtosis-tech/eth2-module/src/shared_utils/shared_utils.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/module_io/parse_input.star")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/package_io/parse_input.star")
el_client_context = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/el/el_client_context.star")
module_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
package_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
# The dirpath of the execution data directory on the client container
EXECUTION_DATA_DIRPATH_ON_CLIENT_CONTAINER = "/execution-data"
......@@ -32,11 +32,11 @@ USED_PORTS = {
}
NETHERMIND_LOG_LEVELS = {
module_io.GlobalClientLogLevel.error: "ERROR",
module_io.GlobalClientLogLevel.warn: "WARN",
module_io.GlobalClientLogLevel.info: "INFO",
module_io.GlobalClientLogLevel.debug: "DEBUG",
module_io.GlobalClientLogLevel.trace: "TRACE",
package_io.GlobalClientLogLevel.error: "ERROR",
package_io.GlobalClientLogLevel.warn: "WARN",
package_io.GlobalClientLogLevel.info: "INFO",
package_io.GlobalClientLogLevel.debug: "DEBUG",
package_io.GlobalClientLogLevel.trace: "TRACE",
}
ENODE_FACT_NAME = "enode-fact"
......
......@@ -21,7 +21,7 @@ teku = import_module("github.com/kurtosis-tech/eth2-module/src/participant_netwo
genesis_constants = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/prelaunch_data_generator/genesis_constants/genesis_constants.star")
participant_module = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/participant.star")
module_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
package_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
CL_CLIENT_SERVICE_ID_PREFIX = "cl-client-"
EL_CLIENT_SERVICE_ID_PREFIX = "el-client-"
......@@ -78,10 +78,10 @@ def launch_participant_network(participants, network_params, global_log_level):
print("Uploaded GETH files succesfully, launching EL participants")
el_launchers = {
module_io.ELClientType.geth : {"launcher": geth.new_geth_launcher(network_params.network_id, el_genesis_data, geth_prefunded_keys_artifact_id, genesis_constants.PRE_FUNDED_ACCOUNTS), "launch_method": geth.launch},
module_io.ELClientType.besu : {"launcher": besu.new_besu_launcher(network_params.network_id, el_genesis_data), "launch_method": besu.launch},
module_io.ELClientType.erigon : {"launcher": erigon.new_erigon_launcher(network_params.network_id, el_genesis_data), "launch_method": erigon.launch},
module_io.ELClientType.nethermind : {"launcher": nethermind.new_nethermind_launcher(el_genesis_data), "launch_method": nethermind.launch},
package_io.ELClientType.geth : {"launcher": geth.new_geth_launcher(network_params.network_id, el_genesis_data, geth_prefunded_keys_artifact_id, genesis_constants.PRE_FUNDED_ACCOUNTS), "launch_method": geth.launch},
package_io.ELClientType.besu : {"launcher": besu.new_besu_launcher(network_params.network_id, el_genesis_data), "launch_method": besu.launch},
package_io.ELClientType.erigon : {"launcher": erigon.new_erigon_launcher(network_params.network_id, el_genesis_data), "launch_method": erigon.launch},
package_io.ELClientType.nethermind : {"launcher": nethermind.new_nethermind_launcher(el_genesis_data), "launch_method": nethermind.launch},
}
all_el_client_contexts = []
......@@ -136,11 +136,11 @@ def launch_participant_network(participants, network_params, global_log_level):
print("Launching CL network")
cl_launchers = {
module_io.CLClientType.lighthouse : {"launcher": lighthouse.new_lighthouse_launcher(cl_genesis_data), "launch_method": lighthouse.launch},
module_io.CLClientType.lodestar: {"launcher": lodestar.new_lodestar_launcher(cl_genesis_data), "launch_method": lodestar.launch},
module_io.CLClientType.nimbus: {"launcher": nimbus.new_nimbus_launcher(cl_genesis_data), "launch_method": nimbus.launch},
module_io.CLClientType.prysm: {"launcher": prysm.new_prysm_launcher(cl_genesis_data, cl_validator_data.prysm_password_relative_filepath, cl_validator_data.prysm_password_artifact_uuid), "launch_method": prysm.launch},
module_io.CLClientType.teku: {"launcher": teku.new_teku_launcher(cl_genesis_data), "launch_method": teku.launch},
package_io.CLClientType.lighthouse : {"launcher": lighthouse.new_lighthouse_launcher(cl_genesis_data), "launch_method": lighthouse.launch},
package_io.CLClientType.lodestar: {"launcher": lodestar.new_lodestar_launcher(cl_genesis_data), "launch_method": lodestar.launch},
package_io.CLClientType.nimbus: {"launcher": nimbus.new_nimbus_launcher(cl_genesis_data), "launch_method": nimbus.launch},
package_io.CLClientType.prysm: {"launcher": prysm.new_prysm_launcher(cl_genesis_data, cl_validator_data.prysm_password_relative_filepath, cl_validator_data.prysm_password_artifact_uuid), "launch_method": prysm.launch},
package_io.CLClientType.teku: {"launcher": teku.new_teku_launcher(cl_genesis_data), "launch_method": teku.launch},
}
all_cl_client_contexts = []
......
......@@ -16,15 +16,15 @@ message ModuleInput {
// - only Ethereum network (EL and CL nodes) will be launched. Nothing else (no transaction spammer)
// - params for the CL nodes will be ignored (e.g. CL node image, CL node extra params)
// This is a hack - it's not very elegant - but this is a commonly-requested feature
// The longterm solution is making the module trivial to decompose so we don't need flags like this; we're working
// The longterm solution is making the package trivial to decompose so we don't need flags like this; we're working
// on this at the Kurtosis product level
optional bool launch_additional_services = 3;
// If set, the module will block until a finalized epoch has occurred.
// If set, the package will block until a finalized epoch has occurred.
// If `waitForVerifications` is set to true, this extra wait will be skipped.
optional bool wait_for_finalization = 4;
// If set to true, the module will block until all verifications have passed
// If set to true, the package will block until all verifications have passed
optional bool wait_for_verifications = 5;
// If set, after the merge, this will be the maximum number of epochs wait for the verifications to succeed.
......
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