txdb

Documentation

Index

• type TxDB
  • func New(clnt arbbridge.ChainTimeGetter, checkpointer checkpointing.RollupCheckpointer, ...) *TxDB
  • func (db *TxDB) AddInitialBlock(ctx context.Context, initialBlockHeight *big.Int) error
  • func (db *TxDB) AddMessages(ctx context.Context, msgs []arbbridge.MessageDeliveredEvent, ...) error
  • func (db *TxDB) GetBlock(height uint64) (*machine.BlockInfo, error)
  • func (db *TxDB) GetBlockResults(res *evm.BlockInfo) ([]*evm.TxResult, error)
  • func (db *TxDB) GetLog(index uint64) (value.Value, error)
  • func (db *TxDB) GetLogs(_ context.Context, blockHash ethcommon.Hash) ([][]*types.Log, error)
  • func (db *TxDB) GetMachineBlockResults(block *machine.BlockInfo) ([]*evm.TxResult, error)
  • func (db *TxDB) GetMessage(index uint64) (value.Value, error)
  • func (db *TxDB) GetReceipts(_ context.Context, blockHash ethcommon.Hash) (types.Receipts, error)
  • func (db *TxDB) GetSnapshot(time inbox.ChainTime) *snapshot.Snapshot
  • func (db *TxDB) LatestBlock() *common.BlockId
  • func (db *TxDB) LatestBlockId() *common.BlockId
  • func (db *TxDB) LatestSnapshot() *snapshot.Snapshot
  • func (db *TxDB) Load(ctx context.Context) error
  • func (db *TxDB) SubscribeBlockProcessingEvent(ch chan<- []*types.Log) event.Subscription
  • func (db *TxDB) SubscribeChainEvent(ch chan<- core.ChainEvent) event.Subscription
  • func (db *TxDB) SubscribeChainHeadEvent(ch chan<- core.ChainEvent) event.Subscription
  • func (db *TxDB) SubscribeChainSideEvent(ch chan<- core.ChainEvent) event.Subscription
  • func (db *TxDB) SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscription
  • func (db *TxDB) SubscribePendingLogsEvent(ch chan<- []*types.Log) event.Subscription
  • func (db *TxDB) SubscribeRemovedLogsEvent(ch chan<- core.RemovedLogsEvent) event.Subscription
• type View
  • func (txdb *View) FindLogs(ctx context.Context, fromHeight *uint64, toHeight *uint64, ...) ([]evm.FullLog, error)
  • func (txdb *View) GetBlock(height uint64) (*machine.BlockInfo, error)
  • func (txdb *View) GetBlockWithHash(blockHash common.Hash) (*machine.BlockInfo, error)
  • func (txdb *View) GetLog(index uint64) (value.Value, error)
  • func (txdb *View) GetMessage(index uint64) (value.Value, error)
  • func (txdb *View) GetRequest(requestId common.Hash) (value.Value, error)
  • func (txdb *View) LatestBlockId() (*common.BlockId, error)

Types

type TxDB

type TxDB struct {
	View
	// contains filtered or unexported fields
}

func New

func New(
	clnt arbbridge.ChainTimeGetter,
	checkpointer checkpointing.RollupCheckpointer,
	as *cmachine.AggregatorStore,
	chain common.Address,
) *TxDB

func (*TxDB) AddInitialBlock

func (db *TxDB) AddInitialBlock(ctx context.Context, initialBlockHeight *big.Int) error

func (*TxDB) AddMessages

func (db *TxDB) AddMessages(ctx context.Context, msgs []arbbridge.MessageDeliveredEvent, finishedBlock *common.BlockId) error

func (*TxDB) GetBlock

func (db *TxDB) GetBlock(height uint64) (*machine.BlockInfo, error)

func (*TxDB) GetBlockResults

func (db *TxDB) GetBlockResults(res *evm.BlockInfo) ([]*evm.TxResult, error)

func (*TxDB) GetLog

func (db *TxDB) GetLog(index uint64) (value.Value, error)

func (*TxDB) GetLogs

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

func (*TxDB) GetMachineBlockResults

func (db *TxDB) GetMachineBlockResults(block *machine.BlockInfo) ([]*evm.TxResult, error)

func (*TxDB) GetMessage

func (db *TxDB) GetMessage(index uint64) (value.Value, error)

func (*TxDB) GetReceipts

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

func (*TxDB) GetSnapshot

func (db *TxDB) GetSnapshot(time inbox.ChainTime) *snapshot.Snapshot

func (*TxDB) LatestBlock

func (db *TxDB) LatestBlock() *common.BlockId

func (*TxDB) LatestBlockId

func (db *TxDB) LatestBlockId() *common.BlockId

func (*TxDB) LatestSnapshot

func (db *TxDB) LatestSnapshot() *snapshot.Snapshot

func (*TxDB) Load

func (db *TxDB) Load(ctx context.Context) error

func (*TxDB) SubscribeBlockProcessingEvent

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

func (*TxDB) SubscribeChainEvent

func (db *TxDB) SubscribeChainEvent(ch chan<- core.ChainEvent) event.Subscription

func (*TxDB) SubscribeChainHeadEvent

func (db *TxDB) SubscribeChainHeadEvent(ch chan<- core.ChainEvent) event.Subscription

func (*TxDB) SubscribeChainSideEvent

func (db *TxDB) SubscribeChainSideEvent(ch chan<- core.ChainEvent) event.Subscription

func (*TxDB) SubscribeLogsEvent

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

func (*TxDB) SubscribePendingLogsEvent

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

func (*TxDB) SubscribeRemovedLogsEvent

func (db *TxDB) SubscribeRemovedLogsEvent(ch chan<- core.RemovedLogsEvent) event.Subscription

type View

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

func (*View) FindLogs

func (txdb *View) FindLogs(
	ctx context.Context,
	fromHeight *uint64,
	toHeight *uint64,
	address []common.Address,
	topics [][]common.Hash,
) ([]evm.FullLog, error)

func (*View) GetBlock

func (txdb *View) GetBlock(height uint64) (*machine.BlockInfo, error)

func (*View) GetBlockWithHash

func (txdb *View) GetBlockWithHash(blockHash common.Hash) (*machine.BlockInfo, error)

func (*View) GetLog

func (txdb *View) GetLog(index uint64) (value.Value, error)

func (*View) GetMessage

func (txdb *View) GetMessage(index uint64) (value.Value, error)

func (*View) GetRequest

func (txdb *View) GetRequest(requestId common.Hash) (value.Value, error)

func (*View) LatestBlockId

func (txdb *View) LatestBlockId() (*common.BlockId, error)