ruler

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 23, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Directories

Path Synopsis
sinks

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL