nodescanner

Documentation

Index

• func CheckDataDepth(ctx context.Context, address string) (uint64, uint64, uint64, error)
• func CheckGQL(address string) (time.Duration, uint64, error)
• func CheckGRPC(address string) (time.Duration, uint64, error)
• func CheckREST(address string) (time.Duration, uint64, error)
• func GetTradesCount(ctx context.Context, address string, dateRangeEnd time.Time) (uint64, error)
• type NodeScannerService
  • func NewNodeScannerService(config *config.MonitoringConfig, collector *collectors.VegaMonitoringCollector, ...) *NodeScannerService
  • func (s *NodeScannerService) Start(ctx context.Context) error

Functions

func CheckDataDepth

func CheckDataDepth(ctx context.Context, address string) (uint64, uint64, uint64, error)

func CheckGQL

func CheckGQL(address string) (time.Duration, uint64, error)

func CheckGRPC

func CheckGRPC(address string) (time.Duration, uint64, error)

func CheckREST

func CheckREST(address string) (time.Duration, uint64, error)

func GetTradesCount

func GetTradesCount(ctx context.Context, address string, dateRangeEnd time.Time) (uint64, error)

Types

type NodeScannerService

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

func NewNodeScannerService

func NewNodeScannerService(
	config *config.MonitoringConfig,
	collector *collectors.VegaMonitoringCollector,
	log *logging.Logger,
) *NodeScannerService

func (*NodeScannerService) Start

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