Mempool (mavkit-protocol-alpha-libs.Mavryk_client_alpha.Mockup.M.Block

type t = {

validated : (Mavryk_base.TzPervasives.Operation_hash.t * Protocol.operation) list;
refused : (Protocol.operation * Mavryk_base.TzPervasives.error list) Mavryk_base.TzPervasives.Operation_hash.Map.t;
outdated : (Protocol.operation * Mavryk_base.TzPervasives.error list) Mavryk_base.TzPervasives.Operation_hash.Map.t;
branch_refused : (Protocol.operation * Mavryk_base.TzPervasives.error list) Mavryk_base.TzPervasives.Operation_hash.Map.t;
branch_delayed : (Protocol.operation * Mavryk_base.TzPervasives.error list) Mavryk_base.TzPervasives.Operation_hash.Map.t;
unprocessed : Protocol.operation Mavryk_base.TzPervasives.Operation_hash.Map.t;

}

val pending_operations : 
  Mavryk_rpc.Context.simple ->
  ?chain:[ `Main | `Test | `Hash of Mavryk_base.TzPervasives.Chain_id.t ] ->
  ?version:Mavryk_shell_services__Block_services.version ->
  ?validated:bool ->
  ?branch_delayed:bool ->
  ?branch_refused:bool ->
  ?refused:bool ->
  ?outdated:bool ->
  ?validation_passes:int list ->
  unit ->
  t Mavryk_base.TzPervasives.tzresult Lwt.t

val ban_operation : 
  Mavryk_rpc.Context.simple ->
  ?chain:[ `Main | `Test | `Hash of Mavryk_base.TzPervasives.Chain_id.t ] ->
  Mavryk_base.TzPervasives.Operation_hash.t ->
  unit Mavryk_error_monad.Error_monad.tzresult Lwt.t

val unban_operation : 
  Mavryk_rpc.Context.simple ->
  ?chain:[ `Main | `Test | `Hash of Mavryk_base.TzPervasives.Chain_id.t ] ->
  Mavryk_base.TzPervasives.Operation_hash.t ->
  unit Mavryk_error_monad.Error_monad.tzresult Lwt.t

val unban_all_operations : 
  Mavryk_rpc.Context.simple ->
  ?chain:[ `Main | `Test | `Hash of Mavryk_base.TzPervasives.Chain_id.t ] ->
  unit ->
  unit Mavryk_error_monad.Error_monad.tzresult Lwt.t

val monitor_operations : 
  Mavryk_rpc.Context.streamed ->
  ?chain:[ `Main | `Test | `Hash of Mavryk_base.TzPervasives.Chain_id.t ] ->
  ?version:Mavryk_shell_services__Block_services.version ->
  ?validated:bool ->
  ?branch_delayed:bool ->
  ?branch_refused:bool ->
  ?refused:bool ->
  ?outdated:bool ->
  ?validation_passes:int list ->
  unit ->
  (((Mavryk_base.TzPervasives.Operation_hash.t * Protocol.operation)
    * Mavryk_base.TzPervasives.error Mavryk_base.TzPervasives.trace option)
     list
     Lwt_stream.t
   * Mavryk_rpc.Context.stopper)
    Mavryk_base.TzPervasives.tzresult
    Lwt.t

val request_operations : 
  Mavryk_rpc.Context.simple ->
  ?chain:[ `Main | `Test | `Hash of Mavryk_base.TzPervasives.Chain_id.t ] ->
  ?peer_id:Mavryk_base.P2p_peer.Id.t ->
  unit ->
  unit Mavryk_base.TzPervasives.tzresult Lwt.t