Struct StateManager 

pub struct StateManager { /* private fields */ }

Manages persistent state for bulk operations

Implementations

impl StateManager

pub fn new() -> Result<Self, AdminError>

Create a new state manager using the default state directory

pub fn with_dir(state_dir: PathBuf) -> Result<Self, AdminError>

Create a state manager with a custom directory (for testing)

pub fn state_dir(&self) -> &PathBuf

Get the state directory path

pub async fn create_operation( &self, operation_type: OperationType, parameters: Value, project_ids: Vec<String>, ) -> Result<Uuid, AdminError>

Create a new operation state

Arguments

• operation_type - Type of bulk operation
• parameters - Operation parameters (as JSON)
• project_ids - List of project IDs to process

Returns

The new operation’s UUID

pub async fn load_operation( &self, operation_id: Uuid, ) -> Result<OperationState, AdminError>

Load an existing operation state

pub async fn update_state( &self, operation_id: Uuid, update: StateUpdate, ) -> Result<(), AdminError>

Update operation state

pub async fn complete_operation( &self, operation_id: Uuid, status: OperationStatus, ) -> Result<(), AdminError>

Mark operation as complete with final result

pub async fn list_operations( &self, status_filter: Option<OperationStatus>, ) -> Result<Vec<OperationSummary>, AdminError>

List all operations, optionally filtered by status

pub async fn get_resumable_operation(&self) -> Result<Option<Uuid>, AdminError>

Get the most recent incomplete operation

pub fn get_pending_projects(&self, state: &OperationState) -> Vec<String>

Get project IDs that haven’t been processed yet

pub async fn cancel_operation( &self, operation_id: Uuid, ) -> Result<(), AdminError>

Cancel an operation (mark as cancelled)

pub async fn delete_operation( &self, operation_id: Uuid, ) -> Result<(), AdminError>

Delete an operation state file