Vibe.Agent.Streaming.Registry (vibe v0.2.3)

Copy Markdown View Source

ETS-backed callback and runtime-call registry for agent streaming.

Summary

Functions

callbacks(agent_id)

@spec callbacks(String.t()) :: {:ok, map()} | :error

delete_callbacks(agent_id)

@spec delete_callbacks(String.t()) :: :ok

delete_runtime_delta_calls(agent_id)

@spec delete_runtime_delta_calls(String.t()) :: :ok

ensure_tables!()

@spec ensure_tables!() :: :ok

mark_runtime_delta_call(agent_id, call_id)

@spec mark_runtime_delta_call(String.t(), String.t() | nil) :: :ok

put_callbacks(agent_id, callbacks)

@spec put_callbacks(String.t(), map()) :: :ok

runtime_delta_call?(agent_id, call_id)

@spec runtime_delta_call?(String.t(), String.t() | nil) :: boolean()