opensearchapi: add new fields for opensearch 3.0

Signed-off-by: Jakob Hahn <[email protected]>

Author: Jakob3xD

CHANGELOG.md

@@ -7,6 +7,7 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
 ### Dependencies
 
 ### Added
+- Adds new fields for Opensearch 3.0 ([#702](https://github.com/opensearch-project/opensearch-go/pull/702))
 
 ### Changed
 - Test against Opensearch 3.0 ([#702](https://github.com/opensearch-project/opensearch-go/pull/702))
@@ -35,6 +36,7 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
 ### Changed
 - Bump golang version to 1.22 ([#691](https://github.com/opensearch-project/opensearch-go/pull/691))
 - Change ChangeCatRecoveryItemResp Byte fields from int to string ([#691](https://github.com/opensearch-project/opensearch-go/pull/691))
+
 ### Deprecated
 
 ### Removed

opensearchapi/api_cluster-state.go

@@ -194,6 +194,7 @@ type ClusterStateMetaDataStream struct {
 type ClusterStateRoutingIndex struct {
 	State                    string  `json:"state"`
 	Primary                  bool    `json:"primary"`
+	SearchOnly               bool    `json:"searchOnly"`
 	Node                     *string `json:"node"`
 	RelocatingNode           *string `json:"relocating_node"`
 	Shard                    int     `json:"shard"`

opensearchapi/api_cluster-stats.go

@@ -194,6 +194,7 @@ type ClusterStatsNodes struct {
 		Master              int `json:"master"`
 		RemoteClusterClient int `json:"remote_cluster_client"`
 		Search              int `json:"search"`
+		Warm                int `json:"warm"`
 	} `json:"count"`
 	Versions []string `json:"versions"`
 	Os       struct {

opensearchapi/api_nodes-info.go

@@ -71,28 +71,29 @@ func (r NodesInfoResp) Inspect() Inspect {
 
 // NodesInfo is a sub type of NodesInfoResp containing information about nodes and their stats
 type NodesInfo struct {
-	Name                string                         `json:"name"`
-	TransportAddress    string                         `json:"transport_address"`
-	Host                string                         `json:"host"`
-	IP                  string                         `json:"ip"`
-	Version             string                         `json:"version"`
-	BuildType           string                         `json:"build_type"`
-	BuildHash           string                         `json:"build_hash"`
-	TotalIndexingBuffer int64                          `json:"total_indexing_buffer"`
-	Roles               []string                       `json:"roles"`
-	Attributes          map[string]string              `json:"attributes"`
-	Settings            json.RawMessage                `json:"settings"` // Won't parse as it may contain fields that we can't know
-	OS                  NodesInfoOS                    `json:"os"`
-	Process             NodesInfoProcess               `json:"process"`
-	JVM                 NodesInfoJVM                   `json:"jvm"`
-	ThreadPool          map[string]NodesInfoThreadPool `json:"thread_pool"`
-	Transport           NodesInfoTransport             `json:"transport"`
-	HTTP                NodesInfoHTTP                  `json:"http"`
-	Plugins             []NodesInfoPlugin              `json:"plugins"`
-	Modules             []NodesInfoPlugin              `json:"modules"`
-	Ingest              NodesInfoIngest                `json:"ingest"`
-	Aggregations        map[string]NodesInfoAgg        `json:"aggregations"`
-	SearchPipelines     NodesInfoSearchPipelines       `json:"search_pipelines"`
+	Name                       string                         `json:"name"`
+	TransportAddress           string                         `json:"transport_address"`
+	Host                       string                         `json:"host"`
+	IP                         string                         `json:"ip"`
+	Version                    string                         `json:"version"`
+	BuildType                  string                         `json:"build_type"`
+	BuildHash                  string                         `json:"build_hash"`
+	TotalIndexingBuffer        int64                          `json:"total_indexing_buffer"`
+	TotalIndexingBufferInBytes int64                          `json:"total_indexing_buffer_in_bytes"`
+	Roles                      []string                       `json:"roles"`
+	Attributes                 map[string]string              `json:"attributes"`
+	Settings                   json.RawMessage                `json:"settings"` // Won't parse as it may contain fields that we can't know
+	OS                         NodesInfoOS                    `json:"os"`
+	Process                    NodesInfoProcess               `json:"process"`
+	JVM                        NodesInfoJVM                   `json:"jvm"`
+	ThreadPool                 map[string]NodesInfoThreadPool `json:"thread_pool"`
+	Transport                  NodesInfoTransport             `json:"transport"`
+	HTTP                       NodesInfoHTTP                  `json:"http"`
+	Plugins                    []NodesInfoPlugin              `json:"plugins"`
+	Modules                    []NodesInfoPlugin              `json:"modules"`
+	Ingest                     NodesInfoIngest                `json:"ingest"`
+	Aggregations               map[string]NodesInfoAgg        `json:"aggregations"`
+	SearchPipelines            NodesInfoSearchPipelines       `json:"search_pipelines"`
 }
 
 // NodesInfoOS is a sub type of NodesInfo containing information about the Operating System

opensearchapi/api_nodes-stats.go

@@ -624,6 +624,7 @@ type NodesStatsSearchBackpressure struct {
 			CancellationCount             int `json:"cancellation_count"`
 			CancellationLimitReachedCount int `json:"cancellation_limit_reached_count"`
 		} `json:"cancellation_stats"`
+		CompletionCount int `json:"completion_count"`
 	} `json:"search_task"`
 	SearchShardTask struct {
 		ResourceTrackerStats struct {
@@ -640,6 +641,7 @@ type NodesStatsSearchBackpressure struct {
 			CancellationCount             int `json:"cancellation_count"`
 			CancellationLimitReachedCount int `json:"cancellation_limit_reached_count"`
 		} `json:"cancellation_stats"`
+		CompletionCount int `json:"completion_count"`
 	} `json:"search_shard_task"`
 	Mode string `json:"mode"`
 }
@@ -678,10 +680,14 @@ type NodesStatsSearchPipeline struct {
 
 // NodesStatsTaskCancellation is a sub type of NodesStats containing stats about canceled tasks
 type NodesStatsTaskCancellation struct {
-	SearchShardTask struct {
-		CurrentCountPostCancel int `json:"current_count_post_cancel"`
-		TotalCountPostCancel   int `json:"total_count_post_cancel"`
-	} `json:"search_shard_task"`
+	SearchTask      NodesStatsTaskCancellationValues `json:"search_task"`
+	SearchShardTask NodesStatsTaskCancellationValues `json:"search_shard_task"`
+}
+
+// NodesStatsTaskCancellationValues is a sub type of NodesStatsTaskCancellation
+type NodesStatsTaskCancellationValues struct {
+	CurrentCountPostCancel int `json:"current_count_post_cancel"`
+	TotalCountPostCancel   int `json:"total_count_post_cancel"`
 }
 
 // NodesStatsIndicesSearchRequest is a sub type of NodesStatsIndices containing stats about search requests

opensearchapi/api_search_shards.go

@@ -72,6 +72,7 @@ type SearchShardsResp struct {
 	Shards  [][]struct {
 		State                    string  `json:"state"`
 		Primary                  bool    `json:"primary"`
+		SearchOnly               bool    `json:"searchOnly"`
 		Node                     string  `json:"node"`
 		RelocatingNode           *string `json:"relocating_node"`
 		Shard                    int     `json:"shard"`