Struct NodeEventStore 

pub struct NodeEventStore { /* private fields */ }

OpenClaw event store wrapper for Node.js.

Provides append-only event storage for session events with CRDT projections for conflict-free state.

Implementations

impl NodeEventStore

pub fn instance_of<V: NapiRaw>(env: Env, value: V) -> Result<bool>

impl NodeEventStore

pub fn into_reference( val: NodeEventStore, env: Env, ) -> Result<Reference<NodeEventStore>>

pub fn into_instance(self, env: Env) -> Result<ClassInstance<NodeEventStore>>

impl NodeEventStore

pub fn new(path: String) -> Result<Self>

Open or create an event store at the given path.

pub fn append_event( &self, session_key: String, agent_id: String, event_type: String, data: String, ) -> Result<String>

Append a session event and return the event ID.

Arguments

• session_key - The session key
• agent_id - The agent ID
• event_type - Event type: “session_started”, “message_received”, “message_sent”, “agent_response”, “session_ended”, “state_changed”, “tool_called”, “tool_result”
• data - JSON data for the event

pub fn get_events(&self, session_key: String) -> Result<String>

Get all events for a session as JSON.

pub fn get_projection(&self, session_key: String) -> Result<String>

Get the session projection as JSON.

The projection is a materialized view of the session state derived from the event stream.

pub fn list_sessions(&self) -> Result<Vec<String>>

List all session keys.

pub fn flush(&self) -> Result<()>

Flush pending writes to disk.

Trait Implementations

impl FromNapiMutRef for NodeEventStore

unsafe fn from_napi_mut_ref( env: napi_env, napi_val: napi_value, ) -> Result<&'static mut Self>

Safety

impl FromNapiRef for NodeEventStore

unsafe fn from_napi_ref( env: napi_env, napi_val: napi_value, ) -> Result<&'static Self>

Safety

impl FromNapiValue for &NodeEventStore

unsafe fn from_napi_value(env: napi_env, napi_val: napi_value) -> Result<Self>

Safety

fn from_unknown(value: JsUnknown) -> Result<Self, Error>

impl FromNapiValue for &mut NodeEventStore

unsafe fn from_napi_value(env: napi_env, napi_val: napi_value) -> Result<Self>

Safety

fn from_unknown(value: JsUnknown) -> Result<Self, Error>

impl ObjectFinalize for NodeEventStore

fn finalize(self, env: Env) -> Result<(), Error>

impl ToNapiValue for NodeEventStore

unsafe fn to_napi_value( env: napi_env, val: NodeEventStore, ) -> Result<napi_value>

Safety

impl TypeName for &NodeEventStore

fn type_name() -> &'static str

fn value_type() -> ValueType

impl TypeName for &mut NodeEventStore

fn type_name() -> &'static str

fn value_type() -> ValueType

impl TypeName for NodeEventStore

fn type_name() -> &'static str

fn value_type() -> ValueType

impl ValidateNapiValue for &NodeEventStore

unsafe fn validate(env: napi_env, napi_val: napi_value) -> Result<napi_value>

Safety

impl ValidateNapiValue for &mut NodeEventStore

unsafe fn validate(env: napi_env, napi_val: napi_value) -> Result<napi_value>

Safety