Queries (flexmasa.Flexmasa.Test

val all_levels : 
  ?chain:Internal_pervasives.string ->
  < application_name : Internal_pervasives.string
    ; console : Console.t
    ; paths : Paths.t
    ; runner : Running_processes.State.t.. > ->
  nodes:Mavryk_node.t Internal_pervasives.list ->
  ((Internal_pervasives.string
    * [> `Failed
      | `Level of Internal_pervasives.int
      | `Null
      | `Unknown of Internal_pervasives.string ])
     Internal_pervasives.list,
    [> Internal_pervasives.System_error.t ])
    Internal_pervasives.Asynchronous_result.t

Get the current chain level for all the nodes, returns node-ID × level values.

val wait_for_all_levels_to_be : 
  ?attempts_factor:Internal_pervasives.float ->
  ?chain:Internal_pervasives.string ->
  ?silent:Internal_pervasives.bool ->
  < application_name : Internal_pervasives.string
    ; console : Console.t
    ; paths : Paths.t
    ; runner : Running_processes.State.t.. > ->
  attempts:Internal_pervasives.int ->
  seconds:
    (Internal_pervasives.unit ->
      (Internal_pervasives.float,
        [> Internal_pervasives.System_error.t
        | `Waiting_for of Internal_pervasives.string * [ `Time_out ] ] as 'errors)
        Internal_pervasives.Asynchronous_result.t) ->
  Mavryk_node.t Internal_pervasives.list ->
  [< `At_least of Internal_pervasives.int
  | `Equal_to of Internal_pervasives.int ] ->
  (Internal_pervasives.unit, 'errors) Internal_pervasives.Asynchronous_result.t

Try-sleep-loop waiting for all given nodes to reach a given level.

val run_wait_level : 
  Mavryk_protocol.t ->
  < application_name : Internal_pervasives.string
    ; console : Console.t
    ; paths : Paths.t
    ; runner : Running_processes.State.t.. >
    Internal_pervasives.Base_state.t ->
  Mavryk_node.t Flexmasa.Internal_pervasives.List.t ->
  [< `At_least of Internal_pervasives.int
  | `Equal_to of Internal_pervasives.int ] ->
  Internal_pervasives.int ->
  (Internal_pervasives.unit,
    [> `System_error of [ `Fatal ] * Internal_pervasives.System_error.static
    | `Waiting_for of Internal_pervasives.string * [ `Time_out ] ])
    Internal_pervasives.Asynchronous_result.t

Runs wait_for_all_levels_to_be and provides ~seconds by querying the node for time_between_blocks.

val wait_for_bake : 
  < application_name : Internal_pervasives.string
    ; console : Console.t
    ; paths : Paths.t
    ; env_config : Environment_configuration.t
    ; runner : Running_processes.State.t.. > ->
  nodes:Mavryk_node.t Internal_pervasives.list ->
  (Internal_pervasives.unit,
    [> Internal_pervasives.System_error.t
    | `Waiting_for of Internal_pervasives.string * [ `Time_out ] ])
    Internal_pervasives.Asynchronous_result.t

wait until at least one block is baked on all nodes