mergedb

Documentation

Index

• func MergeStores(kvStore1 *kvstore.KVStore, kvStore2 *kvstore.KVStore, nbOfThreads int, ...)
• func NewMergedb(dbsPath string, outPath string, maxSize bool)
• type DBMerger

Functions

func MergeStores

func MergeStores(kvStore1 *kvstore.KVStore, kvStore2 *kvstore.KVStore, nbOfThreads int, wg *sync.WaitGroup)

func NewMergedb

func NewMergedb(dbsPath string, outPath string, maxSize bool)

Types

type DBMerger

type DBMerger struct {
	KVToMerge sync.Map
	// contains filtered or unexported fields
}