4159712b92
Return []Changes and a "closer" func to return them to Pool. Update tests for LoadChanges new return values.
33 lines
1.1 KiB
Go
33 lines
1.1 KiB
Go
package node
|
|
|
|
import (
|
|
"github.com/lbryio/lbcd/claimtrie/change"
|
|
)
|
|
|
|
// Repo defines APIs for Node to access persistence layer.
|
|
type Repo interface {
|
|
// AppendChanges saves changes into the repo.
|
|
// The changes can belong to different nodes, but the chronological
|
|
// order must be preserved for the same node.
|
|
AppendChanges(changes []change.Change) error
|
|
|
|
// LoadChanges loads changes of a node up to (includes) the specified height.
|
|
// If no changes found, both returned slice and error will be nil.
|
|
// The returned closer func() should be called to release changes after
|
|
// work on them is finished.
|
|
LoadChanges(name []byte) (changes []change.Change, closer func(), err error)
|
|
|
|
DropChanges(name []byte, finalHeight int32) error
|
|
|
|
// Close closes the repo.
|
|
Close() error
|
|
|
|
// IterateChildren returns change sets for each of name.+
|
|
// Return false on f to stop the iteration.
|
|
IterateChildren(name []byte, f func(changes []change.Change) bool) error
|
|
|
|
// IterateAll iterates keys until the predicate function returns false
|
|
IterateAll(predicate func(name []byte) bool)
|
|
|
|
Flush() error
|
|
}
|