Module Resource_pool.Diff

val of_yojson : Yojson.Safe.t -> t Ppx_deriving_yojson_runtime.error_or
include Ppx_sexp_conv_lib.Sexpable.S with type t := t
val t_of_sexp : Sexplib0__.Sexp.t -> t
val sexp_of_t : t -> Sexplib0__.Sexp.t
module Diff_error : sig ... end
module Rejected : sig ... end
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
include Intf.Resource_pool_diff_intf with type t := t and type pool := t and type rejected = Rejected.t
val to_yojson : t -> Yojson.Safe.t
include Ppx_sexp_conv_lib.Sexpable.S with type t := t
val t_of_sexp : Sexplib0__.Sexp.t -> t
val sexp_of_t : t -> Sexplib0__.Sexp.t
type verified
val verified_to_yojson : verified -> Yojson.Safe.t
val sexp_of_verified : verified -> Ppx_sexp_conv_lib.Sexp.t
val verified_of_sexp : Ppx_sexp_conv_lib.Sexp.t -> verified
type rejected = Rejected.t

Part of the diff that was not added to the resource pool

val rejected_to_yojson : rejected -> Yojson.Safe.t
val sexp_of_rejected : rejected -> Ppx_sexp_conv_lib.Sexp.t
val rejected_of_sexp : Ppx_sexp_conv_lib.Sexp.t -> rejected
val empty : t
val reject_overloaded_diff : verified -> rejected
val size : t -> int

Used to check whether or not information was filtered out of diffs * during diff application. Assumes that diff size will be the equal or * smaller after application is completed.

val score : t -> int

How big to consider this diff for purposes of metering.

val max_per_15_seconds : int

The maximum "diff score" permitted per IP/peer-id per 15 seconds.

val summary : t -> string
val verify : t -> t Network_peer.Envelope.Incoming.t -> verified Network_peer.Envelope.Incoming.t Async_kernel.Deferred.Or_error.t

Warning: It must be safe to call this function asynchronously!

val unsafe_apply : t -> verified Network_peer.Envelope.Incoming.t -> ( [ `Accept | `Reject ] * t * rejected, [ `Locally_generated of t * rejected | `Other of Core_kernel.Error.t ] ) Async_kernel.Deferred.Result.t

Warning: Using this directly could corrupt the resource pool if it conincides with applying locally generated diffs or diffs from the network or diffs from transition frontier extensions.

val is_empty : t -> bool