
    =i
                         d Z ddlmZmZmZmZmZ ddlmZm	Z	 ddl
mZmZmZ ddlmZmZmZ ddlmZmZ ddlmZmZmZ ddlmZmZmZ dd	lmZmZm Z m!Z! g d
Z"y)u  
core.coherence — Multi-agent state coherence package.

Exports the StateDelta dataclass and supporting utilities for
RFC 6902 JSON Patch-based state change proposals.

Also exports RedisMasterState and CommitResult for versioned,
OCC-protected Redis state management.

Also exports TaskDAGPusher for pushing task DAGs to Redis Streams
for exactly-once delivery to Gemini swarm workers via Consumer Groups.

Also exports StagingArea for Redis Hash-backed delta collection hub.

Also exports BulkheadGuard and BulkheadResult for asyncio.gather
exception isolation — one crashed agent never brings down the swarm.

Also exports OCCCommitEngine, OccCommitResult, and MAX_RETRIES for the
barrier-sync + OCC commit cycle that orchestrates multi-agent swarm rounds.

Also exports CoherenceOrchestrator and CoherenceResult for the complete
8-step coherence execution flow coordinator (MAP → CLAIM → PROPOSE →
BARRIER → REDUCE → COMMIT → RELEASE → SCAR).
    )
StateDeltaPatchConflictErrorvalidate_patchapply_patch	VALID_OPS)RedisMasterStateCommitResult)TaskDAGPusher
STREAM_KEYDEFAULT_GROUP)StagingAreaSTAGING_KEY_PREFIXSTAGING_TTL_SECONDS)SwarmWorkerBasePEL_TIMEOUT_MS)BulkheadGuardBulkheadResultCRITICAL_THRESHOLD)OCCCommitEngineOccCommitResultMAX_RETRIES)CoherenceOrchestratorCoherenceResultORCHESTRATION_TIMEOUT_SECONDSEVENTS_LOG_PATH)r   r   r   r   r   r   r	   r
   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   N)#__doc__core.coherence.state_deltar   r   r   r   r   !core.coherence.redis_master_stater   r	   core.coherence.task_dag_pusherr
   r   r   core.coherence.staging_arear   r   r    core.coherence.swarm_worker_baser   r   core.coherence.bulkheadr   r   r   core.coherence.occ_commitr   r   r   %core.coherence.coherence_orchestratorr   r   r   r   __all__     0/mnt/e/genesis-system/core/coherence/__init__.py<module>r)      sW   2 
  
   "r'   