View Source AntikytheraCore.ExecutorPool.WebsocketConnectionsCounter (antikythera v0.5.1)

A GenServer to count number of websocket connections that belong to the executor pool.

Before termination of the current host, all monitored websocket connections will be disconnected in order to prompt clients to reconnect to other active nodes (this is executed within temporary processes but uses monitors created by this GenServer).

Summary

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

gradually_terminate_all_ws_connections()
increment(epool_id, ws_pid)
set_max(epool_id, max)
start_link(list)
start_terminating_all_ws_connections()
stats(epool_id)

Functions

Link to this function

child_spec(init_arg)

View Source

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

gradually_terminate_all_ws_connections()

View Source 
@spec gradually_terminate_all_ws_connections() :: :ok
Link to this function

increment(epool_id, ws_pid)

View Source 
@spec increment(Antikythera.ExecutorPool.Id.t(), pid()) ::
  :ok | {:error, :too_many_connections}
Link to this function

set_max(epool_id, max)

View Source 
@spec set_max(Antikythera.ExecutorPool.Id.t(), non_neg_integer()) :: :ok
Link to this function

start_link(list)

View Source
Link to this function

start_terminating_all_ws_connections()

View Source 
@spec start_terminating_all_ws_connections() :: :ok
Link to this function

stats(epool_id)

View Source 
@spec stats(Antikythera.ExecutorPool.Id.t()) :: %{
  required(:count | :max | :rejected) => non_neg_integer()
}