Documentation ¶
Index ¶
- Constants
- Variables
- func FormatEthAddress(addr common.Address) string
- func GetEthAddress(privKey *crypto.PrivateKeySECP256K1R) common.Address
- func IsSortedAndUniqueEVMInputs(inputs []EVMInput) bool
- func IsSortedAndUniqueEVMOutputs(outputs []EVMOutput) bool
- func IsSortedEVMOutputs(outputs []EVMOutput) bool
- func NewAtomicTxRepository(db *versiondb.Database, codec codec.Manager, lastAcceptedHeight uint64) (*atomicTxRepository, error)
- func ParseEthAddress(addrStr string) (common.Address, error)
- func PublicKeyToEthAddress(pubKey *crypto.PublicKeySECP256K1R) common.Address
- func SortEVMInputsAndSigners(inputs []EVMInput, signers [][]*crypto.PrivateKeySECP256K1R)
- func SortEVMOutputs(outputs []EVMOutput)
- type Admin
- func (p *Admin) LockProfile(r *http.Request, args *struct{}, reply *api.SuccessResponse) error
- func (p *Admin) MemoryProfile(r *http.Request, args *struct{}, reply *api.SuccessResponse) error
- func (p *Admin) SetLogLevel(r *http.Request, args *SetLogLevelArgs, reply *api.SuccessResponse) error
- func (p *Admin) StartCPUProfiler(r *http.Request, args *struct{}, reply *api.SuccessResponse) error
- func (p *Admin) StopCPUProfiler(r *http.Request, args *struct{}, reply *api.SuccessResponse) error
- type AtomicTrie
- type AtomicTrieIterator
- type AtomicTxRepository
- type Batch
- type Block
- func (b *Block) Accept() error
- func (b *Block) Bytes() []byte
- func (b *Block) Height() uint64
- func (b *Block) ID() ids.ID
- func (b *Block) Parent() ids.ID
- func (b *Block) Reject() error
- func (b *Block) SetStatus(status choices.Status)
- func (b *Block) Status() choices.Status
- func (b *Block) String() string
- func (b *Block) Timestamp() time.Time
- func (b *Block) Verify() error
- type BlockValidator
- type BuildGenesisReply
- type Client
- type Config
- type Database
- type DjtxAPI
- func (service *DjtxAPI) Export(_ *http.Request, args *ExportArgs, response *api.JSONTxID) error
- func (service *DjtxAPI) ExportDJTX(_ *http.Request, args *ExportDJTXArgs, response *api.JSONTxID) error
- func (service *DjtxAPI) ExportKey(r *http.Request, args *ExportKeyArgs, reply *ExportKeyReply) error
- func (service *DjtxAPI) GetAtomicTx(r *http.Request, args *api.GetTxArgs, reply *FormattedTx) error
- func (service *DjtxAPI) GetAtomicTxStatus(r *http.Request, args *api.JSONTxID, reply *GetAtomicTxStatusReply) error
- func (service *DjtxAPI) GetUTXOs(r *http.Request, args *api.GetUTXOsArgs, reply *api.GetUTXOsReply) error
- func (service *DjtxAPI) Import(_ *http.Request, args *ImportArgs, response *api.JSONTxID) error
- func (service *DjtxAPI) ImportDJTX(_ *http.Request, args *ImportArgs, response *api.JSONTxID) error
- func (service *DjtxAPI) ImportKey(r *http.Request, args *ImportKeyArgs, reply *api.JSONAddress) error
- func (service *DjtxAPI) IssueTx(r *http.Request, args *api.FormattedTx, response *api.JSONTxID) error
- func (service *DjtxAPI) Version(r *http.Request, args *struct{}, reply *VersionReply) error
- type Duration
- type EVMInput
- type EVMOutput
- type ExportArgs
- type ExportDJTXArgs
- type ExportKeyArgs
- type ExportKeyReply
- type Factory
- type FormattedTx
- type GetAcceptedFrontReply
- type GetAtomicTxStatusReply
- type GossipHandler
- type Gossiper
- type ImportArgs
- type ImportKeyArgs
- type Mempool
- func (m *Mempool) AddTx(tx *Tx) error
- func (m *Mempool) CancelCurrentTx(txID ids.ID)
- func (m *Mempool) CancelCurrentTxs()
- func (m *Mempool) DiscardCurrentTx(txID ids.ID)
- func (m *Mempool) DiscardCurrentTxs()
- func (m *Mempool) ForceAddTx(tx *Tx) error
- func (m *Mempool) GetNewTxs() []*Tx
- func (m *Mempool) GetPendingTx(txID ids.ID) (*Tx, bool)
- func (m *Mempool) GetTx(txID ids.ID) (*Tx, bool, bool)
- func (m *Mempool) IssueCurrentTxs()
- func (m *Mempool) Len() int
- func (m *Mempool) NextTx() (*Tx, bool)
- func (m *Mempool) RemoveTx(txID ids.ID)
- type SetLogLevelArgs
- type SnowmanAPI
- type StaticService
- type Status
- type TestTx
- func (t *TestTx) AtomicOps() (ids.ID, *atomic.Requests, error)
- func (t *TestTx) Burned(assetID ids.ID) (uint64, error)
- func (t *TestTx) Bytes() []byte
- func (t *TestTx) EVMStateTransfer(ctx *snow.Context, state *state.StateDB) error
- func (t *TestTx) GasUsed(fixedFee bool) (uint64, error)
- func (t *TestTx) ID() ids.ID
- func (t *TestTx) Initialize(unsignedBytes, signedBytes []byte)
- func (t *TestTx) InputUTXOs() ids.Set
- func (t *TestTx) SemanticVerify(vm *VM, stx *Tx, parent *Block, baseFee *big.Int, rules params.Rules) error
- func (t *TestTx) UnsignedBytes() []byte
- func (t *TestTx) Verify(ctx *snow.Context, rules params.Rules) error
- type Tx
- type UnsignedAtomicTx
- type UnsignedExportTx
- func (tx *UnsignedExportTx) AtomicOps() (ids.ID, *atomic.Requests, error)
- func (tx *UnsignedExportTx) Burned(assetID ids.ID) (uint64, error)
- func (tx *UnsignedExportTx) EVMStateTransfer(ctx *snow.Context, state *state.StateDB) error
- func (tx *UnsignedExportTx) GasUsed(fixedFee bool) (uint64, error)
- func (tx *UnsignedExportTx) InputUTXOs() ids.Set
- func (tx *UnsignedExportTx) SemanticVerify(vm *VM, stx *Tx, _ *Block, baseFee *big.Int, rules params.Rules) error
- func (tx *UnsignedExportTx) Verify(ctx *snow.Context, rules params.Rules) error
- type UnsignedImportTx
- func (tx *UnsignedImportTx) AtomicOps() (ids.ID, *atomic.Requests, error)
- func (tx *UnsignedImportTx) Burned(assetID ids.ID) (uint64, error)
- func (tx *UnsignedImportTx) EVMStateTransfer(ctx *snow.Context, state *state.StateDB) error
- func (tx *UnsignedImportTx) GasUsed(fixedFee bool) (uint64, error)
- func (tx *UnsignedImportTx) InputUTXOs() ids.Set
- func (tx *UnsignedImportTx) SemanticVerify(vm *VM, stx *Tx, parent *Block, baseFee *big.Int, rules params.Rules) error
- func (tx *UnsignedImportTx) Verify(ctx *snow.Context, rules params.Rules) error
- type UnsignedTx
- type VM
- func (vm *VM) Clock() *mockable.Clock
- func (vm *VM) Codec() codec.Manager
- func (vm *VM) CodecRegistry() codec.Registry
- func (vm *VM) CreateHandlers() (map[string]*commonEng.HTTPHandler, error)
- func (vm *VM) CreateStaticHandlers() (map[string]*commonEng.HTTPHandler, error)
- func (vm *VM) FormatAddress(chainID ids.ID, addr ids.ShortID) (string, error)
- func (vm *VM) FormatLocalAddress(addr ids.ShortID) (string, error)
- func (vm *VM) GetActivationTime() time.Time
- func (vm *VM) GetAtomicUTXOs(chainID ids.ID, addrs ids.ShortSet, startAddr ids.ShortID, startUTXOID ids.ID, ...) ([]*djtx.UTXO, ids.ShortID, ids.ID, error)
- func (vm *VM) GetBlockIDAtHeight(blkHeight uint64) (ids.ID, error)
- func (vm *VM) GetCurrentNonce(address common.Address) (uint64, error)
- func (vm *VM) GetSpendableDJTXWithFee(keys []*crypto.PrivateKeySECP256K1R, amount uint64, cost uint64, ...) ([]EVMInput, [][]*crypto.PrivateKeySECP256K1R, error)
- func (vm *VM) GetSpendableFunds(keys []*crypto.PrivateKeySECP256K1R, assetID ids.ID, amount uint64) ([]EVMInput, [][]*crypto.PrivateKeySECP256K1R, error)
- func (vm *VM) HealthCheck() (interface{}, error)
- func (vm *VM) Initialize(ctx *snow.Context, dbManager manager.Manager, genesisBytes []byte, ...) error
- func (vm *VM) Logger() logging.Logger
- func (vm *VM) NewBlockBuilder(notifyBuildBlockChan chan<- commonEng.Message) *blockBuilder
- func (vm *VM) ParseAddress(addrStr string) (ids.ID, ids.ShortID, error)
- func (vm *VM) ParseLocalAddress(addrStr string) (ids.ShortID, error)
- func (vm *VM) SetPreference(blkID ids.ID) error
- func (vm *VM) SetState(state snow.State) error
- func (vm *VM) Shutdown() error
- func (vm *VM) VerifyHeightIndex() error
- func (vm *VM) Version() (string, error)
- type VersionReply
Constants ¶
const ( GenesisTestAddr = "0x751a0b96e1042bee789452ecb20253fba40dbe85" GenesisTestKey = "0xabd71b35d559563fea757f0f5edbde286fb8c043105b15abb7cd57189306d7d1" )
test constants
Variables ¶
var ( TxBytesGas uint64 = 1 EVMOutputGas uint64 = (common.AddressLength + wrappers.LongLen + hashing.HashLen) * TxBytesGas EVMInputGas uint64 = (common.AddressLength+wrappers.LongLen+hashing.HashLen+wrappers.LongLen)*TxBytesGas + secp256k1fx.CostPerSignature )
Constants for calculating the gas consumed by atomic transactions
var ( // GitCommit is set by the build script GitCommit string // Version is the version of Coreth Version string = "v0.8.7" )
var Codec codec.Manager
Codec does serialization and deserialization
var ( // ID this VM should be referenced by ID = ids.ID{'e', 'v', 'm'} )
Functions ¶
func FormatEthAddress ¶ added in v0.1.2
FormatEthAddress formats [addr] into a string
func GetEthAddress ¶ added in v0.1.2
func GetEthAddress(privKey *crypto.PrivateKeySECP256K1R) common.Address
GetEthAddress returns the ethereum address derived from [privKey]
func IsSortedAndUniqueEVMInputs ¶ added in v0.1.2
IsSortedAndUniqueEVMInputs returns true if the EVM Inputs are sorted and unique based on the account addresses
func IsSortedAndUniqueEVMOutputs ¶ added in v0.1.2
IsSortedAndUniqueEVMOutputs returns true if the EVMOutputs are sorted and unique based on the account addresses and assetIDs
func IsSortedEVMOutputs ¶ added in v0.1.2
IsSortedEVMOutputs returns true if the EVMOutputs are sorted based on the account addresses and assetIDs
func NewAtomicTxRepository ¶ added in v0.6.7
func ParseEthAddress ¶ added in v0.1.2
ParseEthAddress parses [addrStr] and returns an Ethereum address
func PublicKeyToEthAddress ¶ added in v0.1.2
func PublicKeyToEthAddress(pubKey *crypto.PublicKeySECP256K1R) common.Address
PublicKeyToEthAddress returns the ethereum address derived from [pubKey]
func SortEVMInputsAndSigners ¶ added in v0.1.2
func SortEVMInputsAndSigners(inputs []EVMInput, signers [][]*crypto.PrivateKeySECP256K1R)
SortEVMInputsAndSigners sorts the list of EVMInputs based on the addresses and assetIDs
func SortEVMOutputs ¶ added in v0.1.2
func SortEVMOutputs(outputs []EVMOutput)
SortEVMOutputs sorts the list of EVMOutputs based on the addresses and assetIDs of the outputs
Types ¶
type Admin ¶ added in v0.6.7
type Admin struct {
// contains filtered or unexported fields
}
Admin is the API service for admin API calls
func NewAdminService ¶ added in v0.6.7
func (*Admin) LockProfile ¶ added in v0.6.7
LockProfile runs a mutex profile writing to the specified file
func (*Admin) MemoryProfile ¶ added in v0.6.7
MemoryProfile runs a memory profile writing to the specified file
func (*Admin) SetLogLevel ¶ added in v0.6.7
func (p *Admin) SetLogLevel(r *http.Request, args *SetLogLevelArgs, reply *api.SuccessResponse) error
func (*Admin) StartCPUProfiler ¶ added in v0.6.7
StartCPUProfiler starts a cpu profile writing to the specified file
func (*Admin) StopCPUProfiler ¶ added in v0.6.7
StopCPUProfiler stops the cpu profile
type AtomicTrie ¶ added in v0.6.7
type AtomicTrie interface { // Index indexes the given atomicOps at the specified block height // Atomic trie is committed if the block height is multiple of commit interval Index(height uint64, atomicOps map[ids.ID]*atomic.Requests) error // Iterator returns an AtomicTrieIterator to iterate the trie at the given // root hash starting at [cursor]. Iterator(hash common.Hash, cursor []byte) (AtomicTrieIterator, error) // LastCommitted returns the last committed hash and corresponding block height LastCommitted() (common.Hash, uint64) // UpdateLastCommitted sets the state to last committed hash and height // This function is used by statesync.Syncer to set the atomic trie metadata // as it is not synced as part of the atomic trie. UpdateLastCommitted(hash common.Hash, height uint64) error // TrieDB returns the underlying trie database TrieDB() *trie.Database // Root returns hash if it exists at specified height // if trie was not committed at provided height, it returns // common.Hash{} instead Root(height uint64) (common.Hash, error) // but not yet applied to shared memory for heights less than or equal to [lastAcceptedBlock]. // This executes operations in the range [cursorHeight+1, lastAcceptedBlock]. // The cursor is initially set by MarkApplyToSharedMemoryCursor to signal to the atomic trie // the range of operations that were added to the trie without being executed on shared memory. ApplyToSharedMemory(lastAcceptedBlock uint64) error // have not been executed on shared memory starting at [previousLastAcceptedHeight+1]. // This is used when state sync syncs the atomic trie, such that the atomic operations // from [previousLastAcceptedHeight+1] to the [lastAcceptedHeight] set by state sync // will not have been executed on shared memory. MarkApplyToSharedMemoryCursor(previousLastAcceptedHeight uint64) error }
AtomicTrie maintains an index of atomic operations by blockchainIDs for every block height containing atomic transactions. The backing data structure for this index is a Trie. The keys of the trie are block heights and the values (leaf nodes) are the atomic operations applied to shared memory while processing the block accepted at the corresponding height.
func NewAtomicTrie ¶ added in v0.6.7
func NewAtomicTrie( db *versiondb.Database, sharedMemory atomic.SharedMemory, bonusBlocks map[uint64]ids.ID, repo AtomicTxRepository, codec codec.Manager, lastAcceptedHeight uint64, ) (AtomicTrie, error)
NewAtomicTrie returns a new instance of a atomicTrie with the default commitHeightInterval. Initializes the trie before returning it. If the cursor set by MarkApplyToSharedMemoryCursor exists, the atomic operations are applied synchronously during initialization (blocks until ApplyToSharedMemory completes).
type AtomicTrieIterator ¶ added in v0.6.7
type AtomicTrieIterator interface { // Next advances the iterator to the next node in the atomic trie and // returns true if there are more nodes to iterate Next() bool // Key returns the current database key that the iterator is iterating // returned []byte can be freely modified Key() []byte // BlockNumber returns the current block number BlockNumber() uint64 // BlockchainID returns the current blockchain ID at the current block number BlockchainID() ids.ID // AtomicOps returns a map of blockchainIDs to the set of atomic requests // for that blockchainID at the current block number AtomicOps() *atomic.Requests // Error returns error, if any encountered during this iteration Error() error }
AtomicTrieIterator is a stateful iterator that iterates the leafs of an AtomicTrie
func NewAtomicTrieIterator ¶ added in v0.6.7
func NewAtomicTrieIterator(trieIterator *trie.Iterator, codec codec.Manager) AtomicTrieIterator
type AtomicTxRepository ¶ added in v0.6.7
type AtomicTxRepository interface { GetIndexHeight() (uint64, error) GetByTxID(txID ids.ID) (*Tx, uint64, error) GetByHeight(height uint64) ([]*Tx, error) Write(height uint64, txs []*Tx) error WriteBonus(height uint64, txs []*Tx) error IterateByHeight([]byte) database.Iterator IsBonusBlocksRepaired() (bool, error) MarkBonusBlocksRepaired(repairedEntries uint64) error }
AtomicTxRepository defines an entity that manages storage and indexing of atomic transactions
type Batch ¶
Batch implements ethdb.Batch
type Block ¶
type Block struct {
// contains filtered or unexported fields
}
Block implements the snowman.Block interface
func (*Block) Reject ¶
Reject implements the snowman.Block interface If [b] contains an atomic transaction, attempt to re-issue it
func (*Block) SetStatus ¶ added in v0.1.2
SetStatus implements the InternalBlock interface allowing ChainState to set the status on an existing block
type BlockValidator ¶ added in v0.1.2
type BuildGenesisReply ¶ added in v0.1.2
type BuildGenesisReply struct { Bytes string `json:"bytes"` Encoding formatting.Encoding `json:"encoding"` }
BuildGenesisReply is the reply from BuildGenesis
type Client ¶ added in v0.1.2
type Client interface { IssueTx(ctx context.Context, txBytes []byte) (ids.ID, error) GetAtomicTxStatus(ctx context.Context, txID ids.ID) (Status, error) GetAtomicTx(ctx context.Context, txID ids.ID) ([]byte, error) GetAtomicUTXOs(ctx context.Context, addrs []string, sourceChain string, limit uint32, startAddress, startUTXOID string) ([][]byte, api.Index, error) ListAddresses(ctx context.Context, userPass api.UserPass) ([]string, error) ExportKey(ctx context.Context, userPass api.UserPass, addr string) (string, string, error) ImportKey(ctx context.Context, userPass api.UserPass, privateKey string) (string, error) Import(ctx context.Context, userPass api.UserPass, to string, sourceChain string) (ids.ID, error) ExportDJTX(ctx context.Context, userPass api.UserPass, amount uint64, to string) (ids.ID, error) Export(ctx context.Context, userPass api.UserPass, amount uint64, to string, assetID string) (ids.ID, error) StartCPUProfiler(ctx context.Context) (bool, error) StopCPUProfiler(ctx context.Context) (bool, error) MemoryProfile(ctx context.Context) (bool, error) LockProfile(ctx context.Context) (bool, error) SetLogLevel(ctx context.Context, level log.Lvl) (bool, error) }
Client interface for interacting with EVM chain
func NewCChainClient ¶ added in v0.1.2
NewCChainClient returns a Client for interacting with the C Chain
type Config ¶ added in v0.1.2
type Config struct { // Coreth APIs SnowmanAPIEnabled bool `json:"snowman-api-enabled"` CorethAdminAPIEnabled bool `json:"coreth-admin-api-enabled"` CorethAdminAPIDir string `json:"coreth-admin-api-dir"` // EnabledEthAPIs is a list of Ethereum services that should be enabled // If none is specified, then we use the default list [defaultEnabledAPIs] EnabledEthAPIs []string `json:"eth-apis"` // Continuous Profiler ContinuousProfilerDir string `json:"continuous-profiler-dir"` // If set to non-empty string creates a continuous profiler ContinuousProfilerFrequency Duration `json:"continuous-profiler-frequency"` // Frequency to run continuous profiler if enabled ContinuousProfilerMaxFiles int `json:"continuous-profiler-max-files"` // Maximum number of files to maintain // Coreth API Gas/Price Caps RPCGasCap uint64 `json:"rpc-gas-cap"` RPCTxFeeCap float64 `json:"rpc-tx-fee-cap"` // Eth Settings Preimages bool `json:"preimages-enabled"` SnapshotAsync bool `json:"snapshot-async"` SnapshotVerify bool `json:"snapshot-verification-enabled"` // Pruning Settings Pruning bool `json:"pruning-enabled"` // If enabled, trie roots are only persisted every 4096 blocks AllowMissingTries bool `json:"allow-missing-tries"` // If enabled, warnings preventing an incomplete trie index are suppressed PopulateMissingTries *uint64 `json:"populate-missing-tries,omitempty"` // Sets the starting point for re-populating missing tries. Disables re-generation if nil. // Metric Settings MetricsEnabled bool `json:"metrics-enabled"` MetricsExpensiveEnabled bool `json:"metrics-expensive-enabled"` // API Settings LocalTxsEnabled bool `json:"local-txs-enabled"` APIMaxDuration Duration `json:"api-max-duration"` WSCPURefillRate Duration `json:"ws-cpu-refill-rate"` WSCPUMaxStored Duration `json:"ws-cpu-max-stored"` MaxBlocksPerRequest int64 `json:"api-max-blocks-per-request"` AllowUnfinalizedQueries bool `json:"allow-unfinalized-queries"` AllowUnprotectedTxs bool `json:"allow-unprotected-txs"` // Keystore Settings KeystoreDirectory string `json:"keystore-directory"` // both absolute and relative supported KeystoreExternalSigner string `json:"keystore-external-signer"` KeystoreInsecureUnlockAllowed bool `json:"keystore-insecure-unlock-allowed"` // Gossip Settings RemoteTxGossipOnlyEnabled bool `json:"remote-tx-gossip-only-enabled"` TxRegossipFrequency Duration `json:"tx-regossip-frequency"` TxRegossipMaxSize int `json:"tx-regossip-max-size"` // Log level LogLevel string `json:"log-level"` // Offline Pruning Settings OfflinePruning bool `json:"offline-pruning-enabled"` OfflinePruningBloomFilterSize uint64 `json:"offline-pruning-bloom-filter-size"` OfflinePruningDataDirectory string `json:"offline-pruning-data-directory"` // VM2VM network MaxOutboundActiveRequests int64 `json:"max-outbound-active-requests"` }
Config ...
func (Config) EthAPIs ¶ added in v0.1.2
EthAPIs returns an array of strings representing the Eth APIs that should be enabled
func (Config) EthBackendSettings ¶ added in v0.1.2
func (*Config) SetDefaults ¶ added in v0.1.2
func (c *Config) SetDefaults()
type Database ¶
Database implements ethdb.Database
func (Database) NewIterator ¶
NewIterator implements ethdb.Database
Note: This method assumes that the prefix is NOT part of the start, so there's no need for the caller to prepend the prefix to the start.
type DjtxAPI ¶ added in v0.1.2
type DjtxAPI struct {
// contains filtered or unexported fields
}
DjtxAPI offers Avalanche network related API methods
func (*DjtxAPI) Export ¶ added in v0.1.2
Export exports an asset from the C-Chain to the X-Chain It must be imported on the X-Chain to complete the transfer
func (*DjtxAPI) ExportDJTX ¶ added in v0.1.2
func (service *DjtxAPI) ExportDJTX(_ *http.Request, args *ExportDJTXArgs, response *api.JSONTxID) error
ExportDJTX exports DJTX from the C-Chain to the X-Chain It must be imported on the X-Chain to complete the transfer
func (*DjtxAPI) ExportKey ¶ added in v0.1.2
func (service *DjtxAPI) ExportKey(r *http.Request, args *ExportKeyArgs, reply *ExportKeyReply) error
ExportKey returns a private key from the provided user
func (*DjtxAPI) GetAtomicTx ¶ added in v0.1.2
GetAtomicTx returns the specified transaction
func (*DjtxAPI) GetAtomicTxStatus ¶ added in v0.1.2
func (service *DjtxAPI) GetAtomicTxStatus(r *http.Request, args *api.JSONTxID, reply *GetAtomicTxStatusReply) error
GetAtomicTxStatus returns the status of the specified transaction
func (*DjtxAPI) GetUTXOs ¶ added in v0.1.2
func (service *DjtxAPI) GetUTXOs(r *http.Request, args *api.GetUTXOsArgs, reply *api.GetUTXOsReply) error
GetUTXOs gets all utxos for passed in addresses
func (*DjtxAPI) Import ¶ added in v0.1.2
Import issues a transaction to import DJTX from the X-chain. The DJTX must have already been exported from the X-Chain.
func (*DjtxAPI) ImportDJTX ¶ added in v0.1.2
ImportDJTX is a deprecated name for Import.
func (*DjtxAPI) ImportKey ¶ added in v0.1.2
func (service *DjtxAPI) ImportKey(r *http.Request, args *ImportKeyArgs, reply *api.JSONAddress) error
ImportKey adds a private key to the provided user
type Duration ¶ added in v0.1.2
func (*Duration) UnmarshalJSON ¶ added in v0.1.2
type EVMInput ¶ added in v0.1.2
type EVMInput struct { Address common.Address `serialize:"true" json:"address"` Amount uint64 `serialize:"true" json:"amount"` AssetID ids.ID `serialize:"true" json:"assetID"` Nonce uint64 `serialize:"true" json:"nonce"` }
EVMInput defines an input created from the EVM state to fund export transactions
type EVMOutput ¶ added in v0.1.2
type EVMOutput struct { Address common.Address `serialize:"true" json:"address"` Amount uint64 `serialize:"true" json:"amount"` AssetID ids.ID `serialize:"true" json:"assetID"` }
EVMOutput defines an output that is added to the EVM state created by import transactions
type ExportArgs ¶ added in v0.1.2
type ExportArgs struct { ExportDJTXArgs // AssetID of the tokens AssetID string `json:"assetID"` }
ExportArgs are the arguments to Export
type ExportDJTXArgs ¶ added in v0.1.2
type ExportDJTXArgs struct { api.UserPass // Fee that should be used when creating the tx BaseFee *hexutil.Big `json:"baseFee"` // Amount of asset to send Amount json.Uint64 `json:"amount"` // ID of the address that will receive the DJTX. This address includes the // chainID, which is used to determine what the destination chain is. To string `json:"to"` }
ExportDJTXArgs are the arguments to ExportDJTX
type ExportKeyArgs ¶ added in v0.1.2
ExportKeyArgs are arguments for ExportKey
type ExportKeyReply ¶ added in v0.1.2
type ExportKeyReply struct { // The decrypted PrivateKey for the Address provided in the arguments PrivateKey string `json:"privateKey"` PrivateKeyHex string `json:"privateKeyHex"` }
ExportKeyReply is the response for ExportKey
type FormattedTx ¶ added in v0.1.2
type FormattedTx struct { api.FormattedTx BlockHeight *json.Uint64 `json:"blockHeight,omitempty"` }
type GetAcceptedFrontReply ¶
type GetAcceptedFrontReply struct { Hash common.Hash `json:"hash"` Number *big.Int `json:"number"` }
GetAcceptedFrontReply defines the reply that will be sent from the GetAcceptedFront API call
type GetAtomicTxStatusReply ¶ added in v0.1.2
type GetAtomicTxStatusReply struct { Status Status `json:"status"` BlockHeight *json.Uint64 `json:"blockHeight,omitempty"` }
GetAtomicTxStatusReply defines the GetAtomicTxStatus replies returned from the API
type GossipHandler ¶ added in v0.6.7
type GossipHandler struct {
// contains filtered or unexported fields
}
GossipHandler handles incoming gossip messages
func NewGossipHandler ¶ added in v0.6.7
func NewGossipHandler(vm *VM) *GossipHandler
func (*GossipHandler) HandleAtomicTx ¶ added in v0.6.7
func (h *GossipHandler) HandleAtomicTx(nodeID ids.ShortID, msg message.AtomicTxGossip) error
func (*GossipHandler) HandleEthTxs ¶ added in v0.6.7
func (h *GossipHandler) HandleEthTxs(nodeID ids.ShortID, msg message.EthTxsGossip) error
type Gossiper ¶ added in v0.6.7
type Gossiper interface { // GossipAtomicTxs sends AppGossip message containing the given [txs] GossipAtomicTxs(txs []*Tx) error // GossipEthTxs sends AppGossip message containing the given [txs] GossipEthTxs(txs []*types.Transaction) error }
Gossiper handles outgoing gossip of transactions
type ImportArgs ¶ added in v0.1.2
type ImportArgs struct { api.UserPass // Fee that should be used when creating the tx BaseFee *hexutil.Big `json:"baseFee"` // Chain the funds are coming from SourceChain string `json:"sourceChain"` // The address that will receive the imported funds To string `json:"to"` }
ImportArgs are arguments for passing into Import requests
type ImportKeyArgs ¶ added in v0.1.2
ImportKeyArgs are arguments for ImportKey
type Mempool ¶ added in v0.1.2
type Mempool struct { // DJTXAssetID is the fee paying currency of any atomic transaction DJTXAssetID ids.ID // Pending is a channel of length one, which the mempool ensures has an item on // it as long as there is an unissued transaction remaining in [txs] Pending chan struct{} // contains filtered or unexported fields }
Mempool is a simple mempool for atomic transactions
func NewMempool ¶ added in v0.1.2
NewMempool returns a Mempool with [maxSize]
func (*Mempool) AddTx ¶ added in v0.1.2
Add attempts to add [tx] to the mempool and returns an error if it could not be addeed to the mempool.
func (*Mempool) CancelCurrentTx ¶ added in v0.1.2
CancelCurrentTx marks the attempt to issue [txID] as being aborted. This should be called after NextTx returns [txID] and the transaction [txID] cannot be included in the block, but should not be discarded. For example, CancelCurrentTx should be called if including the transaction will put the block above the atomic tx gas limit.
func (*Mempool) CancelCurrentTxs ¶ added in v0.6.7
func (m *Mempool) CancelCurrentTxs()
[CancelCurrentTxs] marks the attempt to issue [currentTxs] as being aborted. If this is called after a buildBlock error caused by the atomic transaction, then DiscardCurrentTx should have been called such that this call will have no effect and should not re-issue the invalid tx.
func (*Mempool) DiscardCurrentTx ¶ added in v0.1.2
DiscardCurrentTx marks a [tx] in the [currentTxs] map as invalid and aborts the attempt to issue it since it failed verification.
func (*Mempool) DiscardCurrentTxs ¶ added in v0.6.7
func (m *Mempool) DiscardCurrentTxs()
DiscardCurrentTxs marks all txs in [currentTxs] as discarded.
func (*Mempool) ForceAddTx ¶ added in v0.6.7
forceAddTx forcibly adds a *Tx to the mempool and bypasses all verification.
func (*Mempool) GetNewTxs ¶ added in v0.6.7
GetNewTxs returns the array of [newTxs] and replaces it with a new array.
func (*Mempool) GetPendingTx ¶ added in v0.6.7
GetPendingTx returns the transaction [txID] and true if it is currently in the [txHeap] waiting to be issued into a block. Returns nil, false otherwise.
func (*Mempool) GetTx ¶ added in v0.1.2
GetTx returns the transaction [txID] if it was issued by this node and returns whether it was dropped and whether it exists.
func (*Mempool) IssueCurrentTxs ¶ added in v0.6.7
func (m *Mempool) IssueCurrentTxs()
IssueCurrentTx marks [currentTx] as issued if there is one
type SetLogLevelArgs ¶ added in v0.6.7
type SetLogLevelArgs struct {
Level string `json:"level"`
}
type SnowmanAPI ¶
type SnowmanAPI struct {
// contains filtered or unexported fields
}
SnowmanAPI introduces snowman specific functionality to the evm
func (*SnowmanAPI) GetAcceptedFront ¶
func (api *SnowmanAPI) GetAcceptedFront(ctx context.Context) (*GetAcceptedFrontReply, error)
GetAcceptedFront returns the last accepted block's hash and height
func (*SnowmanAPI) IssueBlock ¶ added in v0.1.2
func (api *SnowmanAPI) IssueBlock(ctx context.Context) error
IssueBlock to the chain
type StaticService ¶
type StaticService struct{}
StaticService defines the static API services exposed by the evm
func (*StaticService) BuildGenesis ¶
func (*StaticService) BuildGenesis(_ context.Context, args *core.Genesis) (*BuildGenesisReply, error)
BuildGenesis returns the UTXOs such that at least one address in [args.Addresses] is referenced in the UTXO.
type Status ¶ added in v0.1.2
type Status uint32
Status ...
List of possible status values Unknown Zero value, means the status is not known Dropped means the transaction was in the mempool, but was dropped because it failed verification Processing means the transaction is in the mempool Accepted means the transaction was accepted
func (Status) MarshalJSON ¶ added in v0.1.2
MarshalJSON ...
func (*Status) UnmarshalJSON ¶ added in v0.1.2
UnmarshalJSON ...
type TestTx ¶ added in v0.6.7
type TestTx struct { GasUsedV uint64 `serialize:"true"` AcceptRequestsBlockchainIDV ids.ID `serialize:"true"` AcceptRequestsV *atomic.Requests `serialize:"true"` VerifyV error IDV ids.ID `serialize:"true" json:"id"` BurnedV uint64 `serialize:"true"` UnsignedBytesV []byte BytesV []byte InputUTXOsV ids.Set SemanticVerifyV error EVMStateTransferV error }
func (*TestTx) EVMStateTransfer ¶ added in v0.6.7
EVMStateTransfer implements the UnsignedAtomicTx interface
func (*TestTx) Initialize ¶ added in v0.6.7
Initialize implements the UnsignedAtomicTx interface
func (*TestTx) InputUTXOs ¶ added in v0.6.7
InputUTXOs implements the UnsignedAtomicTx interface
func (*TestTx) SemanticVerify ¶ added in v0.6.7
func (t *TestTx) SemanticVerify(vm *VM, stx *Tx, parent *Block, baseFee *big.Int, rules params.Rules) error
SemanticVerify implements the UnsignedAtomicTx interface
func (*TestTx) UnsignedBytes ¶ added in v0.6.7
UnsignedBytes implements the UnsignedAtomicTx interface
type Tx ¶ added in v0.1.2
type Tx struct { // The body of this transaction UnsignedAtomicTx `serialize:"true" json:"unsignedTx"` // The credentials of this transaction Creds []verify.Verifiable `serialize:"true" json:"credentials"` }
Tx is a signed transaction
func ExtractAtomicTx ¶ added in v0.6.7
ExtractAtomicTx extracts a singular atomic transaction from [atomicTxBytes] and returns a slice of atomic transactions for compatibility with the type returned post ApricotPhase5. Note: this function assumes [atomicTxBytes] is non-empty.
func ExtractAtomicTxs ¶ added in v0.6.7
extractAtomicTxs returns the atomic transactions in [atomicTxBytes] if they exist. if [batch] is true, it attempts to unmarshal [atomicTxBytes] as a slice of transactions (post-ApricotPhase5), and if it is false, then it unmarshals it as a single atomic transaction.
func ExtractAtomicTxsBatch ¶ added in v0.6.7
ExtractAtomicTxsBatch extracts a slice of atomic transactions from [atomicTxBytes]. Note: this function assumes [atomicTxBytes] is non-empty.
func (*Tx) BlockFeeContribution ¶ added in v0.6.7
func (tx *Tx) BlockFeeContribution(fixedFee bool, djtxAssetID ids.ID, baseFee *big.Int) (*big.Int, *big.Int, error)
BlockFeeContribution calculates how much DJTX towards the block fee contribution was paid for via this transaction denominated in [djtxAssetID] with [baseFee] used to calculate the cost of this transaction. This function also returns the [gasUsed] by the transaction for inclusion in the [baseFee] algorithm.
type UnsignedAtomicTx ¶ added in v0.1.2
type UnsignedAtomicTx interface { UnsignedTx // InputUTXOs returns the UTXOs this tx consumes InputUTXOs() ids.Set // Verify attempts to verify that the transaction is well formed Verify(ctx *snow.Context, rules params.Rules) error // Attempts to verify this transaction with the provided state. SemanticVerify(vm *VM, stx *Tx, parent *Block, baseFee *big.Int, rules params.Rules) error // AtomicOps returns the blockchainID and set of atomic requests that // must be applied to shared memory for this transaction to be accepted. // The set of atomic requests must be returned in a consistent order. AtomicOps() (ids.ID, *atomic.Requests, error) EVMStateTransfer(ctx *snow.Context, state *state.StateDB) error }
UnsignedAtomicTx is an unsigned operation that can be atomically accepted
type UnsignedExportTx ¶ added in v0.1.2
type UnsignedExportTx struct { djtx.Metadata // ID of the network on which this tx was issued NetworkID uint32 `serialize:"true" json:"networkID"` // ID of this blockchain. BlockchainID ids.ID `serialize:"true" json:"blockchainID"` // Which chain to send the funds to DestinationChain ids.ID `serialize:"true" json:"destinationChain"` // Inputs Ins []EVMInput `serialize:"true" json:"inputs"` // Outputs that are exported to the chain ExportedOutputs []*djtx.TransferableOutput `serialize:"true" json:"exportedOutputs"` }
UnsignedExportTx is an unsigned ExportTx
func (*UnsignedExportTx) AtomicOps ¶ added in v0.6.7
AtomicOps returns the atomic operations for this transaction.
func (*UnsignedExportTx) Burned ¶ added in v0.6.7
func (tx *UnsignedExportTx) Burned(assetID ids.ID) (uint64, error)
Amount of [assetID] burned by this transaction
func (*UnsignedExportTx) EVMStateTransfer ¶ added in v0.1.2
EVMStateTransfer executes the state update from the atomic export transaction
func (*UnsignedExportTx) GasUsed ¶ added in v0.6.7
func (tx *UnsignedExportTx) GasUsed(fixedFee bool) (uint64, error)
func (*UnsignedExportTx) InputUTXOs ¶ added in v0.1.2
func (tx *UnsignedExportTx) InputUTXOs() ids.Set
InputUTXOs returns a set of all the hash(address:nonce) exporting funds.
type UnsignedImportTx ¶ added in v0.1.2
type UnsignedImportTx struct { djtx.Metadata // ID of the network on which this tx was issued NetworkID uint32 `serialize:"true" json:"networkID"` // ID of this blockchain. BlockchainID ids.ID `serialize:"true" json:"blockchainID"` // Which chain to consume the funds from SourceChain ids.ID `serialize:"true" json:"sourceChain"` // Inputs that consume UTXOs produced on the chain ImportedInputs []*djtx.TransferableInput `serialize:"true" json:"importedInputs"` // Outputs Outs []EVMOutput `serialize:"true" json:"outputs"` }
UnsignedImportTx is an unsigned ImportTx
func (*UnsignedImportTx) AtomicOps ¶ added in v0.6.7
AtomicOps returns imported inputs spent on this transaction We spend imported UTXOs here rather than in semanticVerify because we don't want to remove an imported UTXO in semanticVerify only to have the transaction not be Accepted. This would be inconsistent. Recall that imported UTXOs are not kept in a versionDB.
func (*UnsignedImportTx) Burned ¶ added in v0.6.7
func (tx *UnsignedImportTx) Burned(assetID ids.ID) (uint64, error)
Amount of [assetID] burned by this transaction
func (*UnsignedImportTx) EVMStateTransfer ¶ added in v0.1.2
EVMStateTransfer performs the state transfer to increase the balances of accounts accordingly with the imported EVMOutputs
func (*UnsignedImportTx) GasUsed ¶ added in v0.6.7
func (tx *UnsignedImportTx) GasUsed(fixedFee bool) (uint64, error)
func (*UnsignedImportTx) InputUTXOs ¶ added in v0.1.2
func (tx *UnsignedImportTx) InputUTXOs() ids.Set
InputUTXOs returns the UTXOIDs of the imported funds
type UnsignedTx ¶ added in v0.1.2
type UnsignedTx interface { Initialize(unsignedBytes, signedBytes []byte) ID() ids.ID GasUsed(fixedFee bool) (uint64, error) Burned(assetID ids.ID) (uint64, error) UnsignedBytes() []byte Bytes() []byte }
UnsignedTx is an unsigned transaction
type VM ¶
type VM struct { // *chain.State helps to implement the VM interface by wrapping blocks // with an efficient caching layer. *chain.State peer.Network // contains filtered or unexported fields }
VM implements the snowman.ChainVM interface
func (*VM) CodecRegistry ¶ added in v0.1.2
CodecRegistry implements the secp256k1fx interface
func (*VM) CreateHandlers ¶
func (vm *VM) CreateHandlers() (map[string]*commonEng.HTTPHandler, error)
CreateHandlers makes new http handlers that can handle API calls
func (*VM) CreateStaticHandlers ¶
func (vm *VM) CreateStaticHandlers() (map[string]*commonEng.HTTPHandler, error)
CreateStaticHandlers makes new http handlers that can handle API calls
func (*VM) FormatAddress ¶ added in v0.1.2
FormatAddress takes in a chainID and a raw address and produces the formatted address
func (*VM) FormatLocalAddress ¶ added in v0.1.2
FormatLocalAddress takes in a raw address and produces the formatted address
func (*VM) GetActivationTime ¶ added in v0.6.7
implements SnowmanPlusPlusVM interface
func (*VM) GetAtomicUTXOs ¶ added in v0.1.2
func (vm *VM) GetAtomicUTXOs( chainID ids.ID, addrs ids.ShortSet, startAddr ids.ShortID, startUTXOID ids.ID, limit int, ) ([]*djtx.UTXO, ids.ShortID, ids.ID, error)
GetAtomicUTXOs returns the utxos that at least one of the provided addresses is referenced in.
func (*VM) GetBlockIDAtHeight ¶ added in v0.6.7
GetBlockIDAtHeight retrieves the blkID of the canonical block at [blkHeight] if [blkHeight] is less than the height of the last accepted block, this will return a canonical block. Otherwise, it may return a blkID that has not yet been accepted.
func (*VM) GetCurrentNonce ¶ added in v0.1.2
GetCurrentNonce returns the nonce associated with the address at the preferred block
func (*VM) GetSpendableDJTXWithFee ¶ added in v0.6.7
func (vm *VM) GetSpendableDJTXWithFee( keys []*crypto.PrivateKeySECP256K1R, amount uint64, cost uint64, baseFee *big.Int, ) ([]EVMInput, [][]*crypto.PrivateKeySECP256K1R, error)
GetSpendableDJTXWithFee returns a list of EVMInputs and keys (in corresponding order) to total [amount] + [fee] of [DJTX] owned by [keys]. This function accounts for the added cost of the additional inputs needed to create the transaction and makes sure to skip any keys with a balance that is insufficient to cover the additional fee. Note: we return [][]*crypto.PrivateKeySECP256K1R even though each input corresponds to a single key, so that the signers can be passed in to [tx.Sign] which supports multiple keys on a single input.
func (*VM) GetSpendableFunds ¶ added in v0.1.2
func (vm *VM) GetSpendableFunds( keys []*crypto.PrivateKeySECP256K1R, assetID ids.ID, amount uint64, ) ([]EVMInput, [][]*crypto.PrivateKeySECP256K1R, error)
GetSpendableFunds returns a list of EVMInputs and keys (in corresponding order) to total [amount] of [assetID] owned by [keys]. Note: we return [][]*crypto.PrivateKeySECP256K1R even though each input corresponds to a single key, so that the signers can be passed in to [tx.Sign] which supports multiple keys on a single input.
func (*VM) HealthCheck ¶ added in v0.1.2
Health returns nil if this chain is healthy. Also returns details, which should be one of: string, []byte, map[string]string
func (*VM) Initialize ¶
func (vm *VM) Initialize( ctx *snow.Context, dbManager manager.Manager, genesisBytes []byte, upgradeBytes []byte, configBytes []byte, toEngine chan<- commonEng.Message, fxs []*commonEng.Fx, appSender commonEng.AppSender, ) error
Initialize implements the snowman.ChainVM interface
func (*VM) NewBlockBuilder ¶ added in v0.6.7
func (*VM) ParseAddress ¶ added in v0.1.2
ParseAddress takes in an address and produces the ID of the chain it's for the ID of the address
func (*VM) ParseLocalAddress ¶ added in v0.1.2
ParseLocalAddress takes in an address for this chain and produces the ID
func (*VM) SetPreference ¶
SetPreference sets what the current tail of the chain is
func (*VM) VerifyHeightIndex ¶ added in v0.6.7
type VersionReply ¶ added in v0.1.2
type VersionReply struct {
Version string `json:"version"`
}
Source Files ¶
- admin.go
- atomic_trie.go
- atomic_trie_iterator.go
- atomic_tx_repository.go
- block.go
- block_builder.go
- block_verification.go
- client.go
- codec.go
- config.go
- database.go
- export_tx.go
- ext_data_hashes.go
- factory.go
- formatting.go
- gasprice_update.go
- gossiper.go
- health.go
- import_tx.go
- mempool.go
- service.go
- static_service.go
- status.go
- test_tx.go
- tx.go
- tx_heap.go
- user.go
- version.go
- vm.go