MaxiTaxi is a very simple application:

1. Taxis send their location information to MaxiTaxi.
2. Customers can order a taxi and use it to get from A to B.

The system will track:

1. The last known position of each taxi.
2. Whether a taxi is occupied or not.

The following operations will be supported:

1. Update the location of a taxi.
2. Search for a nearby taxi that is unoccupied.
3. Enter a taxi.
4. Leave a taxi.

The tutorial is split into 4 branches:

• exercise_1
• exercise_2
• exercise_3
• exercise_4

You can start with exercise_1. If you have completed the exercises, then you can continue in that branch with your own solutions, or you can choose to switch to the exercise_2 branch to continue.

The topics covered are:

1. libcluster & :rpc
2. Distributed location database
3. Horde
4. Horde partition tolerance

Install libcluster in the application.

Configure libcluster using the guide in the README (Cluster.Strategy.Epmd) to connect nodes [email protected] and [email protected].

Start the nodes:

iex --name [email protected] -S mix

iex --name [email protected] -S mix

Confirm that the nodes are connected:

iex([email protected])1> Node.list()
[:"[email protected]"]

We will distribute the location database to all nodes in the cluster. We will use :rpc.call/4 for this.

1. Send updates to all nodes in the cluster using :rpc.call/4.
2. Implement a TTL of 2s on updates to prevent stale information from being served (in case of a netsplit for example).

Use send/2 instead of :rpc.call/4. This will help us avoid bottlenecks in :rpc.

Reminder: {name, node}.

Now we have a "distributed location database", but there is no way for nodes to recover if there is a conflict.

1. Use delta_crdt to make the database eventually consistent.

Note: information on nodes can still be out of date, but after a netsplit the database will globally converge.

A taxi can be entered and exited, but we can't allow more than one customer to enter a taxi.

We will use Horde (docs) to distribute taxi processes among the nodes in the cluster. We will register and access the taxi processes using Horde.Registry. Horde.Registry will also keep them unique.

Horde.DynamicSupervisor will ensure that if a node goes down, that the taxi processes are restarted on another node.

1. start taxi state processes using Horde.DynamicSupervisor
2. register processes with Horde.Registry

1. read the docs of Horde and figure out how to handle registry conflicts.