diff options
| author | kballou <kballou@devnulllabs.io> | 2014-10-21 18:08:30 -0600 |
|---|---|---|
| committer | kballou <kballou@devnulllabs.io> | 2014-10-21 18:11:55 -0600 |
| commit | 5a9a4ded49b32322a702e9ae3a02d3e4238b41a0 (patch) | |
| tree | e47ef0317a956177daac765f8727d93d779dc4a1 | |
| parent | ee9e42ff17dc2bafd287fa1f069a4de685314559 (diff) | |
| download | poolparty-5a9a4ded49b32322a702e9ae3a02d3e4238b41a0.tar.gz poolparty-5a9a4ded49b32322a702e9ae3a02d3e4238b41a0.tar.xz | |
Add `leave` to pool scheduler api
| -rw-r--r-- | lib/poolparty/scheduler.ex | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/lib/poolparty/scheduler.ex b/lib/poolparty/scheduler.ex index dc9e1b3..dc4d731 100644 --- a/lib/poolparty/scheduler.ex +++ b/lib/poolparty/scheduler.ex @@ -30,6 +30,11 @@ defmodule PoolParty.Scheduler do GenServer.cast(__MODULE__, {:ready, result, worker_pid}) end + def leave(worker_pid) do + Logger.debug("[#{__MODULE__}]: Worker leaving pool") + GenServer.cast(__MODULE__, {:leave, worker_pid}) + end + def process(func, args, from) do Logger.debug("[#{__MODULE__}]: Casting work request") GenServer.cast(__MODULE__, {:process, func, args, from}) |