Commit 58b41687 authored by Gyanendra Mishra's avatar Gyanendra Mishra

command overrides work

parent e047faf2
...@@ -11,7 +11,7 @@ module_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto") ...@@ -11,7 +11,7 @@ module_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
def main(input_args): def main(input_args):
input_args_with_right_defaults = module_io.ModuleInput(parse_input(input_args)) input_args_with_right_defaults = module_io.ModuleInput(parse_input(input_args))
num_participants = len(input_args_with_right_defaults.participants) num_participants = len(input_args_with_right_defaults.participants)
grafana_datasource_config_template = read_file(GRAFANA_DATASOURCE_CONFIG_TEMPLATE_FILEPATH) grafana_datasource_config_template = read_file(GRAFANA_DATASOURCE_CONFIG_TEMPLATE_FILEPATH)
grafana_dashboards_config_template = read_file(GRAFANA_DASHBOARD_PROVIDERS_CONFIG_TEMPLATE_FILEPATH) grafana_dashboards_config_template = read_file(GRAFANA_DASHBOARD_PROVIDERS_CONFIG_TEMPLATE_FILEPATH)
prometheus_config_template = read_file(PROMETHEUS_CONFIG_TEMPLATE_FILEPATH) prometheus_config_template = read_file(PROMETHEUS_CONFIG_TEMPLATE_FILEPATH)
...@@ -20,19 +20,19 @@ def main(input_args): ...@@ -20,19 +20,19 @@ def main(input_args):
print("Launching participant network with {0} participants and the following network params {1}".format(num_participants, input_args_with_right_defaults.network_params)) print("Launching participant network with {0} participants and the following network params {1}".format(num_participants, input_args_with_right_defaults.network_params))
all_participants, cl_gensis_timestamp = launch_participant_network(input_args_with_right_defaults.participants, input_args_with_right_defaults.network_params, input_args_with_right_defaults.global_client_log_level) all_participants, cl_gensis_timestamp = launch_participant_network(input_args_with_right_defaults.participants, input_args_with_right_defaults.network_params, input_args_with_right_defaults.global_client_log_level)
print(all_participants) print(all_participants)
print(cl_gensis_timestamp) print(cl_gensis_timestamp)
all_el_client_contexts = [] all_el_client_contexts = []
all_cl_client_contexts = [] all_cl_client_contexts = []
for participant in participants: for participant in all_participants:
all_el_client_contexts.append(participant.el_client_context) all_el_client_contexts.append(participant.el_client_context)
all_cl_client_contexts.append(participant.cl_client_context) all_cl_client_contexts.append(participant.cl_client_context)
if not input_args_with_right_defaults.launch_additional_services: if not input_args_with_right_defaults.launch_additional_services:
return return
print("Launching transaction spammer") print("Launching transaction spammer")
launch_transaction_spammer(PRE_FUNDED_ACCOUNTS, all_el_client_contexts[0]) launch_transaction_spammer(PRE_FUNDED_ACCOUNTS, all_el_client_contexts[0])
......
...@@ -19,10 +19,12 @@ def get_service_config(prefunded_addresses, el_client_context): ...@@ -19,10 +19,12 @@ def get_service_config(prefunded_addresses, el_client_context):
return struct( return struct(
container_image_name = IMAGE_NAME, container_image_name = IMAGE_NAME,
cmd_args = [ cmd_args = [
"http://{0}:{1}".fomrat(el_client_context.ip_addr, el_client_context.rpc_port_num), "./tx-fuzz.bin",
"http://{0}:{1}".format(el_client_context.ip_addr, el_client_context.rpc_port_num),
"spam", "spam",
comma_separated_private_keys, comma_separated_private_keys,
comma_separated_addresses comma_separated_addresses
] ],
used_ports = {}
) )
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