storages

type BundleEngine interface {
	NewStorage(bundle *pathbuilder.Bundle) (BundleStorage, error)
}

type BundleStorage interface {
	io.Closer

	// Add adds a new entity with the given URI (and optional path information)
	// to this bundle.
	//
	// Calls to add for a specific bundle storage are serialized.
	Add(uri wisski.URI, path []wisski.URI, triples []wisski.Triple) error

	// AddFieldValue adds a value to the given field for the entity with the given uri.
	//
	// Concurrent calls to distinct fields may take place, however within each field calls are always syncronized.
	//
	// A non-existing parent should return ErrNoEntity.
	AddFieldValue(uri wisski.URI, field string, value any, path []wisski.URI, triples []wisski.Triple) error

	// RegisterChildStorage register the given storage as a BundleStorage for the child bundle.
	// The Storage should delete the reference to the child storage when it is closed.
	RegisterChildStorage(bundle string, storage BundleStorage) error

	// AddChild adds a child entity of the given bundle to the given entity.
	//
	// Multiple concurrent calls to AddChild may take place, but every concurrent call will be for a different bundle.
	//
	// A non-existing parent should return ErrNoEntity.
	AddChild(parent wisski.URI, bundle string, child wisski.URI) error

	// Finalize is called to signal to this storage that no more write operations will take place.
	Finalize() error

	// Get returns an iterator that iterates over the url of every entity in this bundle, along with their parent URIs.
	// The iterator is guaranteed to iterate in some consistent order, but no further guarantees beyond that.
	//
	// parentPathIndex returns the index of the parent uri in child paths.
	Get(parentPathIndex int) iterator.Iterator[URIWithParent]

	// Count counts the number of entities in this storage.
	Count() (int64, error)

	// Load loads an entity with the given URI from this storage.
	// A non-existing entity should return err = ErrNoEntity.
	Load(uri wisski.URI) (wisski.Entity, error)
}

type Disk struct {
	DB *leveldb.DB
	// contains filtered or unexported fields
}

type DiskEngine struct {
	Path string
}

type Memory struct {
	Entities []wisski.Entity
	// contains filtered or unexported fields
}

type MemoryEngine struct{}

type URIWithParent struct {
	URI    wisski.URI
	Parent wisski.URI
}