execution

Apr 9, 2019

Changes in this version

type ExecutionConfig

+ TimeoutFactor float64

+ type ExecutorFunc func(txEnv *txs.Envelope) (*exec.TxExecution, error)

+ func (f ExecutorFunc) Execute(txEnv *txs.Envelope) (*exec.TxExecution, error)

type Transactor

+ Emitter *event.Emitter

Mar 6, 2019

Changes in this version

type Transactor

+ BlockchainInfo bcm.BlockchainInfo

Feb 27, 2019

Changes in this version

+ func HeightAtVersion(version int64) uint64

+ func VersionAtHeight(height uint64) int64

+ type Params struct

+ ChainID string

+ ProposalThreshold uint64

+ func ParamsFromGenesis(genesisDoc *genesis.GenesisDoc) Params

Dec 20, 2018

Changes in this version

+ const VersionOffset

type State

+ func (s *State) CommitID(version int64) (*CommitID, error)

+ func (s *State) Version() int64

Dec 18, 2018

Changes in this version

type CommitID

+ func (cid CommitID) String() string

Nov 9, 2018

Changes in this version

type ExecutionConfig

+ CallStackMaxDepth uint64

+ DataStackInitialCapacity uint64

+ DataStackMaxDepth uint64

type State

+ func (s *State) GetProposal(proposalHash []byte) (*payload.Ballot, error)

+ func (s *State) IterateProposals(consumer func(proposalHash []byte, proposal *payload.Ballot) (stop bool)) (stopped bool, err error)

Sep 21, 2018

Changes in this version

+ type CommitID struct

+ Hash binary.HexBytes

+ Height uint64

+ Version int64

Aug 17, 2018

Changes in this version

type Transactor

+ func (trans *Transactor) MaybeSignTxMempool(txEnv *txs.Envelope) (UnlockFunc, error)

Jul 24, 2018

Changes in this version

+ const BlockingTimeout

+ const SubscribeBufferSize

+ func CallCodeSim(reader state.Reader, tip bcm.BlockchainInfo, ...) (_ *exec.TxExecution, err error)

+ func CallSim(reader state.Reader, tip bcm.BlockchainInfo, ...) (*exec.TxExecution, error)

+ type Context interface

+ Execute func(txe *exec.TxExecution) error

type SequentialSigningAccount

+ Address crypto.Address

type State

+ func (s *State) GetBlock(height uint64) (*exec.BlockExecution, error)

+ func (s *State) GetBlocks(startHeight, endHeight uint64, consumer func(*exec.BlockExecution) (stop bool)) (stopped bool, err error)

+ func (s *State) GetName(name string) (*names.Entry, error)

+ func (s *State) GetTx(txHash []byte) (*exec.TxExecution, error)

+ func (s *State) IterateNames(consumer func(*names.Entry) (stop bool)) (stopped bool, err error)

type Transactor

+ MempoolAccounts *Accounts

+ Subscribable event.Subscribable

+ Tip bcm.BlockchainInfo

+ func (trans *Transactor) BroadcastTxSync(ctx context.Context, txEnv *txs.Envelope) (*exec.TxExecution, error)

+ func (trans *Transactor) CallCodeSim(fromAddress crypto.Address, code, data []byte) (*exec.TxExecution, error)

+ func (trans *Transactor) CallSim(fromAddress, address crypto.Address, data []byte) (*exec.TxExecution, error)

+ func (trans *Transactor) CheckTxAsync(txEnv *txs.Envelope, callback func(res *abciTypes.Response)) error

+ func (trans *Transactor) CheckTxAsyncRaw(txBytes []byte, callback func(res *abciTypes.Response)) error

+ func (trans *Transactor) CheckTxSync(txEnv *txs.Envelope) (*txs.Receipt, error)

+ func (trans *Transactor) CheckTxSyncRaw(txBytes []byte) (*txs.Receipt, error)

