types

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Jun 28, 2021 License: Apache-2.0 Imports: 19 Imported by: 16

Documentation

Index

Constants

View Source 
const (
	// ReceiptStatusFailed is the status code of a transaction if execution failed.
	ReceiptStatusFailed = uint64(0)

	// ReceiptStatusSuccessful is the status code of a transaction if execution succeeded.
	ReceiptStatusSuccessful = uint64(1)
)
View Source 
const (
	BondStatusUnbonded = "Unbonded"
	BondStatusBonded   = "Bonded"
)
View Source 
const ACCOUNT_KEY byte = 23
View Source 
const ACCOUNT_NOT_EXIST int = 1026
View Source 
const BYTECODE_KEY byte = 25
View Source 
const CREATION_COUNTER_KEY byte = 21
View Source 
const CURR_BLOCK_KEY byte = 29
View Source 
const FAILED_TO_COMMIT int = 1025
View Source 
const IGNORE_TOO_OLD_TX int = 1024
View Source 
const TOO_OLD_THRESHOLD uint64 = 10
View Source 
const TX_NONCE_TOO_LARGE int = 1029
View Source 
const TX_NONCE_TOO_SMALL int = 1027
View Source 
const VALUE_KEY byte = 27

Variables

View Source 
var (
	ErrAccountNotExist = errors.New("account does not exist")
	ErrNonceTooSmall   = errors.New("tx nonce is smaller than the account nonce")
	ErrNonceTooLarge   = errors.New("tx nonce is larger than the account nonce")
	ErrTooManyEntries  = errors.New("too many candidicate entries to be returned, please limit the difference between startHeight and endHeight")
)
View Source 
var (
	ErrAccNotFound         = errors.New("account not found")
	ErrCodeNotFound        = errors.New("code not found")
	ErrBadAccData          = errors.New("bad account data")
	ErrBadNonce            = errors.New("bad nonce")
	ErrBadGasPrice         = errors.New("bad gas price")
	ErrInsufficientBalance = errors.New("insufficient balance")
	ErrBlockNotFound       = errors.New("block not found")
	ErrTxNotFound          = errors.New("tx not found")
	ErrNoFromAddr          = errors.New("missing from address")
	ErrInvalidHeight       = errors.New("invalid height")
)
View Source 
var StandbyTxQueueKey [8]byte = [8]byte{255, 255, 255, 255, 255, 255, 255, 0}

Functions

func FromGethAddreses 

func FromGethAddreses(gethAddresses []gethcmn.Address) [][20]byte

func FromGethHashes 

func FromGethHashes(gethHashes []gethcmn.Hash) [][32]byte

func GetAccountKey 

func GetAccountKey(addr common.Address) []byte

func GetBytecodeKey 

func GetBytecodeKey(addr common.Address) []byte

func GetCreationCounterKey 

func GetCreationCounterKey(lsb uint8) []byte

func GetStandbyTxKey 

func GetStandbyTxKey(num uint64) []byte

func GetValueKey 

func GetValueKey(seq uint64, key string) []byte

func ToGethHashes 

func ToGethHashes(rawHashes [][32]byte) []gethcmn.Hash

func ToGethLog 

func ToGethLog(log Log) *gethtypes.Log

func ToGethLogs 

func ToGethLogs(logs []Log) []*gethtypes.Log

Types

type AccountInfo 

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

func NewAccountInfo 

func NewAccountInfo(data []byte) *AccountInfo

func ZeroAccountInfo 

func ZeroAccountInfo() *AccountInfo

func (*AccountInfo) Balance 

func (info *AccountInfo) Balance() *uint256.Int

func (*AccountInfo) BalanceSlice 

func (info *AccountInfo) BalanceSlice() []byte

func (*AccountInfo) Bytes 

func (info *AccountInfo) Bytes() []byte

func (*AccountInfo) Nonce 

func (info *AccountInfo) Nonce() uint64

func (*AccountInfo) NonceSlice 

func (info *AccountInfo) NonceSlice() []byte

