eth

Documentation

Index

• Constants
• Variables
• type EthSubModule
  • func NewEthSubModule(ctx context.Context, cfg *config.Config, chainModule *chain.ChainSubmodule, ...) (*EthSubModule, error)
  • func (em *EthSubModule) API() v1api.FullETH
  • func (em *EthSubModule) Close(ctx context.Context) error
  • func (em *EthSubModule) Start(_ context.Context) error
• type EthSubscriptionManager
  • func (e *EthSubscriptionManager) StartSubscription(ctx context.Context, out ethSubscriptionCallback) (*ethSubscription, error)
  • func (e *EthSubscriptionManager) StopSubscription(ctx context.Context, id types.EthSubscriptionID) ([]filter.Filter, error)

Constants

const (
	EthSubscribeEventTypeHeads               = "newHeads"
	EthSubscribeEventTypeLogs                = "logs"
	EthSubscribeEventTypePendingTransactions = "newPendingTransactions"
)

const ChainHeadConfidence = 1

Variables

var ErrModuleDisabled = errors.New("module disabled, enable with Fevm.EnableEthRPC / VENUS_FEVM_ENABLEETHRPC")

Types

type EthSubModule

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

func NewEthSubModule

func NewEthSubModule(ctx context.Context,
	cfg *config.Config,
	chainModule *chain.ChainSubmodule,
	mpoolModule *mpool.MessagePoolSubmodule,
	sqlitePath string,
) (*EthSubModule, error)

func (*EthSubModule) API

func (em *EthSubModule) API() v1api.FullETH

func (*EthSubModule) Close

func (em *EthSubModule) Close(ctx context.Context) error

func (*EthSubModule) Start

func (em *EthSubModule) Start(_ context.Context) error

type EthSubscriptionManager

type EthSubscriptionManager struct {
	ChainAPI v1.IChain
	// contains filtered or unexported fields
}

func (*EthSubscriptionManager) StartSubscription

func (e *EthSubscriptionManager) StartSubscription(ctx context.Context, out ethSubscriptionCallback) (*ethSubscription, error)

func (*EthSubscriptionManager) StopSubscription

func (e *EthSubscriptionManager) StopSubscription(ctx context.Context, id types.EthSubscriptionID) ([]filter.Filter, error)