node

package
v0.1.7 Latest Latest
Warning

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

Go to latest
Published: Dec 20, 2024 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DB

type DB interface {
	UpdateLabels(unsafe, safe, finalized common.Hash) error
	Height() (uint64, error)
	HeaderByHash(hash common.Hash) (*monomer.Header, error)
	Rollback(unsafe, safe, finalized common.Hash) error
	HeaderByHeight(height uint64) (*monomer.Header, error)
	AppendBlock(*monomer.Block) error
	HeadHeader() (*monomer.Header, error)
	BlockByLabel(opeth.BlockLabel) (*monomer.Block, error)
	BlockByHeight(uint64) (*monomer.Block, error)
	BlockByHash(hash common.Hash) (*monomer.Block, error)
	HeadBlock() (*monomer.Block, error)
}

type EventListener

type EventListener interface {
	OnEngineHTTPServeErr(error)
	OnEngineWebsocketServeErr(error)
	OnCometServeErr(error)
	OnPrometheusServeErr(error)
}

type Node

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

func New

func New(
	app monomer.Application,
	g *genesis.Genesis,
	engineWS net.Listener,
	cometHTTPAndWS net.Listener,
	blockdb DB,
	mempooldb dbm.DB,
	txdb cometdb.DB,
	ethstatedb state.Database,
	prometheusCfg *config.InstrumentationConfig,
	eventListener EventListener,
) *Node

func (*Node) Run

func (n *Node) Run(ctx context.Context, env *environment.Env) error

type SelectiveListener

type SelectiveListener struct {
	OnEngineHTTPServeErrCb      func(error)
	OnEngineWebsocketServeErrCb func(error)
	OnCometServeErrCb           func(error)
	OnPrometheusServeErrCb      func(error)
}

func (*SelectiveListener) OnCometServeErr

func (s *SelectiveListener) OnCometServeErr(err error)

func (*SelectiveListener) OnEngineHTTPServeErr

func (s *SelectiveListener) OnEngineHTTPServeErr(err error)

func (*SelectiveListener) OnEngineWebsocketServeErr

func (s *SelectiveListener) OnEngineWebsocketServeErr(err error)

func (*SelectiveListener) OnPrometheusServeErr

func (s *SelectiveListener) OnPrometheusServeErr(err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL