tezos-shell-services 12.3 · OCaml Package

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

applied : (Tezos_crypto.Operation_hash.t * Block_services.Fake_protocol.operation) list;
refused : (Block_services.Fake_protocol.operation * Tezos_error_monad.TzCore.error list) Tezos_crypto.Operation_hash.Map.t;
outdated : (Block_services.Fake_protocol.operation * Tezos_error_monad.TzCore.error list) Tezos_crypto.Operation_hash.Map.t;
branch_refused : (Block_services.Fake_protocol.operation * Tezos_error_monad.TzCore.error list) Tezos_crypto.Operation_hash.Map.t;
branch_delayed : (Block_services.Fake_protocol.operation * Tezos_error_monad.TzCore.error list) Tezos_crypto.Operation_hash.Map.t;
unprocessed : Block_services.Fake_protocol.operation Tezos_crypto.Operation_hash.Map.t;

}

type t_with_version =
  Block_services.Make(Block_services.Fake_protocol)(Block_services.Fake_protocol).Mempool.t_with_version

val pending_operations_version_dispatcher : 
  version:int ->
  t ->
  t_with_version Tezos_rpc.RPC_answer.t Lwt.t

val pending_operations : 
  Tezos_rpc.RPC_context.simple ->
  ?chain:Block_services.chain ->
  ?version:int ->
  unit ->
  (t, Tezos_error_monad.TzCore.error list) Stdlib.result Lwt.t

Call RPC GET /chains/chain/mempool/pending_operations

val ban_operation : 
  Tezos_rpc.RPC_context.simple ->
  ?chain:Block_services.chain ->
  Tezos_crypto.Operation_hash.t ->
  unit Tezos_error_monad.Error_monad.tzresult Lwt.t

Call RPC POST /chains/chain/mempool/ban_operation

val unban_operation : 
  Tezos_rpc.RPC_context.simple ->
  ?chain:Block_services.chain ->
  Tezos_crypto.Operation_hash.t ->
  unit Tezos_error_monad.Error_monad.tzresult Lwt.t

Call RPC POST /chains/chain/mempool/unban_operation

val unban_all_operations : 
  Tezos_rpc.RPC_context.simple ->
  ?chain:Block_services.chain ->
  unit ->
  unit Tezos_error_monad.Error_monad.tzresult Lwt.t

Call RPC POST /chains/chain/mempool/unban_all_operations

val monitor_operations : 
  Tezos_rpc.RPC_context.streamed ->
  ?chain:Block_services.chain ->
  ?applied:bool ->
  ?branch_delayed:bool ->
  ?branch_refused:bool ->
  ?refused:bool ->
  ?outdated:bool ->
  unit ->
  (((Tezos_crypto.Operation_hash.t * Block_services.Fake_protocol.operation)
    * Tezos_error_monad.TzCore.error list option)
     list
     Lwt_stream.t
   * Tezos_rpc.RPC_context.stopper,
    Tezos_error_monad.TzCore.error list)
    Stdlib.result
    Lwt.t

Call RPC GET /chains/chain/mempool/monitor_operations

val request_operations : 
  Tezos_rpc.RPC_context.simple ->
  ?chain:Block_services.chain ->
  ?peer_id:Tezos_base.P2p_peer.Id.t ->
  unit ->
  (unit, Tezos_error_monad.TzCore.error list) Stdlib.result Lwt.t

Call RPC POST /chains/chain/mempool/request_operations

package tezos-shell-services