Traffic_generation.Commands
val cmdline_fail :
('a,
Flexmasa.Internal_pervasives.Formatter.t,
Internal_pervasives.unit,
('b, [> `Command_line of Internal_pervasives.string ])
Internal_pervasives.Asynchronous_result.t)
Internal_pervasives.format4 ->
'a
module Sexp_options : sig ... end
val protect_with_keyed_client :
Internal_pervasives.string ->
client:Mavryk_client.Keyed.t ->
f:
(Internal_pervasives.unit ->
('a,
[< `Command_line of Internal_pervasives.string
| Internal_pervasives.Process_result.Error.t
| Internal_pervasives.System_error.t
| `Waiting_for of Internal_pervasives.string * [< `Time_out ] ])
Internal_pervasives.Asynchronous_result.t) ->
('a,
[> `Command_line of Internal_pervasives.string
| Internal_pervasives.Process_result.Error.t ])
Internal_pervasives.Asynchronous_result.t
val counter_option : Sexp_options.option
val size_option : Sexp_options.option
val fee_option : Sexp_options.option
val level_option : Sexp_options.option
val contract_repeat_option : Sexp_options.option
val num_signers_option : Sexp_options.option
val repeat_all_option : Sexp_options.option
val random_choice_option : Sexp_options.option
type all_options = {
counter_option : Sexp_options.option;
size_option : Sexp_options.option;
fee_option : Sexp_options.option;
num_signers_option : Sexp_options.option;
contract_repeat_option : Sexp_options.option;
}
val all_opts : all_options
type batch_action = {
src : Internal_pervasives.string;
initial_counter_override : Internal_pervasives.int Internal_pervasives.option;
size : Internal_pervasives.int;
fee : Internal_pervasives.float;
}
val sexp_of_batch_action : batch_action -> Sexplib0.Sexp.t
val batch_action_of_sexp : Sexplib0.Sexp.t -> batch_action
type multisig_action = {
src : Internal_pervasives.string;
initial_counter_override : Internal_pervasives.int Internal_pervasives.option;
fee : Internal_pervasives.float;
num_signers : Internal_pervasives.int;
outer_repeat : Internal_pervasives.int;
contract_repeat : Internal_pervasives.int;
}
val sexp_of_multisig_action : multisig_action -> Sexplib0.Sexp.t
val multisig_action_of_sexp : Sexplib0.Sexp.t -> multisig_action
val sexp_of_action : action -> Sexplib0.Sexp.t
val action_of_sexp : Sexplib0.Sexp.t -> action
val __action_of_sexp__ : Sexplib0.Sexp.t -> action
val history_file_path : < paths : Paths.t.. > -> Internal_pervasives.string
val get_timestamp : Internal_pervasives.unit -> Internal_pervasives.string
val init_cmd_history :
< application_name : Internal_pervasives.string
; console : Console.t
; env_config : Environment_configuration.t
; paths : Paths.t
; runner : Running_processes.State.t.. > ->
(Internal_pervasives.unit, [> Internal_pervasives.System_error.t ])
Internal_pervasives.Attached_result.t
Lwt.t
val get_cmd_history :
< application_name : Internal_pervasives.string
; console : Console.t
; env_config : Environment_configuration.t
; paths : Paths.t
; runner : Running_processes.State.t.. > ->
(Internal_pervasives.string, [> Internal_pervasives.System_error.t ])
Internal_pervasives.Attached_result.t
Lwt.t
val add_cmd_to_history :
< application_name : Internal_pervasives.string
; console : Console.t
; env_config : Environment_configuration.t
; paths : Paths.t
; runner : Running_processes.State.t.. > ->
new_cmd:Internal_pervasives.string ->
start_time:Internal_pervasives.string ->
end_time:Internal_pervasives.string ->
(Internal_pervasives.unit, [> Internal_pervasives.System_error.t ])
Internal_pervasives.Attached_result.t
Lwt.t
val get_batch_args :
< application_name : Internal_pervasives.string
; console : Console.t
; paths : Paths.t
; env_config : Environment_configuration.t
; runner : Running_processes.State.t.. > ->
client:Mavryk_client.Keyed.t ->
all_options ->
Base.Sexp.t Internal_pervasives.list ->
([> action ], [> `Command_line of Internal_pervasives.string ])
Internal_pervasives.Asynchronous_result.t
val get_multisig_args :
< application_name : Internal_pervasives.string
; console : Console.t
; paths : Paths.t
; env_config : Environment_configuration.t
; runner : Running_processes.State.t.. > ->
client:Mavryk_client.Keyed.t ->
all_options ->
Base.Sexp.t Internal_pervasives.list ->
([> `Multisig_action of multisig_action ],
[> `Command_line of Internal_pervasives.string
| Internal_pervasives.Process_result.Error.t ])
Internal_pervasives.Asynchronous_result.t
val to_action :
< application_name : Internal_pervasives.string
; console : Console.t
; operations_log : Log_recorder.Operations.t
; env_config : Environment_configuration.t
; paths : Paths.t
; runner : Running_processes.State.t.. > ->
client:Mavryk_client.Keyed.t ->
all_options ->
Base.Sexp.t ->
([> action ],
[> `Command_line of Internal_pervasives.string
| Internal_pervasives.Process_result.Error.t
| `System_error of [ `Fatal ] * Internal_pervasives.System_error.static ])
Internal_pervasives.Asynchronous_result.t
val process_repeat_action :
Base.Sexp.t ->
Internal_pervasives.int * Base.Sexp.t
val process_random_choice :
Base.Sexp.t ->
Internal_pervasives.bool * Base.Sexp.t
val process_action_cmds :
< application_name : Internal_pervasives.string
; console : Console.t
; operations_log : Log_recorder.Operations.t
; env_config : Environment_configuration.t
; paths : Paths.t
; runner : Running_processes.State.t.. > ->
client:Mavryk_client.Keyed.t ->
all_options ->
Base.Sexp.t ->
random_choice:Internal_pervasives.bool ->
(action Internal_pervasives.list,
[> `Command_line of Internal_pervasives.string
| Internal_pervasives.Process_result.Error.t
| `System_error of [ `Fatal ] * Internal_pervasives.System_error.static ])
Internal_pervasives.Asynchronous_result.t
val process_gen_batch :
< application_name : Internal_pervasives.string
; console : Console.t
; operations_log : Log_recorder.Operations.t
; env_config : Environment_configuration.t
; paths : Paths.t
; runner : Running_processes.State.t.. > ->
client:Mavryk_client.Keyed.t ->
batch_action ->
(Internal_pervasives.unit,
[> `Command_line of Internal_pervasives.string
| Internal_pervasives.System_error.t
| Internal_pervasives.Process_result.Error.t ])
Internal_pervasives.Asynchronous_result.t
val process_gen_multi_sig :
< application_name : Internal_pervasives.string
; console : Console.t
; operations_log : Log_recorder.Operations.t
; env_config : Environment_configuration.t
; paths : Paths.t
; runner : Running_processes.State.t
; test_baking : Internal_pervasives.bool.. > ->
client:Mavryk_client.Keyed.t ->
nodes:Mavryk_node.t Internal_pervasives.list ->
multisig_action ->
(Internal_pervasives.unit,
[> `Command_line of Internal_pervasives.string
| Internal_pervasives.System_error.t ])
Internal_pervasives.Asynchronous_result.t
val run_actions :
< application_name : Internal_pervasives.string
; console : Console.t
; operations_log : Log_recorder.Operations.t
; env_config : Environment_configuration.t
; paths : Paths.t
; runner : Running_processes.State.t
; test_baking : Internal_pervasives.bool.. > ->
client:Mavryk_client.Keyed.t ->
nodes:Mavryk_node.t Internal_pervasives.list ->
actions:[< action ] Internal_pervasives.list ->
rep_counter:Internal_pervasives.int ->
(Internal_pervasives.unit,
[> `Command_line of Internal_pervasives.string
| Internal_pervasives.System_error.t
| Internal_pervasives.Process_result.Error.t ])
Internal_pervasives.Asynchronous_result.t