Skip to content

Commit 1b3b15b

Browse files
committed
add correlation rule layer for events-correlation-engine
Signed-off-by: Subhobrata Dey <[email protected]>
1 parent 2c38caa commit 1b3b15b

File tree

3 files changed

+3
-2
lines changed

3 files changed

+3
-2
lines changed

plugins/events-correlation-engine/src/main/java/org/opensearch/plugin/correlation/rules/model/CorrelationRule.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@
4141
* }
4242
*
4343
* @opensearch.api
44+
* @opensearch.experimental
4445
*/
4546
public class CorrelationRule implements Writeable, ToXContentObject {
4647

plugins/events-correlation-engine/src/main/java/org/opensearch/plugin/correlation/rules/transport/TransportIndexCorrelationRuleAction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ protected void doExecute(Task task, IndexCorrelationRuleRequest request, ActionL
8282
asyncAction.start();
8383
}
8484

85-
class AsyncIndexCorrelationRuleAction {
85+
private class AsyncIndexCorrelationRuleAction {
8686
private final IndexCorrelationRuleRequest request;
8787

8888
private final ActionListener<IndexCorrelationRuleResponse> listener;

plugins/events-correlation-engine/src/main/java/org/opensearch/plugin/correlation/utils/CorrelationRuleIndices.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ public static String correlationRuleIndexMappings() throws IOException {
6464
* @throws IOException IOException
6565
*/
6666
public void initCorrelationRuleIndex(ActionListener<CreateIndexResponse> actionListener) throws IOException {
67-
if (!correlationRuleIndexExists()) {
67+
if (correlationRuleIndexExists() == false) {
6868
CreateIndexRequest indexRequest = new CreateIndexRequest(CorrelationRule.CORRELATION_RULE_INDEX).mapping(
6969
correlationRuleIndexMappings()
7070
).settings(Settings.builder().put("index.hidden", true).build());

0 commit comments

Comments
 (0)