monitor

Documentation

Index

• type Service
  • func NewService(config *config.Config) *Service
  • func (s *Service) AddNodeError(list []*service.NodeSource) error
  • func (s *Service) DelNodeErrorWithBlockByBlockNumber(number string, chain *config.BlockConfig) error
  • func (s *Service) DelNodeErrorWithReceiptByBlockNumber(number string, chain *config.BlockConfig) error
  • func (s *Service) HandlerDeadTask()
  • func (s *Service) HandlerManyFailTask()
  • func (s *Service) RetryTaskForFail()
  • func (s *Service) Start()

Types

type Service

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

func NewService

func NewService(config *config.Config) *Service

func (*Service) AddNodeError

func (s *Service) AddNodeError(list []*service.NodeSource) error

func (*Service) DelNodeErrorWithBlockByBlockNumber

func (s *Service) DelNodeErrorWithBlockByBlockNumber(number string, chain *config.BlockConfig) error

func (*Service) DelNodeErrorWithReceiptByBlockNumber

func (s *Service) DelNodeErrorWithReceiptByBlockNumber(number string, chain *config.BlockConfig) error

func (*Service) HandlerDeadTask

func (s *Service) HandlerDeadTask()

func (*Service) HandlerManyFailTask

func (s *Service) HandlerManyFailTask()

func (*Service) RetryTaskForFail

func (s *Service) RetryTaskForFail()

RetryTaskForFail 针对失败的任务，重发任务

func (*Service) Start

func (s *Service) Start()