alikafka-20190916/Sources/AlibabacloudAlikafka20190916/Client.swift (2,315 lines of code) (raw):

import Foundation import Tea import TeaUtils import AlibabacloudOpenApi import AlibabaCloudOpenApiUtil import AlibabacloudEndpointUtil open class Client : AlibabacloudOpenApi.Client { public override init(_ config: AlibabacloudOpenApi.Config) throws { try super.init(config) self._endpointRule = "regional" try checkConfig(config as! AlibabacloudOpenApi.Config) self._endpoint = try getEndpoint("alikafka", self._regionId ?? "", self._endpointRule ?? "", self._network ?? "", self._suffix ?? "", self._endpointMap ?? [:], self._endpoint ?? "") } public func getEndpoint(_ productId: String, _ regionId: String, _ endpointRule: String, _ network: String, _ suffix: String, _ endpointMap: [String: String], _ endpoint: String) throws -> String { if (!TeaUtils.Client.empty(endpoint)) { return endpoint as! String } if (!TeaUtils.Client.isUnset(endpointMap) && !TeaUtils.Client.empty(endpointMap[regionId as! String])) { return endpointMap[regionId as! String] ?? "" } return try AlibabacloudEndpointUtil.Client.getEndpointRules(productId, regionId, endpointRule, network, suffix) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func changeResourceGroupWithOptions(_ request: ChangeResourceGroupRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> ChangeResourceGroupResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.newResourceGroupId)) { query["NewResourceGroupId"] = request.newResourceGroupId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.resourceId)) { query["ResourceId"] = request.resourceId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "ChangeResourceGroup", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(ChangeResourceGroupResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func changeResourceGroup(_ request: ChangeResourceGroupRequest) async throws -> ChangeResourceGroupResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await changeResourceGroupWithOptions(request as! ChangeResourceGroupRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func convertPostPayOrderWithOptions(_ request: ConvertPostPayOrderRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> ConvertPostPayOrderResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.duration)) { query["Duration"] = request.duration!; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.paidType)) { query["PaidType"] = request.paidType!; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "ConvertPostPayOrder", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(ConvertPostPayOrderResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func convertPostPayOrder(_ request: ConvertPostPayOrderRequest) async throws -> ConvertPostPayOrderResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await convertPostPayOrderWithOptions(request as! ConvertPostPayOrderRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createAclWithOptions(_ request: CreateAclRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> CreateAclResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.aclOperationType)) { query["AclOperationType"] = request.aclOperationType ?? ""; } if (!TeaUtils.Client.isUnset(request.aclOperationTypes)) { query["AclOperationTypes"] = request.aclOperationTypes ?? ""; } if (!TeaUtils.Client.isUnset(request.aclPermissionType)) { query["AclPermissionType"] = request.aclPermissionType ?? ""; } if (!TeaUtils.Client.isUnset(request.aclResourceName)) { query["AclResourceName"] = request.aclResourceName ?? ""; } if (!TeaUtils.Client.isUnset(request.aclResourcePatternType)) { query["AclResourcePatternType"] = request.aclResourcePatternType ?? ""; } if (!TeaUtils.Client.isUnset(request.aclResourceType)) { query["AclResourceType"] = request.aclResourceType ?? ""; } if (!TeaUtils.Client.isUnset(request.host)) { query["Host"] = request.host ?? ""; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.username)) { query["Username"] = request.username ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "CreateAcl", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(CreateAclResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createAcl(_ request: CreateAclRequest) async throws -> CreateAclResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await createAclWithOptions(request as! CreateAclRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createConsumerGroupWithOptions(_ request: CreateConsumerGroupRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> CreateConsumerGroupResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.consumerId)) { query["ConsumerId"] = request.consumerId ?? ""; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.remark)) { query["Remark"] = request.remark ?? ""; } if (!TeaUtils.Client.isUnset(request.tag)) { query["Tag"] = request.tag ?? []; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "CreateConsumerGroup", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(CreateConsumerGroupResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createConsumerGroup(_ request: CreateConsumerGroupRequest) async throws -> CreateConsumerGroupResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await createConsumerGroupWithOptions(request as! CreateConsumerGroupRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createPostPayInstanceWithOptions(_ tmpReq: CreatePostPayInstanceRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> CreatePostPayInstanceResponse { try TeaUtils.Client.validateModel(tmpReq) var request: CreatePostPayInstanceShrinkRequest = CreatePostPayInstanceShrinkRequest([:]) AlibabaCloudOpenApiUtil.Client.convert(tmpReq, request) if (!TeaUtils.Client.isUnset(tmpReq.serverlessConfig)) { request.serverlessConfigShrink = AlibabaCloudOpenApiUtil.Client.arrayToStringWithSpecifiedStyle(tmpReq.serverlessConfig, "ServerlessConfig", "json") } var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.deployType)) { query["DeployType"] = request.deployType!; } if (!TeaUtils.Client.isUnset(request.diskSize)) { query["DiskSize"] = request.diskSize!; } if (!TeaUtils.Client.isUnset(request.diskType)) { query["DiskType"] = request.diskType ?? ""; } if (!TeaUtils.Client.isUnset(request.eipMax)) { query["EipMax"] = request.eipMax!; } if (!TeaUtils.Client.isUnset(request.ioMaxSpec)) { query["IoMaxSpec"] = request.ioMaxSpec ?? ""; } if (!TeaUtils.Client.isUnset(request.paidType)) { query["PaidType"] = request.paidType!; } if (!TeaUtils.Client.isUnset(request.partitionNum)) { query["PartitionNum"] = request.partitionNum!; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.resourceGroupId)) { query["ResourceGroupId"] = request.resourceGroupId ?? ""; } if (!TeaUtils.Client.isUnset(request.serverlessConfigShrink)) { query["ServerlessConfig"] = request.serverlessConfigShrink ?? ""; } if (!TeaUtils.Client.isUnset(request.specType)) { query["SpecType"] = request.specType ?? ""; } if (!TeaUtils.Client.isUnset(request.tag)) { query["Tag"] = request.tag ?? []; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "CreatePostPayInstance", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(CreatePostPayInstanceResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createPostPayInstance(_ request: CreatePostPayInstanceRequest) async throws -> CreatePostPayInstanceResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await createPostPayInstanceWithOptions(request as! CreatePostPayInstanceRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createPostPayOrderWithOptions(_ tmpReq: CreatePostPayOrderRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> CreatePostPayOrderResponse { try TeaUtils.Client.validateModel(tmpReq) var request: CreatePostPayOrderShrinkRequest = CreatePostPayOrderShrinkRequest([:]) AlibabaCloudOpenApiUtil.Client.convert(tmpReq, request) if (!TeaUtils.Client.isUnset(tmpReq.serverlessConfig)) { request.serverlessConfigShrink = AlibabaCloudOpenApiUtil.Client.arrayToStringWithSpecifiedStyle(tmpReq.serverlessConfig, "ServerlessConfig", "json") } var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.deployType)) { query["DeployType"] = request.deployType!; } if (!TeaUtils.Client.isUnset(request.diskSize)) { query["DiskSize"] = request.diskSize!; } if (!TeaUtils.Client.isUnset(request.diskType)) { query["DiskType"] = request.diskType ?? ""; } if (!TeaUtils.Client.isUnset(request.eipMax)) { query["EipMax"] = request.eipMax!; } if (!TeaUtils.Client.isUnset(request.ioMax)) { query["IoMax"] = request.ioMax!; } if (!TeaUtils.Client.isUnset(request.ioMaxSpec)) { query["IoMaxSpec"] = request.ioMaxSpec ?? ""; } if (!TeaUtils.Client.isUnset(request.paidType)) { query["PaidType"] = request.paidType!; } if (!TeaUtils.Client.isUnset(request.partitionNum)) { query["PartitionNum"] = request.partitionNum!; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.resourceGroupId)) { query["ResourceGroupId"] = request.resourceGroupId ?? ""; } if (!TeaUtils.Client.isUnset(request.serverlessConfigShrink)) { query["ServerlessConfig"] = request.serverlessConfigShrink ?? ""; } if (!TeaUtils.Client.isUnset(request.specType)) { query["SpecType"] = request.specType ?? ""; } if (!TeaUtils.Client.isUnset(request.tag)) { query["Tag"] = request.tag ?? []; } if (!TeaUtils.Client.isUnset(request.topicQuota)) { query["TopicQuota"] = request.topicQuota!; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "CreatePostPayOrder", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(CreatePostPayOrderResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createPostPayOrder(_ request: CreatePostPayOrderRequest) async throws -> CreatePostPayOrderResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await createPostPayOrderWithOptions(request as! CreatePostPayOrderRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createPrePayInstanceWithOptions(_ tmpReq: CreatePrePayInstanceRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> CreatePrePayInstanceResponse { try TeaUtils.Client.validateModel(tmpReq) var request: CreatePrePayInstanceShrinkRequest = CreatePrePayInstanceShrinkRequest([:]) AlibabaCloudOpenApiUtil.Client.convert(tmpReq, request) if (!TeaUtils.Client.isUnset(tmpReq.confluentConfig)) { request.confluentConfigShrink = AlibabaCloudOpenApiUtil.Client.arrayToStringWithSpecifiedStyle(tmpReq.confluentConfig, "ConfluentConfig", "json") } var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.confluentConfigShrink)) { query["ConfluentConfig"] = request.confluentConfigShrink ?? ""; } if (!TeaUtils.Client.isUnset(request.deployType)) { query["DeployType"] = request.deployType!; } if (!TeaUtils.Client.isUnset(request.diskSize)) { query["DiskSize"] = request.diskSize!; } if (!TeaUtils.Client.isUnset(request.diskType)) { query["DiskType"] = request.diskType ?? ""; } if (!TeaUtils.Client.isUnset(request.duration)) { query["Duration"] = request.duration!; } if (!TeaUtils.Client.isUnset(request.eipMax)) { query["EipMax"] = request.eipMax!; } if (!TeaUtils.Client.isUnset(request.ioMaxSpec)) { query["IoMaxSpec"] = request.ioMaxSpec ?? ""; } if (!TeaUtils.Client.isUnset(request.paidType)) { query["PaidType"] = request.paidType!; } if (!TeaUtils.Client.isUnset(request.partitionNum)) { query["PartitionNum"] = request.partitionNum!; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.resourceGroupId)) { query["ResourceGroupId"] = request.resourceGroupId ?? ""; } if (!TeaUtils.Client.isUnset(request.specType)) { query["SpecType"] = request.specType ?? ""; } if (!TeaUtils.Client.isUnset(request.tag)) { query["Tag"] = request.tag ?? []; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "CreatePrePayInstance", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(CreatePrePayInstanceResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createPrePayInstance(_ request: CreatePrePayInstanceRequest) async throws -> CreatePrePayInstanceResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await createPrePayInstanceWithOptions(request as! CreatePrePayInstanceRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createPrePayOrderWithOptions(_ tmpReq: CreatePrePayOrderRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> CreatePrePayOrderResponse { try TeaUtils.Client.validateModel(tmpReq) var request: CreatePrePayOrderShrinkRequest = CreatePrePayOrderShrinkRequest([:]) AlibabaCloudOpenApiUtil.Client.convert(tmpReq, request) if (!TeaUtils.Client.isUnset(tmpReq.confluentConfig)) { request.confluentConfigShrink = AlibabaCloudOpenApiUtil.Client.arrayToStringWithSpecifiedStyle(tmpReq.confluentConfig, "ConfluentConfig", "json") } var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.confluentConfigShrink)) { query["ConfluentConfig"] = request.confluentConfigShrink ?? ""; } if (!TeaUtils.Client.isUnset(request.deployType)) { query["DeployType"] = request.deployType!; } if (!TeaUtils.Client.isUnset(request.diskSize)) { query["DiskSize"] = request.diskSize!; } if (!TeaUtils.Client.isUnset(request.diskType)) { query["DiskType"] = request.diskType ?? ""; } if (!TeaUtils.Client.isUnset(request.duration)) { query["Duration"] = request.duration!; } if (!TeaUtils.Client.isUnset(request.eipMax)) { query["EipMax"] = request.eipMax!; } if (!TeaUtils.Client.isUnset(request.ioMax)) { query["IoMax"] = request.ioMax!; } if (!TeaUtils.Client.isUnset(request.ioMaxSpec)) { query["IoMaxSpec"] = request.ioMaxSpec ?? ""; } if (!TeaUtils.Client.isUnset(request.paidType)) { query["PaidType"] = request.paidType!; } if (!TeaUtils.Client.isUnset(request.partitionNum)) { query["PartitionNum"] = request.partitionNum!; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.resourceGroupId)) { query["ResourceGroupId"] = request.resourceGroupId ?? ""; } if (!TeaUtils.Client.isUnset(request.specType)) { query["SpecType"] = request.specType ?? ""; } if (!TeaUtils.Client.isUnset(request.tag)) { query["Tag"] = request.tag ?? []; } if (!TeaUtils.Client.isUnset(request.topicQuota)) { query["TopicQuota"] = request.topicQuota!; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "CreatePrePayOrder", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(CreatePrePayOrderResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createPrePayOrder(_ request: CreatePrePayOrderRequest) async throws -> CreatePrePayOrderResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await createPrePayOrderWithOptions(request as! CreatePrePayOrderRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createSaslUserWithOptions(_ request: CreateSaslUserRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> CreateSaslUserResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.mechanism)) { query["Mechanism"] = request.mechanism ?? ""; } if (!TeaUtils.Client.isUnset(request.password)) { query["Password"] = request.password ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.type)) { query["Type"] = request.type ?? ""; } if (!TeaUtils.Client.isUnset(request.username)) { query["Username"] = request.username ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "CreateSaslUser", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(CreateSaslUserResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createSaslUser(_ request: CreateSaslUserRequest) async throws -> CreateSaslUserResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await createSaslUserWithOptions(request as! CreateSaslUserRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createScheduledScalingRuleWithOptions(_ tmpReq: CreateScheduledScalingRuleRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> CreateScheduledScalingRuleResponse { try TeaUtils.Client.validateModel(tmpReq) var request: CreateScheduledScalingRuleShrinkRequest = CreateScheduledScalingRuleShrinkRequest([:]) AlibabaCloudOpenApiUtil.Client.convert(tmpReq, request) if (!TeaUtils.Client.isUnset(tmpReq.weeklyTypes)) { request.weeklyTypesShrink = AlibabaCloudOpenApiUtil.Client.arrayToStringWithSpecifiedStyle(tmpReq.weeklyTypes, "WeeklyTypes", "json") } var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.durationMinutes)) { query["DurationMinutes"] = request.durationMinutes!; } if (!TeaUtils.Client.isUnset(request.enable)) { query["Enable"] = request.enable!; } if (!TeaUtils.Client.isUnset(request.firstScheduledTime)) { query["FirstScheduledTime"] = request.firstScheduledTime!; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.repeatType)) { query["RepeatType"] = request.repeatType ?? ""; } if (!TeaUtils.Client.isUnset(request.reservedPubFlow)) { query["ReservedPubFlow"] = request.reservedPubFlow!; } if (!TeaUtils.Client.isUnset(request.reservedSubFlow)) { query["ReservedSubFlow"] = request.reservedSubFlow!; } if (!TeaUtils.Client.isUnset(request.ruleName)) { query["RuleName"] = request.ruleName ?? ""; } if (!TeaUtils.Client.isUnset(request.scheduleType)) { query["ScheduleType"] = request.scheduleType ?? ""; } if (!TeaUtils.Client.isUnset(request.timeZone)) { query["TimeZone"] = request.timeZone ?? ""; } if (!TeaUtils.Client.isUnset(request.weeklyTypesShrink)) { query["WeeklyTypes"] = request.weeklyTypesShrink ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "CreateScheduledScalingRule", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(CreateScheduledScalingRuleResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createScheduledScalingRule(_ request: CreateScheduledScalingRuleRequest) async throws -> CreateScheduledScalingRuleResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await createScheduledScalingRuleWithOptions(request as! CreateScheduledScalingRuleRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createTopicWithOptions(_ request: CreateTopicRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> CreateTopicResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.compactTopic)) { query["CompactTopic"] = request.compactTopic!; } if (!TeaUtils.Client.isUnset(request.config)) { query["Config"] = request.config ?? ""; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.localTopic)) { query["LocalTopic"] = request.localTopic!; } if (!TeaUtils.Client.isUnset(request.minInsyncReplicas)) { query["MinInsyncReplicas"] = request.minInsyncReplicas!; } if (!TeaUtils.Client.isUnset(request.partitionNum)) { query["PartitionNum"] = request.partitionNum ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.remark)) { query["Remark"] = request.remark ?? ""; } if (!TeaUtils.Client.isUnset(request.replicationFactor)) { query["ReplicationFactor"] = request.replicationFactor!; } if (!TeaUtils.Client.isUnset(request.tag)) { query["Tag"] = request.tag ?? []; } if (!TeaUtils.Client.isUnset(request.topic)) { query["Topic"] = request.topic ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "CreateTopic", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(CreateTopicResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func createTopic(_ request: CreateTopicRequest) async throws -> CreateTopicResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await createTopicWithOptions(request as! CreateTopicRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func deleteAclWithOptions(_ request: DeleteAclRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> DeleteAclResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.aclOperationType)) { query["AclOperationType"] = request.aclOperationType ?? ""; } if (!TeaUtils.Client.isUnset(request.aclOperationTypes)) { query["AclOperationTypes"] = request.aclOperationTypes ?? ""; } if (!TeaUtils.Client.isUnset(request.aclPermissionType)) { query["AclPermissionType"] = request.aclPermissionType ?? ""; } if (!TeaUtils.Client.isUnset(request.aclResourceName)) { query["AclResourceName"] = request.aclResourceName ?? ""; } if (!TeaUtils.Client.isUnset(request.aclResourcePatternType)) { query["AclResourcePatternType"] = request.aclResourcePatternType ?? ""; } if (!TeaUtils.Client.isUnset(request.aclResourceType)) { query["AclResourceType"] = request.aclResourceType ?? ""; } if (!TeaUtils.Client.isUnset(request.host)) { query["Host"] = request.host ?? ""; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.username)) { query["Username"] = request.username ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "DeleteAcl", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(DeleteAclResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func deleteAcl(_ request: DeleteAclRequest) async throws -> DeleteAclResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await deleteAclWithOptions(request as! DeleteAclRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func deleteConsumerGroupWithOptions(_ request: DeleteConsumerGroupRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> DeleteConsumerGroupResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.consumerId)) { query["ConsumerId"] = request.consumerId ?? ""; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "DeleteConsumerGroup", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(DeleteConsumerGroupResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func deleteConsumerGroup(_ request: DeleteConsumerGroupRequest) async throws -> DeleteConsumerGroupResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await deleteConsumerGroupWithOptions(request as! DeleteConsumerGroupRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func deleteInstanceWithOptions(_ request: DeleteInstanceRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> DeleteInstanceResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "DeleteInstance", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(DeleteInstanceResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func deleteInstance(_ request: DeleteInstanceRequest) async throws -> DeleteInstanceResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await deleteInstanceWithOptions(request as! DeleteInstanceRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func deleteSaslUserWithOptions(_ request: DeleteSaslUserRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> DeleteSaslUserResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.mechanism)) { query["Mechanism"] = request.mechanism ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.type)) { query["Type"] = request.type ?? ""; } if (!TeaUtils.Client.isUnset(request.username)) { query["Username"] = request.username ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "DeleteSaslUser", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(DeleteSaslUserResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func deleteSaslUser(_ request: DeleteSaslUserRequest) async throws -> DeleteSaslUserResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await deleteSaslUserWithOptions(request as! DeleteSaslUserRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func deleteScheduledScalingRuleWithOptions(_ request: DeleteScheduledScalingRuleRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> DeleteScheduledScalingRuleResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.ruleName)) { query["RuleName"] = request.ruleName ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "DeleteScheduledScalingRule", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(DeleteScheduledScalingRuleResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func deleteScheduledScalingRule(_ request: DeleteScheduledScalingRuleRequest) async throws -> DeleteScheduledScalingRuleResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await deleteScheduledScalingRuleWithOptions(request as! DeleteScheduledScalingRuleRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func deleteTopicWithOptions(_ request: DeleteTopicRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> DeleteTopicResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.topic)) { query["Topic"] = request.topic ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "DeleteTopic", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(DeleteTopicResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func deleteTopic(_ request: DeleteTopicRequest) async throws -> DeleteTopicResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await deleteTopicWithOptions(request as! DeleteTopicRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func describeAclResourceNameWithOptions(_ request: DescribeAclResourceNameRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> DescribeAclResourceNameResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.aclResourcePatternType)) { query["AclResourcePatternType"] = request.aclResourcePatternType ?? ""; } if (!TeaUtils.Client.isUnset(request.aclResourceType)) { query["AclResourceType"] = request.aclResourceType ?? ""; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "DescribeAclResourceName", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(DescribeAclResourceNameResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func describeAclResourceName(_ request: DescribeAclResourceNameRequest) async throws -> DescribeAclResourceNameResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await describeAclResourceNameWithOptions(request as! DescribeAclResourceNameRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func describeAclsWithOptions(_ request: DescribeAclsRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> DescribeAclsResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.aclOperationType)) { query["AclOperationType"] = request.aclOperationType ?? ""; } if (!TeaUtils.Client.isUnset(request.aclPermissionType)) { query["AclPermissionType"] = request.aclPermissionType ?? ""; } if (!TeaUtils.Client.isUnset(request.aclResourceName)) { query["AclResourceName"] = request.aclResourceName ?? ""; } if (!TeaUtils.Client.isUnset(request.aclResourcePatternType)) { query["AclResourcePatternType"] = request.aclResourcePatternType ?? ""; } if (!TeaUtils.Client.isUnset(request.aclResourceType)) { query["AclResourceType"] = request.aclResourceType ?? ""; } if (!TeaUtils.Client.isUnset(request.host)) { query["Host"] = request.host ?? ""; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.username)) { query["Username"] = request.username ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "DescribeAcls", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(DescribeAclsResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func describeAcls(_ request: DescribeAclsRequest) async throws -> DescribeAclsResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await describeAclsWithOptions(request as! DescribeAclsRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func describeSaslUsersWithOptions(_ request: DescribeSaslUsersRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> DescribeSaslUsersResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "DescribeSaslUsers", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(DescribeSaslUsersResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func describeSaslUsers(_ request: DescribeSaslUsersRequest) async throws -> DescribeSaslUsersResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await describeSaslUsersWithOptions(request as! DescribeSaslUsersRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func enableAutoGroupCreationWithOptions(_ request: EnableAutoGroupCreationRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> EnableAutoGroupCreationResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.enable)) { query["Enable"] = request.enable!; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "EnableAutoGroupCreation", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(EnableAutoGroupCreationResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func enableAutoGroupCreation(_ request: EnableAutoGroupCreationRequest) async throws -> EnableAutoGroupCreationResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await enableAutoGroupCreationWithOptions(request as! EnableAutoGroupCreationRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func enableAutoTopicCreationWithOptions(_ request: EnableAutoTopicCreationRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> EnableAutoTopicCreationResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.operate)) { query["Operate"] = request.operate ?? ""; } if (!TeaUtils.Client.isUnset(request.partitionNum)) { query["PartitionNum"] = request.partitionNum!; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.updatePartition)) { query["UpdatePartition"] = request.updatePartition!; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "EnableAutoTopicCreation", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(EnableAutoTopicCreationResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func enableAutoTopicCreation(_ request: EnableAutoTopicCreationRequest) async throws -> EnableAutoTopicCreationResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await enableAutoTopicCreationWithOptions(request as! EnableAutoTopicCreationRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getAllInstanceIdListWithOptions(_ request: GetAllInstanceIdListRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> GetAllInstanceIdListResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "GetAllInstanceIdList", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(GetAllInstanceIdListResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getAllInstanceIdList(_ request: GetAllInstanceIdListRequest) async throws -> GetAllInstanceIdListResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await getAllInstanceIdListWithOptions(request as! GetAllInstanceIdListRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getAllowedIpListWithOptions(_ request: GetAllowedIpListRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> GetAllowedIpListResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "GetAllowedIpList", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(GetAllowedIpListResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getAllowedIpList(_ request: GetAllowedIpListRequest) async throws -> GetAllowedIpListResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await getAllowedIpListWithOptions(request as! GetAllowedIpListRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getAutoScalingConfigurationWithOptions(_ request: GetAutoScalingConfigurationRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> GetAutoScalingConfigurationResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "GetAutoScalingConfiguration", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(GetAutoScalingConfigurationResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getAutoScalingConfiguration(_ request: GetAutoScalingConfigurationRequest) async throws -> GetAutoScalingConfigurationResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await getAutoScalingConfigurationWithOptions(request as! GetAutoScalingConfigurationRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getConsumerListWithOptions(_ request: GetConsumerListRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> GetConsumerListResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.consumerId)) { query["ConsumerId"] = request.consumerId ?? ""; } if (!TeaUtils.Client.isUnset(request.currentPage)) { query["CurrentPage"] = request.currentPage!; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.pageSize)) { query["PageSize"] = request.pageSize!; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "GetConsumerList", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(GetConsumerListResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getConsumerList(_ request: GetConsumerListRequest) async throws -> GetConsumerListResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await getConsumerListWithOptions(request as! GetConsumerListRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getConsumerProgressWithOptions(_ request: GetConsumerProgressRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> GetConsumerProgressResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.consumerId)) { query["ConsumerId"] = request.consumerId ?? ""; } if (!TeaUtils.Client.isUnset(request.hideLastTimestamp)) { query["HideLastTimestamp"] = request.hideLastTimestamp!; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "GetConsumerProgress", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(GetConsumerProgressResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getConsumerProgress(_ request: GetConsumerProgressRequest) async throws -> GetConsumerProgressResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await getConsumerProgressWithOptions(request as! GetConsumerProgressRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getInstanceListWithOptions(_ request: GetInstanceListRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> GetInstanceListResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? []; } if (!TeaUtils.Client.isUnset(request.orderId)) { query["OrderId"] = request.orderId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.resourceGroupId)) { query["ResourceGroupId"] = request.resourceGroupId ?? ""; } if (!TeaUtils.Client.isUnset(request.series)) { query["Series"] = request.series ?? ""; } if (!TeaUtils.Client.isUnset(request.tag)) { query["Tag"] = request.tag ?? []; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "GetInstanceList", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(GetInstanceListResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getInstanceList(_ request: GetInstanceListRequest) async throws -> GetInstanceListResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await getInstanceListWithOptions(request as! GetInstanceListRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getKafkaClientIpWithOptions(_ request: GetKafkaClientIpRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> GetKafkaClientIpResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.endTime)) { query["EndTime"] = request.endTime!; } if (!TeaUtils.Client.isUnset(request.group)) { query["Group"] = request.group ?? ""; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.startTime)) { query["StartTime"] = request.startTime!; } if (!TeaUtils.Client.isUnset(request.topic)) { query["Topic"] = request.topic ?? ""; } if (!TeaUtils.Client.isUnset(request.type)) { query["Type"] = request.type ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "GetKafkaClientIp", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(GetKafkaClientIpResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getKafkaClientIp(_ request: GetKafkaClientIpRequest) async throws -> GetKafkaClientIpResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await getKafkaClientIpWithOptions(request as! GetKafkaClientIpRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getQuotaTipWithOptions(_ request: GetQuotaTipRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> GetQuotaTipResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "GetQuotaTip", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(GetQuotaTipResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getQuotaTip(_ request: GetQuotaTipRequest) async throws -> GetQuotaTipResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await getQuotaTipWithOptions(request as! GetQuotaTipRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getTopicListWithOptions(_ request: GetTopicListRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> GetTopicListResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.currentPage)) { query["CurrentPage"] = request.currentPage ?? ""; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.pageSize)) { query["PageSize"] = request.pageSize ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.topic)) { query["Topic"] = request.topic ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "GetTopicList", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(GetTopicListResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getTopicList(_ request: GetTopicListRequest) async throws -> GetTopicListResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await getTopicListWithOptions(request as! GetTopicListRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getTopicStatusWithOptions(_ request: GetTopicStatusRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> GetTopicStatusResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.topic)) { query["Topic"] = request.topic ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "GetTopicStatus", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(GetTopicStatusResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getTopicStatus(_ request: GetTopicStatusRequest) async throws -> GetTopicStatusResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await getTopicStatusWithOptions(request as! GetTopicStatusRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getTopicSubscribeStatusWithOptions(_ request: GetTopicSubscribeStatusRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> GetTopicSubscribeStatusResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.topic)) { query["Topic"] = request.topic ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "GetTopicSubscribeStatus", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(GetTopicSubscribeStatusResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func getTopicSubscribeStatus(_ request: GetTopicSubscribeStatusRequest) async throws -> GetTopicSubscribeStatusResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await getTopicSubscribeStatusWithOptions(request as! GetTopicSubscribeStatusRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func listTagResourcesWithOptions(_ request: ListTagResourcesRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> ListTagResourcesResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.nextToken)) { query["NextToken"] = request.nextToken ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.resourceId)) { query["ResourceId"] = request.resourceId ?? []; } if (!TeaUtils.Client.isUnset(request.resourceType)) { query["ResourceType"] = request.resourceType ?? ""; } if (!TeaUtils.Client.isUnset(request.tag)) { query["Tag"] = request.tag ?? []; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "ListTagResources", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(ListTagResourcesResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func listTagResources(_ request: ListTagResourcesRequest) async throws -> ListTagResourcesResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await listTagResourcesWithOptions(request as! ListTagResourcesRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func modifyInstanceNameWithOptions(_ request: ModifyInstanceNameRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> ModifyInstanceNameResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.instanceName)) { query["InstanceName"] = request.instanceName ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "ModifyInstanceName", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(ModifyInstanceNameResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func modifyInstanceName(_ request: ModifyInstanceNameRequest) async throws -> ModifyInstanceNameResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await modifyInstanceNameWithOptions(request as! ModifyInstanceNameRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func modifyPartitionNumWithOptions(_ request: ModifyPartitionNumRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> ModifyPartitionNumResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.addPartitionNum)) { query["AddPartitionNum"] = request.addPartitionNum!; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.topic)) { query["Topic"] = request.topic ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "ModifyPartitionNum", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(ModifyPartitionNumResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func modifyPartitionNum(_ request: ModifyPartitionNumRequest) async throws -> ModifyPartitionNumResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await modifyPartitionNumWithOptions(request as! ModifyPartitionNumRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func modifyScheduledScalingRuleWithOptions(_ request: ModifyScheduledScalingRuleRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> ModifyScheduledScalingRuleResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.enable)) { query["Enable"] = request.enable!; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.ruleName)) { query["RuleName"] = request.ruleName ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "ModifyScheduledScalingRule", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(ModifyScheduledScalingRuleResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func modifyScheduledScalingRule(_ request: ModifyScheduledScalingRuleRequest) async throws -> ModifyScheduledScalingRuleResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await modifyScheduledScalingRuleWithOptions(request as! ModifyScheduledScalingRuleRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func modifyTopicRemarkWithOptions(_ request: ModifyTopicRemarkRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> ModifyTopicRemarkResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.remark)) { query["Remark"] = request.remark ?? ""; } if (!TeaUtils.Client.isUnset(request.topic)) { query["Topic"] = request.topic ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "ModifyTopicRemark", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(ModifyTopicRemarkResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func modifyTopicRemark(_ request: ModifyTopicRemarkRequest) async throws -> ModifyTopicRemarkResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await modifyTopicRemarkWithOptions(request as! ModifyTopicRemarkRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func queryMessageWithOptions(_ request: QueryMessageRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> QueryMessageResponse { try TeaUtils.Client.validateModel(request) var query: [String: String] = AlibabaCloudOpenApiUtil.Client.query(TeaUtils.Client.toMap(request)) var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "QueryMessage", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "GET", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(QueryMessageResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func queryMessage(_ request: QueryMessageRequest) async throws -> QueryMessageResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await queryMessageWithOptions(request as! QueryMessageRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func releaseInstanceWithOptions(_ request: ReleaseInstanceRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> ReleaseInstanceResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.forceDeleteInstance)) { query["ForceDeleteInstance"] = request.forceDeleteInstance!; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "ReleaseInstance", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(ReleaseInstanceResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func releaseInstance(_ request: ReleaseInstanceRequest) async throws -> ReleaseInstanceResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await releaseInstanceWithOptions(request as! ReleaseInstanceRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func reopenInstanceWithOptions(_ request: ReopenInstanceRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> ReopenInstanceResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "ReopenInstance", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(ReopenInstanceResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func reopenInstance(_ request: ReopenInstanceRequest) async throws -> ReopenInstanceResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await reopenInstanceWithOptions(request as! ReopenInstanceRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func startInstanceWithOptions(_ request: StartInstanceRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> StartInstanceResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.config)) { query["Config"] = request.config ?? ""; } if (!TeaUtils.Client.isUnset(request.crossZone)) { query["CrossZone"] = request.crossZone!; } if (!TeaUtils.Client.isUnset(request.deployModule)) { query["DeployModule"] = request.deployModule ?? ""; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.isEipInner)) { query["IsEipInner"] = request.isEipInner!; } if (!TeaUtils.Client.isUnset(request.isForceSelectedZones)) { query["IsForceSelectedZones"] = request.isForceSelectedZones!; } if (!TeaUtils.Client.isUnset(request.isSetUserAndPassword)) { query["IsSetUserAndPassword"] = request.isSetUserAndPassword!; } if (!TeaUtils.Client.isUnset(request.KMSKeyId)) { query["KMSKeyId"] = request.KMSKeyId ?? ""; } if (!TeaUtils.Client.isUnset(request.name)) { query["Name"] = request.name ?? ""; } if (!TeaUtils.Client.isUnset(request.notifier)) { query["Notifier"] = request.notifier ?? ""; } if (!TeaUtils.Client.isUnset(request.password)) { query["Password"] = request.password ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.securityGroup)) { query["SecurityGroup"] = request.securityGroup ?? ""; } if (!TeaUtils.Client.isUnset(request.selectedZones)) { query["SelectedZones"] = request.selectedZones ?? ""; } if (!TeaUtils.Client.isUnset(request.serviceVersion)) { query["ServiceVersion"] = request.serviceVersion ?? ""; } if (!TeaUtils.Client.isUnset(request.userPhoneNum)) { query["UserPhoneNum"] = request.userPhoneNum ?? ""; } if (!TeaUtils.Client.isUnset(request.username)) { query["Username"] = request.username ?? ""; } if (!TeaUtils.Client.isUnset(request.vSwitchId)) { query["VSwitchId"] = request.vSwitchId ?? ""; } if (!TeaUtils.Client.isUnset(request.vSwitchIds)) { query["VSwitchIds"] = request.vSwitchIds ?? []; } if (!TeaUtils.Client.isUnset(request.vpcId)) { query["VpcId"] = request.vpcId ?? ""; } if (!TeaUtils.Client.isUnset(request.zoneId)) { query["ZoneId"] = request.zoneId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "StartInstance", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(StartInstanceResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func startInstance(_ request: StartInstanceRequest) async throws -> StartInstanceResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await startInstanceWithOptions(request as! StartInstanceRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func stopInstanceWithOptions(_ request: StopInstanceRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> StopInstanceResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "StopInstance", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(StopInstanceResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func stopInstance(_ request: StopInstanceRequest) async throws -> StopInstanceResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await stopInstanceWithOptions(request as! StopInstanceRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func tagResourcesWithOptions(_ request: TagResourcesRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> TagResourcesResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.resourceId)) { query["ResourceId"] = request.resourceId ?? []; } if (!TeaUtils.Client.isUnset(request.resourceType)) { query["ResourceType"] = request.resourceType ?? ""; } if (!TeaUtils.Client.isUnset(request.tag)) { query["Tag"] = request.tag ?? []; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "TagResources", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(TagResourcesResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func tagResources(_ request: TagResourcesRequest) async throws -> TagResourcesResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await tagResourcesWithOptions(request as! TagResourcesRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func untagResourcesWithOptions(_ request: UntagResourcesRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> UntagResourcesResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.all)) { query["All"] = request.all!; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.resourceId)) { query["ResourceId"] = request.resourceId ?? []; } if (!TeaUtils.Client.isUnset(request.resourceType)) { query["ResourceType"] = request.resourceType ?? ""; } if (!TeaUtils.Client.isUnset(request.tagKey)) { query["TagKey"] = request.tagKey ?? []; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "UntagResources", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(UntagResourcesResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func untagResources(_ request: UntagResourcesRequest) async throws -> UntagResourcesResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await untagResourcesWithOptions(request as! UntagResourcesRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func updateAllowedIpWithOptions(_ request: UpdateAllowedIpRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> UpdateAllowedIpResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.allowedListIp)) { query["AllowedListIp"] = request.allowedListIp ?? ""; } if (!TeaUtils.Client.isUnset(request.allowedListType)) { query["AllowedListType"] = request.allowedListType ?? ""; } if (!TeaUtils.Client.isUnset(request.description_)) { query["Description"] = request.description_ ?? ""; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.portRange)) { query["PortRange"] = request.portRange ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.updateType)) { query["UpdateType"] = request.updateType ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "UpdateAllowedIp", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(UpdateAllowedIpResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func updateAllowedIp(_ request: UpdateAllowedIpRequest) async throws -> UpdateAllowedIpResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await updateAllowedIpWithOptions(request as! UpdateAllowedIpRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func updateConsumerOffsetWithOptions(_ tmpReq: UpdateConsumerOffsetRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> UpdateConsumerOffsetResponse { try TeaUtils.Client.validateModel(tmpReq) var request: UpdateConsumerOffsetShrinkRequest = UpdateConsumerOffsetShrinkRequest([:]) AlibabaCloudOpenApiUtil.Client.convert(tmpReq, request) if (!TeaUtils.Client.isUnset(tmpReq.offsets)) { request.offsetsShrink = AlibabaCloudOpenApiUtil.Client.arrayToStringWithSpecifiedStyle(tmpReq.offsets, "Offsets", "json") } var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.consumerId)) { query["ConsumerId"] = request.consumerId ?? ""; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.offsetsShrink)) { query["Offsets"] = request.offsetsShrink ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.resetType)) { query["ResetType"] = request.resetType ?? ""; } if (!TeaUtils.Client.isUnset(request.time)) { query["Time"] = request.time ?? ""; } if (!TeaUtils.Client.isUnset(request.topic)) { query["Topic"] = request.topic ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "UpdateConsumerOffset", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(UpdateConsumerOffsetResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func updateConsumerOffset(_ request: UpdateConsumerOffsetRequest) async throws -> UpdateConsumerOffsetResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await updateConsumerOffsetWithOptions(request as! UpdateConsumerOffsetRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func updateInstanceConfigWithOptions(_ request: UpdateInstanceConfigRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> UpdateInstanceConfigResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.config)) { query["Config"] = request.config ?? ""; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "UpdateInstanceConfig", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(UpdateInstanceConfigResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func updateInstanceConfig(_ request: UpdateInstanceConfigRequest) async throws -> UpdateInstanceConfigResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await updateInstanceConfigWithOptions(request as! UpdateInstanceConfigRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func updateTopicConfigWithOptions(_ request: UpdateTopicConfigRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> UpdateTopicConfigResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.config)) { query["Config"] = request.config ?? ""; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.topic)) { query["Topic"] = request.topic ?? ""; } if (!TeaUtils.Client.isUnset(request.value)) { query["Value"] = request.value ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "UpdateTopicConfig", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(UpdateTopicConfigResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func updateTopicConfig(_ request: UpdateTopicConfigRequest) async throws -> UpdateTopicConfigResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await updateTopicConfigWithOptions(request as! UpdateTopicConfigRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func upgradeInstanceVersionWithOptions(_ request: UpgradeInstanceVersionRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> UpgradeInstanceVersionResponse { try TeaUtils.Client.validateModel(request) var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.targetVersion)) { query["TargetVersion"] = request.targetVersion ?? ""; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "UpgradeInstanceVersion", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(UpgradeInstanceVersionResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func upgradeInstanceVersion(_ request: UpgradeInstanceVersionRequest) async throws -> UpgradeInstanceVersionResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await upgradeInstanceVersionWithOptions(request as! UpgradeInstanceVersionRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func upgradePostPayOrderWithOptions(_ tmpReq: UpgradePostPayOrderRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> UpgradePostPayOrderResponse { try TeaUtils.Client.validateModel(tmpReq) var request: UpgradePostPayOrderShrinkRequest = UpgradePostPayOrderShrinkRequest([:]) AlibabaCloudOpenApiUtil.Client.convert(tmpReq, request) if (!TeaUtils.Client.isUnset(tmpReq.serverlessConfig)) { request.serverlessConfigShrink = AlibabaCloudOpenApiUtil.Client.arrayToStringWithSpecifiedStyle(tmpReq.serverlessConfig, "ServerlessConfig", "json") } var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.diskSize)) { query["DiskSize"] = request.diskSize!; } if (!TeaUtils.Client.isUnset(request.eipMax)) { query["EipMax"] = request.eipMax!; } if (!TeaUtils.Client.isUnset(request.eipModel)) { query["EipModel"] = request.eipModel!; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.ioMax)) { query["IoMax"] = request.ioMax!; } if (!TeaUtils.Client.isUnset(request.ioMaxSpec)) { query["IoMaxSpec"] = request.ioMaxSpec ?? ""; } if (!TeaUtils.Client.isUnset(request.partitionNum)) { query["PartitionNum"] = request.partitionNum!; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.serverlessConfigShrink)) { query["ServerlessConfig"] = request.serverlessConfigShrink ?? ""; } if (!TeaUtils.Client.isUnset(request.specType)) { query["SpecType"] = request.specType ?? ""; } if (!TeaUtils.Client.isUnset(request.topicQuota)) { query["TopicQuota"] = request.topicQuota!; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "UpgradePostPayOrder", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(UpgradePostPayOrderResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func upgradePostPayOrder(_ request: UpgradePostPayOrderRequest) async throws -> UpgradePostPayOrderResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await upgradePostPayOrderWithOptions(request as! UpgradePostPayOrderRequest, runtime as! TeaUtils.RuntimeOptions) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func upgradePrePayOrderWithOptions(_ tmpReq: UpgradePrePayOrderRequest, _ runtime: TeaUtils.RuntimeOptions) async throws -> UpgradePrePayOrderResponse { try TeaUtils.Client.validateModel(tmpReq) var request: UpgradePrePayOrderShrinkRequest = UpgradePrePayOrderShrinkRequest([:]) AlibabaCloudOpenApiUtil.Client.convert(tmpReq, request) if (!TeaUtils.Client.isUnset(tmpReq.confluentConfig)) { request.confluentConfigShrink = AlibabaCloudOpenApiUtil.Client.arrayToStringWithSpecifiedStyle(tmpReq.confluentConfig, "ConfluentConfig", "json") } var query: [String: Any] = [:] if (!TeaUtils.Client.isUnset(request.confluentConfigShrink)) { query["ConfluentConfig"] = request.confluentConfigShrink ?? ""; } if (!TeaUtils.Client.isUnset(request.diskSize)) { query["DiskSize"] = request.diskSize!; } if (!TeaUtils.Client.isUnset(request.eipMax)) { query["EipMax"] = request.eipMax!; } if (!TeaUtils.Client.isUnset(request.eipModel)) { query["EipModel"] = request.eipModel!; } if (!TeaUtils.Client.isUnset(request.instanceId)) { query["InstanceId"] = request.instanceId ?? ""; } if (!TeaUtils.Client.isUnset(request.ioMax)) { query["IoMax"] = request.ioMax!; } if (!TeaUtils.Client.isUnset(request.ioMaxSpec)) { query["IoMaxSpec"] = request.ioMaxSpec ?? ""; } if (!TeaUtils.Client.isUnset(request.paidType)) { query["PaidType"] = request.paidType!; } if (!TeaUtils.Client.isUnset(request.partitionNum)) { query["PartitionNum"] = request.partitionNum!; } if (!TeaUtils.Client.isUnset(request.regionId)) { query["RegionId"] = request.regionId ?? ""; } if (!TeaUtils.Client.isUnset(request.specType)) { query["SpecType"] = request.specType ?? ""; } if (!TeaUtils.Client.isUnset(request.topicQuota)) { query["TopicQuota"] = request.topicQuota!; } var req: AlibabacloudOpenApi.OpenApiRequest = AlibabacloudOpenApi.OpenApiRequest([ "query": AlibabaCloudOpenApiUtil.Client.query(query) ]) var params: AlibabacloudOpenApi.Params = AlibabacloudOpenApi.Params([ "action": "UpgradePrePayOrder", "version": "2019-09-16", "protocol": "HTTPS", "pathname": "/", "method": "POST", "authType": "AK", "style": "RPC", "reqBodyType": "formData", "bodyType": "json" ]) var tmp: [String: Any] = try await callApi(params as! AlibabacloudOpenApi.Params, req as! AlibabacloudOpenApi.OpenApiRequest, runtime as! TeaUtils.RuntimeOptions) return Tea.TeaConverter.fromMap(UpgradePrePayOrderResponse(), tmp) } @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *) public func upgradePrePayOrder(_ request: UpgradePrePayOrderRequest) async throws -> UpgradePrePayOrderResponse { var runtime: TeaUtils.RuntimeOptions = TeaUtils.RuntimeOptions([:]) return try await upgradePrePayOrderWithOptions(request as! UpgradePrePayOrderRequest, runtime as! TeaUtils.RuntimeOptions) } }