Tezos_shell_services.Chain_services.Blocks.Mempool · tezos-shell-services 7.4

type t =
  Tezos_shell_services.Block_services.Make(Tezos_shell_services.Block_services.Fake_protocol)(Tezos_shell_services.Block_services.Fake_protocol).Mempool.t =
  {

applied : (Tezos_crypto.Operation_hash.t
           * Tezos_shell_services.Block_services.Fake_protocol.operation)
            list;

refused : (Tezos_shell_services.Block_services.Fake_protocol.operation
           * Tezos_base__TzPervasives.error list)
            Tezos_crypto.Operation_hash.Map.t;

branch_refused : (Tezos_shell_services.Block_services.Fake_protocol.operation
                  * Tezos_base__TzPervasives.error list)
                   Tezos_crypto.Operation_hash.Map.t;

branch_delayed : (Tezos_shell_services.Block_services.Fake_protocol.operation
                  * Tezos_base__TzPervasives.error list)
                   Tezos_crypto.Operation_hash.Map.t;

unprocessed : Tezos_shell_services.Block_services.Fake_protocol.operation
                Tezos_crypto.Operation_hash.Map.t;

}

val pending_operations : 
  Tezos_rpc.RPC_context.simple ->
  ?chain:Tezos_shell_services.Block_services.chain ->
  unit ->
  ( t, Tezos_base__TzPervasives.error list ) result Lwt.t

val monitor_operations : 
  Tezos_rpc.RPC_context.streamed ->
  ?chain:Tezos_shell_services.Block_services.chain ->
  ?applied:bool ->
  ?branch_delayed:bool ->
  ?branch_refused:bool ->
  ?refused:bool ->
  unit ->
  ( Tezos_shell_services.Block_services.Fake_protocol.operation list
      Lwt_stream.t
    * Tezos_rpc.RPC_context.stopper,
    Tezos_base__TzPervasives.error list )
    result
    Lwt.t

val request_operations : 
  Tezos_rpc.RPC_context.simple ->
  ?chain:Tezos_shell_services.Block_services.chain ->
  unit ->
  ( unit, Tezos_base__TzPervasives.error list ) result Lwt.t