Packages

poolex

1.4.1
1.6.4 1.6.3 1.6.2 1.6.1 1.6.0 1.5.0 1.5.0-rc.0 1.4.2 1.4.1 1.4.0 1.3.0 1.2.1 1.2.0 1.1.0 1.0.0 1.0.0-rc.0 0.10.0 0.9.0 0.9.0-rc.2 0.9.0-rc.1 0.9.0-rc.0 0.8.0 0.8.0-rc.1 0.8.0-rc.0 0.7.6 0.7.5 0.7.4 retired 0.7.3 0.7.2 0.7.1 0.7.0 0.6.1 0.6.0 0.5.1 0.5.0 0.4.0 0.3.1 retired 0.3.0 retired 0.2.2 0.2.1 0.2.0 0.1.1 0.1.0

The library for managing pools of workers.

HexDocs

Current section

Files

Jump to
Readme
43 Versions
2 Dependencies
Dependants
Files
Activity
poolex lib poolex private state.ex
Raw

lib/poolex/private/state.ex 

defmodule Poolex.Private.State do

  @moduledoc """

  Internal structure containing the state of the pool.



  Can be used for debugging.

  """



  @enforce_keys [

    :failed_workers_retry_interval,

    :max_overflow,

    :pool_id,

    :supervisor,

    :worker_args,

    :worker_module,

    :worker_start_fun,

    :worker_shutdown_delay

  ]



  defstruct @enforce_keys ++

              [

                busy_workers_impl: nil,

                busy_workers_state: nil,

                failed_to_start_workers_count: 0,

                idle_overflowed_workers_impl: nil,

                idle_overflowed_workers_last_touches: %{},

                idle_overflowed_workers_state: nil,

                idle_workers_impl: nil,

                idle_workers_state: nil,

                monitors: %{},

                overflow: 0,

                waiting_callers_impl: nil,

                waiting_callers_state: nil

              ]



  @type t() :: %__MODULE__{

          busy_workers_impl: module(),

          busy_workers_state: nil | Poolex.Workers.Behaviour.state(),

          failed_to_start_workers_count: non_neg_integer(),

          failed_workers_retry_interval: timeout() | nil,

          idle_overflowed_workers_impl: module(),

          idle_overflowed_workers_last_touches: %{pid() => Time.t()},

          idle_overflowed_workers_state: nil | Poolex.Workers.Behaviour.state(),

          idle_workers_impl: module(),

          idle_workers_state: nil | Poolex.Workers.Behaviour.state(),

          max_overflow: non_neg_integer(),

          monitors: %{reference() => Poolex.Private.Monitoring.kind_of_process()},

          overflow: non_neg_integer(),

          pool_id: Poolex.pool_id(),

          supervisor: pid(),

          waiting_callers_impl: module(),

          waiting_callers_state: nil | Poolex.Callers.Behaviour.state(),

          worker_args: list(any()),

          worker_module: module(),

          worker_shutdown_delay: timeout(),

          worker_start_fun: atom()

        }

end