feat: use kwargs to pass query parameters into API list call

Author: bednar

influxdb_client/client/authorizations_api.py

@@ -42,10 +42,10 @@ def find_authorizations(self, **kwargs):
         """
         Get a list of all authorizations.
 
-        :param str user_id: filter authorizations belonging to a user id
-        :param str user: filter authorizations belonging to a user name
-        :param str org_id: filter authorizations belonging to a org id
-        :param str org: filter authorizations belonging to a org name
+        :key str user_id: filter authorizations belonging to a user id
+        :key str user: filter authorizations belonging to a user name
+        :key str org_id: filter authorizations belonging to a org id
+        :key str org: filter authorizations belonging to a org name
         :return: Authorizations
         """
         authorizations = self._authorizations_service.get_authorizations(**kwargs)

influxdb_client/client/bucket_api.py

@@ -87,6 +87,15 @@ def find_bucket_by_name(self, bucket_name):
         else:
             return None
 
-    def find_buckets(self, limit=20, offset=0):
-        """Get all buckets."""
-        return self._buckets_service.get_buckets(limit=limit, offset=offset)
+    def find_buckets(self, **kwargs):
+        """List buckets.
+
+        :key int offset: Offset for pagination
+        :key int limit: Limit for pagination
+        :key str after: The last resource ID from which to seek from (but not including). This is to be used instead of `offset`.
+        :key str org: The organization name.
+        :key str org_id: The organization ID.
+        :key str name: Only returns buckets with a specific name.
+        :return: Buckets
+        """
+        return self._buckets_service.get_buckets(**kwargs)

influxdb_client/client/labels_api.py

@@ -67,13 +67,15 @@ def clone_label(self, cloned_name: str, label: Label) -> Label:
 
         return self.create_label(name=cloned_name, properties=cloned_properties, org_id=label.org_id)
 
-    def find_labels(self) -> List['Label']:
+    def find_labels(self, **kwargs) -> List['Label']:
         """
         Get all available labels.
 
+        :key str org_id: The organization ID.
+
         :return: labels
         """
-        return self._service.get_labels().labels
+        return self._service.get_labels(**kwargs).labels
 
     def find_label_by_id(self, label_id: str):
         """

influxdb_client/client/organizations_api.py

@@ -26,9 +26,18 @@ def find_organization(self, org_id):
         """Retrieve an organization."""
         return self._organizations_service.get_orgs_id(org_id=org_id)
 
-    def find_organizations(self):
-        """List all organizations."""
-        return self._organizations_service.get_orgs().orgs
+    def find_organizations(self, **kwargs):
+        """
+        List all organizations.
+
+        :key int offset: Offset for pagination
+        :key int limit: Limit for pagination
+        :key bool descending:
+        :key str org: Filter organizations to a specific organization name.
+        :key str org_id: Filter organizations to a specific organization ID.
+        :key str user_id: Filter organizations to a specific user ID.
+        """
+        return self._organizations_service.get_orgs(**kwargs).orgs
 
     def create_organization(self, name: str = None, organization: Organization = None) -> Organization:
         """Create an organization."""

influxdb_client/client/tasks_api.py

@@ -28,12 +28,12 @@ def find_task_by_id(self, task_id) -> Task:
     def find_tasks(self, **kwargs):
         """List all tasks.
 
-        :param str name: only returns tasks with the specified name
-        :param str after: returns tasks after specified ID
-        :param str user: filter tasks to a specific user ID
-        :param str org: filter tasks to a specific organization name
-        :param str org_id: filter tasks to a specific organization ID
-        :param int limit: the number of tasks to return
+        :key str name: only returns tasks with the specified name
+        :key str after: returns tasks after specified ID
+        :key str user: filter tasks to a specific user ID
+        :key str org: filter tasks to a specific organization name
+        :key str org_id: filter tasks to a specific organization ID
+        :key int limit: the number of tasks to return
         :return: Tasks
         """
         return self._service.get_tasks(**kwargs).tasks

tests/test_BucketsApi.py

@@ -83,6 +83,26 @@ def test_create_bucket_retention_list(self):
 
         self.delete_test_bucket(my_bucket)
 
+    def test_pagination(self):
+        my_org = self.find_my_org()
+        buckets = self.buckets_api.find_buckets().buckets
+        size = len(buckets)
+
+        # create 2 buckets
+        self.buckets_api.create_bucket(bucket_name=generate_bucket_name(), org_id=my_org.id)
+        self.buckets_api.create_bucket(bucket_name=generate_bucket_name(), org_id=my_org.id)
+
+        buckets = self.buckets_api.find_buckets().buckets
+        self.assertEqual(size + 2, len(buckets))
+
+        # offset 1
+        buckets = self.buckets_api.find_buckets(offset=1).buckets
+        self.assertEqual(size + 1, len(buckets))
+
+        # count 1
+        buckets = self.buckets_api.find_buckets(limit=1).buckets
+        self.assertEqual(1, len(buckets))
+
 
 if __name__ == '__main__':
     unittest.main()