Chain_validator (mavkit-shell-libs.Mavryk_shell.Chain

type t

val create : 
  start_prevalidator:bool ->
  start_testchain:bool ->
  active_chains:t Mavryk_base.TzPervasives.Chain_id.Table.t ->
  block_validator_process:Block_validator_process.t ->
  Mavryk_shell_services.Shell_limits.peer_validator_limits ->
  Mavryk_shell_services.Shell_limits.prevalidator_limits ->
  Block_validator.t ->
  Mavryk_store.Store.Block.t Lwt_watcher.input ->
  (Mavryk_base.TzPervasives.Chain_id.t * bool) Lwt_watcher.input ->
  Distributed_db.t ->
  Mavryk_store.Store.chain_store ->
  Mavryk_shell_services.Shell_limits.chain_validator_limits ->
  t Mavryk_base.TzPervasives.tzresult Lwt.t

val chain_id : t -> Mavryk_base.TzPervasives.Chain_id.t

val chain_store : t -> Mavryk_store.Store.chain_store

val sync_status : t -> Synchronisation_heuristic.status

val bootstrapped : t -> unit Lwt.t

Wait for the `synchronisation_status` to be `Synchronised`. Subsequent calls return immediately. In other words, once a node is bootstrapped, it remains bootstrapped until it terminates (except if force_bootstrapped is used).

val is_bootstrapped : t -> bool

val force_bootstrapped : t -> bool -> unit Lwt.t

val prevalidator : t -> Prevalidator.t option

val chain_db : t -> Distributed_db.chain_db

val child : t -> t option

val reconfigure_event_logging : 
  t ->
  Mavryk_base_unix.Internal_event_unix.Configuration.t ->
  unit Mavryk_base.TzPervasives.tzresult Lwt.t

val validate_block : 
  t ->
  ?force:bool ->
  Mavryk_base.TzPervasives.Block_hash.t ->
  Mavryk_base.Block_header.t ->
  Mavryk_base.Operation.t list list ->
  unit Mavryk_base.TzPervasives.tzresult Lwt.t

val shutdown : t -> unit Lwt.t

val valid_block_watcher : 
  t ->
  Mavryk_store.Store.Block.t Lwt_stream.t * Lwt_watcher.stopper

val received_block_watcher : 
  t ->
  Mavryk_base.TzPervasives.Block_hash.t Lwt_stream.t * Lwt_watcher.stopper

val new_head_watcher : 
  t ->
  (Mavryk_base.TzPervasives.Block_hash.t * Mavryk_base.Block_header.t)
    Lwt_stream.t
  * Lwt_watcher.stopper

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

val status : t -> Mavryk_base.Worker_types.worker_status

val information : t -> Mavryk_base.Worker_types.worker_information

val pending_requests : 
  t ->
  (Mavryk_base.Time.System.t
   * Mavryk_shell_services.Chain_validator_worker_state.Request.view)
    list

val pending_requests_length : t -> int

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

val ddb_information : 
  t ->
  Mavryk_shell_services.Chain_validator_worker_state.Distributed_db_state.view