Peer_validator (mavkit-shell-libs.Mavryk_shell.Peer

type t

val peer_id : t -> Mavryk_base.P2p_peer.Id.t

val create : 
  ?notify_new_block:(Block_validator.new_block -> unit) ->
  ?notify_termination:(unit -> unit) ->
  Mavryk_shell_services.Shell_limits.peer_validator_limits ->
  Block_validator.t ->
  Distributed_db.chain_db ->
  Mavryk_base.P2p_peer.Id.t ->
  t Lwt.t

val shutdown : t -> unit Lwt.t

val notify_branch : t -> Mavryk_base.Block_locator.t -> unit

val notify_head : 
  t ->
  Mavryk_base.TzPervasives.Block_hash.t ->
  Mavryk_base.Block_header.t ->
  unit

val running_workers : 
  unit ->
  ((Mavryk_base.TzPervasives.Chain_id.t * Mavryk_base.P2p_peer.Id.t) * t) list

val status : t -> Mavryk_base.Worker_types.worker_status

val information : t -> Mavryk_base.Worker_types.worker_information

val current_request : 
  t ->
  (Mavryk_base.Time.System.t
   * Mavryk_base.Time.System.t
   * Mavryk_shell_services.Peer_validator_worker_state.Request.view)
    option

val pipeline_length : 
  t ->
  Mavryk_shell_services.Peer_validator_worker_state.pipeline_length

module Internal_for_tests : sig ... end