actions/opensearch-pyd
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

add time/size params in cat api (#882)

Browse Source 
Thanks for the patch
This commit is contained in:
Loading Zhang
2019-03-28 13:24:25 -06:00
committed by Nick Lang
parent 51ad5d3617
commit dfcaea65e8
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
elasticsearch/client/cat.py
+6 -6
View File
@@ -22,7 +22,7 @@ class CatClient(NamespacedClient):
return self.transport.perform_request('GET', _make_path('_cat', return self.transport.perform_request('GET', _make_path('_cat',
'aliases', name), params=params) 'aliases', name), params=params)
@query_params('bytes', 'format', 'h', 'help', 'local', 'master_timeout', @query_params('bytes', 'size', 'format', 'h', 'help', 'local', 'master_timeout',
's', 'v') 's', 'v')
def allocation(self, node_id=None, params=None): def allocation(self, node_id=None, params=None):
""" """
@@ -48,7 +48,7 @@ class CatClient(NamespacedClient):
return self.transport.perform_request('GET', _make_path('_cat', return self.transport.perform_request('GET', _make_path('_cat',
'allocation', node_id), params=params) 'allocation', node_id), params=params)
@query_params('format', 'h', 'help', 'local', 'master_timeout', 's', 'v') @query_params('size', 'format', 'h', 'help', 'local', 'master_timeout', 's', 'v')
def count(self, index=None, params=None): def count(self, index=None, params=None):
""" """
Count provides quick access to the document count of the entire cluster, Count provides quick access to the document count of the entire cluster,
@@ -106,7 +106,7 @@ class CatClient(NamespacedClient):
""" """
return self.transport.perform_request('GET', '/_cat', params=params) return self.transport.perform_request('GET', '/_cat', params=params)
@query_params('bytes', 'format', 'h', 'health', 'help', 'local', @query_params('bytes', 'time', 'size', 'format', 'h', 'health', 'help', 'local',
'master_timeout', 'pri', 's', 'v') 'master_timeout', 'pri', 's', 'v')
def indices(self, index=None, params=None): def indices(self, index=None, params=None):
""" """
@@ -179,7 +179,7 @@ class CatClient(NamespacedClient):
return self.transport.perform_request('GET', '/_cat/nodes', return self.transport.perform_request('GET', '/_cat/nodes',
params=params) params=params)
@query_params('bytes', 'format', 'h', 'help', 'master_timeout', 's', 'v') @query_params('bytes', 'time', 'size', 'format', 'h', 'help', 'master_timeout', 's', 'v')
def recovery(self, index=None, params=None): def recovery(self, index=None, params=None):
""" """
recovery is a view of shard replication. recovery is a view of shard replication.
@@ -201,7 +201,7 @@ class CatClient(NamespacedClient):
return self.transport.perform_request('GET', _make_path('_cat', return self.transport.perform_request('GET', _make_path('_cat',
'recovery', index), params=params) 'recovery', index), params=params)
@query_params('bytes', 'format', 'h', 'help', 'local', 'master_timeout', 's', 'v') @query_params('bytes', 'time', 'size', 'format', 'h', 'help', 'local', 'master_timeout', 's', 'v')
def shards(self, index=None, params=None): def shards(self, index=None, params=None):
""" """
The shards command is the detailed view of what nodes contain which shards. The shards command is the detailed view of what nodes contain which shards.
@@ -225,7 +225,7 @@ class CatClient(NamespacedClient):
return self.transport.perform_request('GET', _make_path('_cat', return self.transport.perform_request('GET', _make_path('_cat',
'shards', index), params=params) 'shards', index), params=params)
@query_params('bytes', 'format', 'h', 'help', 's', 'v') @query_params('bytes', 'size', 'format', 'h', 'help', 's', 'v')
def segments(self, index=None, params=None): def segments(self, index=None, params=None):
""" """
The segments command is the detailed view of Lucene segments per index. The segments command is the detailed view of Lucene segments per index.