ReqManagedAgents.Host.Locator (req_managed_agents_host v0.1.0)

Copy Markdown View Source

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

fetch(store, external_id)
list(store)
list_by(store, metadata)
mark_context_sent(store, external_id)
put(store, record)
set_status(store, external_id, status)

Types

external_id()

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

Functions

fetch(store, external_id)

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

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

set_status(store, external_id, status)

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