Index of values


__t_of_sexp__ [Import.Cluster]

B
bin_read_t [Import.Cluster]
bin_read_t_ [Import.Cluster]
bin_read_t__ [Import.Cluster]
bin_reader_t [Import.Cluster]
bin_size_t [Import.Cluster]
bin_t [Import.Cluster]
bin_write_t [Import.Cluster]
bin_write_t_ [Import.Cluster]
bin_writer_t [Import.Cluster]

C
clients [Hub]
close [Hub]
close [Channel]
create [Hub]
create [Channel]
create is type-unsafe, and should not be used by user code.
create_process [Master_process]
Request a new process.

D
dbp [Import]
debug [Import]

E
errors [Channel]
Similar to Monitor.errors, collects all writer errors.

F
flushed [Hub]
flushed [Channel]

H
hub [Intf]
create a new hub.

I
init [Master_process]
init initializes the system and creates the master process.
init [Intf]
init initializes the system and creates the master process.
is_worker_machine [Intf]
returns true if this is a worker machine.

L
listen [Hub]
listen and listen_simple start a loop that accepts connections from clients that wish to open channels connected to the hub.
listen_simple [Hub]

M
mine [Token]
my_ip [Import]

O
oc [Import]
open_channel [Hub]
open_channel may be called even in a different process than the creator of the hub.

P
pre_pack [Channel]

R
random [Master_process]
random [Intf]
random_in [Master_process]
random_in [Intf]
read [Channel]
read_full [Channel]
round_robin [Master_process]
round_robin [Intf]
run [Worker_process]
run [Intf]
Run the specified closure in another process and return its result.

S
send [Hub]
send_to_all [Hub]
sexp_of_t [Import.Cluster]
sexp_of_t [Hub.Client_id]
shutdown [Master_process]
Tell the master process to shutdown.
shutdown [Intf]
shutdown requests that the master process kill all workers and then shutdown.
socket [Hub]
socket [Channel]
spawn [Intf]
spawn f spawns a process running f, supplying f a hub that it may use to communicate with other processes.

T
t_of_sexp [Import.Cluster]
t_of_sexp [Hub.Client_id]

V
valid [Token]

W
write [Channel]
write_pre_packed [Channel]