engine

package

v0.1.6 Latest Latest Go to latest Published: Mar 19, 2026 License: AGPL-3.0 Imports: 13 Imported by: 0

Details

This section is empty.

View Source

var Events = &EventCache{records: make(map[string]*types.Event)}

View Source

var (
	FromAgent = "unknown"
)

func PushRawEvents(pluginName string, pluginObj plugins.Plugin, ins plugins.Instance, queue *safe.Queue[*types.Event])

type EventCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

这里不需要定期清理，原因： 1. 内存里的事件数量不大 2. 有些事件就是很久才恢复，恢复的时候如果发现之前告警的事件已经被清理了，就无法生成恢复事件了

func (c *EventCache) Del(key string)

func (c *EventCache) Get(key string) *types.Event

func (c *EventCache) Set(val *types.Event)