util

package

Go to main page

Versions in this module

v1

v1.13.0

Mar 9, 2024

Changes in this version

type ExtensionNode

+ func (en *ExtensionNode) CloneNode() Node

+ func (en *ExtensionNode) CopyFrom(v interface{}) bool

type FullNode

+ func (fn *FullNode) CloneNode() Node

+ func (fn *FullNode) CopyFrom(v interface{}) bool

type LeafNode

+ func (ln *LeafNode) CloneNode() Node

+ func (ln *LeafNode) CopyFrom(v interface{}) bool

type MerklePatriciaTrie

+ func (mpt *MerklePatriciaTrie) Cache() *statecache.TransactionCache

+ func (mpt *MerklePatriciaTrie) GetAllMissingNodes() ([]Key, error)

type MerklePatriciaTrieI

+ Cache func() *statecache.TransactionCache

+ GetAllMissingNodes func() ([]Key, error)

type Node

+ CloneNode func() Node

type PNodeDB

+ func (pndb *PNodeDB) EstimateSize() (string, string)

type ValueNode

+ func (vn *ValueNode) CloneNode() Node

+ func (vn *ValueNode) CopyFrom(v interface{}) bool

v0

v0.0.6

Aug 21, 2023

Changes in this version

+ const MPTMaxAllowableNodeSize

type MerklePatriciaTrie

+ func (mpt *MerklePatriciaTrie) GetMissingNodeKeys() []Key

type MerklePatriciaTrieI

+ GetMissingNodeKeys func() []Key

v0.0.5

Sep 4, 2022

v0.0.4

Sep 1, 2022

Changes in this version

+ const BatchSize

+ const FmtIntermediateNodeExists

+ const NodeTypeExtensionNode

+ const NodeTypeFullNode

+ const NodeTypeLeafNode

+ const NodeTypeValueNode

+ const NodeTypesAll

+ const PruneStateAbandoned

+ const PruneStateCommplete

+ const PruneStateDelete

+ const PruneStateStart

+ const PruneStateSynch

+ const PruneStateUpdate

+ const SSTTypeBlockBasedTable

+ const SSTTypePlainTable

+ const Separator

+ var DebugMPTNode = false

+ var ErrInvalidEncoding = errors.New("invalid node encoding")

+ var ErrIteratingChildNodes = errors.New("Error iterating child nodes")

+ var ErrMissingNodes = errors.New("missing nodes")

+ var ErrNilPartialStateRoot = errors.New("partial state root is nil")

+ var ErrNodeNotFound = errors.New("node not found")

+ var ErrValueNotPresent = errors.New("value not present")

+ var PNodeDBCompression = gorocksdb.LZ4Compression

+ var PathElements = []byte("0123456789abcdef")

+ func GetSerializationPrefix(node Node) byte

+ func Hash(text string) string

+ func HashStringToBytes(hash string) []byte

+ func IncludesNodeType(nodeTypes byte, nodeType byte) bool

+ func IsMPTValid(mpt MerklePatriciaTrieI) error

+ func MHash(h1 string, h2 string) string

+ func MergeState(ctx context.Context, fndb NodeDB, tndb NodeDB) error

+ func PrintChanges(w io.Writer, changes []*NodeChange)

+ func ToHex(buf []byte) string

+ func ToUpperHex(buf []byte) string

+ func VerifyMerklePath(hash string, path *MTPath, root string) bool

+ func WithPruneStats(ctx context.Context) context.Context

+ type ChangeCollector struct

+ Changes map[string]*NodeChange

+ Deletes map[string]Node

+ func (cc *ChangeCollector) AddChange(oldNode Node, newNode Node)

+ func (cc *ChangeCollector) Clone() ChangeCollectorI

+ func (cc *ChangeCollector) DeleteChange(oldNode Node)

+ func (cc *ChangeCollector) GetChanges() []*NodeChange

+ func (cc *ChangeCollector) GetDeletes() []Node

+ func (cc *ChangeCollector) GetStartRoot() Key

+ func (cc *ChangeCollector) UpdateChanges(ndb NodeDB, origin Sequence, includeDeletes bool) error

+ func (cc *ChangeCollector) Validate() error

+ type ChangeCollectorI interface

+ AddChange func(oldNode Node, newNode Node)

