Struct StakpakStorage 

pub struct StakpakStorage { /* private fields */ }

Stakpak API storage implementation

Implementations

impl StakpakStorage

pub fn new(api_key: &str, api_endpoint: &str) -> Result<Self, StorageError>

Create a new Stakpak storage client

pub fn client(&self) -> &StakpakApiClient

Get the underlying API client

Trait Implementations

impl Clone for StakpakStorage

fn clone(&self) -> StakpakStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl SessionStorage for StakpakStorage

fn list_sessions<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 ListSessionsQuery, ) -> Pin<Box<dyn Future<Output = Result<ListSessionsResult, StorageError>> + Send + 'async_trait>>

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

List all sessions

fn get_session<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Session, StorageError>> + Send + 'async_trait>>

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

Get a session by ID (includes active checkpoint)

fn create_session<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 CreateSessionRequest, ) -> Pin<Box<dyn Future<Output = Result<CreateSessionResult, StorageError>> + Send + 'async_trait>>

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

Create a new session with initial checkpoint

fn update_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: Uuid, request: &'life1 UpdateSessionRequest, ) -> Pin<Box<dyn Future<Output = Result<Session, StorageError>> + Send + 'async_trait>>

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

Update session metadata (title, visibility)

fn delete_session<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Delete a session

fn list_checkpoints<'life0, 'life1, 'async_trait>( &'life0 self, session_id: Uuid, query: &'life1 ListCheckpointsQuery, ) -> Pin<Box<dyn Future<Output = Result<ListCheckpointsResult, StorageError>> + Send + 'async_trait>>

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

List checkpoints for a session

fn get_checkpoint<'life0, 'async_trait>( &'life0 self, checkpoint_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Checkpoint, StorageError>> + Send + 'async_trait>>

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

Get a checkpoint by ID

fn create_checkpoint<'life0, 'life1, 'async_trait>( &'life0 self, session_id: Uuid, request: &'life1 CreateCheckpointRequest, ) -> Pin<Box<dyn Future<Output = Result<Checkpoint, StorageError>> + Send + 'async_trait>>

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

Create a new checkpoint for a session

fn get_active_checkpoint<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Checkpoint, StorageError>> + Send + 'async_trait>>

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

Get the latest/active checkpoint for a session

fn get_session_stats<'life0, 'async_trait>( &'life0 self, _session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<SessionStats, StorageError>> + Send + 'async_trait>>

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

Get session stats (optional - returns default if not supported)