blob: 54ea48d8a80e3506060089f7b10eda04fe090ac8 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
/*
* ================================================================================
* Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
*
*/
package org.onap.dcae.analytics.tca.core.util.function.calculation;
import java.util.Optional;
import org.onap.dcae.analytics.model.TcaModelConstants;
import org.onap.dcae.analytics.model.cef.CommonEventHeader;
import org.onap.dcae.analytics.model.cef.EventListener;
import org.onap.dcae.analytics.tca.core.service.TcaExecutionContext;
import org.onap.dcae.analytics.tca.core.service.TcaResultContext;
import org.onap.dcae.analytics.tca.model.facade.Aai;
import org.onap.dcae.analytics.tca.model.facade.TcaAlert;
import org.onap.dcae.analytics.tca.model.policy.ClosedLoopEventStatus;
import org.onap.dcae.analytics.tca.model.policy.ControlLoopSchemaType;
import org.onap.dcae.analytics.tca.model.policy.MetricsPerEventName;
import org.onap.dcae.analytics.tca.model.policy.Threshold;
/**
* @author Rajiv Singla
*/
public class TcaAlertCreationFunction implements TcaCalculationFunction {
@Override
public TcaExecutionContext calculate(final TcaExecutionContext tcaExecutionContext) {
// get violated metrics per event name
final Optional<MetricsPerEventName> violatedMetricsPerEventNameOptional =
Optional.ofNullable(tcaExecutionContext.getTcaResultContext())
.map(TcaResultContext::getViolatedMetricsPerEventName);
// If no violated metrics per event name is present skip alert creation
if (!violatedMetricsPerEventNameOptional.isPresent()) {
return tcaExecutionContext;
}
final TcaResultContext resultContext = tcaExecutionContext.getTcaResultContext();
// Request id should be set to previous request id for abated events if present
final String requestId = Optional.ofNullable(resultContext.getPreviousRequestId())
.orElse(tcaExecutionContext.getRequestId());
// create new tca alert
final TcaAlert tcaAlert = createNewTcaAlert(requestId, tcaExecutionContext.getTcaProcessingContext()
.getEventListener(), violatedMetricsPerEventNameOptional.get());
// update tca processing result context with alert message
tcaExecutionContext.getTcaResultContext().setTcaAlert(tcaAlert);
return tcaExecutionContext;
}
private static TcaAlert createNewTcaAlert(final String requestId,
final EventListener eventListener,
final MetricsPerEventName violatedMetricsPerEventName) {
final Threshold violatedThreshold = violatedMetricsPerEventName.getThresholds().get(0);
final CommonEventHeader commonEventHeader = eventListener.getEvent().getCommonEventHeader();
final TcaAlert tcaAlert = new TcaAlert();
// ClosedLoopControlName included in the DCAE configuration Policy
tcaAlert.setClosedLoopControlName(violatedThreshold.getClosedLoopControlName());
// version included in the DCAE configuration Policy
tcaAlert.setVersion(violatedThreshold.getVersion());
// request id
tcaAlert.setRequestId(requestId);
// commonEventHeader.startEpochMicrosec from the received VES message
tcaAlert.setClosedLoopAlarmStart(commonEventHeader.getStartEpochMicrosec());
// commonEventHeader.lastEpochMicrosec from the received VES message for abated alerts
if (violatedThreshold.getClosedLoopEventStatus() == ClosedLoopEventStatus.ABATED) {
tcaAlert.setClosedLoopAlarmEnd(commonEventHeader.getLastEpochMicrosec());
}
// get service name
tcaAlert.setClosedLoopEventClient(TcaModelConstants.TCA_SERVICE_NAME);
final Aai aai = new Aai();
tcaAlert.setAai(aai);
// VM specific settings
if (violatedMetricsPerEventName.getControlLoopSchemaType() == ControlLoopSchemaType.VM) {
// Hard Coded - "VM"
tcaAlert.setTargetType(TcaModelConstants.TCA_ALERT_VM_TARGET_TYPE);
// Hard Coded - "vserver.vserver-name"
tcaAlert.setTarget(TcaModelConstants.TCA_ALERT_VM_TARGET);
// commonEventHeader.sourceName from the received VES message
aai.setGenericServerName(commonEventHeader.getSourceName());
} else {
// VNF specific settings
// Hard Coded - "VNF"
tcaAlert.setTargetType(TcaModelConstants.TCA_ALERT_VNF_TARGET_TYPE);
// Hard Coded - "generic-vnf.vnf-name"
tcaAlert.setTarget(TcaModelConstants.TCA_ALERT_VNF_TARGET);
// commonEventHeader.sourceName from the received VES message
aai.setGenericVNFName(commonEventHeader.getSourceName());
}
// Hard Coded - "DCAE"
tcaAlert.setFrom(TcaModelConstants.TCA_VES_RESPONSE_FROM);
// policyScope included in the DCAE configuration Policy
tcaAlert.setPolicyScope(violatedMetricsPerEventName.getPolicyScope());
// policyName included in the DCAE configuration Policy
tcaAlert.setPolicyName(violatedMetricsPerEventName.getPolicyName());
// policyVersion included in the DCAE configuration Policy
tcaAlert.setPolicyVersion(violatedMetricsPerEventName.getPolicyVersion());
// Extracted from violated threshold
tcaAlert.setClosedLoopEventStatus(violatedThreshold.getClosedLoopEventStatus().name());
// return new tca Alert
return tcaAlert;
}
}
|
