lua

package
v0.0.173 Latest Latest
Warning

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

 Go to latest Published: Oct 28, 2025 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const TriggerTypeCron = "cron"

TriggerTypeCron 表示定时触发

View Source 
const TriggerTypeManual = "manual"

TriggerTypeManual 表示手动触发

Variables

This section is empty.

Functions

func InitClusterInspection 

func InitClusterInspection()

Types

type CancellableJob added in v0.0.173 

type CancellableJob struct {
	// contains filtered or unexported fields
}

CancellableJob 可取消的任务包装

func NewCancellableJob added in v0.0.173 

func NewCancellableJob(f func(ctx context.Context)) *CancellableJob

func (*CancellableJob) Cancel added in v0.0.173 

func (cj *CancellableJob) Cancel()

func (*CancellableJob) Run added in v0.0.173 

func (cj *CancellableJob) Run()

type CheckEvent 

type CheckEvent struct {
	Status     string         `json:"status"` // 检查状态（如“正常”、“失败”）
	Msg        string         `json:"msg"`
	Extra      map[string]any `json:"extra,omitempty"`
	ScriptName string         `json:"scriptName"` // 检测脚本名称
	Kind       string         `json:"kind"`       // 检查的资源类型
	CheckDesc  string         `json:"checkDesc"`  // 检查脚本内容描述
	Namespace  string         `json:"ns"`         // 资源命名空间
	Name       string         `json:"name"`       // 资源名称
}

CheckEvent 用于记录每次检测的详细信息，包括检测状态、消息、额外上下文、脚本名称、资源类型、描述、命名空间和资源名。

type CheckResult 

type CheckResult struct {
	Name         string
	StartTime    time.Time
	EndTime      time.Time
	LuaRunOutput string
	LuaRunError  error
	Events       []CheckEvent
}

type Inspection 

type Inspection struct {
	Cluster string // 集群名称

	Schedule *models.InspectionSchedule // 巡检计划ID
	// contains filtered or unexported fields
}

func NewLuaInspection 

func NewLuaInspection(schedule *models.InspectionSchedule, cluster string) *Inspection

func (*Inspection) Start 

func (p *Inspection) Start() []CheckResult

type Kubectl 

type Kubectl struct {
	// contains filtered or unexported fields
}

type ScheduleBackground 

type ScheduleBackground struct {
}

func NewScheduleBackground added in v0.0.173 

func NewScheduleBackground() *ScheduleBackground

func (*ScheduleBackground) Add 

func (s *ScheduleBackground) Add(scheduleID uint)

func (*ScheduleBackground) AddCronJobFromDB added in v0.0.173 

func (s *ScheduleBackground) AddCronJobFromDB()

AddCronJobFromDB 后台自动执行调度

func (*ScheduleBackground) AutoGenerateSummary added in v0.0.169 

func (s *ScheduleBackground) AutoGenerateSummary(recordID uint)

AutoGenerateSummary 如果启用了AI总结，则自动生成总结 该方法在巡检执行完成后被调用，生成的AI总结会保存到数据库中 调用时机：巡检完成后立即调用，在发送webhook之前 设计原则：AI总结生成与webhook发送分离，确保职责单一

func (*ScheduleBackground) GetSummaryMsg added in v0.0.132 

func (s *ScheduleBackground) GetSummaryMsg(recordID uint) (*SummaryMsg, error)

GetSummaryMsg 获取巡检记录的汇总信息 该函数根据记录ID查询巡检记录详情，包括关联的调度任务信息和失败事件统计 返回的数据中，record_date字段会将原始的UTC时间转换为本地时间，以便前端正确显示 参数:

  • recordID: 巡检记录的唯一标识符

返回值:

  • *SummaryMsg: 包含巡检汇总信息的结构体，包括记录日期、调度信息、错误统计等
  • error: 如果查询失败或记录不存在则返回错误

func (*ScheduleBackground) IsEventStatusPass 

func (s *ScheduleBackground) IsEventStatusPass(status string) bool

