trie

package
v2.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 14, 2024 License: Apache-2.0, GPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TagHashNode        = 0
	TagValueNode       = 1
	TagShortNode       = 2
	TagFullNode        = 17
	LenOfChildrenNodes = 17
)

Variables

This section is empty.

Functions

func CopyBytes 

func CopyBytes(b []byte) (copiedBytes []byte)

func Deserialize 

func Deserialize(hash []byte, r io.Reader, needFlags bool) (node, error)

func Sha256Key added in v2.1.6 

func Sha256Key(bs []byte) []byte

Types

type Database 

type Database interface {
	Get(key []byte) ([]byte, error)
	Has(key []byte) (bool, error)
	Delete(key []byte) error
	Compact() error
	NewBatch() error
	BatchPut(key, value []byte) error
	BatchDelete(key []byte) error
	BatchCommit() error
	NewIterator(prefix []byte) db.IIterator
}

type Iterator 

type Iterator struct {
	Key   []byte
	Value []byte
	Err   error
	// contains filtered or unexported fields
}

func NewIterator 

func NewIterator(it NodeIterator) *Iterator

func (*Iterator) Next 

func (it *Iterator) Next() bool

type MemDatabase 

type MemDatabase struct {
	// contains filtered or unexported fields
}

func NewMemDatabase 

func NewMemDatabase() *MemDatabase

func (*MemDatabase) BatchPut 

func (db *MemDatabase) BatchPut(key []byte, value []byte) error

func (*MemDatabase) Delete 

func (db *MemDatabase) Delete(key []byte) error

func (*MemDatabase) Get 

func (db *MemDatabase) Get(key []byte) ([]byte, error)

func (*MemDatabase) Has 

func (db *MemDatabase) Has(key []byte) (bool, error)

func (*MemDatabase) ViewDB 

func (db *MemDatabase) ViewDB()

type NodeIterator 

type NodeIterator interface {
	Next(bool) bool
	Error() error
	Hash() common.Uint256
	Parent() common.Uint256
	Path() []byte
	Leaf() bool
	LeafKey() []byte
	LeafBlob() []byte
}

type RefCounts 

type RefCounts struct {
	// contains filtered or unexported fields
}

func NewRefCounts 

func NewRefCounts(t *Trie, refCountTargetHeight, pruningTargetHeight uint32) (*RefCounts, error)

func (*RefCounts) ClearNeedReset added in v2.1.7 

func (ref *RefCounts) ClearNeedReset() error

func (*RefCounts) Commit 

func (ref *RefCounts) Commit() error

func (*RefCounts) Compact 

func (ref *RefCounts) Compact() error

func (*RefCounts) CreateRefCounts 

func (ref *RefCounts) CreateRefCounts(hash common.Uint256, inMemory, persistIntermediate bool) error

func (*RefCounts) LengthOfCounts 

func (ref *RefCounts) LengthOfCounts() int

func (*RefCounts) NeedReset added in v2.1.7 

func (ref *RefCounts) NeedReset() (bool, error)

func (*RefCounts) NewBatch 

func (ref *RefCounts) NewBatch() error

func (*RefCounts) PersistNeedReset added in v2.1.7 

func (ref *RefCounts) PersistNeedReset() error

func (*RefCounts) PersistPrunedHeights 

func (ref *RefCounts) PersistPrunedHeights() error

func (*RefCounts) PersistRefCountHeights 

func (ref *RefCounts) PersistRefCountHeights() error

func (*RefCounts) PersistRefCounts 

func (ref *RefCounts) PersistRefCounts() error

func (*RefCounts) Prune 

func (ref *RefCounts) Prune(hash common.Uint256, inMemory bool) error

func (*RefCounts) RebuildRefCount 

func (ref *RefCounts) RebuildRefCount() error

func (*RefCounts) RemoveAllRefCount added in v2.1.7 

func (ref *RefCounts) RemoveAllRefCount() error

func (*RefCounts) SequentialPrune 

func (ref *RefCounts) SequentialPrune() error

func (*RefCounts) Verify 

func (ref *RefCounts) Verify(hash common.Uint256) error

type Sync added in v2.1.7 

type Sync struct {
	sync.RWMutex

	DataAvailable chan struct{} // Notify when new states arrived
	// contains filtered or unexported fields
}

Sync is the main state trie synchronisation scheduler, which provides yet unknown trie hashes to retrieve, accepts node data associated with said hashes and reconstructs the trie step by step until all is done.

func NewSync added in v2.1.7 

func NewSync(root common.Uint256) *Sync

func (*Sync) AddSubTrie added in v2.1.7 

func (s *Sync) AddSubTrie(root common.Uint256, path []byte)

AddSubTrie registers a new trie to the sync code, rooted at the designated parent.

func (*Sync) Commit added in v2.1.7 

func (s *Sync) Commit(sdb db.IStore) error

Commit flushes the data stored in the internal membatch out to persistent storage, returning any occurred error.

func (*Sync) Pending added in v2.1.7 

func (s *Sync) Pending() int

Pending returns the number of state entries currently pending for download.

func (*Sync) Pop added in v2.1.7 

func (s *Sync) Pop(max int) ([]common.Uint256, []int64)

Pop return the specific number of hash jobs from heap

func (*Sync) Process added in v2.1.7 

func (s *Sync) Process(result SyncResult) error

Process injects the received data for requested item.

func (*Sync) Push added in v2.1.7 

func (s *Sync) Push(hashes []common.Uint256, prio int64)

type SyncPath added in v2.1.7 

type SyncPath []byte

type SyncResult added in v2.1.7 

type SyncResult struct {
	Hash common.Uint256 // Hash of the originally unknown trie node
	Data []byte         // Data content of the retrieved node
}

SyncResult is a response with requested data along with it's hash.

type Trie 

type Trie struct {
	// contains filtered or unexported fields
}

func New 

func New(hash common.Uint256, db Database) (*Trie, error)

func (*Trie) Commit 

func (t *Trie) Commit() (common.Uint256, error)

func (*Trie) CommitTo 

func (t *Trie) CommitTo(db Database) (common.Uint256, error)

func (*Trie) Copy 

func (t *Trie) Copy() *Trie

func (*Trie) Delete 

func (t *Trie) Delete(key []byte)

func (*Trie) Get 

func (t *Trie) Get(key []byte) []byte

func (*Trie) Hash 

func (t *Trie) Hash() common.Uint256

func (*Trie) NewRefCounts 

func (t *Trie) NewRefCounts(targetRefCountHeight, targetPruningHeight uint32) (*RefCounts, error)

func (*Trie) NodeIterator 

func (t *Trie) NodeIterator(start []byte) NodeIterator

func (*Trie) Reset added in v2.1.6 

func (t *Trie) Reset()

Reset drops the referenced root node and cleans all internal state.

func (*Trie) TryDelete 

func (t *Trie) TryDelete(key []byte) error

func (*Trie) TryGet 

func (t *Trie) TryGet(key []byte) ([]byte, error)

func (*Trie) TryTraverse 

func (t *Trie) TryTraverse(needPrint bool) error

func (*Trie) TryUpdate 

func (t *Trie) TryUpdate(key, value []byte) error

func (*Trie) Update 

func (t *Trie) Update(key, value []byte)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.