Help us shape the future of Go! Take the 2026 Go Developer Survey

arbitrum

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Dec 5, 2023 License: GPL-3.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DefaultConfig = Config{
	RPCGasCap:               ethconfig.Defaults.RPCGasCap,
	RPCTxFeeCap:             ethconfig.Defaults.RPCTxFeeCap,
	RPCEVMTimeout:           ethconfig.Defaults.RPCEVMTimeout,
	BloomBitsBlocks:         params.BloomBitsBlocks * 4,
	BloomConfirms:           params.BloomConfirms,
	FeeHistoryMaxBlockCount: 1024,
	ClassicRedirect:         "",
	ArbDebug: ArbDebugConfig{
		BlockRangeBound:   1024,
		TimeoutQueueBound: 1024,
	},
}

Functions

func ConfigAddOptions 

func ConfigAddOptions(prefix string, f *flag.FlagSet)

func EstimateGas 

func EstimateGas(ctx context.Context, b ethapi.Backend, args TransactionArgs, blockNrOrHash rpc.BlockNumberOrHash, gasCap uint64) (hexutil.Uint64, error)

func HeaderByNumber 

func HeaderByNumber(blockchain *core.BlockChain, number rpc.BlockNumber) *types.Header

func HeaderByNumberOrHash 

func HeaderByNumberOrHash(blockchain *core.BlockChain, blockNrOrHash rpc.BlockNumberOrHash) (*types.Header, error)

func NewRevertReason 

func NewRevertReason(result *core.ExecutionResult) error

func PreimagesFromRecording 

func PreimagesFromRecording(chainContextIf core.ChainContext, recordingDb *RecordingKV) (map[common.Hash][]byte, error)

Types

type APIBackend 

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

func (*APIBackend) AccountManager 

func (a *APIBackend) AccountManager() *accounts.Manager

func (*APIBackend) BlockByHash 

func (a *APIBackend) BlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)

func (*APIBackend) BlockByNumber 

func (a *APIBackend) BlockByNumber(ctx context.Context, number rpc.BlockNumber) (*types.Block, error)

func (*APIBackend) BlockByNumberOrHash 

func (a *APIBackend) BlockByNumberOrHash(ctx context.Context, blockNrOrHash rpc.BlockNumberOrHash) (*types.Block, error)

func (*APIBackend) BloomStatus 

func (a *APIBackend) BloomStatus() (uint64, uint64)

Filter API

func (*APIBackend) ChainConfig 

func (a *APIBackend) ChainConfig() *params.ChainConfig

func (*APIBackend) ChainDb 

func (a *APIBackend) ChainDb() ethdb.Database

func (*APIBackend) CurrentBlock 

func (a *APIBackend) CurrentBlock() *types.Block

func (*APIBackend) CurrentHeader 

func (a *APIBackend) CurrentHeader() *types.Header

func (*APIBackend) Engine 

func (a *APIBackend) Engine() consensus.Engine

func (*APIBackend) ExtRPCEnabled 

func (a *APIBackend) ExtRPCEnabled() bool

func (*APIBackend) FallbackClient 

func (b *APIBackend) FallbackClient() types.FallbackClient

func (*APIBackend) FeeHistory 

func (a *APIBackend) FeeHistory(
	ctx context.Context,
	blocks int,
	newestBlock rpc.BlockNumber,
	rewardPercentiles []float64,
) (*big.Int, [][]*big.Int, []*big.Int, []float64, error)

func (*APIBackend) GetAPIs 

func (a *APIBackend) GetAPIs() []rpc.API

func (*APIBackend) GetArbitrumNode 

func (a *APIBackend) GetArbitrumNode() interface{}

func (*APIBackend) GetEVM 

func (a *APIBackend) GetEVM(ctx context.Context, msg core.Message, state *state.StateDB, header *types.Header, vmConfig *vm.Config) (*vm.EVM, func() error, error)

func (*APIBackend) GetLogs 

func (a *APIBackend) GetLogs(ctx context.Context, blockHash common.Hash) ([][]*types.Log, error)

func (*APIBackend) GetPoolNonce 

func (a *APIBackend) GetPoolNonce(ctx context.Context, addr common.Address) (uint64, error)

func (*APIBackend) GetPoolTransaction 

func (a *APIBackend) GetPoolTransaction(txHash common.Hash) *types.Transaction

func (*APIBackend) GetPoolTransactions 

func (a *APIBackend) GetPoolTransactions() (types.Transactions, error)

func (*APIBackend) GetReceipts 

func (a *APIBackend) GetReceipts(ctx context.Context, hash common.Hash) (types.Receipts, error)

func (*APIBackend) GetTd 

func (a *APIBackend) GetTd(ctx context.Context, hash common.Hash) *big.Int

func (*APIBackend) GetTransaction 

func (a *APIBackend) GetTransaction(ctx context.Context, txHash common.Hash) (*types.Transaction, common.Hash, uint64, uint64, error)

func (*APIBackend) HeaderByHash 

func (a *APIBackend) HeaderByHash(ctx context.Context, hash common.Hash) (*types.Header, error)

func (*APIBackend) HeaderByNumber 

