listener

Documentation

Overview

Copyright 2020 ChainSafe Systems SPDX-License-Identifier: LGPL-3.0-only

Copyright 2020 ChainSafe Systems SPDX-License-Identifier: LGPL-3.0-only

Index

• Variables
• func GetTransactions() types.Transactions
• func GetTxRoot(transactions types.Transactions) (common.Hash, error)
• func NewListener(cfg *config.CeloChainConfig, client client.LogFilterWithLatestBlock, ...) *listener
• type Blockstorer
• type IBridge
• type IERC20Handler
• type IERC721Handler
• type IGenericHandler
• type IRouter
• type ValidatorsAggregator

Variables

var BlockDelay = big.NewInt(1)

var BlockRetryInterval = time.Second * 5

var BlockRetryLimit = 5

var ErrFatalPolling = errors.New("listener block polling failed")

var ExpectedBlockTime = time.Second

Functions

func GetTransactions

func GetTransactions() types.Transactions

func GetTxRoot

func GetTxRoot(transactions types.Transactions) (common.Hash, error)

func NewListener

func NewListener(cfg *config.CeloChainConfig, client client.LogFilterWithLatestBlock, bs Blockstorer, stop <-chan struct{}, sysErr chan<- error, router IRouter, valsAggr ValidatorsAggregator) *listener

Types

type Blockstorer

type Blockstorer interface {
	StoreBlock(*big.Int) error
}

type IBridge

type IBridge interface {
	ResourceIDToHandlerAddress(opts *bind.CallOpts, arg0 [32]byte) (common.Address, error)
}

type IERC20Handler

type IERC20Handler interface {
	GetDepositRecord(opts *bind.CallOpts, depositNonce uint64, destId uint8) (erc20.ERC20HandlerDepositRecord, error)
}

type IERC721Handler

type IERC721Handler interface {
	GetDepositRecord(opts *bind.CallOpts, depositNonce uint64, destId uint8) (erc721.ERC721HandlerDepositRecord, error)
}

type IGenericHandler

type IGenericHandler interface {
	GetDepositRecord(opts *bind.CallOpts, depositNonce uint64, destId uint8) (genericHandler.GenericHandlerDepositRecord, error)
}

type IRouter

type IRouter interface {
	Send(msg *utils.Message) error
}

type ValidatorsAggregator

type ValidatorsAggregator interface {
	GetAPKForBlock(block *big.Int, chainID uint8, epochSize uint64) ([]byte, error)
}