list_objects: add extra headers and extra query parameters

Fixes #1278 Signed-off-by: Bala.FA <[email protected]>
minio · Nov 20, 2024 · 0c18732 · 0c18732
1 parent b048920
commit 0c18732
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/minio/api.py b/minio/api.py
@@ -2005,6 +2005,8 @@ def list_objects(
             use_api_v1: bool = False,
             use_url_encoding_type: bool = True,
             fetch_owner: bool = False,
+            extra_headers: DictType | None = None,
+            extra_query_params: DictType | None = None,
     ):
         """
         Lists object information of a bucket.
@@ -2020,6 +2022,8 @@ def list_objects(
         :param use_api_v1: Flag to control to use ListObjectV1 S3 API or not.
         :param use_url_encoding_type: Flag to control whether URL encoding type
                                       to be used or not.
+        :param extra_headers: Extra HTTP headers for advanced usage.
+        :param extra_query_params: Extra query parameters for advanced usage.
         :return: Iterator of :class:`Object <Object>`.
 
         Example::
@@ -2064,6 +2068,8 @@ def list_objects(
             include_version=include_version,
             encoding_type="url" if use_url_encoding_type else None,
             fetch_owner=fetch_owner,
+            extra_headers=extra_headers,
+            extra_query_params=extra_query_params,
         )
 
     def stat_object(
@@ -3135,6 +3141,8 @@ def _list_objects(
             version_id_marker: str | None = None,  # versioned
             use_api_v1: bool = False,
             include_version: bool = False,
+            extra_headers: DictType | None = None,
+            extra_query_params: DictType | None = None,
     ) -> Iterator[Object]:
         """
         List objects optionally including versions.
@@ -3151,7 +3159,7 @@ def _list_objects(
 
         is_truncated = True
         while is_truncated:
-            query = {}
+            query = extra_query_params or {}
             if include_version:
                 query["versions"] = ""
             elif not use_api_v1:
@@ -3183,6 +3191,7 @@ def _list_objects(
                 "GET",
                 bucket_name,
                 query_params=cast(DictType, query),
+                headers=extra_headers,
             )
 
             objects, is_truncated, start_after, version_id_marker = (