func (a *APIBackend) HeaderByNumber(ctx context.Context, number rpc.BlockNumber) (*types.Header, error)

func (*APIBackend) HeaderByNumberOrHash 

func (a *APIBackend) HeaderByNumberOrHash(ctx context.Context, blockNrOrHash rpc.BlockNumberOrHash) (*types.Header, error)

func (*APIBackend) PendingBlockAndReceipts 

func (b *APIBackend) PendingBlockAndReceipts() (*types.Block, types.Receipts)

func (*APIBackend) RPCEVMTimeout 

func (a *APIBackend) RPCEVMTimeout() time.Duration

func (*APIBackend) RPCGasCap 

func (a *APIBackend) RPCGasCap() uint64

func (*APIBackend) RPCTxFeeCap 

func (a *APIBackend) RPCTxFeeCap() float64

func (*APIBackend) SendTx 

func (a *APIBackend) SendTx(ctx context.Context, signedTx *types.Transaction) error

Transaction pool API

func (*APIBackend) ServiceFilter 

func (a *APIBackend) ServiceFilter(ctx context.Context, session *bloombits.MatcherSession)

func (*APIBackend) SetHead 

func (a *APIBackend) SetHead(number uint64)

Blockchain API

func (*APIBackend) StateAndHeaderByNumber 

func (a *APIBackend) StateAndHeaderByNumber(ctx context.Context, number rpc.BlockNumber) (*state.StateDB, *types.Header, error)

func (*APIBackend) StateAndHeaderByNumberOrHash 

func (a *APIBackend) StateAndHeaderByNumberOrHash(ctx context.Context, blockNrOrHash rpc.BlockNumberOrHash) (*state.StateDB, *types.Header, error)

func (*APIBackend) StateAtBlock 

func (a *APIBackend) StateAtBlock(ctx context.Context, block *types.Block, reexec uint64, base *state.StateDB, checkLive bool, preferDisk bool) (statedb *state.StateDB, err error)

func (*APIBackend) StateAtTransaction 

func (a *APIBackend) StateAtTransaction(ctx context.Context, block *types.Block, txIndex int, reexec uint64) (core.Message, vm.BlockContext, *state.StateDB, error)

func (*APIBackend) Stats 

func (a *APIBackend) Stats() (pending int, queued int)

func (*APIBackend) SubscribeChainEvent 

func (a *APIBackend) SubscribeChainEvent(ch chan<- core.ChainEvent) event.Subscription

func (*APIBackend) SubscribeChainHeadEvent 

func (a *APIBackend) SubscribeChainHeadEvent(ch chan<- core.ChainHeadEvent) event.Subscription

func (*APIBackend) SubscribeChainSideEvent 

func (a *APIBackend) SubscribeChainSideEvent(ch chan<- core.ChainSideEvent) event.Subscription

func (*APIBackend) SubscribeLogsEvent 

func (a *APIBackend) SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscription

func (*APIBackend) SubscribeNewTxsEvent 

func (a *APIBackend) SubscribeNewTxsEvent(ch chan<- core.NewTxsEvent) event.Subscription

func (*APIBackend) SubscribePendingLogsEvent 

func (a *APIBackend) SubscribePendingLogsEvent(ch chan<- []*types.Log) event.Subscription

func (*APIBackend) SubscribeRemovedLogsEvent 

func (a *APIBackend) SubscribeRemovedLogsEvent(ch chan<- core.RemovedLogsEvent) event.Subscription

func (*APIBackend) SuggestGasTipCap 

func (a *APIBackend) SuggestGasTipCap(ctx context.Context) (*big.Int, error)

func (*APIBackend) SyncProgress 

func (a *APIBackend) SyncProgress() ethereum.SyncProgress

func (*APIBackend) SyncProgressMap 

func (a *APIBackend) SyncProgressMap() map[string]interface{}

General Ethereum API

func (*APIBackend) TxPoolContent 

func (a *APIBackend) TxPoolContent() (map[common.Address]types.Transactions, map[common.Address]types.Transactions)

func (*APIBackend) TxPoolContentFrom 

func (a *APIBackend) TxPoolContentFrom(addr common.Address) (types.Transactions, types.Transactions)

func (*APIBackend) UnprotectedAllowed 

func (a *APIBackend) UnprotectedAllowed() bool

type ArbDebugConfig 

type ArbDebugConfig struct {
	BlockRangeBound   uint64 `koanf:"block-range-bound"`
	TimeoutQueueBound uint64 `koanf:"timeout-queue-bound"`
}

type ArbInterface 

type ArbInterface interface {
	PublishTransaction(ctx context.Context, tx *types.Transaction) error
	BlockChain() *core.BlockChain
	ArbNode() interface{}
}

type Backend 

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

func NewBackend 

func NewBackend(stack *node.Node, config *Config, chainDb ethdb.Database, publisher ArbInterface, sync SyncProgressBackend) (*Backend, error)

func (*Backend) APIBackend 

func (b *Backend) APIBackend() *APIBackend

func (*Backend) ArbInterface 

func (b *Backend) ArbInterface() ArbInterface

func (*Backend) ChainDb 

