state

package
v1.4.7 Latest Latest
Warning

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

 Go to latest Published: Feb 6, 2023 License: GPL-3.0 Imports: 23 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAccountWrapperMock        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAccountWrapperMock          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAccountWrapperMock = fmt.Errorf("proto: unexpected end of group")
)

Functions

func CreateTestingTriePruningStorer 

func CreateTestingTriePruningStorer(coordinator sharding.Coordinator, notifier pruning.EpochStartNotifier) (storage.Storer, *persisterMap, error)

CreateTestingTriePruningStorer creates a new trie pruning storer that is used for testing

func NewPersistersMap 

func NewPersistersMap() *persisterMap

NewPersistersMap returns a new persisterMap

Types

type AccountWrapMock 

type AccountWrapMock struct {
	AccountWrapMockData

	CodeHash     []byte
	CodeMetadata []byte
	RootHash     []byte

	Balance *big.Int

	SetNonceWithJournalCalled    func(nonce uint64) error           `json:"-"`
	SetCodeHashWithJournalCalled func(codeHash []byte) error        `json:"-"`
	SetCodeWithJournalCalled     func([]byte) error                 `json:"-"`
	AccountDataHandlerCalled     func() vmcommon.AccountDataHandler `json:"-"`
	// contains filtered or unexported fields
}

AccountWrapMock -

func NewAccountWrapMock 

func NewAccountWrapMock(adr []byte) *AccountWrapMock

NewAccountWrapMock -

func (*AccountWrapMock) AccountDataHandler 

func (awm *AccountWrapMock) AccountDataHandler() vmcommon.AccountDataHandler

AccountDataHandler -

func (*AccountWrapMock) AddToBalance 

func (awm *AccountWrapMock) AddToBalance(_ *big.Int) error

AddToBalance -

func (*AccountWrapMock) AddToDeveloperReward 

func (awm *AccountWrapMock) AddToDeveloperReward(*big.Int)

AddToDeveloperReward -

func (*AccountWrapMock) AddressBytes 

func (awm *AccountWrapMock) AddressBytes() []byte

AddressBytes -

func (*AccountWrapMock) ChangeOwnerAddress 

func (awm *AccountWrapMock) ChangeOwnerAddress([]byte, []byte) error

ChangeOwnerAddress -

func (*AccountWrapMock) ClaimDeveloperRewards 

func (awm *AccountWrapMock) ClaimDeveloperRewards([]byte) (*big.Int, error)

ClaimDeveloperRewards -

func (*AccountWrapMock) DataTrie 

func (awm *AccountWrapMock) DataTrie() common.DataTrieHandler

DataTrie -

func (*AccountWrapMock) GetBalance 

func (awm *AccountWrapMock) GetBalance() *big.Int

GetBalance -

func (*AccountWrapMock) GetCodeHash 

func (awm *AccountWrapMock) GetCodeHash() []byte

GetCodeHash -

func (*AccountWrapMock) GetCodeMetadata 

func (awm *AccountWrapMock) GetCodeMetadata() []byte

GetCodeMetadata -

func (*AccountWrapMock) GetDeveloperReward 

func (awm *AccountWrapMock) GetDeveloperReward() *big.Int

GetDeveloperReward -

func (*AccountWrapMock) GetNonce 

func (awm *AccountWrapMock) GetNonce() uint64

GetNonce gets the nonce of the account

func (*AccountWrapMock) GetOwnerAddress 

func (awm *AccountWrapMock) GetOwnerAddress() []byte

GetOwnerAddress -

func (*AccountWrapMock) GetRootHash 

func (awm *AccountWrapMock) GetRootHash() []byte

GetRootHash -

func (*AccountWrapMock) GetUserName 

func (awm *AccountWrapMock) GetUserName() []byte

GetUserName -

func (*AccountWrapMock) HasNewCode 

func (awm *AccountWrapMock) HasNewCode() bool

HasNewCode -

func (*AccountWrapMock) IncreaseNonce 

func (awm *AccountWrapMock) IncreaseNonce(val uint64)

IncreaseNonce adds the given value to the current nonce

