huginn

package
v1.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 14, 2021 License: GPL-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var HuginnBaseUrl = "http://ct.mazhangjing.com:8099"
View Source 
var HuginnLoginUrl = "http://ct.mazhangjing.com:8099/login"
View Source 
var PASSWORD = "spring123456"
View Source 
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 状态字段

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.