Versions in this module Expand all Collapse all v1 v1.4.0 Aug 14, 2022 v1.3.0 Mar 19, 2022 Changes in this version + const ClusterStoragePrefix + const LocalStoragePrefix + const MaxSizeRebalanceLists + const RPLoc + const RPRoot + const RPSrc + const RPStoreName + const RPVer + const RTExists + const RTFetch + const RTFree + const RTGetMain + const RTGetRoot + const RTInsert + const RTRebalance + const RTSetMain + const RTSetRoot + const RTUpdate + var DSRetNew error + func ClearMSMap() + func DumpMemoryClusterLayout(smname string) string + func WaitForTransfer() + type DataRequest struct + Args map[DataRequestArg]interface{} + RequestType RequestType + Transfer bool + Value interface{} + type DataRequestArg string + type DistributedStorage struct + MemberManager *manager.MemberManager + func NewDistributedStorage(gs graphstorage.Storage, config map[string]interface{}, ...) (*DistributedStorage, error) + func (ds *DistributedStorage) Close() error + func (ds *DistributedStorage) DistributionTable() (*DistributionTable, error) + func (ds *DistributedStorage) FlushAll() error + func (ds *DistributedStorage) FlushMain() error + func (ds *DistributedStorage) IsOperational() bool + func (ds *DistributedStorage) LocalName() string + func (ds *DistributedStorage) MainDB() map[string]string + func (ds *DistributedStorage) Name() string + func (ds *DistributedStorage) ReplicationFactor() int + func (ds *DistributedStorage) RollbackMain() error + func (ds *DistributedStorage) SetDistributionTable(dt *DistributionTable) + func (ds *DistributedStorage) SetDistributionTableError(err error) + func (ds *DistributedStorage) Start() error + func (ds *DistributedStorage) StorageManager(smname string, create bool) storage.Manager + type DistributedStorageError struct + func (dse *DistributedStorageError) Error() string + type DistributedStorageManager struct + func (dsm *DistributedStorageManager) Close() error + func (dsm *DistributedStorageManager) Exists(loc uint64) (bool, error) + func (dsm *DistributedStorageManager) Fetch(loc uint64, o interface{}) error + func (dsm *DistributedStorageManager) FetchCached(loc uint64) (interface{}, error) + func (dsm *DistributedStorageManager) Flush() error + func (dsm *DistributedStorageManager) Free(loc uint64) error + func (dsm *DistributedStorageManager) Insert(o interface{}) (uint64, error) + func (dsm *DistributedStorageManager) Name() string + func (dsm *DistributedStorageManager) Rollback() error + func (dsm *DistributedStorageManager) Root(root int) uint64 + func (dsm *DistributedStorageManager) SetRoot(root int, val uint64) + func (dsm *DistributedStorageManager) Update(loc uint64, o interface{}) error + type DistributionTable struct + func NewDistributionTable(members []string, repFac int) (*DistributionTable, error) + func (dd *DistributionTable) LocationHome(loc uint64) (string, []string) + func (dd *DistributionTable) MemberRange(name string) (uint64, uint64) + func (dd *DistributionTable) Members() []string + func (dd *DistributionTable) OtherReplicationMembers(loc uint64, name string) []string + func (dd *DistributionTable) Replicas(name string) []string + func (dd *DistributionTable) ReplicationRange(name string) (uint64, uint64) + func (dd *DistributionTable) String() string + type RequestType string