Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

alertHistoryIndex and findingIndexPattern in data sources #288

Closed
wants to merge 3 commits into from
Closed

alertHistoryIndex and findingIndexPattern in data sources #288

Changes from 1 commit
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
8ef26b8
alertHistoryIndex
Oct 18, 2022
74e26f3
added findingIndex pattern
Oct 18, 2022
96e1d12
missing constructor params
Oct 18, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 11 additions & 0 deletions src/main/kotlin/org/opensearch/commons/alerting/model/DataSources.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,9 @@ data class DataSources(
* If index is pre-existing, mapping is updated. */
val alertsIndex: String = ".opendistro-alerting-alerts", // AlertIndices.ALERT_INDEX

/** Configures a custom index to store historic alerts for a monitor.*/
val alertsHistoryIndex: String,
petardz marked this conversation as resolved.
Show resolved Hide resolved

/** Configures custom mappings by field type for query index.
* Custom query index mappings are configurable, only if a custom query index is configured too. */
val queryIndexMappingsByType: Map<String, Map<String, String>> = mapOf()
Expand Down Expand Up @@ -59,6 +62,7 @@ data class DataSources(
queryIndex = sin.readString(),
findingsIndex = sin.readString(),
alertsIndex = sin.readString(),
alertsHistoryIndex = sin.readString(),
queryIndexMappingsByType = sin.readMap() as Map<String, Map<String, String>>
)

Expand All @@ -68,6 +72,7 @@ data class DataSources(
QUERY_INDEX_FIELD to queryIndex,
FINDINGS_INDEX_FIELD to findingsIndex,
ALERTS_INDEX_FIELD to alertsIndex,
ALERTS_HISTORY_INDEX_FIELD to alertsHistoryIndex,
QUERY_INDEX_MAPPINGS_BY_TYPE to queryIndexMappingsByType
)
}
Expand All @@ -77,6 +82,7 @@ data class DataSources(
builder.field(QUERY_INDEX_FIELD, queryIndex)
builder.field(FINDINGS_INDEX_FIELD, findingsIndex)
builder.field(ALERTS_INDEX_FIELD, alertsIndex)
builder.field(ALERTS_HISTORY_INDEX_FIELD, alertsIndex)
builder.field(QUERY_INDEX_MAPPINGS_BY_TYPE, queryIndexMappingsByType as Map<String, Any>)
builder.endObject()
return builder
Expand All @@ -86,6 +92,7 @@ data class DataSources(
const val QUERY_INDEX_FIELD = "query_index"
const val FINDINGS_INDEX_FIELD = "findings_index"
const val ALERTS_INDEX_FIELD = "alerts_index"
const val ALERTS_HISTORY_INDEX_FIELD = "alerts_history_index"
const val QUERY_INDEX_MAPPINGS_BY_TYPE = "query_index_mappings_by_type"

@JvmStatic
Expand All @@ -95,6 +102,7 @@ data class DataSources(
var queryIndex = ""
var findingsIndex = ""
var alertsIndex = ""
var alertsHistoryIndex = ""
var queryIndexMappingsByType: Map<String, Map<String, String>> = mapOf()

XContentParserUtils.ensureExpectedToken(XContentParser.Token.START_OBJECT, xcp.currentToken(), xcp)
Expand All @@ -106,13 +114,15 @@ data class DataSources(
QUERY_INDEX_FIELD -> queryIndex = xcp.text()
FINDINGS_INDEX_FIELD -> findingsIndex = xcp.text()
ALERTS_INDEX_FIELD -> alertsIndex = xcp.text()
ALERTS_HISTORY_INDEX_FIELD -> alertsHistoryIndex = xcp.text()
QUERY_INDEX_MAPPINGS_BY_TYPE -> queryIndexMappingsByType = xcp.map() as Map<String, Map<String, String>>
}
}
return DataSources(
queryIndex = queryIndex,
findingsIndex = findingsIndex,
alertsIndex = alertsIndex,
alertsHistoryIndex = alertsHistoryIndex,
queryIndexMappingsByType = queryIndexMappingsByType
)
}
Expand All @@ -123,6 +133,7 @@ data class DataSources(
out.writeString(queryIndex)
out.writeString(findingsIndex)
out.writeString(alertsIndex)
out.writeString(alertsHistoryIndex)
out.writeMap(queryIndexMappingsByType as Map<String, Any>)
}
}