rules

package
v0.14.0-alpha Latest Latest
Warning

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

Go to latest
Published: Apr 2, 2024 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrUnsupportedRuleSetVersion = errors.New("unsupported rule set version")
View Source
var Module = fx.Options(
	fx.Provide(
		fx.Annotate(
			func(logger zerolog.Logger) event.RuleSetChangedEventQueue {
				logger.Debug().Msg("Creating rule set event queue.")

				return make(event.RuleSetChangedEventQueue, defaultQueueSize)
			},
			fx.OnStop(
				func(queue event.RuleSetChangedEventQueue, logger zerolog.Logger) {
					logger.Debug().Msg("Closing rule set event queue")

					close(queue)
				},
			),
		),
		NewRuleFactory,
		fx.Annotate(
			newRepository,
			fx.OnStart(func(ctx context.Context, o *repository) error { return o.Start(ctx) }),
			fx.OnStop(func(ctx context.Context, o *repository) error { return o.Stop(ctx) }),
		),
		func(r *repository) rule.Repository { return r },
		newRuleExecutor,
		NewRuleSetProcessor,
	),
	provider.Module,
)

Module is invoked on app bootstrapping. nolint: gochecknoglobals

Functions

func NewRuleFactory

func NewRuleFactory(
	hf mechanisms.Factory,
	conf *config.Configuration,
	mode config.OperationMode,
	logger zerolog.Logger,
) (rule.Factory, error)

func NewRuleSetProcessor

func NewRuleSetProcessor(
	queue event.RuleSetChangedEventQueue, factory rule.Factory, logger zerolog.Logger,
) rule.SetProcessor

Types

type CheckFunc

type CheckFunc func() error

Jump to

Keyboard shortcuts

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