class

AtomSpace::DistributedStorageNode

Inherits AtomSpace::StorageNode < AtomSpace::Node < AtomSpace::Atom < Reference < Object

Storage node that participates in distributed clustering

Constructors

new(name : String, cluster : DistributedAtomSpaceCluster, local_storage_backend : String = "file", storage_path : String = "./distributed_storage", partition_strategy : PartitionStrategy = PartitionStrategy::HashBased, replication_strategy : ReplicationStrategy = ReplicationStrategy::PrimaryBackup, replication_factor : Int32 = 2)
Source

Instance methods

close

Close connection to storage backend

Source
cluster
Source
cluster=(cluster : DistributedAtomSpaceCluster)
Source
connected?

Check if connection is open

Source
distribution_metrics

Get data distribution metrics

Source
fetch_atom(handle : Handle) : Atom | Nil

Fetch a single atom by handle

Source
get_stats

Get storage statistics

Source
load_atomspace(atomspace : AtomSpace) : Bool

Load all atoms into AtomSpace

Source
open

Open connection to storage backend

Source
partition_strategy
Source
partition_strategy=(partition_strategy : PartitionStrategy)
Source
rebalance_cluster

Rebalance data across cluster nodes

Source
remove_atom(atom : Atom) : Bool

Remove an atom from storage

Source
replication_factor
Source
replication_factor=(replication_factor : Int32)
Source
replication_strategy
Source
replication_strategy=(replication_strategy : ReplicationStrategy)
Source
store_atom(atom : Atom) : Bool

Store a single atom

Source
store_atomspace(atomspace : AtomSpace) : Bool

Store all atoms from AtomSpace

Source

Nested types