worker

package

v0.26.2 Latest Latest Go to latest Published: Jan 10, 2026 License: MIT Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

EventWorker 中文函数注释：事件处理Worker。

func Instance() *EventWorker

Instance 中文函数注释：获取全局事件处理Worker实例。

func NewEventWorker() *EventWorker

NewEventWorker 中文函数注释：创建事件处理Worker。

func (w *EventWorker) Start()

Start 中文函数注释：启动Worker。

func (w *EventWorker) Stop()

Stop 中文函数注释：无论当前配置开关状态如何，均立即停止事件处理循环并等待退出。

func (w *EventWorker) UpdateConfig()

UpdateConfig 中文函数注释：动态刷新事件处理配置（从数据库重新加载）。

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

RuleMatcher 中文函数注释：事件规则匹配器。

func NewRuleMatcher(clusterRules map[string]config.RuleConfig) *RuleMatcher

NewRuleMatcher 中文函数注释：创建匹配器。

func (m *RuleMatcher) Match(event *models.K8sEvent) bool

Match 中文函数注释：判断事件是否命中指定集群规则。