Message (mina_networking.Mina_networking.Gossip

module Master : sig ... end

include module type of struct include Master.T end

type msg = Master.T.msg =

| New_state of Mina_block.t

| Snark_pool_diff of Network_pool.Snark_pool.Resource_pool.Diff.t

| Transaction_pool_diff of Network_pool.Transaction_pool.Resource_pool.Diff.t

val msg_to_yojson : msg -> Yojson.Safe.t

val _ : msg -> Yojson.Safe.t

val msg_of_sexp : Ppx_sexp_conv_lib.Sexp.t -> msg

val sexp_of_msg : msg -> Ppx_sexp_conv_lib.Sexp.t

type state_msg = Mina_block.t

type snark_pool_diff_msg = Network_pool.Snark_pool.Resource_pool.Diff.t

type transaction_pool_diff_msg =
  Network_pool.Transaction_pool.Resource_pool.Diff.t

module Register (Version : sig ... end) : sig ... end

val dispatch_multi : 
  Async_rpc_kernel__Versioned_rpc.Connection_with_menu.t ->
  Master.Caller.msg ->
  unit Core_kernel.Or_error.t

val implement_multi : 
  ?log_not_previously_seen_version:( name:string -> int -> unit ) ->
  ( 'state -> version:int -> Master.Callee.msg -> unit ) ->
  'state Async_rpc_kernel__.Rpc.Implementation.t list

val rpcs : unit -> Async_rpc_kernel__.Rpc.Any.t list

val versions : unit -> Core_kernel.Int.Set.t

val name : string

module V1 : sig ... end

module Latest = V1

val summary : Latest.T.msg -> string

type block_sink_msg =
  [ `Transition of state_msg Network_peer.Envelope.Incoming.t ]
  * [ `Time_received of Block_time.t ]
  * [ `Valid_cb of Mina_net2.Validation_callback.t ]

type tx_sink_msg =
  transaction_pool_diff_msg Network_peer.Envelope.Incoming.t
  * Mina_net2.Validation_callback.t

type snark_sink_msg =
  snark_pool_diff_msg Network_peer.Envelope.Incoming.t
  * Mina_net2.Validation_callback.t

type 'msg push_modifier =
  ( 'msg -> unit Async.Deferred.t ) ->
  'msg ->
  unit Async.Deferred.t

module type Sinks_intf = sig ... end

type ('sink_block, 'sink_tx, 'sink_snark) sinks_impl =
  (module Sinks_intf
  with type Block_sink.t = 'sink_block
   and type Snark_sink.t = 'sink_snark
   and type Tx_sink.t = 'sink_tx)

type sinks =

| Any_sinks : ( 'a, 'b, 'c ) sinks_impl * ('a * 'b * 'c) -> sinks