Versions in this module Expand all Collapse all v0 v0.6.0 Sep 19, 2019 v0.1.0 Sep 6, 2019 Changes in this version + var ErrQueueEmpty = fmt.Errorf("rule queue is empty") + type Entry struct + FSM *fsm.FSM + LastCheckTime time.Time + Rule rule.Rule + Spec v1alpha1.AutopilotRule + type RuleQueue interface + Dequeue func() (*Entry, error) + DequeueByUUID func(uuid string) (*Entry, error) + Enqueue func(e *Entry) + GetByUUID func(uuid string) (*Entry, error) + Len func() int + func NewRuleQueue() RuleQueue
Go to main page