A C E F G I M O P R S T U V W

A

AbstractTCAECEFPolicyProcessor - Class in org.openecomp.dcae.apod.analytics.tca.processor

Encapsulates common functionality for all TCA CEF Policy Processors

AbstractTCAECEFPolicyProcessor() - Constructor for class org.openecomp.dcae.apod.analytics.tca.processor.AbstractTCAECEFPolicyProcessor

apply(TCAAppPreferences) - Method in class org.openecomp.dcae.apod.analytics.tca.utils.AppPreferencesToPublisherConfigMapper

apply(TCAAppPreferences) - Method in class org.openecomp.dcae.apod.analytics.tca.utils.AppPreferencesToSubscriberConfigMapper

AppPreferencesToPublisherConfigMapper - Class in org.openecomp.dcae.apod.analytics.tca.utils

Function which translates TCAAppPreferences to DMaaPMRPublisherConfig

AppPreferencesToPublisherConfigMapper() - Constructor for class org.openecomp.dcae.apod.analytics.tca.utils.AppPreferencesToPublisherConfigMapper

AppPreferencesToSubscriberConfigMapper - Class in org.openecomp.dcae.apod.analytics.tca.utils

Function which translates TCAAppPreferences to DMaaPMRSubscriberConfig

AppPreferencesToSubscriberConfigMapper() - Constructor for class org.openecomp.dcae.apod.analytics.tca.utils.AppPreferencesToSubscriberConfigMapper

C

computeThresholdViolations(TCACEFProcessorContext) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Computes threshold violations

configure() - Method in class org.openecomp.dcae.apod.analytics.tca.flow.TCAVESCollectorFlow

configure() - Method in class org.openecomp.dcae.apod.analytics.tca.flowlet.TCAVESAlertsSinkFlowlet

configure() - Method in class org.openecomp.dcae.apod.analytics.tca.flowlet.TCAVESMessageRouterFlowlet

configure() - Method in class org.openecomp.dcae.apod.analytics.tca.flowlet.TCAVESThresholdViolationCalculatorFlowlet

configure() - Method in class org.openecomp.dcae.apod.analytics.tca.TCAAnalyticsApplication

configure() - Method in class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPMockSubscriberWorker

configure() - Method in class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPPublisherWorker

configure() - Method in class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPSubscriberWorker

createNewMetricsPerFunctionalRole(Map.Entry<String, Map<String, String>>) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Create new MetricsPerFunctionalRole instance with policy Name, policy Version and policy Scope extracted from given functionalRolesEntry

createNewTCAVESResponse(TCACEFProcessorContext, String) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Creates TCAVESResponse object

createNewThreshold(Map<String, String>) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Creates new instance of TCA Policy Threshold with values extracted from thresholdMap

createRowKey(Date) - Static method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAVESAlertsPersister

Creates Row Key for Alerts Table

createTCAPolicyMetricsPerFunctionalRoleList(Map<String, Map<String, String>>) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Creates TCAPolicy Metrics per Functional Role list

createViolatedMetrics(TCAPolicy, Threshold, String) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Creates MetricsPerFunctionalRole object which contains violated thresholds

E

execute(JobExecutionContext) - Method in class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPMRPublisherJob

execute(JobExecutionContext) - Method in class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPMRSubscriberJob

extractAlertFromAlertEntities(Collection<TCAVESAlertEntity>) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Extracts alert message strings from TCAVESAlertEntity

extractSubTree(Map<String, String>, int, int, String) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Converts a flattened key/value map which has keys delimited by a given delimiter.

F

filterCEFMessage(String, TCAPolicy) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Creates a GenericMessageChainProcessor of TCACEFJsonProcessor, TCACEFPolicyDomainFilter and TCACEFPolicyFunctionalRoleFilters to filter out messages which does not match policy domain or functional role

filterMapByKeyNamePrefix(Map<String, String>, String) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Provides a view of underlying map that filters out entries with keys starting with give prefix

