[Backport 9.1] Add warnings for private APIs (#3212)

elasticsearch/_async/client/__init__.py

@@ -84,9 +84,9 @@
     CLIENT_META_SERVICE,
     SKIP_IN_PATH,
     Stability,
+    _availability_warning,
     _quote,
     _rewrite_parameters,
-    _stability_warning,
     client_node_configs,
     is_requests_http_auth,
     is_requests_node_class,
@@ -4127,7 +4127,7 @@ async def render_search_template(
     @_rewrite_parameters(
         body_fields=("context", "context_setup", "script"),
     )
-    @_stability_warning(Stability.EXPERIMENTAL)
+    @_availability_warning(Stability.EXPERIMENTAL)
     async def scripts_painless_execute(
         self,
         *,

elasticsearch/_async/client/autoscaling.py

@@ -20,12 +20,20 @@
 from elastic_transport import ObjectApiResponse
 
 from ._base import NamespacedClient
-from .utils import SKIP_IN_PATH, _quote, _rewrite_parameters
+from .utils import (
+    SKIP_IN_PATH,
+    Stability,
+    Visibility,
+    _availability_warning,
+    _quote,
+    _rewrite_parameters,
+)
 
 
 class AutoscalingClient(NamespacedClient):
 
     @_rewrite_parameters()
+    @_availability_warning(Stability.STABLE, Visibility.PRIVATE)
     async def delete_autoscaling_policy(
         self,
         *,
@@ -81,6 +89,7 @@ async def delete_autoscaling_policy(
         )
 
     @_rewrite_parameters()
+    @_availability_warning(Stability.STABLE, Visibility.PRIVATE)
     async def get_autoscaling_capacity(
         self,
         *,
@@ -134,6 +143,7 @@ async def get_autoscaling_capacity(
         )
 
     @_rewrite_parameters()
+    @_availability_warning(Stability.STABLE, Visibility.PRIVATE)
     async def get_autoscaling_policy(
         self,
         *,
@@ -186,6 +196,7 @@ async def get_autoscaling_policy(
     @_rewrite_parameters(
         body_name="policy",
     )
+    @_availability_warning(Stability.STABLE, Visibility.PRIVATE)
     async def put_autoscaling_policy(
         self,
         *,

elasticsearch/_async/client/cat.py

@@ -23,9 +23,9 @@
 from .utils import (
     SKIP_IN_PATH,
     Stability,
+    _availability_warning,
     _quote,
     _rewrite_parameters,
-    _stability_warning,
 )
 
 
@@ -3861,7 +3861,7 @@ async def snapshots(
         )
 
     @_rewrite_parameters()
-    @_stability_warning(Stability.EXPERIMENTAL)
+    @_availability_warning(Stability.EXPERIMENTAL)
     async def tasks(
         self,
         *,

elasticsearch/_async/client/connector.py

@@ -23,16 +23,17 @@
 from .utils import (
     SKIP_IN_PATH,
     Stability,
+    Visibility,
+    _availability_warning,
     _quote,
     _rewrite_parameters,
-    _stability_warning,
 )
 
 
 class ConnectorClient(NamespacedClient):
 
     @_rewrite_parameters()
-    @_stability_warning(Stability.EXPERIMENTAL)
+    @_availability_warning(Stability.EXPERIMENTAL)
     async def check_in(
         self,
         *,
@@ -77,7 +78,7 @@ async def check_in(
         )
 
     @_rewrite_parameters()
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def delete(
         self,
         *,
@@ -134,7 +135,7 @@ async def delete(
         )
 
     @_rewrite_parameters()
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def get(
         self,
         *,
@@ -199,7 +200,7 @@ async def get(
             "sync_cursor",
         ),
     )
-    @_stability_warning(Stability.EXPERIMENTAL)
+    @_availability_warning(Stability.EXPERIMENTAL, Visibility.PRIVATE)
     async def last_sync(
         self,
         *,
@@ -333,7 +334,7 @@ async def last_sync(
     @_rewrite_parameters(
         parameter_aliases={"from": "from_"},
     )
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def list(
         self,
         *,
@@ -416,7 +417,7 @@ async def list(
             "service_type",
         ),
     )
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def post(
         self,
         *,
@@ -500,7 +501,7 @@ async def post(
             "service_type",
         ),
     )
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def put(
         self,
         *,
@@ -580,7 +581,7 @@ async def put(
         )
 
     @_rewrite_parameters()
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def sync_job_cancel(
         self,
         *,
@@ -630,7 +631,7 @@ async def sync_job_cancel(
         )
 
     @_rewrite_parameters()
-    @_stability_warning(Stability.EXPERIMENTAL)
+    @_availability_warning(Stability.EXPERIMENTAL)
     async def sync_job_check_in(
         self,
         *,
@@ -684,7 +685,7 @@ async def sync_job_check_in(
     @_rewrite_parameters(
         body_fields=("worker_hostname", "sync_cursor"),
     )
-    @_stability_warning(Stability.EXPERIMENTAL)
+    @_availability_warning(Stability.EXPERIMENTAL)
     async def sync_job_claim(
         self,
         *,
@@ -753,7 +754,7 @@ async def sync_job_claim(
         )
 
     @_rewrite_parameters()
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def sync_job_delete(
         self,
         *,
@@ -804,7 +805,7 @@ async def sync_job_delete(
     @_rewrite_parameters(
         body_fields=("error",),
     )
-    @_stability_warning(Stability.EXPERIMENTAL)
+    @_availability_warning(Stability.EXPERIMENTAL)
     async def sync_job_error(
         self,
         *,
@@ -863,7 +864,7 @@ async def sync_job_error(
         )
 
     @_rewrite_parameters()
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def sync_job_get(
         self,
         *,
@@ -911,7 +912,7 @@ async def sync_job_get(
     @_rewrite_parameters(
         parameter_aliases={"from": "from_"},
     )
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def sync_job_list(
         self,
         *,
@@ -994,7 +995,7 @@ async def sync_job_list(
     @_rewrite_parameters(
         body_fields=("id", "job_type", "trigger_method"),
     )
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def sync_job_post(
         self,
         *,
@@ -1066,7 +1067,7 @@ async def sync_job_post(
             "total_document_count",
         ),
     )
-    @_stability_warning(Stability.EXPERIMENTAL)
+    @_availability_warning(Stability.EXPERIMENTAL)
     async def sync_job_update_stats(
         self,
         *,
@@ -1160,7 +1161,7 @@ async def sync_job_update_stats(
         )
 
     @_rewrite_parameters()
-    @_stability_warning(Stability.EXPERIMENTAL)
+    @_availability_warning(Stability.EXPERIMENTAL)
     async def update_active_filtering(
         self,
         *,
@@ -1207,7 +1208,7 @@ async def update_active_filtering(
     @_rewrite_parameters(
         body_fields=("api_key_id", "api_key_secret_id"),
     )
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def update_api_key_id(
         self,
         *,
@@ -1269,7 +1270,7 @@ async def update_api_key_id(
     @_rewrite_parameters(
         body_fields=("configuration", "values"),
     )
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def update_configuration(
         self,
         *,
@@ -1328,7 +1329,7 @@ async def update_configuration(
     @_rewrite_parameters(
         body_fields=("error",),
     )
-    @_stability_warning(Stability.EXPERIMENTAL)
+    @_availability_warning(Stability.EXPERIMENTAL)
     async def update_error(
         self,
         *,
@@ -1387,7 +1388,7 @@ async def update_error(
     @_rewrite_parameters(
         body_fields=("features",),
     )
-    @_stability_warning(Stability.EXPERIMENTAL)
+    @_availability_warning(Stability.EXPERIMENTAL)
     async def update_features(
         self,
         *,
@@ -1455,7 +1456,7 @@ async def update_features(
     @_rewrite_parameters(
         body_fields=("advanced_snippet", "filtering", "rules"),
     )
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def update_filtering(
         self,
         *,
@@ -1520,7 +1521,7 @@ async def update_filtering(
     @_rewrite_parameters(
         body_fields=("validation",),
     )
-    @_stability_warning(Stability.EXPERIMENTAL)
+    @_availability_warning(Stability.EXPERIMENTAL)
     async def update_filtering_validation(
         self,
         *,
@@ -1577,7 +1578,7 @@ async def update_filtering_validation(
     @_rewrite_parameters(
         body_fields=("index_name",),
     )
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def update_index_name(
         self,
         *,
@@ -1634,7 +1635,7 @@ async def update_index_name(
     @_rewrite_parameters(
         body_fields=("description", "name"),
     )
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def update_name(
         self,
         *,
@@ -1692,7 +1693,7 @@ async def update_name(
     @_rewrite_parameters(
         body_fields=("is_native",),
     )
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def update_native(
         self,
         *,
@@ -1748,7 +1749,7 @@ async def update_native(
     @_rewrite_parameters(
         body_fields=("pipeline",),
     )
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def update_pipeline(
         self,
         *,
@@ -1805,7 +1806,7 @@ async def update_pipeline(
     @_rewrite_parameters(
         body_fields=("scheduling",),
     )
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def update_scheduling(
         self,
         *,
@@ -1861,7 +1862,7 @@ async def update_scheduling(
     @_rewrite_parameters(
         body_fields=("service_type",),
     )
-    @_stability_warning(Stability.BETA)
+    @_availability_warning(Stability.BETA)
     async def update_service_type(
         self,
         *,
@@ -1917,7 +1918,7 @@ async def update_service_type(
     @_rewrite_parameters(
         body_fields=("status",),
     )
-    @_stability_warning(Stability.EXPERIMENTAL)
+    @_availability_warning(Stability.EXPERIMENTAL)
     async def update_status(
         self,
         *,

elasticsearch/_async/client/esql.py

@@ -23,9 +23,9 @@
 from .utils import (
     SKIP_IN_PATH,
     Stability,
+    _availability_warning,
     _quote,
     _rewrite_parameters,
-    _stability_warning,
 )
 
 if t.TYPE_CHECKING:
@@ -396,7 +396,7 @@ async def async_query_stop(
         )
 
     @_rewrite_parameters()
-    @_stability_warning(Stability.EXPERIMENTAL)
+    @_availability_warning(Stability.EXPERIMENTAL)
     async def get_query(
         self,
         *,
@@ -441,7 +441,7 @@ async def get_query(
         )
 
     @_rewrite_parameters()
-    @_stability_warning(Stability.EXPERIMENTAL)
+    @_availability_warning(Stability.EXPERIMENTAL)
     async def list_queries(
         self,
         *,