func (*AccountInfo) Sequence 

func (info *AccountInfo) Sequence() uint64

func (*AccountInfo) SequenceSlice 

func (info *AccountInfo) SequenceSlice() []byte

func (*AccountInfo) UpdateBalance 

func (info *AccountInfo) UpdateBalance(newBalance *uint256.Int)

func (*AccountInfo) UpdateNonce 

func (info *AccountInfo) UpdateNonce(newNonce uint64)

func (*AccountInfo) UpdateSequence 

func (info *AccountInfo) UpdateSequence(newSeq uint64)

type BasicTx 

type BasicTx struct {
	From     common.Address
	To       common.Address
	Value    [32]byte
	GasPrice [32]byte
	Gas      uint64
	Data     []byte
	Nonce    uint64
}

type Block 

type Block struct {
	Number           int64      `msg:"num"`     //the block number. Null when the returned block is the pending block.
	Hash             [32]byte   `msg:"hash"`    //32 Bytes - hash of the block. Null when the returned block is the pending block.
	ParentHash       [32]byte   `msg:"parent"`  //32 Bytes - hash of the parent block.
	LogsBloom        [256]byte  `msg:"bloom"`   // 256 Bytes - the bloom filter for the logs of the block. Null when the returned block is the pending block.
	TransactionsRoot [32]byte   `msg:"troot"`   // 32 Bytes - the root of the transaction trie of the block.
	StateRoot        [32]byte   `msg:"sroot"`   //32 Bytes - the root of the final state trie of the block.
	Miner            [20]byte   `msg:"miner"`   //20 Bytes - the address of the beneficiary to whom the mining rewards were given.
	Size             int64      `msg:"size"`    //integer the size of this block in bytes.
	GasUsed          uint64     `msg:"gasused"` //the total used gas by all transactions in this block.
	Timestamp        int64      `msg:"time"`    //the unix timestamp for when the block was collated.
	Transactions     [][32]byte `msg:"txs"`     //Array - Array of transaction objects, or 32 Bytes transaction hashes depending on the last given parameter.

}

BLOCK - A block object, or null when no block was found

func (*Block) DecodeMsg 

func (z *Block) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*Block) EncodeMsg 

func (z *Block) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*Block) FillBasicInfo 

func (blk *Block) FillBasicInfo(bz []byte)

func (*Block) MarshalMsg 

func (z *Block) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*Block) Msgsize 

func (z *Block) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*Block) SerializeBasicInfo 

func (blk *Block) SerializeBasicInfo() []byte

func (*Block) UnmarshalMsg 

func (z *Block) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type BlockInfo 

type BlockInfo struct {
	Coinbase   [20]byte
	Hash       [32]byte
	Number     int64
	Timestamp  int64
	GasLimit   int64
	Difficulty [32]byte
	ChainId    [32]byte
}

type BondStatus 

type BondStatus uint64

BondStatus is the status of a validator

func (BondStatus) String 

func (b BondStatus) String() string

String implements the Stringer interface for BondStatus.

type BytecodeInfo 

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

func NewBytecodeInfo 

func NewBytecodeInfo(data []byte) *BytecodeInfo

func (*BytecodeInfo) BytecodeSlice 

func (info *BytecodeInfo) BytecodeSlice() []byte

func (*BytecodeInfo) Bytes 

func (info *BytecodeInfo) Bytes() []byte

func (*BytecodeInfo) CodeHashSlice 

func (info *BytecodeInfo) CodeHashSlice() []byte

type ChainEvent 

type ChainEvent struct {
	BlockHeader *Header
	Block       *modbtypes.Block
	Hash        gethcmn.Hash
	Logs        []*gethtypes.Log
}
type ChainEvent struct {
	Block *types.Block
	Hash  common.Hash
	Logs  []*types.Log
}

type Context 

type Context struct {
	Height uint64
	Rbt    *rabbit.RabbitStore
	Db     modbtypes.DB
}

func NewContext 

func NewContext(height uint64, rbt *rabbit.RabbitStore, db modbtypes.DB) *Context

