Struct CollectionPolicy 

pub struct CollectionPolicy {
    pub unique: ConflictPolicy,
    pub foreign_key: ConflictPolicy,
    pub not_null: ConflictPolicy,
    pub check: ConflictPolicy,
    pub strict_consistency: bool,
}

Per-collection conflict resolution policies, keyed by constraint kind.

Fields

unique: ConflictPolicy

Policy for UNIQUE constraint violations.

foreign_key: ConflictPolicy

Policy for FOREIGN_KEY constraint violations.

not_null: ConflictPolicy

Policy for NOT_NULL constraint violations.

check: ConflictPolicy

Policy for CHECK constraint violations.

strict_consistency: bool

If true, stricter defaults apply (defaults to EscalateToDlq).

Implementations

impl CollectionPolicy

pub fn ephemeral() -> Self

Create a policy suitable for ephemeral agent state (AP mode). Defaults to LAST_WRITER_WINS for most constraints.

pub fn strict() -> Self

Create a policy suitable for strict consistency mode (CP mode). Defaults to escalating most violations to DLQ.

pub fn for_kind(&self, kind: &ConstraintKind) -> &ConflictPolicy

Retrieve the policy for a given constraint kind.

Trait Implementations

impl Clone for CollectionPolicy

fn clone(&self) -> CollectionPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CollectionPolicy

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CollectionPolicy

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for CollectionPolicy

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.