Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
func NewMetaAlarmEventProcessor ¶
func NewMetaAlarmEventProcessor( dbClient mongo.DbClient, adapter libalarm.Adapter, ruleAdapter correlation.RulesAdapter, alarmStatusService alarmstatus.Service, alarmConfigProvider config.AlarmConfigProvider, encoder encoding.Encoder, amqpPublisher libamqp.Publisher, metricsSender metrics.Sender, metaAlarmStatesService correlation.MetaAlarmStateService, templateExecutor template.Executor, eventGenerator libevent.Generator, logger zerolog.Logger, ) libalarm.MetaAlarmEventProcessor
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, metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor, metricsSender metrics.Sender, eventStatisticsSender statistics.EventStatisticsSender, remediationRpcClient libengine.RPCClient, externalTagUpdater alarmtag.ExternalUpdater, internalTagAlarmMatcher alarmtag.InternalTagAlarmMatcher, amqpPublisher amqp.Publisher, eventGenerator libevent.Generator, logger zerolog.Logger, ) event.Processor
type MessageProcessor ¶
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
Source Files ¶
- clean_external_tag_periodical_worker.go
- default.go
- external_tag_periodical_worker.go
- idle_since_periodical_worker.go
- internal_tag_periodical_worker.go
- message_processor.go
- meta_alarm_event_processor.go
- periodical_worker.go
- reload_local_cache_periodical_worker.go
- resolved_archiver_worker.go
- rpc_message_processor.go
- rpc_pbehavior_client_message_processor.go
Click to show internal directories.
Click to hide internal directories.