Struct CursorRestore 

pub struct CursorRestore { /* private fields */ }

Cursor Restore Manager

Implementations

impl CursorRestore

pub fn new() -> Self

Create a new cursor restore manager

pub fn with_max_cursors(self, max: usize) -> Self

Configure max cursors per session

pub fn with_backend_template(self, template: BackendConfig) -> Self

Attach a backend-connection template so real cursor recreation can run DECLARE / MOVE against the target node.

pub async fn register_endpoint(&self, node_id: NodeId, endpoint: NodeEndpoint)

Register an endpoint for a node so restore can resolve where to re-declare the cursor.

pub fn set_enabled(&mut self, enabled: bool)

Enable or disable cursor restore

pub async fn save_cursor(&self, state: CursorState) -> Result<()>

Save cursor state

pub async fn update_position( &self, cursor_name: &str, new_position: u64, ) -> Result<()>

Update cursor position

pub async fn close_cursor(&self, cursor_name: &str) -> Result<()>

Close a cursor

pub async fn get_cursor(&self, cursor_name: &str) -> Option<CursorState>

Get cursor state

pub async fn get_session_cursors(&self, session_id: &Uuid) -> Vec<CursorState>

Get all cursors for a session

pub async fn restore_cursor( &self, cursor_name: &str, target_node: NodeId, ) -> Result<CursorRestoreResult>

Restore a cursor on a new node

pub async fn restore_session_cursors( &self, session_id: &Uuid, target_node: NodeId, ) -> Vec<CursorRestoreResult>

Restore all cursors for a session

pub async fn clear_session(&self, session_id: &Uuid)

Clear all cursors for a session

pub async fn stats(&self) -> CursorRestoreStats

Get statistics

Trait Implementations

impl Default for CursorRestore

fn default() -> Self

Returns the “default value” for a type.