eventqueue

Nov 1, 2022

Changes in this version

+ type Event struct

+ EventType rules.EventType

+ Objects []*unstructured.Unstructured

+ RuleID rules.RuleID

+ type EventQueue struct

+ func New(executor QueueExecutor, queueOpts Opts) *EventQueue

+ func (eq *EventQueue) StartQueueWorkerPool()

+ type Opts struct

+ MaxTryCount int

+ RequeueDelay time.Duration

+ WorkerCount int

+ type QueueExecutor interface

+ Execute func(event *Event) error