Diff (network_pool.Network_pool.Transaction_pool.Make0.Resource

type t = Mina_base.User_command.t list

val to_yojson : t -> Yojson.Safe.t

val of_yojson : Yojson.Safe.t -> t Ppx_deriving_yojson_runtime.error_or

val t_of_sexp : Ppx_sexp_conv_lib.Sexp.t -> t

val sexp_of_t : t -> Ppx_sexp_conv_lib.Sexp.t

type _unused = unit constraint t = Diff_versioned.t

module Diff_error : sig ... end

module Rejected : sig ... end

type rejected = Rejected.t

val rejected_to_yojson : rejected -> Yojson.Safe.t

val rejected_of_yojson : 
  Yojson.Safe.t ->
  rejected Ppx_deriving_yojson_runtime.error_or

val rejected_of_sexp : Ppx_sexp_conv_lib.Sexp.t -> rejected

val sexp_of_rejected : rejected -> Ppx_sexp_conv_lib.Sexp.t

val compare_rejected : rejected -> rejected -> int

type verified = Diff_versioned.verified

val verified_to_yojson : verified -> Yojson.Safe.t

val _ : verified -> Yojson.Safe.t

val verified_of_sexp : Ppx_sexp_conv_lib.Sexp.t -> verified

val sexp_of_verified : verified -> Ppx_sexp_conv_lib.Sexp.t

val reject_overloaded_diff : verified -> rejected

val empty : 'a list

val size : 'a list -> int

val score : 'a list -> Core.Int.t

val max_per_15_seconds : int

val summary : 'a list -> string

val is_empty : 'a list -> bool

val log_and_punish : 
  ?punish:bool ->
  t ->
  'a Network_peer.Envelope.Incoming.t ->
  Base.Error.t ->
  unit Async_kernel.Deferred.t

val of_indexed_pool_error : 
  Indexed_pool.Command_error.t ->
  Diff_versioned.Diff_error.t * (string * Yojson.Safe.t) list

val report_command_error : 
  logger:Logger__Impl.Stable.V1.t ->
  is_sender_local:bool ->
  Mina_base.User_command.t ->
  Indexed_pool.Command_error.t ->
  unit

val verify : 
  pool ->
  t Network_peer.Envelope.Incoming.t ->
  verified Network_peer.Envelope.Incoming.t Async.Deferred.Or_error.t

val register_locally_generated : 
  t ->
  Mina_transaction.Transaction_hash.User_command_with_valid_signature.t
    Core.Hashtbl.key ->
  unit

val apply : 
  t ->
  verified Network_peer.Envelope.Incoming.t ->
  ([> `Accept | `Reject ]
   * Mina_transaction.Transaction_hash.User_command_with_valid_signature.t list
   * (Mina_transaction.Transaction_hash.User_command_with_valid_signature.t
      * Diff_error.t)
       list)
    Base__Or_error.t

val unsafe_apply' : 
  pool ->
  verified Network_peer.Envelope.Incoming.t ->
  ( [ `Accept | `Reject ] * t * rejected, [> `Other of Base__.Error.t ] )
    Core.Result.t

val unsafe_apply : 
  pool ->
  verified Network_peer.Envelope.Incoming.t ->
  ( [ `Accept | `Reject ] * t * rejected, [> `Other of Base__.Error.t ] )
    Core.Result.t
    Async.Deferred.t

type Structured_log_events.t +=

| Transactions_received of {

txns : t;

sender : Network_peer.Envelope.Sender.t;

}

val transactions_received_structured_events_id : Structured_log_events.id

val transactions_received_structured_events_repr : Structured_log_events.repr

val update_metrics : 
  t Network_peer.Envelope.Incoming.t ->
  Mina_net2.Validation_callback.t ->
  Logger__Impl.Stable.V1.t option ->
  unit