huginn

Documentation

Index

• Variables
• func PushTask(groupName string, maxRetry int, newData []string) (data string)
• type FinishedTask
  • func FinishJob(runnerName, groupName string, taskId int, status, result, note string) (FinishedTask, error)
• type Task
  • func FetchJob(runnerName, groupName string, fetchCount, returnGroupInSeconds int) ([]Task, error)
  • func GetStatus(groupName, kind string) (data []Task, err error)

Variables

var HuginnBaseUrl = "http://ct.mazhangjing.com:8099"

var HuginnLoginUrl = "http://ct.mazhangjing.com:8099/login"

var PASSWORD = "spring123456"

var USERNAME = "corkine"

Functions

func PushTask

func PushTask(groupName string, maxRetry int, newData []string) (data string)

PushTask 为某个组 groupName 写入新的查询任务 newData，其中 []string 包含数据库 data 字段

Types

type FinishedTask

type FinishedTask struct {
	WorkStatus   string `json:"workStatus"`
	Note         string `json:"note"`
	FinishStatus string `json:"finishStatus"`
	GroupId      string `json:"groupId"`
	TaskId       int    `json:"taskId"`
	Task         Task   `json:"bean"`
}

FinishedTask 指的是写入 Task 结果后数据库返回的值

func FinishJob

func FinishJob(runnerName, groupName string, taskId int, status, result, note string) (FinishedTask, error)

FinishJob 将一个已经获取到结果的 Job 信息写回服务器，runnerName，groupName 表示 Job 执行者信息和 Task 分组名称 taskId 表示 Job 的 Id 主键，即数据库 id 字段。status 表示 Job 的状态，一般是 FINISHED，note 一般为空，可以附带信息。

type Task

type Task struct {
	Id                         int    `json:"id"`
	RemainFailedRetryTime      int    `json:"remainFailedRetryTime"`
	WorkerPromiseReturnSeconds int    `json:"workerPromiseReturnSeconds"`
	TaskGroup                  string `json:"taskGroup"`
	Data                       string `json:"data"`
	Status                     string `json:"status"`
	Result                     string `json:"result"`
	Information                string `json:"information"`
	UpdateTime                 string `json:"updateTime"`
}

Task 指的是一条查询的结构

func FetchJob

func FetchJob(runnerName, groupName string, fetchCount, returnGroupInSeconds int) ([]Task, error)

FetchJob 从某个 groupName 获取一个 Task，作为一个 Job，相比较 Task，Job 添加了 runnerName 执行者信息 fetchCount 最大尝试次数，returnGroupInSeconds 最晚多长时间返回结果给服务器（如果超时，则任务 status 被看做 NEW， 且 fetchCount - 1，当 fetchCount 为 0 后，status 被置为 SUSPEND）

func GetStatus

func GetStatus(groupName, kind string) (data []Task, err error)

GetStatus 获取当前组 groupName 的状态，其中 kind 可以为 ALL,NEW,SUSPEND,FINISHED 等数据库 status 状态字段