Monitor_services (mavkit-shell-libs.Mavryk_shell_services.Monitor

type chain_status =

| Active_main of Mavryk_base.TzPervasives.Chain_id.t
| Active_test of {
1. chain : Mavryk_base.TzPervasives.Chain_id.t;
2. protocol : Mavryk_base.TzPervasives.Protocol_hash.t;
3. expiration_date : Mavryk_base.Time.Protocol.t;
}
| Stopping of Mavryk_base.TzPervasives.Chain_id.t

val bootstrapped : 
  Mavryk_rpc.Context.streamed ->
  ((Mavryk_base.TzPervasives.Block_hash.t * Mavryk_base.Time.Protocol.t)
     Lwt_stream.t
   * Mavryk_rpc.Context.stopper)
    Mavryk_base.TzPervasives.tzresult
    Lwt.t

val validated_blocks : 
  Mavryk_rpc.Context.streamed ->
  ?chains:Chain_services.chain list ->
  ?protocols:Mavryk_base.TzPervasives.Protocol_hash.t list ->
  ?next_protocols:Mavryk_base.TzPervasives.Protocol_hash.t list ->
  unit ->
  ((Mavryk_base.TzPervasives.Chain_id.t
    * Mavryk_base.TzPervasives.Block_hash.t
    * Mavryk_base.Block_header.t
    * Mavryk_base.Operation.t list list)
     Lwt_stream.t
   * Mavryk_rpc.Context.stopper)
    Mavryk_base.TzPervasives.tzresult
    Lwt.t

Call RPC GET /monitor/validated_blocks

Default chains is Main.
Default protocols is [].
Default next_protocols is [].

val applied_blocks : 
  Mavryk_rpc.Context.streamed ->
  ?chains:Chain_services.chain list ->
  ?protocols:Mavryk_base.TzPervasives.Protocol_hash.t list ->
  ?next_protocols:Mavryk_base.TzPervasives.Protocol_hash.t list ->
  unit ->
  ((Mavryk_base.TzPervasives.Chain_id.t
    * Mavryk_base.TzPervasives.Block_hash.t
    * Mavryk_base.Block_header.t
    * Mavryk_base.Operation.t list list)
     Lwt_stream.t
   * Mavryk_rpc.Context.stopper)
    Mavryk_base.TzPervasives.tzresult
    Lwt.t

Call RPC GET /monitor/applied_blocks

Default chains is Main.
Default protocols is [].
Default next_protocols is [].

val received_blocks : 
  Mavryk_rpc.Context.streamed ->
  Chain_services.chain ->
  (Mavryk_base.TzPervasives.Block_hash.t Lwt_stream.t
   * Mavryk_rpc.Context.stopper)
    Mavryk_base.TzPervasives.tzresult
    Lwt.t

Call RPC GET /monitor/received_blocks

val heads : 
  Mavryk_rpc.Context.streamed ->
  ?protocols:Mavryk_base.TzPervasives.Protocol_hash.t list ->
  ?next_protocols:Mavryk_base.TzPervasives.Protocol_hash.t list ->
  Chain_services.chain ->
  ((Mavryk_base.TzPervasives.Block_hash.t * Mavryk_base.Block_header.t)
     Lwt_stream.t
   * Mavryk_rpc.Context.stopper)
    Mavryk_base.TzPervasives.tzresult
    Lwt.t

val protocols : 
  Mavryk_rpc.Context.streamed ->
  (Mavryk_base.TzPervasives.Protocol_hash.t Lwt_stream.t
   * Mavryk_rpc.Context.stopper)
    Mavryk_base.TzPervasives.tzresult
    Lwt.t

val commit_hash : 
  Mavryk_rpc.Context.simple ->
  string Mavryk_base.TzPervasives.tzresult Lwt.t

val active_chains : 
  Mavryk_rpc.Context.streamed ->
  (chain_status list Lwt_stream.t * Mavryk_rpc.Context.stopper)
    Mavryk_base.TzPervasives.tzresult
    Lwt.t

module S : sig ... end