+ Clone func() ChangeCollectorI

+ DeleteChange func(oldNode Node)

+ GetChanges func() []*NodeChange

+ GetDeletes func() []Node

+ GetStartRoot func() Key

+ UpdateChanges func(ndb NodeDB, origin Sequence, includeDeletes bool) error

+ Validate func() error

+ func NewChangeCollector(startRoot Key) ChangeCollectorI

+ type ContextKey string

+ const PruneStatsKey

+ type ExtensionNode struct

+ NodeKey Key

+ Path Path

+ func NewExtensionNode(path Path, key Key) *ExtensionNode

+ func (en *ExtensionNode) Clone() Node

+ func (en *ExtensionNode) Decode(buf []byte) error

+ func (en *ExtensionNode) Encode() []byte

+ func (en *ExtensionNode) GetHash() string

+ func (en *ExtensionNode) GetHashBytes() []byte

+ func (en *ExtensionNode) GetNodeType() byte

+ type FullNode struct

+ Children [16][]byte

+ Value *ValueNode

+ func NewFullNode(value MPTSerializable) *FullNode

+ func (fn *FullNode) Clone() Node

+ func (fn *FullNode) Decode(buf []byte) error

+ func (fn *FullNode) Encode() []byte

+ func (fn *FullNode) GetChild(hex byte) []byte

+ func (fn *FullNode) GetHash() string

+ func (fn *FullNode) GetHashBytes() []byte

+ func (fn *FullNode) GetNodeType() byte

+ func (fn *FullNode) GetNumChildren() byte

+ func (fn *FullNode) GetValue() MPTSerializable

+ func (fn *FullNode) GetValueBytes() []byte

+ func (fn *FullNode) HasValue() bool

+ func (fn *FullNode) PutChild(hex byte, child []byte)

+ func (fn *FullNode) SetValue(value MPTSerializable)

+ type Hashable interface

+ GetHash func() string

+ GetHashBytes func() []byte

+ type Key []byte

+ type LeafNode struct

+ Path Path

+ Prefix Path

+ Value *ValueNode

+ func NewLeafNode(prefix, path Path, origin Sequence, value MPTSerializable) *LeafNode

+ func (ln *LeafNode) Clone() Node

+ func (ln *LeafNode) Decode(buf []byte) error

+ func (ln *LeafNode) Encode() []byte

+ func (ln *LeafNode) GetHash() string

+ func (ln *LeafNode) GetHashBytes() []byte

+ func (ln *LeafNode) GetNodeType() byte

+ func (ln *LeafNode) GetValue() MPTSerializable

+ func (ln *LeafNode) GetValueBytes() []byte

+ func (ln *LeafNode) HasValue() bool

+ func (ln *LeafNode) SetValue(value MPTSerializable)

+ type LevelNodeDB struct

+ DeletedNodes map[StrKey]bool

+ PropagateDeletes bool

+ func NewLevelNodeDB(curNDB NodeDB, prevNDB NodeDB, propagateDeletes bool) *LevelNodeDB

+ func (lndb *LevelNodeDB) DeleteNode(key Key) error

+ func (lndb *LevelNodeDB) GetCurrent() NodeDB

+ func (lndb *LevelNodeDB) GetDBVersion() int64

+ func (lndb *LevelNodeDB) GetNode(key Key) (Node, error)

+ func (lndb *LevelNodeDB) GetPrev() NodeDB

+ func (lndb *LevelNodeDB) Iterate(ctx context.Context, handler NodeDBIteratorHandler) error

+ func (lndb *LevelNodeDB) MultiDeleteNode(keys []Key) error

+ func (lndb *LevelNodeDB) MultiGetNode(keys []Key) (nodes []Node, err error)

+ func (lndb *LevelNodeDB) MultiPutNode(keys []Key, nodes []Node) error

+ func (lndb *LevelNodeDB) PruneBelowVersion(ctx context.Context, version int64) error

+ func (lndb *LevelNodeDB) PutNode(key Key, node Node) error

+ func (lndb *LevelNodeDB) RebaseCurrentDB(ndb NodeDB)

+ func (lndb *LevelNodeDB) RecordDeadNodes([]Node, int64) error

+ func (lndb *LevelNodeDB) SetPrev(prevDB NodeDB)

+ func (lndb *LevelNodeDB) Size(ctx context.Context) int64

+ type MPTIteratorHandler func(ctx context.Context, path Path, key Key, node Node) error

+ type MPTMissingNodeHandler func(ctx context.Context, path Path, key Key) error

+ type MPTSerializable interface

+ type MPTSerializableSize interface

+ type MTPath struct

+ LeafIndex int

+ Nodes []string

+ type MemoryNodeDB struct

+ Nodes map[StrKey]Node

+ func NewMemoryNodeDB() *MemoryNodeDB

+ func (mndb *MemoryNodeDB) ComputeRoot() (root Node, err error)

+ func (mndb *MemoryNodeDB) DeleteNode(key Key) error

+ func (mndb *MemoryNodeDB) GetDBVersions() []int64

+ func (mndb *MemoryNodeDB) GetNode(key Key) (Node, error)

+ func (mndb *MemoryNodeDB) Iterate(ctx context.Context, handler NodeDBIteratorHandler) error

+ func (mndb *MemoryNodeDB) MultiDeleteNode(keys []Key) error

+ func (mndb *MemoryNodeDB) MultiGetNode(keys []Key) (nodes []Node, err error)

+ func (mndb *MemoryNodeDB) MultiPutNode(keys []Key, nodes []Node) error

+ func (mndb *MemoryNodeDB) PruneBelowVersion(ctx context.Context, version int64) error

+ func (mndb *MemoryNodeDB) PutNode(key Key, node Node) error

+ func (mndb *MemoryNodeDB) Reachable(from, to Node) (ok bool)

+ func (mndb *MemoryNodeDB) RecordDeadNodes([]Node, int64) error

+ func (mndb *MemoryNodeDB) Size(_ context.Context) int64

+ func (mndb *MemoryNodeDB) Validate(root Node) error

+ type MerklePatriciaTrie struct

+ ChangeCollector ChangeCollectorI

+ Version Sequence

+ func CloneMPT(mpt MerklePatriciaTrieI) *MerklePatriciaTrie

+ func NewMerklePatriciaTrie(db NodeDB, version Sequence, root Key) *MerklePatriciaTrie

+ func (mpt *MerklePatriciaTrie) Delete(path Path) (Key, error)

+ func (mpt *MerklePatriciaTrie) FindMissingNodes(ctx context.Context) ([]Path, []Key, error)

+ func (mpt *MerklePatriciaTrie) GetChangeCount() int

+ func (mpt *MerklePatriciaTrie) GetChanges() (Key, []*NodeChange, []Node, Key)

+ func (mpt *MerklePatriciaTrie) GetDeletes() []Node

+ func (mpt *MerklePatriciaTrie) GetNodeDB() NodeDB

+ func (mpt *MerklePatriciaTrie) GetNodeValue(path Path, v MPTSerializable) error

+ func (mpt *MerklePatriciaTrie) GetNodeValueRaw(path Path) ([]byte, error)

+ func (mpt *MerklePatriciaTrie) GetPathNodes(path Path) ([]Node, error)

+ func (mpt *MerklePatriciaTrie) GetRoot() Key

+ func (mpt *MerklePatriciaTrie) GetVersion() Sequence

+ func (mpt *MerklePatriciaTrie) HasMissingNodes(ctx context.Context) (bool, error)

+ func (mpt *MerklePatriciaTrie) Insert(path Path, value MPTSerializable) (Key, error)

+ func (mpt *MerklePatriciaTrie) Iterate(ctx context.Context, handler MPTIteratorHandler, visitNodeTypes byte) error

+ func (mpt *MerklePatriciaTrie) IterateFrom(ctx context.Context, node Key, handler MPTIteratorHandler, visitNodeTypes byte) error

+ func (mpt *MerklePatriciaTrie) MergeChanges(newRoot Key, changes []*NodeChange, deletes []Node, startRoot Key) error

+ func (mpt *MerklePatriciaTrie) MergeDB(ndb NodeDB, root Key) error

+ func (mpt *MerklePatriciaTrie) MergeMPTChanges(mpt2 MerklePatriciaTrieI) error

+ func (mpt *MerklePatriciaTrie) PrettyPrint(w io.Writer) error

+ func (mpt *MerklePatriciaTrie) SaveChanges(ctx context.Context, ndb NodeDB, includeDeletes bool) error

+ func (mpt *MerklePatriciaTrie) SetNodeDB(ndb NodeDB)

+ func (mpt *MerklePatriciaTrie) SetVersion(version Sequence)

+ func (mpt *MerklePatriciaTrie) UpdateVersion(ctx context.Context, version Sequence, missingNodeHander MPTMissingNodeHandler) error

+ func (mpt *MerklePatriciaTrie) Validate() error

+ type MerklePatriciaTrieI interface

+ Delete func(path Path) (Key, error)

+ FindMissingNodes func(ctx context.Context) ([]Path, []Key, error)

+ GetChangeCount func() int

+ GetChanges func() (Key, []*NodeChange, []Node, Key)

+ GetDeletes func() []Node

+ GetNodeDB func() NodeDB

+ GetNodeValue func(path Path, v MPTSerializable) error

+ GetNodeValueRaw func(path Path) ([]byte, error)

+ GetPathNodes func(path Path) ([]Node, error)

+ GetRoot func() Key

+ GetVersion func() Sequence

+ HasMissingNodes func(ctx context.Context) (bool, error)

+ Insert func(path Path, value MPTSerializable) (Key, error)

+ Iterate func(ctx context.Context, handler MPTIteratorHandler, visitNodeTypes byte) error

+ IterateFrom func(ctx context.Context, node Key, handler MPTIteratorHandler, visitNodeTypes byte) error

+ MergeChanges func(newRoot Key, changes []*NodeChange, deletes []Node, startRoot Key) error

+ MergeDB func(ndb NodeDB, root Key) error

+ MergeMPTChanges func(mpt2 MerklePatriciaTrieI) error

+ PrettyPrint func(w io.Writer) error

+ SaveChanges func(ctx context.Context, ndb NodeDB, includeDeletes bool) error

+ SetNodeDB func(ndb NodeDB)

+ SetVersion func(version Sequence)

+ UpdateVersion func(ctx context.Context, version Sequence, missingNodeHander MPTMissingNodeHandler) error

+ Validate func() error

+ type MerkleTree struct

+ func (mt *MerkleTree) ComputeTree(hashes []Hashable)

+ func (mt *MerkleTree) GetLeafIndex(hash Hashable) int

+ func (mt *MerkleTree) GetPath(hash Hashable) *MTPath

+ func (mt *MerkleTree) GetPathByIndex(idx int) *MTPath

+ func (mt *MerkleTree) GetRoot() string

+ func (mt *MerkleTree) GetTree() []string

+ func (mt *MerkleTree) SetTree(leavesCount int, tree []string) error

+ func (mt *MerkleTree) VerifyPath(hash Hashable, path *MTPath) bool

+ type MerkleTreeI interface

+ ComputeTree func(hashes []Hashable)

+ GetPath func(hash Hashable) *MTPath

+ GetPathByIndex func(idx int) *MTPath

+ GetRoot func() string

+ GetTree func() []string

+ SetTree func(leavesCount int, tree []string) error

+ VerifyPath func(hash Hashable, path *MTPath) bool

+ type Node interface

+ Clone func() Node

+ GetNodeType func() byte

+ GetOriginTracker func() OriginTrackerI

+ SetOriginTracker func(ot OriginTrackerI)

+ func CreateNode(r io.Reader) (Node, error)

+ type NodeChange struct

+ New Node

+ Old Node

+ type NodeDB interface

+ DeleteNode func(key Key) error

+ GetNode func(key Key) (Node, error)

+ Iterate func(ctx context.Context, handler NodeDBIteratorHandler) error

+ MultiDeleteNode func(keys []Key) error

+ MultiGetNode func(keys []Key) ([]Node, error)

+ MultiPutNode func(keys []Key, nodes []Node) error

+ PruneBelowVersion func(ctx context.Context, version int64) error

+ PutNode func(key Key, node Node) error

+ RecordDeadNodes func([]Node, int64) error

+ Size func(ctx context.Context) int64

+ type NodeDBIteratorHandler func(ctx context.Context, key Key, node Node) error

+ type OriginTracker struct

+ Origin Sequence