filterVESMessages(String) - Method in class org.openecomp.dcae.apod.analytics.tca.flowlet.TCAVESThresholdViolationCalculatorFlowlet

G

getAlertMessage() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getAlertMessage() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAVESAlertEntity

getCEFEventListener() - Method in class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFProcessorContext

Returns Common Event Format EventListener if present else null

getCreationTS() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getCreationTS() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAVESAlertEntity

getDatasetProperties(int) - Static method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusPersister

Create TCA VES Message Status Table Properties

getDatasetProperties(int) - Static method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAVESAlertsPersister

Creates DatasetProperties for Alerts Table

getDomain() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getDomainAndFunctionalRole(TCACEFProcessorContext) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Extract Domain and functional Role from processor context if present

getDomainFilterMessage() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getDomainFilterStatus() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getFlowletInstance() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getFunctionalRole() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getFunctionalRoleFilterMessage() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getFunctionalRoleFilterStatus() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getJsonPathValue(String, Set<String>) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Extracts json path values for given json Field Paths from using Json path notation.

getJsonProcessorMessage() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getJsonProcessorStatus() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getMessageType() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getMetricsPerFunctionalRole() - Method in class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFProcessorContext

Returns TCA Policy MetricsPerFunctionalRole which was has violated Threshold for the CEF Message if present else null

getPolicyFRThresholdsTable(TCAPolicy) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Creates a Table to lookup thresholds of a TCAPolicy by its Functional Role and Threshold Field path

getPolicyFRThresholdsTableSupplier(TCAPolicy) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

A Supplier which caches Policy Functional Role and Threshold Field Path Thresholds lookup table

getPolicyFunctionalRoles(TCAPolicy) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Extracts TCAPolicy Functional Roles

getPolicyFunctionalRoleSupplier(TCAPolicy) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

A Supplier which caches TCAPolicy Functional Roles as they are not expected to change during runtime

getProcessorDescription() - Method in class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFJsonProcessor

getProcessorDescription() - Method in class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFPolicyDomainFilter

getProcessorDescription() - Method in class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFPolicyFunctionalRoleFilter

getProcessorDescription() - Method in class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFPolicyThresholdsProcessor

getPublisherContentType() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getPublisherHostName() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getPublisherHostPort() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getPublisherMaxBatchSize() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getPublisherMaxRecoveryQueueSize() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getPublisherPollingInterval() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getPublisherProtocol() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getPublisherTopicName() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getPublisherUserName() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getPublisherUserPassword() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getSubscriberConsumerGroup() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getSubscriberConsumerId() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getSubscriberContentType() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getSubscriberHostName() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getSubscriberHostPort() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getSubscriberMessageLimit() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getSubscriberPollingInterval() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getSubscriberProtocol() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getSubscriberTimeoutMS() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getSubscriberTopicName() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getSubscriberUserName() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getSubscriberUserPassword() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

getTCAPolicy() - Method in class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFProcessorContext

Returns TCAPolicy Object

getTcaSubscriberOutputStreamName() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppConfig

getTcaVESAlertsTableName() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppConfig

getTcaVESAlertsTableTTLSeconds() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppConfig

getTcaVESMessageStatusTableName() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppConfig

getTcaVESMessageStatusTableTTLSeconds() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppConfig

getThresholdCalculatorFlowletInstances() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppConfig

getThresholdCalculatorMessage() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getThresholdCalculatorStatus() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getThresholdDirection() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getThresholdPath() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getThresholdSeverity() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getThresholdValue() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

getValidatedTCAAppPreferences(RuntimeContext) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Parses and validates Runtime Arguments to TCAAppPreferences object

getValidatedTCAPolicyPreferences(RuntimeContext) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Converts Runtime Arguments to TCAPolicyPreferences object

getVesMessage() - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

I

initialize(FlowletContext) - Method in class org.openecomp.dcae.apod.analytics.tca.flowlet.TCAVESAlertsSinkFlowlet

