itx

Documentation

Index

• func StartServer(ctx context.Context, svr *Server, probeSvr *probe.Server, cfg config.Config)
• type HeartbeatHandler
  • func NewHeartbeatHandler(s *Server) *HeartbeatHandler
  • func (h *HeartbeatHandler) Log()
• type Server
  • func NewInMemTestServer(cfg config.Config) (*Server, error)
  • func NewServer(cfg config.Config) (*Server, error)
  • func (s *Server) ChainService(id uint32) *chainservice.ChainService
  • func (s *Server) Dispatcher() dispatcher.Dispatcher
  • func (s *Server) HandleBlock(blk *block.Block) error
  • func (s *Server) NewSubChainService(cfg config.Config, opts ...chainservice.Option) error
  • func (s *Server) P2PAgent() *p2p.Agent
  • func (s *Server) Start(ctx context.Context) error
  • func (s *Server) Stop(ctx context.Context) error
  • func (s *Server) StopChainService(ctx context.Context, id uint32) error

Functions

func StartServer

func StartServer(ctx context.Context, svr *Server, probeSvr *probe.Server, cfg config.Config)

StartServer starts a node server

Types

type HeartbeatHandler

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

HeartbeatHandler is the handler to periodically log the system key metrics

func NewHeartbeatHandler

func NewHeartbeatHandler(s *Server) *HeartbeatHandler

NewHeartbeatHandler instantiates a HeartbeatHandler instance

func (*HeartbeatHandler) Log

func (h *HeartbeatHandler) Log()

Log executes the logging logic

type Server

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

Server is the iotex server instance containing all components.

func NewInMemTestServer

func NewInMemTestServer(cfg config.Config) (*Server, error)

NewInMemTestServer creates a test server in memory

func NewServer

func NewServer(cfg config.Config) (*Server, error)

NewServer creates a new server TODO clean up config, make root config contains network, dispatch and chainservice

func (*Server) ChainService

func (s *Server) ChainService(id uint32) *chainservice.ChainService

ChainService returns the chainservice hold in Server with given id.

func (*Server) Dispatcher

func (s *Server) Dispatcher() dispatcher.Dispatcher

Dispatcher returns the Dispatcher

func (*Server) HandleBlock

func (s *Server) HandleBlock(blk *block.Block) error

HandleBlock implements interface BlockCreationSubscriber

func (*Server) NewSubChainService

func (s *Server) NewSubChainService(cfg config.Config, opts ...chainservice.Option) error

NewSubChainService creates a new chain service in this server.

func (*Server) P2PAgent

func (s *Server) P2PAgent() *p2p.Agent

P2PAgent returns the P2P agent

func (*Server) Start

func (s *Server) Start(ctx context.Context) error

Start starts the server

func (*Server) Stop

func (s *Server) Stop(ctx context.Context) error

Stop stops the server

func (*Server) StopChainService

func (s *Server) StopChainService(ctx context.Context, id uint32) error

StopChainService stops the chain service run in the server.