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

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,
	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
	PublishToQueue           string
	FifoAckExchange          string
	PeriodicalWaitTime       time.Duration
	TagsPeriodicalWaitTime   time.Duration
	SliPeriodicalWaitTime    time.Duration
	RecomputeAllOnInit       bool
	Workers                  int
}

func ParseOptions

func ParseOptions() Options