add client for cluster health and cluster get settings

Author: born2ngopi

src/nimastic.nim

@@ -2,10 +2,10 @@ import nimastic/transport
 import nimastic/api/[api, catmaster, cataliases, catallocation, catanomalydetectors, catdataframeanalytics,
         catcount, catdatafeeds, cathealth, catfielddata, catindices, catnodeattrs, catnodes, catpendingtasks,
         catplugins, catrecovery, catrepositories, catsegments, catsnapshots, cattasks, cattemplates,catthreadpool,
-        cattrainedmodels, cattransforms, clusterallocationexplain]
+        cattrainedmodels, cattransforms, clusterallocationexplain, clustergetsettings, clusterhealth]
 
 export transport
 export api, catmaster, cataliases, catallocation, catanomalydetectors, catdataframeanalytics,
     catcount, catDatafeeds, cathealth, catfielddata, catindices, catnodeattrs, catnodes, catpendingtasks,
     catplugins, catrecovery, catrepositories, catsegments, catsnapshots, cattasks, cattemplates, catthreadpool,
-    cattrainedmodels, cattransforms, clusterallocationexplain
+    cattrainedmodels, cattransforms, clusterallocationexplain, clustergetsettings, clusterhealth

src/nimastic/api/api.nim

@@ -2,7 +2,8 @@ import catmaster, cataliases, catallocation, catanomalydetectors, catcount,
         catdataframeanalytics, catdatafeeds, catfielddata, cathealth, catindices,
         catnodeattrs, catnodes, catpendingtasks, catplugins, catrecovery, catrepositories,
         catshards, catsegments, catsnapshots, cattasks, cattemplates, catthreadpool,
-        cattrainedmodels, cattransforms, clusterallocationexplain
+        cattrainedmodels, cattransforms, clusterallocationexplain, clustergetsettings,
+        clusterhealth
 
 type
     elasticsearch* = object
@@ -30,4 +31,6 @@ type
         CatThreadPool*: catThreadPool
         CatTrainedModels*: catTrainedModels
         CatTransforms*: catTransforms
-        ClusterAllocationExplain*: clusterAllocationExplain
+        ClusterAllocationExplain*: clusterAllocationExplain
+        ClusterGetSettings*: clusterGetSettings
+        ClusterHealth*: clusterHealth

src/nimastic/api/clusterallocationexplain.nim

@@ -1,4 +1,4 @@
-import httpclient, json
+import strutils, httpclient, json
 import ../transport
 
 type
@@ -12,6 +12,11 @@ type
         Primary*: bool
         Shard*: int
 
+        Pretty*: bool
+        Human*: bool
+        ErrorTrace*: bool
+        FilterPath*: seq[string]
+
 method Do*( c: var elClient, this: clusterAllocationExplain ): Response {.base.} =
 
     var q = ""
@@ -36,6 +41,18 @@ method Do*( c: var elClient, this: clusterAllocationExplain ): Response {.base.}
 
     body["shard"] = %* this.Shard
 
+    if this.Pretty :
+        q.add("&pretty")
+
+    if this.Human :
+        q.add("&human")
+
+    if this.ErrorTrace :
+        q.add("&error_trace") 
+
+    if len(this.FilterPath) > 0 :
+        q.add("&filter_path=" & join(this.FilterPath, ",") )
+
     c.Query = q
     c.Body = $body
     c.Method = HttpGet

src/nimastic/api/clustergetsettings.nim

@@ -0,0 +1,49 @@
+import strutils, httpclient
+import ../transport
+
+type
+    clusterGetSettings* = object
+        #query
+        FlatSettings*: bool
+        IncludeDefaults*: bool
+        MasterTimeout*: string
+        Timeout*: string
+
+        Pretty*: bool
+        Human*: bool
+        ErrorTrace*: bool
+        FilterPath*: seq[string]
+
+method Do*(c: var elClient, this: clusterGetSettings ): Response {.base.} =
+
+    var q = ""
+
+    if this.FlatSettings :
+        q.add("flat_settings")
+
+    if this.IncludeDefaults :
+        q.add("&include_defaults")
+
+    if this.MasterTimeout != "" :
+        q.add("&master_timeout=" & this.MasterTimeout)
+
+    if this.Timeout != "" :
+        q.add("&timeout=" & this.Timeout)
+
+    if this.Pretty :
+        q.add("&pretty")
+
+    if this.Human :
+        q.add("&human")
+
+    if this.ErrorTrace :
+        q.add("&error_trace") 
+
+    if len(this.FilterPath) > 0 :
+        q.add("&filter_path=" & join(this.FilterPath, ",") )
+
+    c.Query = q
+    c.Method = HttpGet
+    c.Endpoint = "/_cluster/settings"
+
+    return c.estransport()

src/nimastic/api/clusterhealth.nim

@@ -0,0 +1,78 @@
+import strutils, httpclient
+import ../transport
+
+type
+    clusterHealth* = object
+        Target*: seq[string]
+        #query
+        Level*: string
+        Local*: bool
+        MasterTimeout*: string
+        Timeout*: string
+        WaitForActiveShards*: string
+        WaitForEvents*: string
+        WaitForNoInitializingShards*: bool
+        WaitForNoRelocatingShards*: bool
+        WaitForNodes*: string
+        WaitForStatus*: string
+
+        Pretty*: bool
+        Human*: bool
+        ErrorTrace*: bool
+        FilterPath*: seq[string]
+
+
+method Do*(c: var elClient, this: clusterHealth): Response {.base.} =
+
+    var q = ""
+
+    if this.Level != "" :
+        q.add("level=" & this.Level)
+
+    if this.Local :
+        q.add("&local")
+
+    if this.MasterTimeout != "" :
+        q.add("&master_timeout=" & this.MasterTimeout)
+
+    if this.Timeout != "" :
+        q.add("&timeout=" & this.Timeout)
+
+    if this.WaitForActiveShards != "" :
+        q.add("&wait_for_active_shards=" & this.WaitForActiveShards)
+
+    if this.WaitForEvents != "" :
+        q.add("&wait_for_events=" & this.WaitForEvents)
+
+    if this.WaitForNoInitializingShards :
+        q.add("&wait_for_no_initializing_shards")
+
+    if this.WaitForNoRelocatingShards :
+        q.add("&wait_for_no_relocating_shards")
+
+    if this.WaitForNodes != "" :
+        q.add("&wait_for_nodes=" & this.WaitForNodes)
+
+    if this.WaitForStatus != "" :
+        q.add("&wait_for_status=" & this.WaitForStatus)
+
+    if this.Pretty :
+        q.add("&pretty")
+
+    if this.Human :
+        q.add("&human")
+
+    if this.ErrorTrace :
+        q.add("&error_trace") 
+
+    if len(this.FilterPath) > 0 :
+        q.add("&filter_path=" & join(this.FilterPath, ",") )
+
+    c.Query = q
+    c.Method = HttpGet
+    c.Endpoint = "/_cluster/health/"
+
+    if len(this.Target) > 0 :
+        c.Endpoint.add("/" & join(this.Target, ","))
+
+    return c.estransport()