executor

Documentation

Index

• Constants
• Variables
• func ExecutorRequestHandler(subtasks []taskmodel.SubtaskBody) error
• func GetTaskExecutor(taskType uint32, executor *taskmodel.ITaskExecutor) error
• func ReportRoutine()
• type ExecutorService
  • func GetExecutorService() *ExecutorService
  • func (service *ExecutorService) Init() error
• type SubtaskResultReporter
  • func GetReporter() *SubtaskResultReporter
  • func (reporter *SubtaskResultReporter) AddSubtaskResult(result *taskmodel.SubtaskResult) error
  • func (reporter *SubtaskResultReporter) PopSubtaskResult(retList *[]taskmodel.SubtaskResult) error
  • func (reporter *SubtaskResultReporter) ReportToCollector(results []taskmodel.SubtaskResult)

Constants

const (
	MaxSubtaskElemCount = 10000
	MaxCountPerTime     = 10
)

Variables

var CollectorInvoker taskmodel.CollectorInvoker

collector service invoker

Functions

func ExecutorRequestHandler

func ExecutorRequestHandler(subtasks []taskmodel.SubtaskBody) error

handler executor service request

func GetTaskExecutor

func GetTaskExecutor(taskType uint32, executor *taskmodel.ITaskExecutor) error

func ReportRoutine

func ReportRoutine()

Types

type ExecutorService

type ExecutorService struct {
	ExecutorMap map[uint32]taskmodel.ITaskExecutor
	Lock        sync.Mutex
}

func GetExecutorService

func GetExecutorService() *ExecutorService

func (*ExecutorService) Init

func (service *ExecutorService) Init() error

type SubtaskResultReporter

type SubtaskResultReporter struct {
	Results []taskmodel.SubtaskResult
	Lock    sync.Mutex
}

func GetReporter

func GetReporter() *SubtaskResultReporter

func (*SubtaskResultReporter) AddSubtaskResult

func (reporter *SubtaskResultReporter) AddSubtaskResult(result *taskmodel.SubtaskResult) error

func (*SubtaskResultReporter) PopSubtaskResult

func (reporter *SubtaskResultReporter) PopSubtaskResult(retList *[]taskmodel.SubtaskResult) error

func (*SubtaskResultReporter) ReportToCollector

func (reporter *SubtaskResultReporter) ReportToCollector(results []taskmodel.SubtaskResult)