|
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 | *, |
@@ -170,6 +179,7 @@ async def get( |
170 | 179 | "sync_cursor", |
171 | 180 | ), |
172 | 181 | ) |
| 182 | + @_stability_warning(Stability.EXPERIMENTAL) |
173 | 183 | async def last_sync( |
174 | 184 | self, |
175 | 185 | *, |
@@ -299,6 +309,7 @@ async def last_sync( |
299 | 309 | @_rewrite_parameters( |
300 | 310 | parameter_aliases={"from": "from_"}, |
301 | 311 | ) |
| 312 | + @_stability_warning(Stability.BETA) |
302 | 313 | async def list( |
303 | 314 | self, |
304 | 315 | *, |
@@ -372,6 +383,7 @@ async def list( |
372 | 383 | "service_type", |
373 | 384 | ), |
374 | 385 | ) |
| 386 | + @_stability_warning(Stability.BETA) |
375 | 387 | async def post( |
376 | 388 | self, |
377 | 389 | *, |
@@ -453,6 +465,7 @@ async def post( |
453 | 465 | "service_type", |
454 | 466 | ), |
455 | 467 | ) |
| 468 | + @_stability_warning(Stability.BETA) |
456 | 469 | async def put( |
457 | 470 | self, |
458 | 471 | *, |
@@ -529,6 +542,7 @@ async def put( |
529 | 542 | ) |
530 | 543 |
|
531 | 544 | @_rewrite_parameters() |
| 545 | + @_stability_warning(Stability.BETA) |
532 | 546 | async def sync_job_cancel( |
533 | 547 | self, |
534 | 548 | *, |
@@ -576,6 +590,7 @@ async def sync_job_cancel( |
576 | 590 | ) |
577 | 591 |
|
578 | 592 | @_rewrite_parameters() |
| 593 | + @_stability_warning(Stability.BETA) |
579 | 594 | async def sync_job_delete( |
580 | 595 | self, |
581 | 596 | *, |
@@ -620,6 +635,7 @@ async def sync_job_delete( |
620 | 635 | ) |
621 | 636 |
|
622 | 637 | @_rewrite_parameters() |
| 638 | + @_stability_warning(Stability.BETA) |
623 | 639 | async def sync_job_get( |
624 | 640 | self, |
625 | 641 | *, |
@@ -664,6 +680,7 @@ async def sync_job_get( |
664 | 680 | @_rewrite_parameters( |
665 | 681 | parameter_aliases={"from": "from_"}, |
666 | 682 | ) |
| 683 | + @_stability_warning(Stability.BETA) |
667 | 684 | async def sync_job_list( |
668 | 685 | self, |
669 | 686 | *, |
@@ -743,6 +760,7 @@ async def sync_job_list( |
743 | 760 | @_rewrite_parameters( |
744 | 761 | body_fields=("id", "job_type", "trigger_method"), |
745 | 762 | ) |
| 763 | + @_stability_warning(Stability.BETA) |
746 | 764 | async def sync_job_post( |
747 | 765 | self, |
748 | 766 | *, |
@@ -802,6 +820,7 @@ async def sync_job_post( |
802 | 820 | ) |
803 | 821 |
|
804 | 822 | @_rewrite_parameters() |
| 823 | + @_stability_warning(Stability.EXPERIMENTAL) |
805 | 824 | async def update_active_filtering( |
806 | 825 | self, |
807 | 826 | *, |
@@ -845,6 +864,7 @@ async def update_active_filtering( |
845 | 864 | @_rewrite_parameters( |
846 | 865 | body_fields=("api_key_id", "api_key_secret_id"), |
847 | 866 | ) |
| 867 | + @_stability_warning(Stability.BETA) |
848 | 868 | async def update_api_key_id( |
849 | 869 | self, |
850 | 870 | *, |
@@ -903,6 +923,7 @@ async def update_api_key_id( |
903 | 923 | @_rewrite_parameters( |
904 | 924 | body_fields=("configuration", "values"), |
905 | 925 | ) |
| 926 | + @_stability_warning(Stability.BETA) |
906 | 927 | async def update_configuration( |
907 | 928 | self, |
908 | 929 | *, |
@@ -958,6 +979,7 @@ async def update_configuration( |
958 | 979 | @_rewrite_parameters( |
959 | 980 | body_fields=("error",), |
960 | 981 | ) |
| 982 | + @_stability_warning(Stability.EXPERIMENTAL) |
961 | 983 | async def update_error( |
962 | 984 | self, |
963 | 985 | *, |
@@ -1013,6 +1035,7 @@ async def update_error( |
1013 | 1035 | @_rewrite_parameters( |
1014 | 1036 | body_fields=("advanced_snippet", "filtering", "rules"), |
1015 | 1037 | ) |
| 1038 | + @_stability_warning(Stability.BETA) |
1016 | 1039 | async def update_filtering( |
1017 | 1040 | self, |
1018 | 1041 | *, |
@@ -1074,6 +1097,7 @@ async def update_filtering( |
1074 | 1097 | @_rewrite_parameters( |
1075 | 1098 | body_fields=("validation",), |
1076 | 1099 | ) |
| 1100 | + @_stability_warning(Stability.EXPERIMENTAL) |
1077 | 1101 | async def update_filtering_validation( |
1078 | 1102 | self, |
1079 | 1103 | *, |
@@ -1127,6 +1151,7 @@ async def update_filtering_validation( |
1127 | 1151 | @_rewrite_parameters( |
1128 | 1152 | body_fields=("index_name",), |
1129 | 1153 | ) |
| 1154 | + @_stability_warning(Stability.BETA) |
1130 | 1155 | async def update_index_name( |
1131 | 1156 | self, |
1132 | 1157 | *, |
@@ -1180,6 +1205,7 @@ async def update_index_name( |
1180 | 1205 | @_rewrite_parameters( |
1181 | 1206 | body_fields=("description", "name"), |
1182 | 1207 | ) |
| 1208 | + @_stability_warning(Stability.BETA) |
1183 | 1209 | async def update_name( |
1184 | 1210 | self, |
1185 | 1211 | *, |
@@ -1234,6 +1260,7 @@ async def update_name( |
1234 | 1260 | @_rewrite_parameters( |
1235 | 1261 | body_fields=("is_native",), |
1236 | 1262 | ) |
| 1263 | + @_stability_warning(Stability.BETA) |
1237 | 1264 | async def update_native( |
1238 | 1265 | self, |
1239 | 1266 | *, |
@@ -1286,6 +1313,7 @@ async def update_native( |
1286 | 1313 | @_rewrite_parameters( |
1287 | 1314 | body_fields=("pipeline",), |
1288 | 1315 | ) |
| 1316 | + @_stability_warning(Stability.BETA) |
1289 | 1317 | async def update_pipeline( |
1290 | 1318 | self, |
1291 | 1319 | *, |
@@ -1339,6 +1367,7 @@ async def update_pipeline( |
1339 | 1367 | @_rewrite_parameters( |
1340 | 1368 | body_fields=("scheduling",), |
1341 | 1369 | ) |
| 1370 | + @_stability_warning(Stability.BETA) |
1342 | 1371 | async def update_scheduling( |
1343 | 1372 | self, |
1344 | 1373 | *, |
@@ -1391,6 +1420,7 @@ async def update_scheduling( |
1391 | 1420 | @_rewrite_parameters( |
1392 | 1421 | body_fields=("service_type",), |
1393 | 1422 | ) |
| 1423 | + @_stability_warning(Stability.BETA) |
1394 | 1424 | async def update_service_type( |
1395 | 1425 | self, |
1396 | 1426 | *, |
@@ -1443,6 +1473,7 @@ async def update_service_type( |
1443 | 1473 | @_rewrite_parameters( |
1444 | 1474 | body_fields=("status",), |
1445 | 1475 | ) |
| 1476 | + @_stability_warning(Stability.EXPERIMENTAL) |
1446 | 1477 | async def update_status( |
1447 | 1478 | self, |
1448 | 1479 | *, |
|
0 commit comments