Skip to content

Commit d257620

Browse files
Revert "updating PublishFindingsRequest to use a list of findings rather than… (#832)" (#847)
This reverts commit 774c00d. Signed-off-by: Dennis Toepker <[email protected]> Co-authored-by: Dennis Toepker <[email protected]>
1 parent 569499e commit d257620

File tree

4 files changed

+0
-92
lines changed

4 files changed

+0
-92
lines changed

src/main/kotlin/org/opensearch/commons/alerting/AlertingPluginInterface.kt

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@ import org.opensearch.commons.alerting.action.IndexMonitorRequest
2727
import org.opensearch.commons.alerting.action.IndexMonitorResponse
2828
import org.opensearch.commons.alerting.action.IndexWorkflowRequest
2929
import org.opensearch.commons.alerting.action.IndexWorkflowResponse
30-
import org.opensearch.commons.alerting.action.PublishBatchFindingsRequest
3130
import org.opensearch.commons.alerting.action.PublishFindingsRequest
3231
import org.opensearch.commons.alerting.action.SearchMonitorRequest
3332
import org.opensearch.commons.alerting.action.SubscribeFindingsResponse
@@ -269,24 +268,6 @@ object AlertingPluginInterface {
269268
)
270269
}
271270

272-
fun publishBatchFindings(
273-
client: NodeClient,
274-
request: PublishBatchFindingsRequest,
275-
listener: ActionListener<SubscribeFindingsResponse>
276-
) {
277-
client.execute(
278-
AlertingActions.SUBSCRIBE_BATCH_FINDINGS_ACTION_TYPE,
279-
request,
280-
wrapActionListener(listener) { response ->
281-
recreateObject(response) {
282-
SubscribeFindingsResponse(
283-
it
284-
)
285-
}
286-
}
287-
)
288-
}
289-
290271
/**
291272
* Acknowledge Chained Alerts interface.
292273
* @param client Node client for making transport action

src/main/kotlin/org/opensearch/commons/alerting/action/AlertingActions.kt

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@ object AlertingActions {
1919
const val ACKNOWLEDGE_ALERTS_ACTION_NAME = "cluster:admin/opendistro/alerting/alerts/ack"
2020
const val ACKNOWLEDGE_CHAINED_ALERTS_ACTION_NAME = "cluster:admin/opendistro/alerting/chained_alerts/ack"
2121
const val SUBSCRIBE_FINDINGS_ACTION_NAME = "cluster:admin/opensearch/alerting/findings/subscribe"
22-
const val SUBSCRIBE_BATCH_FINDINGS_ACTION_NAME = "cluster:admin/opensearch/alerting/findings/batch/subscribe"
2322
const val GET_MONITOR_ACTION_NAME = "cluster:admin/opendistro/alerting/monitor/get"
2423
const val SEARCH_MONITORS_ACTION_NAME = "cluster:admin/opendistro/alerting/monitor/search"
2524
const val INDEX_COMMENT_ACTION_NAME = "cluster:admin/opensearch/alerting/comments/write"
@@ -66,10 +65,6 @@ object AlertingActions {
6665
val SUBSCRIBE_FINDINGS_ACTION_TYPE =
6766
ActionType(SUBSCRIBE_FINDINGS_ACTION_NAME, ::SubscribeFindingsResponse)
6867

69-
@JvmField
70-
val SUBSCRIBE_BATCH_FINDINGS_ACTION_TYPE =
71-
ActionType(SUBSCRIBE_BATCH_FINDINGS_ACTION_NAME, ::SubscribeFindingsResponse)
72-
7368
@JvmField
7469
val ACKNOWLEDGE_CHAINED_ALERTS_ACTION_TYPE =
7570
ActionType(ACKNOWLEDGE_CHAINED_ALERTS_ACTION_NAME, ::AcknowledgeAlertResponse)

src/main/kotlin/org/opensearch/commons/alerting/action/PublishBatchFindingsRequest.kt

Lines changed: 0 additions & 39 deletions
This file was deleted.

src/test/kotlin/org/opensearch/commons/alerting/action/PublishBatchFindingsRequestTests.kt

Lines changed: 0 additions & 29 deletions
This file was deleted.

0 commit comments

Comments
 (0)