aggregator

package
v0.7.3 Latest Latest
Warning

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

 Go to latest Published: Nov 24, 2020 License: Apache-2.0 Imports: 23 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 (m *Server) AdjustGas(msg message.Call) message.Call

func (*Server) BlockInfoByHash added in v0.7.3 

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

func (*Server) BlockInfoByNumber added in v0.7.3 

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

func (*Server) BloomStatus added in v0.7.3 

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

func (*Server) Call 

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

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

func (*Server) ChainDb added in v0.7.3 

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

func (*Server) FindLogs 

func (m *Server) FindLogs(ctx context.Context, fromHeight, toHeight *uint64, addresses []ethcommon.Address, topics [][]ethcommon.Hash) ([]evm.FullLog, error)

FindLogs takes a set of parameters and return the list of all logs that match the query

func (*Server) GetBlockCount 

func (m *Server) GetBlockCount() uint64

func (*Server) GetChainAddress 

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

GetVMInfo returns current metadata about this VM

func (*Server) GetLogs added in v0.7.3 

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

func (*Server) GetMachineBlockResults added in v0.7.3 

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

func (*Server) GetOutputMessage 

func (m *Server) GetOutputMessage(
	args *evm.GetOutputMessageArgs,
	reply *evm.GetOutputMessageReply,
) error

func (*Server) GetReceipts added in v0.7.3 

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

func (*Server) GetRequestResult 

func (m *Server) GetRequestResult(requestId common.Hash) (value.Value, 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 added in v0.7.2 

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

func (*Server) HeaderByHash added in v0.7.3 

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

func (*Server) HeaderByNumber added in v0.7.3 

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

func (*Server) LatestSnapshot 

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

func (*Server) PendingCall 

func (m *Server) PendingCall(msg message.Call, 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

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 added in v0.7.3 

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

func (*Server) SubscribeBlockProcessingEvent added in v0.7.3 

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

func (*Server) SubscribeChainEvent added in v0.7.3 

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

func (*Server) SubscribeChainHeadEvent added in v0.7.3 

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

func (*Server) SubscribeChainSideEvent added in v0.7.3 

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

func (*Server) SubscribeLogsEvent added in v0.7.3 

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

func (*Server) SubscribeNewTxsEvent added in v0.7.3 

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

func (*Server) SubscribePendingLogsEvent added in v0.7.3 

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

func (*Server) SubscribeRemovedLogsEvent added in v0.7.3 

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

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.