dao

package
v0.98.5 Latest Latest
Warning

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

 Go to latest Published: May 13, 2022 License: MIT Imports: 14 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// ErrAlreadyExists is returned when transaction exists in dao.
	ErrAlreadyExists = errors.New("transaction already exists")
	// ErrHasConflicts is returned when transaction is in the list of conflicting
	// transactions which are already in dao.
	ErrHasConflicts = errors.New("transaction has conflicts")
)

HasTransaction errors.

Functions

This section is empty.

Types

type Simple 

type Simple struct {
	Version Version
	Store   *storage.MemCachedStore
	// contains filtered or unexported fields
}

Simple is memCached wrapper around DB, simple DAO implementation.

func NewSimple 

func NewSimple(backend storage.Store, stateRootInHeader bool, p2pSigExtensions bool) *Simple

NewSimple creates new simple dao using provided backend store.

func (*Simple) DeleteBlock added in v0.92.0 

func (dao *Simple) DeleteBlock(h util.Uint256) error

DeleteBlock removes block from dao. It's not atomic, so make sure you're using private MemCached instance here.

func (*Simple) DeleteContractID added in v0.92.0 

func (dao *Simple) DeleteContractID(id int32)

DeleteContractID deletes contract's id to hash mapping.

func (*Simple) DeleteStorageItem 

func (dao *Simple) DeleteStorageItem(id int32, key []byte)

DeleteStorageItem drops storage item for the given id with the given key from the store.

func (*Simple) GetAndDecode 

func (dao *Simple) GetAndDecode(entity io.Serializable, key []byte) error

GetAndDecode performs get operation and decoding with serializable structures.

func (*Simple) GetAppExecResults added in v0.92.0 

func (dao *Simple) GetAppExecResults(hash util.Uint256, trig trigger.Type) ([]state.AppExecResult, error)

GetAppExecResults gets application execution results with the specified trigger from the given store.

func (*Simple) GetBatch 

func (dao *Simple) GetBatch() *storage.MemBatch

GetBatch returns currently accumulated DB changeset.

func (*Simple) GetBlock 

func (dao *Simple) GetBlock(hash util.Uint256) (*block.Block, error)

GetBlock returns Block by the given hash if it exists in the store.

func (*Simple) GetContractScriptHash added in v0.91.0 

func (dao *Simple) GetContractScriptHash(id int32) (util.Uint160, error)

GetContractScriptHash retrieves contract's hash given its ID.

func (*Simple) GetCurrentBlockHeight 

func (dao *Simple) GetCurrentBlockHeight() (uint32, error)

GetCurrentBlockHeight returns the current block height found in the underlying store.

func (*Simple) GetCurrentHeaderHeight 

func (dao *Simple) GetCurrentHeaderHeight() (i uint32, h util.Uint256, err error)

GetCurrentHeaderHeight returns the current header height and hash from the underlying store.

func (*Simple) GetHeaderHashes 

func (dao *Simple) GetHeaderHashes() ([]util.Uint256, error)

GetHeaderHashes returns a sorted list of header hashes retrieved from the given underlying store.

func (*Simple) GetPrivate added in v0.98.2 

func (dao *Simple) GetPrivate() *Simple

GetPrivate returns new DAO instance with another layer of private MemCachedStore around the current DAO Store.

func (*Simple) GetStateSyncCurrentBlockHeight added in v0.97.2 

func (dao *Simple) GetStateSyncCurrentBlockHeight() (uint32, error)

GetStateSyncCurrentBlockHeight returns current block height stored during state synchronisation process.

func (*Simple) GetStateSyncPoint added in v0.97.2 

func (dao *Simple) GetStateSyncPoint() (uint32, error)

GetStateSyncPoint returns current state synchronisation point P.

func (*Simple) GetStorageItem 

func (dao *Simple) GetStorageItem(id int32, key []byte) state.StorageItem

GetStorageItem returns StorageItem if it exists in the given store.

func (*Simple) GetStorageItems 

func (dao *Simple) GetStorageItems(id int32) ([]state.StorageItemWithKey, error)

GetStorageItems returns all storage items for a given id.

func (*Simple) GetStorageItemsWithPrefix added in v0.90.0 

func (dao *Simple) GetStorageItemsWithPrefix(id int32, prefix []byte) ([]state.StorageItemWithKey, error)

GetStorageItemsWithPrefix returns all storage items with given id for a given scripthash.

func (*Simple) GetTokenTransferInfo added in v0.98.0 

func (dao *Simple) GetTokenTransferInfo(acc util.Uint160) (*state.TokenTransferInfo, error)

GetTokenTransferInfo retrieves NEP-17 transfer info from the cache.

func (*Simple) GetTokenTransferLog added in v0.98.0 

func (dao *Simple) GetTokenTransferLog(acc util.Uint160, newestTimestamp uint64, index uint32, isNEP11 bool) (*state.TokenTransferLog, error)

GetTokenTransferLog retrieves transfer log from the cache.

func (*Simple) GetTransaction 

func (dao *Simple) GetTransaction(hash util.Uint256) (*transaction.Transaction, uint32, error)

GetTransaction returns Transaction and its height by the given hash if it exists in the store. It does not return dummy transactions.

func (*Simple) GetVersion 

func (dao *Simple) GetVersion() (Version, error)

GetVersion attempts to get the current version stored in the underlying store.

func (*Simple) GetWrapped 

func (dao *Simple) GetWrapped() *Simple

GetWrapped returns new DAO instance with another layer of wrapped MemCachedStore around the current DAO Store.

func (*Simple) HasTransaction 

func (dao *Simple) HasTransaction(hash util.Uint256) error

