Monitor_services (octez-shell-libs.Tezos_shell_services.Monitor

type chain_status =

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

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

val validated_blocks : 
  Tezos_rpc.Context.streamed ->
  ?chains:Chain_services.chain list ->
  ?protocols:Tezos_base.TzPervasives.Protocol_hash.t list ->
  ?next_protocols:Tezos_base.TzPervasives.Protocol_hash.t list ->
  unit ->
  ((Tezos_base.TzPervasives.Chain_id.t
    * Tezos_base.TzPervasives.Block_hash.t
    * Tezos_base.Block_header.t
    * Tezos_base.Operation.t list list)
     Lwt_stream.t
   * Tezos_rpc.Context.stopper)
    Tezos_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 : 
  Tezos_rpc.Context.streamed ->
  ?chains:Chain_services.chain list ->
  ?protocols:Tezos_base.TzPervasives.Protocol_hash.t list ->
  ?next_protocols:Tezos_base.TzPervasives.Protocol_hash.t list ->
  unit ->
  ((Tezos_base.TzPervasives.Chain_id.t
    * Tezos_base.TzPervasives.Block_hash.t
    * Tezos_base.Block_header.t
    * Tezos_base.Operation.t list list)
     Lwt_stream.t
   * Tezos_rpc.Context.stopper)
    Tezos_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 : 
  Tezos_rpc.Context.streamed ->
  Chain_services.chain ->
  (Tezos_base.TzPervasives.Block_hash.t Lwt_stream.t
   * Tezos_rpc.Context.stopper)
    Tezos_base.TzPervasives.tzresult
    Lwt.t

Call RPC GET /monitor/received_blocks

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

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

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

module S : sig ... end