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 }, 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 ¶
Source Files ¶
- cel_execution_condition.go
- composite_error_handler.go
- composite_subject_creator.go
- composite_subject_handler.go
- conditional_subject_handler.go
- default_execution_condition.go
- error_handler.go
- execution_condition.go
- module.go
- repository_impl.go
- rule_factory_impl.go
- rule_impl.go
- ruleset_processor_impl.go
- subject_creator.go
- subject_handler.go
Click to show internal directories.
Click to hide internal directories.