Network_pool.Pool_sink
module type BC_ext = sig ... end
module type Pool_sink = sig ... end
module Base
(Diff : Intf.Resource_pool_diff_intf)
(BC :
BC_ext
with type resource_pool_diff = Diff.t
and type rejected_diff = Diff.rejected)
(Msg : sig ... end) :
Pool_sink
with type pool := Diff.pool
and type unwrapped_t =
Diff.verified Network_peer.Envelope.Incoming.t * BC.t
and type msg := Msg.raw_msg * Msg.raw_callback
module Local_sink
(Diff : Intf.Resource_pool_diff_intf)
(BC :
BC_ext
with type resource_pool_diff = Diff.t
and type rejected_diff = Diff.rejected) :
Pool_sink
with type pool := Diff.pool
and type unwrapped_t =
Diff.verified Network_peer.Envelope.Incoming.t * BC.t
and type msg :=
BC.resource_pool_diff
* ( ([ `Broadcasted | `Not_broadcasted ]
* BC.resource_pool_diff
* BC.rejected_diff)
Core_kernel.Or_error.t ->
unit )
module Remote_sink
(Diff : Intf.Resource_pool_diff_intf)
(BC :
BC_ext
with type resource_pool_diff = Diff.t
and type rejected_diff = Diff.rejected) :
Pool_sink
with type pool := Diff.pool
and type unwrapped_t =
Diff.verified Network_peer.Envelope.Incoming.t * BC.t
and type msg :=
BC.resource_pool_diff Network_peer.Envelope.Incoming.t
* Mina_net2.Validation_callback.t