LlmCore.Pipelines.MemoryPipeline (llm_core v0.6.0)

Copy Markdown View Source

ALF pipeline orchestrating REST memory operations (retain, recall, reflect). It centralizes caching, circuit breaker gating, retries, and async buffering.

Summary

Functions

alf_components()
call(event, opts \\ [debug: false])
cast(event, opts \\ [debug: false, send_result: false])
components()
flow(flow, names, opts \\ [debug: false])
recall(query, opts \\ [])
reflect(question, opts \\ [])
retain_async(content, metadata, opts \\ [])
retain_sync(content, metadata, opts \\ [])
start()
start(opts)
started?()
stop()
stream(stream, opts \\ [debug: false])

Functions

alf_components()

call(event, opts \\ [debug: false])

@spec call(any(), Keyword.t()) :: any() | [any()] | nil
@spec call(any(), Keyword.t()) :: reference()

cast(event, opts \\ [debug: false, send_result: false])

components()

@spec components() :: [map()]

flow(flow, names, opts \\ [debug: false])

@spec flow(map(), list(), Keyword.t()) :: Enumerable.t()

recall(query, opts \\ [])

@spec recall(
  String.t(),
  keyword()
) :: {:ok, [map()]} | {:error, term()}

reflect(question, opts \\ [])

@spec reflect(
  String.t(),
  keyword()
) :: {:ok, term()} | {:error, term()}

retain_async(content, metadata, opts \\ [])

@spec retain_async(String.t(), map(), keyword()) :: :ok

retain_sync(content, metadata, opts \\ [])

@spec retain_sync(String.t(), map(), keyword()) :: {:ok, map()} | {:error, term()}

start()

@spec start() :: :ok

start(opts)

@spec start(list()) :: :ok

started?()

@spec started?() :: true | false

stop()

@spec stop() :: :ok | {:exit, {atom(), any()}}

stream(stream, opts \\ [debug: false])

@spec stream(Enumerable.t(), Keyword.t()) :: Enumerable.t()