Struct SessionStoreExecutor 

pub struct SessionStoreExecutor { /* private fields */ }

Executor adapter that persists runtime checkpoints into a session store.

Implementations

impl SessionStoreExecutor

pub fn new(store: Arc<dyn SessionStore>, session_id: SessionId) -> Self

Create a checkpoint executor for one session.

pub fn new_fenced( store: Arc<dyn SessionStore>, session_id: SessionId, admission_lease: RunAdmissionLease, ) -> Self

Create a checkpoint executor fenced to one active run admission.

pub const fn session_id(&self) -> &SessionId

Return the session id associated with this executor.

Trait Implementations

impl AgentExecutor for SessionStoreExecutor

fn requires_durable_hitl_preparation(&self) -> bool

Return whether sessions using this executor must route HITL effects through durable continuation preparation and exclusive started-claim authorization.

fn checkpoint<'life0, 'async_trait>( &'life0 self, checkpoint: AgentCheckpoint, ) -> Pin<Box<dyn Future<Output = Result<AgentExecutionDecision, AgentExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Persist or inspect a checkpoint and decide whether execution should continue.

impl Clone for SessionStoreExecutor

fn clone(&self) -> SessionStoreExecutor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.