Feat/ivan/pure modules

dimos/memory2/architecture.md

@@ -32,6 +32,9 @@ Supporting Systems:
 | `transform.py` | Transformer ABC, FnTransformer, FnIterTransformer, QualityWindow  |
 | `buffer.py`    | Backpressure buffers for live mode (KeepLast, Bounded, Unbounded) |
 | `embed.py`     | EmbedImages / EmbedText transformers                              |
+| `tick.py`      | Tick assembly — samplers (tick/latest/interpolate/window) + TickMachine |
+| `puremodule.py`| PureModule — pure `step` over aligned inputs; live ports or offline `over()` ([usage](/docs/usage/pure_modules.md), [design notes](puremodule.md)) |
+| `health.py`    | HealthMonitor — drop counters, contracts, `_health` stream for PureModule |
 
 ## Subpackages
 

dimos/memory2/buffer.py

@@ -71,6 +71,15 @@ def close(self) -> None:
     @abstractmethod
     def __len__(self) -> int: ...
 
+    def clone(self) -> BackpressureBuffer[T]:
+        """Fresh, empty buffer with the same policy.
+
+        Lets a buffer instance serve as a *template* (e.g. a class-level
+        ``backpressure = Bounded(8)``) while each consumer gets its own
+        independent state. Subclasses with constructor args must override.
+        """
+        return type(self)()
+
     def __iter__(self) -> Iterator[T]:
         """Yield items until the buffer is closed."""
         while True:
@@ -138,6 +147,9 @@ def __init__(self, maxlen: int) -> None:
         self._closed = False
         self._cond = threading.Condition()
 
+    def clone(self) -> Bounded[T]:
+        return Bounded(self._buf.maxlen or 0)
+
     def put(self, item: T) -> bool:
         with self._cond:
             if self._closed:
@@ -178,6 +190,9 @@ def __init__(self, maxlen: int) -> None:
         self._closed = False
         self._cond = threading.Condition()
 
+    def clone(self) -> DropNew[T]:
+        return DropNew(self._maxlen)
+
     def put(self, item: T) -> bool:
         with self._cond:
             if self._closed or len(self._buf) >= self._maxlen: