util

package

Go to main page

Versions in this module

v1

v1.20.1

Mar 28, 2025

v1.20.0

Mar 24, 2025

v1.19.0

Feb 8, 2025

v1.18.3

Nov 12, 2024

v1.18.2

Oct 31, 2024

v1.18.1

Oct 24, 2024

v1.18.0

Oct 22, 2024

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