package octez-protocol-018-Proxford-libs
Install
dune-project
Dependency
Authors
Maintainers
Sources
sha256=c6df840ebbf115e454db949028c595bec558a59a66cade73b52a6d099d6fa4d4
sha512=d8aee903b9fe130d73176bc8ec38b78c9ff65317da3cb4f3415f09af0c625b4384e7498201fdb61aa39086a7d5d409d0ab3423f9bc3ab989a680cf444a79bc13
doc/octez-protocol-018-Proxford-libs.baking/Tezos_baking_018_Proxford/Baking_scheduling/index.html
Module Tezos_baking_018_Proxford.Baking_schedulingSource
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_stateval retry :
Tezos_client_018_Proxford.Protocol_client_context.full ->
?max_delay:float ->
delay:float ->
factor:float ->
tries:int ->
?msg:string ->
('a -> 'b Tezos_base.TzPervasives.tzresult Lwt.t) ->
'a ->
'b Tezos_base.TzPervasives.tzresult Lwt.tretry ctxt ~delay ?max_delay ~factor ~tries ?msg f x retries applying f x tries until it succeeds or returns an error different from Connection_failed, at most tries number of times. After each try it waits for a number of seconds, but not more than max_delay, if given. The wait time between tries is given by the initial delay, multiplied by factor at each subsequent try. At each failure, msg together with the current delay is printed using ctxt#message.
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.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.TzPervasives.Time.Protocol.t
* Tezos_protocol_018_Proxford.Protocol.Alpha_context.Round.t)
optionval first_potential_round_at_next_level :
Baking_state.state ->
earliest_round:Tezos_protocol_018_Proxford.Protocol.Alpha_context.Round.t ->
(Tezos_protocol_018_Proxford.Protocol.Alpha_context.Round.t
* Baking_state.consensus_key_and_delegate)
optionReturns the first round at the next level, at or after earliest_round, whose baking slot belongs to one of our own delegates; also returns the corresponding delegate. Or returns None if no such round exists.
val compute_next_potential_baking_time_at_next_level :
Baking_state.state ->
(Tezos_base.TzPervasives.Time.Protocol.t
* Tezos_protocol_018_Proxford.Protocol.Alpha_context.Round.t)
option
Lwt.tval compute_next_timeout :
Baking_state.state ->
Baking_state.timeout_kind Lwt.t Tezos_base.TzPervasives.tzresult Lwt.tval create_initial_state :
Tezos_client_018_Proxford.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.tval compute_bootstrap_event :
Baking_state.state ->
Baking_state.event Tezos_base.TzPervasives.tzresultval 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.tval run :
Tezos_client_018_Proxford.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