node

Documentation

Index

• type EventListener
• type Node
  • func New(app monomer.Application, g *genesis.Genesis, engineHTTP net.Listener, ...) *Node
  • func (n *Node) Run(ctx context.Context, env *environment.Env) error
• type SelectiveListener
  • func (s *SelectiveListener) OnCometServeErr(err error)
  • func (s *SelectiveListener) OnEngineHTTPServeErr(err error)
  • func (s *SelectiveListener) OnEngineWebsocketServeErr(err error)

Types

type EventListener

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

type Node

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

func New

func New(
	app monomer.Application,
	g *genesis.Genesis,
	engineHTTP net.Listener,
	engineWS net.Listener,
	cometHTTPAndWS net.Listener,
	blockdb,
	mempooldb dbm.DB,
	txdb cometdb.DB,
	adaptCosmosTxsToEthTxs monomer.CosmosTxAdapter,
	adaptPayloadTxsToCosmosTxs monomer.PayloadTxAdapter,
	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)
}

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)