func (*AccountWrapMock) IsInterfaceNil 

func (awm *AccountWrapMock) IsInterfaceNil() bool

IsInterfaceNil -

func (*AccountWrapMock) RetrieveValue 

func (awm *AccountWrapMock) RetrieveValue(key []byte) ([]byte, uint32, error)

RetrieveValue -

func (*AccountWrapMock) SaveDirtyData 

func (awm *AccountWrapMock) SaveDirtyData(trie common.Trie) (map[string][]byte, error)

SaveDirtyData -

func (*AccountWrapMock) SaveKeyValue 

func (awm *AccountWrapMock) SaveKeyValue(key []byte, value []byte) error

SaveKeyValue -

func (*AccountWrapMock) SetCode 

func (awm *AccountWrapMock) SetCode(code []byte)

SetCode -

func (*AccountWrapMock) SetCodeHash 

func (awm *AccountWrapMock) SetCodeHash(codeHash []byte)

SetCodeHash -

func (*AccountWrapMock) SetCodeMetadata 

func (awm *AccountWrapMock) SetCodeMetadata(codeMetadata []byte)

SetCodeMetadata -

func (*AccountWrapMock) SetDataTrie 

func (awm *AccountWrapMock) SetDataTrie(trie common.Trie)

SetDataTrie -

func (*AccountWrapMock) SetOwnerAddress 

func (awm *AccountWrapMock) SetOwnerAddress([]byte)

SetOwnerAddress -

func (*AccountWrapMock) SetRootHash 

func (awm *AccountWrapMock) SetRootHash(rootHash []byte)

SetRootHash -

func (*AccountWrapMock) SetTrackableDataTrie 

func (awm *AccountWrapMock) SetTrackableDataTrie(tdt state.DataTrieTracker)

SetTrackableDataTrie -

func (*AccountWrapMock) SetUserName 

func (awm *AccountWrapMock) SetUserName(_ []byte)

SetUserName -

func (*AccountWrapMock) SubFromBalance 

func (awm *AccountWrapMock) SubFromBalance(_ *big.Int) error

SubFromBalance -

type AccountWrapMockData 

type AccountWrapMockData struct {
	MockValue int64 `protobuf:"varint,1,opt,name=MockValue,proto3" json:"MockValue"`
}

func (*AccountWrapMockData) Descriptor 

func (*AccountWrapMockData) Descriptor() ([]byte, []int)

func (*AccountWrapMockData) Equal 

func (this *AccountWrapMockData) Equal(that interface{}) bool

func (*AccountWrapMockData) GetMockValue 

func (m *AccountWrapMockData) GetMockValue() int64

func (*AccountWrapMockData) GoString 

func (this *AccountWrapMockData) GoString() string

func (*AccountWrapMockData) Marshal 

func (m *AccountWrapMockData) Marshal() (dAtA []byte, err error)

func (*AccountWrapMockData) MarshalTo 

func (m *AccountWrapMockData) MarshalTo(dAtA []byte) (int, error)

func (*AccountWrapMockData) MarshalToSizedBuffer 

func (m *AccountWrapMockData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AccountWrapMockData) ProtoMessage 

func (*AccountWrapMockData) ProtoMessage()

func (*AccountWrapMockData) Reset 

func (m *AccountWrapMockData) Reset()

func (*AccountWrapMockData) Size 

func (m *AccountWrapMockData) Size() (n int)

func (*AccountWrapMockData) String 

func (this *AccountWrapMockData) String() string

func (*AccountWrapMockData) Unmarshal 

func (m *AccountWrapMockData) Unmarshal(dAtA []byte) error

func (*AccountWrapMockData) XXX_DiscardUnknown 

func (m *AccountWrapMockData) XXX_DiscardUnknown()

func (*AccountWrapMockData) XXX_Marshal 

func (m *AccountWrapMockData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AccountWrapMockData) XXX_Merge 

func (m *AccountWrapMockData) XXX_Merge(src proto.Message)

func (*AccountWrapMockData) XXX_Size 

func (m *AccountWrapMockData) XXX_Size() int

