Emerson Macedo emerleite

Only dependencies are Elixir, Erlang, and glut to access OpenGL.
No UI threads! Individual processes can be used to track mouse
Slides track mouse as long as button is down https://youtu.be/77FW-jrCyCs?t=37m35s
Sliders can be rotated https://youtu.be/77FW-jrCyCs?t=40m4s
500 lines animating still a few ms to render https://youtu.be/77FW-jrCyCs?t=43m34s

	Operating System: macOS"
	CPU Information: Intel(R) Core(TM) i7-4770HQ CPU @ 2.20GHz
	Number of Available Cores: 8
	Available memory: 16 GB
	Elixir 1.7.0-dev
	Erlang 21.0

	Benchmark suite executing with the following configuration:
	warmup: 5 s
	time: 30 s

	defmodule Upa.VideoWatchProgress do
	def save(attrs) do
	struct(Upa.VideoWatchProgress, attrs)
	\|> changeset
	\|> Upa.Repo.insert(on_conflict: insert_conflict_strategy(attrs))
	\|> case do
	{:error, _} = error -> raise Upa.DatabaseCommandError
	{:ok, changeset} -> :ok
	end
	end

	defmodule UpaEventSourcing.VideoWatchProgress.EventAggregator do
	def start_link(event) do
	Task.start_link(fn ->
	Upa.VideoWatchProgress.save(event) #Saves to the database
	end)
	end
	end

	defmodule UpaEventSourcing.VideoWatchProgress.EventConsumer do
	use ConsumerSupervisor

	children = [
	worker(UpaEventSourcing.VideoWatchProgress.EventStore, []),
	worker(UpaEventSourcing.VideoWatchProgress.EventConsumer, [
	%{producer: UpaEventSourcing.VideoWatchProgress.EventStore,
	processor: UpaEventSourcing.VideoWatchProgress.EventAggregator}
	])
	]

	config :upa, video_watch_progress_min_demand: 1
	config :upa, video_watch_progress_max_demand: 192

	config :upa, Upa.Repo,
	adapter: Ecto.Adapters.MySQL,
	hostname: "host.example.com",
	database: "our_database",
	username: "${MYSQL_USR}",
	password: "${MYSQL_PWD}",
	pool_size: 48

	defmodule UpaEventSourcing.VideoWatchProgress.EventStore do
	use GenStage

	@event_processing_timeout 11 #Max seconds to process a track video watch progress event

	def start_link() do

	#Phoenix Action
	def track_time(conn, params) do
	RequestParamsHandler.prepare(conn, params)
	\|> EventStore.enqueue #Send to GenStage pipeline
	send_resp(conn, 201, "")
	end

	#Supervision Tree definition for Events
	children = [
	worker(UpaEventSourcing.VideoWatchProgress.EventStore, []),
	worker(UpaEventSourcing.VideoWatchProgress.EventConsumer, [
	%{producer: UpaEventSourcing.VideoWatchProgress.EventStore,
	processor: UpaEventSourcing.VideoWatchProgress.EventAggregator}
	])
	]