collector

Documentation

Index

• Constants
• func CollectorRequestHandler(results []taskmodel.SubtaskResult) error
• func CompleteSubtaskRoutine()
• func InsertSubtask(result *taskmodel.SubtaskResult)
• func InsertSubtaskList(newElems *[]*SubtaskElem)
• func InsertSubtaskResults(results []taskmodel.SubtaskResult)
• func PopSubtaskList(retList *[]*SubtaskElem)
• func SetSubtaskResult(subtaskId taskmodel.SubtaskIdType, result *taskmodel.SubtaskResult, ...) error
• type SubtaskElem

Constants

const (
	// complete subtask routine limit
	SubtaskRoutineCountDefaultLimit = 300
	SubtaskRoutineLimitEnvName      = "SUBTASK_ROUTINE_LIMIT"
)

const (
	MaxSubtaskElemCount = 10000
	MaxCountPerTime     = 10
)

Functions

func CollectorRequestHandler

func CollectorRequestHandler(results []taskmodel.SubtaskResult) error

handle collector requests

func CompleteSubtaskRoutine

func CompleteSubtaskRoutine()

to complete subtask

func InsertSubtask

func InsertSubtask(result *taskmodel.SubtaskResult)

func InsertSubtaskList

func InsertSubtaskList(newElems *[]*SubtaskElem)

func InsertSubtaskResults

func InsertSubtaskResults(results []taskmodel.SubtaskResult)

func PopSubtaskList

func PopSubtaskList(retList *[]*SubtaskElem)

func SetSubtaskResult

func SetSubtaskResult(
	subtaskId taskmodel.SubtaskIdType,
	result *taskmodel.SubtaskResult,
	ppipeline *redis.Pipeliner,
) error

Types

type SubtaskElem

type SubtaskElem struct {
	Result     *taskmodel.SubtaskResult
	InsertTime time.Time
}