Baking_scheduling (mavkit-protocol-002-PtBoreas-libs.Mavryk_baking_002_PtBoreas.Baking

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 ->
  forge_event_stream:Baking_state.forge_event Lwt_stream.t ->
  Operation_worker.t ->
  loop_state

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

val retry : 
  Mavryk_client_002_PtBoreas.Protocol_client_context.full ->
  ?max_delay:float ->
  delay:float ->
  factor:float ->
  tries:int ->
  ?msg:string ->
  ('a -> 'b Mavryk_base.TzPervasives.tzresult Lwt.t) ->
  'a ->
  'b Mavryk_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.

val wait_next_event : 
  timeout:[ `Timeout of Baking_state.timeout_kind ] Lwt.t ->
  loop_state ->
  (Baking_state.event option,
    Mavryk_base.TzPervasives.error Mavryk_base.TzPervasives.trace)
    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 first_potential_round_at_next_level : 
  Baking_state.state ->
  earliest_round:Mavryk_protocol_002_PtBoreas.Protocol.Alpha_context.Round.t ->
  (Mavryk_protocol_002_PtBoreas.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.

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

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

val create_initial_state : 
  Mavryk_client_002_PtBoreas.Protocol_client_context.full ->
  ?synchronize:bool ->
  chain:Mavryk_shell_services.Chain_services.chain ->
  Baking_configuration.t ->
  Operation_worker.t ->
  current_proposal:Baking_state.proposal ->
  ?constants:Mavryk_protocol_002_PtBoreas.Protocol.Alpha_context.Constants.t ->
  Baking_state.consensus_key list ->
  Baking_state.state Mavryk_base.TzPervasives.tzresult Lwt.t

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

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

val run : 
  Mavryk_client_002_PtBoreas.Protocol_client_context.full ->
  ?canceler:Lwt_canceler.t ->
  ?stop_on_event:(Baking_state.event -> bool) ->
  ?on_error:
    (Mavryk_base.TzPervasives.tztrace ->
      unit Mavryk_base.TzPervasives.tzresult Lwt.t) ->
  ?constants:Mavryk_protocol_002_PtBoreas.Protocol.Alpha_context.Constants.t ->
  chain:Mavryk_shell_services.Chain_services.chain ->
  Baking_configuration.t ->
  Baking_state.consensus_key list ->
  unit Mavryk_base.TzPervasives.tzresult Lwt.t