event

package
v0.0.0-...-9b5cd94 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 5, 2024 License: AGPL-3.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AutoInstructionMatcher 

type AutoInstructionMatcher interface {
	Load(ctx context.Context) error
	Match(triggers []string, alarmWithEntity types.AlarmWithEntity) (bool, error)
}

func NewNullAutoInstructionMatcher 

func NewNullAutoInstructionMatcher() AutoInstructionMatcher

type Processor 

type Processor interface {
	Process(ctx context.Context, event rpc.AxeEvent) (Result, error)
}

func NewAckProcessor 

func NewAckProcessor(
	client mongo.DbClient,
	configProvider config.AlarmConfigProvider,
	entityServiceCountersCalculator calculator.EntityServiceCountersCalculator,
	eventsSender entitycounters.EventsSender,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	metricsSender metrics.Sender,
	logger zerolog.Logger,
) Processor

func NewAckRemoveProcessor 

func NewAckRemoveProcessor(
	client mongo.DbClient,
	configProvider config.AlarmConfigProvider,
	entityServiceCountersCalculator calculator.EntityServiceCountersCalculator,
	eventsSender entitycounters.EventsSender,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	metricsSender metrics.Sender,
	logger zerolog.Logger,
) Processor

func NewActivateProcessor 

func NewActivateProcessor(
	client mongo.DbClient,
	autoInstructionMatcher AutoInstructionMatcher,
	remediationRpcClient engine.RPCClient,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewAssocTicketProcessor 

func NewAssocTicketProcessor(
	client mongo.DbClient,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	metricsSender metrics.Sender,
	logger zerolog.Logger,
) Processor

func NewAutoInstructionActivateProcessor 

func NewAutoInstructionActivateProcessor(
	client mongo.DbClient,
) Processor

func NewAutoWebhookCompleteProcessor 

func NewAutoWebhookCompleteProcessor(
	client mongo.DbClient,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	metricsSender metrics.Sender,
	logger zerolog.Logger,
) Processor

func NewAutoWebhookFailProcessor 

func NewAutoWebhookFailProcessor(
	client mongo.DbClient,
) Processor

func NewAutoWebhookStartProcessor 

func NewAutoWebhookStartProcessor(
	client mongo.DbClient,
) Processor

func NewCancelProcessor 

func NewCancelProcessor(
	client mongo.DbClient,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	logger zerolog.Logger,
) Processor

func NewChangeStateProcessor 

func NewChangeStateProcessor(
	client mongo.DbClient,
	alarmConfigProvider config.AlarmConfigProvider,
	userInterfaceConfigProvider config.UserInterfaceConfigProvider,
	alarmStatusService alarmstatus.Service,
	autoInstructionMatcher AutoInstructionMatcher,
	entityServiceCountersCalculator calculator.EntityServiceCountersCalculator,
	componentCountersCalculator calculator.ComponentCountersCalculator,
	eventsSender entitycounters.EventsSender,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	metricsSender metrics.Sender,
	remediationRpcClient engine.RPCClient,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewCheckProcessor 

func NewCheckProcessor(
	client mongo.DbClient,
	alarmConfigProvider config.AlarmConfigProvider,
	alarmStatusService alarmstatus.Service,
	pbhTypeResolver pbehavior.EntityTypeResolver,
	autoInstructionMatcher AutoInstructionMatcher,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	metricsSender metrics.Sender,
	eventStatisticsSender statistics.EventStatisticsSender,
	remediationRpcClient engine.RPCClient,
	externalTagUpdater alarmtag.ExternalUpdater,
	internalTagAlarmMatcher alarmtag.InternalTagAlarmMatcher,
	entityServiceCountersCalculator calculator.EntityServiceCountersCalculator,
	componentCountersCalculator calculator.ComponentCountersCalculator,
	eventsSender entitycounters.EventsSender,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewCombinedProcessor 

func NewCombinedProcessor(container ProcessorContainer) Processor

func NewCommentProcessor 

func NewCommentProcessor(
	client mongo.DbClient,
	configProvider config.AlarmConfigProvider,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	logger zerolog.Logger,
) Processor

func NewDeclareTicketWebhookProcessor 

func NewDeclareTicketWebhookProcessor(
	client mongo.DbClient,
	metricsSender metrics.Sender,
	amqpPublisher libamqp.Publisher,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewEntityToggledProcessor 

func NewEntityToggledProcessor(
	dbClient mongo.DbClient,
	entityServiceCountersCalculator calculator.EntityServiceCountersCalculator,
	componentCountersCalculator calculator.ComponentCountersCalculator,
	eventsSender entitycounters.EventsSender,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	metricsSender metrics.Sender,
	remediationRpcClient engine.RPCClient,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewEntityUpdatedProcessor 

func NewEntityUpdatedProcessor(
	dbClient mongo.DbClient,
	entityServiceCountersCalculator calculator.EntityServiceCountersCalculator,
	componentCountersCalculator calculator.ComponentCountersCalculator,
	eventsSender entitycounters.EventsSender,
) Processor

func NewForwardProcessor 

func NewForwardProcessor() Processor

func NewForwardWithAlarmProcessor 

func NewForwardWithAlarmProcessor(
	client mongo.DbClient,
) Processor

func NewInstructionProcessor 

func NewInstructionProcessor(
	client mongo.DbClient,
	metricsSender metrics.Sender,
	amqpPublisher libamqp.Publisher,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewJunitProcessor 

func NewJunitProcessor(
	client mongo.DbClient,
) Processor

func NewMetaAlarmAttachProcessor 

func NewMetaAlarmAttachProcessor(
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	metricsSender metrics.Sender,
	encoder encoding.Encoder,
	amqpPublisher libamqp.Publisher,
	logger zerolog.Logger,
) Processor

func NewMetaAlarmChildActivateProcessor 

func NewMetaAlarmChildActivateProcessor(
	client mongo.DbClient,
) Processor

func NewMetaAlarmChildDeactivateProcessor 

func NewMetaAlarmChildDeactivateProcessor(
	client mongo.DbClient,
) Processor

func NewMetaAlarmDetachProcessor 

func NewMetaAlarmDetachProcessor(
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
) Processor

func NewMetaAlarmProcessor 

func NewMetaAlarmProcessor(
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	autoInstructionMatcher AutoInstructionMatcher,
	metricsSender metrics.Sender,
	remediationRpcClient engine.RPCClient,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewNoEventsProcessor 

func NewNoEventsProcessor(
	client mongo.DbClient,
	alarmConfigProvider config.AlarmConfigProvider,
	alarmStatusService alarmstatus.Service,
	pbhTypeResolver pbehavior.EntityTypeResolver,
	autoInstructionMatcher AutoInstructionMatcher,
	entityServiceCountersCalculator calculator.EntityServiceCountersCalculator,
	componentCountersCalculator calculator.ComponentCountersCalculator,
	eventsSender entitycounters.EventsSender,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	metricsSender metrics.Sender,
	remediationRpcClient engine.RPCClient,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewPbhEnterProcessor 

func NewPbhEnterProcessor(
	client mongo.DbClient,
	autoInstructionMatcher AutoInstructionMatcher,
	entityServiceCountersCalculator calculator.EntityServiceCountersCalculator,
	componentCountersCalculator calculator.ComponentCountersCalculator,
	eventsSender entitycounters.EventsSender,
	metricsSender metrics.Sender,
	remediationRpcClient engine.RPCClient,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewPbhLeaveAndEnterProcessor 

func NewPbhLeaveAndEnterProcessor(
	client mongo.DbClient,
	autoInstructionMatcher AutoInstructionMatcher,
	entityServiceCountersCalculator calculator.EntityServiceCountersCalculator,
	componentCountersCalculator calculator.ComponentCountersCalculator,
	eventsSender entitycounters.EventsSender,
	metricsSender metrics.Sender,
	remediationRpcClient engine.RPCClient,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewPbhLeaveProcessor 

func NewPbhLeaveProcessor(
	client mongo.DbClient,
	autoInstructionMatcher AutoInstructionMatcher,
	entityServiceCountersCalculator calculator.EntityServiceCountersCalculator,
	componentCountersCalculator calculator.ComponentCountersCalculator,
	eventsSender entitycounters.EventsSender,
	metricsSender metrics.Sender,
	remediationRpcClient engine.RPCClient,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewRecomputeEntityServiceProcessor 

func NewRecomputeEntityServiceProcessor(
	dbClient mongo.DbClient,
	entityServiceCountersCalculator calculator.EntityServiceCountersCalculator,
	componentCountersCalculator calculator.ComponentCountersCalculator,
	eventsSender entitycounters.EventsSender,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	metricsSender metrics.Sender,
	remediationRpcClient engine.RPCClient,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewResolveCancelProcessor 

func NewResolveCancelProcessor(
	dbClient mongo.DbClient,
	entityServiceCountersCalculator calculator.EntityServiceCountersCalculator,
	componentCountersCalculator calculator.ComponentCountersCalculator,
	eventsSender entitycounters.EventsSender,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	metricsSender metrics.Sender,
	remediationRpcClient engine.RPCClient,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewResolveCloseProcessor 

func NewResolveCloseProcessor(
	dbClient mongo.DbClient,
	entityServiceCountersCalculator calculator.EntityServiceCountersCalculator,
	componentCountersCalculator calculator.ComponentCountersCalculator,
	eventsSender entitycounters.EventsSender,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	metricsSender metrics.Sender,
	remediationRpcClient engine.RPCClient,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewResolveDeletedProcessor 

func NewResolveDeletedProcessor(
	dbClient mongo.DbClient,
	entityServiceCountersCalculator calculator.EntityServiceCountersCalculator,
	componentCountersCalculator calculator.ComponentCountersCalculator,
	eventsSender entitycounters.EventsSender,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	metricsSender metrics.Sender,
	remediationRpcClient engine.RPCClient,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewSnoozeProcessor 

func NewSnoozeProcessor(
	client mongo.DbClient,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	logger zerolog.Logger,
) Processor

func NewTriggerProcessor 

func NewTriggerProcessor(
	client mongo.DbClient,
) Processor

func NewUncancelProcessor 

func NewUncancelProcessor(
	dbClient mongo.DbClient,
	alarmStatusService alarmstatus.Service,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	logger zerolog.Logger,
) Processor

func NewUnsnoozeProcessor 

func NewUnsnoozeProcessor(
	client mongo.DbClient,
	autoInstructionMatcher AutoInstructionMatcher,
	remediationRpcClient engine.RPCClient,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewUpdateCountersProcessor 

func NewUpdateCountersProcessor(
	dbClient mongo.DbClient,
	entityServiceCountersCalculator calculator.EntityServiceCountersCalculator,
	eventsSender entitycounters.EventsSender,
) Processor

func NewUpdateStatusProcessor 

func NewUpdateStatusProcessor(
	dbClient mongo.DbClient,
	alarmStatusService alarmstatus.Service,
	configProvider config.AlarmConfigProvider,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	logger zerolog.Logger,
) Processor

func NewWebhookCompleteProcessor 

func NewWebhookCompleteProcessor(
	client mongo.DbClient,
	metaAlarmEventProcessor libalarm.MetaAlarmEventProcessor,
	metricsSender metrics.Sender,
	amqpPublisher libamqp.Publisher,
	encoder encoding.Encoder,
	logger zerolog.Logger,
) Processor

func NewWebhookFailProcessor 

func NewWebhookFailProcessor(
	client mongo.DbClient,
) Processor

func NewWebhookStartProcessor 

func NewWebhookStartProcessor(
	client mongo.DbClient,
) Processor

type ProcessorContainer 

type ProcessorContainer interface {
	Get(eventType string) (Processor, bool)
	Set(eventType string, p Processor)
	Has(eventType string) bool
}

func NewProcessorContainer 

func NewProcessorContainer() ProcessorContainer

type Result 

type Result struct {
	Alarm       types.Alarm
	Entity      types.Entity
	AlarmChange types.AlarmChange

	Forward              bool
	IsInstructionMatched bool
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.