+ func (trans *Transactor) SignTxMempool(txEnv *txs.Envelope) (*txs.Envelope, UnlockFunc, error)

type Updatable

+ AddBlock func(blockExecution *exec.BlockExecution) error

Jun 26, 2018

Changes in this version

type Accounts

+ func (accs *Accounts) GetSequentialSigningAccount(address, privateKey []byte) (*SequentialSigningAccount, error)

+ type Executor interface

+ Execute func(txEnv *txs.Envelope) error

+ type ExecutorState interface

+ Update func(updater func(ws Updatable) error) (hash []byte, err error)

type State

+ func (s *State) GetEvents(startKey, endKey events.Key, consumer func(ev *events.Event) (stop bool)) (stopped bool, err error)

+ func (s *State) GetNameEntry(name string) (*names.Entry, error)

+ func (s *State) IterateNameEntries(consumer func(*names.Entry) (stop bool)) (stopped bool, err error)

+ func (s *State) LatestEventKey() events.Key

+ func (s *State) Update(updater func(up Updatable) error) ([]byte, error)

type Transactor

+ func (trans *Transactor) BroadcastTxAsyncRaw(txBytes []byte, callback func(res *abciTypes.Response)) error

+ func (trans *Transactor) BroadcastTxRaw(txBytes []byte) (*txs.Receipt, error)

+ type Updatable interface

May 8, 2018

Changes in this version

+ const BlockingTimeoutSeconds

+ const GasLimit

+ func HasPermission(accountGetter state.AccountGetter, acc acm.Account, perm ptypes.PermFlag, ...) bool

+ func NameRegDecode(r io.Reader, n *int, err *error) interface

+ func NameRegEncode(o interface{}, w io.Writer, n *int, err *error)

+ func VMOptions(vmOptions ...func(*evm.VM)) func(*executor)

+ type Accounts struct

+ func NewAccounts(reader state.Reader, keyClient keys.KeyClient, mutexCount int) *Accounts

+ func (accs *Accounts) SequentialSigningAccount(address acm.Address) *SequentialSigningAccount

+ func (accs *Accounts) SequentialSigningAccountFromPrivateKey(privateKeyBytes []byte) (*SequentialSigningAccount, error)

+ func (accs *Accounts) SigningAccount(address acm.Address, signer acm.Signer) (*SigningAccount, error)

+ type BatchCommitter interface

+ Commit func() (stateHash []byte, err error)

+ func NewBatchCommitter(backend *State, chainID string, tip bcm.Tip, publisher event.Publisher, ...) BatchCommitter

+ type BatchExecutor interface

+ Execute func(tx txs.Tx) error

+ Reset func() error

+ func NewBatchChecker(backend *State, chainID string, tip bcm.Tip, logger *logging.Logger, ...) BatchExecutor

+ type Call struct

+ GasUsed uint64

+ Return []byte

+ type ExecutionConfig struct

+ VMOptions []VMOption

+ func DefaultExecutionConfig() *ExecutionConfig

+ func (ec *ExecutionConfig) ExecutionOptions() ([]ExecutionOption, error)

+ type ExecutionOption func(*executor)

+ type InvalidTxError struct

+ Reason error

+ Tx txs.Tx

+ func (txErr InvalidTxError) Error() string

+ type NameRegCache struct

+ func NewNameRegCache(backend NameRegGetter) *NameRegCache

+ func (cache *NameRegCache) Backend() NameRegGetter

+ func (cache *NameRegCache) Flush(state NameRegWriter) error

+ func (cache *NameRegCache) GetNameRegEntry(name string) (*NameRegEntry, error)

+ func (cache *NameRegCache) RemoveNameRegEntry(name string) error

+ func (cache *NameRegCache) Reset(backend NameRegGetter)

+ func (cache *NameRegCache) Sync(state NameRegWriter) error

+ func (cache *NameRegCache) UpdateNameRegEntry(entry *NameRegEntry) error

