|
1
|
""" |
|
2
|
navegador.cluster — infrastructure for agent swarms and distributed coordination. |
|
3
|
|
|
4
|
Modules: |
|
5
|
core — ClusterManager: Redis/SQLite graph sync |
|
6
|
pubsub — GraphNotifier: real-time change notifications via pub/sub |
|
7
|
taskqueue — TaskQueue: work assignment for agent swarms |
|
8
|
partitioning — WorkPartitioner: community-based work partitioning |
|
9
|
sessions — SessionManager: branch-isolated session namespacing |
|
10
|
locking — DistributedLock: Redis-backed mutual exclusion (#49) |
|
11
|
checkpoint — CheckpointManager: graph snapshot / rollback (#50) |
|
12
|
observability — SwarmDashboard: agent + task + graph metrics (#51) |
|
13
|
messaging — MessageBus: agent-to-agent async messaging (#52) |
|
14
|
fossil_live — FossilLiveAdapter: ATTACH DATABASE integration (#57) |
|
15
|
""" |
|
16
|
|
|
17
|
from navegador.cluster.checkpoint import CheckpointManager |
|
18
|
from navegador.cluster.core import ClusterManager |
|
19
|
from navegador.cluster.fossil_live import FossilLiveAdapter |
|
20
|
from navegador.cluster.locking import DistributedLock, LockTimeout |
|
21
|
from navegador.cluster.messaging import Message, MessageBus |
|
22
|
from navegador.cluster.observability import SwarmDashboard |
|
23
|
from navegador.cluster.partitioning import Partition, WorkPartitioner |
|
24
|
from navegador.cluster.pubsub import EventType, GraphNotifier |
|
25
|
from navegador.cluster.sessions import SessionManager |
|
26
|
from navegador.cluster.taskqueue import Task, TaskQueue, TaskStatus |
|
27
|
|
|
28
|
__all__ = [ |
|
29
|
# v0.6 cluster infrastructure (#20, #32, #46, #47, #48) |
|
30
|
"ClusterManager", |
|
31
|
"EventType", |
|
32
|
"GraphNotifier", |
|
33
|
"Partition", |
|
34
|
"SessionManager", |
|
35
|
"Task", |
|
36
|
"TaskQueue", |
|
37
|
"TaskStatus", |
|
38
|
"WorkPartitioner", |
|
39
|
# v0.6 additional infrastructure (#49, #50, #51, #52, #57) |
|
40
|
"CheckpointManager", |
|
41
|
"DistributedLock", |
|
42
|
"FossilLiveAdapter", |
|
43
|
"LockTimeout", |
|
44
|
"Message", |
|
45
|
"MessageBus", |
|
46
|
"SwarmDashboard", |
|
47
|
] |
|
48
|
|