Make (distributed_dsl.Distributed

Parameters

module State : sig ... end

module Message : sig ... end

module Message_delay : Message_delay_intf with type message := Message.t

module Message_label : sig ... end

module Timer_label : sig ... end

module Condition_label : sig ... end

Signature

type t

module Timer_transport : 
  Fake_timer_transport_intf
    with type message := Message.t
     and type peer := Trivial_peer.t

module MyNode : sig ... end

module Identifier : sig ... end

type change =

| Delete of Identifier.t

| Add of MyNode.t

val loop : 
  t ->
  stop:unit Async_kernel.Deferred.t ->
  max_iters:int option ->
  unit Async_kernel.Deferred.t

val change : t -> change list -> unit

val create : 
  count:int ->
  initial_state:State.t ->
  ( int -> MyNode.message_command list * MyNode.handle_command list ) ->
  stop:unit Async_kernel.Deferred.t ->
  t