alikafka-20190916/core/Client.cs (5,336 lines of code) (raw):
// This file is auto-generated, don't edit it. Thanks.
using System;
using System.Collections;
using System.Collections.Generic;
using System.IO;
using System.Threading.Tasks;
using Tea;
using Tea.Utils;
using AlibabaCloud.SDK.Alikafka20190916.Models;
namespace AlibabaCloud.SDK.Alikafka20190916
{
public class Client : AlibabaCloud.OpenApiClient.Client
{
public Client(AlibabaCloud.OpenApiClient.Models.Config config): base(config)
{
this._endpointRule = "regional";
CheckConfig(config);
this._endpoint = GetEndpoint("alikafka", _regionId, _endpointRule, _network, _suffix, _endpointMap, _endpoint);
}
public string GetEndpoint(string productId, string regionId, string endpointRule, string network, string suffix, Dictionary<string, string> endpointMap, string endpoint)
{
if (!AlibabaCloud.TeaUtil.Common.Empty(endpoint))
{
return endpoint;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(endpointMap) && !AlibabaCloud.TeaUtil.Common.Empty(endpointMap.Get(regionId)))
{
return endpointMap.Get(regionId);
}
return AlibabaCloud.EndpointUtil.Common.GetEndpointRules(productId, regionId, endpointRule, network, suffix);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Changes the resource group of an ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <param name="request">
/// ChangeResourceGroupRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ChangeResourceGroupResponse
/// </returns>
public ChangeResourceGroupResponse ChangeResourceGroupWithOptions(ChangeResourceGroupRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.NewResourceGroupId))
{
query["NewResourceGroupId"] = request.NewResourceGroupId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceId))
{
query["ResourceId"] = request.ResourceId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ChangeResourceGroup",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ChangeResourceGroupResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Changes the resource group of an ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <param name="request">
/// ChangeResourceGroupRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ChangeResourceGroupResponse
/// </returns>
public async Task<ChangeResourceGroupResponse> ChangeResourceGroupWithOptionsAsync(ChangeResourceGroupRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.NewResourceGroupId))
{
query["NewResourceGroupId"] = request.NewResourceGroupId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceId))
{
query["ResourceId"] = request.ResourceId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ChangeResourceGroup",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ChangeResourceGroupResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Changes the resource group of an ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <param name="request">
/// ChangeResourceGroupRequest
/// </param>
///
/// <returns>
/// ChangeResourceGroupResponse
/// </returns>
public ChangeResourceGroupResponse ChangeResourceGroup(ChangeResourceGroupRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return ChangeResourceGroupWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Changes the resource group of an ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <param name="request">
/// ChangeResourceGroupRequest
/// </param>
///
/// <returns>
/// ChangeResourceGroupResponse
/// </returns>
public async Task<ChangeResourceGroupResponse> ChangeResourceGroupAsync(ChangeResourceGroupRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await ChangeResourceGroupWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Changes the billing method of a Message Queue for Apache Kafka instance from pay-as-you-go to subscription.</para>
/// </summary>
///
/// <param name="request">
/// ConvertPostPayOrderRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ConvertPostPayOrderResponse
/// </returns>
public ConvertPostPayOrderResponse ConvertPostPayOrderWithOptions(ConvertPostPayOrderRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Duration))
{
query["Duration"] = request.Duration;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PaidType))
{
query["PaidType"] = request.PaidType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ConvertPostPayOrder",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ConvertPostPayOrderResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Changes the billing method of a Message Queue for Apache Kafka instance from pay-as-you-go to subscription.</para>
/// </summary>
///
/// <param name="request">
/// ConvertPostPayOrderRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ConvertPostPayOrderResponse
/// </returns>
public async Task<ConvertPostPayOrderResponse> ConvertPostPayOrderWithOptionsAsync(ConvertPostPayOrderRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Duration))
{
query["Duration"] = request.Duration;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PaidType))
{
query["PaidType"] = request.PaidType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ConvertPostPayOrder",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ConvertPostPayOrderResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Changes the billing method of a Message Queue for Apache Kafka instance from pay-as-you-go to subscription.</para>
/// </summary>
///
/// <param name="request">
/// ConvertPostPayOrderRequest
/// </param>
///
/// <returns>
/// ConvertPostPayOrderResponse
/// </returns>
public ConvertPostPayOrderResponse ConvertPostPayOrder(ConvertPostPayOrderRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return ConvertPostPayOrderWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Changes the billing method of a Message Queue for Apache Kafka instance from pay-as-you-go to subscription.</para>
/// </summary>
///
/// <param name="request">
/// ConvertPostPayOrderRequest
/// </param>
///
/// <returns>
/// ConvertPostPayOrderResponse
/// </returns>
public async Task<ConvertPostPayOrderResponse> ConvertPostPayOrderAsync(ConvertPostPayOrderRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await ConvertPostPayOrderWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates an access control list (ACL).</para>
/// </summary>
///
/// <param name="request">
/// CreateAclRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreateAclResponse
/// </returns>
public CreateAclResponse CreateAclWithOptions(CreateAclRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclOperationType))
{
query["AclOperationType"] = request.AclOperationType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclOperationTypes))
{
query["AclOperationTypes"] = request.AclOperationTypes;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclPermissionType))
{
query["AclPermissionType"] = request.AclPermissionType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourceName))
{
query["AclResourceName"] = request.AclResourceName;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourcePatternType))
{
query["AclResourcePatternType"] = request.AclResourcePatternType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourceType))
{
query["AclResourceType"] = request.AclResourceType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Host))
{
query["Host"] = request.Host;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Username))
{
query["Username"] = request.Username;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreateAcl",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreateAclResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates an access control list (ACL).</para>
/// </summary>
///
/// <param name="request">
/// CreateAclRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreateAclResponse
/// </returns>
public async Task<CreateAclResponse> CreateAclWithOptionsAsync(CreateAclRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclOperationType))
{
query["AclOperationType"] = request.AclOperationType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclOperationTypes))
{
query["AclOperationTypes"] = request.AclOperationTypes;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclPermissionType))
{
query["AclPermissionType"] = request.AclPermissionType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourceName))
{
query["AclResourceName"] = request.AclResourceName;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourcePatternType))
{
query["AclResourcePatternType"] = request.AclResourcePatternType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourceType))
{
query["AclResourceType"] = request.AclResourceType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Host))
{
query["Host"] = request.Host;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Username))
{
query["Username"] = request.Username;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreateAcl",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreateAclResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates an access control list (ACL).</para>
/// </summary>
///
/// <param name="request">
/// CreateAclRequest
/// </param>
///
/// <returns>
/// CreateAclResponse
/// </returns>
public CreateAclResponse CreateAcl(CreateAclRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return CreateAclWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates an access control list (ACL).</para>
/// </summary>
///
/// <param name="request">
/// CreateAclRequest
/// </param>
///
/// <returns>
/// CreateAclResponse
/// </returns>
public async Task<CreateAclResponse> CreateAclAsync(CreateAclRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await CreateAclWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a consumer group.</para>
/// </summary>
///
/// <param name="request">
/// CreateConsumerGroupRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreateConsumerGroupResponse
/// </returns>
public CreateConsumerGroupResponse CreateConsumerGroupWithOptions(CreateConsumerGroupRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ConsumerId))
{
query["ConsumerId"] = request.ConsumerId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Remark))
{
query["Remark"] = request.Remark;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreateConsumerGroup",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreateConsumerGroupResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a consumer group.</para>
/// </summary>
///
/// <param name="request">
/// CreateConsumerGroupRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreateConsumerGroupResponse
/// </returns>
public async Task<CreateConsumerGroupResponse> CreateConsumerGroupWithOptionsAsync(CreateConsumerGroupRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ConsumerId))
{
query["ConsumerId"] = request.ConsumerId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Remark))
{
query["Remark"] = request.Remark;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreateConsumerGroup",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreateConsumerGroupResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a consumer group.</para>
/// </summary>
///
/// <param name="request">
/// CreateConsumerGroupRequest
/// </param>
///
/// <returns>
/// CreateConsumerGroupResponse
/// </returns>
public CreateConsumerGroupResponse CreateConsumerGroup(CreateConsumerGroupRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return CreateConsumerGroupWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a consumer group.</para>
/// </summary>
///
/// <param name="request">
/// CreateConsumerGroupRequest
/// </param>
///
/// <returns>
/// CreateConsumerGroupResponse
/// </returns>
public async Task<CreateConsumerGroupResponse> CreateConsumerGroupAsync(CreateConsumerGroupRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await CreateConsumerGroupWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>创建后付费实例。</para>
/// </summary>
///
/// <param name="tmpReq">
/// CreatePostPayInstanceRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreatePostPayInstanceResponse
/// </returns>
public CreatePostPayInstanceResponse CreatePostPayInstanceWithOptions(CreatePostPayInstanceRequest tmpReq, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(tmpReq);
CreatePostPayInstanceShrinkRequest request = new CreatePostPayInstanceShrinkRequest();
AlibabaCloud.OpenApiUtil.Client.Convert(tmpReq, request);
if (!AlibabaCloud.TeaUtil.Common.IsUnset(tmpReq.ServerlessConfig))
{
request.ServerlessConfigShrink = AlibabaCloud.OpenApiUtil.Client.ArrayToStringWithSpecifiedStyle(tmpReq.ServerlessConfig, "ServerlessConfig", "json");
}
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DeployType))
{
query["DeployType"] = request.DeployType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskSize))
{
query["DiskSize"] = request.DiskSize;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskType))
{
query["DiskType"] = request.DiskType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EipMax))
{
query["EipMax"] = request.EipMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMaxSpec))
{
query["IoMaxSpec"] = request.IoMaxSpec;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PaidType))
{
query["PaidType"] = request.PaidType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PartitionNum))
{
query["PartitionNum"] = request.PartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceGroupId))
{
query["ResourceGroupId"] = request.ResourceGroupId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ServerlessConfigShrink))
{
query["ServerlessConfig"] = request.ServerlessConfigShrink;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.SpecType))
{
query["SpecType"] = request.SpecType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreatePostPayInstance",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreatePostPayInstanceResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>创建后付费实例。</para>
/// </summary>
///
/// <param name="tmpReq">
/// CreatePostPayInstanceRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreatePostPayInstanceResponse
/// </returns>
public async Task<CreatePostPayInstanceResponse> CreatePostPayInstanceWithOptionsAsync(CreatePostPayInstanceRequest tmpReq, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(tmpReq);
CreatePostPayInstanceShrinkRequest request = new CreatePostPayInstanceShrinkRequest();
AlibabaCloud.OpenApiUtil.Client.Convert(tmpReq, request);
if (!AlibabaCloud.TeaUtil.Common.IsUnset(tmpReq.ServerlessConfig))
{
request.ServerlessConfigShrink = AlibabaCloud.OpenApiUtil.Client.ArrayToStringWithSpecifiedStyle(tmpReq.ServerlessConfig, "ServerlessConfig", "json");
}
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DeployType))
{
query["DeployType"] = request.DeployType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskSize))
{
query["DiskSize"] = request.DiskSize;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskType))
{
query["DiskType"] = request.DiskType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EipMax))
{
query["EipMax"] = request.EipMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMaxSpec))
{
query["IoMaxSpec"] = request.IoMaxSpec;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PaidType))
{
query["PaidType"] = request.PaidType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PartitionNum))
{
query["PartitionNum"] = request.PartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceGroupId))
{
query["ResourceGroupId"] = request.ResourceGroupId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ServerlessConfigShrink))
{
query["ServerlessConfig"] = request.ServerlessConfigShrink;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.SpecType))
{
query["SpecType"] = request.SpecType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreatePostPayInstance",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreatePostPayInstanceResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>创建后付费实例。</para>
/// </summary>
///
/// <param name="request">
/// CreatePostPayInstanceRequest
/// </param>
///
/// <returns>
/// CreatePostPayInstanceResponse
/// </returns>
public CreatePostPayInstanceResponse CreatePostPayInstance(CreatePostPayInstanceRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return CreatePostPayInstanceWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>创建后付费实例。</para>
/// </summary>
///
/// <param name="request">
/// CreatePostPayInstanceRequest
/// </param>
///
/// <returns>
/// CreatePostPayInstanceResponse
/// </returns>
public async Task<CreatePostPayInstanceResponse> CreatePostPayInstanceAsync(CreatePostPayInstanceRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await CreatePostPayInstanceWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a pay-as-you-go ApsaraMQ for Kafka instance. Pay-as-you-go instances allow you to pay after you use the resources. You are charged for pay-as-you-go instances based on the actual resource usage. You can use pay-as-you-go instances in test scenarios or scenarios in which the peak traffic is uncertain.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>Before you call this operation, make sure that you understand the billing method and pricing of pay-as-you-go Message Queue for Apache Kafka instances. For more information, see <a href="https://help.aliyun.com/document_detail/84737.html">Billing</a>.</para>
/// </description>
///
/// <param name="tmpReq">
/// CreatePostPayOrderRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreatePostPayOrderResponse
/// </returns>
public CreatePostPayOrderResponse CreatePostPayOrderWithOptions(CreatePostPayOrderRequest tmpReq, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(tmpReq);
CreatePostPayOrderShrinkRequest request = new CreatePostPayOrderShrinkRequest();
AlibabaCloud.OpenApiUtil.Client.Convert(tmpReq, request);
if (!AlibabaCloud.TeaUtil.Common.IsUnset(tmpReq.ServerlessConfig))
{
request.ServerlessConfigShrink = AlibabaCloud.OpenApiUtil.Client.ArrayToStringWithSpecifiedStyle(tmpReq.ServerlessConfig, "ServerlessConfig", "json");
}
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DeployType))
{
query["DeployType"] = request.DeployType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskSize))
{
query["DiskSize"] = request.DiskSize;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskType))
{
query["DiskType"] = request.DiskType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EipMax))
{
query["EipMax"] = request.EipMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMax))
{
query["IoMax"] = request.IoMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMaxSpec))
{
query["IoMaxSpec"] = request.IoMaxSpec;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PaidType))
{
query["PaidType"] = request.PaidType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PartitionNum))
{
query["PartitionNum"] = request.PartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceGroupId))
{
query["ResourceGroupId"] = request.ResourceGroupId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ServerlessConfigShrink))
{
query["ServerlessConfig"] = request.ServerlessConfigShrink;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.SpecType))
{
query["SpecType"] = request.SpecType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.TopicQuota))
{
query["TopicQuota"] = request.TopicQuota;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreatePostPayOrder",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreatePostPayOrderResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a pay-as-you-go ApsaraMQ for Kafka instance. Pay-as-you-go instances allow you to pay after you use the resources. You are charged for pay-as-you-go instances based on the actual resource usage. You can use pay-as-you-go instances in test scenarios or scenarios in which the peak traffic is uncertain.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>Before you call this operation, make sure that you understand the billing method and pricing of pay-as-you-go Message Queue for Apache Kafka instances. For more information, see <a href="https://help.aliyun.com/document_detail/84737.html">Billing</a>.</para>
/// </description>
///
/// <param name="tmpReq">
/// CreatePostPayOrderRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreatePostPayOrderResponse
/// </returns>
public async Task<CreatePostPayOrderResponse> CreatePostPayOrderWithOptionsAsync(CreatePostPayOrderRequest tmpReq, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(tmpReq);
CreatePostPayOrderShrinkRequest request = new CreatePostPayOrderShrinkRequest();
AlibabaCloud.OpenApiUtil.Client.Convert(tmpReq, request);
if (!AlibabaCloud.TeaUtil.Common.IsUnset(tmpReq.ServerlessConfig))
{
request.ServerlessConfigShrink = AlibabaCloud.OpenApiUtil.Client.ArrayToStringWithSpecifiedStyle(tmpReq.ServerlessConfig, "ServerlessConfig", "json");
}
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DeployType))
{
query["DeployType"] = request.DeployType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskSize))
{
query["DiskSize"] = request.DiskSize;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskType))
{
query["DiskType"] = request.DiskType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EipMax))
{
query["EipMax"] = request.EipMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMax))
{
query["IoMax"] = request.IoMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMaxSpec))
{
query["IoMaxSpec"] = request.IoMaxSpec;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PaidType))
{
query["PaidType"] = request.PaidType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PartitionNum))
{
query["PartitionNum"] = request.PartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceGroupId))
{
query["ResourceGroupId"] = request.ResourceGroupId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ServerlessConfigShrink))
{
query["ServerlessConfig"] = request.ServerlessConfigShrink;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.SpecType))
{
query["SpecType"] = request.SpecType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.TopicQuota))
{
query["TopicQuota"] = request.TopicQuota;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreatePostPayOrder",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreatePostPayOrderResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a pay-as-you-go ApsaraMQ for Kafka instance. Pay-as-you-go instances allow you to pay after you use the resources. You are charged for pay-as-you-go instances based on the actual resource usage. You can use pay-as-you-go instances in test scenarios or scenarios in which the peak traffic is uncertain.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>Before you call this operation, make sure that you understand the billing method and pricing of pay-as-you-go Message Queue for Apache Kafka instances. For more information, see <a href="https://help.aliyun.com/document_detail/84737.html">Billing</a>.</para>
/// </description>
///
/// <param name="request">
/// CreatePostPayOrderRequest
/// </param>
///
/// <returns>
/// CreatePostPayOrderResponse
/// </returns>
public CreatePostPayOrderResponse CreatePostPayOrder(CreatePostPayOrderRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return CreatePostPayOrderWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a pay-as-you-go ApsaraMQ for Kafka instance. Pay-as-you-go instances allow you to pay after you use the resources. You are charged for pay-as-you-go instances based on the actual resource usage. You can use pay-as-you-go instances in test scenarios or scenarios in which the peak traffic is uncertain.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>Before you call this operation, make sure that you understand the billing method and pricing of pay-as-you-go Message Queue for Apache Kafka instances. For more information, see <a href="https://help.aliyun.com/document_detail/84737.html">Billing</a>.</para>
/// </description>
///
/// <param name="request">
/// CreatePostPayOrderRequest
/// </param>
///
/// <returns>
/// CreatePostPayOrderResponse
/// </returns>
public async Task<CreatePostPayOrderResponse> CreatePostPayOrderAsync(CreatePostPayOrderRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await CreatePostPayOrderWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>创建预付费实例</para>
/// </summary>
///
/// <param name="tmpReq">
/// CreatePrePayInstanceRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreatePrePayInstanceResponse
/// </returns>
public CreatePrePayInstanceResponse CreatePrePayInstanceWithOptions(CreatePrePayInstanceRequest tmpReq, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(tmpReq);
CreatePrePayInstanceShrinkRequest request = new CreatePrePayInstanceShrinkRequest();
AlibabaCloud.OpenApiUtil.Client.Convert(tmpReq, request);
if (!AlibabaCloud.TeaUtil.Common.IsUnset(tmpReq.ConfluentConfig))
{
request.ConfluentConfigShrink = AlibabaCloud.OpenApiUtil.Client.ArrayToStringWithSpecifiedStyle(tmpReq.ConfluentConfig, "ConfluentConfig", "json");
}
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ConfluentConfigShrink))
{
query["ConfluentConfig"] = request.ConfluentConfigShrink;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DeployType))
{
query["DeployType"] = request.DeployType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskSize))
{
query["DiskSize"] = request.DiskSize;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskType))
{
query["DiskType"] = request.DiskType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Duration))
{
query["Duration"] = request.Duration;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EipMax))
{
query["EipMax"] = request.EipMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMaxSpec))
{
query["IoMaxSpec"] = request.IoMaxSpec;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PaidType))
{
query["PaidType"] = request.PaidType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PartitionNum))
{
query["PartitionNum"] = request.PartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceGroupId))
{
query["ResourceGroupId"] = request.ResourceGroupId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.SpecType))
{
query["SpecType"] = request.SpecType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreatePrePayInstance",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreatePrePayInstanceResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>创建预付费实例</para>
/// </summary>
///
/// <param name="tmpReq">
/// CreatePrePayInstanceRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreatePrePayInstanceResponse
/// </returns>
public async Task<CreatePrePayInstanceResponse> CreatePrePayInstanceWithOptionsAsync(CreatePrePayInstanceRequest tmpReq, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(tmpReq);
CreatePrePayInstanceShrinkRequest request = new CreatePrePayInstanceShrinkRequest();
AlibabaCloud.OpenApiUtil.Client.Convert(tmpReq, request);
if (!AlibabaCloud.TeaUtil.Common.IsUnset(tmpReq.ConfluentConfig))
{
request.ConfluentConfigShrink = AlibabaCloud.OpenApiUtil.Client.ArrayToStringWithSpecifiedStyle(tmpReq.ConfluentConfig, "ConfluentConfig", "json");
}
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ConfluentConfigShrink))
{
query["ConfluentConfig"] = request.ConfluentConfigShrink;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DeployType))
{
query["DeployType"] = request.DeployType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskSize))
{
query["DiskSize"] = request.DiskSize;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskType))
{
query["DiskType"] = request.DiskType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Duration))
{
query["Duration"] = request.Duration;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EipMax))
{
query["EipMax"] = request.EipMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMaxSpec))
{
query["IoMaxSpec"] = request.IoMaxSpec;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PaidType))
{
query["PaidType"] = request.PaidType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PartitionNum))
{
query["PartitionNum"] = request.PartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceGroupId))
{
query["ResourceGroupId"] = request.ResourceGroupId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.SpecType))
{
query["SpecType"] = request.SpecType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreatePrePayInstance",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreatePrePayInstanceResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>创建预付费实例</para>
/// </summary>
///
/// <param name="request">
/// CreatePrePayInstanceRequest
/// </param>
///
/// <returns>
/// CreatePrePayInstanceResponse
/// </returns>
public CreatePrePayInstanceResponse CreatePrePayInstance(CreatePrePayInstanceRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return CreatePrePayInstanceWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>创建预付费实例</para>
/// </summary>
///
/// <param name="request">
/// CreatePrePayInstanceRequest
/// </param>
///
/// <returns>
/// CreatePrePayInstanceResponse
/// </returns>
public async Task<CreatePrePayInstanceResponse> CreatePrePayInstanceAsync(CreatePrePayInstanceRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await CreatePrePayInstanceWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a subscription ApsaraMQ for Kafka instance. You can use subscription instances only after you pay for them. Subscription instances are suitable for long-term and stable business scenarios.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para> Before you call this operation, make sure that you understand the billing methods and pricing of subscription ApsaraMQ for Kafka instances. For more information, see <a href="https://help.aliyun.com/document_detail/84737.html">Billing</a>.</para>
/// <list type="bullet">
/// <item><description>If you create an ApsaraMQ for Kafka instance by calling this operation, the subscription duration is one month and the auto-renewal feature is enabled by default. The auto-renewal cycle is also one month. If you want to change the auto-renewal cycle or disable the auto-renewal feature, you can go to the <a href="https://renew.console.aliyun.com/#/ecs">Renewal</a> page in the Alibaba Cloud Management Console.</description></item>
/// </list>
/// </description>
///
/// <param name="tmpReq">
/// CreatePrePayOrderRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreatePrePayOrderResponse
/// </returns>
public CreatePrePayOrderResponse CreatePrePayOrderWithOptions(CreatePrePayOrderRequest tmpReq, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(tmpReq);
CreatePrePayOrderShrinkRequest request = new CreatePrePayOrderShrinkRequest();
AlibabaCloud.OpenApiUtil.Client.Convert(tmpReq, request);
if (!AlibabaCloud.TeaUtil.Common.IsUnset(tmpReq.ConfluentConfig))
{
request.ConfluentConfigShrink = AlibabaCloud.OpenApiUtil.Client.ArrayToStringWithSpecifiedStyle(tmpReq.ConfluentConfig, "ConfluentConfig", "json");
}
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ConfluentConfigShrink))
{
query["ConfluentConfig"] = request.ConfluentConfigShrink;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DeployType))
{
query["DeployType"] = request.DeployType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskSize))
{
query["DiskSize"] = request.DiskSize;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskType))
{
query["DiskType"] = request.DiskType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Duration))
{
query["Duration"] = request.Duration;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EipMax))
{
query["EipMax"] = request.EipMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMax))
{
query["IoMax"] = request.IoMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMaxSpec))
{
query["IoMaxSpec"] = request.IoMaxSpec;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PaidType))
{
query["PaidType"] = request.PaidType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PartitionNum))
{
query["PartitionNum"] = request.PartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceGroupId))
{
query["ResourceGroupId"] = request.ResourceGroupId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.SpecType))
{
query["SpecType"] = request.SpecType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.TopicQuota))
{
query["TopicQuota"] = request.TopicQuota;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreatePrePayOrder",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreatePrePayOrderResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a subscription ApsaraMQ for Kafka instance. You can use subscription instances only after you pay for them. Subscription instances are suitable for long-term and stable business scenarios.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para> Before you call this operation, make sure that you understand the billing methods and pricing of subscription ApsaraMQ for Kafka instances. For more information, see <a href="https://help.aliyun.com/document_detail/84737.html">Billing</a>.</para>
/// <list type="bullet">
/// <item><description>If you create an ApsaraMQ for Kafka instance by calling this operation, the subscription duration is one month and the auto-renewal feature is enabled by default. The auto-renewal cycle is also one month. If you want to change the auto-renewal cycle or disable the auto-renewal feature, you can go to the <a href="https://renew.console.aliyun.com/#/ecs">Renewal</a> page in the Alibaba Cloud Management Console.</description></item>
/// </list>
/// </description>
///
/// <param name="tmpReq">
/// CreatePrePayOrderRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreatePrePayOrderResponse
/// </returns>
public async Task<CreatePrePayOrderResponse> CreatePrePayOrderWithOptionsAsync(CreatePrePayOrderRequest tmpReq, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(tmpReq);
CreatePrePayOrderShrinkRequest request = new CreatePrePayOrderShrinkRequest();
AlibabaCloud.OpenApiUtil.Client.Convert(tmpReq, request);
if (!AlibabaCloud.TeaUtil.Common.IsUnset(tmpReq.ConfluentConfig))
{
request.ConfluentConfigShrink = AlibabaCloud.OpenApiUtil.Client.ArrayToStringWithSpecifiedStyle(tmpReq.ConfluentConfig, "ConfluentConfig", "json");
}
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ConfluentConfigShrink))
{
query["ConfluentConfig"] = request.ConfluentConfigShrink;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DeployType))
{
query["DeployType"] = request.DeployType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskSize))
{
query["DiskSize"] = request.DiskSize;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskType))
{
query["DiskType"] = request.DiskType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Duration))
{
query["Duration"] = request.Duration;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EipMax))
{
query["EipMax"] = request.EipMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMax))
{
query["IoMax"] = request.IoMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMaxSpec))
{
query["IoMaxSpec"] = request.IoMaxSpec;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PaidType))
{
query["PaidType"] = request.PaidType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PartitionNum))
{
query["PartitionNum"] = request.PartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceGroupId))
{
query["ResourceGroupId"] = request.ResourceGroupId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.SpecType))
{
query["SpecType"] = request.SpecType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.TopicQuota))
{
query["TopicQuota"] = request.TopicQuota;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreatePrePayOrder",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreatePrePayOrderResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a subscription ApsaraMQ for Kafka instance. You can use subscription instances only after you pay for them. Subscription instances are suitable for long-term and stable business scenarios.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para> Before you call this operation, make sure that you understand the billing methods and pricing of subscription ApsaraMQ for Kafka instances. For more information, see <a href="https://help.aliyun.com/document_detail/84737.html">Billing</a>.</para>
/// <list type="bullet">
/// <item><description>If you create an ApsaraMQ for Kafka instance by calling this operation, the subscription duration is one month and the auto-renewal feature is enabled by default. The auto-renewal cycle is also one month. If you want to change the auto-renewal cycle or disable the auto-renewal feature, you can go to the <a href="https://renew.console.aliyun.com/#/ecs">Renewal</a> page in the Alibaba Cloud Management Console.</description></item>
/// </list>
/// </description>
///
/// <param name="request">
/// CreatePrePayOrderRequest
/// </param>
///
/// <returns>
/// CreatePrePayOrderResponse
/// </returns>
public CreatePrePayOrderResponse CreatePrePayOrder(CreatePrePayOrderRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return CreatePrePayOrderWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a subscription ApsaraMQ for Kafka instance. You can use subscription instances only after you pay for them. Subscription instances are suitable for long-term and stable business scenarios.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para> Before you call this operation, make sure that you understand the billing methods and pricing of subscription ApsaraMQ for Kafka instances. For more information, see <a href="https://help.aliyun.com/document_detail/84737.html">Billing</a>.</para>
/// <list type="bullet">
/// <item><description>If you create an ApsaraMQ for Kafka instance by calling this operation, the subscription duration is one month and the auto-renewal feature is enabled by default. The auto-renewal cycle is also one month. If you want to change the auto-renewal cycle or disable the auto-renewal feature, you can go to the <a href="https://renew.console.aliyun.com/#/ecs">Renewal</a> page in the Alibaba Cloud Management Console.</description></item>
/// </list>
/// </description>
///
/// <param name="request">
/// CreatePrePayOrderRequest
/// </param>
///
/// <returns>
/// CreatePrePayOrderResponse
/// </returns>
public async Task<CreatePrePayOrderResponse> CreatePrePayOrderAsync(CreatePrePayOrderRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await CreatePrePayOrderWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a Simple Authentication and Security Layer (SASL) user.</para>
/// </summary>
///
/// <param name="request">
/// CreateSaslUserRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreateSaslUserResponse
/// </returns>
public CreateSaslUserResponse CreateSaslUserWithOptions(CreateSaslUserRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Mechanism))
{
query["Mechanism"] = request.Mechanism;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Password))
{
query["Password"] = request.Password;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Type))
{
query["Type"] = request.Type;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Username))
{
query["Username"] = request.Username;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreateSaslUser",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreateSaslUserResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a Simple Authentication and Security Layer (SASL) user.</para>
/// </summary>
///
/// <param name="request">
/// CreateSaslUserRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreateSaslUserResponse
/// </returns>
public async Task<CreateSaslUserResponse> CreateSaslUserWithOptionsAsync(CreateSaslUserRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Mechanism))
{
query["Mechanism"] = request.Mechanism;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Password))
{
query["Password"] = request.Password;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Type))
{
query["Type"] = request.Type;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Username))
{
query["Username"] = request.Username;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreateSaslUser",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreateSaslUserResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a Simple Authentication and Security Layer (SASL) user.</para>
/// </summary>
///
/// <param name="request">
/// CreateSaslUserRequest
/// </param>
///
/// <returns>
/// CreateSaslUserResponse
/// </returns>
public CreateSaslUserResponse CreateSaslUser(CreateSaslUserRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return CreateSaslUserWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a Simple Authentication and Security Layer (SASL) user.</para>
/// </summary>
///
/// <param name="request">
/// CreateSaslUserRequest
/// </param>
///
/// <returns>
/// CreateSaslUserResponse
/// </returns>
public async Task<CreateSaslUserResponse> CreateSaslUserAsync(CreateSaslUserRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await CreateSaslUserWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a scheduled scaling rule for a serverless ApsaraMQ for Kafka V3 instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h6><a href="#-v3-serverless-"></a>This operation is supported only by serverless ApsaraMQ for Kafka V3 instances.</h6>
/// </description>
///
/// <param name="tmpReq">
/// CreateScheduledScalingRuleRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreateScheduledScalingRuleResponse
/// </returns>
public CreateScheduledScalingRuleResponse CreateScheduledScalingRuleWithOptions(CreateScheduledScalingRuleRequest tmpReq, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(tmpReq);
CreateScheduledScalingRuleShrinkRequest request = new CreateScheduledScalingRuleShrinkRequest();
AlibabaCloud.OpenApiUtil.Client.Convert(tmpReq, request);
if (!AlibabaCloud.TeaUtil.Common.IsUnset(tmpReq.WeeklyTypes))
{
request.WeeklyTypesShrink = AlibabaCloud.OpenApiUtil.Client.ArrayToStringWithSpecifiedStyle(tmpReq.WeeklyTypes, "WeeklyTypes", "json");
}
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DurationMinutes))
{
query["DurationMinutes"] = request.DurationMinutes;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Enable))
{
query["Enable"] = request.Enable;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.FirstScheduledTime))
{
query["FirstScheduledTime"] = request.FirstScheduledTime;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RepeatType))
{
query["RepeatType"] = request.RepeatType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ReservedPubFlow))
{
query["ReservedPubFlow"] = request.ReservedPubFlow;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ReservedSubFlow))
{
query["ReservedSubFlow"] = request.ReservedSubFlow;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RuleName))
{
query["RuleName"] = request.RuleName;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ScheduleType))
{
query["ScheduleType"] = request.ScheduleType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.TimeZone))
{
query["TimeZone"] = request.TimeZone;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.WeeklyTypesShrink))
{
query["WeeklyTypes"] = request.WeeklyTypesShrink;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreateScheduledScalingRule",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreateScheduledScalingRuleResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a scheduled scaling rule for a serverless ApsaraMQ for Kafka V3 instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h6><a href="#-v3-serverless-"></a>This operation is supported only by serverless ApsaraMQ for Kafka V3 instances.</h6>
/// </description>
///
/// <param name="tmpReq">
/// CreateScheduledScalingRuleRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreateScheduledScalingRuleResponse
/// </returns>
public async Task<CreateScheduledScalingRuleResponse> CreateScheduledScalingRuleWithOptionsAsync(CreateScheduledScalingRuleRequest tmpReq, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(tmpReq);
CreateScheduledScalingRuleShrinkRequest request = new CreateScheduledScalingRuleShrinkRequest();
AlibabaCloud.OpenApiUtil.Client.Convert(tmpReq, request);
if (!AlibabaCloud.TeaUtil.Common.IsUnset(tmpReq.WeeklyTypes))
{
request.WeeklyTypesShrink = AlibabaCloud.OpenApiUtil.Client.ArrayToStringWithSpecifiedStyle(tmpReq.WeeklyTypes, "WeeklyTypes", "json");
}
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DurationMinutes))
{
query["DurationMinutes"] = request.DurationMinutes;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Enable))
{
query["Enable"] = request.Enable;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.FirstScheduledTime))
{
query["FirstScheduledTime"] = request.FirstScheduledTime;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RepeatType))
{
query["RepeatType"] = request.RepeatType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ReservedPubFlow))
{
query["ReservedPubFlow"] = request.ReservedPubFlow;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ReservedSubFlow))
{
query["ReservedSubFlow"] = request.ReservedSubFlow;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RuleName))
{
query["RuleName"] = request.RuleName;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ScheduleType))
{
query["ScheduleType"] = request.ScheduleType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.TimeZone))
{
query["TimeZone"] = request.TimeZone;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.WeeklyTypesShrink))
{
query["WeeklyTypes"] = request.WeeklyTypesShrink;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreateScheduledScalingRule",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreateScheduledScalingRuleResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a scheduled scaling rule for a serverless ApsaraMQ for Kafka V3 instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h6><a href="#-v3-serverless-"></a>This operation is supported only by serverless ApsaraMQ for Kafka V3 instances.</h6>
/// </description>
///
/// <param name="request">
/// CreateScheduledScalingRuleRequest
/// </param>
///
/// <returns>
/// CreateScheduledScalingRuleResponse
/// </returns>
public CreateScheduledScalingRuleResponse CreateScheduledScalingRule(CreateScheduledScalingRuleRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return CreateScheduledScalingRuleWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a scheduled scaling rule for a serverless ApsaraMQ for Kafka V3 instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h6><a href="#-v3-serverless-"></a>This operation is supported only by serverless ApsaraMQ for Kafka V3 instances.</h6>
/// </description>
///
/// <param name="request">
/// CreateScheduledScalingRuleRequest
/// </param>
///
/// <returns>
/// CreateScheduledScalingRuleResponse
/// </returns>
public async Task<CreateScheduledScalingRuleResponse> CreateScheduledScalingRuleAsync(CreateScheduledScalingRuleRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await CreateScheduledScalingRuleWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a topic.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para> Each Alibaba Cloud account can call this operation up to once per second.</para>
/// <list type="bullet">
/// <item><description>The maximum number of topics that you can create in an instance is determined by the specification of the instance.</description></item>
/// </list>
/// </description>
///
/// <param name="request">
/// CreateTopicRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreateTopicResponse
/// </returns>
public CreateTopicResponse CreateTopicWithOptions(CreateTopicRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.CompactTopic))
{
query["CompactTopic"] = request.CompactTopic;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Config))
{
query["Config"] = request.Config;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.LocalTopic))
{
query["LocalTopic"] = request.LocalTopic;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.MinInsyncReplicas))
{
query["MinInsyncReplicas"] = request.MinInsyncReplicas;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PartitionNum))
{
query["PartitionNum"] = request.PartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Remark))
{
query["Remark"] = request.Remark;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ReplicationFactor))
{
query["ReplicationFactor"] = request.ReplicationFactor;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreateTopic",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreateTopicResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a topic.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para> Each Alibaba Cloud account can call this operation up to once per second.</para>
/// <list type="bullet">
/// <item><description>The maximum number of topics that you can create in an instance is determined by the specification of the instance.</description></item>
/// </list>
/// </description>
///
/// <param name="request">
/// CreateTopicRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// CreateTopicResponse
/// </returns>
public async Task<CreateTopicResponse> CreateTopicWithOptionsAsync(CreateTopicRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.CompactTopic))
{
query["CompactTopic"] = request.CompactTopic;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Config))
{
query["Config"] = request.Config;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.LocalTopic))
{
query["LocalTopic"] = request.LocalTopic;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.MinInsyncReplicas))
{
query["MinInsyncReplicas"] = request.MinInsyncReplicas;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PartitionNum))
{
query["PartitionNum"] = request.PartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Remark))
{
query["Remark"] = request.Remark;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ReplicationFactor))
{
query["ReplicationFactor"] = request.ReplicationFactor;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "CreateTopic",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<CreateTopicResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a topic.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para> Each Alibaba Cloud account can call this operation up to once per second.</para>
/// <list type="bullet">
/// <item><description>The maximum number of topics that you can create in an instance is determined by the specification of the instance.</description></item>
/// </list>
/// </description>
///
/// <param name="request">
/// CreateTopicRequest
/// </param>
///
/// <returns>
/// CreateTopicResponse
/// </returns>
public CreateTopicResponse CreateTopic(CreateTopicRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return CreateTopicWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Creates a topic.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para> Each Alibaba Cloud account can call this operation up to once per second.</para>
/// <list type="bullet">
/// <item><description>The maximum number of topics that you can create in an instance is determined by the specification of the instance.</description></item>
/// </list>
/// </description>
///
/// <param name="request">
/// CreateTopicRequest
/// </param>
///
/// <returns>
/// CreateTopicResponse
/// </returns>
public async Task<CreateTopicResponse> CreateTopicAsync(CreateTopicRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await CreateTopicWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes an access control list (ACL).</para>
/// </summary>
///
/// <param name="request">
/// DeleteAclRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DeleteAclResponse
/// </returns>
public DeleteAclResponse DeleteAclWithOptions(DeleteAclRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclOperationType))
{
query["AclOperationType"] = request.AclOperationType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclOperationTypes))
{
query["AclOperationTypes"] = request.AclOperationTypes;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclPermissionType))
{
query["AclPermissionType"] = request.AclPermissionType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourceName))
{
query["AclResourceName"] = request.AclResourceName;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourcePatternType))
{
query["AclResourcePatternType"] = request.AclResourcePatternType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourceType))
{
query["AclResourceType"] = request.AclResourceType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Host))
{
query["Host"] = request.Host;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Username))
{
query["Username"] = request.Username;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DeleteAcl",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DeleteAclResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes an access control list (ACL).</para>
/// </summary>
///
/// <param name="request">
/// DeleteAclRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DeleteAclResponse
/// </returns>
public async Task<DeleteAclResponse> DeleteAclWithOptionsAsync(DeleteAclRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclOperationType))
{
query["AclOperationType"] = request.AclOperationType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclOperationTypes))
{
query["AclOperationTypes"] = request.AclOperationTypes;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclPermissionType))
{
query["AclPermissionType"] = request.AclPermissionType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourceName))
{
query["AclResourceName"] = request.AclResourceName;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourcePatternType))
{
query["AclResourcePatternType"] = request.AclResourcePatternType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourceType))
{
query["AclResourceType"] = request.AclResourceType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Host))
{
query["Host"] = request.Host;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Username))
{
query["Username"] = request.Username;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DeleteAcl",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DeleteAclResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes an access control list (ACL).</para>
/// </summary>
///
/// <param name="request">
/// DeleteAclRequest
/// </param>
///
/// <returns>
/// DeleteAclResponse
/// </returns>
public DeleteAclResponse DeleteAcl(DeleteAclRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return DeleteAclWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes an access control list (ACL).</para>
/// </summary>
///
/// <param name="request">
/// DeleteAclRequest
/// </param>
///
/// <returns>
/// DeleteAclResponse
/// </returns>
public async Task<DeleteAclResponse> DeleteAclAsync(DeleteAclRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await DeleteAclWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes a consumer group from a specified Message Queue for Apache Kafka instance.</para>
/// </summary>
///
/// <param name="request">
/// DeleteConsumerGroupRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DeleteConsumerGroupResponse
/// </returns>
public DeleteConsumerGroupResponse DeleteConsumerGroupWithOptions(DeleteConsumerGroupRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ConsumerId))
{
query["ConsumerId"] = request.ConsumerId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DeleteConsumerGroup",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DeleteConsumerGroupResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes a consumer group from a specified Message Queue for Apache Kafka instance.</para>
/// </summary>
///
/// <param name="request">
/// DeleteConsumerGroupRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DeleteConsumerGroupResponse
/// </returns>
public async Task<DeleteConsumerGroupResponse> DeleteConsumerGroupWithOptionsAsync(DeleteConsumerGroupRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ConsumerId))
{
query["ConsumerId"] = request.ConsumerId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DeleteConsumerGroup",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DeleteConsumerGroupResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes a consumer group from a specified Message Queue for Apache Kafka instance.</para>
/// </summary>
///
/// <param name="request">
/// DeleteConsumerGroupRequest
/// </param>
///
/// <returns>
/// DeleteConsumerGroupResponse
/// </returns>
public DeleteConsumerGroupResponse DeleteConsumerGroup(DeleteConsumerGroupRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return DeleteConsumerGroupWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes a consumer group from a specified Message Queue for Apache Kafka instance.</para>
/// </summary>
///
/// <param name="request">
/// DeleteConsumerGroupRequest
/// </param>
///
/// <returns>
/// DeleteConsumerGroupResponse
/// </returns>
public async Task<DeleteConsumerGroupResponse> DeleteConsumerGroupAsync(DeleteConsumerGroupRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await DeleteConsumerGroupWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes an instance. You can delete subscription and pay-as-you-go instances after you release them.</para>
/// </summary>
///
/// <param name="request">
/// DeleteInstanceRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DeleteInstanceResponse
/// </returns>
public DeleteInstanceResponse DeleteInstanceWithOptions(DeleteInstanceRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DeleteInstance",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DeleteInstanceResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes an instance. You can delete subscription and pay-as-you-go instances after you release them.</para>
/// </summary>
///
/// <param name="request">
/// DeleteInstanceRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DeleteInstanceResponse
/// </returns>
public async Task<DeleteInstanceResponse> DeleteInstanceWithOptionsAsync(DeleteInstanceRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DeleteInstance",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DeleteInstanceResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes an instance. You can delete subscription and pay-as-you-go instances after you release them.</para>
/// </summary>
///
/// <param name="request">
/// DeleteInstanceRequest
/// </param>
///
/// <returns>
/// DeleteInstanceResponse
/// </returns>
public DeleteInstanceResponse DeleteInstance(DeleteInstanceRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return DeleteInstanceWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes an instance. You can delete subscription and pay-as-you-go instances after you release them.</para>
/// </summary>
///
/// <param name="request">
/// DeleteInstanceRequest
/// </param>
///
/// <returns>
/// DeleteInstanceResponse
/// </returns>
public async Task<DeleteInstanceResponse> DeleteInstanceAsync(DeleteInstanceRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await DeleteInstanceWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes a Simple Authentication and Security Layer (SASL) user.</para>
/// </summary>
///
/// <param name="request">
/// DeleteSaslUserRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DeleteSaslUserResponse
/// </returns>
public DeleteSaslUserResponse DeleteSaslUserWithOptions(DeleteSaslUserRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Mechanism))
{
query["Mechanism"] = request.Mechanism;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Type))
{
query["Type"] = request.Type;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Username))
{
query["Username"] = request.Username;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DeleteSaslUser",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DeleteSaslUserResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes a Simple Authentication and Security Layer (SASL) user.</para>
/// </summary>
///
/// <param name="request">
/// DeleteSaslUserRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DeleteSaslUserResponse
/// </returns>
public async Task<DeleteSaslUserResponse> DeleteSaslUserWithOptionsAsync(DeleteSaslUserRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Mechanism))
{
query["Mechanism"] = request.Mechanism;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Type))
{
query["Type"] = request.Type;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Username))
{
query["Username"] = request.Username;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DeleteSaslUser",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DeleteSaslUserResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes a Simple Authentication and Security Layer (SASL) user.</para>
/// </summary>
///
/// <param name="request">
/// DeleteSaslUserRequest
/// </param>
///
/// <returns>
/// DeleteSaslUserResponse
/// </returns>
public DeleteSaslUserResponse DeleteSaslUser(DeleteSaslUserRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return DeleteSaslUserWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes a Simple Authentication and Security Layer (SASL) user.</para>
/// </summary>
///
/// <param name="request">
/// DeleteSaslUserRequest
/// </param>
///
/// <returns>
/// DeleteSaslUserResponse
/// </returns>
public async Task<DeleteSaslUserResponse> DeleteSaslUserAsync(DeleteSaslUserRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await DeleteSaslUserWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes the scheduled scaling policy of a serverless ApsaraMQ for Kafka instance after you deploy the instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h6><a href="#-serverless-"></a>This operation is available only for serverless ApsaraMQ for Kafka instances.</h6>
/// </description>
///
/// <param name="request">
/// DeleteScheduledScalingRuleRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DeleteScheduledScalingRuleResponse
/// </returns>
public DeleteScheduledScalingRuleResponse DeleteScheduledScalingRuleWithOptions(DeleteScheduledScalingRuleRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RuleName))
{
query["RuleName"] = request.RuleName;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DeleteScheduledScalingRule",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DeleteScheduledScalingRuleResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes the scheduled scaling policy of a serverless ApsaraMQ for Kafka instance after you deploy the instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h6><a href="#-serverless-"></a>This operation is available only for serverless ApsaraMQ for Kafka instances.</h6>
/// </description>
///
/// <param name="request">
/// DeleteScheduledScalingRuleRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DeleteScheduledScalingRuleResponse
/// </returns>
public async Task<DeleteScheduledScalingRuleResponse> DeleteScheduledScalingRuleWithOptionsAsync(DeleteScheduledScalingRuleRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RuleName))
{
query["RuleName"] = request.RuleName;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DeleteScheduledScalingRule",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DeleteScheduledScalingRuleResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes the scheduled scaling policy of a serverless ApsaraMQ for Kafka instance after you deploy the instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h6><a href="#-serverless-"></a>This operation is available only for serverless ApsaraMQ for Kafka instances.</h6>
/// </description>
///
/// <param name="request">
/// DeleteScheduledScalingRuleRequest
/// </param>
///
/// <returns>
/// DeleteScheduledScalingRuleResponse
/// </returns>
public DeleteScheduledScalingRuleResponse DeleteScheduledScalingRule(DeleteScheduledScalingRuleRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return DeleteScheduledScalingRuleWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes the scheduled scaling policy of a serverless ApsaraMQ for Kafka instance after you deploy the instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h6><a href="#-serverless-"></a>This operation is available only for serverless ApsaraMQ for Kafka instances.</h6>
/// </description>
///
/// <param name="request">
/// DeleteScheduledScalingRuleRequest
/// </param>
///
/// <returns>
/// DeleteScheduledScalingRuleResponse
/// </returns>
public async Task<DeleteScheduledScalingRuleResponse> DeleteScheduledScalingRuleAsync(DeleteScheduledScalingRuleRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await DeleteScheduledScalingRuleWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes a topic.</para>
/// </summary>
///
/// <param name="request">
/// DeleteTopicRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DeleteTopicResponse
/// </returns>
public DeleteTopicResponse DeleteTopicWithOptions(DeleteTopicRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DeleteTopic",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DeleteTopicResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes a topic.</para>
/// </summary>
///
/// <param name="request">
/// DeleteTopicRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DeleteTopicResponse
/// </returns>
public async Task<DeleteTopicResponse> DeleteTopicWithOptionsAsync(DeleteTopicRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DeleteTopic",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DeleteTopicResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes a topic.</para>
/// </summary>
///
/// <param name="request">
/// DeleteTopicRequest
/// </param>
///
/// <returns>
/// DeleteTopicResponse
/// </returns>
public DeleteTopicResponse DeleteTopic(DeleteTopicRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return DeleteTopicWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deletes a topic.</para>
/// </summary>
///
/// <param name="request">
/// DeleteTopicRequest
/// </param>
///
/// <returns>
/// DeleteTopicResponse
/// </returns>
public async Task<DeleteTopicResponse> DeleteTopicAsync(DeleteTopicRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await DeleteTopicWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>查询acl资源名</para>
/// </summary>
///
/// <param name="request">
/// DescribeAclResourceNameRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DescribeAclResourceNameResponse
/// </returns>
public DescribeAclResourceNameResponse DescribeAclResourceNameWithOptions(DescribeAclResourceNameRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourcePatternType))
{
query["AclResourcePatternType"] = request.AclResourcePatternType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourceType))
{
query["AclResourceType"] = request.AclResourceType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DescribeAclResourceName",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DescribeAclResourceNameResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>查询acl资源名</para>
/// </summary>
///
/// <param name="request">
/// DescribeAclResourceNameRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DescribeAclResourceNameResponse
/// </returns>
public async Task<DescribeAclResourceNameResponse> DescribeAclResourceNameWithOptionsAsync(DescribeAclResourceNameRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourcePatternType))
{
query["AclResourcePatternType"] = request.AclResourcePatternType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourceType))
{
query["AclResourceType"] = request.AclResourceType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DescribeAclResourceName",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DescribeAclResourceNameResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>查询acl资源名</para>
/// </summary>
///
/// <param name="request">
/// DescribeAclResourceNameRequest
/// </param>
///
/// <returns>
/// DescribeAclResourceNameResponse
/// </returns>
public DescribeAclResourceNameResponse DescribeAclResourceName(DescribeAclResourceNameRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return DescribeAclResourceNameWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>查询acl资源名</para>
/// </summary>
///
/// <param name="request">
/// DescribeAclResourceNameRequest
/// </param>
///
/// <returns>
/// DescribeAclResourceNameResponse
/// </returns>
public async Task<DescribeAclResourceNameResponse> DescribeAclResourceNameAsync(DescribeAclResourceNameRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await DescribeAclResourceNameWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries access control lists (ACLs).</para>
/// </summary>
///
/// <param name="request">
/// DescribeAclsRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DescribeAclsResponse
/// </returns>
public DescribeAclsResponse DescribeAclsWithOptions(DescribeAclsRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclOperationType))
{
query["AclOperationType"] = request.AclOperationType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclPermissionType))
{
query["AclPermissionType"] = request.AclPermissionType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourceName))
{
query["AclResourceName"] = request.AclResourceName;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourcePatternType))
{
query["AclResourcePatternType"] = request.AclResourcePatternType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourceType))
{
query["AclResourceType"] = request.AclResourceType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Host))
{
query["Host"] = request.Host;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Username))
{
query["Username"] = request.Username;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DescribeAcls",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DescribeAclsResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries access control lists (ACLs).</para>
/// </summary>
///
/// <param name="request">
/// DescribeAclsRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DescribeAclsResponse
/// </returns>
public async Task<DescribeAclsResponse> DescribeAclsWithOptionsAsync(DescribeAclsRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclOperationType))
{
query["AclOperationType"] = request.AclOperationType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclPermissionType))
{
query["AclPermissionType"] = request.AclPermissionType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourceName))
{
query["AclResourceName"] = request.AclResourceName;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourcePatternType))
{
query["AclResourcePatternType"] = request.AclResourcePatternType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AclResourceType))
{
query["AclResourceType"] = request.AclResourceType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Host))
{
query["Host"] = request.Host;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Username))
{
query["Username"] = request.Username;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DescribeAcls",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DescribeAclsResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries access control lists (ACLs).</para>
/// </summary>
///
/// <param name="request">
/// DescribeAclsRequest
/// </param>
///
/// <returns>
/// DescribeAclsResponse
/// </returns>
public DescribeAclsResponse DescribeAcls(DescribeAclsRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return DescribeAclsWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries access control lists (ACLs).</para>
/// </summary>
///
/// <param name="request">
/// DescribeAclsRequest
/// </param>
///
/// <returns>
/// DescribeAclsResponse
/// </returns>
public async Task<DescribeAclsResponse> DescribeAclsAsync(DescribeAclsRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await DescribeAclsWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries Simple Authentication and Security Layer (SASL) users.</para>
/// </summary>
///
/// <param name="request">
/// DescribeSaslUsersRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DescribeSaslUsersResponse
/// </returns>
public DescribeSaslUsersResponse DescribeSaslUsersWithOptions(DescribeSaslUsersRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DescribeSaslUsers",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DescribeSaslUsersResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries Simple Authentication and Security Layer (SASL) users.</para>
/// </summary>
///
/// <param name="request">
/// DescribeSaslUsersRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// DescribeSaslUsersResponse
/// </returns>
public async Task<DescribeSaslUsersResponse> DescribeSaslUsersWithOptionsAsync(DescribeSaslUsersRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "DescribeSaslUsers",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<DescribeSaslUsersResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries Simple Authentication and Security Layer (SASL) users.</para>
/// </summary>
///
/// <param name="request">
/// DescribeSaslUsersRequest
/// </param>
///
/// <returns>
/// DescribeSaslUsersResponse
/// </returns>
public DescribeSaslUsersResponse DescribeSaslUsers(DescribeSaslUsersRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return DescribeSaslUsersWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries Simple Authentication and Security Layer (SASL) users.</para>
/// </summary>
///
/// <param name="request">
/// DescribeSaslUsersRequest
/// </param>
///
/// <returns>
/// DescribeSaslUsersResponse
/// </returns>
public async Task<DescribeSaslUsersResponse> DescribeSaslUsersAsync(DescribeSaslUsersRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await DescribeSaslUsersWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Enables and disables the flexible group creation feature.</para>
/// </summary>
///
/// <param name="request">
/// EnableAutoGroupCreationRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// EnableAutoGroupCreationResponse
/// </returns>
public EnableAutoGroupCreationResponse EnableAutoGroupCreationWithOptions(EnableAutoGroupCreationRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Enable))
{
query["Enable"] = request.Enable;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "EnableAutoGroupCreation",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<EnableAutoGroupCreationResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Enables and disables the flexible group creation feature.</para>
/// </summary>
///
/// <param name="request">
/// EnableAutoGroupCreationRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// EnableAutoGroupCreationResponse
/// </returns>
public async Task<EnableAutoGroupCreationResponse> EnableAutoGroupCreationWithOptionsAsync(EnableAutoGroupCreationRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Enable))
{
query["Enable"] = request.Enable;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "EnableAutoGroupCreation",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<EnableAutoGroupCreationResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Enables and disables the flexible group creation feature.</para>
/// </summary>
///
/// <param name="request">
/// EnableAutoGroupCreationRequest
/// </param>
///
/// <returns>
/// EnableAutoGroupCreationResponse
/// </returns>
public EnableAutoGroupCreationResponse EnableAutoGroupCreation(EnableAutoGroupCreationRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return EnableAutoGroupCreationWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Enables and disables the flexible group creation feature.</para>
/// </summary>
///
/// <param name="request">
/// EnableAutoGroupCreationRequest
/// </param>
///
/// <returns>
/// EnableAutoGroupCreationResponse
/// </returns>
public async Task<EnableAutoGroupCreationResponse> EnableAutoGroupCreationAsync(EnableAutoGroupCreationRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await EnableAutoGroupCreationWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Enables or disables the automatic topic creation feature, or changes the number of partitions in topics that are automatically created.</para>
/// </summary>
///
/// <param name="request">
/// EnableAutoTopicCreationRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// EnableAutoTopicCreationResponse
/// </returns>
public EnableAutoTopicCreationResponse EnableAutoTopicCreationWithOptions(EnableAutoTopicCreationRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Operate))
{
query["Operate"] = request.Operate;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PartitionNum))
{
query["PartitionNum"] = request.PartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.UpdatePartition))
{
query["UpdatePartition"] = request.UpdatePartition;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "EnableAutoTopicCreation",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<EnableAutoTopicCreationResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Enables or disables the automatic topic creation feature, or changes the number of partitions in topics that are automatically created.</para>
/// </summary>
///
/// <param name="request">
/// EnableAutoTopicCreationRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// EnableAutoTopicCreationResponse
/// </returns>
public async Task<EnableAutoTopicCreationResponse> EnableAutoTopicCreationWithOptionsAsync(EnableAutoTopicCreationRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Operate))
{
query["Operate"] = request.Operate;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PartitionNum))
{
query["PartitionNum"] = request.PartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.UpdatePartition))
{
query["UpdatePartition"] = request.UpdatePartition;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "EnableAutoTopicCreation",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<EnableAutoTopicCreationResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Enables or disables the automatic topic creation feature, or changes the number of partitions in topics that are automatically created.</para>
/// </summary>
///
/// <param name="request">
/// EnableAutoTopicCreationRequest
/// </param>
///
/// <returns>
/// EnableAutoTopicCreationResponse
/// </returns>
public EnableAutoTopicCreationResponse EnableAutoTopicCreation(EnableAutoTopicCreationRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return EnableAutoTopicCreationWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Enables or disables the automatic topic creation feature, or changes the number of partitions in topics that are automatically created.</para>
/// </summary>
///
/// <param name="request">
/// EnableAutoTopicCreationRequest
/// </param>
///
/// <returns>
/// EnableAutoTopicCreationResponse
/// </returns>
public async Task<EnableAutoTopicCreationResponse> EnableAutoTopicCreationAsync(EnableAutoTopicCreationRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await EnableAutoTopicCreationWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the IDs of all instances in the current account.</para>
/// </summary>
///
/// <param name="request">
/// GetAllInstanceIdListRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetAllInstanceIdListResponse
/// </returns>
public GetAllInstanceIdListResponse GetAllInstanceIdListWithOptions(GetAllInstanceIdListRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetAllInstanceIdList",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetAllInstanceIdListResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the IDs of all instances in the current account.</para>
/// </summary>
///
/// <param name="request">
/// GetAllInstanceIdListRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetAllInstanceIdListResponse
/// </returns>
public async Task<GetAllInstanceIdListResponse> GetAllInstanceIdListWithOptionsAsync(GetAllInstanceIdListRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetAllInstanceIdList",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetAllInstanceIdListResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the IDs of all instances in the current account.</para>
/// </summary>
///
/// <param name="request">
/// GetAllInstanceIdListRequest
/// </param>
///
/// <returns>
/// GetAllInstanceIdListResponse
/// </returns>
public GetAllInstanceIdListResponse GetAllInstanceIdList(GetAllInstanceIdListRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return GetAllInstanceIdListWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the IDs of all instances in the current account.</para>
/// </summary>
///
/// <param name="request">
/// GetAllInstanceIdListRequest
/// </param>
///
/// <returns>
/// GetAllInstanceIdListResponse
/// </returns>
public async Task<GetAllInstanceIdListResponse> GetAllInstanceIdListAsync(GetAllInstanceIdListRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await GetAllInstanceIdListWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the IP address whitelist.</para>
/// </summary>
///
/// <param name="request">
/// GetAllowedIpListRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetAllowedIpListResponse
/// </returns>
public GetAllowedIpListResponse GetAllowedIpListWithOptions(GetAllowedIpListRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetAllowedIpList",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetAllowedIpListResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the IP address whitelist.</para>
/// </summary>
///
/// <param name="request">
/// GetAllowedIpListRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetAllowedIpListResponse
/// </returns>
public async Task<GetAllowedIpListResponse> GetAllowedIpListWithOptionsAsync(GetAllowedIpListRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetAllowedIpList",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetAllowedIpListResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the IP address whitelist.</para>
/// </summary>
///
/// <param name="request">
/// GetAllowedIpListRequest
/// </param>
///
/// <returns>
/// GetAllowedIpListResponse
/// </returns>
public GetAllowedIpListResponse GetAllowedIpList(GetAllowedIpListRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return GetAllowedIpListWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the IP address whitelist.</para>
/// </summary>
///
/// <param name="request">
/// GetAllowedIpListRequest
/// </param>
///
/// <returns>
/// GetAllowedIpListResponse
/// </returns>
public async Task<GetAllowedIpListResponse> GetAllowedIpListAsync(GetAllowedIpListRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await GetAllowedIpListWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the scheduled scaling policy of a serverless ApsaraMQ for Kafka instance after you deploy the instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h6><a href="#-serverless-"></a>**This operation is available only for serverless ApsaraMQ for Kafka instances.</h6>
/// </description>
///
/// <param name="request">
/// GetAutoScalingConfigurationRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetAutoScalingConfigurationResponse
/// </returns>
public GetAutoScalingConfigurationResponse GetAutoScalingConfigurationWithOptions(GetAutoScalingConfigurationRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetAutoScalingConfiguration",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetAutoScalingConfigurationResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the scheduled scaling policy of a serverless ApsaraMQ for Kafka instance after you deploy the instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h6><a href="#-serverless-"></a>**This operation is available only for serverless ApsaraMQ for Kafka instances.</h6>
/// </description>
///
/// <param name="request">
/// GetAutoScalingConfigurationRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetAutoScalingConfigurationResponse
/// </returns>
public async Task<GetAutoScalingConfigurationResponse> GetAutoScalingConfigurationWithOptionsAsync(GetAutoScalingConfigurationRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetAutoScalingConfiguration",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetAutoScalingConfigurationResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the scheduled scaling policy of a serverless ApsaraMQ for Kafka instance after you deploy the instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h6><a href="#-serverless-"></a>**This operation is available only for serverless ApsaraMQ for Kafka instances.</h6>
/// </description>
///
/// <param name="request">
/// GetAutoScalingConfigurationRequest
/// </param>
///
/// <returns>
/// GetAutoScalingConfigurationResponse
/// </returns>
public GetAutoScalingConfigurationResponse GetAutoScalingConfiguration(GetAutoScalingConfigurationRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return GetAutoScalingConfigurationWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the scheduled scaling policy of a serverless ApsaraMQ for Kafka instance after you deploy the instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h6><a href="#-serverless-"></a>**This operation is available only for serverless ApsaraMQ for Kafka instances.</h6>
/// </description>
///
/// <param name="request">
/// GetAutoScalingConfigurationRequest
/// </param>
///
/// <returns>
/// GetAutoScalingConfigurationResponse
/// </returns>
public async Task<GetAutoScalingConfigurationResponse> GetAutoScalingConfigurationAsync(GetAutoScalingConfigurationRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await GetAutoScalingConfigurationWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries one or more consumer groups in a specified Message Queue for Apache Kafka instance.</para>
/// </summary>
///
/// <param name="request">
/// GetConsumerListRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetConsumerListResponse
/// </returns>
public GetConsumerListResponse GetConsumerListWithOptions(GetConsumerListRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ConsumerId))
{
query["ConsumerId"] = request.ConsumerId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.CurrentPage))
{
query["CurrentPage"] = request.CurrentPage;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PageSize))
{
query["PageSize"] = request.PageSize;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetConsumerList",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetConsumerListResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries one or more consumer groups in a specified Message Queue for Apache Kafka instance.</para>
/// </summary>
///
/// <param name="request">
/// GetConsumerListRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetConsumerListResponse
/// </returns>
public async Task<GetConsumerListResponse> GetConsumerListWithOptionsAsync(GetConsumerListRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ConsumerId))
{
query["ConsumerId"] = request.ConsumerId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.CurrentPage))
{
query["CurrentPage"] = request.CurrentPage;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PageSize))
{
query["PageSize"] = request.PageSize;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetConsumerList",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetConsumerListResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries one or more consumer groups in a specified Message Queue for Apache Kafka instance.</para>
/// </summary>
///
/// <param name="request">
/// GetConsumerListRequest
/// </param>
///
/// <returns>
/// GetConsumerListResponse
/// </returns>
public GetConsumerListResponse GetConsumerList(GetConsumerListRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return GetConsumerListWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries one or more consumer groups in a specified Message Queue for Apache Kafka instance.</para>
/// </summary>
///
/// <param name="request">
/// GetConsumerListRequest
/// </param>
///
/// <returns>
/// GetConsumerListResponse
/// </returns>
public async Task<GetConsumerListResponse> GetConsumerListAsync(GetConsumerListRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await GetConsumerListWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the consumer progress of a consumer group.</para>
/// </summary>
///
/// <param name="request">
/// GetConsumerProgressRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetConsumerProgressResponse
/// </returns>
public GetConsumerProgressResponse GetConsumerProgressWithOptions(GetConsumerProgressRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ConsumerId))
{
query["ConsumerId"] = request.ConsumerId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.HideLastTimestamp))
{
query["HideLastTimestamp"] = request.HideLastTimestamp;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetConsumerProgress",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetConsumerProgressResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the consumer progress of a consumer group.</para>
/// </summary>
///
/// <param name="request">
/// GetConsumerProgressRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetConsumerProgressResponse
/// </returns>
public async Task<GetConsumerProgressResponse> GetConsumerProgressWithOptionsAsync(GetConsumerProgressRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ConsumerId))
{
query["ConsumerId"] = request.ConsumerId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.HideLastTimestamp))
{
query["HideLastTimestamp"] = request.HideLastTimestamp;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetConsumerProgress",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetConsumerProgressResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the consumer progress of a consumer group.</para>
/// </summary>
///
/// <param name="request">
/// GetConsumerProgressRequest
/// </param>
///
/// <returns>
/// GetConsumerProgressResponse
/// </returns>
public GetConsumerProgressResponse GetConsumerProgress(GetConsumerProgressRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return GetConsumerProgressWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the consumer progress of a consumer group.</para>
/// </summary>
///
/// <param name="request">
/// GetConsumerProgressRequest
/// </param>
///
/// <returns>
/// GetConsumerProgressResponse
/// </returns>
public async Task<GetConsumerProgressResponse> GetConsumerProgressAsync(GetConsumerProgressRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await GetConsumerProgressWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the information about instances in a specified region.</para>
/// </summary>
///
/// <param name="request">
/// GetInstanceListRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetInstanceListResponse
/// </returns>
public GetInstanceListResponse GetInstanceListWithOptions(GetInstanceListRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.OrderId))
{
query["OrderId"] = request.OrderId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceGroupId))
{
query["ResourceGroupId"] = request.ResourceGroupId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Series))
{
query["Series"] = request.Series;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetInstanceList",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetInstanceListResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the information about instances in a specified region.</para>
/// </summary>
///
/// <param name="request">
/// GetInstanceListRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetInstanceListResponse
/// </returns>
public async Task<GetInstanceListResponse> GetInstanceListWithOptionsAsync(GetInstanceListRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.OrderId))
{
query["OrderId"] = request.OrderId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceGroupId))
{
query["ResourceGroupId"] = request.ResourceGroupId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Series))
{
query["Series"] = request.Series;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetInstanceList",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetInstanceListResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the information about instances in a specified region.</para>
/// </summary>
///
/// <param name="request">
/// GetInstanceListRequest
/// </param>
///
/// <returns>
/// GetInstanceListResponse
/// </returns>
public GetInstanceListResponse GetInstanceList(GetInstanceListRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return GetInstanceListWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the information about instances in a specified region.</para>
/// </summary>
///
/// <param name="request">
/// GetInstanceListRequest
/// </param>
///
/// <returns>
/// GetInstanceListResponse
/// </returns>
public async Task<GetInstanceListResponse> GetInstanceListAsync(GetInstanceListRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await GetInstanceListWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the IP addresses of the clients that are connected to an ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para> The IP information is obtained from the sampled logs generated for the requests that the client sends to the broker by calling the API operations of ApsaraMQ for Kafka.</para>
/// <list type="bullet">
/// <item><description>Statistics refers to the number of connections on different ports of an IP address within a specific period of time.</description></item>
/// <item><description>If the broker is not of the latest minor version, the sampled logs may not be accurate. This may cause inaccurate IP information. Therefore, we recommend that you update your broker to the latest version at the earliest opportunity.</description></item>
/// </list>
/// </description>
///
/// <param name="request">
/// GetKafkaClientIpRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetKafkaClientIpResponse
/// </returns>
public GetKafkaClientIpResponse GetKafkaClientIpWithOptions(GetKafkaClientIpRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EndTime))
{
query["EndTime"] = request.EndTime;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Group))
{
query["Group"] = request.Group;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.StartTime))
{
query["StartTime"] = request.StartTime;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Type))
{
query["Type"] = request.Type;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetKafkaClientIp",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetKafkaClientIpResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the IP addresses of the clients that are connected to an ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para> The IP information is obtained from the sampled logs generated for the requests that the client sends to the broker by calling the API operations of ApsaraMQ for Kafka.</para>
/// <list type="bullet">
/// <item><description>Statistics refers to the number of connections on different ports of an IP address within a specific period of time.</description></item>
/// <item><description>If the broker is not of the latest minor version, the sampled logs may not be accurate. This may cause inaccurate IP information. Therefore, we recommend that you update your broker to the latest version at the earliest opportunity.</description></item>
/// </list>
/// </description>
///
/// <param name="request">
/// GetKafkaClientIpRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetKafkaClientIpResponse
/// </returns>
public async Task<GetKafkaClientIpResponse> GetKafkaClientIpWithOptionsAsync(GetKafkaClientIpRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EndTime))
{
query["EndTime"] = request.EndTime;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Group))
{
query["Group"] = request.Group;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.StartTime))
{
query["StartTime"] = request.StartTime;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Type))
{
query["Type"] = request.Type;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetKafkaClientIp",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetKafkaClientIpResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the IP addresses of the clients that are connected to an ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para> The IP information is obtained from the sampled logs generated for the requests that the client sends to the broker by calling the API operations of ApsaraMQ for Kafka.</para>
/// <list type="bullet">
/// <item><description>Statistics refers to the number of connections on different ports of an IP address within a specific period of time.</description></item>
/// <item><description>If the broker is not of the latest minor version, the sampled logs may not be accurate. This may cause inaccurate IP information. Therefore, we recommend that you update your broker to the latest version at the earliest opportunity.</description></item>
/// </list>
/// </description>
///
/// <param name="request">
/// GetKafkaClientIpRequest
/// </param>
///
/// <returns>
/// GetKafkaClientIpResponse
/// </returns>
public GetKafkaClientIpResponse GetKafkaClientIp(GetKafkaClientIpRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return GetKafkaClientIpWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the IP addresses of the clients that are connected to an ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para> The IP information is obtained from the sampled logs generated for the requests that the client sends to the broker by calling the API operations of ApsaraMQ for Kafka.</para>
/// <list type="bullet">
/// <item><description>Statistics refers to the number of connections on different ports of an IP address within a specific period of time.</description></item>
/// <item><description>If the broker is not of the latest minor version, the sampled logs may not be accurate. This may cause inaccurate IP information. Therefore, we recommend that you update your broker to the latest version at the earliest opportunity.</description></item>
/// </list>
/// </description>
///
/// <param name="request">
/// GetKafkaClientIpRequest
/// </param>
///
/// <returns>
/// GetKafkaClientIpResponse
/// </returns>
public async Task<GetKafkaClientIpResponse> GetKafkaClientIpAsync(GetKafkaClientIpRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await GetKafkaClientIpWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the used quota of topics and partitions.</para>
/// </summary>
///
/// <param name="request">
/// GetQuotaTipRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetQuotaTipResponse
/// </returns>
public GetQuotaTipResponse GetQuotaTipWithOptions(GetQuotaTipRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetQuotaTip",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetQuotaTipResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the used quota of topics and partitions.</para>
/// </summary>
///
/// <param name="request">
/// GetQuotaTipRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetQuotaTipResponse
/// </returns>
public async Task<GetQuotaTipResponse> GetQuotaTipWithOptionsAsync(GetQuotaTipRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetQuotaTip",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetQuotaTipResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the used quota of topics and partitions.</para>
/// </summary>
///
/// <param name="request">
/// GetQuotaTipRequest
/// </param>
///
/// <returns>
/// GetQuotaTipResponse
/// </returns>
public GetQuotaTipResponse GetQuotaTip(GetQuotaTipRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return GetQuotaTipWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the used quota of topics and partitions.</para>
/// </summary>
///
/// <param name="request">
/// GetQuotaTipRequest
/// </param>
///
/// <returns>
/// GetQuotaTipResponse
/// </returns>
public async Task<GetQuotaTipResponse> GetQuotaTipAsync(GetQuotaTipRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await GetQuotaTipWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the information about a topic.</para>
/// </summary>
///
/// <param name="request">
/// GetTopicListRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetTopicListResponse
/// </returns>
public GetTopicListResponse GetTopicListWithOptions(GetTopicListRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.CurrentPage))
{
query["CurrentPage"] = request.CurrentPage;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PageSize))
{
query["PageSize"] = request.PageSize;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetTopicList",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetTopicListResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the information about a topic.</para>
/// </summary>
///
/// <param name="request">
/// GetTopicListRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetTopicListResponse
/// </returns>
public async Task<GetTopicListResponse> GetTopicListWithOptionsAsync(GetTopicListRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.CurrentPage))
{
query["CurrentPage"] = request.CurrentPage;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PageSize))
{
query["PageSize"] = request.PageSize;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetTopicList",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetTopicListResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the information about a topic.</para>
/// </summary>
///
/// <param name="request">
/// GetTopicListRequest
/// </param>
///
/// <returns>
/// GetTopicListResponse
/// </returns>
public GetTopicListResponse GetTopicList(GetTopicListRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return GetTopicListWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the information about a topic.</para>
/// </summary>
///
/// <param name="request">
/// GetTopicListRequest
/// </param>
///
/// <returns>
/// GetTopicListResponse
/// </returns>
public async Task<GetTopicListResponse> GetTopicListAsync(GetTopicListRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await GetTopicListWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the messaging status of a topic.</para>
/// </summary>
///
/// <param name="request">
/// GetTopicStatusRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetTopicStatusResponse
/// </returns>
public GetTopicStatusResponse GetTopicStatusWithOptions(GetTopicStatusRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetTopicStatus",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetTopicStatusResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the messaging status of a topic.</para>
/// </summary>
///
/// <param name="request">
/// GetTopicStatusRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetTopicStatusResponse
/// </returns>
public async Task<GetTopicStatusResponse> GetTopicStatusWithOptionsAsync(GetTopicStatusRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetTopicStatus",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetTopicStatusResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the messaging status of a topic.</para>
/// </summary>
///
/// <param name="request">
/// GetTopicStatusRequest
/// </param>
///
/// <returns>
/// GetTopicStatusResponse
/// </returns>
public GetTopicStatusResponse GetTopicStatus(GetTopicStatusRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return GetTopicStatusWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the messaging status of a topic.</para>
/// </summary>
///
/// <param name="request">
/// GetTopicStatusRequest
/// </param>
///
/// <returns>
/// GetTopicStatusResponse
/// </returns>
public async Task<GetTopicStatusResponse> GetTopicStatusAsync(GetTopicStatusRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await GetTopicStatusWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the information about the groups that subscribe to a topic.</para>
/// </summary>
///
/// <param name="request">
/// GetTopicSubscribeStatusRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetTopicSubscribeStatusResponse
/// </returns>
public GetTopicSubscribeStatusResponse GetTopicSubscribeStatusWithOptions(GetTopicSubscribeStatusRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetTopicSubscribeStatus",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetTopicSubscribeStatusResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the information about the groups that subscribe to a topic.</para>
/// </summary>
///
/// <param name="request">
/// GetTopicSubscribeStatusRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// GetTopicSubscribeStatusResponse
/// </returns>
public async Task<GetTopicSubscribeStatusResponse> GetTopicSubscribeStatusWithOptionsAsync(GetTopicSubscribeStatusRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "GetTopicSubscribeStatus",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<GetTopicSubscribeStatusResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the information about the groups that subscribe to a topic.</para>
/// </summary>
///
/// <param name="request">
/// GetTopicSubscribeStatusRequest
/// </param>
///
/// <returns>
/// GetTopicSubscribeStatusResponse
/// </returns>
public GetTopicSubscribeStatusResponse GetTopicSubscribeStatus(GetTopicSubscribeStatusRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return GetTopicSubscribeStatusWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the information about the groups that subscribe to a topic.</para>
/// </summary>
///
/// <param name="request">
/// GetTopicSubscribeStatusRequest
/// </param>
///
/// <returns>
/// GetTopicSubscribeStatusResponse
/// </returns>
public async Task<GetTopicSubscribeStatusResponse> GetTopicSubscribeStatusAsync(GetTopicSubscribeStatusRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await GetTopicSubscribeStatusWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the tags that are attached to a specified resource.</para>
/// </summary>
///
/// <param name="request">
/// ListTagResourcesRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ListTagResourcesResponse
/// </returns>
public ListTagResourcesResponse ListTagResourcesWithOptions(ListTagResourcesRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.NextToken))
{
query["NextToken"] = request.NextToken;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceId))
{
query["ResourceId"] = request.ResourceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceType))
{
query["ResourceType"] = request.ResourceType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ListTagResources",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ListTagResourcesResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the tags that are attached to a specified resource.</para>
/// </summary>
///
/// <param name="request">
/// ListTagResourcesRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ListTagResourcesResponse
/// </returns>
public async Task<ListTagResourcesResponse> ListTagResourcesWithOptionsAsync(ListTagResourcesRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.NextToken))
{
query["NextToken"] = request.NextToken;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceId))
{
query["ResourceId"] = request.ResourceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceType))
{
query["ResourceType"] = request.ResourceType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ListTagResources",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ListTagResourcesResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the tags that are attached to a specified resource.</para>
/// </summary>
///
/// <param name="request">
/// ListTagResourcesRequest
/// </param>
///
/// <returns>
/// ListTagResourcesResponse
/// </returns>
public ListTagResourcesResponse ListTagResources(ListTagResourcesRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return ListTagResourcesWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries the tags that are attached to a specified resource.</para>
/// </summary>
///
/// <param name="request">
/// ListTagResourcesRequest
/// </param>
///
/// <returns>
/// ListTagResourcesResponse
/// </returns>
public async Task<ListTagResourcesResponse> ListTagResourcesAsync(ListTagResourcesRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await ListTagResourcesWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Changes the name of an ApsaraMQ for Kafka instance. After you deploy an instance, you can call this operation to change the name of the instance.</para>
/// </summary>
///
/// <param name="request">
/// ModifyInstanceNameRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ModifyInstanceNameResponse
/// </returns>
public ModifyInstanceNameResponse ModifyInstanceNameWithOptions(ModifyInstanceNameRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceName))
{
query["InstanceName"] = request.InstanceName;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ModifyInstanceName",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ModifyInstanceNameResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Changes the name of an ApsaraMQ for Kafka instance. After you deploy an instance, you can call this operation to change the name of the instance.</para>
/// </summary>
///
/// <param name="request">
/// ModifyInstanceNameRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ModifyInstanceNameResponse
/// </returns>
public async Task<ModifyInstanceNameResponse> ModifyInstanceNameWithOptionsAsync(ModifyInstanceNameRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceName))
{
query["InstanceName"] = request.InstanceName;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ModifyInstanceName",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ModifyInstanceNameResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Changes the name of an ApsaraMQ for Kafka instance. After you deploy an instance, you can call this operation to change the name of the instance.</para>
/// </summary>
///
/// <param name="request">
/// ModifyInstanceNameRequest
/// </param>
///
/// <returns>
/// ModifyInstanceNameResponse
/// </returns>
public ModifyInstanceNameResponse ModifyInstanceName(ModifyInstanceNameRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return ModifyInstanceNameWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Changes the name of an ApsaraMQ for Kafka instance. After you deploy an instance, you can call this operation to change the name of the instance.</para>
/// </summary>
///
/// <param name="request">
/// ModifyInstanceNameRequest
/// </param>
///
/// <returns>
/// ModifyInstanceNameResponse
/// </returns>
public async Task<ModifyInstanceNameResponse> ModifyInstanceNameAsync(ModifyInstanceNameRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await ModifyInstanceNameWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Changes the number of partitions in a topic.</para>
/// </summary>
///
/// <param name="request">
/// ModifyPartitionNumRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ModifyPartitionNumResponse
/// </returns>
public ModifyPartitionNumResponse ModifyPartitionNumWithOptions(ModifyPartitionNumRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AddPartitionNum))
{
query["AddPartitionNum"] = request.AddPartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ModifyPartitionNum",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ModifyPartitionNumResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Changes the number of partitions in a topic.</para>
/// </summary>
///
/// <param name="request">
/// ModifyPartitionNumRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ModifyPartitionNumResponse
/// </returns>
public async Task<ModifyPartitionNumResponse> ModifyPartitionNumWithOptionsAsync(ModifyPartitionNumRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AddPartitionNum))
{
query["AddPartitionNum"] = request.AddPartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ModifyPartitionNum",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ModifyPartitionNumResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Changes the number of partitions in a topic.</para>
/// </summary>
///
/// <param name="request">
/// ModifyPartitionNumRequest
/// </param>
///
/// <returns>
/// ModifyPartitionNumResponse
/// </returns>
public ModifyPartitionNumResponse ModifyPartitionNum(ModifyPartitionNumRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return ModifyPartitionNumWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Changes the number of partitions in a topic.</para>
/// </summary>
///
/// <param name="request">
/// ModifyPartitionNumRequest
/// </param>
///
/// <returns>
/// ModifyPartitionNumResponse
/// </returns>
public async Task<ModifyPartitionNumResponse> ModifyPartitionNumAsync(ModifyPartitionNumRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await ModifyPartitionNumWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Modifies the scheduled scaling policy of a serverless ApsaraMQ for Kafka instance after you deploy the instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h6><a href="#-serverless-"></a>This operation is available only for serverless ApsaraMQ for Kafka instances.</h6>
/// </description>
///
/// <param name="request">
/// ModifyScheduledScalingRuleRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ModifyScheduledScalingRuleResponse
/// </returns>
public ModifyScheduledScalingRuleResponse ModifyScheduledScalingRuleWithOptions(ModifyScheduledScalingRuleRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Enable))
{
query["Enable"] = request.Enable;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RuleName))
{
query["RuleName"] = request.RuleName;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ModifyScheduledScalingRule",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ModifyScheduledScalingRuleResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Modifies the scheduled scaling policy of a serverless ApsaraMQ for Kafka instance after you deploy the instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h6><a href="#-serverless-"></a>This operation is available only for serverless ApsaraMQ for Kafka instances.</h6>
/// </description>
///
/// <param name="request">
/// ModifyScheduledScalingRuleRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ModifyScheduledScalingRuleResponse
/// </returns>
public async Task<ModifyScheduledScalingRuleResponse> ModifyScheduledScalingRuleWithOptionsAsync(ModifyScheduledScalingRuleRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Enable))
{
query["Enable"] = request.Enable;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RuleName))
{
query["RuleName"] = request.RuleName;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ModifyScheduledScalingRule",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ModifyScheduledScalingRuleResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Modifies the scheduled scaling policy of a serverless ApsaraMQ for Kafka instance after you deploy the instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h6><a href="#-serverless-"></a>This operation is available only for serverless ApsaraMQ for Kafka instances.</h6>
/// </description>
///
/// <param name="request">
/// ModifyScheduledScalingRuleRequest
/// </param>
///
/// <returns>
/// ModifyScheduledScalingRuleResponse
/// </returns>
public ModifyScheduledScalingRuleResponse ModifyScheduledScalingRule(ModifyScheduledScalingRuleRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return ModifyScheduledScalingRuleWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Modifies the scheduled scaling policy of a serverless ApsaraMQ for Kafka instance after you deploy the instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h6><a href="#-serverless-"></a>This operation is available only for serverless ApsaraMQ for Kafka instances.</h6>
/// </description>
///
/// <param name="request">
/// ModifyScheduledScalingRuleRequest
/// </param>
///
/// <returns>
/// ModifyScheduledScalingRuleResponse
/// </returns>
public async Task<ModifyScheduledScalingRuleResponse> ModifyScheduledScalingRuleAsync(ModifyScheduledScalingRuleRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await ModifyScheduledScalingRuleWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Modifies the description of a topic.</para>
/// </summary>
///
/// <param name="request">
/// ModifyTopicRemarkRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ModifyTopicRemarkResponse
/// </returns>
public ModifyTopicRemarkResponse ModifyTopicRemarkWithOptions(ModifyTopicRemarkRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Remark))
{
query["Remark"] = request.Remark;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ModifyTopicRemark",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ModifyTopicRemarkResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Modifies the description of a topic.</para>
/// </summary>
///
/// <param name="request">
/// ModifyTopicRemarkRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ModifyTopicRemarkResponse
/// </returns>
public async Task<ModifyTopicRemarkResponse> ModifyTopicRemarkWithOptionsAsync(ModifyTopicRemarkRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Remark))
{
query["Remark"] = request.Remark;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ModifyTopicRemark",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ModifyTopicRemarkResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Modifies the description of a topic.</para>
/// </summary>
///
/// <param name="request">
/// ModifyTopicRemarkRequest
/// </param>
///
/// <returns>
/// ModifyTopicRemarkResponse
/// </returns>
public ModifyTopicRemarkResponse ModifyTopicRemark(ModifyTopicRemarkRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return ModifyTopicRemarkWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Modifies the description of a topic.</para>
/// </summary>
///
/// <param name="request">
/// ModifyTopicRemarkRequest
/// </param>
///
/// <returns>
/// ModifyTopicRemarkResponse
/// </returns>
public async Task<ModifyTopicRemarkResponse> ModifyTopicRemarkAsync(ModifyTopicRemarkRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await ModifyTopicRemarkWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries messages stored in a topic. You can query messages by creation time or offset.</para>
/// </summary>
///
/// <param name="request">
/// QueryMessageRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// QueryMessageResponse
/// </returns>
public QueryMessageResponse QueryMessageWithOptions(QueryMessageRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, string> query = AlibabaCloud.OpenApiUtil.Client.Query(AlibabaCloud.TeaUtil.Common.ToMap(request));
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "QueryMessage",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "GET",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<QueryMessageResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries messages stored in a topic. You can query messages by creation time or offset.</para>
/// </summary>
///
/// <param name="request">
/// QueryMessageRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// QueryMessageResponse
/// </returns>
public async Task<QueryMessageResponse> QueryMessageWithOptionsAsync(QueryMessageRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, string> query = AlibabaCloud.OpenApiUtil.Client.Query(AlibabaCloud.TeaUtil.Common.ToMap(request));
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "QueryMessage",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "GET",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<QueryMessageResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries messages stored in a topic. You can query messages by creation time or offset.</para>
/// </summary>
///
/// <param name="request">
/// QueryMessageRequest
/// </param>
///
/// <returns>
/// QueryMessageResponse
/// </returns>
public QueryMessageResponse QueryMessage(QueryMessageRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return QueryMessageWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Queries messages stored in a topic. You can query messages by creation time or offset.</para>
/// </summary>
///
/// <param name="request">
/// QueryMessageRequest
/// </param>
///
/// <returns>
/// QueryMessageResponse
/// </returns>
public async Task<QueryMessageResponse> QueryMessageAsync(QueryMessageRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await QueryMessageWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Releases a pay-as-you-go instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>You cannot call this operation to release a subscription Message Queue for Apache Kafka instance.</para>
/// </description>
///
/// <param name="request">
/// ReleaseInstanceRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ReleaseInstanceResponse
/// </returns>
public ReleaseInstanceResponse ReleaseInstanceWithOptions(ReleaseInstanceRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ForceDeleteInstance))
{
query["ForceDeleteInstance"] = request.ForceDeleteInstance;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ReleaseInstance",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ReleaseInstanceResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Releases a pay-as-you-go instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>You cannot call this operation to release a subscription Message Queue for Apache Kafka instance.</para>
/// </description>
///
/// <param name="request">
/// ReleaseInstanceRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ReleaseInstanceResponse
/// </returns>
public async Task<ReleaseInstanceResponse> ReleaseInstanceWithOptionsAsync(ReleaseInstanceRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ForceDeleteInstance))
{
query["ForceDeleteInstance"] = request.ForceDeleteInstance;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ReleaseInstance",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ReleaseInstanceResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Releases a pay-as-you-go instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>You cannot call this operation to release a subscription Message Queue for Apache Kafka instance.</para>
/// </description>
///
/// <param name="request">
/// ReleaseInstanceRequest
/// </param>
///
/// <returns>
/// ReleaseInstanceResponse
/// </returns>
public ReleaseInstanceResponse ReleaseInstance(ReleaseInstanceRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return ReleaseInstanceWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Releases a pay-as-you-go instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>You cannot call this operation to release a subscription Message Queue for Apache Kafka instance.</para>
/// </description>
///
/// <param name="request">
/// ReleaseInstanceRequest
/// </param>
///
/// <returns>
/// ReleaseInstanceResponse
/// </returns>
public async Task<ReleaseInstanceResponse> ReleaseInstanceAsync(ReleaseInstanceRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await ReleaseInstanceWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Enables an ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>You can call this operation only if your instance is in the Stopped state.</para>
/// </description>
///
/// <param name="request">
/// ReopenInstanceRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ReopenInstanceResponse
/// </returns>
public ReopenInstanceResponse ReopenInstanceWithOptions(ReopenInstanceRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ReopenInstance",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ReopenInstanceResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Enables an ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>You can call this operation only if your instance is in the Stopped state.</para>
/// </description>
///
/// <param name="request">
/// ReopenInstanceRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// ReopenInstanceResponse
/// </returns>
public async Task<ReopenInstanceResponse> ReopenInstanceWithOptionsAsync(ReopenInstanceRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "ReopenInstance",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<ReopenInstanceResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Enables an ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>You can call this operation only if your instance is in the Stopped state.</para>
/// </description>
///
/// <param name="request">
/// ReopenInstanceRequest
/// </param>
///
/// <returns>
/// ReopenInstanceResponse
/// </returns>
public ReopenInstanceResponse ReopenInstance(ReopenInstanceRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return ReopenInstanceWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Enables an ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>You can call this operation only if your instance is in the Stopped state.</para>
/// </description>
///
/// <param name="request">
/// ReopenInstanceRequest
/// </param>
///
/// <returns>
/// ReopenInstanceResponse
/// </returns>
public async Task<ReopenInstanceResponse> ReopenInstanceAsync(ReopenInstanceRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await ReopenInstanceWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deploys an ApsaraMQ for Kafka instance. You must purchase and deploy an ApsaraMQ for Kafka instance before you can use the instance to send and receive messages.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <remarks>
/// <para> You can call this operation up to twice per second.</para>
/// </remarks>
/// </description>
///
/// <param name="request">
/// StartInstanceRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// StartInstanceResponse
/// </returns>
public StartInstanceResponse StartInstanceWithOptions(StartInstanceRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Config))
{
query["Config"] = request.Config;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.CrossZone))
{
query["CrossZone"] = request.CrossZone;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DeployModule))
{
query["DeployModule"] = request.DeployModule;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IsEipInner))
{
query["IsEipInner"] = request.IsEipInner;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IsForceSelectedZones))
{
query["IsForceSelectedZones"] = request.IsForceSelectedZones;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IsSetUserAndPassword))
{
query["IsSetUserAndPassword"] = request.IsSetUserAndPassword;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.KMSKeyId))
{
query["KMSKeyId"] = request.KMSKeyId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Name))
{
query["Name"] = request.Name;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Notifier))
{
query["Notifier"] = request.Notifier;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Password))
{
query["Password"] = request.Password;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.SecurityGroup))
{
query["SecurityGroup"] = request.SecurityGroup;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.SelectedZones))
{
query["SelectedZones"] = request.SelectedZones;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ServiceVersion))
{
query["ServiceVersion"] = request.ServiceVersion;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.UserPhoneNum))
{
query["UserPhoneNum"] = request.UserPhoneNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Username))
{
query["Username"] = request.Username;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.VSwitchId))
{
query["VSwitchId"] = request.VSwitchId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.VSwitchIds))
{
query["VSwitchIds"] = request.VSwitchIds;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.VpcId))
{
query["VpcId"] = request.VpcId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ZoneId))
{
query["ZoneId"] = request.ZoneId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "StartInstance",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<StartInstanceResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deploys an ApsaraMQ for Kafka instance. You must purchase and deploy an ApsaraMQ for Kafka instance before you can use the instance to send and receive messages.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <remarks>
/// <para> You can call this operation up to twice per second.</para>
/// </remarks>
/// </description>
///
/// <param name="request">
/// StartInstanceRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// StartInstanceResponse
/// </returns>
public async Task<StartInstanceResponse> StartInstanceWithOptionsAsync(StartInstanceRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Config))
{
query["Config"] = request.Config;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.CrossZone))
{
query["CrossZone"] = request.CrossZone;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DeployModule))
{
query["DeployModule"] = request.DeployModule;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IsEipInner))
{
query["IsEipInner"] = request.IsEipInner;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IsForceSelectedZones))
{
query["IsForceSelectedZones"] = request.IsForceSelectedZones;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IsSetUserAndPassword))
{
query["IsSetUserAndPassword"] = request.IsSetUserAndPassword;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.KMSKeyId))
{
query["KMSKeyId"] = request.KMSKeyId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Name))
{
query["Name"] = request.Name;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Notifier))
{
query["Notifier"] = request.Notifier;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Password))
{
query["Password"] = request.Password;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.SecurityGroup))
{
query["SecurityGroup"] = request.SecurityGroup;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.SelectedZones))
{
query["SelectedZones"] = request.SelectedZones;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ServiceVersion))
{
query["ServiceVersion"] = request.ServiceVersion;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.UserPhoneNum))
{
query["UserPhoneNum"] = request.UserPhoneNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Username))
{
query["Username"] = request.Username;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.VSwitchId))
{
query["VSwitchId"] = request.VSwitchId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.VSwitchIds))
{
query["VSwitchIds"] = request.VSwitchIds;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.VpcId))
{
query["VpcId"] = request.VpcId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ZoneId))
{
query["ZoneId"] = request.ZoneId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "StartInstance",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<StartInstanceResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deploys an ApsaraMQ for Kafka instance. You must purchase and deploy an ApsaraMQ for Kafka instance before you can use the instance to send and receive messages.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <remarks>
/// <para> You can call this operation up to twice per second.</para>
/// </remarks>
/// </description>
///
/// <param name="request">
/// StartInstanceRequest
/// </param>
///
/// <returns>
/// StartInstanceResponse
/// </returns>
public StartInstanceResponse StartInstance(StartInstanceRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return StartInstanceWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Deploys an ApsaraMQ for Kafka instance. You must purchase and deploy an ApsaraMQ for Kafka instance before you can use the instance to send and receive messages.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <remarks>
/// <para> You can call this operation up to twice per second.</para>
/// </remarks>
/// </description>
///
/// <param name="request">
/// StartInstanceRequest
/// </param>
///
/// <returns>
/// StartInstanceResponse
/// </returns>
public async Task<StartInstanceResponse> StartInstanceAsync(StartInstanceRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await StartInstanceWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Stops an ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>You cannot stop a subscription ApsaraMQ for Kafka instance. If you want to stop a subscription ApsaraMQ for Kafka instance, submit a ticket.</para>
/// </description>
///
/// <param name="request">
/// StopInstanceRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// StopInstanceResponse
/// </returns>
public StopInstanceResponse StopInstanceWithOptions(StopInstanceRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "StopInstance",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<StopInstanceResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Stops an ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>You cannot stop a subscription ApsaraMQ for Kafka instance. If you want to stop a subscription ApsaraMQ for Kafka instance, submit a ticket.</para>
/// </description>
///
/// <param name="request">
/// StopInstanceRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// StopInstanceResponse
/// </returns>
public async Task<StopInstanceResponse> StopInstanceWithOptionsAsync(StopInstanceRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "StopInstance",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<StopInstanceResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Stops an ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>You cannot stop a subscription ApsaraMQ for Kafka instance. If you want to stop a subscription ApsaraMQ for Kafka instance, submit a ticket.</para>
/// </description>
///
/// <param name="request">
/// StopInstanceRequest
/// </param>
///
/// <returns>
/// StopInstanceResponse
/// </returns>
public StopInstanceResponse StopInstance(StopInstanceRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return StopInstanceWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Stops an ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>You cannot stop a subscription ApsaraMQ for Kafka instance. If you want to stop a subscription ApsaraMQ for Kafka instance, submit a ticket.</para>
/// </description>
///
/// <param name="request">
/// StopInstanceRequest
/// </param>
///
/// <returns>
/// StopInstanceResponse
/// </returns>
public async Task<StopInstanceResponse> StopInstanceAsync(StopInstanceRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await StopInstanceWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Attaches a tag to a resource.</para>
/// </summary>
///
/// <param name="request">
/// TagResourcesRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// TagResourcesResponse
/// </returns>
public TagResourcesResponse TagResourcesWithOptions(TagResourcesRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceId))
{
query["ResourceId"] = request.ResourceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceType))
{
query["ResourceType"] = request.ResourceType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "TagResources",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<TagResourcesResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Attaches a tag to a resource.</para>
/// </summary>
///
/// <param name="request">
/// TagResourcesRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// TagResourcesResponse
/// </returns>
public async Task<TagResourcesResponse> TagResourcesWithOptionsAsync(TagResourcesRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceId))
{
query["ResourceId"] = request.ResourceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceType))
{
query["ResourceType"] = request.ResourceType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Tag))
{
query["Tag"] = request.Tag;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "TagResources",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<TagResourcesResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Attaches a tag to a resource.</para>
/// </summary>
///
/// <param name="request">
/// TagResourcesRequest
/// </param>
///
/// <returns>
/// TagResourcesResponse
/// </returns>
public TagResourcesResponse TagResources(TagResourcesRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return TagResourcesWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Attaches a tag to a resource.</para>
/// </summary>
///
/// <param name="request">
/// TagResourcesRequest
/// </param>
///
/// <returns>
/// TagResourcesResponse
/// </returns>
public async Task<TagResourcesResponse> TagResourcesAsync(TagResourcesRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await TagResourcesWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Detaches tags from a specified resource.</para>
/// </summary>
///
/// <param name="request">
/// UntagResourcesRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// UntagResourcesResponse
/// </returns>
public UntagResourcesResponse UntagResourcesWithOptions(UntagResourcesRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.All))
{
query["All"] = request.All;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceId))
{
query["ResourceId"] = request.ResourceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceType))
{
query["ResourceType"] = request.ResourceType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.TagKey))
{
query["TagKey"] = request.TagKey;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "UntagResources",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<UntagResourcesResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Detaches tags from a specified resource.</para>
/// </summary>
///
/// <param name="request">
/// UntagResourcesRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// UntagResourcesResponse
/// </returns>
public async Task<UntagResourcesResponse> UntagResourcesWithOptionsAsync(UntagResourcesRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.All))
{
query["All"] = request.All;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceId))
{
query["ResourceId"] = request.ResourceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResourceType))
{
query["ResourceType"] = request.ResourceType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.TagKey))
{
query["TagKey"] = request.TagKey;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "UntagResources",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<UntagResourcesResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Detaches tags from a specified resource.</para>
/// </summary>
///
/// <param name="request">
/// UntagResourcesRequest
/// </param>
///
/// <returns>
/// UntagResourcesResponse
/// </returns>
public UntagResourcesResponse UntagResources(UntagResourcesRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return UntagResourcesWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Detaches tags from a specified resource.</para>
/// </summary>
///
/// <param name="request">
/// UntagResourcesRequest
/// </param>
///
/// <returns>
/// UntagResourcesResponse
/// </returns>
public async Task<UntagResourcesResponse> UntagResourcesAsync(UntagResourcesRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await UntagResourcesWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Updates the IP address whitelist of an ApsaraMQ for Kafka instance. Only IP addresses and ports that are configured in the IP address whitelist of an instance can access the instance.</para>
/// </summary>
///
/// <param name="request">
/// UpdateAllowedIpRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// UpdateAllowedIpResponse
/// </returns>
public UpdateAllowedIpResponse UpdateAllowedIpWithOptions(UpdateAllowedIpRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AllowedListIp))
{
query["AllowedListIp"] = request.AllowedListIp;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AllowedListType))
{
query["AllowedListType"] = request.AllowedListType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Description))
{
query["Description"] = request.Description;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PortRange))
{
query["PortRange"] = request.PortRange;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.UpdateType))
{
query["UpdateType"] = request.UpdateType;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "UpdateAllowedIp",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<UpdateAllowedIpResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Updates the IP address whitelist of an ApsaraMQ for Kafka instance. Only IP addresses and ports that are configured in the IP address whitelist of an instance can access the instance.</para>
/// </summary>
///
/// <param name="request">
/// UpdateAllowedIpRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// UpdateAllowedIpResponse
/// </returns>
public async Task<UpdateAllowedIpResponse> UpdateAllowedIpWithOptionsAsync(UpdateAllowedIpRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AllowedListIp))
{
query["AllowedListIp"] = request.AllowedListIp;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.AllowedListType))
{
query["AllowedListType"] = request.AllowedListType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Description))
{
query["Description"] = request.Description;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PortRange))
{
query["PortRange"] = request.PortRange;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.UpdateType))
{
query["UpdateType"] = request.UpdateType;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "UpdateAllowedIp",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<UpdateAllowedIpResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Updates the IP address whitelist of an ApsaraMQ for Kafka instance. Only IP addresses and ports that are configured in the IP address whitelist of an instance can access the instance.</para>
/// </summary>
///
/// <param name="request">
/// UpdateAllowedIpRequest
/// </param>
///
/// <returns>
/// UpdateAllowedIpResponse
/// </returns>
public UpdateAllowedIpResponse UpdateAllowedIp(UpdateAllowedIpRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return UpdateAllowedIpWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Updates the IP address whitelist of an ApsaraMQ for Kafka instance. Only IP addresses and ports that are configured in the IP address whitelist of an instance can access the instance.</para>
/// </summary>
///
/// <param name="request">
/// UpdateAllowedIpRequest
/// </param>
///
/// <returns>
/// UpdateAllowedIpResponse
/// </returns>
public async Task<UpdateAllowedIpResponse> UpdateAllowedIpAsync(UpdateAllowedIpRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await UpdateAllowedIpWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Resets the consumer offsets of the subscribed topics of a consumer group.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>You can call this operation to reset the consumer offset of a specific consumer group. You can use the timestamp or offset parameter to reset the consumer offset of a consumer group. You can implement the following features by configuring a combination of different parameters:</para>
/// <list type="bullet">
/// <item><description>Reset the consumer offsets of one or all subscribed topics of a consumer group to the latest offset. This way, you can consume messages in the topics from the latest offset.</description></item>
/// <item><description>Reset the consumer offsets of one or all subscribed topics of a consumer group to a specific point in time. This way, you can consume messages in the topics from the specified point in time.</description></item>
/// <item><description>Reset the consumer offset of one subscribed topic of a consumer group to a specific offset in a specific partition. This way, you can consume messages from the specified offset in the specified partition.</description></item>
/// </list>
/// </description>
///
/// <param name="tmpReq">
/// UpdateConsumerOffsetRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// UpdateConsumerOffsetResponse
/// </returns>
public UpdateConsumerOffsetResponse UpdateConsumerOffsetWithOptions(UpdateConsumerOffsetRequest tmpReq, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(tmpReq);
UpdateConsumerOffsetShrinkRequest request = new UpdateConsumerOffsetShrinkRequest();
AlibabaCloud.OpenApiUtil.Client.Convert(tmpReq, request);
if (!AlibabaCloud.TeaUtil.Common.IsUnset(tmpReq.Offsets))
{
request.OffsetsShrink = AlibabaCloud.OpenApiUtil.Client.ArrayToStringWithSpecifiedStyle(tmpReq.Offsets, "Offsets", "json");
}
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ConsumerId))
{
query["ConsumerId"] = request.ConsumerId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.OffsetsShrink))
{
query["Offsets"] = request.OffsetsShrink;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResetType))
{
query["ResetType"] = request.ResetType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Time))
{
query["Time"] = request.Time;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "UpdateConsumerOffset",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<UpdateConsumerOffsetResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Resets the consumer offsets of the subscribed topics of a consumer group.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>You can call this operation to reset the consumer offset of a specific consumer group. You can use the timestamp or offset parameter to reset the consumer offset of a consumer group. You can implement the following features by configuring a combination of different parameters:</para>
/// <list type="bullet">
/// <item><description>Reset the consumer offsets of one or all subscribed topics of a consumer group to the latest offset. This way, you can consume messages in the topics from the latest offset.</description></item>
/// <item><description>Reset the consumer offsets of one or all subscribed topics of a consumer group to a specific point in time. This way, you can consume messages in the topics from the specified point in time.</description></item>
/// <item><description>Reset the consumer offset of one subscribed topic of a consumer group to a specific offset in a specific partition. This way, you can consume messages from the specified offset in the specified partition.</description></item>
/// </list>
/// </description>
///
/// <param name="tmpReq">
/// UpdateConsumerOffsetRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// UpdateConsumerOffsetResponse
/// </returns>
public async Task<UpdateConsumerOffsetResponse> UpdateConsumerOffsetWithOptionsAsync(UpdateConsumerOffsetRequest tmpReq, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(tmpReq);
UpdateConsumerOffsetShrinkRequest request = new UpdateConsumerOffsetShrinkRequest();
AlibabaCloud.OpenApiUtil.Client.Convert(tmpReq, request);
if (!AlibabaCloud.TeaUtil.Common.IsUnset(tmpReq.Offsets))
{
request.OffsetsShrink = AlibabaCloud.OpenApiUtil.Client.ArrayToStringWithSpecifiedStyle(tmpReq.Offsets, "Offsets", "json");
}
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ConsumerId))
{
query["ConsumerId"] = request.ConsumerId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.OffsetsShrink))
{
query["Offsets"] = request.OffsetsShrink;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ResetType))
{
query["ResetType"] = request.ResetType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Time))
{
query["Time"] = request.Time;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "UpdateConsumerOffset",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<UpdateConsumerOffsetResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Resets the consumer offsets of the subscribed topics of a consumer group.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>You can call this operation to reset the consumer offset of a specific consumer group. You can use the timestamp or offset parameter to reset the consumer offset of a consumer group. You can implement the following features by configuring a combination of different parameters:</para>
/// <list type="bullet">
/// <item><description>Reset the consumer offsets of one or all subscribed topics of a consumer group to the latest offset. This way, you can consume messages in the topics from the latest offset.</description></item>
/// <item><description>Reset the consumer offsets of one or all subscribed topics of a consumer group to a specific point in time. This way, you can consume messages in the topics from the specified point in time.</description></item>
/// <item><description>Reset the consumer offset of one subscribed topic of a consumer group to a specific offset in a specific partition. This way, you can consume messages from the specified offset in the specified partition.</description></item>
/// </list>
/// </description>
///
/// <param name="request">
/// UpdateConsumerOffsetRequest
/// </param>
///
/// <returns>
/// UpdateConsumerOffsetResponse
/// </returns>
public UpdateConsumerOffsetResponse UpdateConsumerOffset(UpdateConsumerOffsetRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return UpdateConsumerOffsetWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Resets the consumer offsets of the subscribed topics of a consumer group.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>You can call this operation to reset the consumer offset of a specific consumer group. You can use the timestamp or offset parameter to reset the consumer offset of a consumer group. You can implement the following features by configuring a combination of different parameters:</para>
/// <list type="bullet">
/// <item><description>Reset the consumer offsets of one or all subscribed topics of a consumer group to the latest offset. This way, you can consume messages in the topics from the latest offset.</description></item>
/// <item><description>Reset the consumer offsets of one or all subscribed topics of a consumer group to a specific point in time. This way, you can consume messages in the topics from the specified point in time.</description></item>
/// <item><description>Reset the consumer offset of one subscribed topic of a consumer group to a specific offset in a specific partition. This way, you can consume messages from the specified offset in the specified partition.</description></item>
/// </list>
/// </description>
///
/// <param name="request">
/// UpdateConsumerOffsetRequest
/// </param>
///
/// <returns>
/// UpdateConsumerOffsetResponse
/// </returns>
public async Task<UpdateConsumerOffsetResponse> UpdateConsumerOffsetAsync(UpdateConsumerOffsetRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await UpdateConsumerOffsetWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Modifies the configurations of an ApsaraMQ for Kafka instance. ApsaraMQ for Kafka allows you to modify the configurations of an instance, including the access control list (ACL) feature, the Secure Sockets Layer (SSL) feature, the message retention period, and the maximum message size.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h2><b>Permissions</b></h2>
/// <para>If a RAM user wants to call the <b>UpdateInstanceConfig</b> operation, the RAM user must be granted the required permissions. For more information about how to grant permissions, see <a href="https://help.aliyun.com/document_detail/185815.html">RAM policies</a>.</para>
/// <table>
/// <thead>
/// <tr>
/// <th>API</th>
/// <th>Action</th>
/// <th>Resource</th>
/// </tr>
/// </thead>
/// <tbody><tr>
/// <td>UpdateInstanceConfig</td>
/// <td>alikafka: UpdateInstance</td>
/// <td>acs:alikafka:<em>:</em>:{instanceId}</td>
/// </tr>
/// </tbody></table>
/// </description>
///
/// <param name="request">
/// UpdateInstanceConfigRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// UpdateInstanceConfigResponse
/// </returns>
public UpdateInstanceConfigResponse UpdateInstanceConfigWithOptions(UpdateInstanceConfigRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Config))
{
query["Config"] = request.Config;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "UpdateInstanceConfig",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<UpdateInstanceConfigResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Modifies the configurations of an ApsaraMQ for Kafka instance. ApsaraMQ for Kafka allows you to modify the configurations of an instance, including the access control list (ACL) feature, the Secure Sockets Layer (SSL) feature, the message retention period, and the maximum message size.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h2><b>Permissions</b></h2>
/// <para>If a RAM user wants to call the <b>UpdateInstanceConfig</b> operation, the RAM user must be granted the required permissions. For more information about how to grant permissions, see <a href="https://help.aliyun.com/document_detail/185815.html">RAM policies</a>.</para>
/// <table>
/// <thead>
/// <tr>
/// <th>API</th>
/// <th>Action</th>
/// <th>Resource</th>
/// </tr>
/// </thead>
/// <tbody><tr>
/// <td>UpdateInstanceConfig</td>
/// <td>alikafka: UpdateInstance</td>
/// <td>acs:alikafka:<em>:</em>:{instanceId}</td>
/// </tr>
/// </tbody></table>
/// </description>
///
/// <param name="request">
/// UpdateInstanceConfigRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// UpdateInstanceConfigResponse
/// </returns>
public async Task<UpdateInstanceConfigResponse> UpdateInstanceConfigWithOptionsAsync(UpdateInstanceConfigRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Config))
{
query["Config"] = request.Config;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "UpdateInstanceConfig",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<UpdateInstanceConfigResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Modifies the configurations of an ApsaraMQ for Kafka instance. ApsaraMQ for Kafka allows you to modify the configurations of an instance, including the access control list (ACL) feature, the Secure Sockets Layer (SSL) feature, the message retention period, and the maximum message size.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h2><b>Permissions</b></h2>
/// <para>If a RAM user wants to call the <b>UpdateInstanceConfig</b> operation, the RAM user must be granted the required permissions. For more information about how to grant permissions, see <a href="https://help.aliyun.com/document_detail/185815.html">RAM policies</a>.</para>
/// <table>
/// <thead>
/// <tr>
/// <th>API</th>
/// <th>Action</th>
/// <th>Resource</th>
/// </tr>
/// </thead>
/// <tbody><tr>
/// <td>UpdateInstanceConfig</td>
/// <td>alikafka: UpdateInstance</td>
/// <td>acs:alikafka:<em>:</em>:{instanceId}</td>
/// </tr>
/// </tbody></table>
/// </description>
///
/// <param name="request">
/// UpdateInstanceConfigRequest
/// </param>
///
/// <returns>
/// UpdateInstanceConfigResponse
/// </returns>
public UpdateInstanceConfigResponse UpdateInstanceConfig(UpdateInstanceConfigRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return UpdateInstanceConfigWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Modifies the configurations of an ApsaraMQ for Kafka instance. ApsaraMQ for Kafka allows you to modify the configurations of an instance, including the access control list (ACL) feature, the Secure Sockets Layer (SSL) feature, the message retention period, and the maximum message size.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h2><b>Permissions</b></h2>
/// <para>If a RAM user wants to call the <b>UpdateInstanceConfig</b> operation, the RAM user must be granted the required permissions. For more information about how to grant permissions, see <a href="https://help.aliyun.com/document_detail/185815.html">RAM policies</a>.</para>
/// <table>
/// <thead>
/// <tr>
/// <th>API</th>
/// <th>Action</th>
/// <th>Resource</th>
/// </tr>
/// </thead>
/// <tbody><tr>
/// <td>UpdateInstanceConfig</td>
/// <td>alikafka: UpdateInstance</td>
/// <td>acs:alikafka:<em>:</em>:{instanceId}</td>
/// </tr>
/// </tbody></table>
/// </description>
///
/// <param name="request">
/// UpdateInstanceConfigRequest
/// </param>
///
/// <returns>
/// UpdateInstanceConfigResponse
/// </returns>
public async Task<UpdateInstanceConfigResponse> UpdateInstanceConfigAsync(UpdateInstanceConfigRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await UpdateInstanceConfigWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Modifies the configurations of a topic. After you create a topic, you can modify the message retention period and maximum message size of the topic.</para>
/// </summary>
///
/// <param name="request">
/// UpdateTopicConfigRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// UpdateTopicConfigResponse
/// </returns>
public UpdateTopicConfigResponse UpdateTopicConfigWithOptions(UpdateTopicConfigRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Config))
{
query["Config"] = request.Config;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Value))
{
query["Value"] = request.Value;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "UpdateTopicConfig",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<UpdateTopicConfigResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Modifies the configurations of a topic. After you create a topic, you can modify the message retention period and maximum message size of the topic.</para>
/// </summary>
///
/// <param name="request">
/// UpdateTopicConfigRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// UpdateTopicConfigResponse
/// </returns>
public async Task<UpdateTopicConfigResponse> UpdateTopicConfigWithOptionsAsync(UpdateTopicConfigRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Config))
{
query["Config"] = request.Config;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Topic))
{
query["Topic"] = request.Topic;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.Value))
{
query["Value"] = request.Value;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "UpdateTopicConfig",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<UpdateTopicConfigResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Modifies the configurations of a topic. After you create a topic, you can modify the message retention period and maximum message size of the topic.</para>
/// </summary>
///
/// <param name="request">
/// UpdateTopicConfigRequest
/// </param>
///
/// <returns>
/// UpdateTopicConfigResponse
/// </returns>
public UpdateTopicConfigResponse UpdateTopicConfig(UpdateTopicConfigRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return UpdateTopicConfigWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Modifies the configurations of a topic. After you create a topic, you can modify the message retention period and maximum message size of the topic.</para>
/// </summary>
///
/// <param name="request">
/// UpdateTopicConfigRequest
/// </param>
///
/// <returns>
/// UpdateTopicConfigResponse
/// </returns>
public async Task<UpdateTopicConfigResponse> UpdateTopicConfigAsync(UpdateTopicConfigRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await UpdateTopicConfigWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Updates the version of an instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h2><b>Permissions</b></h2>
/// <para>A RAM user must be granted the required permissions before the RAM user calls the <b>UpgradeInstanceVersion</b> operation. For information about how to grant permissions, see <a href="https://help.aliyun.com/document_detail/185815.html">RAM policies</a>.</para>
/// <table>
/// <thead>
/// <tr>
/// <th>API</th>
/// <th>Action</th>
/// <th>Resource</th>
/// </tr>
/// </thead>
/// <tbody><tr>
/// <td>UpgradeInstanceVersion</td>
/// <td>UpdateInstance</td>
/// <td>acs:alikafka:<em>:</em>:{instanceId}</td>
/// </tr>
/// </tbody></table>
/// <h2><b>QPS limits</b></h2>
/// <para>You can send a maximum of two queries per second (QPS).</para>
/// </description>
///
/// <param name="request">
/// UpgradeInstanceVersionRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// UpgradeInstanceVersionResponse
/// </returns>
public UpgradeInstanceVersionResponse UpgradeInstanceVersionWithOptions(UpgradeInstanceVersionRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.TargetVersion))
{
query["TargetVersion"] = request.TargetVersion;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "UpgradeInstanceVersion",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<UpgradeInstanceVersionResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Updates the version of an instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h2><b>Permissions</b></h2>
/// <para>A RAM user must be granted the required permissions before the RAM user calls the <b>UpgradeInstanceVersion</b> operation. For information about how to grant permissions, see <a href="https://help.aliyun.com/document_detail/185815.html">RAM policies</a>.</para>
/// <table>
/// <thead>
/// <tr>
/// <th>API</th>
/// <th>Action</th>
/// <th>Resource</th>
/// </tr>
/// </thead>
/// <tbody><tr>
/// <td>UpgradeInstanceVersion</td>
/// <td>UpdateInstance</td>
/// <td>acs:alikafka:<em>:</em>:{instanceId}</td>
/// </tr>
/// </tbody></table>
/// <h2><b>QPS limits</b></h2>
/// <para>You can send a maximum of two queries per second (QPS).</para>
/// </description>
///
/// <param name="request">
/// UpgradeInstanceVersionRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// UpgradeInstanceVersionResponse
/// </returns>
public async Task<UpgradeInstanceVersionResponse> UpgradeInstanceVersionWithOptionsAsync(UpgradeInstanceVersionRequest request, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(request);
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.TargetVersion))
{
query["TargetVersion"] = request.TargetVersion;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "UpgradeInstanceVersion",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<UpgradeInstanceVersionResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Updates the version of an instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h2><b>Permissions</b></h2>
/// <para>A RAM user must be granted the required permissions before the RAM user calls the <b>UpgradeInstanceVersion</b> operation. For information about how to grant permissions, see <a href="https://help.aliyun.com/document_detail/185815.html">RAM policies</a>.</para>
/// <table>
/// <thead>
/// <tr>
/// <th>API</th>
/// <th>Action</th>
/// <th>Resource</th>
/// </tr>
/// </thead>
/// <tbody><tr>
/// <td>UpgradeInstanceVersion</td>
/// <td>UpdateInstance</td>
/// <td>acs:alikafka:<em>:</em>:{instanceId}</td>
/// </tr>
/// </tbody></table>
/// <h2><b>QPS limits</b></h2>
/// <para>You can send a maximum of two queries per second (QPS).</para>
/// </description>
///
/// <param name="request">
/// UpgradeInstanceVersionRequest
/// </param>
///
/// <returns>
/// UpgradeInstanceVersionResponse
/// </returns>
public UpgradeInstanceVersionResponse UpgradeInstanceVersion(UpgradeInstanceVersionRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return UpgradeInstanceVersionWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Updates the version of an instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <h2><b>Permissions</b></h2>
/// <para>A RAM user must be granted the required permissions before the RAM user calls the <b>UpgradeInstanceVersion</b> operation. For information about how to grant permissions, see <a href="https://help.aliyun.com/document_detail/185815.html">RAM policies</a>.</para>
/// <table>
/// <thead>
/// <tr>
/// <th>API</th>
/// <th>Action</th>
/// <th>Resource</th>
/// </tr>
/// </thead>
/// <tbody><tr>
/// <td>UpgradeInstanceVersion</td>
/// <td>UpdateInstance</td>
/// <td>acs:alikafka:<em>:</em>:{instanceId}</td>
/// </tr>
/// </tbody></table>
/// <h2><b>QPS limits</b></h2>
/// <para>You can send a maximum of two queries per second (QPS).</para>
/// </description>
///
/// <param name="request">
/// UpgradeInstanceVersionRequest
/// </param>
///
/// <returns>
/// UpgradeInstanceVersionResponse
/// </returns>
public async Task<UpgradeInstanceVersionResponse> UpgradeInstanceVersionAsync(UpgradeInstanceVersionRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await UpgradeInstanceVersionWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Upgrades a pay-as-you-go ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>Before you call this operation, make sure that you understand the billing method and pricing of pay-as-you-go Message Queue for Apache Kafka instances. For more information, see <a href="https://help.aliyun.com/document_detail/84737.html">Billing</a>.</para>
/// </description>
///
/// <param name="tmpReq">
/// UpgradePostPayOrderRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// UpgradePostPayOrderResponse
/// </returns>
public UpgradePostPayOrderResponse UpgradePostPayOrderWithOptions(UpgradePostPayOrderRequest tmpReq, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(tmpReq);
UpgradePostPayOrderShrinkRequest request = new UpgradePostPayOrderShrinkRequest();
AlibabaCloud.OpenApiUtil.Client.Convert(tmpReq, request);
if (!AlibabaCloud.TeaUtil.Common.IsUnset(tmpReq.ServerlessConfig))
{
request.ServerlessConfigShrink = AlibabaCloud.OpenApiUtil.Client.ArrayToStringWithSpecifiedStyle(tmpReq.ServerlessConfig, "ServerlessConfig", "json");
}
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskSize))
{
query["DiskSize"] = request.DiskSize;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EipMax))
{
query["EipMax"] = request.EipMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EipModel))
{
query["EipModel"] = request.EipModel;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMax))
{
query["IoMax"] = request.IoMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMaxSpec))
{
query["IoMaxSpec"] = request.IoMaxSpec;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PartitionNum))
{
query["PartitionNum"] = request.PartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ServerlessConfigShrink))
{
query["ServerlessConfig"] = request.ServerlessConfigShrink;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.SpecType))
{
query["SpecType"] = request.SpecType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.TopicQuota))
{
query["TopicQuota"] = request.TopicQuota;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "UpgradePostPayOrder",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<UpgradePostPayOrderResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Upgrades a pay-as-you-go ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>Before you call this operation, make sure that you understand the billing method and pricing of pay-as-you-go Message Queue for Apache Kafka instances. For more information, see <a href="https://help.aliyun.com/document_detail/84737.html">Billing</a>.</para>
/// </description>
///
/// <param name="tmpReq">
/// UpgradePostPayOrderRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// UpgradePostPayOrderResponse
/// </returns>
public async Task<UpgradePostPayOrderResponse> UpgradePostPayOrderWithOptionsAsync(UpgradePostPayOrderRequest tmpReq, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(tmpReq);
UpgradePostPayOrderShrinkRequest request = new UpgradePostPayOrderShrinkRequest();
AlibabaCloud.OpenApiUtil.Client.Convert(tmpReq, request);
if (!AlibabaCloud.TeaUtil.Common.IsUnset(tmpReq.ServerlessConfig))
{
request.ServerlessConfigShrink = AlibabaCloud.OpenApiUtil.Client.ArrayToStringWithSpecifiedStyle(tmpReq.ServerlessConfig, "ServerlessConfig", "json");
}
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskSize))
{
query["DiskSize"] = request.DiskSize;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EipMax))
{
query["EipMax"] = request.EipMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EipModel))
{
query["EipModel"] = request.EipModel;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMax))
{
query["IoMax"] = request.IoMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMaxSpec))
{
query["IoMaxSpec"] = request.IoMaxSpec;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PartitionNum))
{
query["PartitionNum"] = request.PartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ServerlessConfigShrink))
{
query["ServerlessConfig"] = request.ServerlessConfigShrink;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.SpecType))
{
query["SpecType"] = request.SpecType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.TopicQuota))
{
query["TopicQuota"] = request.TopicQuota;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "UpgradePostPayOrder",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<UpgradePostPayOrderResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Upgrades a pay-as-you-go ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>Before you call this operation, make sure that you understand the billing method and pricing of pay-as-you-go Message Queue for Apache Kafka instances. For more information, see <a href="https://help.aliyun.com/document_detail/84737.html">Billing</a>.</para>
/// </description>
///
/// <param name="request">
/// UpgradePostPayOrderRequest
/// </param>
///
/// <returns>
/// UpgradePostPayOrderResponse
/// </returns>
public UpgradePostPayOrderResponse UpgradePostPayOrder(UpgradePostPayOrderRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return UpgradePostPayOrderWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Upgrades a pay-as-you-go ApsaraMQ for Kafka instance.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>Before you call this operation, make sure that you understand the billing method and pricing of pay-as-you-go Message Queue for Apache Kafka instances. For more information, see <a href="https://help.aliyun.com/document_detail/84737.html">Billing</a>.</para>
/// </description>
///
/// <param name="request">
/// UpgradePostPayOrderRequest
/// </param>
///
/// <returns>
/// UpgradePostPayOrderResponse
/// </returns>
public async Task<UpgradePostPayOrderResponse> UpgradePostPayOrderAsync(UpgradePostPayOrderRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await UpgradePostPayOrderWithOptionsAsync(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Upgrades a Message Queue for Apache Kafka instance that uses the subscription billing method.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>Before you call this operation, make sure that you understand the billing method and pricing of subscription Message Queue for Apache Kafka instances. For more information, see <a href="https://help.aliyun.com/document_detail/84737.html">Billing overview</a>.</para>
/// </description>
///
/// <param name="tmpReq">
/// UpgradePrePayOrderRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// UpgradePrePayOrderResponse
/// </returns>
public UpgradePrePayOrderResponse UpgradePrePayOrderWithOptions(UpgradePrePayOrderRequest tmpReq, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(tmpReq);
UpgradePrePayOrderShrinkRequest request = new UpgradePrePayOrderShrinkRequest();
AlibabaCloud.OpenApiUtil.Client.Convert(tmpReq, request);
if (!AlibabaCloud.TeaUtil.Common.IsUnset(tmpReq.ConfluentConfig))
{
request.ConfluentConfigShrink = AlibabaCloud.OpenApiUtil.Client.ArrayToStringWithSpecifiedStyle(tmpReq.ConfluentConfig, "ConfluentConfig", "json");
}
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ConfluentConfigShrink))
{
query["ConfluentConfig"] = request.ConfluentConfigShrink;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskSize))
{
query["DiskSize"] = request.DiskSize;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EipMax))
{
query["EipMax"] = request.EipMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EipModel))
{
query["EipModel"] = request.EipModel;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMax))
{
query["IoMax"] = request.IoMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMaxSpec))
{
query["IoMaxSpec"] = request.IoMaxSpec;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PaidType))
{
query["PaidType"] = request.PaidType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PartitionNum))
{
query["PartitionNum"] = request.PartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.SpecType))
{
query["SpecType"] = request.SpecType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.TopicQuota))
{
query["TopicQuota"] = request.TopicQuota;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "UpgradePrePayOrder",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<UpgradePrePayOrderResponse>(CallApi(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Upgrades a Message Queue for Apache Kafka instance that uses the subscription billing method.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>Before you call this operation, make sure that you understand the billing method and pricing of subscription Message Queue for Apache Kafka instances. For more information, see <a href="https://help.aliyun.com/document_detail/84737.html">Billing overview</a>.</para>
/// </description>
///
/// <param name="tmpReq">
/// UpgradePrePayOrderRequest
/// </param>
/// <param name="runtime">
/// runtime options for this request RuntimeOptions
/// </param>
///
/// <returns>
/// UpgradePrePayOrderResponse
/// </returns>
public async Task<UpgradePrePayOrderResponse> UpgradePrePayOrderWithOptionsAsync(UpgradePrePayOrderRequest tmpReq, AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime)
{
AlibabaCloud.TeaUtil.Common.ValidateModel(tmpReq);
UpgradePrePayOrderShrinkRequest request = new UpgradePrePayOrderShrinkRequest();
AlibabaCloud.OpenApiUtil.Client.Convert(tmpReq, request);
if (!AlibabaCloud.TeaUtil.Common.IsUnset(tmpReq.ConfluentConfig))
{
request.ConfluentConfigShrink = AlibabaCloud.OpenApiUtil.Client.ArrayToStringWithSpecifiedStyle(tmpReq.ConfluentConfig, "ConfluentConfig", "json");
}
Dictionary<string, object> query = new Dictionary<string, object>(){};
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.ConfluentConfigShrink))
{
query["ConfluentConfig"] = request.ConfluentConfigShrink;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.DiskSize))
{
query["DiskSize"] = request.DiskSize;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EipMax))
{
query["EipMax"] = request.EipMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.EipModel))
{
query["EipModel"] = request.EipModel;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.InstanceId))
{
query["InstanceId"] = request.InstanceId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMax))
{
query["IoMax"] = request.IoMax;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.IoMaxSpec))
{
query["IoMaxSpec"] = request.IoMaxSpec;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PaidType))
{
query["PaidType"] = request.PaidType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.PartitionNum))
{
query["PartitionNum"] = request.PartitionNum;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.RegionId))
{
query["RegionId"] = request.RegionId;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.SpecType))
{
query["SpecType"] = request.SpecType;
}
if (!AlibabaCloud.TeaUtil.Common.IsUnset(request.TopicQuota))
{
query["TopicQuota"] = request.TopicQuota;
}
AlibabaCloud.OpenApiClient.Models.OpenApiRequest req = new AlibabaCloud.OpenApiClient.Models.OpenApiRequest
{
Query = AlibabaCloud.OpenApiUtil.Client.Query(query),
};
AlibabaCloud.OpenApiClient.Models.Params params_ = new AlibabaCloud.OpenApiClient.Models.Params
{
Action = "UpgradePrePayOrder",
Version = "2019-09-16",
Protocol = "HTTPS",
Pathname = "/",
Method = "POST",
AuthType = "AK",
Style = "RPC",
ReqBodyType = "formData",
BodyType = "json",
};
return TeaModel.ToObject<UpgradePrePayOrderResponse>(await CallApiAsync(params_, req, runtime));
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Upgrades a Message Queue for Apache Kafka instance that uses the subscription billing method.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>Before you call this operation, make sure that you understand the billing method and pricing of subscription Message Queue for Apache Kafka instances. For more information, see <a href="https://help.aliyun.com/document_detail/84737.html">Billing overview</a>.</para>
/// </description>
///
/// <param name="request">
/// UpgradePrePayOrderRequest
/// </param>
///
/// <returns>
/// UpgradePrePayOrderResponse
/// </returns>
public UpgradePrePayOrderResponse UpgradePrePayOrder(UpgradePrePayOrderRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return UpgradePrePayOrderWithOptions(request, runtime);
}
/// <term><b>Summary:</b></term>
/// <summary>
/// <para>Upgrades a Message Queue for Apache Kafka instance that uses the subscription billing method.</para>
/// </summary>
///
/// <term><b>Description:</b></term>
/// <description>
/// <para>Before you call this operation, make sure that you understand the billing method and pricing of subscription Message Queue for Apache Kafka instances. For more information, see <a href="https://help.aliyun.com/document_detail/84737.html">Billing overview</a>.</para>
/// </description>
///
/// <param name="request">
/// UpgradePrePayOrderRequest
/// </param>
///
/// <returns>
/// UpgradePrePayOrderResponse
/// </returns>
public async Task<UpgradePrePayOrderResponse> UpgradePrePayOrderAsync(UpgradePrePayOrderRequest request)
{
AlibabaCloud.TeaUtil.Models.RuntimeOptions runtime = new AlibabaCloud.TeaUtil.Models.RuntimeOptions();
return await UpgradePrePayOrderWithOptionsAsync(request, runtime);
}
}
}