deque-blog’s gists

deque-blog / worker_history_result.ex

Created September 7, 2018 14:40

	[
	%Worker.LogEntry{event: "friend", origin: #PID<0.183.0>, time: 1},
	%Worker.LogEntry{event: "dear", origin: #PID<0.184.0>, time: 1},
	%Worker.LogEntry{event: "my", origin: #PID<0.185.0>, time: 1},
	%Worker.LogEntry{event: "hello", origin: #PID<0.186.0>, time: 1},
	%Worker.LogEntry{event: "how", origin: #PID<0.186.0>, time: 5},
	%Worker.LogEntry{event: "are", origin: #PID<0.185.0>, time: 6},
	%Worker.LogEntry{event: "in", origin: #PID<0.183.0>, time: 7},
	%Worker.LogEntry{event: "you", origin: #PID<0.184.0>, time: 7},
	%Worker.LogEntry{event: "glorious", origin: #PID<0.185.0>, time: 9},

deque-blog / worker.ex

Created September 7, 2018 14:35

	defmodule Worker do
	use GenServer

	def start_link(_) do
	GenServer.start_link(__MODULE__, %{}, [])
	end

	def get_history(self) do
	GenServer.call(self, :get_history)
	end

deque-blog / pool.ex

Created September 7, 2018 14:34

	defmodule Pool do

	def start_link(poolName, %{worker_module: worker_module, size: size}) do
	pool_config = [
	{:name, {:local, poolName}},
	{:worker_module, worker_module},
	{:size, size},
	{:max_overflow, 0}
	]
	children = [ :poolboy.child_spec(poolName, pool_config) ]

deque-blog / pub_sub.ex

Created September 7, 2018 14:32

	defmodule PubSub do
	alias Phoenix.PubSub

	def start_link() do
	import Supervisor.Spec, warn: false
	children = [
	supervisor(Phoenix.PubSub.PG2, [__MODULE__, []]),
	]
	Supervisor.start_link(children, strategy: :one_for_one)
	end

deque-blog / on_write_broadcast.ex

Last active September 12, 2018 13:54

PubSub.broadcast(@log_replication_topic, {:replication_log, logEntry})

deque-blog / on_write_new_state.ex

Last active September 12, 2018 14:00

	newWorkerState = %{ worker \| # Update worker state
	clock: worker.clock + 1, # - increment clock by one
	eventLog: [logEntry \| worker.eventLog] # - prepend log entry to event log
	}

deque-blog / on_write_log_entry.ex

Last active September 7, 2018 14:18

deque-blog / sorted_log.ex

Created September 7, 2018 14:09

sortedLog = Enum.sort_by(worker.eventLog, fn event -> {event.time, event.origin} end)

deque-blog / worker_log_entry.ex

Last active September 12, 2018 12:05

	defmodule LogEntry do
	defstruct origin: nil, time: 0, event: nil
	end

deque-blog / on_node_pop.ex

Last active September 5, 2018 15:13

	def init(_) do
	PubSub.subscribe(@replication_log_topic, self())
	{:ok, %State{ name: self(), clock: 1, eventLog: [] }}
	end