Skip to content
This repository has been archived by the owner on Aug 2, 2022. It is now read-only.

Commit

Permalink
Fill in missing ScheduledJobStats and ScheduledJobsStatsResponse cons…
Browse files Browse the repository at this point in the history
…tructor. (#142)

* Update to OD 1.3 -> ES 7.3.2, fix broken stats API. Update release docs.

* Update release notes to be correct.

* Github actions works, updating ES version to be correct now.

* Make plugin verison consistant.

* It builds, and runs, and tests. TODO: 3 compiler warnings, no jacoco.

* Bump jacoco version to work with new JDK. Fix one warning for kotlin.

* Uncomment the jacoco.

* Fill in missing ScheduledJobStats constructor.

* Fill in missing ScheduledJobsStatsResponse constructor.

* Fix ktlint.

* Bump opendistro version.
  • Loading branch information
lucaswin-amzn authored and dbbaughe committed Jan 8, 2020
1 parent 05aa041 commit 1d3e87e
Show file tree
Hide file tree
Showing 3 changed files with 12 additions and 4 deletions.
2 changes: 1 addition & 1 deletion build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ apply plugin: 'jacoco'
apply from: 'build-tools/merged-coverage.gradle'

ext {
opendistroVersion = '1.3.0'
opendistroVersion = '1.4.0'
isSnapshot = "true" == System.getProperty("build.snapshot", "true")
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -40,11 +40,15 @@ class ScheduledJobStats : BaseNodeResponse, ToXContentFragment {
}
}

lateinit var status: ScheduleStatus
var status: ScheduleStatus
var jobSweeperMetrics: JobSweeperMetrics? = null
var jobInfos: Array<JobSchedulerMetrics>? = null

constructor(si: StreamInput): super(si)
constructor(si: StreamInput): super(si) {
this.status = si.readEnum(ScheduleStatus::class.java)
this.jobSweeperMetrics = JobSweeperMetrics(si)
this.jobInfos = si.readList { JobSchedulerMetrics(it) }.toTypedArray()
}

constructor(
node: DiscoveryNode,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,11 @@ class ScheduledJobsStatsResponse : BaseNodesResponse<ScheduledJobStats>, ToXCont
private var indexExists: Boolean? = null
private var indexHealth: ClusterIndexHealth? = null

constructor(si: StreamInput): super(si)
constructor(si: StreamInput): super(si) {
this.scheduledJobEnabled = si.readBoolean()
this.indexExists = si.readBoolean()
this.indexHealth = si.readOptionalWriteable { ClusterIndexHealth(si) }
}

constructor(
clusterName: ClusterName,
Expand Down

0 comments on commit 1d3e87e

Please sign in to comment.