tezos-baking-alpha 12.3 · OCaml Package

type loop_state

val create_loop_state : 
  Baking_state.proposal Lwt_stream.t ->
  Operation_worker.t ->
  loop_state

val sleep_until : Tezos_base.Time.Protocol.t -> unit Lwt.t option

val wait_next_event : 
  timeout:Baking_state.timeout_kind Lwt.t ->
  loop_state ->
  (Baking_state.event option, Tezos_error_monad.TzCore.error list)
    Stdlib.result
    Lwt.t

An event monitor using the streams in loop_state (to create promises) and a timeout promise timeout. The function reacts to a promise being fulfilled by firing an event Baking_state.event.

val compute_next_round_time : 
  Baking_state.state ->
  (Tezos_base.Time.Protocol.t
   * Tezos_protocol_alpha.Protocol.Alpha_context.Round.t)
    option

val first_potential_round_at_next_level : 
  Baking_state.state ->
  earliest_round:Tezos_protocol_alpha.Protocol.Alpha_context.Round.t ->
  (Tezos_protocol_alpha.Protocol.Alpha_context.Round.t * Baking_state.delegate)
    option

val compute_next_potential_baking_time_at_next_level : 
  Baking_state.state ->
  (Tezos_base.Time.Protocol.t
   * Tezos_protocol_alpha.Protocol.Alpha_context.Round.t)
    option
    Lwt.t

val compute_next_timeout : 
  Baking_state.state ->
  (Baking_state.timeout_kind Lwt.t, Tezos_error_monad.TzCore.error list)
    Stdlib.result
    Lwt.t

val create_initial_state : 
  Tezos_client_alpha.Protocol_client_context.full ->
  ?synchronize:bool ->
  chain:Tezos_shell_services.Chain_services.chain ->
  Baking_configuration.t ->
  Operation_worker.t ->
  current_proposal:Baking_state.proposal ->
  Baking_state.delegate list ->
  (Baking_state.state, Tezos_error_monad.TzCore.error list) Stdlib.result Lwt.t

val compute_bootstrap_event : 
  Baking_state.state ->
  (Baking_state.event, Tezos_error_monad.TzCore.error list) Stdlib.result

val automaton_loop : 
  ?stop_on_event:(Baking_state.event -> bool) ->
  config:Baking_configuration.t ->
  on_error:
    (Tezos_error_monad.TzCore.error list ->
      (unit, Tezos_error_monad.TzCore.error list) Stdlib.result Lwt.t) ->
  loop_state ->
  Baking_state.state ->
  Baking_state.event ->
  (Baking_state.event option, Tezos_error_monad.TzCore.error list)
    Stdlib.result
    Lwt.t

val run : 
  Tezos_client_alpha.Protocol_client_context.full ->
  ?canceler:Lwt_canceler.t ->
  ?stop_on_event:(Baking_state.event -> bool) ->
  ?on_error:
    (Tezos_error_monad.TzCore.error list ->
      (unit, Tezos_error_monad.TzCore.error list) Stdlib.result Lwt.t) ->
  chain:Tezos_shell_services.Chain_services.chain ->
  Baking_configuration.t ->
  Baking_state.delegate list ->
  (unit, Tezos_error_monad.TzCore.error list) Stdlib.result Lwt.t

package tezos-baking-alpha