diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/DeleteMonitorV2Action.kt b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/DeleteMonitorV2Action.kt
new file mode 100644
index 000000000..2cd1ba703
--- /dev/null
+++ b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/DeleteMonitorV2Action.kt
@@ -0,0 +1,10 @@
+package org.opensearch.alerting.actionv2
+
+import org.opensearch.action.ActionType
+
+class DeleteMonitorV2Action private constructor() : ActionType<DeleteMonitorV2Response>(NAME, ::DeleteMonitorV2Response) {
+    companion object {
+        val INSTANCE = DeleteMonitorV2Action()
+        const val NAME = "cluster:admin/opensearch/alerting/v2/monitor/delete"
+    }
+}
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/DeleteMonitorV2Request.kt b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/DeleteMonitorV2Request.kt
new file mode 100644
index 000000000..601d83588
--- /dev/null
+++ b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/DeleteMonitorV2Request.kt
@@ -0,0 +1,34 @@
+package org.opensearch.alerting.actionv2
+
+import org.opensearch.action.ActionRequest
+import org.opensearch.action.ActionRequestValidationException
+import org.opensearch.action.support.WriteRequest
+import org.opensearch.core.common.io.stream.StreamInput
+import org.opensearch.core.common.io.stream.StreamOutput
+import java.io.IOException
+
+class DeleteMonitorV2Request : ActionRequest {
+    val monitorV2Id: String
+    val refreshPolicy: WriteRequest.RefreshPolicy
+
+    constructor(monitorV2Id: String, refreshPolicy: WriteRequest.RefreshPolicy) : super() {
+        this.monitorV2Id = monitorV2Id
+        this.refreshPolicy = refreshPolicy
+    }
+
+    @Throws(IOException::class)
+    constructor(sin: StreamInput) : this(
+        monitorV2Id = sin.readString(),
+        refreshPolicy = WriteRequest.RefreshPolicy.readFrom(sin)
+    )
+
+    override fun validate(): ActionRequestValidationException? {
+        return null
+    }
+
+    @Throws(IOException::class)
+    override fun writeTo(out: StreamOutput) {
+        out.writeString(monitorV2Id)
+        refreshPolicy.writeTo(out)
+    }
+}
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/DeleteMonitorV2Response.kt b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/DeleteMonitorV2Response.kt
new file mode 100644
index 000000000..71dcfcbd4
--- /dev/null
+++ b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/DeleteMonitorV2Response.kt
@@ -0,0 +1,38 @@
+package org.opensearch.alerting.actionv2
+
+import org.opensearch.commons.alerting.util.IndexUtils
+import org.opensearch.commons.notifications.action.BaseResponse
+import org.opensearch.core.common.io.stream.StreamInput
+import org.opensearch.core.common.io.stream.StreamOutput
+import org.opensearch.core.xcontent.ToXContent
+import org.opensearch.core.xcontent.XContentBuilder
+
+class DeleteMonitorV2Response : BaseResponse {
+    var id: String
+    var version: Long
+
+    constructor(
+        id: String,
+        version: Long
+    ) : super() {
+        this.id = id
+        this.version = version
+    }
+
+    constructor(sin: StreamInput) : this(
+        sin.readString(), // id
+        sin.readLong() // version
+    )
+
+    override fun writeTo(out: StreamOutput) {
+        out.writeString(id)
+        out.writeLong(version)
+    }
+
+    override fun toXContent(builder: XContentBuilder, params: ToXContent.Params): XContentBuilder {
+        return builder.startObject()
+            .field(IndexUtils._ID, id)
+            .field(IndexUtils._VERSION, version)
+            .endObject()
+    }
+}
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/ExecuteMonitorV2Action.kt b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/ExecuteMonitorV2Action.kt
new file mode 100644
index 000000000..c3ba7968b
--- /dev/null
+++ b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/ExecuteMonitorV2Action.kt
@@ -0,0 +1,10 @@
+package org.opensearch.alerting.actionv2
+
+import org.opensearch.action.ActionType
+
+class ExecuteMonitorV2Action private constructor() : ActionType<ExecuteMonitorV2Response>(NAME, ::ExecuteMonitorV2Response) {
+    companion object {
+        val INSTANCE = ExecuteMonitorV2Action()
+        const val NAME = "cluster:admin/opensearch/alerting/v2/monitor/execute"
+    }
+}
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/ExecuteMonitorV2Request.kt b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/ExecuteMonitorV2Request.kt
new file mode 100644
index 000000000..8084430c5
--- /dev/null
+++ b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/ExecuteMonitorV2Request.kt
@@ -0,0 +1,66 @@
+package org.opensearch.alerting.actionv2
+
+import org.opensearch.action.ActionRequest
+import org.opensearch.action.ActionRequestValidationException
+import org.opensearch.action.ValidateActions
+import org.opensearch.alerting.core.modelv2.MonitorV2
+import org.opensearch.common.unit.TimeValue
+import org.opensearch.core.common.io.stream.StreamInput
+import org.opensearch.core.common.io.stream.StreamOutput
+import java.io.IOException
+
+class ExecuteMonitorV2Request : ActionRequest {
+    val dryrun: Boolean
+    val monitorId: String? // exactly one of monitorId or monitor must be non-null
+    val monitorV2: MonitorV2?
+    val requestStart: TimeValue?
+    val requestEnd: TimeValue
+
+    constructor(
+        dryrun: Boolean,
+        monitorId: String?,
+        monitorV2: MonitorV2?,
+        requestStart: TimeValue? = null,
+        requestEnd: TimeValue
+    ) : super() {
+        this.dryrun = dryrun
+        this.monitorId = monitorId
+        this.monitorV2 = monitorV2
+        this.requestStart = requestStart
+        this.requestEnd = requestEnd
+    }
+
+    @Throws(IOException::class)
+    constructor(sin: StreamInput) : this(
+        sin.readBoolean(), // dryrun
+        sin.readOptionalString(), // monitorId
+        if (sin.readBoolean()) {
+            MonitorV2.readFrom(sin) // monitor
+        } else {
+            null
+        },
+        sin.readOptionalTimeValue(),
+        sin.readTimeValue() // requestEnd
+    )
+
+    override fun validate(): ActionRequestValidationException? =
+        if (monitorV2 == null && monitorId == null) {
+            ValidateActions.addValidationError("Neither a monitor ID nor monitor object was supplied", null)
+        } else {
+            null
+        }
+
+    @Throws(IOException::class)
+    override fun writeTo(out: StreamOutput) {
+        out.writeBoolean(dryrun)
+        out.writeOptionalString(monitorId)
+        if (monitorV2 != null) {
+            out.writeBoolean(true)
+            monitorV2.writeTo(out)
+        } else {
+            out.writeBoolean(false)
+        }
+        out.writeOptionalTimeValue(requestStart)
+        out.writeTimeValue(requestEnd)
+    }
+}
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/ExecuteMonitorV2Response.kt b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/ExecuteMonitorV2Response.kt
new file mode 100644
index 000000000..6635f3791
--- /dev/null
+++ b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/ExecuteMonitorV2Response.kt
@@ -0,0 +1,33 @@
+package org.opensearch.alerting.actionv2
+
+import org.opensearch.alerting.core.modelv2.MonitorV2RunResult
+import org.opensearch.core.action.ActionResponse
+import org.opensearch.core.common.io.stream.StreamInput
+import org.opensearch.core.common.io.stream.StreamOutput
+import org.opensearch.core.xcontent.ToXContent
+import org.opensearch.core.xcontent.ToXContentObject
+import org.opensearch.core.xcontent.XContentBuilder
+import java.io.IOException
+
+class ExecuteMonitorV2Response : ActionResponse, ToXContentObject {
+    val monitorV2RunResult: MonitorV2RunResult<*>
+
+    constructor(monitorV2RunResult: MonitorV2RunResult<*>) : super() {
+        this.monitorV2RunResult = monitorV2RunResult
+    }
+
+    @Throws(IOException::class)
+    constructor(sin: StreamInput) : this(
+        MonitorV2RunResult.readFrom(sin) // monitorRunResult
+    )
+
+    @Throws(IOException::class)
+    override fun writeTo(out: StreamOutput) {
+        monitorV2RunResult.writeTo(out)
+    }
+
+    @Throws(IOException::class)
+    override fun toXContent(builder: XContentBuilder, params: ToXContent.Params): XContentBuilder {
+        return monitorV2RunResult.toXContent(builder, ToXContent.EMPTY_PARAMS)
+    }
+}
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/GetMonitorV2Action.kt b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/GetMonitorV2Action.kt
new file mode 100644
index 000000000..9fb0915c6
--- /dev/null
+++ b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/GetMonitorV2Action.kt
@@ -0,0 +1,10 @@
+package org.opensearch.alerting.actionv2
+
+import org.opensearch.action.ActionType
+
+class GetMonitorV2Action private constructor() : ActionType<GetMonitorV2Response>(NAME, ::GetMonitorV2Response) {
+    companion object {
+        val INSTANCE = GetMonitorV2Action()
+        const val NAME = "cluster:admin/opensearch/alerting/v2/monitor/get"
+    }
+}
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/GetMonitorV2Request.kt b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/GetMonitorV2Request.kt
new file mode 100644
index 000000000..a14f482e7
--- /dev/null
+++ b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/GetMonitorV2Request.kt
@@ -0,0 +1,47 @@
+package org.opensearch.alerting.actionv2
+
+import org.opensearch.action.ActionRequest
+import org.opensearch.action.ActionRequestValidationException
+import org.opensearch.core.common.io.stream.StreamInput
+import org.opensearch.core.common.io.stream.StreamOutput
+import org.opensearch.search.fetch.subphase.FetchSourceContext
+import java.io.IOException
+
+class GetMonitorV2Request : ActionRequest {
+    val monitorV2Id: String
+    val version: Long
+    val srcContext: FetchSourceContext?
+
+    constructor(
+        monitorV2Id: String,
+        version: Long,
+        srcContext: FetchSourceContext?
+    ) : super() {
+        this.monitorV2Id = monitorV2Id
+        this.version = version
+        this.srcContext = srcContext
+    }
+
+    @Throws(IOException::class)
+    constructor(sin: StreamInput) : this(
+        sin.readString(), // monitorV2Id
+        sin.readLong(), // version
+        if (sin.readBoolean()) {
+            FetchSourceContext(sin) // srcContext
+        } else {
+            null
+        }
+    )
+
+    override fun validate(): ActionRequestValidationException? {
+        return null
+    }
+
+    @Throws(IOException::class)
+    override fun writeTo(out: StreamOutput) {
+        out.writeString(monitorV2Id)
+        out.writeLong(version)
+        out.writeBoolean(srcContext != null)
+        srcContext?.writeTo(out)
+    }
+}
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/GetMonitorV2Response.kt b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/GetMonitorV2Response.kt
new file mode 100644
index 000000000..fe083f5e0
--- /dev/null
+++ b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/GetMonitorV2Response.kt
@@ -0,0 +1,75 @@
+package org.opensearch.alerting.actionv2
+
+import org.opensearch.alerting.core.modelv2.MonitorV2
+import org.opensearch.commons.alerting.util.IndexUtils.Companion._ID
+import org.opensearch.commons.alerting.util.IndexUtils.Companion._PRIMARY_TERM
+import org.opensearch.commons.alerting.util.IndexUtils.Companion._SEQ_NO
+import org.opensearch.commons.alerting.util.IndexUtils.Companion._VERSION
+import org.opensearch.commons.notifications.action.BaseResponse
+import org.opensearch.core.common.io.stream.StreamInput
+import org.opensearch.core.common.io.stream.StreamOutput
+import org.opensearch.core.xcontent.ToXContent
+import org.opensearch.core.xcontent.XContentBuilder
+import java.io.IOException
+
+class GetMonitorV2Response : BaseResponse {
+    var id: String
+    var version: Long
+    var seqNo: Long
+    var primaryTerm: Long
+    var monitorV2: MonitorV2?
+
+    constructor(
+        id: String,
+        version: Long,
+        seqNo: Long,
+        primaryTerm: Long,
+        monitorV2: MonitorV2?
+    ) : super() {
+        this.id = id
+        this.version = version
+        this.seqNo = seqNo
+        this.primaryTerm = primaryTerm
+        this.monitorV2 = monitorV2
+    }
+
+    @Throws(IOException::class)
+    constructor(sin: StreamInput) : this(
+        id = sin.readString(), // id
+        version = sin.readLong(), // version
+        seqNo = sin.readLong(), // seqNo
+        primaryTerm = sin.readLong(), // primaryTerm
+        monitorV2 = if (sin.readBoolean()) {
+            MonitorV2.readFrom(sin) // monitorV2
+        } else {
+            null
+        }
+    )
+
+    @Throws(IOException::class)
+    override fun writeTo(out: StreamOutput) {
+        out.writeString(id)
+        out.writeLong(version)
+        out.writeLong(seqNo)
+        out.writeLong(primaryTerm)
+        if (monitorV2 != null) {
+            out.writeBoolean(true)
+            monitorV2?.writeTo(out)
+        } else {
+            out.writeBoolean(false)
+        }
+    }
+
+    @Throws(IOException::class)
+    override fun toXContent(builder: XContentBuilder, params: ToXContent.Params): XContentBuilder {
+        builder.startObject()
+            .field(_ID, id)
+            .field(_VERSION, version)
+            .field(_SEQ_NO, seqNo)
+            .field(_PRIMARY_TERM, primaryTerm)
+        if (monitorV2 != null) {
+            builder.field("monitorV2", monitorV2)
+        }
+        return builder.endObject()
+    }
+}
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/IndexMonitorV2Action.kt b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/IndexMonitorV2Action.kt
new file mode 100644
index 000000000..cff851598
--- /dev/null
+++ b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/IndexMonitorV2Action.kt
@@ -0,0 +1,10 @@
+package org.opensearch.alerting.actionv2
+
+import org.opensearch.action.ActionType
+
+class IndexMonitorV2Action private constructor() : ActionType<IndexMonitorV2Response>(NAME, ::IndexMonitorV2Response) {
+    companion object {
+        val INSTANCE = IndexMonitorV2Action()
+        const val NAME = "cluster:admin/opensearch/alerting/v2/monitor/write"
+    }
+}
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/IndexMonitorV2Request.kt b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/IndexMonitorV2Request.kt
new file mode 100644
index 000000000..39b0d594e
--- /dev/null
+++ b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/IndexMonitorV2Request.kt
@@ -0,0 +1,64 @@
+package org.opensearch.alerting.actionv2
+
+import org.opensearch.action.ActionRequest
+import org.opensearch.action.ActionRequestValidationException
+import org.opensearch.action.support.WriteRequest
+import org.opensearch.alerting.core.modelv2.MonitorV2
+import org.opensearch.core.common.io.stream.StreamInput
+import org.opensearch.core.common.io.stream.StreamOutput
+import org.opensearch.rest.RestRequest
+import java.io.IOException
+
+class IndexMonitorV2Request : ActionRequest {
+    val monitorId: String
+    val seqNo: Long
+    val primaryTerm: Long
+    val refreshPolicy: WriteRequest.RefreshPolicy
+    val method: RestRequest.Method
+    var monitorV2: MonitorV2
+//    val rbacRoles: List<String>?
+
+    constructor(
+        monitorId: String,
+        seqNo: Long,
+        primaryTerm: Long,
+        refreshPolicy: WriteRequest.RefreshPolicy,
+        method: RestRequest.Method,
+        monitorV2: MonitorV2
+//        rbacRoles: List<String>? = null
+    ) : super() {
+        this.monitorId = monitorId
+        this.seqNo = seqNo
+        this.primaryTerm = primaryTerm
+        this.refreshPolicy = refreshPolicy
+        this.method = method
+        this.monitorV2 = monitorV2
+//        this.rbacRoles = rbacRoles
+    }
+
+    @Throws(IOException::class)
+    constructor(sin: StreamInput) : this(
+        monitorId = sin.readString(),
+        seqNo = sin.readLong(),
+        primaryTerm = sin.readLong(),
+        refreshPolicy = WriteRequest.RefreshPolicy.readFrom(sin),
+        method = sin.readEnum(RestRequest.Method::class.java),
+        monitorV2 = MonitorV2.readFrom(sin)
+//        rbacRoles = sin.readOptionalStringList()
+    )
+
+    override fun validate(): ActionRequestValidationException? {
+        return null
+    }
+
+    @Throws(IOException::class)
+    override fun writeTo(out: StreamOutput) {
+        out.writeString(monitorId)
+        out.writeLong(seqNo)
+        out.writeLong(primaryTerm)
+        refreshPolicy.writeTo(out)
+        out.writeEnum(method)
+        MonitorV2.writeTo(out, monitorV2)
+//        out.writeOptionalStringCollection(rbacRoles)
+    }
+}
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/IndexMonitorV2Response.kt b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/IndexMonitorV2Response.kt
new file mode 100644
index 000000000..35640330b
--- /dev/null
+++ b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/IndexMonitorV2Response.kt
@@ -0,0 +1,68 @@
+package org.opensearch.alerting.actionv2
+
+import org.opensearch.alerting.core.modelv2.MonitorV2
+import org.opensearch.commons.alerting.util.IndexUtils.Companion._ID
+import org.opensearch.commons.alerting.util.IndexUtils.Companion._PRIMARY_TERM
+import org.opensearch.commons.alerting.util.IndexUtils.Companion._SEQ_NO
+import org.opensearch.commons.alerting.util.IndexUtils.Companion._VERSION
+import org.opensearch.commons.notifications.action.BaseResponse
+import org.opensearch.core.common.io.stream.StreamInput
+import org.opensearch.core.common.io.stream.StreamOutput
+import org.opensearch.core.xcontent.ToXContent
+import org.opensearch.core.xcontent.XContentBuilder
+import java.io.IOException
+
+class IndexMonitorV2Response : BaseResponse {
+    var id: String
+    var version: Long
+    var seqNo: Long
+    var primaryTerm: Long
+    var monitorV2: MonitorV2
+
+    constructor(
+        id: String,
+        version: Long,
+        seqNo: Long,
+        primaryTerm: Long,
+        monitorV2: MonitorV2
+    ) : super() {
+        this.id = id
+        this.version = version
+        this.seqNo = seqNo
+        this.primaryTerm = primaryTerm
+        this.monitorV2 = monitorV2
+    }
+
+    @Throws(IOException::class)
+    constructor(sin: StreamInput) : this(
+        sin.readString(), // id
+        sin.readLong(), // version
+        sin.readLong(), // seqNo
+        sin.readLong(), // primaryTerm
+        MonitorV2.readFrom(sin) // monitorV2
+    )
+
+    @Throws(IOException::class)
+    override fun writeTo(out: StreamOutput) {
+        out.writeString(id)
+        out.writeLong(version)
+        out.writeLong(seqNo)
+        out.writeLong(primaryTerm)
+        MonitorV2.writeTo(out, monitorV2)
+    }
+
+    @Throws(IOException::class)
+    override fun toXContent(builder: XContentBuilder, params: ToXContent.Params): XContentBuilder {
+        return builder.startObject()
+            .field(_ID, id)
+            .field(_VERSION, version)
+            .field(_SEQ_NO, seqNo)
+            .field(_PRIMARY_TERM, primaryTerm)
+            .field(MONITOR_V2_FIELD, monitorV2)
+            .endObject()
+    }
+
+    companion object {
+        const val MONITOR_V2_FIELD = "monitor_v2"
+    }
+}
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/SearchMonitorV2Action.kt b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/SearchMonitorV2Action.kt
new file mode 100644
index 000000000..d83ffd510
--- /dev/null
+++ b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/SearchMonitorV2Action.kt
@@ -0,0 +1,11 @@
+package org.opensearch.alerting.actionv2
+
+import org.opensearch.action.ActionType
+import org.opensearch.action.search.SearchResponse
+
+class SearchMonitorV2Action private constructor() : ActionType<SearchResponse>(NAME, ::SearchResponse) {
+    companion object {
+        val INSTANCE = SearchMonitorV2Action()
+        const val NAME = "cluster:admin/opensearch/alerting/v2/monitor/search"
+    }
+}
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/SearchMonitorV2Request.kt b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/SearchMonitorV2Request.kt
new file mode 100644
index 000000000..51fba09aa
--- /dev/null
+++ b/alerting/src/main/kotlin/org/opensearch/alerting/actionv2/SearchMonitorV2Request.kt
@@ -0,0 +1,32 @@
+package org.opensearch.alerting.actionv2
+
+import org.opensearch.action.ActionRequest
+import org.opensearch.action.ActionRequestValidationException
+import org.opensearch.action.search.SearchRequest
+import org.opensearch.core.common.io.stream.StreamInput
+import org.opensearch.core.common.io.stream.StreamOutput
+import java.io.IOException
+
+class SearchMonitorV2Request : ActionRequest {
+    val searchRequest: SearchRequest
+
+    constructor(
+        searchRequest: SearchRequest
+    ) : super() {
+        this.searchRequest = searchRequest
+    }
+
+    @Throws(IOException::class)
+    constructor(sin: StreamInput) : this(
+        searchRequest = SearchRequest(sin)
+    )
+
+    override fun validate(): ActionRequestValidationException? {
+        return null
+    }
+
+    @Throws(IOException::class)
+    override fun writeTo(out: StreamOutput) {
+        searchRequest.writeTo(out)
+    }
+}