+ type NameRegEntry struct

+ Data string

+ Expires uint64

+ Name string

+ Owner account.Address

+ func DecodeNameRegEntry(entryBytes []byte) *NameRegEntry

+ type NameRegGetter interface

+ GetNameRegEntry func(name string) (*NameRegEntry, error)

+ type NameRegIterable interface

+ IterateNameRegEntries func(consumer func(*NameRegEntry) (stop bool)) (stopped bool, err error)

+ type NameRegUpdater interface

+ RemoveNameRegEntry func(name string) error

+ UpdateNameRegEntry func(entry *NameRegEntry) error

+ type NameRegWriter interface

+ type SequentialSigningAccount struct

+ func (ssa *SequentialSigningAccount) Lock() (*SigningAccount, UnlockFunc, error)

+ type SigningAccount struct

+ type State struct

+ func LoadState(db dbm.DB, hash []byte) (*State, error)

+ func MakeGenesisState(db dbm.DB, genesisDoc *genesis.GenesisDoc) (*State, error)

+ func NewState(db dbm.DB) *State

+ func (s *State) Copy(db dbm.DB) *State

+ func (s *State) GetAccount(address acm.Address) (acm.Account, error)

+ func (s *State) GetNameRegEntry(name string) (*NameRegEntry, error)

+ func (s *State) GetStorage(address acm.Address, key binary.Word256) (binary.Word256, error)

+ func (s *State) Hash() []byte

+ func (s *State) IterateAccounts(consumer func(acm.Account) (stop bool)) (stopped bool, err error)

+ func (s *State) IterateNameRegEntries(consumer func(*NameRegEntry) (stop bool)) (stopped bool, err error)

+ func (s *State) IterateStorage(address acm.Address, consumer func(key, value binary.Word256) (stop bool)) (stopped bool, err error)

+ func (s *State) RemoveAccount(address acm.Address) error

+ func (s *State) RemoveNameRegEntry(name string) error

+ func (s *State) Save() error

+ func (s *State) SetStorage(address acm.Address, key, value binary.Word256) error

+ func (s *State) UpdateAccount(account acm.Account) error

+ func (s *State) UpdateNameRegEntry(entry *NameRegEntry) error

+ type Transactor struct

+ func NewTransactor(tip blockchain.Tip, eventEmitter event.Emitter, ...) *Transactor

+ func (trans *Transactor) BroadcastTx(tx txs.Tx) (*txs.Receipt, error)

+ func (trans *Transactor) BroadcastTxAsync(tx txs.Tx, callback func(res *abci_types.Response)) error

+ func (trans *Transactor) Call(reader state.Reader, fromAddress, toAddress acm.Address, data []byte) (call *Call, err error)

+ func (trans *Transactor) CallCode(reader state.Reader, fromAddress acm.Address, code, data []byte) (*Call, error)

+ func (trans *Transactor) Send(sequentialSigningAccount *SequentialSigningAccount, toAddress acm.Address, ...) (*txs.Receipt, error)

+ func (trans *Transactor) SendAndHold(sequentialSigningAccount *SequentialSigningAccount, toAddress acm.Address, ...) (*txs.Receipt, error)

+ func (trans *Transactor) SignTx(tx txs.Tx, signingAccounts []acm.AddressableSigner) (txs.Tx, error)

+ func (trans *Transactor) Transact(sequentialSigningAccount *SequentialSigningAccount, address *acm.Address, ...) (*txs.Receipt, error)

+ func (trans *Transactor) TransactAndHold(sequentialSigningAccount *SequentialSigningAccount, address *acm.Address, ...) (*evm_events.EventDataCall, error)

+ func (trans *Transactor) TransactNameReg(sequentialSigningAccount *SequentialSigningAccount, name, data string, ...) (*txs.Receipt, error)

+ type UnlockFunc func()

+ type VMOption string

+ const DebugOpcodes

+ const DumpTokens