datastoremanager

Documentation

Index

• Variables
• type DataStoreManager
  • func CreateDataStore(parentDirectory string, log *zap.Logger) *DataStoreManager
  • func (dsm *DataStoreManager) Close()
  • func (dsm *DataStoreManager) GetDataNode(slotID dht.ShardID) (js.JobFetcher, error)
  • func (dsm *DataStoreManager) InitialiseDataStores(slots []dht.ShardID) error

Variables

var (
	ErrDataStoreNotInitialised = errors.New("data store not initialised")
)

Types

type DataStoreManager

type DataStoreManager struct {
	// contains filtered or unexported fields
}

func CreateDataStore

func CreateDataStore(parentDirectory string, log *zap.Logger) *DataStoreManager

Creates the datastores for the nodes it owns.

func (*DataStoreManager) Close

func (dsm *DataStoreManager) Close()

func (*DataStoreManager) GetDataNode

func (dsm *DataStoreManager) GetDataNode(slotID dht.ShardID) (js.JobFetcher, error)

func (*DataStoreManager) InitialiseDataStores

func (dsm *DataStoreManager) InitialiseDataStores(slots []dht.ShardID) error