tweet_aggregator

TweetAggregator

Distributed Tweet Aggregator

Nodes

• GateKeeper
• Aggregator
• Search.Client

Example Usage

1. Export required environment vairables for GateKeeper to make OAuth requests

$ touch .env

# .env
export TWEET_CONSUMER_KEY=...
export TWEET_CONSUMER_SECRET=...
export TWEET_ACCESS_TOKEN=...
export TWEET_ACCESS_TOKEN_SECRET=...

$ source .env

2. Start GateKeeper node

$ iex --name gatekeeper@127.0.0.1 --cookie foo -S mix
iex(gatekeeper@127.0.0.1)1> TweetAggregator.GateKeeper.become_leader
:yes

2. Start Aggregator node

$ iex --name aggregator@127.0.0.1 --cookie foo -S mix
iex(aggregator@127.0.0.1)1> TweetAggregator.Aggregator.become_leader
:yes

3. Start client search node(s)

$ iex --name client1@127.0.0.1 --cookie foo -S mix
iex(client1@127.0.0.1)1> Node.connect :"aggregator@127.0.0.1"
true
NodeMonitor: aggregator@127.0.0.1 joined

iex(client1@127.0.0.1)2> Node.connect :"gatekeeper@127.0.0.1"
true
NodeMonitor: gatekeeper@127.0.0.1 joined

iex(client1@127.0.0.1)3> TweetAggregator.Search.Client.poll ["elixir"]
New results
Client: Got 1 result(s)

4. Watch Aggregator notifications on Aggregator node

>> client1
@noctarius2k: Elixir - The Ruby like Erlang VM Language http://t.co/FzCeytAv5t