initialize(FlowletContext) - Method in class org.openecomp.dcae.apod.analytics.tca.flowlet.TCAVESThresholdViolationCalculatorFlowlet

initialize(WorkerContext) - Method in class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPMockSubscriberWorker

initialize(WorkerContext) - Method in class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPPublisherWorker

initialize(WorkerContext) - Method in class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPSubscriberWorker

M

map(TCAAppPreferences) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.AppPreferencesToPublisherConfigMapper

map(TCAAppPreferences) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.AppPreferencesToSubscriberConfigMapper

MAP_ALERT_ENTITY_TO_ALERT_STRING_FUNCTION - Static variable in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Function that extracts alert message string from TCAVESAlertEntity

O

org.openecomp.dcae.apod.analytics.tca - package org.openecomp.dcae.apod.analytics.tca

org.openecomp.dcae.apod.analytics.tca.flow - package org.openecomp.dcae.apod.analytics.tca.flow

org.openecomp.dcae.apod.analytics.tca.flowlet - package org.openecomp.dcae.apod.analytics.tca.flowlet

org.openecomp.dcae.apod.analytics.tca.persistance - package org.openecomp.dcae.apod.analytics.tca.persistance

org.openecomp.dcae.apod.analytics.tca.processor - package org.openecomp.dcae.apod.analytics.tca.processor

org.openecomp.dcae.apod.analytics.tca.settings - package org.openecomp.dcae.apod.analytics.tca.settings

org.openecomp.dcae.apod.analytics.tca.utils - package org.openecomp.dcae.apod.analytics.tca.utils

org.openecomp.dcae.apod.analytics.tca.validator - package org.openecomp.dcae.apod.analytics.tca.validator

org.openecomp.dcae.apod.analytics.tca.worker - package org.openecomp.dcae.apod.analytics.tca.worker

P

persist(TCACEFProcessorContext, FlowletContext, TCACalculatorMessageType, ObjectMappedTable<TCAMessageStatusEntity>) - Static method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusPersister

Saves Message Status in Table.

persist(TCACEFProcessorContext, FlowletContext, TCACalculatorMessageType, ObjectMappedTable<TCAMessageStatusEntity>, String) - Static method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusPersister

Saves Message Status in Table.

persist(String, ObjectMappedTable<TCAVESAlertEntity>) - Static method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAVESAlertsPersister

Persists Alert Message to Alerts Table

preProcessor(TCACEFProcessorContext) - Method in class org.openecomp.dcae.apod.analytics.tca.processor.AbstractTCAECEFPolicyProcessor

For all TCA Policy Processor the pre processor ensures that EventListener object is present

preProcessor(TCACEFProcessorContext) - Method in class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFPolicyThresholdsProcessor

prioritizeThresholdViolations(Map<String, Threshold>) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Prioritize Threshold to be reported in case there was multiple TCA violations in a single CEF message.

processMessage(TCACEFProcessorContext) - Method in class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFJsonProcessor

processMessage(TCACEFProcessorContext) - Method in class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFPolicyDomainFilter

processMessage(TCACEFProcessorContext) - Method in class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFPolicyFunctionalRoleFilter

processMessage(TCACEFProcessorContext) - Method in class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFPolicyThresholdsProcessor

publisherContentType - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

publisherHostName - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

publisherHostPort - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

publisherMaxBatchSize - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

publisherMaxRecoveryQueueSize - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

publisherPollingInterval - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

publisherProtocol - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

publisherTopicName - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

publisherUserName - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

publisherUserPassword - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

R

readFields(DataInput) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

readFields(DataInput) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAVESAlertEntity

routeVESMessage(StreamEvent) - Method in class org.openecomp.dcae.apod.analytics.tca.flowlet.TCAVESMessageRouterFlowlet

run() - Method in class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPMockSubscriberWorker

run() - Method in class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPPublisherWorker

run() - Method in class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPSubscriberWorker

S

saveAlerts(String) - Method in class org.openecomp.dcae.apod.analytics.tca.flowlet.TCAVESAlertsSinkFlowlet

