package octez-protocol-alpha-libs

  1. Overview
  2. Docs
Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Module Tezos_baking_alpha.Baking_schedulingSource

Sourcetype loop_state
Sourceval create_loop_state : ?get_valid_blocks_stream:Baking_state.proposal Lwt_stream.t Lwt.t -> heads_stream:Baking_state.proposal Lwt_stream.t -> forge_event_stream:Baking_state.forge_event Lwt_stream.t -> Operation_worker.t -> loop_state
Sourceval sleep_until : Tezos_base.TzPervasives.Time.Protocol.t -> unit Lwt.t option
Sourceval retry : Tezos_client_alpha.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.t

retry 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.

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.

Sourceval 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.consensus_key_and_delegate) option

Returns 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.

Sourceval compute_next_potential_baking_time_at_next_level : Baking_state.state -> (Tezos_base.TzPervasives.Time.Protocol.t * Tezos_protocol_alpha.Protocol.Alpha_context.Round.t) option Lwt.t
Sourceval 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 -> ?constants:Tezos_protocol_alpha.Protocol.Alpha_context.Constants.t -> Baking_state.consensus_key list -> Baking_state.state Tezos_base.TzPervasives.tzresult Lwt.t
Sourceval run : Tezos_client_alpha.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) -> ?constants:Tezos_protocol_alpha.Protocol.Alpha_context.Constants.t -> chain:Tezos_shell_services.Chain_services.chain -> Baking_configuration.t -> Baking_state.consensus_key list -> unit Tezos_base.TzPervasives.tzresult Lwt.t
OCaml

Innovation. Community. Security.