/
ActivityIndexDefinition.java
67 lines (60 loc) · 2.61 KB
/
ActivityIndexDefinition.java
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
/*
* SonarQube, open source software quality management tool.
* Copyright (C) 2008-2014 SonarSource
* mailto:contact AT sonarsource DOT com
*
* SonarQube is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 3 of the License, or (at your option) any later version.
*
* SonarQube is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public License
* along with this program; if not, write to the Free Software Foundation,
* Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
*/
package org.sonar.server.activity.index;
import com.google.common.collect.ImmutableMap;
import org.sonar.api.config.Settings;
import org.sonar.server.es.EsUtils;
import org.sonar.server.es.IndexDefinition;
import org.sonar.server.es.NewIndex;
/**
* Definition of ES index "activities", including settings and fields.
*/
public class ActivityIndexDefinition implements IndexDefinition {
public static final String INDEX = "activities";
public static final String TYPE = "activity";
public static final String FIELD_KEY = "key";
public static final String FIELD_TYPE = "type";
public static final String FIELD_ACTION = "action";
public static final String FIELD_CREATED_AT = "createdAt";
public static final String FIELD_LOGIN = "login";
public static final String FIELD_DETAILS = "details";
public static final String FIELD_MESSAGE = "message";
private final Settings settings;
public ActivityIndexDefinition(Settings settings) {
this.settings = settings;
}
@Override
public void define(IndexDefinitionContext context) {
NewIndex index = context.create(INDEX);
index.getSettings().put("analysis.analyzer.default.type", "keyword");
EsUtils.refreshHandledByIndexer(index);
EsUtils.setShards(index, settings);
// type "activity"
NewIndex.NewIndexType mapping = index.createType(TYPE);
mapping.setAttribute("_id", ImmutableMap.of("path", FIELD_KEY));
mapping.stringFieldBuilder(FIELD_KEY).build();
mapping.stringFieldBuilder(FIELD_TYPE).build();
mapping.stringFieldBuilder(FIELD_ACTION).build();
mapping.stringFieldBuilder(FIELD_LOGIN).build();
mapping.createDynamicNestedField(FIELD_DETAILS);
mapping.stringFieldBuilder(FIELD_MESSAGE).build();
mapping.createDateTimeField(FIELD_CREATED_AT);
}
}