class

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)
Source

Instance methods

add_atom(atom : Atom) : Atom

Add a new atom to the local AtomSpace and propagate to cluster

Source
add_event_observer(observer : Proc(ClusterEvent, String, Nil))

Add event observer

Source
cluster_id
Source
cluster_id=(cluster_id : String)
Source
cluster_nodes

Get information about all cluster nodes

Source
cluster_stats

Get cluster-wide statistics

Source
full_cluster_sync

Force full cluster synchronization

Source
join_cluster(seed_host : String, seed_port : Int32) : Bool

Join an existing cluster by connecting to a seed node

Source
local_atomspace
Source
local_atomspace=(local_atomspace : AtomSpace)
Source
local_node
Source
node_id
Source
node_id=(node_id : String)
Source
remove_atom(atom : Atom) : Bool

Remove an atom from the local AtomSpace and propagate to cluster

Source
start

Start the cluster node and begin operations

Source
stop

Stop the cluster node

Source
sync_strategy
Source
sync_strategy=(sync_strategy : SyncStrategy)
Source
trigger_sync

Manual synchronization trigger

Source