Diff (network_pool.Network_pool.Pool_sink.Remote

type pool

type 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

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 : 
  pool ->
  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 : 
  pool ->
  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

val update_metrics : 
  t Network_peer.Envelope.Incoming.t ->
  Mina_net2.Validation_callback.t ->
  Logger.t option ->
  unit