Struct GenericConflictResolver 

pub struct GenericConflictResolver<T: Conflictable> { /* private fields */ }

Generic conflict resolver for any Conflictable type

Maintains an index of active items by conflict key for efficient detection. Works with any type implementing the Conflictable trait.

Example

use peat_protocol::policy::{GenericConflictResolver, LastWriteWinsPolicy, Conflictable, ConflictResult};

// Create a resolver for your type
let resolver = GenericConflictResolver::<MyType>::new();

// Check for conflicts
let result = resolver.check_conflict(&my_item).await;

// Resolve if needed
if let ConflictResult::Conflict(existing) = result {
    let policy = LastWriteWinsPolicy;
    let winner = resolver.resolve(vec![existing[0].clone(), my_item], &policy)?;
}

Implementations

impl<T: Conflictable> GenericConflictResolver<T>

pub fn new() -> Self

Create a new generic conflict resolver

pub async fn check_conflict(&self, item: &T) -> ConflictResult<T>

Check if a new item conflicts with existing items

Returns ConflictResult::Conflict if there are existing items with overlapping conflict keys.

pub fn resolve( &self, items: Vec<T>, policy: &dyn ResolutionPolicy<T>, ) -> Result<T>

Resolve conflict using the specified policy

Takes a list of conflicting items and returns the “winning” item according to the policy’s logic.

pub async fn register(&self, item: &T) -> Result<()>

Register an item as active (after conflict resolution)

Adds the item to the conflict index for future conflict checks.

pub async fn unregister(&self, item_id: &str) -> Result<()>

Unregister an item from active tracking

Removes the item from all conflict key indices. Called when an item completes, expires, or is cancelled.

pub async fn get_all_active(&self) -> Vec<T>

Get all active items

pub async fn active_count(&self) -> usize

Get count of active items

pub async fn get_by_key(&self, key: &str) -> Vec<T>

Get active items by conflict key

Trait Implementations

impl<T: Conflictable> Default for GenericConflictResolver<T>

fn default() -> Self

Returns the “default value” for a type.