Copy-on-Write

# Version 1 is created
mem.write("svc", "config", {"pool_size": 5})

# Version 2 is created; version 1 is superseded
mem.write("svc", "config", {"pool_size": 10})

# Version 3 is created; version 2 is superseded
mem.write("svc", "config", {"pool_size": 20})

entry = mem.read("svc", "config")
print(entry.version)  # 3
print(entry.value)    # {"pool_size": 20}

for entry in mem.history("svc", "config"):
    print(f"v{entry.version}: {entry.value} (confidence {entry.confidence})")

all_versions = mem.list("svc", include_superseded=True)

amfs inspect diff svc config

# Diff a specific version against the current one.
# Omit old_version to compare the two most recent versions.
result = mem.diff("svc", "config", old_version=1)

for change in result["field_changes"]:
    print(f"{change['operation']} {change['path']}: "
          f"{change['old_value']} → {change['new_value']}")

replace /pool_size: 5 → 20

from amfs_core.models import ConflictPolicy

mem = AgentMemory(
    agent_id="my-agent",
    conflict_policy=ConflictPolicy.RAISE,
)

def resolve(existing, incoming, value):
    # Merge logic here
    return {**existing.value, **value}

mem = AgentMemory(
    agent_id="my-agent",
    on_conflict=resolve,
)