ASM.SessionControl (ASM v0.12.1)

Provider-native session control helpers for historical resume and interrupt-then-intervene flows.

Summary

resume_target()

Returns a stable lineage descriptor connecting semantic, ASM, and provider sessions.

lineage_keys()

Returns a stable provider fact for pressure or reconnect events.

@type provider_or_session() :: ASM.Provider.provider_name() | pid()

@type resume_target() :: :checkpoint | :latest | String.t()

@spec checkpoint(pid()) :: {:ok, map() | nil} | {:error, ASM.Error.t()}

@spec continuation_from_checkpoint(
  map() | nil,
  keyword()
) :: {:ok, map()} | {:error, ASM.Error.t()}

@spec intervene(pid(), String.t(), String.t(), keyword()) ::
  {:ok, String.t(), pid() | :queued} | {:error, ASM.Error.t()}

@spec lineage_descriptor(
  provider_or_session() | map(),
  keyword()
) :: {:ok, map()} | {:error, ASM.Error.t()}

Returns a stable lineage descriptor connecting semantic, ASM, and provider sessions.

@spec lineage_keys() :: [atom(), ...]

@spec list_provider_sessions(
  provider_or_session(),
  keyword()
) :: {:ok, [ASM.SessionControl.Entry.t()]} | {:error, ASM.Error.t()}

@spec pause(pid(), String.t()) :: :ok | {:error, ASM.Error.t()}

@spec provider_fact(:pressure | :reconnect, map()) :: map()

Returns a stable provider fact for pressure or reconnect events.

@spec resume_run(pid(), String.t(), keyword()) ::
  {:ok, String.t(), pid() | :queued} | {:error, ASM.Error.t()}