blockchainer

Documentation

Index

• type Blockchainer
• type Blockqueuer
• type Policer
• type StateRoot
• type StateSync

Types

type Blockchainer

type Blockchainer interface {
	ApplyPolicyToTxSet([]*transaction.Transaction) []*transaction.Transaction
	GetConfig() config.ProtocolConfiguration
	Blockqueuer // Blockqueuer interface
	CalculateClaimable(h util.Uint160, endHeight uint32) (*big.Int, error)
	Close()
	InitVerificationVM(v *vm.VM, getContract func(util.Uint160) (*state.Contract, error), hash util.Uint160, witness *transaction.Witness) error
	IsTxStillRelevant(t *transaction.Transaction, txpool *mempool.Pool, isPartialTx bool) bool
	HeaderHeight() uint32
	GetBlock(hash util.Uint256) (*block.Block, error)
	GetCommittee() (keys.PublicKeys, error)
	GetContractState(hash util.Uint160) *state.Contract
	GetContractScriptHash(id int32) (util.Uint160, error)
	GetEnrollments() ([]state.Validator, error)
	GetGoverningTokenBalance(acc util.Uint160) (*big.Int, uint32)
	ForEachNEP11Transfer(util.Uint160, func(*state.NEP11Transfer) (bool, error)) error
	ForEachNEP17Transfer(util.Uint160, func(*state.NEP17Transfer) (bool, error)) error
	GetHeaderHash(int) util.Uint256
	GetHeader(hash util.Uint256) (*block.Header, error)
	CurrentHeaderHash() util.Uint256
	CurrentBlockHash() util.Uint256
	HasBlock(util.Uint256) bool
	HasTransaction(util.Uint256) bool
	IsExtensibleAllowed(util.Uint160) bool
	GetAppExecResults(util.Uint256, trigger.Type) ([]state.AppExecResult, error)
	GetNotaryDepositExpiration(acc util.Uint160) uint32
	GetNativeContractScriptHash(string) (util.Uint160, error)
	GetNatives() []state.NativeContract
	GetNextBlockValidators() ([]*keys.PublicKey, error)
	GetNEP11Contracts() []util.Uint160
	GetNEP17Contracts() []util.Uint160
	GetTokenLastUpdated(acc util.Uint160) (map[int32]uint32, error)
	GetNotaryContractScriptHash() util.Uint160
	GetNotaryBalance(acc util.Uint160) *big.Int
	GetPolicer() Policer
	GetValidators() ([]*keys.PublicKey, error)
	GetStandByCommittee() keys.PublicKeys
	GetStandByValidators() keys.PublicKeys
	GetStateModule() StateRoot
	GetStateSyncModule() StateSync
	GetStorageItem(id int32, key []byte) state.StorageItem
	GetStorageItems(id int32) ([]state.StorageItemWithKey, error)
	GetTestVM(t trigger.Type, tx *transaction.Transaction, b *block.Block) (*vm.VM, func())
	GetTransaction(util.Uint256) (*transaction.Transaction, uint32, error)
	SetOracle(service services.Oracle)
	mempool.Feer // fee interface
	ManagementContractHash() util.Uint160
	PoolTx(t *transaction.Transaction, pools ...*mempool.Pool) error
	PoolTxWithData(t *transaction.Transaction, data interface{}, mp *mempool.Pool, feer mempool.Feer, verificationFunction func(bc Blockchainer, t *transaction.Transaction, data interface{}) error) error
	RegisterPostBlock(f func(Blockchainer, *mempool.Pool, *block.Block))
	SetNotary(mod services.Notary)
	SubscribeForBlocks(ch chan<- *block.Block)
	SubscribeForExecutions(ch chan<- *state.AppExecResult)
	SubscribeForNotifications(ch chan<- *subscriptions.NotificationEvent)
	SubscribeForTransactions(ch chan<- *transaction.Transaction)
	VerifyTx(*transaction.Transaction) error
	VerifyWitness(util.Uint160, hash.Hashable, *transaction.Witness, int64) (int64, error)
	GetMemPool() *mempool.Pool
	UnsubscribeFromBlocks(ch chan<- *block.Block)
	UnsubscribeFromExecutions(ch chan<- *state.AppExecResult)
	UnsubscribeFromNotifications(ch chan<- *subscriptions.NotificationEvent)
	UnsubscribeFromTransactions(ch chan<- *transaction.Transaction)
}

Blockchainer is an interface that abstract the implementation of the blockchain.

type Blockqueuer

type Blockqueuer interface {
	AddBlock(block *block.Block) error
	AddHeaders(...*block.Header) error
	BlockHeight() uint32
}

Blockqueuer is an interface for blockqueue.

type Policer

type Policer interface {
	GetBaseExecFee() int64
	GetMaxVerificationGAS() int64
	GetStoragePrice() int64
	FeePerByte() int64
}

Policer is an interface that abstracts the implementation of policy methods.

type StateRoot

type StateRoot interface {
	AddStateRoot(root *state.MPTRoot) error
	CleanStorage() error
	CurrentLocalHeight() uint32
	CurrentLocalStateRoot() util.Uint256
	CurrentValidatedHeight() uint32
	FindStates(root util.Uint256, prefix, start []byte, max int) ([]storage.KeyValue, error)
	GetState(root util.Uint256, key []byte) ([]byte, error)
	GetStateProof(root util.Uint256, key []byte) ([][]byte, error)
	GetStateRoot(height uint32) (*state.MPTRoot, error)
	GetStateValidators(height uint32) keys.PublicKeys
	SetUpdateValidatorsCallback(func(uint32, keys.PublicKeys))
	UpdateStateValidators(height uint32, pubs keys.PublicKeys)
}

StateRoot represents local state root module.

type StateSync

type StateSync interface {
	AddMPTNodes([][]byte) error
	Blockqueuer // Blockqueuer interface
	Init(currChainHeight uint32) error
	IsActive() bool
	IsInitialized() bool
	GetUnknownMPTNodesBatch(limit int) []util.Uint256
	NeedHeaders() bool
	NeedMPTNodes() bool
	Traverse(root util.Uint256, process func(node mpt.Node, nodeBytes []byte) bool) error
}

StateSync represents state sync module.