event

Documentation

Index

• type Processor
  • func NewComponentProcessor(dbClient libmongo.DbClient, contextGraphManager contextgraph.Manager, ...) Processor
  • func NewConnectorProcessor(dbClient libmongo.DbClient, contextGraphManager contextgraph.Manager, ...) Processor
  • func NewMetaAlarmProcessor() Processor
  • func NewResourceProcessor(dbClient libmongo.DbClient, contextGraphManager contextgraph.Manager, ...) Processor
  • func NewServiceProcessor(dbClient libmongo.DbClient, contextGraphManager contextgraph.Manager, ...) Processor
• type ProcessorContainer
  • func NewProcessorContainer() ProcessorContainer

Types

type Processor

type Processor interface {
	Process(ctx context.Context, event *types.Event) (
		[]types.Entity,
		[]string,
		techmetrics.CheEventMetric,
		error,
	)
}

func NewComponentProcessor

func NewComponentProcessor(
	dbClient libmongo.DbClient,
	contextGraphManager contextgraph.Manager,
	eventFilterService eventfilter.Service,
) Processor

func NewConnectorProcessor

func NewConnectorProcessor(
	dbClient libmongo.DbClient,
	contextGraphManager contextgraph.Manager,
	eventFilterService eventfilter.Service,
) Processor

func NewMetaAlarmProcessor

func NewMetaAlarmProcessor() Processor

func NewResourceProcessor

func NewResourceProcessor(
	dbClient libmongo.DbClient,
	contextGraphManager contextgraph.Manager,
	eventFilterService eventfilter.Service,
) Processor

func NewServiceProcessor

func NewServiceProcessor(
	dbClient libmongo.DbClient,
	contextGraphManager contextgraph.Manager,
	eventFilterService eventfilter.Service,
) 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