chain

Documentation

Index

• Constants
• type EvmChainClient
  • func NewEvmChainClient(ctx context.Context, cfg *EvmChainConfig) (*EvmChainClient, error)
  • func (ecc *EvmChainClient) InitBlock() error
  • func (ecc *EvmChainClient) ProcessBlock(block *types.Block) error
  • func (ecc *EvmChainClient) ProcessTransaction(tx *types.Transaction, blockTime uint64, blockNumber *big.Int, status uint64) error
  • func (ecc *EvmChainClient) ProcessTransactionEvent(rLog *types.Log, status uint64) error
  • func (ecc *EvmChainClient) Start() error
  • func (ecc *EvmChainClient) Stop()
  • func (ecc *EvmChainClient) SyncLoop()
• type EvmChainConfig

Constants

const (
	DefaultTimeout = 5 * time.Second
)

Types

type EvmChainClient

type EvmChainClient struct {
	Ctx       context.Context
	EthClient *ethclient.Client
	Cfg       *EvmChainConfig
	// contains filtered or unexported fields
}

func NewEvmChainClient

func NewEvmChainClient(ctx context.Context, cfg *EvmChainConfig) (*EvmChainClient, error)

func (*EvmChainClient) InitBlock

func (ecc *EvmChainClient) InitBlock() error

func (*EvmChainClient) ProcessBlock

func (ecc *EvmChainClient) ProcessBlock(block *types.Block) error

func (*EvmChainClient) ProcessTransaction

func (ecc *EvmChainClient) ProcessTransaction(tx *types.Transaction, blockTime uint64, blockNumber *big.Int, status uint64) error

func (*EvmChainClient) ProcessTransactionEvent

func (ecc *EvmChainClient) ProcessTransactionEvent(rLog *types.Log, status uint64) error

func (*EvmChainClient) Start

func (ecc *EvmChainClient) Start() error

func (*EvmChainClient) Stop

func (ecc *EvmChainClient) Stop()

func (*EvmChainClient) SyncLoop

func (ecc *EvmChainClient) SyncLoop()

type EvmChainConfig

type EvmChainConfig struct {
	EthRpc          string
	DisableHTTP2    bool
	SyncBlockHeight uint64
	LoopInterval    time.Duration
	Database        *db.Database
}