Transaction_pool (network_pool.Network_pool.Transaction

val max_per_15_seconds : int

module type Transition_frontier_intf = sig ... end

module Diff_versioned : sig ... end

type Structured_log_events.t +=

| Rejecting_command_for_reason of {

command : Mina_base.User_command.t;

reason : Diff_versioned.Diff_error.t;

error_extra : (string * Yojson.Safe.t) list;

}

val rejecting_command_for_reason_structured_events_id : 
  Structured_log_events.id

val rejecting_command_for_reason_structured_events_repr : 
  Structured_log_events.repr

module type S = sig ... end

module Make0
  (Base_ledger : Intf.Base_ledger_intf)
  (Staged_ledger : sig ... end)
  (Transition_frontier : 
    Transition_frontier_intf with type staged_ledger := Staged_ledger.t) : 
  sig ... end

module Make
  (Staged_ledger : sig ... end)
  (Transition_frontier : 
    Transition_frontier_intf with type staged_ledger := Staged_ledger.t) : 
  S with type transition_frontier := Transition_frontier.t

module Resource_pool : sig ... end

type t

module Local_sink : sig ... end

module Remote_sink : sig ... end

module Broadcast_callback : sig ... end

val create : 
  config:Resource_pool.Config.t ->
  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 ->
  logger:Logger.t ->
  log_gossip_heard:bool ->
  on_remote_push:( unit -> unit Async_kernel.Deferred.t ) ->
  t * Remote_sink.t * Local_sink.t

val of_resource_pool_and_diffs : 
  Resource_pool.t ->
  logger:Logger.t ->
  constraint_constants:Genesis_constants.Constraint_constants.t ->
  tf_diffs:Resource_pool.transition_frontier_diff Pipe_lib.Strict_pipe.Reader.t ->
  log_gossip_heard:bool ->
  on_remote_push:( unit -> unit Async_kernel.Deferred.t ) ->
  t * Remote_sink.t * Local_sink.t

val resource_pool : t -> Resource_pool.t

val broadcasts : t -> Diff_versioned.t Pipe_lib.Linear_pipe.Reader.t

val create_rate_limiter : unit -> Rate_limiter.t

val apply_and_broadcast : 
  t ->
  Diff_versioned.verified Network_peer.Envelope.Incoming.t ->
  Broadcast_callback.t ->
  unit Async_kernel.Deferred.t