acmstate

package
v0.29.7 Latest Latest
Warning

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

 Go to latest Published: Jan 27, 2020 License: Apache-2.0 Imports: 13 Imported by: 15

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GlobalAccountPermissions 

func GlobalAccountPermissions(getter AccountGetter) (permission.AccountPermissions, error)

Get global permissions from the account at GlobalPermissionsAddress

Types

type AccountGetter 

type AccountGetter interface {
	// Get an account by its address return nil if it does not exist (which should not be an error)
	GetAccount(address crypto.Address) (*acm.Account, error)
}

type AccountIterable 

type AccountIterable interface {
	// Iterates through accounts calling passed function once per account, if the consumer
	// returns true the iteration breaks and returns true to indicate it iteration
	// was escaped
	IterateAccounts(consumer func(*acm.Account) error) (err error)
}

type AccountStats 

type AccountStats struct {
	AccountsWithCode    uint64
	AccountsWithoutCode uint64
}

type AccountStatsGetter 

type AccountStatsGetter interface {
	GetAccountStats() AccountStats
}

type AccountUpdater 

type AccountUpdater interface {
	// Updates the fields of updatedAccount by address, creating the account
	// if it does not exist
	UpdateAccount(updatedAccount *acm.Account) error
	// Remove the account at address
	RemoveAccount(address crypto.Address) error
}

type Cache 

type Cache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewCache 

func NewCache(backend Reader, options ...CacheOption) *Cache

Returns a Cache that wraps an underlying Reader to use on a cache miss, can write to an output Writer via Sync. Goroutine safe for concurrent access.

func (*Cache) Flush 

func (cache *Cache) Flush(output Writer, backend Reader) error

Syncs the Cache to output and Resets it to use backend as Reader

func (*Cache) GetAccount 

func (cache *Cache) GetAccount(address crypto.Address) (*acm.Account, error)

func (*Cache) GetStorage 

func (cache *Cache) GetStorage(address crypto.Address, key binary.Word256) ([]byte, error)

func (*Cache) IterateCachedAccount 

func (cache *Cache) IterateCachedAccount(consumer func(*acm.Account) (stop bool)) (stopped bool, err error)

Iterates over all cached accounts first in cache and then in backend until consumer returns true for 'stop'

func (*Cache) IterateCachedStorage 

func (cache *Cache) IterateCachedStorage(address crypto.Address,
	consumer func(key binary.Word256, value []byte) error) error

Iterates over all cached storage items first in cache and then in backend until consumer returns true for 'stop'

func (*Cache) RemoveAccount 

func (cache *Cache) RemoveAccount(address crypto.Address) error

func (*Cache) Reset 

func (cache *Cache) Reset(backend Reader)

Resets the cache to empty initialising the backing map to the same size as the previous iteration.

func (*Cache) SetStorage 

func (cache *Cache) SetStorage(address crypto.Address, key binary.Word256, value []byte) error

NOTE: Set value to zero to remove.

func (*Cache) String 

func (cache *Cache) String() string

func (*Cache) Sync 

func (cache *Cache) Sync(st Writer) error

Syncs changes to the backend in deterministic order. Sends storage updates before updating the account they belong so that storage values can be taken account of in the update.

func (*Cache) UpdateAccount 

func (cache *Cache) UpdateAccount(account *acm.Account) error

type CacheOption 

type CacheOption func(*Cache) *Cache
var ReadOnly CacheOption = func(cache *Cache) *Cache {
	cache.readonly = true
	return cache
}

func Named 

func Named(name string) CacheOption

type CodeHash added in v0.28.0 

type CodeHash [32]byte

CodeHash is the keccak hash for the code for an account. This is used for the EVM CODEHASH opcode, and to find the correct Metadata for a contract

func (*CodeHash) Bytes added in v0.28.0 

func (h *CodeHash) Bytes() []byte

func (CodeHash) MarshalText added in v0.28.0 

func (ch CodeHash) MarshalText() ([]byte, error)

func (CodeHash) String added in v0.28.0 

func (ch CodeHash) String() string

func (*CodeHash) UnmarshalText added in v0.28.0 

func (ch *CodeHash) UnmarshalText(hexBytes []byte) error

type DumpState 

type DumpState struct {
	bytes.Buffer
}

func (*DumpState) RemoveAccount 

func (dw *DumpState) RemoveAccount(address crypto.Address) error

func (*DumpState) SetStorage 

func (dw *DumpState) SetStorage(address crypto.Address, key, value []byte) error

func (*DumpState) UpdateAccount 

func (dw *DumpState) UpdateAccount(updatedAccount *acm.Account) error

type Iterable 

type Iterable interface {
	AccountIterable
	StorageIterable
}

type IterableReader 

type IterableReader interface {
	Iterable
	Reader
}

Read and list account and storage state

type IterableReaderWriter 

type IterableReaderWriter interface {
	Iterable
	Reader
	Writer
}

