Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CommandExecutor ¶
type CommandExecutor struct {
// contains filtered or unexported fields
}
CommandExecutor 命令执行器
func NewCommandExecutor ¶
func NewCommandExecutor(logger *zap.Logger) *CommandExecutor
NewCommandExecutor 创建命令执行器
func (*CommandExecutor) Execute ¶
func (e *CommandExecutor) Execute(ctx context.Context, task *CommandTask) (string, error)
Execute 执行命令,返回输出字符串
type CommandTask ¶
type CommandTask struct {
Command string `json:"command"`
Args model.StringList `json:"args"`
WorkDir string `json:"work_dir"`
Environment model.KeyValueList `json:"environment"`
Timeout int `json:"timeout"`
}
CommandTask 命令任务配置
type CronHandlers ¶
type CronHandlers struct {
// contains filtered or unexported fields
}
func NewCronHandlers ¶
func NewCronHandlers( logger *zap.Logger, cronDAO dao.CronJobDAO, treeLocalDAO treeDAO.TreeLocalDAO, onDutyDAO alert.AlertManagerOnDutyDAO, k8sDAO k8sDao.ClusterDAO, k8sClient client.K8sClient, clusterMgr manager.ClusterManager, promConfigCache cache.MonitorCache, ) *CronHandlers
func (*CronHandlers) ProcessTask ¶
ProcessTask 处理任务的主入口
type CronTaskPayload ¶
type CronTaskPayload struct {
JobID int `json:"job_id"`
JobName string `json:"job_name"`
TaskType model.CronJobType `json:"task_type"`
TriggerBy string `json:"trigger_by,omitempty"`
Data map[string]interface{} `json:"data,omitempty"`
}
CronTaskPayload 任务载荷
type ExecutionResult ¶
type ExecutionResult struct {
Success bool `json:"success"`
Output string `json:"output"`
ErrorMsg string `json:"error_msg"`
}
ExecutionResult 执行结果
type HTTPExecutor ¶
type HTTPExecutor struct {
// contains filtered or unexported fields
}
HTTPExecutor HTTP执行器
func NewHTTPExecutor ¶
func NewHTTPExecutor(logger *zap.Logger) *HTTPExecutor
NewHTTPExecutor 创建HTTP执行器
type HTTPTask ¶
type HTTPTask struct {
Method string `json:"method"`
URL string `json:"url"`
Headers model.KeyValueList `json:"headers"`
Body string `json:"body"`
Timeout int `json:"timeout"`
}
HTTPTask HTTP任务配置
type ScriptExecutor ¶
type ScriptExecutor struct {
// contains filtered or unexported fields
}
ScriptExecutor 脚本执行器
func NewScriptExecutor ¶
func NewScriptExecutor(logger *zap.Logger) *ScriptExecutor
NewScriptExecutor 创建脚本执行器
func (*ScriptExecutor) Execute ¶
func (e *ScriptExecutor) Execute(ctx context.Context, task *ScriptTask) (string, error)
Execute 执行脚本,返回输出字符串
type ScriptTask ¶
type ScriptTask struct {
Type string `json:"type"`
Content string `json:"content"`
Timeout int `json:"timeout"`
}
ScriptTask 脚本任务配置
Click to show internal directories.
Click to hide internal directories.