|
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