type IterableStatsReader 

type IterableStatsReader interface {
	Iterable
	Reader
	AccountStatsGetter
}

type MemoryState 

type MemoryState struct {
	Accounts map[crypto.Address]*acm.Account
	Storage  map[crypto.Address]map[binary.Word256][]byte
	Metadata map[MetadataHash]string
}

func NewMemoryState 

func NewMemoryState() *MemoryState

Get an in-memory state IterableReader

func (*MemoryState) GetAccount 

func (ms *MemoryState) GetAccount(address crypto.Address) (*acm.Account, error)

func (*MemoryState) GetMetadata added in v0.28.0 

func (ms *MemoryState) GetMetadata(metahash MetadataHash) (string, error)

func (*MemoryState) GetStorage 

func (ms *MemoryState) GetStorage(address crypto.Address, key binary.Word256) ([]byte, error)

func (*MemoryState) IterateAccounts 

func (ms *MemoryState) IterateAccounts(consumer func(*acm.Account) error) (err error)

func (*MemoryState) IterateStorage 

func (ms *MemoryState) IterateStorage(address crypto.Address, consumer func(key binary.Word256, value []byte) error) (err error)

func (*MemoryState) RemoveAccount 

func (ms *MemoryState) RemoveAccount(address crypto.Address) error

func (*MemoryState) SetMetadata added in v0.28.0 

func (ms *MemoryState) SetMetadata(metahash MetadataHash, metadata string) error

func (*MemoryState) SetStorage 

func (ms *MemoryState) SetStorage(address crypto.Address, key binary.Word256, value []byte) error

func (*MemoryState) UpdateAccount 

func (ms *MemoryState) UpdateAccount(updatedAccount *acm.Account) error

type MetadataCache added in v0.29.1 

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

func NewMetadataCache added in v0.29.1 

func NewMetadataCache(backend MetadataReader) *MetadataCache

func (*MetadataCache) Flush added in v0.29.1 

func (cache *MetadataCache) Flush(output MetadataWriter, backend MetadataReader) error

func (*MetadataCache) GetMetadata added in v0.29.1 

func (cache *MetadataCache) GetMetadata(metahash MetadataHash) (string, error)

func (*MetadataCache) SetMetadata added in v0.29.1 

func (cache *MetadataCache) SetMetadata(metahash MetadataHash, metadata string) error

func (*MetadataCache) Sync added in v0.29.1 

func (cache *MetadataCache) Sync(st MetadataWriter) error

Syncs changes to the backend in deterministic order. Sends storage updates before updating the account they belong so that storage values can be taken account of in the update.

type MetadataHash added in v0.28.0 

type MetadataHash [32]byte

MetadataHash is the keccak hash for the metadata. This is to make the metadata content-addressed

func GetMetadataHash added in v0.28.0 

func GetMetadataHash(metadata string) (metahash MetadataHash)

func (*MetadataHash) Bytes added in v0.28.0 

func (h *MetadataHash) Bytes() []byte

func (MetadataHash) MarshalText added in v0.28.0 

func (ch MetadataHash) MarshalText() ([]byte, error)

func (MetadataHash) String added in v0.28.0 

func (ch MetadataHash) String() string

func (*MetadataHash) UnmarshalText added in v0.28.0 

func (ch *MetadataHash) UnmarshalText(hexBytes []byte) error

type MetadataReader added in v0.29.1 

type MetadataReader interface {
	// Get an Metadata by its hash. This is content-addressed
	GetMetadata(metahash MetadataHash) (string, error)
}

type MetadataReaderWriter added in v0.29.1 

type MetadataReaderWriter interface {
	MetadataReader
	MetadataWriter
}

type MetadataWriter added in v0.29.1 

type MetadataWriter interface {
	// Set an Metadata according to it keccak-256 hash.
	SetMetadata(metahash MetadataHash, metadata string) error
}

type Reader 

type Reader interface {
	AccountGetter
	StorageGetter
}

Read-only account and storage state

type ReaderWriter 

type ReaderWriter interface {
	Reader
	Writer
}

Read and write account and storage state

type StorageGetter 

type StorageGetter interface {
	// Retrieve a 32-byte value stored at key for the account at address, return Zero256 if key does not exist but
	// error if address does not
	GetStorage(address crypto.Address, key binary.Word256) (value []byte, err error)
}

type StorageIterable 

type StorageIterable interface {
	// Iterates through the storage of account ad address calling the passed function once per account,
	// if the iterator function returns true the iteration breaks and returns true to indicate it iteration
	// was escaped
	IterateStorage(address crypto.Address, consumer func(key binary.Word256, value []byte) error) (err error)
}

type StorageSetter 

type StorageSetter interface {
	// Store a 32-byte value at key for the account at address, setting to Zero256 removes the key
	SetStorage(address crypto.Address, key binary.Word256, value []byte) error
}

type Writer 

type Writer interface {
	AccountUpdater
	StorageSetter
}

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.