func (*Context) BasicQueryLogs 

func (c *Context) BasicQueryLogs(address common.Address, topics []common.Hash,
	startHeight, endHeight, limit uint32) (logs []Log, err error)

func (*Context) CheckNonce 

func (c *Context) CheckNonce(sender common.Address, nonce uint64) (*AccountInfo, error)

func (*Context) Close 

func (c *Context) Close(dirty bool)

func (*Context) DeductTxFee 

func (c *Context) DeductTxFee(sender common.Address, acc *AccountInfo, txGas uint64, gasPrice *uint256.Int) error

func (*Context) DeleteAccount 

func (c *Context) DeleteAccount(address common.Address)

func (*Context) GetAccount 

func (c *Context) GetAccount(address common.Address) *AccountInfo

func (*Context) GetBalance 

func (c *Context) GetBalance(owner common.Address, height int64) (*uint256.Int, error)

func (*Context) GetBlockByHash 

func (c *Context) GetBlockByHash(hash common.Hash) (blk *Block, err error)

func (*Context) GetBlockByHeight 

func (c *Context) GetBlockByHeight(height uint64) (*Block, error)

func (*Context) GetBlockHashByHeight added in v0.1.1 

func (c *Context) GetBlockHashByHeight(height uint64) [32]byte

func (*Context) GetCode 

func (c *Context) GetCode(contract common.Address) *BytecodeInfo

func (*Context) GetCurrBlockBasicInfo 

func (c *Context) GetCurrBlockBasicInfo() *Block

func (*Context) GetFromAddressCount added in v0.1.4 

func (c *Context) GetFromAddressCount(addr common.Address) int64

return the times addr acts as a from-address of a transaction

func (*Context) GetLatestHeight 

func (c *Context) GetLatestHeight() int64

func (*Context) GetSep20FromAddressCount added in v0.1.1 

func (c *Context) GetSep20FromAddressCount(contract common.Address, addr common.Address) int64

return the times addr acts as a from-address of a SEP20 Transfer event at some contract

func (*Context) GetSep20ToAddressCount added in v0.1.1 

func (c *Context) GetSep20ToAddressCount(contract common.Address, addr common.Address) int64

return the times addr acts as a to-address of a SEP20 Transfer event at some contract

func (*Context) GetStorageAt 

func (c *Context) GetStorageAt(seq uint64, key string) []byte

func (*Context) GetToAddressCount added in v0.1.1 

func (c *Context) GetToAddressCount(addr common.Address) int64

return the times addr acts as a to-address of a transaction

func (*Context) GetTxByBlkHtAndTxIndex 

func (c *Context) GetTxByBlkHtAndTxIndex(height uint64, index uint64) *Transaction

func (*Context) GetTxByHash 

func (c *Context) GetTxByHash(txHash common.Hash) (tx *Transaction, err error)

func (*Context) GetTxListByHeight 

func (c *Context) GetTxListByHeight(height uint32) (txs []*Transaction, err error)

func (*Context) GetTxListByHeightWithRange added in v0.2.0 

func (c *Context) GetTxListByHeightWithRange(height uint32, start, end int) (txs []*Transaction, err error)

func (*Context) IncrNonce 

func (c *Context) IncrNonce(sender common.Address, acc *AccountInfo)

func (*Context) QueryLogs 

func (c *Context) QueryLogs(addresses []common.Address, topics [][]common.Hash, startHeight, endHeight uint32, filter FilterFunc) (logs []Log, err error)

func (*Context) QueryTxByAddr 

func (c *Context) QueryTxByAddr(addr common.Address, startHeight, endHeight, limit uint32) (txs []*Transaction, err error)

func (*Context) QueryTxByDst 

func (c *Context) QueryTxByDst(addr common.Address, startHeight, endHeight, limit uint32) (txs []*Transaction, err error)

func (*Context) QueryTxBySrc 

func (c *Context) QueryTxBySrc(addr common.Address, startHeight, endHeight, limit uint32) (txs []*Transaction, err error)

