axe

Documentation

Index

• func NewEngine(ctx context.Context, options Options, dbClient mongo.DbClient, ...) libengine.Engine
• type DependencyMaker
  • func (m DependencyMaker) EventProcessor(dbClient mongo.DbClient, alarmConfigProvider config.AlarmConfigProvider, ...) event.Processor
• type MessageProcessor
  • func (p *MessageProcessor) Process(parentCtx context.Context, d amqp.Delivery) ([]byte, error)
• type Options
  • func ParseOptions() (Options, []string)

Functions

func NewEngine

func NewEngine(
	ctx context.Context,
	options Options,
	dbClient mongo.DbClient,
	amqpConnection amqp.Connection,
	cfg config.CanopsisConf,
	metricsSender metrics.Sender,
	autoInstructionMatcher event.AutoInstructionMatcher,
	remediationRpcClient libengine.RPCClient,
	dynamicInfosRpcClient libengine.RPCClient,
	rpcPublishQueues []string,
	publishQueuePrefix string,
	logger zerolog.Logger,
) libengine.Engine

Types

type DependencyMaker

type DependencyMaker struct {
	depmake.DependencyMaker
}

func (DependencyMaker) EventProcessor

func (m DependencyMaker) EventProcessor(
	dbClient mongo.DbClient,
	alarmConfigProvider config.AlarmConfigProvider,
	userInterfaceConfigProvider config.UserInterfaceConfigProvider,
	alarmStatusService alarmstatus.Service,
	pbhTypeResolver pbehavior.EntityTypeResolver,
	autoInstructionMatcher event.AutoInstructionMatcher,
	entityServiceCountersCalculator calculator.EntityServiceCountersCalculator,
	componentCountersCalculator calculator.ComponentCountersCalculator,
	eventsSender entitycounters.EventsSender,
	metaAlarmPostProcessor event.MetaAlarmPostProcessor,
	metaAlarmStatesService correlation.MetaAlarmStateService,
	metricsSender metrics.Sender,
	eventStatisticsSender statistics.EventStatisticsSender,
	remediationRpcClient libengine.RPCClient,
	externalTagUpdater alarmtag.ExternalUpdater,
	internalTagAlarmMatcher alarmtag.InternalTagAlarmMatcher,
	amqpPublisher amqp.Publisher,
	eventGenerator libevent.Generator,
	templateExecutor template.Executor,
	logger zerolog.Logger,
) event.Processor

type MessageProcessor

type MessageProcessor struct {
	FeaturePrintEventOnError bool

	EventProcessor    libevent.Processor
	Encoder           encoding.Encoder
	Decoder           encoding.Decoder
	TechMetricsSender techmetrics.Sender
	AlarmCollection   mongo.DbCollection
	Logger            zerolog.Logger
}

func (*MessageProcessor) Process

func (p *MessageProcessor) Process(parentCtx context.Context, d amqp.Delivery) ([]byte, error)

type Options

type Options struct {
	Version                          bool
	FeaturePrintEventOnError         bool
	ModeDebug                        bool
	FifoAckExchange                  string
	PeriodicalWaitTime               time.Duration
	TagsPeriodicalWaitTime           time.Duration
	SliPeriodicalWaitTime            time.Duration
	SoftDeleteCorrPeriodicalWaitTime time.Duration
	ExternalWorkers                  int
	SystemWorkers                    int
	UserWorkers                      int
	RpcWorkers                       int
	RecomputeAllOnInit               bool
}

func ParseOptions

func ParseOptions() (Options, []string)