ruler

Documentation

Index

• type KubeEventsRuler
  • func NewKubeEventsRuler(cfg *rest.Config, taskPool *ants.Pool) *KubeEventsRuler
  • func (r *KubeEventsRuler) AddEvents(evts []*types.Event)
  • func (r *KubeEventsRuler) ReloadConfig(c *config.RulerConfig) error
  • func (r *KubeEventsRuler) Run(ctx context.Context) error
• type RuleCache
  • func NewRuleCache(kcfg *rest.Config, rcfg *config.RulerConfig) (*RuleCache, error)
  • func (c *RuleCache) GetRules(ctx context.Context, evt *types.Event) (rules []*v1alpha1.Rule)
  • func (c *RuleCache) Run(ctx context.Context) error

Types

type KubeEventsRuler

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

func NewKubeEventsRuler

func NewKubeEventsRuler(cfg *rest.Config, taskPool *ants.Pool) *KubeEventsRuler

func (*KubeEventsRuler) AddEvents

func (r *KubeEventsRuler) AddEvents(evts []*types.Event)

func (*KubeEventsRuler) ReloadConfig

func (r *KubeEventsRuler) ReloadConfig(c *config.RulerConfig) error

func (*KubeEventsRuler) Run

func (r *KubeEventsRuler) Run(ctx context.Context) error

type RuleCache

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

func NewRuleCache

func NewRuleCache(kcfg *rest.Config, rcfg *config.RulerConfig) (*RuleCache, error)

func (*RuleCache) GetRules

func (c *RuleCache) GetRules(ctx context.Context, evt *types.Event) (rules []*v1alpha1.Rule)

func (*RuleCache) Run

func (c *RuleCache) Run(ctx context.Context) error