IsEventStatusPass 判断事件状态是否为通过 这里的通过状态包括：正常、pass、ok、success、通过 入库前将状态描述文字统一为正常、失败两种

func (*ScheduleBackground) PushToHooksByRecordID added in v0.0.130 

func (s *ScheduleBackground) PushToHooksByRecordID(recordID uint) ([]*webhook.SendResult, error)

PushToHooksByRecordID 根据巡检记录ID发送webhook通知 该方法从数据库中获取已生成的AI总结，然后发送到所有关联的webhook 调用时机：在AutoGenerateSummaryIfEnabled()完成后调用 设计原则：单纯的webhook发送功能，不负责AI总结生成

func (*ScheduleBackground) Remove 

func (s *ScheduleBackground) Remove(scheduleID uint)

func (*ScheduleBackground) RunByCluster 

func (s *ScheduleBackground) RunByCluster(ctx context.Context, scheduleID *uint, cluster string, triggerType string) (*models.InspectionRecord, error)

RunByCluster 启动一次巡检任务，并记录执行及每个脚本的结果到数据库 scheduleID: 定时任务ID cluster: 目标集群 triggerType: 触发类型（manual/cron）

func (*ScheduleBackground) SaveSummaryBack added in v0.0.132 

func (s *ScheduleBackground) SaveSummaryBack(id uint, summary string, summaryErr error, resultRaw string) error

SaveSummaryBack 保存AI总结结果到数据库 参数：id 巡检记录ID，summary AI总结内容，summaryErr AI总结错误，resultRaw 原始巡检结果JSON字符串

func (*ScheduleBackground) SummaryByAI added in v0.0.130 

func (s *ScheduleBackground) SummaryByAI(ctx context.Context, msg *SummaryMsg) (string, error)

SummaryByAI 生成巡检总结 参数：msg 包含巡检数据和AI配置的消息 返回：总结内容和错误信息

func (*ScheduleBackground) Update added in v0.0.173 

func (s *ScheduleBackground) Update(scheduleID uint)

type SummaryMsg added in v0.0.169 

type SummaryMsg struct {
	RecordDate       string                         `json:"record_date"`        // 巡检记录日期（本地时间格式）
	RecordID         uint                           `json:"record_id"`          // 巡检记录ID
	ScheduleID       *uint                          `json:"schedule_id"`        // 巡检计划ID
	ScheduleName     string                         `json:"schedule_name"`      // 巡检计划名称
	Cluster          string                         `json:"cluster"`            // 集群名称
	TotalRules       int                            `json:"total_rules"`        // 总规则数
	FailedCount      int                            `json:"failed_count"`       // 失败数量
	FailedList       []*models.InspectionCheckEvent `json:"failed_list"`        // 失败事件列表
	AIEnabled        bool                           `json:"ai_enabled"`         // 是否启用AI汇总
	AIPromptTemplate string                         `json:"ai_prompt_template"` // AI提示模板
}

SummaryMsg 巡检记录汇总信息结构体 用于替代原来的 map[string]any 返回类型，提供类型安全和更好的性能

type TaskManager added in v0.0.173 

type TaskManager struct {
	// contains filtered or unexported fields
}

TaskManager 任务管理

func NewTaskManager added in v0.0.173 

func NewTaskManager() *TaskManager

func (*TaskManager) Add added in v0.0.173 

func (tm *TaskManager) Add(name, spec string, jobFunc func(ctx context.Context)) error

Add 新增任务，name 用于后续管理

func (*TaskManager) Remove added in v0.0.173 

func (tm *TaskManager) Remove(name string)

Remove 删除任务（不会中断正在运行的 job，但会 cancel 长任务）

func (*TaskManager) Start added in v0.0.173 

func (tm *TaskManager) Start()

func (*TaskManager) Stop added in v0.0.173 

func (tm *TaskManager) Stop() context.Context

func (*TaskManager) Update added in v0.0.173 

func (tm *TaskManager) Update(name, spec string, jobFunc func(ctx context.Context)) error

Update = Remove + Add（立即生效），如果需要立刻触发一次可以在 Add 后主动 go jobFunc(ctx)

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.