aggregator

package
v0.8.0 Latest Latest
Warning

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

Go to latest
Published: Mar 30, 2021 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Server

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

func NewServer

func NewServer(
	batch batcher.TransactionBatcher,
	rollupAddress common.Address,
	db *txdb.TxDB,
) *Server

NewServer returns a new instance of the Server class

func (*Server) AdjustGas

func (*Server) BlockInfoByHash

func (m *Server) BlockInfoByHash(hash common.Hash) (*machine.BlockInfo, error)

func (*Server) BlockInfoByNumber

func (m *Server) BlockInfoByNumber(height uint64) (*machine.BlockInfo, error)

func (*Server) BlockLogFromInfo

func (m *Server) BlockLogFromInfo(block *machine.BlockInfo) (*evm.BlockInfo, error)

func (*Server) BlockNum

func (m *Server) BlockNum(block *rpc.BlockNumber) (uint64, error)

func (*Server) BloomStatus

func (m *Server) BloomStatus() (uint64, uint64)

func (*Server) Call

Call takes a request from a Client to process in a temporary context and return the result

func (*Server) ChainDb

func (m *Server) ChainDb() ethdb.Database

func (*Server) GetBlockCount

func (m *Server) GetBlockCount() (uint64, error)

func (*Server) GetChainAddress

func (m *Server) GetChainAddress() ethcommon.Address

GetVMInfo returns current metadata about this VM

func (*Server) GetL2ToL1Proof

func (m *Server) GetL2ToL1Proof(batchNumber *big.Int, index uint64) (*evm.MerkleRootProof, error)

func (*Server) GetLogs

func (m *Server) GetLogs(_ context.Context, blockHash ethcommon.Hash) ([][]*types.Log, error)

func (*Server) GetMachineBlockResults

func (m *Server) GetMachineBlockResults(block *machine.BlockInfo) (*evm.BlockInfo, []*evm.TxResult, error)

func (*Server) GetReceipts

func (m *Server) GetReceipts(_ context.Context, blockHash ethcommon.Hash) (types.Receipts, error)

func (*Server) GetRequestResult

func (m *Server) GetRequestResult(requestId common.Hash) (*evm.TxResult, error)

GetMessageResult returns the value output by the VM in response to the l2message with the given hash

func (*Server) GetSnapshot

func (m *Server) GetSnapshot(blockHeight uint64) (*snapshot.Snapshot, error)

func (*Server) GetTxInBlockAtIndexResults

func (m *Server) GetTxInBlockAtIndexResults(res *machine.BlockInfo, index uint64) (*evm.TxResult, error)

func (*Server) HeaderByHash

func (m *Server) HeaderByHash(_ context.Context, blockHash ethcommon.Hash) (*types.Header, error)

func (*Server) HeaderByNumber

func (m *Server) HeaderByNumber(_ context.Context, blockNumber rpc.BlockNumber) (*types.Header, error)

func (*Server) LatestSnapshot

func (m *Server) LatestSnapshot() (*snapshot.Snapshot, error)

func (*Server) PendingCall

func (m *Server) PendingCall(msg message.ContractTransaction, sender ethcommon.Address) (*evm.TxResult, error)

PendingCall takes a request from a Client to process in a temporary context and return the result

func (*Server) PendingSnapshot

func (m *Server) PendingSnapshot() (*snapshot.Snapshot, error)

func (*Server) PendingTransactionCount

func (m *Server) PendingTransactionCount(ctx context.Context, account common.Address) *uint64

func (*Server) SendTransaction

func (m *Server) SendTransaction(ctx context.Context, tx *types.Transaction) error

SendTransaction takes a request signed transaction l2message from a Client and puts it in a queue to be included in the next transaction batch

func (*Server) ServiceFilter

func (m *Server) ServiceFilter(_ context.Context, _ *bloombits.MatcherSession)

func (*Server) SubscribeBlockProcessingEvent

func (m *Server) SubscribeBlockProcessingEvent(ch chan<- []*types.Log) event.Subscription

func (*Server) SubscribeChainEvent

func (m *Server) SubscribeChainEvent(ch chan<- ethcore.ChainEvent) event.Subscription

func (*Server) SubscribeChainHeadEvent

func (m *Server) SubscribeChainHeadEvent(ch chan<- ethcore.ChainEvent) event.Subscription

func (*Server) SubscribeChainSideEvent

func (m *Server) SubscribeChainSideEvent(ch chan<- ethcore.ChainEvent) event.Subscription

func (*Server) SubscribeLogsEvent

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

func (*Server) SubscribeNewTxsEvent

func (m *Server) SubscribeNewTxsEvent(ch chan<- ethcore.NewTxsEvent) event.Subscription

func (*Server) SubscribePendingLogsEvent

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

func (*Server) SubscribeRemovedLogsEvent

func (m *Server) SubscribeRemovedLogsEvent(ch chan<- ethcore.RemovedLogsEvent) event.Subscription

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL