Skip to content

Commit 1e06e6a

Browse files
author
BitsAdmin
committed
Merge branch 'rds_postgresql-Python-2022-01-01-online-1032-2025_03_17_19_11_05' into 'integration_2025-03-20_798327825666'
feat: [development task] rds_postgresql-1032-Python (1094122) See merge request iaasng/volcengine-python-sdk!542
2 parents ad6df31 + a466693 commit 1e06e6a

File tree

48 files changed

+1455
-501
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

48 files changed

+1455
-501
lines changed

volcenginesdkrdspostgresql/__init__.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,8 @@
7272
from volcenginesdkrdspostgresql.models.delete_database_response import DeleteDatabaseResponse
7373
from volcenginesdkrdspostgresql.models.delete_schema_request import DeleteSchemaRequest
7474
from volcenginesdkrdspostgresql.models.delete_schema_response import DeleteSchemaResponse
75+
from volcenginesdkrdspostgresql.models.delete_slot_request import DeleteSlotRequest
76+
from volcenginesdkrdspostgresql.models.delete_slot_response import DeleteSlotResponse
7577
from volcenginesdkrdspostgresql.models.describe_allow_list_detail_request import DescribeAllowListDetailRequest
7678
from volcenginesdkrdspostgresql.models.describe_allow_list_detail_response import DescribeAllowListDetailResponse
7779
from volcenginesdkrdspostgresql.models.describe_allow_lists_request import DescribeAllowListsRequest
@@ -110,6 +112,8 @@
110112
from volcenginesdkrdspostgresql.models.describe_regions_response import DescribeRegionsResponse
111113
from volcenginesdkrdspostgresql.models.describe_schemas_request import DescribeSchemasRequest
112114
from volcenginesdkrdspostgresql.models.describe_schemas_response import DescribeSchemasResponse
115+
from volcenginesdkrdspostgresql.models.describe_slots_request import DescribeSlotsRequest
116+
from volcenginesdkrdspostgresql.models.describe_slots_response import DescribeSlotsResponse
113117
from volcenginesdkrdspostgresql.models.disassociate_allow_list_request import DisassociateAllowListRequest
114118
from volcenginesdkrdspostgresql.models.disassociate_allow_list_response import DisassociateAllowListResponse
115119
from volcenginesdkrdspostgresql.models.endpoint_for_describe_db_instance_detail_output import EndpointForDescribeDBInstanceDetailOutput
@@ -172,6 +176,7 @@
172176
from volcenginesdkrdspostgresql.models.region_for_describe_regions_output import RegionForDescribeRegionsOutput
173177
from volcenginesdkrdspostgresql.models.remove_tags_from_resource_request import RemoveTagsFromResourceRequest
174178
from volcenginesdkrdspostgresql.models.remove_tags_from_resource_response import RemoveTagsFromResourceResponse
179+
from volcenginesdkrdspostgresql.models.replication_slot_for_describe_slots_output import ReplicationSlotForDescribeSlotsOutput
175180
from volcenginesdkrdspostgresql.models.reset_db_account_request import ResetDBAccountRequest
176181
from volcenginesdkrdspostgresql.models.reset_db_account_response import ResetDBAccountResponse
177182
from volcenginesdkrdspostgresql.models.restart_db_instance_request import RestartDBInstanceRequest

volcenginesdkrdspostgresql/api/rds_postgresql_api.py

Lines changed: 194 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1682,6 +1682,103 @@ def delete_schema_with_http_info(self, body, **kwargs): # noqa: E501
16821682
_request_timeout=params.get('_request_timeout'),
16831683
collection_formats=collection_formats)
16841684

1685+
def delete_slot(self, body, **kwargs): # noqa: E501
1686+
"""delete_slot # noqa: E501
1687+
1688+
This method makes a synchronous HTTP request by default. To make an
1689+
asynchronous HTTP request, please pass async_req=True
1690+
>>> thread = api.delete_slot(body, async_req=True)
1691+
>>> result = thread.get()
1692+
1693+
:param async_req bool
1694+
:param DeleteSlotRequest body: (required)
1695+
:return: DeleteSlotResponse
1696+
If the method is called asynchronously,
1697+
returns the request thread.
1698+
"""
1699+
kwargs['_return_http_data_only'] = True
1700+
if kwargs.get('async_req'):
1701+
return self.delete_slot_with_http_info(body, **kwargs) # noqa: E501
1702+
else:
1703+
(data) = self.delete_slot_with_http_info(body, **kwargs) # noqa: E501
1704+
return data
1705+
1706+
def delete_slot_with_http_info(self, body, **kwargs): # noqa: E501
1707+
"""delete_slot # noqa: E501
1708+
1709+
This method makes a synchronous HTTP request by default. To make an
1710+
asynchronous HTTP request, please pass async_req=True
1711+
>>> thread = api.delete_slot_with_http_info(body, async_req=True)
1712+
>>> result = thread.get()
1713+
1714+
:param async_req bool
1715+
:param DeleteSlotRequest body: (required)
1716+
:return: DeleteSlotResponse
1717+
If the method is called asynchronously,
1718+
returns the request thread.
1719+
"""
1720+
1721+
all_params = ['body'] # noqa: E501
1722+
all_params.append('async_req')
1723+
all_params.append('_return_http_data_only')
1724+
all_params.append('_preload_content')
1725+
all_params.append('_request_timeout')
1726+
1727+
params = locals()
1728+
for key, val in six.iteritems(params['kwargs']):
1729+
if key not in all_params:
1730+
raise TypeError(
1731+
"Got an unexpected keyword argument '%s'"
1732+
" to method delete_slot" % key
1733+
)
1734+
params[key] = val
1735+
del params['kwargs']
1736+
# verify the required parameter 'body' is set
1737+
if self.api_client.client_side_validation and ('body' not in params or
1738+
params['body'] is None): # noqa: E501
1739+
raise ValueError("Missing the required parameter `body` when calling `delete_slot`") # noqa: E501
1740+
1741+
collection_formats = {}
1742+
1743+
path_params = {}
1744+
1745+
query_params = []
1746+
1747+
header_params = {}
1748+
1749+
form_params = []
1750+
local_var_files = {}
1751+
1752+
body_params = None
1753+
if 'body' in params:
1754+
body_params = params['body']
1755+
# HTTP header `Accept`
1756+
header_params['Accept'] = self.api_client.select_header_accept(
1757+
['application/json']) # noqa: E501
1758+
1759+
# HTTP header `Content-Type`
1760+
header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501
1761+
['application/json']) # noqa: E501
1762+
1763+
# Authentication setting
1764+
auth_settings = ['volcengineSign'] # noqa: E501
1765+
1766+
return self.api_client.call_api(
1767+
'/DeleteSlot/2022-01-01/rds_postgresql/post/application_json/', 'POST',
1768+
path_params,
1769+
query_params,
1770+
header_params,
1771+
body=body_params,
1772+
post_params=form_params,
1773+
files=local_var_files,
1774+
response_type='DeleteSlotResponse', # noqa: E501
1775+
auth_settings=auth_settings,
1776+
async_req=params.get('async_req'),
1777+
_return_http_data_only=params.get('_return_http_data_only'),
1778+
_preload_content=params.get('_preload_content', True),
1779+
_request_timeout=params.get('_request_timeout'),
1780+
collection_formats=collection_formats)
1781+
16851782
def describe_allow_list_detail(self, body, **kwargs): # noqa: E501
16861783
"""describe_allow_list_detail # noqa: E501
16871784
@@ -3525,6 +3622,103 @@ def describe_schemas_with_http_info(self, body, **kwargs): # noqa: E501
35253622
_request_timeout=params.get('_request_timeout'),
35263623
collection_formats=collection_formats)
35273624

3625+
def describe_slots(self, body, **kwargs): # noqa: E501
3626+
"""describe_slots # noqa: E501
3627+
3628+
This method makes a synchronous HTTP request by default. To make an
3629+
asynchronous HTTP request, please pass async_req=True
3630+
>>> thread = api.describe_slots(body, async_req=True)
3631+
>>> result = thread.get()
3632+
3633+
:param async_req bool
3634+
:param DescribeSlotsRequest body: (required)
3635+
:return: DescribeSlotsResponse
3636+
If the method is called asynchronously,
3637+
returns the request thread.
3638+
"""
3639+
kwargs['_return_http_data_only'] = True
3640+
if kwargs.get('async_req'):
3641+
return self.describe_slots_with_http_info(body, **kwargs) # noqa: E501
3642+
else:
3643+
(data) = self.describe_slots_with_http_info(body, **kwargs) # noqa: E501
3644+
return data
3645+
3646+
def describe_slots_with_http_info(self, body, **kwargs): # noqa: E501
3647+
"""describe_slots # noqa: E501
3648+
3649+
This method makes a synchronous HTTP request by default. To make an
3650+
asynchronous HTTP request, please pass async_req=True
3651+
>>> thread = api.describe_slots_with_http_info(body, async_req=True)
3652+
>>> result = thread.get()
3653+
3654+
:param async_req bool
3655+
:param DescribeSlotsRequest body: (required)
3656+
:return: DescribeSlotsResponse
3657+
If the method is called asynchronously,
3658+
returns the request thread.
3659+
"""
3660+
3661+
all_params = ['body'] # noqa: E501
3662+
all_params.append('async_req')
3663+
all_params.append('_return_http_data_only')
3664+
all_params.append('_preload_content')
3665+
all_params.append('_request_timeout')
3666+
3667+
params = locals()
3668+
for key, val in six.iteritems(params['kwargs']):
3669+
if key not in all_params:
3670+
raise TypeError(
3671+
"Got an unexpected keyword argument '%s'"
3672+
" to method describe_slots" % key
3673+
)
3674+
params[key] = val
3675+
del params['kwargs']
3676+
# verify the required parameter 'body' is set
3677+
if self.api_client.client_side_validation and ('body' not in params or
3678+
params['body'] is None): # noqa: E501
3679+
raise ValueError("Missing the required parameter `body` when calling `describe_slots`") # noqa: E501
3680+
3681+
collection_formats = {}
3682+
3683+
path_params = {}
3684+
3685+
query_params = []
3686+
3687+
header_params = {}
3688+
3689+
form_params = []
3690+
local_var_files = {}
3691+
3692+
body_params = None
3693+
if 'body' in params:
3694+
body_params = params['body']
3695+
# HTTP header `Accept`
3696+
header_params['Accept'] = self.api_client.select_header_accept(
3697+
['application/json']) # noqa: E501
3698+
3699+
# HTTP header `Content-Type`
3700+
header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501
3701+
['application/json']) # noqa: E501
3702+
3703+
# Authentication setting
3704+
auth_settings = ['volcengineSign'] # noqa: E501
3705+
3706+
return self.api_client.call_api(
3707+
'/DescribeSlots/2022-01-01/rds_postgresql/post/application_json/', 'POST',
3708+
path_params,
3709+
query_params,
3710+
header_params,
3711+
body=body_params,
3712+
post_params=form_params,
3713+
files=local_var_files,
3714+
response_type='DescribeSlotsResponse', # noqa: E501
3715+
auth_settings=auth_settings,
3716+
async_req=params.get('async_req'),
3717+
_return_http_data_only=params.get('_return_http_data_only'),
3718+
_preload_content=params.get('_preload_content', True),
3719+
_request_timeout=params.get('_request_timeout'),
3720+
collection_formats=collection_formats)
3721+
35283722
def disassociate_allow_list(self, body, **kwargs): # noqa: E501
35293723
"""disassociate_allow_list # noqa: E501
35303724

volcenginesdkrdspostgresql/models/__init__.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,8 @@
6868
from volcenginesdkrdspostgresql.models.delete_database_response import DeleteDatabaseResponse
6969
from volcenginesdkrdspostgresql.models.delete_schema_request import DeleteSchemaRequest
7070
from volcenginesdkrdspostgresql.models.delete_schema_response import DeleteSchemaResponse
71+
from volcenginesdkrdspostgresql.models.delete_slot_request import DeleteSlotRequest
72+
from volcenginesdkrdspostgresql.models.delete_slot_response import DeleteSlotResponse
7173
from volcenginesdkrdspostgresql.models.describe_allow_list_detail_request import DescribeAllowListDetailRequest
7274
from volcenginesdkrdspostgresql.models.describe_allow_list_detail_response import DescribeAllowListDetailResponse
7375
from volcenginesdkrdspostgresql.models.describe_allow_lists_request import DescribeAllowListsRequest
@@ -106,6 +108,8 @@
106108
from volcenginesdkrdspostgresql.models.describe_regions_response import DescribeRegionsResponse
107109
from volcenginesdkrdspostgresql.models.describe_schemas_request import DescribeSchemasRequest
108110
from volcenginesdkrdspostgresql.models.describe_schemas_response import DescribeSchemasResponse
111+
from volcenginesdkrdspostgresql.models.describe_slots_request import DescribeSlotsRequest
112+
from volcenginesdkrdspostgresql.models.describe_slots_response import DescribeSlotsResponse
109113
from volcenginesdkrdspostgresql.models.disassociate_allow_list_request import DisassociateAllowListRequest
110114
from volcenginesdkrdspostgresql.models.disassociate_allow_list_response import DisassociateAllowListResponse
111115
from volcenginesdkrdspostgresql.models.endpoint_for_describe_db_instance_detail_output import EndpointForDescribeDBInstanceDetailOutput
@@ -168,6 +172,7 @@
168172
from volcenginesdkrdspostgresql.models.region_for_describe_regions_output import RegionForDescribeRegionsOutput
169173
from volcenginesdkrdspostgresql.models.remove_tags_from_resource_request import RemoveTagsFromResourceRequest
170174
from volcenginesdkrdspostgresql.models.remove_tags_from_resource_response import RemoveTagsFromResourceResponse
175+
from volcenginesdkrdspostgresql.models.replication_slot_for_describe_slots_output import ReplicationSlotForDescribeSlotsOutput
171176
from volcenginesdkrdspostgresql.models.reset_db_account_request import ResetDBAccountRequest
172177
from volcenginesdkrdspostgresql.models.reset_db_account_response import ResetDBAccountResponse
173178
from volcenginesdkrdspostgresql.models.restart_db_instance_request import RestartDBInstanceRequest

volcenginesdkrdspostgresql/models/basic_info_for_describe_db_instance_detail_output.py

Lines changed: 1 addition & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,6 @@ class BasicInfoForDescribeDBInstanceDetailOutput(object):
3333
and the value is json key in definition.
3434
"""
3535
swagger_types = {
36-
'allow_list_version': 'str',
3736
'create_time': 'str',
3837
'db_engine_version': 'str',
3938
'data_sync_mode': 'str',
@@ -62,7 +61,6 @@ class BasicInfoForDescribeDBInstanceDetailOutput(object):
6261
}
6362

6463
attribute_map = {
65-
'allow_list_version': 'AllowListVersion',
6664
'create_time': 'CreateTime',
6765
'db_engine_version': 'DBEngineVersion',
6866
'data_sync_mode': 'DataSyncMode',
@@ -90,13 +88,12 @@ class BasicInfoForDescribeDBInstanceDetailOutput(object):
9088
'zone_id': 'ZoneId'
9189
}
9290

93-
def __init__(self, allow_list_version=None, create_time=None, db_engine_version=None, data_sync_mode=None, instance_id=None, instance_name=None, instance_status=None, instance_tag=None, instance_type=None, memory=None, node_number=None, node_spec=None, project_name=None, region_id=None, storage_data_use=None, storage_log_use=None, storage_space=None, storage_temp_use=None, storage_type=None, storage_use=None, storage_wal_use=None, subnet_id=None, update_time=None, vcpu=None, vpc_id=None, zone_id=None, _configuration=None): # noqa: E501
91+
def __init__(self, create_time=None, db_engine_version=None, data_sync_mode=None, instance_id=None, instance_name=None, instance_status=None, instance_tag=None, instance_type=None, memory=None, node_number=None, node_spec=None, project_name=None, region_id=None, storage_data_use=None, storage_log_use=None, storage_space=None, storage_temp_use=None, storage_type=None, storage_use=None, storage_wal_use=None, subnet_id=None, update_time=None, vcpu=None, vpc_id=None, zone_id=None, _configuration=None): # noqa: E501
9492
"""BasicInfoForDescribeDBInstanceDetailOutput - a model defined in Swagger""" # noqa: E501
9593
if _configuration is None:
9694
_configuration = Configuration()
9795
self._configuration = _configuration
9896

99-
self._allow_list_version = None
10097
self._create_time = None
10198
self._db_engine_version = None
10299
self._data_sync_mode = None
@@ -124,8 +121,6 @@ def __init__(self, allow_list_version=None, create_time=None, db_engine_version=
124121
self._zone_id = None
125122
self.discriminator = None
126123

127-
if allow_list_version is not None:
128-
self.allow_list_version = allow_list_version
129124
if create_time is not None:
130125
self.create_time = create_time
131126
if db_engine_version is not None:
@@ -177,27 +172,6 @@ def __init__(self, allow_list_version=None, create_time=None, db_engine_version=
177172
if zone_id is not None:
178173
self.zone_id = zone_id
179174

180-
@property
181-
def allow_list_version(self):
182-
"""Gets the allow_list_version of this BasicInfoForDescribeDBInstanceDetailOutput. # noqa: E501
183-
184-
185-
:return: The allow_list_version of this BasicInfoForDescribeDBInstanceDetailOutput. # noqa: E501
186-
:rtype: str
187-
"""
188-
return self._allow_list_version
189-
190-
@allow_list_version.setter
191-
def allow_list_version(self, allow_list_version):
192-
"""Sets the allow_list_version of this BasicInfoForDescribeDBInstanceDetailOutput.
193-
194-
195-
:param allow_list_version: The allow_list_version of this BasicInfoForDescribeDBInstanceDetailOutput. # noqa: E501
196-
:type: str
197-
"""
198-
199-
self._allow_list_version = allow_list_version
200-
201175
@property
202176
def create_time(self):
203177
"""Gets the create_time of this BasicInfoForDescribeDBInstanceDetailOutput. # noqa: E501

volcenginesdkrdspostgresql/models/charge_info_for_create_db_instance_input.py

Lines changed: 0 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -111,13 +111,6 @@ def charge_type(self, charge_type):
111111
:param charge_type: The charge_type of this ChargeInfoForCreateDBInstanceInput. # noqa: E501
112112
:type: str
113113
"""
114-
allowed_values = ["PostPaid", "PrePaid"] # noqa: E501
115-
if (self._configuration.client_side_validation and
116-
charge_type not in allowed_values):
117-
raise ValueError(
118-
"Invalid value for `charge_type` ({0}), must be one of {1}" # noqa: E501
119-
.format(charge_type, allowed_values)
120-
)
121114

122115
self._charge_type = charge_type
123116

@@ -181,13 +174,6 @@ def period_unit(self, period_unit):
181174
:param period_unit: The period_unit of this ChargeInfoForCreateDBInstanceInput. # noqa: E501
182175
:type: str
183176
"""
184-
allowed_values = ["Month", "Year"] # noqa: E501
185-
if (self._configuration.client_side_validation and
186-
period_unit not in allowed_values):
187-
raise ValueError(
188-
"Invalid value for `period_unit` ({0}), must be one of {1}" # noqa: E501
189-
.format(period_unit, allowed_values)
190-
)
191177

192178
self._period_unit = period_unit
193179

volcenginesdkrdspostgresql/models/charge_info_for_describe_db_instance_price_detail_input.py

Lines changed: 0 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -111,13 +111,6 @@ def charge_type(self, charge_type):
111111
:param charge_type: The charge_type of this ChargeInfoForDescribeDBInstancePriceDetailInput. # noqa: E501
112112
:type: str
113113
"""
114-
allowed_values = ["PostPaid", "PrePaid"] # noqa: E501
115-
if (self._configuration.client_side_validation and
116-
charge_type not in allowed_values):
117-
raise ValueError(
118-
"Invalid value for `charge_type` ({0}), must be one of {1}" # noqa: E501
119-
.format(charge_type, allowed_values)
120-
)
121114

122115
self._charge_type = charge_type
123116

@@ -181,13 +174,6 @@ def period_unit(self, period_unit):
181174
:param period_unit: The period_unit of this ChargeInfoForDescribeDBInstancePriceDetailInput. # noqa: E501
182175
:type: str
183176
"""
184-
allowed_values = ["Month", "Year"] # noqa: E501
185-
if (self._configuration.client_side_validation and
186-
period_unit not in allowed_values):
187-
raise ValueError(
188-
"Invalid value for `period_unit` ({0}), must be one of {1}" # noqa: E501
189-
.format(period_unit, allowed_values)
190-
)
191177

192178
self._period_unit = period_unit
193179

0 commit comments

Comments
 (0)