func (*Context) SetAccount 

func (c *Context) SetAccount(address common.Address, acc *AccountInfo)

func (*Context) SetCode 

func (c *Context) SetCode(contract common.Address, code *BytecodeInfo)

func (*Context) SetCurrBlockBasicInfo 

func (c *Context) SetCurrBlockBasicInfo(blk *Block)

func (*Context) SetStorageAt 

func (c *Context) SetStorageAt(seq uint64, key string, val []byte)

func (*Context) StoreBlock 

func (c *Context) StoreBlock(blk *modbtypes.Block)

func (*Context) WithDb 

func (c *Context) WithDb(db modbtypes.DB) *Context

func (*Context) WithRbt 

func (c *Context) WithRbt(rabbitStore *rabbit.RabbitStore) *Context

func (*Context) WithRbtCopy 

func (c *Context) WithRbtCopy() *Context

new empty rbt with same parent store as the old one

type Description 

type Description struct {
	Moniker         string `json:"moniker" yaml:"moniker"`                   // name
	Identity        string `json:"identity" yaml:"identity"`                 // optional identity signature (ex. UPort or Keybase)
	Website         string `json:"website" yaml:"website"`                   // optional website link
	SecurityContact string `json:"security_contact" yaml:"security_contact"` // optional security contact info
	Details         string `json:"details" yaml:"details"`                   // optional details
}

Description - description fields for a validator

func NewDescription 

func NewDescription(moniker, identity, website, securityContact, details string) Description

NewDescription returns a new Description with the provided values.

type EvmLog 

type EvmLog struct {
	Address common.Address
	Topics  []common.Hash
	Data    []byte
}

type FilterFunc added in v0.2.0 

type FilterFunc func(addr common.Address, topics []common.Hash, addrList []common.Address, topicsList [][]common.Hash) (ok bool)
type Header struct {
	Number    uint64
	BlockHash gethcmn.Hash
	Bloom     gethcore.Bloom
}

func (*Header) Hash 

func (h *Header) Hash() gethcmn.Hash

type Log 

type Log struct {
	// Consensus fields:
	// address of the contract that generated the event
	Address [20]byte `msgp:"address"`
	// list of topics provided by the contract.
	Topics [][32]byte `msgp:"topics"`
	// supplied by the contract, usually ABI-encoded
	Data []byte `msgp:"data"`

	// Derived fields. These fields are filled in by the node
	// but not secured by consensus.
	// block in which the transaction was included
	BlockNumber uint64 `msgp:"blockNumber"`
	// hash of the transaction
	TxHash [32]byte `msgp:"transactionHash"`
	// index of the transaction in the block
	TxIndex uint `msgp:"transactionIndex"`
	// hash of the block in which the transaction was included
	BlockHash [32]byte `msgp:"blockHash"`
	// index of the log in the block
	Index uint `msgp:"logIndex"`

	// The Removed field is true if this log was reverted due to a chain reorganisation.
	// You must pay attention to this field if you receive logs through a filter query.
	Removed bool `msgp:"removed"`
}

func (*Log) DecodeMsg 

func (z *Log) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*Log) EncodeMsg 

func (z *Log) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*Log) MarshalMsg 

func (z *Log) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*Log) Msgsize 

func (z *Log) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*Log) UnmarshalMsg 

func (z *Log) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type SystemContractExecutor 

type SystemContractExecutor interface {
	vm.PrecompiledContract
	Init(ctx *Context)
	IsSystemContract(addr common.Address) bool
	Execute(context *Context, currBlock *BlockInfo, tx *TxToRun) (status int, logs []EvmLog, gasUsed uint64, outData []byte)
}

type Transaction 

