Module Snark_pool_diff.Make

Parameters

module Transition_frontier : Core_kernel.T
module Pool : Intf.Snark_resource_pool_intf with type transition_frontier := Transition_frontier.t

Signature

val compare : t -> t -> int
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 = t
val compare_verified : verified -> verified -> int
val sexp_of_verified : verified -> Ppx_sexp_conv_lib.Sexp.t
val verified_of_sexp : Ppx_sexp_conv_lib.Sexp.t -> verified
val compact_to_yojson : compact -> Yojson.Safe.t
val compact_of_yojson : Yojson.Safe.t -> compact Ppx_deriving_yojson_runtime.error_or
val hash_fold_compact : Ppx_hash_lib.Std.Hash.state -> compact -> Ppx_hash_lib.Std.Hash.state
val hash_compact : compact -> Ppx_hash_lib.Std.Hash.hash_value
type Structured_log_events.t +=
| Snark_work_received of {
work : compact;
sender : Network_peer.Envelope.Sender.t;
}
val snark_work_received_structured_events_id : Structured_log_events.id
val snark_work_received_structured_events_repr : Structured_log_events.repr
include Intf.Resource_pool_diff_intf with type t := t and type verified := t and type pool := Pool.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
val verified_to_yojson : t -> Yojson.Safe.t
val sexp_of_verified : t -> Ppx_sexp_conv_lib.Sexp.t
val verified_of_sexp : Ppx_sexp_conv_lib.Sexp.t -> t
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 : t -> 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 -> t Network_peer.Envelope.Incoming.t -> t 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.t -> t 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 to_compact : t -> compact option
val compact_json : t -> Yojson.Safe.t option