tree

type DummyMap map[string]string // place holder for cache_map package that will be merged soon

type InitTreesRepository func(manager sstable.Manager) TreeRepo

type TreePart struct {
	PartName sstable.ID   `json:"part_name"`
	MaxKey   graveler.Key `json:"max_path"`
}

type TreeRepo interface {
	// NewTreeWriter returns a writer that uses the part manager to create a new tree
	NewTreeWriter(splitFactor int,

		closeAsync sstable.BatchWriterCloser,

	) TreeWriter
	// NewScannerFromTreeID accepts a tree ID, and returns an iterator over the tree
	NewIteratorFromTreeID(treeID graveler.TreeID, start graveler.Key) (graveler.ValueIterator, error)
	// NewIteratorFromTreeParts accept a tree in memory, returns iterator over the tree
	NewIteratorFromTreeSlice(treeSlice TreeSlice, start graveler.Key) (graveler.ValueIterator, error)
}

type TreeSlice struct {
	TreeSlice []TreePart
}

type TreeWriter interface {
	WriteEntry(record graveler.ValueRecord) error
	// FlushIterToTree writes the content of an iterator to the tree.
	FlushIterToTree(iter graveler.ValueIterator) error
	// SaveTree stores the tree to tierFS. During tree writing, parts are closed asynchronously and copied by tierFS
	// while writing continues. SaveTree waits until closing and copying all parts
	SaveTree() (graveler.TreeID, error)
	SaveTreeWithReusedParts(reuseTree TreeSlice,

	) (graveler.TreeID, error)
}

type TreesRepo struct {
	TreesMap   DummyMap
	PartManger sstable.Manager
}