AdaSdk.Events (ada_sdk v0.0.1)

Copy Markdown View Source

Summary

Functions

event_names()
on_memory_ingest_finished(principal, handler)
on_memory_ingest_started(principal, handler)
on_memory_recall_finished(principal, handler)
on_memory_recall_started(principal, handler)

Functions

event_names()

@spec event_names() :: [atom()]

on_memory_ingest_finished(principal, handler)

@spec on_memory_ingest_finished(
  AdaSdk.Principal.t(),
  (Ada.V1.MemoryIngestFinished.t() -> term())
) ::
  {:ok, AdaSdk.StreamHub.unsubscribe()} | {:error, :closed | :invalid_handler}

on_memory_ingest_started(principal, handler)

@spec on_memory_ingest_started(
  AdaSdk.Principal.t(),
  (Ada.V1.MemoryIngestStarted.t() -> term())
) ::
  {:ok, AdaSdk.StreamHub.unsubscribe()} | {:error, :closed | :invalid_handler}

on_memory_recall_finished(principal, handler)

@spec on_memory_recall_finished(
  AdaSdk.Principal.t(),
  (Ada.V1.MemoryRecallFinished.t() -> term())
) ::
  {:ok, AdaSdk.StreamHub.unsubscribe()} | {:error, :closed | :invalid_handler}

on_memory_recall_started(principal, handler)

@spec on_memory_recall_started(
  AdaSdk.Principal.t(),
  (Ada.V1.MemoryRecallStarted.t() -> term())
) ::
  {:ok, AdaSdk.StreamHub.unsubscribe()} | {:error, :closed | :invalid_handler}