Commands (mavbox.Mavbox.Traffic_generation.Commands)

val cmdline_fail : 
  ('a,
    Mavbox.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

type action = [

| `Batch_action of batch_action
| `Multisig_action of 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