Index of values


(>>=) [Async.Std]
>>= is used to chain blocking functions together.
(>>|) [Async.Std]
>>| is similar to >>=, but it is used for non-blocking functions.

A
after [Async.Std]
a deferred that becomes determined after the given amount of time
all [Async.Std.Deferred]
all ts returns a deferred that becomes determined when every t in ts is determined.
any [Async.Std.Deferred]
any ts returns a deferred that is fulfilled when any of the underlying deferreds is fulfilled

B
both [Async.Std.Deferred]
both t1 t2 becomes determined after both t1 and t2 become determined.

C
combine [Combiner.Make]
Function for grouping output from the mappers by key
connect [Async.Std.Tcp]
Create a connection to the given address.
create [AQueue]
Create a new queue
create [Async.Std.Pipe]
Creates a new pipe, and returns the reader and writer ends.
create [Async.Std.Ivar]
Create a new unfilled Ivar.t

D
don't_wait_for [Async.Std]
a convenience function for ignoring a deferred value

E
every [Async.Std]
every t f schedules f to be executed every t seconds.

F
file_contents [Async.Std.Reader]
file_contents filename returns the string with the full contents of the file
file_lines [Async.Std.Reader]
file_lines filename returns a list of the lines in the named file.
fill [Async.Std.Ivar]
Fill the given Ivar.t.
fill_if_empty [Async.Std.Ivar]
Fill the given Ivar.t.
filter [Async.Std.Deferred.List]
find [Async.Std.Deferred.List]
fold [Async.Std.Deferred.List]

G
get_app [MapReduce]
get_job [MapReduce]

I
init [Worker]
Start the worker server.
init [RemoteController]
set up the map reduce controller to connect the the provided worker addresses
is_empty [Async.Std.Ivar]
Return true if the Ivar.t is empty.
is_full [Async.Std.Ivar]
Return true if the Ivar.t is full.
iter [Async.Std.Deferred.List]

L
list_apps [MapReduce]
list_jobs [MapReduce]

M
main [MapReduce.EntryPoint]
the entry point of an app
map [MapReduce.Job]
perform the map phase.
map [Async.Std.Deferred.List]
map_reduce [MapReduce.Controller]
Execute that map and reduce phase of Job on the given list of inputs.

N
name [MapReduce.App]
a unique name for the app
name [MapReduce.Job]
a unique name for the job
never [Async.Std]
a deferred that is never determined

P
pop [AQueue]
Wait until an element becomes available, and then return it.
printf [Async.Std]
This function is an Async-friendly version of Printf.printf, which is very useful for debugging.
push [AQueue]
Add an element to the queue.

R
read [Async.Std.Pipe]
Reads data from the reader end of the pipe.
read [Async.Std.Ivar]
read iv returns the Deferred.t associated with iv.
read_line [Async.Std.Reader]
reads a single line from the given input stream.
receive [Protocol.Marshalable]
receive and send receive and send messages.
reduce [MapReduce.Job]
perform the reduce phase.
register_app [MapReduce]
register_job [MapReduce]
return [Async.Std]
return is used to create a Deferred.t that is immediately determined with the provided value.
run [Worker.Make]
Handle all of the requests for a single connection.

S
send [Protocol.Marshalable]
shutdown [Async.Std.Socket]
Close one or both ends of a socket

T
to_host_and_port [Async.Std.Tcp]
Interprets a string and int as a network host and port that can be connected to.
try_with [Async.Std]
try_with f runs the blocking function f, and returns Core.Std.Ok x if f () returns x.

W
with_timeout [Async.Std]
with_timeout t x will become determined with `Result v if x becomes determined with v within the timespan t.
write [Async.Std.Pipe]
Writes data into the writer end of a pipe.
write_line [Async.Std.Writer]
Writes a line of text to the given output stream.