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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.