HasTransaction returns nil if the given store does not contain the given Transaction hash. It returns an error in case if transaction is in chain or in the list of conflicting transactions.

func (*Simple) Persist 

func (dao *Simple) Persist() (int, error)

Persist flushes all the changes made into the (supposedly) persistent underlying store. It doesn't block accesses to DAO from other threads.

func (*Simple) PersistSync added in v0.98.0 

func (dao *Simple) PersistSync() (int, error)

PersistSync flushes all the changes made into the (supposedly) persistent underlying store. It's a synchronous version of Persist that doesn't allow other threads to work with DAO while flushing the Store.

func (*Simple) PutContractID added in v0.92.0 

func (dao *Simple) PutContractID(id int32, hash util.Uint160)

PutContractID adds a mapping from contract's ID to its hash.

func (*Simple) PutCurrentHeader 

func (dao *Simple) PutCurrentHeader(h util.Uint256, index uint32)

PutCurrentHeader stores current header.

func (*Simple) PutStateSyncCurrentBlockHeight added in v0.97.2 

func (dao *Simple) PutStateSyncCurrentBlockHeight(h uint32)

PutStateSyncCurrentBlockHeight stores current block height during state synchronisation process.

func (*Simple) PutStateSyncPoint added in v0.97.2 

func (dao *Simple) PutStateSyncPoint(p uint32)

PutStateSyncPoint stores current state synchronisation point P.

func (*Simple) PutStorageItem 

func (dao *Simple) PutStorageItem(id int32, key []byte, si state.StorageItem)

PutStorageItem puts given StorageItem for given id with given key into the given store.

func (*Simple) PutTokenTransferInfo added in v0.98.0 

func (dao *Simple) PutTokenTransferInfo(acc util.Uint160, bs *state.TokenTransferInfo) error

PutTokenTransferInfo saves NEP-17 transfer info in the cache.

func (*Simple) PutTokenTransferLog added in v0.98.0 

func (dao *Simple) PutTokenTransferLog(acc util.Uint160, start uint64, index uint32, isNEP11 bool, lg *state.TokenTransferLog)

PutTokenTransferLog saves given transfer log in the cache.

func (*Simple) PutVersion 

func (dao *Simple) PutVersion(v Version)

PutVersion stores the given version in the underlying store.

func (*Simple) Seek added in v0.92.0 

func (dao *Simple) Seek(id int32, rng storage.SeekRange, f func(k, v []byte) bool)

Seek executes f for all storage items matching a given `rng` (matching given prefix and starting from the point specified). If key or value is to be used outside of f, they may not be copied. Seek continues iterating until false is returned from f.

func (*Simple) SeekAsync added in v0.98.0 

func (dao *Simple) SeekAsync(ctx context.Context, id int32, rng storage.SeekRange) chan storage.KeyValue

SeekAsync sends all storage items matching a given `rng` (matching given prefix and starting from the point specified) to a channel and returns the channel. Resulting keys and values may not be copied.

func (*Simple) SeekNEP11TransferLog added in v0.98.1 

func (dao *Simple) SeekNEP11TransferLog(acc util.Uint160, newestTimestamp uint64, f func(*state.NEP11Transfer) (bool, error)) error

SeekNEP11TransferLog executes f for each NEP-11 transfer in log starting from the transfer with the newest timestamp up to the oldest transfer. It continues iteration until false is returned from f. The last non-nil error is returned.

func (*Simple) SeekNEP17TransferLog added in v0.98.1 

func (dao *Simple) SeekNEP17TransferLog(acc util.Uint160, newestTimestamp uint64, f func(*state.NEP17Transfer) (bool, error)) error

SeekNEP17TransferLog executes f for each NEP-17 transfer in log starting from the transfer with the newest timestamp up to the oldest transfer. It continues iteration until false is returned from f. The last non-nil error is returned.

func (*Simple) StoreAsBlock 

func (dao *Simple) StoreAsBlock(block *block.Block, aer1 *state.AppExecResult, aer2 *state.AppExecResult) error

StoreAsBlock stores given block as DataBlock. It can reuse given buffer for the purpose of value serialization.

func (*Simple) StoreAsCurrentBlock 

func (dao *Simple) StoreAsCurrentBlock(block *block.Block)

StoreAsCurrentBlock stores a hash of the given block with prefix SYSCurrentBlock. It can reuse given buffer for the purpose of value serialization.

func (*Simple) StoreAsTransaction 

func (dao *Simple) StoreAsTransaction(tx *transaction.Transaction, index uint32, aer *state.AppExecResult) error

StoreAsTransaction stores given TX as DataTransaction. It also stores transactions given tx has conflicts with as DataTransaction with dummy version. It can reuse given buffer for the purpose of value serialization.

func (*Simple) StoreHeader added in v0.98.2 

func (dao *Simple) StoreHeader(h *block.Header) error

StoreHeader saves block header into the store.

func (*Simple) StoreHeaderHashes added in v0.98.2 

func (dao *Simple) StoreHeaderHashes(hashes []util.Uint256, height uint32) error

StoreHeaderHashes pushes a batch of header hashes into the store.

type Version added in v0.98.0 

type Version struct {
	StoragePrefix              storage.KeyPrefix
	StateRootInHeader          bool
	P2PSigExtensions           bool
	P2PStateExchangeExtensions bool
	KeepOnlyLatestState        bool
	Value                      string
}

Version represents current dao version.

func (*Version) Bytes added in v0.98.0 

func (v *Version) Bytes() []byte

Bytes encodes v to a byte-slice.

func (*Version) FromBytes added in v0.98.0 

func (v *Version) FromBytes(data []byte) error

FromBytes decodes v from a byte-slice.

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.