handler

package
v1.0.20250928075430 Latest Latest
Warning

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

Go to latest
Published: Sep 28, 2025 License: MIT Imports: 21 Imported by: 0

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

func (h *CronHandlers) ProcessTask(ctx context.Context, t *asynq.Task) error

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执行器

func (*HTTPExecutor) Execute

func (e *HTTPExecutor) Execute(ctx context.Context, task *HTTPTask) (string, error)

Execute 执行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 脚本任务配置

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL