@spec broadcast_all(any()) :: :ok

Broadcast a message to all active sessions.

Examples

iex> Phoenix.SessionProcess.Helpers.broadcast_all({:system_message, "Maintenance in 5 minutes"})
:ok

@spec create_session_with_retry(binary(), module() | nil, any() | nil, integer()) ::
  {:ok, pid()} | {:error, term()}

Create a session with automatic retry on rate limit.

Examples

iex> Phoenix.SessionProcess.Helpers.create_session_with_retry("session_123")
{:ok, #PID<0.123.0>}

@spec find_sessions_by_pattern(Regex.t()) :: [binary()]

Find sessions by pattern matching on session ID.

Examples

iex> Phoenix.SessionProcess.Helpers.find_sessions_by_pattern(~r/user_.*/)
["user_123", "user_456"]

@spec get_session_module(pid()) :: module()

Gets the session module for a given process PID.

@spec safe_call(binary(), any(), integer(), non_neg_integer()) ::
  {:ok, any()} | {:error, term()}

Safely call a session with automatic retry on timeout.

Examples

iex> Phoenix.SessionProcess.Helpers.safe_call("session_123", :get_user, 3)
{:ok, %User{}}

@spec session_health() :: %{healthy: integer(), crashed: integer(), total: integer()}

Get health status for all sessions.

Examples

iex> Phoenix.SessionProcess.Helpers.session_health()
%{healthy: 10, crashed: 0, total: 10}

@spec start_sessions([binary()]) :: [{binary(), {:ok, pid()} | {:error, term()}}]

Start sessions for multiple session IDs in parallel.

Examples

iex> Phoenix.SessionProcess.Helpers.start_sessions(["session1", "session2"])
[{"session1", {:ok, #PID<0.123.0>}}, {"session2", {:ok, #PID<0.124.0>}}]

@spec terminate_sessions([binary()]) :: [{binary(), :ok | {:error, term()}}]

Terminate multiple sessions in parallel.

Examples

iex> Phoenix.SessionProcess.Helpers.terminate_sessions(["session1", "session2"])
[{"session1", :ok}, {"session2", {:error, :not_found}}]