aquin.engine.sync Namespace Reference

Functions
httpx.Client	_client ()
int	push_events (str session_id, list[dict[str, Any]] events, str api_key, str base_url, float timeout=15.0)
dict[str, Any]	fetch_session_state (str session_id, str api_key, str base_url, float timeout=10.0)
dict[str, Any]	load_session_memory (str session_id, str api_key, str base_url, *, dict[str, Any]|None local=None)

Function Documentation

_client()

httpx.Client _client ( )

protected

Definition at line 19 of file sync.py.

Referenced by fetch_session_state().

fetch_session_state()

dict[str, Any] fetch_session_state	(	str	session_id,
		str	api_key,
		str	base_url,
		float	timeout = 10.0 )

Load session state from cloud; merge memory from snapshot + event replay.

Definition at line 35 of file sync.py.

References _client().

Referenced by load_session_memory().

load_session_memory()

dict[str, Any] load_session_memory	(	str	session_id,
		str	api_key,
		str	base_url,
		*	,
		dict[str, Any] | None	local = None )

Merged memory: cloud snapshot/events, then local ctx, then disk cache.

Definition at line 66 of file sync.py.

References fetch_session_state().

push_events()

int push_events	(	str	session_id,
		list[dict[str, Any]]	events,
		str	api_key,
		str	base_url,
		float	timeout = 15.0 )

No-op :  web sync event push removed.

Definition at line 23 of file sync.py.