Struct DelegationEventStore 

pub struct DelegationEventStore { /* private fields */ }

Implementations

impl DelegationEventStore

pub fn open( sessions: Arc<SessionStore>, ) -> Result<Arc<Self>, DelegationEventError>

Folds delegation records from root logs only. Depth-1 records live in the parent’s log, so roots are complete at startup; nested records arrive later through Self::extend_from_payloads when their tree is loaded.

pub fn extend_from_payloads( &self, payloads: &[(SessionId, Option<RunId>, EventPayload)], ) -> Result<Vec<DelegationEntry>, DelegationEventError>

Folds delegation records harvested from child logs (§4.1.2), returning the entries that changed so the engine can rebuild only what moved.

pub fn reserve( &self, invocation_id: InvocationId, parent_session_id: SessionId, parent_run_id: RunId, parent_tool_call_id: ToolCallId, child_agent: AgentSnapshot, revisions: DelegationRuntimeRevisions, selected_suffix: Vec<FrozenModelBinding>, cache_strategies: Vec<Option<FrozenCacheStrategy>>, request_fingerprint: Sha256Digest, request: DelegateRequestPayload, ) -> Result<DelegationEntry, DelegationEventError>

pub fn mark_started( &self, invocation_id: InvocationId, ) -> Result<(), DelegationEventError>

pub fn mark_run_started( &self, invocation_id: InvocationId, child_run_id: RunId, ) -> Result<(), DelegationEventError>

pub fn mark_run_attached( &self, invocation_id: InvocationId, child_run_id: RunId, ) -> Result<(), DelegationEventError>

pub fn mark_finished( &self, invocation_id: InvocationId, status: SessionStatus, ) -> Result<(), DelegationEventError>

pub fn mark_finished_with_reason( &self, invocation_id: InvocationId, status: SessionStatus, reason: Option<SafeErrorMessage>, ) -> Result<(), DelegationEventError>

pub fn get(&self, invocation_id: InvocationId) -> Option<DelegationEntry>

pub fn entries(&self) -> Vec<DelegationEntry>

pub fn reconcile_parent( &self, parent_session_id: SessionId, ) -> Result<(), DelegationEventError>

Trait Implementations

impl Debug for DelegationEventStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.