Resource_pool (network_pool.Network_pool.Network_pool_base.Make.2-Resource

include Intf.Resource_pool_base_intf
  with type transition_frontier := Transition_frontier.t

type t

val sexp_of_t : t -> Ppx_sexp_conv_lib.Sexp.t

val label : string

type transition_frontier_diff

module Config : sig ... end

val handle_transition_frontier_diff : 
  transition_frontier_diff ->
  t ->
  unit Async_kernel.Deferred.t

Diff from a transition frontier extension that would update the resource pool

val create : 
  constraint_constants:Genesis_constants.Constraint_constants.t ->
  consensus_constants:Consensus.Constants.t ->
  time_controller:Block_time.Controller.t ->
  frontier_broadcast_pipe:
    Transition_frontier.t Core_kernel.Option.t Pipe_lib.Broadcast_pipe.Reader.t ->
  config:Config.t ->
  logger:Logger.t ->
  tf_diff_writer:
    ( transition_frontier_diff,
      Pipe_lib.Strict_pipe.synchronous,
      unit Async_kernel.Deferred.t )
      Pipe_lib.Strict_pipe.Writer.t ->
  t

module Diff : Intf.Resource_pool_diff_intf with type pool := t

val get_rebroadcastable : 
  t ->
  has_timed_out:( Core_kernel.Time.t -> [ `Timed_out | `Ok ] ) ->
  Diff.t list

Locally generated items (user commands and snarks) should be periodically rebroadcast, to ensure network unreliability doesn't mean they're never included in a block. This function gets the locally generated items that are currently rebroadcastable. has_timed_out is a function that returns true if an item that was added at a given time should not be rebroadcast anymore. If it does, the implementation should not return that item, and remove it from the set of potentially-rebroadcastable item.