+ Version Sequence

+ func (o *OriginTracker) GetOrigin() Sequence

+ func (o *OriginTracker) GetVersion() Sequence

+ func (o *OriginTracker) Read(r io.Reader) error

+ func (o *OriginTracker) SetOrigin(origin Sequence)

+ func (o *OriginTracker) SetVersion(version Sequence)

+ func (o *OriginTracker) Write(w io.Writer) error

+ type OriginTrackerI interface

+ GetOrigin func() Sequence

+ GetVersion func() Sequence

+ Read func(r io.Reader) error

+ SetOrigin func(origin Sequence)

+ SetVersion func(version Sequence)

+ Write func(w io.Writer) error

+ type OriginTrackerNode struct

+ OriginTracker OriginTrackerI

+ func NewOriginTrackerNode() *OriginTrackerNode

+ func (otn *OriginTrackerNode) Clone() *OriginTrackerNode

+ func (otn *OriginTrackerNode) GetOrigin() Sequence

+ func (otn *OriginTrackerNode) GetOriginTracker() OriginTrackerI

+ func (otn *OriginTrackerNode) GetVersion() Sequence

+ func (otn *OriginTrackerNode) Read(r io.Reader) error

+ func (otn *OriginTrackerNode) SetOrigin(origin Sequence)

+ func (otn *OriginTrackerNode) SetOriginTracker(ot OriginTrackerI)

+ func (otn *OriginTrackerNode) SetVersion(version Sequence)

+ func (otn *OriginTrackerNode) Write(w io.Writer) error

+ type PNodeDB struct

+ func NewPNodeDB(stateDir, logDir string) (*PNodeDB, error)

+ func (pndb *PNodeDB) Close()

+ func (pndb *PNodeDB) DeleteNode(key Key) error

+ func (pndb *PNodeDB) Flush()

+ func (pndb *PNodeDB) GetNode(key Key) (Node, error)

+ func (pndb *PNodeDB) Iterate(ctx context.Context, handler NodeDBIteratorHandler) error

+ func (pndb *PNodeDB) MultiDeleteNode(keys []Key) error

+ func (pndb *PNodeDB) MultiGetNode(keys []Key) ([]Node, error)

+ func (pndb *PNodeDB) MultiPutNode(keys []Key, nodes []Node) error

+ func (pndb *PNodeDB) PruneBelowVersion(ctx context.Context, version int64) error

+ func (pndb *PNodeDB) PutNode(key Key, node Node) error

+ func (pndb *PNodeDB) RecordDeadNodes(nodes []Node, version int64) error

+ func (pndb *PNodeDB) Size(ctx context.Context) int64

+ type Path []byte

+ type PruneStats struct

+ BelowVersion int64

+ DeleteTime time.Duration

+ Deleted int64

+ Leaves int64

+ MissingNodes int64

+ Stage string

+ Total int64

+ UpdateTime time.Duration

+ Version Sequence

+ func GetPruneStats(ctx context.Context) *PruneStats

+ type SecureSerializableValue struct

+ Buffer []byte

+ func (spv *SecureSerializableValue) GetHash() string

+ func (spv *SecureSerializableValue) GetHashBytes() []byte

+ func (spv *SecureSerializableValue) MarshalMsg([]byte) ([]byte, error)

+ func (spv *SecureSerializableValue) UnmarshalMsg(buf []byte) ([]byte, error)

+ type SecureSerializableValueI interface

+ type Sequence int64

+ type Serializable interface

+ Decode func([]byte) error

+ Encode func() []byte

+ type StrKey string

+ type ValueNode struct

+ Value MPTSerializable

+ func GetValueNode(node Node) *ValueNode

+ func NewValueNode() *ValueNode

+ func (vn *ValueNode) Clone() Node

+ func (vn *ValueNode) Decode(buf []byte) error

+ func (vn *ValueNode) Encode() []byte

+ func (vn *ValueNode) GetHash() string

+ func (vn *ValueNode) GetHashBytes() []byte

+ func (vn *ValueNode) GetNodeType() byte

+ func (vn *ValueNode) GetValue() MPTSerializable

+ func (vn *ValueNode) GetValueBytes() []byte

+ func (vn *ValueNode) SetValue(value MPTSerializable)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL