Packages

poolder

0.1.3
0.1.16 0.1.15 0.1.14 0.1.13 0.1.12 0.1.11 0.1.10 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

A compile-time builder that generates a concurrent pool of worker processes, batchers and schedulers for parallel task execution

HexDocs

Current section

Files

Jump to
Readme
17 Versions
0 Dependencies
Dependants
Files
Activity
poolder lib behaviour.ex
Raw

lib/behaviour.ex 

defmodule Poolder.Behaviour do

  @callback handle_init(id :: integer()) :: {:ok, state :: any()}

  @callback handle_pool_ready(supervisor_pid :: pid()) :: any()

  @callback handle_job(data :: any(), state :: any()) ::

              {:noreply, state :: any()}

              | {:push, any(), any(), state :: any()}

              | {:reply, reply :: any(), state :: any()}

              | {:stop, reason :: any(), state :: any()}

              | {:exit, reason :: any(), state :: any()}

  @callback handle_error(data :: any(), attempt :: integer(), error :: any(), state :: any()) ::

              {:retry, state :: any()} | {:delay, integer()} | :halt



  @callback handle_periodic_job(name :: atom()) ::

              :ok

              | :stop

              | :exit

              | {:set, integer()}

              | {:set, atom(), integer()}

              | {:kill, atom()}

end