AtomSpace::DistributedAtomSpaceCluster
Inherits Reference < Object
Main distributed AtomSpace cluster coordination class
Constructors
new(cluster_id : String, local_atomspace : AtomSpace, host : String = "localhost", port : Int32 = 0, sync_strategy : SyncStrategy = SyncStrategy::MergeUsingTruthValues, adaptive_heartbeat_enabled : Bool = true)
Instance methods
adaptive_heartbeat
adaptive_heartbeat=(adaptive_heartbeat : AdaptiveHeartbeatConfig)
add_atom(atom : Atom) : Atom
Add a new atom to the local AtomSpace and propagate to cluster
add_event_observer(observer : Proc(ClusterEvent, String, Nil))
Add event observer
cluster_id
cluster_id=(cluster_id : String)
cluster_nodes
Get information about all cluster nodes
cluster_stats
Get cluster-wide statistics
full_cluster_sync
Force full cluster synchronization
heartbeat_stats
Get adaptive heartbeat statistics
join_cluster(seed_host : String, seed_port : Int32) : Bool
Join an existing cluster by connecting to a seed node
local_atomspace
local_atomspace=(local_atomspace : AtomSpace)
local_node
node_id
node_id=(node_id : String)
remove_atom(atom : Atom) : Bool
Remove an atom from the local AtomSpace and propagate to cluster
start
Start the cluster node and begin operations
stop
Stop the cluster node
sync_strategy
sync_strategy=(sync_strategy : SyncStrategy)
trigger_sync
Manual synchronization trigger