LemonRouter.SessionTransitions (lemon_router v0.1.0)

View Source

Pure queue/state transitions for LemonRouter.SessionCoordinator.

Summary

Functions

abort_run(state, run_id, reason)
abort_session(state, session_key, reason)
active_down(state, pid, mon_ref)
active_down(state, pid, mon_ref, now_ms)
cancel(state, reason)
cancel_session(state, session_key, reason)
dispatch_steer_failed(state, submission_run_id)
dispatch_steer_failed(state, submission_run_id, now_ms)
steer_accepted(state, submission_run_id)
steer_rejected(state, submission_run_id)
steer_rejected(state, submission_run_id, now_ms)
submit(state, submission, now_ms)

Functions

abort_run(state, run_id, reason)

@spec abort_run(LemonRouter.SessionState.t(), binary(), term()) ::
  {:ok, LemonRouter.SessionState.t(), [LemonRouter.QueueEffect.t()]}

abort_session(state, session_key, reason)

@spec abort_session(LemonRouter.SessionState.t(), binary(), term()) ::
  {:ok, LemonRouter.SessionState.t(), [LemonRouter.QueueEffect.t()]}

active_down(state, pid, mon_ref)

@spec active_down(LemonRouter.SessionState.t(), pid(), reference()) ::
  {:ok, LemonRouter.SessionState.t(), [LemonRouter.QueueEffect.t()]}

active_down(state, pid, mon_ref, now_ms)

@spec active_down(LemonRouter.SessionState.t(), pid(), reference(), integer()) ::
  {:ok, LemonRouter.SessionState.t(), [LemonRouter.QueueEffect.t()]}

cancel(state, reason)

@spec cancel(LemonRouter.SessionState.t(), term()) ::
  {:ok, LemonRouter.SessionState.t(), [LemonRouter.QueueEffect.t()]}

cancel_session(state, session_key, reason)

@spec cancel_session(LemonRouter.SessionState.t(), binary(), term()) ::
  {:ok, LemonRouter.SessionState.t(), [LemonRouter.QueueEffect.t()]}

dispatch_steer_failed(state, submission_run_id)

@spec dispatch_steer_failed(LemonRouter.SessionState.t(), binary()) ::
  {:ok, LemonRouter.SessionState.t(), [LemonRouter.QueueEffect.t()]}

dispatch_steer_failed(state, submission_run_id, now_ms)

@spec dispatch_steer_failed(LemonRouter.SessionState.t(), binary(), integer()) ::
  {:ok, LemonRouter.SessionState.t(), [LemonRouter.QueueEffect.t()]}

steer_accepted(state, submission_run_id)

@spec steer_accepted(LemonRouter.SessionState.t(), binary()) ::
  {:ok, LemonRouter.SessionState.t(), [LemonRouter.QueueEffect.t()]}

steer_rejected(state, submission_run_id)

@spec steer_rejected(LemonRouter.SessionState.t(), binary()) ::
  {:ok, LemonRouter.SessionState.t(), [LemonRouter.QueueEffect.t()]}

steer_rejected(state, submission_run_id, now_ms)

@spec steer_rejected(LemonRouter.SessionState.t(), binary(), integer()) ::
  {:ok, LemonRouter.SessionState.t(), [LemonRouter.QueueEffect.t()]}

submit(state, submission, now_ms)

@spec submit(LemonRouter.SessionState.t(), LemonRouter.Submission.t(), integer()) ::
  {:ok, LemonRouter.SessionState.t(), [LemonRouter.QueueEffect.t()]}