datanode

Documentation

Index

• type DataNodeCheckerService
  • func NewDataNodeCheckerService(config *[]config.DataNodeConfig, metrics *prometheus.Metrics, ...) *DataNodeCheckerService
  • func (s *DataNodeCheckerService) Start(ctx context.Context) error

Types

type DataNodeCheckerService

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

func NewDataNodeCheckerService

func NewDataNodeCheckerService(
	config *[]config.DataNodeConfig,
	metrics *prometheus.Metrics,
	log *logging.Logger,
) *DataNodeCheckerService

func (*DataNodeCheckerService) Start

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