View Source Chorex.Proxy (Chorex v0.4.3)

@type state() :: %{
  pid_session: %{required(pid()) => session_key()},
  session_data: any(),
  session_handler: %{required(session_key()) => pid()}
}

Functions

begin_session(proxy, session_pids, proxy_module, start_func, start_args)

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

fetch_state(config)

init(init_state)

Callback implementation for GenServer.init/1.

send_proxied(proxy_pid, msg)

@spec send_proxied(pid(), any()) :: any()

Send a message to a proxied service.

Handles the wrapping of the message with the {:chorex, self(), ...} tuple so that the proxy knows which session to send the message on to.

set_state(proxy, new_state)

update_state(config, update_fn)

@spec update_state(map(), (session_state() -> {any(), session_state()})) :: any()

Updates the session state for the current process.

For use by proxied processes.