func (*AccountWrapMockData) XXX_Unmarshal 

func (m *AccountWrapMockData) XXX_Unmarshal(b []byte) error

type AccountsFactoryStub 

type AccountsFactoryStub struct {
	CreateAccountCalled func(address []byte) (vmcommon.AccountHandler, error)
}

AccountsFactoryStub -

func (*AccountsFactoryStub) CreateAccount 

func (afs *AccountsFactoryStub) CreateAccount(address []byte) (vmcommon.AccountHandler, error)

CreateAccount -

func (*AccountsFactoryStub) IsInterfaceNil 

func (afs *AccountsFactoryStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

type AccountsRepositoryStub 

type AccountsRepositoryStub struct {
	GetAccountWithBlockInfoCalled        func(address []byte, options api.AccountQueryOptions) (vmcommon.AccountHandler, common.BlockInfo, error)
	GetCodeWithBlockInfoCalled           func(codeHash []byte, options api.AccountQueryOptions) ([]byte, common.BlockInfo, error)
	GetCurrentStateAccountsWrapperCalled func() state.AccountsAdapterAPI
	CloseCalled                          func() error
}

AccountsRepositoryStub -

func (*AccountsRepositoryStub) Close 

func (stub *AccountsRepositoryStub) Close() error

Close -

func (*AccountsRepositoryStub) GetAccountWithBlockInfo 

func (stub *AccountsRepositoryStub) GetAccountWithBlockInfo(address []byte, options api.AccountQueryOptions) (vmcommon.AccountHandler, common.BlockInfo, error)

GetAccountWithBlockInfo -

func (*AccountsRepositoryStub) GetCodeWithBlockInfo 

func (stub *AccountsRepositoryStub) GetCodeWithBlockInfo(codeHash []byte, options api.AccountQueryOptions) ([]byte, common.BlockInfo, error)

GetCodeWithBlockInfo -

func (*AccountsRepositoryStub) GetCurrentStateAccountsWrapper 

func (stub *AccountsRepositoryStub) GetCurrentStateAccountsWrapper() state.AccountsAdapterAPI

GetCurrentStateAccountsWrapper -

func (*AccountsRepositoryStub) IsInterfaceNil 

func (stub *AccountsRepositoryStub) IsInterfaceNil() bool

IsInterfaceNil -

type AccountsStub 

type AccountsStub struct {
	GetExistingAccountCalled      func(addressContainer []byte) (vmcommon.AccountHandler, error)
	GetAccountFromBytesCalled     func(address []byte, accountBytes []byte) (vmcommon.AccountHandler, error)
	LoadAccountCalled             func(container []byte) (vmcommon.AccountHandler, error)
	SaveAccountCalled             func(account vmcommon.AccountHandler) error
	RemoveAccountCalled           func(addressContainer []byte) error
	CommitCalled                  func() ([]byte, error)
	CommitInEpochCalled           func(uint32, uint32) ([]byte, error)
	JournalLenCalled              func() int
	RevertToSnapshotCalled        func(snapshot int) error
	RootHashCalled                func() ([]byte, error)
	RecreateTrieCalled            func(rootHash []byte) error
	RecreateTrieFromEpochCalled   func(options common.RootHashHolder) error
	PruneTrieCalled               func(rootHash []byte, identifier state.TriePruningIdentifier, handler state.PruningHandler)
	CancelPruneCalled             func(rootHash []byte, identifier state.TriePruningIdentifier)
	SnapshotStateCalled           func(rootHash []byte)
	SetStateCheckpointCalled      func(rootHash []byte)
	IsPruningEnabledCalled        func() bool
	GetAllLeavesCalled            func(leavesChannels *common.TrieIteratorChannels, ctx context.Context, rootHash []byte) error
	RecreateAllTriesCalled        func(rootHash []byte) (map[string]common.Trie, error)
	GetCodeCalled                 func([]byte) []byte
	GetTrieCalled                 func([]byte) (common.Trie, error)
	GetStackDebugFirstEntryCalled func() []byte
	GetAccountWithBlockInfoCalled func(address []byte, options common.RootHashHolder) (vmcommon.AccountHandler, common.BlockInfo, error)
	GetCodeWithBlockInfoCalled    func(codeHash []byte, options common.RootHashHolder) ([]byte, common.BlockInfo, error)
	CloseCalled                   func() error
	SetSyncerCalled               func(syncer state.AccountsDBSyncer) error
	StartSnapshotIfNeededCalled   func() error
}

AccountsStub -

func (*AccountsStub) CancelPrune 

func (as *AccountsStub) CancelPrune(rootHash []byte, identifier state.TriePruningIdentifier)

CancelPrune -

func (*AccountsStub) Close 

func (as *AccountsStub) Close() error

Close -

func (*AccountsStub) Commit 

func (as *AccountsStub) Commit() ([]byte, error)

Commit -

func (*AccountsStub) CommitInEpoch 

func (as *AccountsStub) CommitInEpoch(currentEpoch uint32, epochToCommit uint32) ([]byte, error)

CommitInEpoch -

func (*AccountsStub) GetAccountFromBytes 

func (as *AccountsStub) GetAccountFromBytes(address []byte, accountBytes []byte) (vmcommon.AccountHandler, error)

GetAccountFromBytes -

func (*AccountsStub) GetAccountWithBlockInfo 

func (as *AccountsStub) GetAccountWithBlockInfo(address []byte, options common.RootHashHolder) (vmcommon.AccountHandler, common.BlockInfo, error)

GetAccountWithBlockInfo -

func (*AccountsStub) GetAllLeaves 

func (as *AccountsStub) GetAllLeaves(leavesChannels *common.TrieIteratorChannels, ctx context.Context, rootHash []byte) error

GetAllLeaves -

func (*AccountsStub) GetCode 

func (as *AccountsStub) GetCode(codeHash []byte) []byte

GetCode -

func (*AccountsStub) GetCodeWithBlockInfo 

func (as *AccountsStub) GetCodeWithBlockInfo(codeHash []byte, options common.RootHashHolder) ([]byte, common.BlockInfo, error)

GetCodeWithBlockInfo -

func (*AccountsStub) GetExistingAccount 

func (as *AccountsStub) GetExistingAccount(addressContainer []byte) (vmcommon.AccountHandler, error)

GetExistingAccount -

func (*AccountsStub) GetStackDebugFirstEntry 

func (as *AccountsStub) GetStackDebugFirstEntry() []byte

GetStackDebugFirstEntry -

func (*AccountsStub) GetTrie 

func (as *AccountsStub) GetTrie(codeHash []byte) (common.Trie, error)

GetTrie -

func (*AccountsStub) IsInterfaceNil 

func (as *AccountsStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*AccountsStub) IsPruningEnabled 

func (as *AccountsStub) IsPruningEnabled() bool

IsPruningEnabled -

func (*AccountsStub) JournalLen 

func (as *AccountsStub) JournalLen() int

JournalLen -

func (*AccountsStub) LoadAccount 

func (as *AccountsStub) LoadAccount(address []byte) (vmcommon.AccountHandler, error)

LoadAccount -

func (*AccountsStub) PruneTrie 

func (as *AccountsStub) PruneTrie(rootHash []byte, identifier state.TriePruningIdentifier, handler state.PruningHandler)

PruneTrie -

func (*AccountsStub) RecreateAllTries 

func (as *AccountsStub) RecreateAllTries(rootHash []byte) (map[string]common.Trie, error)

RecreateAllTries -

func (*AccountsStub) RecreateTrie 

func (as *AccountsStub) RecreateTrie(rootHash []byte) error

RecreateTrie -

func (*AccountsStub) RecreateTrieFromEpoch 

func (as *AccountsStub) RecreateTrieFromEpoch(options common.RootHashHolder) error

RecreateTrieFromEpoch -

func (*AccountsStub) RemoveAccount 

func (as *AccountsStub) RemoveAccount(addressContainer []byte) error

RemoveAccount -

func (*AccountsStub) RevertToSnapshot 

func (as *AccountsStub) RevertToSnapshot(snapshot int) error

RevertToSnapshot -

func (*AccountsStub) RootHash 

func (as *AccountsStub) RootHash() ([]byte, error)

RootHash -

func (*AccountsStub) SaveAccount 

func (as *AccountsStub) SaveAccount(account vmcommon.AccountHandler) error

SaveAccount -

func (*AccountsStub) SetStateCheckpoint 

func (as *AccountsStub) SetStateCheckpoint(rootHash []byte)

SetStateCheckpoint -

func (*AccountsStub) SetSyncer 

func (as *AccountsStub) SetSyncer(syncer state.AccountsDBSyncer) error

SetSyncer -

func (*AccountsStub) SnapshotState 

func (as *AccountsStub) SnapshotState(rootHash []byte)

SnapshotState -

func (*AccountsStub) StartSnapshotIfNeeded 

func (as *AccountsStub) StartSnapshotIfNeeded() error

StartSnapshotIfNeeded -

type EvictionWaitingListMock 

type EvictionWaitingListMock struct {
	Cache     map[string]common.ModifiedHashes
	CacheSize uint
	OpMutex   sync.RWMutex
}

EvictionWaitingListMock is a mock implementation of state.DBRemoveCacher

func NewEvictionWaitingListMock 

func NewEvictionWaitingListMock(size uint) *EvictionWaitingListMock

NewEvictionWaitingListMock creates a new instance of evictionWaitingList

func (*EvictionWaitingListMock) Close 

func (ewl *EvictionWaitingListMock) Close() error

Close -

func (*EvictionWaitingListMock) Evict 

func (ewl *EvictionWaitingListMock) Evict(rootHash []byte) (common.ModifiedHashes, error)

Evict returns and removes from the waiting list all the hashes from the position given by the root hash

func (*EvictionWaitingListMock) IsInterfaceNil 

func (ewl *EvictionWaitingListMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*EvictionWaitingListMock) Put 

func (ewl *EvictionWaitingListMock) Put(rootHash []byte, hashes common.ModifiedHashes) error

Put stores the given hashes in the eviction waiting list, in the position given by the root hash

func (*EvictionWaitingListMock) ShouldKeepHash 

func (ewl *EvictionWaitingListMock) ShouldKeepHash(hash string, identifier state.TriePruningIdentifier) (bool, error)

ShouldKeepHash -

type StoragePruningManagerStub 

type StoragePruningManagerStub struct {
	MarkForEvictionCalled func(bytes []byte, bytes2 []byte, hashes common.ModifiedHashes, hashes2 common.ModifiedHashes) error
	PruneTrieCalled       func(rootHash []byte, identifier state.TriePruningIdentifier, tsm common.StorageManager, handler state.PruningHandler)
	CancelPruneCalled     func(rootHash []byte, identifier state.TriePruningIdentifier, tsm common.StorageManager)
	CloseCalled           func() error
}

StoragePruningManagerStub -

func (*StoragePruningManagerStub) CancelPrune 

func (stub *StoragePruningManagerStub) CancelPrune(rootHash []byte, identifier state.TriePruningIdentifier, tsm common.StorageManager)

CancelPrune -

func (*StoragePruningManagerStub) Close 

func (stub *StoragePruningManagerStub) Close() error

Close -

func (*StoragePruningManagerStub) IsInterfaceNil 

func (stub *StoragePruningManagerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*StoragePruningManagerStub) MarkForEviction 

func (stub *StoragePruningManagerStub) MarkForEviction(bytes []byte, bytes2 []byte, hashes common.ModifiedHashes, hashes2 common.ModifiedHashes) error

MarkForEviction -

func (*StoragePruningManagerStub) PruneTrie 

func (stub *StoragePruningManagerStub) PruneTrie(rootHash []byte, identifier state.TriePruningIdentifier, tsm common.StorageManager, handler state.PruningHandler)

PruneTrie -

type UserAccountStub 

type UserAccountStub struct {
	Balance             *big.Int
	DeveloperRewards    *big.Int
	UserName            []byte
	Owner               []byte
	Address             []byte
	AddToBalanceCalled  func(value *big.Int) error
	RetrieveValueCalled func(_ []byte) ([]byte, uint32, error)
}

UserAccountStub -

func (*UserAccountStub) AddToBalance 

func (u *UserAccountStub) AddToBalance(value *big.Int) error

AddToBalance -

func (*UserAccountStub) AddToDeveloperReward 

func (u *UserAccountStub) AddToDeveloperReward(*big.Int)

AddToDeveloperReward -

func (*UserAccountStub) AddressBytes 

func (u *UserAccountStub) AddressBytes() []byte

AddressBytes -

func (*UserAccountStub) ChangeOwnerAddress 

func (u *UserAccountStub) ChangeOwnerAddress([]byte, []byte) error

ChangeOwnerAddress -

func (*UserAccountStub) ClaimDeveloperRewards 

func (u *UserAccountStub) ClaimDeveloperRewards([]byte) (*big.Int, error)

ClaimDeveloperRewards -

func (*UserAccountStub) DataTrie 

func (u *UserAccountStub) DataTrie() common.DataTrieHandler

DataTrie -

func (*UserAccountStub) GetBalance 

func (u *UserAccountStub) GetBalance() *big.Int

GetBalance -

func (*UserAccountStub) GetCodeHash 

func (u *UserAccountStub) GetCodeHash() []byte

GetCodeHash -

func (*UserAccountStub) GetCodeMetadata 

func (u *UserAccountStub) GetCodeMetadata() []byte

GetCodeMetadata -

func (*UserAccountStub) GetDeveloperReward 

func (u *UserAccountStub) GetDeveloperReward() *big.Int

GetDeveloperReward -

func (*UserAccountStub) GetNonce 

func (u *UserAccountStub) GetNonce() uint64

GetNonce -

func (*UserAccountStub) GetOwnerAddress 

func (u *UserAccountStub) GetOwnerAddress() []byte

GetOwnerAddress -

func (*UserAccountStub) GetRootHash 

func (u *UserAccountStub) GetRootHash() []byte

GetRootHash -

func (*UserAccountStub) GetUserName 

func (u *UserAccountStub) GetUserName() []byte

GetUserName -

func (*UserAccountStub) HasNewCode 

func (u *UserAccountStub) HasNewCode() bool

HasNewCode -

func (*UserAccountStub) IncreaseNonce 

func (u *UserAccountStub) IncreaseNonce(_ uint64)

IncreaseNonce -

func (*UserAccountStub) IsInterfaceNil 

func (u *UserAccountStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*UserAccountStub) RetrieveValue 

func (u *UserAccountStub) RetrieveValue(key []byte) ([]byte, uint32, error)

RetrieveValue -

func (*UserAccountStub) SaveDirtyData 

func (u *UserAccountStub) SaveDirtyData(_ common.Trie) (map[string][]byte, error)

SaveDirtyData -

func (*UserAccountStub) SaveKeyValue 

func (u *UserAccountStub) SaveKeyValue(_ []byte, _ []byte) error

SaveKeyValue -

func (*UserAccountStub) SetCode 

func (u *UserAccountStub) SetCode(_ []byte)

SetCode -

func (*UserAccountStub) SetCodeHash 

func (u *UserAccountStub) SetCodeHash([]byte)

SetCodeHash -

func (*UserAccountStub) SetCodeMetadata 

func (u *UserAccountStub) SetCodeMetadata(_ []byte)

SetCodeMetadata -

func (*UserAccountStub) SetDataTrie 

func (u *UserAccountStub) SetDataTrie(_ common.Trie)

SetDataTrie -

func (*UserAccountStub) SetOwnerAddress 

func (u *UserAccountStub) SetOwnerAddress([]byte)

SetOwnerAddress -

func (*UserAccountStub) SetRootHash 

func (u *UserAccountStub) SetRootHash([]byte)

SetRootHash -

func (*UserAccountStub) SetUserName 

func (u *UserAccountStub) SetUserName(_ []byte)

SetUserName -

func (*UserAccountStub) SubFromBalance 

func (u *UserAccountStub) SubFromBalance(_ *big.Int) error

SubFromBalance -

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.