setAlertMessage(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setAlertMessage(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAVESAlertEntity

setCEFEventListener(EventListener) - Method in class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFProcessorContext

Sets new EventListener

setCreationTS(long) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setCreationTS(long) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAVESAlertEntity

setDomain(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setDomainFilterMessage(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setDomainFilterStatus(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setFlowletInstance(int) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setFunctionalRole(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setFunctionalRoleFilterMessage(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setFunctionalRoleFilterStatus(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setJsonProcessorMessage(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setJsonProcessorStatus(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setMessageType(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setMetricsPerFunctionalRole(MetricsPerFunctionalRole) - Method in class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFProcessorContext

Assign new TCA Policy MetricsPerFunctionalRole which was has violated Threshold for the CEF Message

setPublisherHostName(String) - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

setPublisherHostPort(Integer) - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

setPublisherProtocol(String) - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

setPublisherTopicName(String) - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

setPublisherUserName(String) - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

setPublisherUserPassword(String) - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

setSubscriberHostName(String) - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

setSubscriberHostPort(Integer) - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

setSubscriberProtocol(String) - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

setSubscriberTopicName(String) - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

setSubscriberUserName(String) - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

setSubscriberUserPassword(String) - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

setThresholdCalculatorMessage(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setThresholdCalculatorStatus(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setThresholdDirection(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setThresholdPath(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setThresholdSeverity(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setThresholdValue(Long) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

setVesMessage(String) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

stop() - Method in class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPMockSubscriberWorker

stop() - Method in class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPPublisherWorker

stop() - Method in class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPSubscriberWorker

subscriberConsumerGroup - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

subscriberConsumerId - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

subscriberContentType - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

subscriberHostName - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

subscriberHostPort - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

subscriberMessageLimit - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

subscriberPollingInterval - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

subscriberProtocol - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

subscriberTimeoutMS - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

subscriberTopicName - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

subscriberUserName - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

subscriberUserPassword - Variable in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

T

TCAAnalyticsApplication - Class in org.openecomp.dcae.apod.analytics.tca

TCAAnalyticsApplication() - Constructor for class org.openecomp.dcae.apod.analytics.tca.TCAAnalyticsApplication

TCAAppConfig - Class in org.openecomp.dcae.apod.analytics.tca.settings

Contains CDAP App Config Settings for TCA Application

TCAAppConfig() - Constructor for class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppConfig

TCAAppConfigValidator - Class in org.openecomp.dcae.apod.analytics.tca.validator

TCA App Config Validator validates any TCA App Config parameter values

TCAAppConfigValidator() - Constructor for class org.openecomp.dcae.apod.analytics.tca.validator.TCAAppConfigValidator

TCAAppPreferences - Class in org.openecomp.dcae.apod.analytics.tca.settings

App Preferences for Analytics TCA (Threshold Crossing Alert) App

TCAAppPreferences() - Constructor for class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

TCACalculatorMessageType - Enum in org.openecomp.dcae.apod.analytics.tca.persistance

TCA Calculator applies TCA Policy to incoming VES messages and classifies them as per this enum

TCACEFJsonProcessor - Class in org.openecomp.dcae.apod.analytics.tca.processor

Processor that converts incoming presumed JSON string CEF message to EventListener object
Pre Conditions: None

TCACEFJsonProcessor() - Constructor for class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFJsonProcessor

TCACEFPolicyDomainFilter - Class in org.openecomp.dcae.apod.analytics.tca.processor

TCA Processor which acts like a filter to filter out messages which does not belong to TCA Policy Domain
Pre Conditions: CEF Event Listener must be present

TCACEFPolicyDomainFilter() - Constructor for class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFPolicyDomainFilter

TCACEFPolicyFunctionalRoleFilter - Class in org.openecomp.dcae.apod.analytics.tca.processor

TCA Processor that acts like a filter to filter out messages which does not belong to TCA Policy Functional Roles
Pre Conditions: CEF Event Listener must be present

TCACEFPolicyFunctionalRoleFilter() - Constructor for class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFPolicyFunctionalRoleFilter

TCACEFPolicyThresholdsProcessor - Class in org.openecomp.dcae.apod.analytics.tca.processor

TCA CEF Policy Threshold processor
Pre Conditions: Domain and Functional Role must be present in CEF Event Listener Object

TCACEFPolicyThresholdsProcessor() - Constructor for class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFPolicyThresholdsProcessor

TCACEFProcessorContext - Class in org.openecomp.dcae.apod.analytics.tca.processor

TCA CEF Policy Processor Context

TCACEFProcessorContext(String, boolean, TCAPolicy) - Constructor for class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFProcessorContext

TCACEFProcessorContext(String, TCAPolicy) - Constructor for class org.openecomp.dcae.apod.analytics.tca.processor.TCACEFProcessorContext

TCADMaaPMockSubscriberWorker - Class in org.openecomp.dcae.apod.analytics.tca.worker

CDAP Worker which mocks fetching VES Messages from DMaaP MR topic.

TCADMaaPMockSubscriberWorker(String) - Constructor for class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPMockSubscriberWorker

TCADMaaPMRPublisherJob - Class in org.openecomp.dcae.apod.analytics.tca.worker

Quartz Job that will monitor any new alert messages in given TCA Alerts table and if any found publish them to DMaaP MR topic

TCADMaaPMRPublisherJob() - Constructor for class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPMRPublisherJob

TCADMaaPMRSubscriberJob - Class in org.openecomp.dcae.apod.analytics.tca.worker

Quartz Job which polls DMaaP MR VES Collector Topic for messages and writes them to a given CDAP Stream

TCADMaaPMRSubscriberJob() - Constructor for class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPMRSubscriberJob

TCADMaaPPublisherWorker - Class in org.openecomp.dcae.apod.analytics.tca.worker

TCA DMaaP Publisher will monitor alerts table at regular intervals and publish any alerts to DMaaP MR Publishing Topic

TCADMaaPPublisherWorker(String) - Constructor for class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPPublisherWorker

TCADMaaPSubscriberWorker - Class in org.openecomp.dcae.apod.analytics.tca.worker

TCA DMaaP Subscriber will read messages and post them to cdap stream at regular intervals

TCADMaaPSubscriberWorker(String) - Constructor for class org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPSubscriberWorker

tcaFunctionalRoleExtractorFunction() - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Function that extracts MetricsPerFunctionalRole.getFunctionalRole() from MetricsPerFunctionalRole

TCAMessageStatusEntity - Class in org.openecomp.dcae.apod.analytics.tca.persistance

TCA Message Status is an Entity which is used to persist TCA VES Message status information in Message Status Table

TCAMessageStatusEntity() - Constructor for class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

TCAMessageStatusEntity(long, int, String, String, String, String) - Constructor for class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

TCAMessageStatusEntity(long, int, String, String, String, String, String, String, String, Long, String, String, String, String, String, String, String, String, String) - Constructor for class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

TCAMessageStatusPersister - Class in org.openecomp.dcae.apod.analytics.tca.persistance

TCAMessageStatusPersister() - Constructor for class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusPersister

tcaPolicyMetricsExtractorFunction() - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Function that extracts TCAPolicy.getMetricsPerFunctionalRole() from TCAPolicy

TCAPolicyPreferences - Class in org.openecomp.dcae.apod.analytics.tca.settings

A wrapper over TCAPolicy to act as app Preferences as TCA Policy is passed by controller as runtime arguments from CDAP app preferences

TCAPolicyPreferences() - Constructor for class org.openecomp.dcae.apod.analytics.tca.settings.TCAPolicyPreferences

TCAPolicyPreferencesValidator - Class in org.openecomp.dcae.apod.analytics.tca.validator

Validates TCA Policy Preferences

TCAPolicyPreferencesValidator() - Constructor for class org.openecomp.dcae.apod.analytics.tca.validator.TCAPolicyPreferencesValidator

TCAPreferencesValidator - Class in org.openecomp.dcae.apod.analytics.tca.validator

TCAPreferencesValidator() - Constructor for class org.openecomp.dcae.apod.analytics.tca.validator.TCAPreferencesValidator

TCAUtils - Class in org.openecomp.dcae.apod.analytics.tca.utils

Utility Helper methods for TCA sub module only.

TCAUtils() - Constructor for class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

TCAVESAlertEntity - Class in org.openecomp.dcae.apod.analytics.tca.persistance

TCAVESAlertEntity() - Constructor for class org.openecomp.dcae.apod.analytics.tca.persistance.TCAVESAlertEntity

TCAVESAlertEntity(long, String) - Constructor for class org.openecomp.dcae.apod.analytics.tca.persistance.TCAVESAlertEntity

TCAVESAlertsPersister - Class in org.openecomp.dcae.apod.analytics.tca.persistance

TCAVESAlertsPersister() - Constructor for class org.openecomp.dcae.apod.analytics.tca.persistance.TCAVESAlertsPersister

TCAVESAlertsSinkFlowlet - Class in org.openecomp.dcae.apod.analytics.tca.flowlet

Saves TCA VES Alert Messages in a Time series Table

TCAVESAlertsSinkFlowlet(String) - Constructor for class org.openecomp.dcae.apod.analytics.tca.flowlet.TCAVESAlertsSinkFlowlet

TCAVESCollectorFlow - Class in org.openecomp.dcae.apod.analytics.tca.flow

TCA Flow for VES (Virtual Event Streaming) Collector Flow

TCAVESCollectorFlow(TCAAppConfig) - Constructor for class org.openecomp.dcae.apod.analytics.tca.flow.TCAVESCollectorFlow

TCAVESMessageRouterFlowlet - Class in org.openecomp.dcae.apod.analytics.tca.flowlet

TCA Message Router Flowlet emits VES Message to TCAVESThresholdViolationCalculatorFlowlet instances

TCAVESMessageRouterFlowlet() - Constructor for class org.openecomp.dcae.apod.analytics.tca.flowlet.TCAVESMessageRouterFlowlet

TCAVESThresholdViolationCalculatorFlowlet - Class in org.openecomp.dcae.apod.analytics.tca.flowlet

TCA VES Message Filter filters out messages which are not applicable for TCA as per TCA Policy

TCAVESThresholdViolationCalculatorFlowlet(String) - Constructor for class org.openecomp.dcae.apod.analytics.tca.flowlet.TCAVESThresholdViolationCalculatorFlowlet

thresholdCalculator(List<Long>, List<Threshold>) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Computes if any CEF Message Fields have violated any Policy Thresholds.

toString() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppConfig

toString() - Method in class org.openecomp.dcae.apod.analytics.tca.settings.TCAAppPreferences

U

updateDMaaPPubSubValues(Map<String, String>, TCAAppPreferences) - Static method in class org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils

Updates DMaaP Subscriber and Publisher Urls if present in runtime arguments.

V

validateAppSettings(TCAAppConfig) - Method in class org.openecomp.dcae.apod.analytics.tca.validator.TCAAppConfigValidator

validateAppSettings(TCAPolicyPreferences) - Method in class org.openecomp.dcae.apod.analytics.tca.validator.TCAPolicyPreferencesValidator

validateAppSettings(TCAAppPreferences) - Method in class org.openecomp.dcae.apod.analytics.tca.validator.TCAPreferencesValidator

valueOf(String) - Static method in enum org.openecomp.dcae.apod.analytics.tca.persistance.TCACalculatorMessageType

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.openecomp.dcae.apod.analytics.tca.persistance.TCACalculatorMessageType

Returns an array containing the constants of this enum type, in the order they are declared.

W

write(DataOutput) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAMessageStatusEntity

write(DataOutput) - Method in class org.openecomp.dcae.apod.analytics.tca.persistance.TCAVESAlertEntity

A C E F G I M O P R S T U V W