tezos-baking-017-PtNairob 17.3 (latest)

type loop_state

val create_loop_state : 
  ?get_valid_blocks_stream:Baking_state.proposal Lwt_stream.t Lwt.t ->
  heads_stream:Baking_state.proposal Lwt_stream.t ->
  Operation_worker.t ->
  loop_state

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

val wait_next_event : 
  timeout:[ `Timeout of Baking_state.timeout_kind ] Lwt.t ->
  loop_state ->
  (Baking_state.event option,
    Tezos_base.TzPervasives.error Tezos_base.TzPervasives.trace)
    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.TzPervasives.Time.Protocol.t
   * Tezos_protocol_017_PtNairob.Protocol.Alpha_context.Round.t)
    option

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

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

val compute_next_timeout : 
  Baking_state.state ->
  Baking_state.timeout_kind Lwt.t Tezos_base.TzPervasives.tzresult Lwt.t

val create_initial_state : 
  Tezos_client_017_PtNairob.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.consensus_key list ->
  Baking_state.state Tezos_base.TzPervasives.tzresult Lwt.t

val compute_bootstrap_event : 
  Baking_state.state ->
  Baking_state.event Tezos_base.TzPervasives.tzresult

val automaton_loop : 
  ?stop_on_event:(Baking_state.event -> bool) ->
  config:Baking_configuration.t ->
  on_error:
    (Tezos_base.TzPervasives.tztrace ->
      (unit, Tezos_base.TzPervasives.tztrace) result Lwt.t) ->
  loop_state ->
  Baking_state.state ->
  Baking_state.event ->
  Baking_state.event option Tezos_base.TzPervasives.tzresult Lwt.t

val run : 
  Tezos_client_017_PtNairob.Protocol_client_context.full ->
  ?canceler:Lwt_canceler.t ->
  ?stop_on_event:(Baking_state.event -> bool) ->
  ?on_error:
    (Tezos_base.TzPervasives.tztrace ->
      unit Tezos_base.TzPervasives.tzresult Lwt.t) ->
  chain:Tezos_shell_services.Chain_services.chain ->
  Baking_configuration.t ->
  Baking_state.consensus_key list ->
  unit Tezos_base.TzPervasives.tzresult Lwt.t

package tezos-baking-017-PtNairob