rules

Documentation

Index

• Variables
• func NewRuleFactory(hf mechanisms.Factory, conf *config.Configuration, mode config.OperationMode, ...) (rule.Factory, error)
• func NewRuleSetProcessor(queue event.RuleSetChangedEventQueue, factory rule.Factory, ...) rule.SetProcessor
• type CheckFunc
• type UpstreamURLFactory

Variables

var ErrUnsupportedRuleSetVersion = errors.New("unsupported rule set version")

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

type CheckFunc

type CheckFunc func() error

type UpstreamURLFactory

type UpstreamURLFactory interface {
	CreateURL(from *url.URL) *url.URL
}