Module `Blocks.Mempool`Source

Source

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

validated : (Tezos_base.TzPervasives.Operation_hash.t * Block_services.Fake_protocol.operation) list;
refused : (Block_services.Fake_protocol.operation * Tezos_base.TzPervasives.error list) Tezos_base.TzPervasives.Operation_hash.Map.t;
outdated : (Block_services.Fake_protocol.operation * Tezos_base.TzPervasives.error list) Tezos_base.TzPervasives.Operation_hash.Map.t;
branch_refused : (Block_services.Fake_protocol.operation * Tezos_base.TzPervasives.error list) Tezos_base.TzPervasives.Operation_hash.Map.t;
branch_delayed : (Block_services.Fake_protocol.operation * Tezos_base.TzPervasives.error list) Tezos_base.TzPervasives.Operation_hash.Map.t;
unprocessed : Block_services.Fake_protocol.operation Tezos_base.TzPervasives.Operation_hash.Map.t;

}

Source

val pending_operations : 
  Tezos_rpc.Context.simple ->
  ?chain:Block_services.chain ->
  ?version:Block_services.version ->
  ?validated:bool ->
  ?branch_delayed:bool ->
  ?branch_refused:bool ->
  ?refused:bool ->
  ?outdated:bool ->
  ?validation_passes:int list ->
  unit ->
  t Tezos_base.TzPervasives.tzresult Lwt.t

Call RPC GET /chains/chain/mempool/pending_operations

Default version is 0.
Default validated is true.
Default branch_delayed is true.
Default branch_refused is true.
Default refused is true.
Default outdated is true.
Default validation_passes is []

Source

val ban_operation : 
  Tezos_rpc.Context.simple ->
  ?chain:Block_services.chain ->
  Tezos_base.TzPervasives.Operation_hash.t ->
  unit Tezos_error_monad.Error_monad.tzresult Lwt.t

Call RPC POST /chains/chain/mempool/ban_operation

Source

val unban_operation : 
  Tezos_rpc.Context.simple ->
  ?chain:Block_services.chain ->
  Tezos_base.TzPervasives.Operation_hash.t ->
  unit Tezos_error_monad.Error_monad.tzresult Lwt.t

Call RPC POST /chains/chain/mempool/unban_operation

Source

val unban_all_operations : 
  Tezos_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

Source

val monitor_operations : 
  Tezos_rpc.Context.streamed ->
  ?chain:Block_services.chain ->
  ?version:Block_services.version ->
  ?validated:bool ->
  ?branch_delayed:bool ->
  ?branch_refused:bool ->
  ?refused:bool ->
  ?outdated:bool ->
  ?validation_passes:int list ->
  unit ->
  (((Tezos_base.TzPervasives.Operation_hash.t
     * Block_services.Fake_protocol.operation)
    * Tezos_base.TzPervasives.error Tezos_base.TzPervasives.trace option)
     list
     Lwt_stream.t
   * Tezos_rpc.Context.stopper)
    Tezos_base.TzPervasives.tzresult
    Lwt.t

Call RPC GET /chains/chain/mempool/monitor_operations

Source

val request_operations : 
  Tezos_rpc.Context.simple ->
  ?chain:Block_services.chain ->
  ?peer_id:Tezos_base.P2p_peer.Id.t ->
  unit ->
  unit Tezos_base.TzPervasives.tzresult Lwt.t

Call RPC POST /chains/chain/mempool/request_operations

Install

Dune Dependency

Authors

Maintainers

Sources

doc/octez-shell-libs.shell-services/Tezos_shell_services/Chain_services/Blocks/Mempool/index.html

Module `Blocks.Mempool`Source

package octez-shell-libs

Install

Dune Dependency

Authors

Maintainers

Sources

doc/octez-shell-libs.shell-services/Tezos_shell_services/Chain_services/Blocks/Mempool/index.html

Module Blocks.MempoolSource

Module `Blocks.Mempool`Source