Package | Description |
---|---|
org.openecomp.dcae.apod.analytics.tca.persistance | |
org.openecomp.dcae.apod.analytics.tca.processor | |
org.openecomp.dcae.apod.analytics.tca.utils |
Modifier and Type | Method and Description |
---|---|
static void |
TCAMessageStatusPersister.persist(TCACEFProcessorContext processorContext,
co.cask.cdap.api.flow.flowlet.FlowletContext flowletContext,
TCACalculatorMessageType calculatorMessageType,
co.cask.cdap.api.dataset.lib.ObjectMappedTable<TCAMessageStatusEntity> messageStatusTable)
Saves Message Status in Table.
|
static void |
TCAMessageStatusPersister.persist(TCACEFProcessorContext processorContext,
co.cask.cdap.api.flow.flowlet.FlowletContext flowletContext,
TCACalculatorMessageType calculatorMessageType,
co.cask.cdap.api.dataset.lib.ObjectMappedTable<TCAMessageStatusEntity> messageStatusTable,
String alertMessage)
Saves Message Status in Table.
|
Modifier and Type | Method and Description |
---|---|
TCACEFProcessorContext |
AbstractTCAECEFPolicyProcessor.preProcessor(TCACEFProcessorContext processorContext)
For all TCA Policy Processor the pre processor ensures that
EventListener object is
present |
TCACEFProcessorContext |
TCACEFPolicyThresholdsProcessor.preProcessor(TCACEFProcessorContext processorContext) |
TCACEFProcessorContext |
TCACEFPolicyDomainFilter.processMessage(TCACEFProcessorContext processorContext) |
TCACEFProcessorContext |
TCACEFJsonProcessor.processMessage(TCACEFProcessorContext processorContext) |
TCACEFProcessorContext |
TCACEFPolicyThresholdsProcessor.processMessage(TCACEFProcessorContext processorContext) |
TCACEFProcessorContext |
TCACEFPolicyFunctionalRoleFilter.processMessage(TCACEFProcessorContext processorContext) |
Modifier and Type | Method and Description |
---|---|
TCACEFProcessorContext |
AbstractTCAECEFPolicyProcessor.preProcessor(TCACEFProcessorContext processorContext)
For all TCA Policy Processor the pre processor ensures that
EventListener object is
present |
TCACEFProcessorContext |
TCACEFPolicyThresholdsProcessor.preProcessor(TCACEFProcessorContext processorContext) |
TCACEFProcessorContext |
TCACEFPolicyDomainFilter.processMessage(TCACEFProcessorContext processorContext) |
TCACEFProcessorContext |
TCACEFJsonProcessor.processMessage(TCACEFProcessorContext processorContext) |
TCACEFProcessorContext |
TCACEFPolicyThresholdsProcessor.processMessage(TCACEFProcessorContext processorContext) |
TCACEFProcessorContext |
TCACEFPolicyFunctionalRoleFilter.processMessage(TCACEFProcessorContext processorContext) |
Modifier and Type | Method and Description |
---|---|
static TCACEFProcessorContext |
TCAUtils.computeThresholdViolations(TCACEFProcessorContext processorContext)
Computes threshold violations
|
static TCACEFProcessorContext |
TCAUtils.filterCEFMessage(String cefMessage,
org.openecomp.dcae.apod.analytics.model.domain.policy.tca.TCAPolicy tcaPolicy)
Creates a
GenericMessageChainProcessor of TCACEFJsonProcessor ,
TCACEFPolicyDomainFilter and TCACEFPolicyFunctionalRoleFilter s to
filter out messages which does not match policy domain or functional role |
Modifier and Type | Method and Description |
---|---|
static TCACEFProcessorContext |
TCAUtils.computeThresholdViolations(TCACEFProcessorContext processorContext)
Computes threshold violations
|
static org.openecomp.dcae.apod.analytics.model.facade.tca.TCAVESResponse |
TCAUtils.createNewTCAVESResponse(TCACEFProcessorContext processorContext,
String tcaAppName)
Creates
TCAVESResponse object |
static org.apache.commons.lang3.tuple.Pair<String,String> |
TCAUtils.getDomainAndFunctionalRole(TCACEFProcessorContext processorContext)
Extract Domain and functional Role from processor context if present
|
Copyright © 2017. All rights reserved.