ReqManagedAgents.Host.Locator (req_managed_agents_host v0.2.0)

Durable external_id -> upstream identity map over a Store. Reads and writes Locator.Record rows; translates the store's :miss (and any non-Record value found in a shared store) to the caller-facing :error.

Summary

Types

external_id()

Functions

delete_transcript(store, external_id)

Delete a persisted transcript (record-removal cleanup).

fetch(store, external_id)

fetch_transcript(store, external_id)

Fetch a persisted transcript. :miss when none was stored.

list(store)

list_by(store, metadata)

mark_context_sent(store, external_id)

put(store, record)

put_transcript(store, external_id, messages)

Persist a session transcript under the sibling key {:transcript, external_id}.

set_status(store, external_id, status)

Types

external_id()

@type external_id() :: String.t()

Functions

delete_transcript(store, external_id)

@spec delete_transcript(ReqManagedAgents.Host.Store.store(), external_id()) :: :ok

Delete a persisted transcript (record-removal cleanup).

fetch(store, external_id)

@spec fetch(ReqManagedAgents.Host.Store.store(), external_id()) ::
  {:ok, ReqManagedAgents.Host.Locator.Record.t()} | :error

fetch_transcript(store, external_id)

@spec fetch_transcript(ReqManagedAgents.Host.Store.store(), external_id()) ::
  {:ok, [map()]} | :miss

Fetch a persisted transcript. :miss when none was stored.

list(store)

@spec list(ReqManagedAgents.Host.Store.store()) :: [
  ReqManagedAgents.Host.Locator.Record.t()
]

list_by(store, metadata)

@spec list_by(ReqManagedAgents.Host.Store.store(), map()) :: [
  ReqManagedAgents.Host.Locator.Record.t()
]

mark_context_sent(store, external_id)

@spec mark_context_sent(ReqManagedAgents.Host.Store.store(), external_id()) ::
  :ok | :error

put(store, record)

@spec put(
  ReqManagedAgents.Host.Store.store(),
  ReqManagedAgents.Host.Locator.Record.t()
) :: :ok

put_transcript(store, external_id, messages)

@spec put_transcript(ReqManagedAgents.Host.Store.store(), external_id(), [map()]) ::
  :ok

Persist a session transcript under the sibling key {:transcript, external_id}.

set_status(store, external_id, status)

@spec set_status(
  ReqManagedAgents.Host.Store.store(),
  external_id(),
  ReqManagedAgents.Host.Locator.Record.status()
) :: :ok | :error