Struct OptimisticController 

pub struct OptimisticController { /* private fields */ }

Optimistic concurrency controller

Implementations

impl OptimisticController

pub fn new() -> Self

Create a new optimistic controller with default settings

pub fn with_default_strategy(strategy: ResolutionStrategy) -> Self

Create with a custom default strategy

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

Set maximum history entries

pub async fn begin_optimistic( &self, agent_id: &str, resource_id: &str, ) -> OptimisticToken

Start an optimistic operation - returns token with current version

pub async fn commit_optimistic( &self, token: OptimisticToken, new_content_hash: &str, ) -> Result<u64, OptimisticConflict>

Commit optimistic operation - returns conflict if version changed

pub async fn commit_or_resolve( &self, token: OptimisticToken, new_content_hash: &str, new_content: Option<&str>, ) -> Result<CommitResult, String>

Try to commit, and if conflict occurs, resolve it

pub async fn resolve_conflict( &self, conflict: &OptimisticConflictDetails, ) -> Resolution

Manually resolve a conflict with full details

pub async fn register_strategy( &self, resource_pattern: &str, strategy: ResolutionStrategy, )

Register a resolution strategy for a resource pattern

pub async fn get_version(&self, resource_id: &str) -> Option<ResourceVersion>

Get the current version of a resource

pub async fn has_changed(&self, resource_id: &str, since_version: u64) -> bool

Check if a resource has been modified since a given version

pub async fn get_conflict_history(&self) -> Vec<ConflictRecord>

Get conflict history

pub async fn clear_history(&self)

Clear conflict history

pub async fn get_stats(&self) -> OptimisticStats

Get statistics about conflicts

Trait Implementations

impl Default for OptimisticController

fn default() -> Self

Returns the “default value” for a type.