func (b *Backend) ChainDb() ethdb.Database

func (*Backend) EnqueueL2Message 

func (b *Backend) EnqueueL2Message(ctx context.Context, tx *types.Transaction) error

func (*Backend) Stack 

func (b *Backend) Stack() *node.Node

func (*Backend) Start 

func (b *Backend) Start() error

TODO: this is used when registering backend as lifecycle in stack

func (*Backend) Stop 

func (b *Backend) Stop() error

func (*Backend) SubscribeNewTxsEvent 

func (b *Backend) SubscribeNewTxsEvent(ch chan<- core.NewTxsEvent) event.Subscription

type Config 

type Config struct {
	// RPCGasCap is the global gas cap for eth-call variants.
	RPCGasCap uint64 `koanf:"gas-cap"`

	// RPCTxFeeCap is the global transaction fee(price * gaslimit) cap for
	// send-transction variants. The unit is ether.
	RPCTxFeeCap float64 `koanf:"tx-fee-cap"`

	// RPCEVMTimeout is the global timeout for eth-call.
	RPCEVMTimeout time.Duration `koanf:"evm-timeout"`

	// Parameters for the bloom indexer
	BloomBitsBlocks uint64 `koanf:"bloom-bits-blocks"`
	BloomConfirms   uint64 `koanf:"bloom-confirms"`

	// FeeHistoryMaxBlockCount limits the number of historical blocks a fee history request may cover
	FeeHistoryMaxBlockCount uint64 `koanf:"feehistory-max-block-count"`

	ArbDebug ArbDebugConfig `koanf:"arbdebug"`

	ClassicRedirect        string        `koanf:"classic-redirect"`
	ClassicRedirectTimeout time.Duration `koanf:"classic-redirect-timeout"`
}

type PublicNetAPI 

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

PublicNetAPI offers network related RPC methods

func NewPublicNetAPI 

func NewPublicNetAPI(networkVersion uint64) *PublicNetAPI

NewPublicNetAPI creates a new net API instance.

func (*PublicNetAPI) Version 

func (s *PublicNetAPI) Version() string

Version returns the current ethereum protocol version.

type PublicTxPoolAPI 

type PublicTxPoolAPI struct{}

PublicNetAPI offers network related RPC methods

func NewPublicTxPoolAPI 

func NewPublicTxPoolAPI() *PublicTxPoolAPI

NewPublicNetAPI creates a new net API instance.

func (*PublicTxPoolAPI) Content 

func (s *PublicTxPoolAPI) Content() map[string]map[string]map[string]*struct{}

Version returns the current ethereum protocol version.

type RecordingChainContext 

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

func NewRecordingChainContext 

func NewRecordingChainContext(inner core.ChainContext, blocknumber uint64) *RecordingChainContext

func (*RecordingChainContext) Engine 

func (r *RecordingChainContext) Engine() consensus.Engine

func (*RecordingChainContext) GetHeader 

func (r *RecordingChainContext) GetHeader(hash common.Hash, num uint64) *types.Header

func (*RecordingChainContext) GetMinBlockNumberAccessed 

func (r *RecordingChainContext) GetMinBlockNumberAccessed() uint64

type RecordingKV 

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

func NewRecordingKV 

func NewRecordingKV(inner *trie.Database) *RecordingKV

func PrepareRecording 

func PrepareRecording(blockchain *core.BlockChain, lastBlockHeader *types.Header) (*state.StateDB, core.ChainContext, *RecordingKV, error)

func (*RecordingKV) Close 

func (db *RecordingKV) Close() error

func (*RecordingKV) Compact 

func (db *RecordingKV) Compact(start []byte, limit []byte) error

func (*RecordingKV) Delete 

func (db *RecordingKV) Delete(key []byte) error

func (*RecordingKV) EnableBypass 

func (db *RecordingKV) EnableBypass()

func (*RecordingKV) Get 

func (db *RecordingKV) Get(key []byte) ([]byte, error)

func (*RecordingKV) GetRecordedEntries 

func (db *RecordingKV) GetRecordedEntries() map[common.Hash][]byte

func (*RecordingKV) Has 

func (db *RecordingKV) Has(key []byte) (bool, error)

func (*RecordingKV) NewBatch 

func (db *RecordingKV) NewBatch() ethdb.Batch

func (*RecordingKV) NewBatchWithSize 

func (db *RecordingKV) NewBatchWithSize(size int) ethdb.Batch

func (*RecordingKV) NewIterator 

func (db *RecordingKV) NewIterator(prefix []byte, start []byte) ethdb.Iterator

func (*RecordingKV) NewSnapshot 

func (db *RecordingKV) NewSnapshot() (ethdb.Snapshot, error)

func (*RecordingKV) Put 

func (db *RecordingKV) Put(key []byte, value []byte) error

func (*RecordingKV) Release 

func (db *RecordingKV) Release()

func (*RecordingKV) Stat 

func (db *RecordingKV) Stat(property string) (string, error)

type SyncProgressBackend 

type SyncProgressBackend interface {
	SyncProgressMap() map[string]interface{}
}

type TransactionArgs 

type TransactionArgs = ethapi.TransactionArgs

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.