in src/main/kotlin/org/opensearch/replication/action/index/ReplicateIndexRequest.kt [93:110]
override fun validate(): ActionRequestValidationException? {
var validationException = ActionRequestValidationException()
if (!this::leaderAlias.isInitialized ||
!this::leaderIndex.isInitialized ||
!this::followerIndex.isInitialized) {
validationException.addValidationError("Mandatory params are missing for the request")
}
validateName(leaderIndex, validationException)
validateName(followerIndex, validationException)
if(useRoles != null && (useRoles!!.size < 2 || useRoles!![LEADER_CLUSTER_ROLE] == null ||
useRoles!![FOLLOWER_CLUSTER_ROLE] == null)) {
validationException.addValidationError("Need roles for $LEADER_CLUSTER_ROLE and $FOLLOWER_CLUSTER_ROLE")
}
return if(validationException.validationErrors().isEmpty()) return null else validationException
}