type Transaction struct {
	Hash              [32]byte  `msg:"hash"`         //32 Bytes - hash of the transaction.
	TransactionIndex  int64     `msg:"index"`        //integer of the transactions index position in the block. null when its pending.
	Nonce             uint64    `msg:"nonce"`        //the number of transactions made by the sender prior to this one.
	BlockHash         [32]byte  `msg:"block"`        //32 Bytes - hash of the block where this transaction was in. null when its pending.
	BlockNumber       int64     `msg:"height"`       //block number where this transaction was in. null when its pending.
	From              [20]byte  `msg:"from"`         //20 Bytes - address of the sender.
	To                [20]byte  `msg:"to"`           //20 Bytes - address of the receiver. null when its a contract creation transaction.
	Value             [32]byte  `msg:"value"`        //value transferred in Wei.
	GasPrice          [32]byte  `msg:"gasprice"`     //gas price provided by the sender in Wei.
	Gas               uint64    `msg:"gas"`          //gas provided by the sender.
	Input             []byte    `msg:"input"`        //the data send along with the transaction.
	CumulativeGasUsed uint64    `msg:"cgasused"`     // the total amount of gas used when this transaction was executed in the block.
	GasUsed           uint64    `msg:"gasused"`      //the amount of gas used by this specific transaction alone.
	ContractAddress   [20]byte  `msg:"contractaddr"` //20 Bytes - the contract address created, if the transaction was a contract creation, otherwise - null.
	Logs              []Log     `msg:"logs"`         //Array - Array of log objects, which this transaction generated.
	LogsBloom         [256]byte `msg:"bloom"`        //256 Bytes - Bloom filter for light clients to quickly retrieve related logs.
	Status            uint64    `msg:"status"`       //tx execute result: ReceiptStatusFailed or ReceiptStatusSuccessful
	StatusStr         string    `msg:"statusstr"`    //tx execute result explained
	OutData           []byte    `msg:"outdata"`      //the output data from the transaction

}

TRANSACTION - A transaction object, or null when no transaction was found

func (*Transaction) DecodeMsg 

func (z *Transaction) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*Transaction) EncodeMsg 

func (z *Transaction) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*Transaction) MarshalMsg 

func (z *Transaction) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*Transaction) Msgsize 

func (z *Transaction) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*Transaction) UnmarshalMsg 

func (z *Transaction) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type TxToRun 

type TxToRun struct {
	BasicTx
	HashID common.Hash
	Height uint64
}

func (*TxToRun) FromBytes 

func (tx *TxToRun) FromBytes(bz []byte)

func (*TxToRun) FromGethTx 

func (tx *TxToRun) FromGethTx(gethTx *coretypes.Transaction, sender common.Address, height uint64)

func (TxToRun) ToBytes 

func (tx TxToRun) ToBytes() []byte

type ValAddress 

type ValAddress []byte

type Validator 

type Validator struct {
	OperatorAddress ValAddress    `json:"operator_address" yaml:"operator_address"` // address of the validator's operator; bech encoded in JSON
	ConsPubKey      crypto.PubKey `json:"consensus_pubkey" yaml:"consensus_pubkey"` // the consensus public key of the validator; bech encoded in JSON
	//Jailed                  bool           `json:"jailed" yaml:"jailed"`                           // has the validator been jailed from bonded status?
	Status      BondStatus  `json:"status" yaml:"status"`           // validator status (bonded/unbonded)
	Tokens      *big.Int    `json:"tokens" yaml:"tokens"`           // delegated tokens
	Description Description `json:"description" yaml:"description"` // description terms for the validator
}

func (Validator) MarshalJSON 

func (v Validator) MarshalJSON() ([]byte, error)

func (Validator) String 

func (v Validator) String() string

String returns a human readable string representation of a validator.

func (*Validator) UnmarshalJSON 

func (v *Validator) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshals the validator from JSON using Bech32

type Validators 

type Validators []Validator

Validators is a collection of Validator

func (Validators) Len 

func (v Validators) Len() int

Implements sort interface

func (Validators) Less 

func (v Validators) Less(i, j int) bool

Implements sort interface

func (Validators) Sort 

func (v Validators) Sort()

Sort Validators sorts validator array in ascending operator address order

func (Validators) String 

func (v Validators) String() (out string)

func (Validators) Swap 

func (v Validators) Swap(i, j int)

Implements sort interface

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.