val create_loop_state :
Baking_state.proposal Lwt_stream.t ->
Operation_worker.t ->
loop_stateval sleep_until : Tezos_base.Time.Protocol.t -> unit Lwt.t optionval wait_next_event :
timeout:Baking_state.timeout_kind Lwt.t ->
loop_state ->
(Baking_state.event option, Tezos_error_monad.TzCore.error list) result Lwt.tAn 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)
optionval 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)
optionval 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.tval compute_next_timeout :
Baking_state.state ->
(Baking_state.timeout_kind Lwt.t, Tezos_error_monad.TzCore.error list) result
Lwt.tval 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) result Lwt.tval compute_bootstrap_event :
Baking_state.state ->
(Baking_state.event, Tezos_error_monad.TzCore.error list) resultval 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) result Lwt.t) ->
loop_state ->
Baking_state.state ->
Baking_state.event ->
(Baking_state.event option, Tezos_error_monad.TzCore.error list) result Lwt.tval 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) result Lwt.t) ->
chain:Tezos_shell_services.Chain_services.chain ->
Baking_configuration.t ->
Baking_state.delegate list ->
(unit, Tezos_error_monad.TzCore.error list) result Lwt.t