| __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] |