@@ -33,6 +33,103 @@ def __init__(self, api_client=None):
33
33
api_client = volcenginesdkcore .ApiClient ()
34
34
self .api_client = api_client
35
35
36
+ def create_endpoint_acl_policies (self , body , ** kwargs ): # noqa: E501
37
+ """create_endpoint_acl_policies # noqa: E501
38
+
39
+ This method makes a synchronous HTTP request by default. To make an
40
+ asynchronous HTTP request, please pass async_req=True
41
+ >>> thread = api.create_endpoint_acl_policies(body, async_req=True)
42
+ >>> result = thread.get()
43
+
44
+ :param async_req bool
45
+ :param CreateEndpointAclPoliciesRequest body: (required)
46
+ :return: CreateEndpointAclPoliciesResponse
47
+ If the method is called asynchronously,
48
+ returns the request thread.
49
+ """
50
+ kwargs ['_return_http_data_only' ] = True
51
+ if kwargs .get ('async_req' ):
52
+ return self .create_endpoint_acl_policies_with_http_info (body , ** kwargs ) # noqa: E501
53
+ else :
54
+ (data ) = self .create_endpoint_acl_policies_with_http_info (body , ** kwargs ) # noqa: E501
55
+ return data
56
+
57
+ def create_endpoint_acl_policies_with_http_info (self , body , ** kwargs ): # noqa: E501
58
+ """create_endpoint_acl_policies # noqa: E501
59
+
60
+ This method makes a synchronous HTTP request by default. To make an
61
+ asynchronous HTTP request, please pass async_req=True
62
+ >>> thread = api.create_endpoint_acl_policies_with_http_info(body, async_req=True)
63
+ >>> result = thread.get()
64
+
65
+ :param async_req bool
66
+ :param CreateEndpointAclPoliciesRequest body: (required)
67
+ :return: CreateEndpointAclPoliciesResponse
68
+ If the method is called asynchronously,
69
+ returns the request thread.
70
+ """
71
+
72
+ all_params = ['body' ] # noqa: E501
73
+ all_params .append ('async_req' )
74
+ all_params .append ('_return_http_data_only' )
75
+ all_params .append ('_preload_content' )
76
+ all_params .append ('_request_timeout' )
77
+
78
+ params = locals ()
79
+ for key , val in six .iteritems (params ['kwargs' ]):
80
+ if key not in all_params :
81
+ raise TypeError (
82
+ "Got an unexpected keyword argument '%s'"
83
+ " to method create_endpoint_acl_policies" % key
84
+ )
85
+ params [key ] = val
86
+ del params ['kwargs' ]
87
+ # verify the required parameter 'body' is set
88
+ if self .api_client .client_side_validation and ('body' not in params or
89
+ params ['body' ] is None ): # noqa: E501
90
+ raise ValueError ("Missing the required parameter `body` when calling `create_endpoint_acl_policies`" ) # noqa: E501
91
+
92
+ collection_formats = {}
93
+
94
+ path_params = {}
95
+
96
+ query_params = []
97
+
98
+ header_params = {}
99
+
100
+ form_params = []
101
+ local_var_files = {}
102
+
103
+ body_params = None
104
+ if 'body' in params :
105
+ body_params = params ['body' ]
106
+ # HTTP header `Accept`
107
+ header_params ['Accept' ] = self .api_client .select_header_accept (
108
+ ['application/json' ]) # noqa: E501
109
+
110
+ # HTTP header `Content-Type`
111
+ header_params ['Content-Type' ] = self .api_client .select_header_content_type ( # noqa: E501
112
+ ['application/json' ]) # noqa: E501
113
+
114
+ # Authentication setting
115
+ auth_settings = ['volcengineSign' ] # noqa: E501
116
+
117
+ return self .api_client .call_api (
118
+ '/CreateEndpointAclPolicies/2022-05-12/cr/post/application_json/' , 'POST' ,
119
+ path_params ,
120
+ query_params ,
121
+ header_params ,
122
+ body = body_params ,
123
+ post_params = form_params ,
124
+ files = local_var_files ,
125
+ response_type = 'CreateEndpointAclPoliciesResponse' , # noqa: E501
126
+ auth_settings = auth_settings ,
127
+ async_req = params .get ('async_req' ),
128
+ _return_http_data_only = params .get ('_return_http_data_only' ),
129
+ _preload_content = params .get ('_preload_content' , True ),
130
+ _request_timeout = params .get ('_request_timeout' ),
131
+ collection_formats = collection_formats )
132
+
36
133
def create_namespace (self , body , ** kwargs ): # noqa: E501
37
134
"""create_namespace # noqa: E501
38
135
@@ -324,6 +421,103 @@ def create_repository_with_http_info(self, body, **kwargs): # noqa: E501
324
421
_request_timeout = params .get ('_request_timeout' ),
325
422
collection_formats = collection_formats )
326
423
424
+ def delete_endpoint_acl_policies (self , body , ** kwargs ): # noqa: E501
425
+ """delete_endpoint_acl_policies # noqa: E501
426
+
427
+ This method makes a synchronous HTTP request by default. To make an
428
+ asynchronous HTTP request, please pass async_req=True
429
+ >>> thread = api.delete_endpoint_acl_policies(body, async_req=True)
430
+ >>> result = thread.get()
431
+
432
+ :param async_req bool
433
+ :param DeleteEndpointAclPoliciesRequest body: (required)
434
+ :return: DeleteEndpointAclPoliciesResponse
435
+ If the method is called asynchronously,
436
+ returns the request thread.
437
+ """
438
+ kwargs ['_return_http_data_only' ] = True
439
+ if kwargs .get ('async_req' ):
440
+ return self .delete_endpoint_acl_policies_with_http_info (body , ** kwargs ) # noqa: E501
441
+ else :
442
+ (data ) = self .delete_endpoint_acl_policies_with_http_info (body , ** kwargs ) # noqa: E501
443
+ return data
444
+
445
+ def delete_endpoint_acl_policies_with_http_info (self , body , ** kwargs ): # noqa: E501
446
+ """delete_endpoint_acl_policies # noqa: E501
447
+
448
+ This method makes a synchronous HTTP request by default. To make an
449
+ asynchronous HTTP request, please pass async_req=True
450
+ >>> thread = api.delete_endpoint_acl_policies_with_http_info(body, async_req=True)
451
+ >>> result = thread.get()
452
+
453
+ :param async_req bool
454
+ :param DeleteEndpointAclPoliciesRequest body: (required)
455
+ :return: DeleteEndpointAclPoliciesResponse
456
+ If the method is called asynchronously,
457
+ returns the request thread.
458
+ """
459
+
460
+ all_params = ['body' ] # noqa: E501
461
+ all_params .append ('async_req' )
462
+ all_params .append ('_return_http_data_only' )
463
+ all_params .append ('_preload_content' )
464
+ all_params .append ('_request_timeout' )
465
+
466
+ params = locals ()
467
+ for key , val in six .iteritems (params ['kwargs' ]):
468
+ if key not in all_params :
469
+ raise TypeError (
470
+ "Got an unexpected keyword argument '%s'"
471
+ " to method delete_endpoint_acl_policies" % key
472
+ )
473
+ params [key ] = val
474
+ del params ['kwargs' ]
475
+ # verify the required parameter 'body' is set
476
+ if self .api_client .client_side_validation and ('body' not in params or
477
+ params ['body' ] is None ): # noqa: E501
478
+ raise ValueError ("Missing the required parameter `body` when calling `delete_endpoint_acl_policies`" ) # noqa: E501
479
+
480
+ collection_formats = {}
481
+
482
+ path_params = {}
483
+
484
+ query_params = []
485
+
486
+ header_params = {}
487
+
488
+ form_params = []
489
+ local_var_files = {}
490
+
491
+ body_params = None
492
+ if 'body' in params :
493
+ body_params = params ['body' ]
494
+ # HTTP header `Accept`
495
+ header_params ['Accept' ] = self .api_client .select_header_accept (
496
+ ['application/json' ]) # noqa: E501
497
+
498
+ # HTTP header `Content-Type`
499
+ header_params ['Content-Type' ] = self .api_client .select_header_content_type ( # noqa: E501
500
+ ['application/json' ]) # noqa: E501
501
+
502
+ # Authentication setting
503
+ auth_settings = ['volcengineSign' ] # noqa: E501
504
+
505
+ return self .api_client .call_api (
506
+ '/DeleteEndpointAclPolicies/2022-05-12/cr/post/application_json/' , 'POST' ,
507
+ path_params ,
508
+ query_params ,
509
+ header_params ,
510
+ body = body_params ,
511
+ post_params = form_params ,
512
+ files = local_var_files ,
513
+ response_type = 'DeleteEndpointAclPoliciesResponse' , # noqa: E501
514
+ auth_settings = auth_settings ,
515
+ async_req = params .get ('async_req' ),
516
+ _return_http_data_only = params .get ('_return_http_data_only' ),
517
+ _preload_content = params .get ('_preload_content' , True ),
518
+ _request_timeout = params .get ('_request_timeout' ),
519
+ collection_formats = collection_formats )
520
+
327
521
def delete_namespace (self , body , ** kwargs ): # noqa: E501
328
522
"""delete_namespace # noqa: E501
329
523
0 commit comments