Skip to content

Commit 29ae09b

Browse files
committed
added fields for update monitor in IndexMonitorRequest
1 parent 2acf9e0 commit 29ae09b

File tree

1 file changed

+11
-10
lines changed

1 file changed

+11
-10
lines changed

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

Lines changed: 11 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -7,41 +7,42 @@ import org.opensearch.action.support.WriteRequest
77
import org.opensearch.commons.alerting.model.MonitorV2
88
import org.opensearch.core.common.io.stream.StreamInput
99
import org.opensearch.core.common.io.stream.StreamOutput
10+
import org.opensearch.rest.RestRequest
1011

1112
class IndexMonitorV2Request : ActionRequest {
12-
// val monitorId: String
13+
val monitorId: String
1314
val seqNo: Long
1415
val primaryTerm: Long
1516
val refreshPolicy: WriteRequest.RefreshPolicy
16-
// val method: RestRequest.Method
17+
val method: RestRequest.Method
1718
var monitorV2: MonitorV2
1819
// val rbacRoles: List<String>?
1920

2021
constructor(
21-
// monitorId: String,
22+
monitorId: String,
2223
seqNo: Long,
2324
primaryTerm: Long,
2425
refreshPolicy: WriteRequest.RefreshPolicy,
25-
// method: RestRequest.Method,
26+
method: RestRequest.Method,
2627
monitorV2: MonitorV2,
2728
// rbacRoles: List<String>? = null
2829
) : super() {
29-
// this.monitorId = monitorId
30+
this.monitorId = monitorId
3031
this.seqNo = seqNo
3132
this.primaryTerm = primaryTerm
3233
this.refreshPolicy = refreshPolicy
33-
// this.method = method
34+
this.method = method
3435
this.monitorV2 = monitorV2
3536
// this.rbacRoles = rbacRoles
3637
}
3738

3839
@Throws(IOException::class)
3940
constructor(sin: StreamInput) : this(
40-
// monitorId = sin.readString(),
41+
monitorId = sin.readString(),
4142
seqNo = sin.readLong(),
4243
primaryTerm = sin.readLong(),
4344
refreshPolicy = WriteRequest.RefreshPolicy.readFrom(sin),
44-
// method = sin.readEnum(RestRequest.Method::class.java),
45+
method = sin.readEnum(RestRequest.Method::class.java),
4546
monitorV2 = MonitorV2.readFrom(sin),
4647
// rbacRoles = sin.readOptionalStringList()
4748
)
@@ -52,11 +53,11 @@ class IndexMonitorV2Request : ActionRequest {
5253

5354
@Throws(IOException::class)
5455
override fun writeTo(out: StreamOutput) {
55-
// out.writeString(monitorId)
56+
out.writeString(monitorId)
5657
out.writeLong(seqNo)
5758
out.writeLong(primaryTerm)
5859
refreshPolicy.writeTo(out)
59-
// out.writeEnum(method)
60+
out.writeEnum(method)
6061
MonitorV2.writeTo(out, monitorV2)
6162
// out.writeOptionalStringCollection(rbacRoles)
6263
}

0 commit comments

Comments
 (0)