|
20 | 20 | from elastic_transport import ObjectApiResponse |
21 | 21 |
|
22 | 22 | from ._base import NamespacedClient |
23 | | -from .utils import SKIP_IN_PATH, _quote, _rewrite_parameters |
| 23 | +from .utils import ( |
| 24 | + SKIP_IN_PATH, |
| 25 | + Stability, |
| 26 | + _quote, |
| 27 | + _rewrite_parameters, |
| 28 | + _stability_warning, |
| 29 | +) |
24 | 30 |
|
25 | 31 |
|
26 | 32 | class ConnectorClient(NamespacedClient): |
27 | 33 |
|
28 | 34 | @_rewrite_parameters() |
| 35 | + @_stability_warning(Stability.EXPERIMENTAL) |
29 | 36 | async def check_in( |
30 | 37 | self, |
31 | 38 | *, |
@@ -67,6 +74,7 @@ async def check_in( |
67 | 74 | ) |
68 | 75 |
|
69 | 76 | @_rewrite_parameters() |
| 77 | + @_stability_warning(Stability.BETA) |
70 | 78 | async def delete( |
71 | 79 | self, |
72 | 80 | *, |
@@ -115,6 +123,7 @@ async def delete( |
115 | 123 | ) |
116 | 124 |
|
117 | 125 | @_rewrite_parameters() |
| 126 | + @_stability_warning(Stability.BETA) |
118 | 127 | async def get( |
119 | 128 | self, |
120 | 129 | *, |
@@ -157,6 +166,7 @@ async def get( |
157 | 166 | @_rewrite_parameters( |
158 | 167 | parameter_aliases={"from": "from_"}, |
159 | 168 | ) |
| 169 | + @_stability_warning(Stability.BETA) |
160 | 170 | async def list( |
161 | 171 | self, |
162 | 172 | *, |
@@ -230,6 +240,7 @@ async def list( |
230 | 240 | "service_type", |
231 | 241 | ), |
232 | 242 | ) |
| 243 | + @_stability_warning(Stability.BETA) |
233 | 244 | async def post( |
234 | 245 | self, |
235 | 246 | *, |
@@ -311,6 +322,7 @@ async def post( |
311 | 322 | "service_type", |
312 | 323 | ), |
313 | 324 | ) |
| 325 | + @_stability_warning(Stability.BETA) |
314 | 326 | async def put( |
315 | 327 | self, |
316 | 328 | *, |
@@ -387,6 +399,7 @@ async def put( |
387 | 399 | ) |
388 | 400 |
|
389 | 401 | @_rewrite_parameters() |
| 402 | + @_stability_warning(Stability.BETA) |
390 | 403 | async def sync_job_cancel( |
391 | 404 | self, |
392 | 405 | *, |
@@ -434,6 +447,7 @@ async def sync_job_cancel( |
434 | 447 | ) |
435 | 448 |
|
436 | 449 | @_rewrite_parameters() |
| 450 | + @_stability_warning(Stability.BETA) |
437 | 451 | async def sync_job_delete( |
438 | 452 | self, |
439 | 453 | *, |
@@ -478,6 +492,7 @@ async def sync_job_delete( |
478 | 492 | ) |
479 | 493 |
|
480 | 494 | @_rewrite_parameters() |
| 495 | + @_stability_warning(Stability.BETA) |
481 | 496 | async def sync_job_get( |
482 | 497 | self, |
483 | 498 | *, |
@@ -522,6 +537,7 @@ async def sync_job_get( |
522 | 537 | @_rewrite_parameters( |
523 | 538 | parameter_aliases={"from": "from_"}, |
524 | 539 | ) |
| 540 | + @_stability_warning(Stability.BETA) |
525 | 541 | async def sync_job_list( |
526 | 542 | self, |
527 | 543 | *, |
@@ -601,6 +617,7 @@ async def sync_job_list( |
601 | 617 | @_rewrite_parameters( |
602 | 618 | body_fields=("id", "job_type", "trigger_method"), |
603 | 619 | ) |
| 620 | + @_stability_warning(Stability.BETA) |
604 | 621 | async def sync_job_post( |
605 | 622 | self, |
606 | 623 | *, |
@@ -660,6 +677,7 @@ async def sync_job_post( |
660 | 677 | ) |
661 | 678 |
|
662 | 679 | @_rewrite_parameters() |
| 680 | + @_stability_warning(Stability.EXPERIMENTAL) |
663 | 681 | async def update_active_filtering( |
664 | 682 | self, |
665 | 683 | *, |
@@ -703,6 +721,7 @@ async def update_active_filtering( |
703 | 721 | @_rewrite_parameters( |
704 | 722 | body_fields=("api_key_id", "api_key_secret_id"), |
705 | 723 | ) |
| 724 | + @_stability_warning(Stability.BETA) |
706 | 725 | async def update_api_key_id( |
707 | 726 | self, |
708 | 727 | *, |
@@ -761,6 +780,7 @@ async def update_api_key_id( |
761 | 780 | @_rewrite_parameters( |
762 | 781 | body_fields=("configuration", "values"), |
763 | 782 | ) |
| 783 | + @_stability_warning(Stability.BETA) |
764 | 784 | async def update_configuration( |
765 | 785 | self, |
766 | 786 | *, |
@@ -816,6 +836,7 @@ async def update_configuration( |
816 | 836 | @_rewrite_parameters( |
817 | 837 | body_fields=("error",), |
818 | 838 | ) |
| 839 | + @_stability_warning(Stability.EXPERIMENTAL) |
819 | 840 | async def update_error( |
820 | 841 | self, |
821 | 842 | *, |
@@ -871,6 +892,7 @@ async def update_error( |
871 | 892 | @_rewrite_parameters( |
872 | 893 | body_fields=("advanced_snippet", "filtering", "rules"), |
873 | 894 | ) |
| 895 | + @_stability_warning(Stability.BETA) |
874 | 896 | async def update_filtering( |
875 | 897 | self, |
876 | 898 | *, |
@@ -932,6 +954,7 @@ async def update_filtering( |
932 | 954 | @_rewrite_parameters( |
933 | 955 | body_fields=("validation",), |
934 | 956 | ) |
| 957 | + @_stability_warning(Stability.EXPERIMENTAL) |
935 | 958 | async def update_filtering_validation( |
936 | 959 | self, |
937 | 960 | *, |
@@ -985,6 +1008,7 @@ async def update_filtering_validation( |
985 | 1008 | @_rewrite_parameters( |
986 | 1009 | body_fields=("index_name",), |
987 | 1010 | ) |
| 1011 | + @_stability_warning(Stability.BETA) |
988 | 1012 | async def update_index_name( |
989 | 1013 | self, |
990 | 1014 | *, |
@@ -1038,6 +1062,7 @@ async def update_index_name( |
1038 | 1062 | @_rewrite_parameters( |
1039 | 1063 | body_fields=("description", "name"), |
1040 | 1064 | ) |
| 1065 | + @_stability_warning(Stability.BETA) |
1041 | 1066 | async def update_name( |
1042 | 1067 | self, |
1043 | 1068 | *, |
@@ -1092,6 +1117,7 @@ async def update_name( |
1092 | 1117 | @_rewrite_parameters( |
1093 | 1118 | body_fields=("is_native",), |
1094 | 1119 | ) |
| 1120 | + @_stability_warning(Stability.BETA) |
1095 | 1121 | async def update_native( |
1096 | 1122 | self, |
1097 | 1123 | *, |
@@ -1144,6 +1170,7 @@ async def update_native( |
1144 | 1170 | @_rewrite_parameters( |
1145 | 1171 | body_fields=("pipeline",), |
1146 | 1172 | ) |
| 1173 | + @_stability_warning(Stability.BETA) |
1147 | 1174 | async def update_pipeline( |
1148 | 1175 | self, |
1149 | 1176 | *, |
@@ -1197,6 +1224,7 @@ async def update_pipeline( |
1197 | 1224 | @_rewrite_parameters( |
1198 | 1225 | body_fields=("scheduling",), |
1199 | 1226 | ) |
| 1227 | + @_stability_warning(Stability.BETA) |
1200 | 1228 | async def update_scheduling( |
1201 | 1229 | self, |
1202 | 1230 | *, |
@@ -1249,6 +1277,7 @@ async def update_scheduling( |
1249 | 1277 | @_rewrite_parameters( |
1250 | 1278 | body_fields=("service_type",), |
1251 | 1279 | ) |
| 1280 | + @_stability_warning(Stability.BETA) |
1252 | 1281 | async def update_service_type( |
1253 | 1282 | self, |
1254 | 1283 | *, |
@@ -1301,6 +1330,7 @@ async def update_service_type( |
1301 | 1330 | @_rewrite_parameters( |
1302 | 1331 | body_fields=("status",), |
1303 | 1332 | ) |
| 1333 | + @_stability_warning(Stability.EXPERIMENTAL) |
1304 | 1334 | async def update_status( |
1305 | 1335 | self, |
1306 | 1336 | *, |
|
0 commit comments