Versions in this module Expand all Collapse all v1 v1.2.0 Sep 26, 2025 Changes in this version + const EndpointName + type Apis struct + CtgkafkaAclAddV3Api *CtgkafkaAclAddV3Api + CtgkafkaAclDeleteV3Api *CtgkafkaAclDeleteV3Api + CtgkafkaAclQueryV3Api *CtgkafkaAclQueryV3Api + CtgkafkaAddAuthorityApi *CtgkafkaAddAuthorityApi + CtgkafkaBeginningMessageApi *CtgkafkaBeginningMessageApi + CtgkafkaBindElasticIpApi *CtgkafkaBindElasticIpApi + CtgkafkaCanExpandProdApi *CtgkafkaCanExpandProdApi + CtgkafkaChangeAzApi *CtgkafkaChangeAzApi + CtgkafkaChaosCancelApi *CtgkafkaChaosCancelApi + CtgkafkaChaosInjectApi *CtgkafkaChaosInjectApi + CtgkafkaChaosListApi *CtgkafkaChaosListApi + CtgkafkaChaosQueryReqMsgApi *CtgkafkaChaosQueryReqMsgApi + CtgkafkaConsumerGroupBatchDeleteApi *CtgkafkaConsumerGroupBatchDeleteApi + CtgkafkaConsumerGroupCreateV3Api *CtgkafkaConsumerGroupCreateV3Api + CtgkafkaConsumerGroupDeleteV3Api *CtgkafkaConsumerGroupDeleteV3Api + CtgkafkaConsumerGroupInstancesV3Api *CtgkafkaConsumerGroupInstancesV3Api + CtgkafkaConsumerGroupQueryV3Api *CtgkafkaConsumerGroupQueryV3Api + CtgkafkaConsumerGroupResetV3Api *CtgkafkaConsumerGroupResetV3Api + CtgkafkaConsumerGroupStatusV3Api *CtgkafkaConsumerGroupStatusV3Api + CtgkafkaConsumerGroupUpdateApi *CtgkafkaConsumerGroupUpdateApi + CtgkafkaConsumerGroupUpdatetopicsV3Api *CtgkafkaConsumerGroupUpdatetopicsV3Api + CtgkafkaCreateOrderApi *CtgkafkaCreateOrderApi + CtgkafkaCreatePostPayOrderApi *CtgkafkaCreatePostPayOrderApi + CtgkafkaDeleteAuthorityApi *CtgkafkaDeleteAuthorityApi + CtgkafkaDiskExtendApi *CtgkafkaDiskExtendApi + CtgkafkaDiskShrinkApi *CtgkafkaDiskShrinkApi + CtgkafkaElasticBandwidthApi *CtgkafkaElasticBandwidthApi + CtgkafkaEnableAutoReassignApi *CtgkafkaEnableAutoReassignApi + CtgkafkaEndMessageApi *CtgkafkaEndMessageApi + CtgkafkaGetAuthorityApi *CtgkafkaGetAuthorityApi + CtgkafkaGetInstanceConfigApi *CtgkafkaGetInstanceConfigApi + CtgkafkaGetTopicDetailsApi *CtgkafkaGetTopicDetailsApi + CtgkafkaInstQueryApi *CtgkafkaInstQueryApi + CtgkafkaInstanceDeleteV3Api *CtgkafkaInstanceDeleteV3Api + CtgkafkaInstancesModifyNameV3Api *CtgkafkaInstancesModifyNameV3Api + CtgkafkaInstancesRestartV3Api *CtgkafkaInstancesRestartV3Api + CtgkafkaListResourceV3Api *CtgkafkaListResourceV3Api + CtgkafkaListTagV3Api *CtgkafkaListTagV3Api + CtgkafkaMirrorTaskApi *CtgkafkaMirrorTaskApi + CtgkafkaModifyInstanceConfigApi *CtgkafkaModifyInstanceConfigApi + CtgkafkaModifypartitionNumV3Api *CtgkafkaModifypartitionNumV3Api + CtgkafkaMonitorMetricsV3Api *CtgkafkaMonitorMetricsV3Api + CtgkafkaNodeExtendApi *CtgkafkaNodeExtendApi + CtgkafkaNodeShrinkApi *CtgkafkaNodeShrinkApi + CtgkafkaNodeStatusV3Api *CtgkafkaNodeStatusV3Api + CtgkafkaPageQueryFloatingipsApi *CtgkafkaPageQueryFloatingipsApi + CtgkafkaProdDetailApi *CtgkafkaProdDetailApi + CtgkafkaProduceApi *CtgkafkaProduceApi + CtgkafkaQueryCanUpdateVersionV3Api *CtgkafkaQueryCanUpdateVersionV3Api + CtgkafkaQueryMessageApi *CtgkafkaQueryMessageApi + CtgkafkaQueryMessageByOffsetV3Api *CtgkafkaQueryMessageByOffsetV3Api + CtgkafkaQueryMessageByTimestampV3Api *CtgkafkaQueryMessageByTimestampV3Api + CtgkafkaQueryProducersApi *CtgkafkaQueryProducersApi + CtgkafkaQuotaBrokerCreateApi *CtgkafkaQuotaBrokerCreateApi + CtgkafkaQuotaBrokerDeleteApi *CtgkafkaQuotaBrokerDeleteApi + CtgkafkaQuotaBrokerQueryApi *CtgkafkaQuotaBrokerQueryApi + CtgkafkaQuotaBrokerUpdateApi *CtgkafkaQuotaBrokerUpdateApi + CtgkafkaQuotaClientCreateApi *CtgkafkaQuotaClientCreateApi + CtgkafkaQuotaClientDeleteApi *CtgkafkaQuotaClientDeleteApi + CtgkafkaQuotaClientListApi *CtgkafkaQuotaClientListApi + CtgkafkaQuotaClientUpdateApi *CtgkafkaQuotaClientUpdateApi + CtgkafkaQuotaTopicCreateApi *CtgkafkaQuotaTopicCreateApi + CtgkafkaQuotaTopicDeleteApi *CtgkafkaQuotaTopicDeleteApi + CtgkafkaQuotaTopicListApi *CtgkafkaQuotaTopicListApi + CtgkafkaQuotaTopicUpdateApi *CtgkafkaQuotaTopicUpdateApi + CtgkafkaReassignmentsApi *CtgkafkaReassignmentsApi + CtgkafkaResourceTagAddtagV3Api *CtgkafkaResourceTagAddtagV3Api + CtgkafkaSaslUserCreateV3Api *CtgkafkaSaslUserCreateV3Api + CtgkafkaSaslUserDeleteV3Api *CtgkafkaSaslUserDeleteV3Api + CtgkafkaSaslUserQueryV3Api *CtgkafkaSaslUserQueryV3Api + CtgkafkaSelectedTopicsV3Api *CtgkafkaSelectedTopicsV3Api + CtgkafkaSetAcrossVpcInfoApi *CtgkafkaSetAcrossVpcInfoApi + CtgkafkaSpecExtendApi *CtgkafkaSpecExtendApi + CtgkafkaSpecShrinkApi *CtgkafkaSpecShrinkApi + CtgkafkaTagResourceV3Api *CtgkafkaTagResourceV3Api + CtgkafkaTopicBatchDeleteApi *CtgkafkaTopicBatchDeleteApi + CtgkafkaTopicCreateV3Api *CtgkafkaTopicCreateV3Api + CtgkafkaTopicDeleteV3Api *CtgkafkaTopicDeleteV3Api + CtgkafkaTopicDiskusageApi *CtgkafkaTopicDiskusageApi + CtgkafkaTopicModifyremarkV3Api *CtgkafkaTopicModifyremarkV3Api + CtgkafkaTopicQueryV3Api *CtgkafkaTopicQueryV3Api + CtgkafkaTopicStatusV3Api *CtgkafkaTopicStatusV3Api + CtgkafkaTransChargeTypeV3Api *CtgkafkaTransChargeTypeV3Api + CtgkafkaUnTagResourceV3Api *CtgkafkaUnTagResourceV3Api + CtgkafkaUnbindElasticIpApi *CtgkafkaUnbindElasticIpApi + CtgkafkaUnsubscribeInstV3Api *CtgkafkaUnsubscribeInstV3Api + CtgkafkaUpdateInstanceConfigApi *CtgkafkaUpdateInstanceConfigApi + CtgkafkaUpdateTopicApi *CtgkafkaUpdateTopicApi + CtgkafkaUpgradeInstanceVersionV3Api *CtgkafkaUpgradeInstanceVersionV3Api + CtgkafkaUserUpdateApi *CtgkafkaUserUpdateApi + func NewApis(endpointUrl string, client *core.CtyunClient) *Apis + type CtgkafkaAclAddV3Api struct + func NewCtgkafkaAclAddV3Api(client *core.CtyunClient) *CtgkafkaAclAddV3Api + func (a *CtgkafkaAclAddV3Api) Do(ctx context.Context, credential core.Credential, req *CtgkafkaAclAddV3Request) (*CtgkafkaAclAddV3Response, error) + type CtgkafkaAclAddV3Request struct + OperationType string + ProdInstId string + RegionId string + ResourceName string + ResourceType string + Username string + type CtgkafkaAclAddV3Response struct + Error string + Message string + ReturnObj *CtgkafkaAclAddV3ReturnObjResponse + StatusCode string + type CtgkafkaAclAddV3ReturnObjResponse struct + Data string + type CtgkafkaAclDeleteV3Api struct + func NewCtgkafkaAclDeleteV3Api(client *core.CtyunClient) *CtgkafkaAclDeleteV3Api + func (a *CtgkafkaAclDeleteV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaAclDeleteV3Response, error) + type CtgkafkaAclDeleteV3Request struct + OperationType string + ProdInstId string + RegionId string + ResourceName string + ResourceType string + Username string + type CtgkafkaAclDeleteV3Response struct + Error string + Message string + ReturnObj *CtgkafkaAclDeleteV3ReturnObjResponse + StatusCode string + type CtgkafkaAclDeleteV3ReturnObjResponse struct + Data string + type CtgkafkaAclQueryV3Api struct + func NewCtgkafkaAclQueryV3Api(client *core.CtyunClient) *CtgkafkaAclQueryV3Api + func (a *CtgkafkaAclQueryV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaAclQueryV3Response, error) + type CtgkafkaAclQueryV3Request struct + ProdInstId string + RegionId string + ResourceName string + ResourceType string + Username string + type CtgkafkaAclQueryV3Response struct + Error string + Message string + ReturnObj *CtgkafkaAclQueryV3ReturnObjResponse + StatusCode string + type CtgkafkaAclQueryV3ReturnObjDataEntryDataResponse struct + Host string + Principal string + type CtgkafkaAclQueryV3ReturnObjDataEntryResponse struct + Data *CtgkafkaAclQueryV3ReturnObjDataEntryDataResponse + type CtgkafkaAclQueryV3ReturnObjDataResourceResponse struct + Name string + ResourceType string + type CtgkafkaAclQueryV3ReturnObjDataResponse struct + Entry *CtgkafkaAclQueryV3ReturnObjDataEntryResponse + Resource *CtgkafkaAclQueryV3ReturnObjDataResourceResponse + type CtgkafkaAclQueryV3ReturnObjResponse struct + Data []*CtgkafkaAclQueryV3ReturnObjDataResponse + type CtgkafkaAddAuthorityApi struct + func NewCtgkafkaAddAuthorityApi(client *core.CtyunClient) *CtgkafkaAddAuthorityApi + func (a *CtgkafkaAddAuthorityApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaAddAuthorityResponse, error) + type CtgkafkaAddAuthorityRequest struct + AddReadAuthority []string + AddWriteAuthority []string + ProdInstId string + RegionId string + Username string + type CtgkafkaAddAuthorityResponse struct + Error string + Message string + ReturnObj *CtgkafkaAddAuthorityReturnObjResponse + StatusCode string + type CtgkafkaAddAuthorityReturnObjResponse struct + Data string + type CtgkafkaBeginningMessageApi struct + func NewCtgkafkaBeginningMessageApi(client *core.CtyunClient) *CtgkafkaBeginningMessageApi + func (a *CtgkafkaBeginningMessageApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaBeginningMessageResponse, error) + type CtgkafkaBeginningMessageRequest struct + PartitionId int32 + ProdInstId string + RegionId string + TopicName string + type CtgkafkaBeginningMessageResponse struct + Error string + Message string + ReturnObj *CtgkafkaBeginningMessageReturnObjResponse + StatusCode int32 + type CtgkafkaBeginningMessageReturnObjDataResponse struct + Offset int64 + Partition int32 + TimeStamp int64 + TopicName string + type CtgkafkaBeginningMessageReturnObjResponse struct + Data []*CtgkafkaBeginningMessageReturnObjDataResponse + type CtgkafkaBindElasticIpApi struct + func NewCtgkafkaBindElasticIpApi(client *core.CtyunClient) *CtgkafkaBindElasticIpApi + func (a *CtgkafkaBindElasticIpApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaBindElasticIpResponse, error) + type CtgkafkaBindElasticIpRequest struct + ElasticIp string + Ip string + PaasInstanceId string + RegionId string + type CtgkafkaBindElasticIpResponse struct + Error string + Message string + ReturnObj *CtgkafkaBindElasticIpReturnObjResponse + StatusCode string + type CtgkafkaBindElasticIpReturnObjDataResponse struct + type CtgkafkaBindElasticIpReturnObjResponse struct + Data *CtgkafkaBindElasticIpReturnObjDataResponse + type CtgkafkaCanExpandProdApi struct + func NewCtgkafkaCanExpandProdApi(client *core.CtyunClient) *CtgkafkaCanExpandProdApi + func (a *CtgkafkaCanExpandProdApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaCanExpandProdResponse, error) + type CtgkafkaCanExpandProdRequest struct + ProdInstId string + RegionId string + type CtgkafkaCanExpandProdResponse struct + Error string + Message string + ReturnObj *CtgkafkaCanExpandProdReturnObjResponse + StatusCode string + type CtgkafkaCanExpandProdReturnObjResponse struct + type CtgkafkaChangeAzApi struct + func NewCtgkafkaChangeAzApi(client *core.CtyunClient) *CtgkafkaChangeAzApi + func (a *CtgkafkaChangeAzApi) Do(ctx context.Context, credential core.Credential, req *CtgkafkaChangeAzRequest) (*CtgkafkaChangeAzResponse, error) + type CtgkafkaChangeAzRequest struct + AzInfoList []string + ProdInstId string + RegionId string + type CtgkafkaChangeAzResponse struct + Error string + Message string + ReturnObj *CtgkafkaChangeAzReturnObjResponse + StatusCode string + type CtgkafkaChangeAzReturnObjResponse struct + Data string + type CtgkafkaChaosCancelApi struct + func NewCtgkafkaChaosCancelApi(client *core.CtyunClient) *CtgkafkaChaosCancelApi + func (a *CtgkafkaChaosCancelApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaChaosCancelResponse, error) + type CtgkafkaChaosCancelRequest struct + ExperimentId string + ProdInstId string + RegionId string + type CtgkafkaChaosCancelResponse struct + Error string + Message string + ReturnObj *CtgkafkaChaosCancelReturnObjResponse + StatusCode int32 + type CtgkafkaChaosCancelReturnObjResponse struct + Data string + type CtgkafkaChaosInjectActionParameterRequest struct + AzName string + CpuPercent int32 + Duration int32 + EcsId string + NodeKillType int32 + type CtgkafkaChaosInjectApi struct + func NewCtgkafkaChaosInjectApi(client *core.CtyunClient) *CtgkafkaChaosInjectApi + func (a *CtgkafkaChaosInjectApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaChaosInjectResponse, error) + type CtgkafkaChaosInjectRequest struct + ActionCode string + ActionParameter *CtgkafkaChaosInjectActionParameterRequest + ProdInstId string + RegionId string + type CtgkafkaChaosInjectResponse struct + Error string + Message string + ReturnObj *CtgkafkaChaosInjectReturnObjResponse + StatusCode int32 + type CtgkafkaChaosInjectReturnObjResponse struct + ExperimentId string + TaskId string + type CtgkafkaChaosListApi struct + func NewCtgkafkaChaosListApi(client *core.CtyunClient) *CtgkafkaChaosListApi + func (a *CtgkafkaChaosListApi) Do(ctx context.Context, credential core.Credential, req *CtgkafkaChaosListRequest) (*CtgkafkaChaosListResponse, error) + type CtgkafkaChaosListRequest struct + PageNum int32 + PageSize int32 + ProdInstId string + RegionId string + type CtgkafkaChaosListResponse struct + Error string + Message string + ReturnObj *CtgkafkaChaosListReturnObjResponse + StatusCode int32 + type CtgkafkaChaosListReturnObjDataActionActionParameterResponse struct + Code string + Value string + type CtgkafkaChaosListReturnObjDataActionResponse struct + ActionCode string + ActionParameter []*CtgkafkaChaosListReturnObjDataActionActionParameterResponse + ActionScope string + type CtgkafkaChaosListReturnObjDataInjectActionInstanceActionParameterResponse struct + Code string + Value string + type CtgkafkaChaosListReturnObjDataInjectActionInstanceLogsResponse struct + LogLevel string + LogTime string + Msg string + StepName string + StepResult string + SubStepName string + type CtgkafkaChaosListReturnObjDataInjectActionInstanceResponse struct + ActionParameter []*CtgkafkaChaosListReturnObjDataInjectActionInstanceActionParameterResponse + EndTime int64 + Logs []*CtgkafkaChaosListReturnObjDataInjectActionInstanceLogsResponse + StartTime int64 + State int32 + TaskId string + type CtgkafkaChaosListReturnObjDataRecoveryActionInstanceActionParameterResponse struct + Code string + Value string + type CtgkafkaChaosListReturnObjDataRecoveryActionInstanceLogsResponse struct + LogLevel string + LogTime string + Msg string + StepName string + StepResult string + SubStepName string + type CtgkafkaChaosListReturnObjDataRecoveryActionInstanceResponse struct + ActionParameter []*CtgkafkaChaosListReturnObjDataRecoveryActionInstanceActionParameterResponse + EndTime int64 + Logs []*CtgkafkaChaosListReturnObjDataRecoveryActionInstanceLogsResponse + StartTime int64 + State int32 + TaskId string + type CtgkafkaChaosListReturnObjDataResponse struct + Action *CtgkafkaChaosListReturnObjDataActionResponse + CreateDate int64 + ExperimentId string + InjectActionInstance *CtgkafkaChaosListReturnObjDataInjectActionInstanceResponse + RecoveryActionInstance *CtgkafkaChaosListReturnObjDataRecoveryActionInstanceResponse + type CtgkafkaChaosListReturnObjResponse struct + Data []*CtgkafkaChaosListReturnObjDataResponse + Total int32 + type CtgkafkaChaosQueryReqMsgApi struct + func NewCtgkafkaChaosQueryReqMsgApi(client *core.CtyunClient) *CtgkafkaChaosQueryReqMsgApi + func (a *CtgkafkaChaosQueryReqMsgApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaChaosQueryReqMsgResponse, error) + type CtgkafkaChaosQueryReqMsgRequest struct + ExperimentId string + ProdInstId string + RegionId string + TaskId string + type CtgkafkaChaosQueryReqMsgResponse struct + Error string + Message string + ReturnObj *CtgkafkaChaosQueryReqMsgReturnObjResponse + StatusCode int32 + type CtgkafkaChaosQueryReqMsgReturnObjResponse struct + CpuPercent int32 + Duration int32 + NodeKillType int32 + Nodes []string + type CtgkafkaConsumerGroupBatchDeleteApi struct + func NewCtgkafkaConsumerGroupBatchDeleteApi(client *core.CtyunClient) *CtgkafkaConsumerGroupBatchDeleteApi + func (a *CtgkafkaConsumerGroupBatchDeleteApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaConsumerGroupBatchDeleteResponse, error) + type CtgkafkaConsumerGroupBatchDeleteRequest struct + GroupNames []string + ProdInstId string + RegionId string + type CtgkafkaConsumerGroupBatchDeleteResponse struct + Error string + Message string + ReturnObj *CtgkafkaConsumerGroupBatchDeleteReturnObjResponse + StatusCode string + type CtgkafkaConsumerGroupBatchDeleteReturnObjResponse struct + Data string + type CtgkafkaConsumerGroupCreateV3Api struct + func NewCtgkafkaConsumerGroupCreateV3Api(client *core.CtyunClient) *CtgkafkaConsumerGroupCreateV3Api + func (a *CtgkafkaConsumerGroupCreateV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaConsumerGroupCreateV3Response, error) + type CtgkafkaConsumerGroupCreateV3Request struct + Description string + GroupName string + ProdInstId string + RegionId string + type CtgkafkaConsumerGroupCreateV3Response struct + Error string + Message string + ReturnObj *CtgkafkaConsumerGroupCreateV3ReturnObjResponse + StatusCode string + type CtgkafkaConsumerGroupCreateV3ReturnObjResponse struct + Data string + type CtgkafkaConsumerGroupDeleteV3Api struct + func NewCtgkafkaConsumerGroupDeleteV3Api(client *core.CtyunClient) *CtgkafkaConsumerGroupDeleteV3Api + func (a *CtgkafkaConsumerGroupDeleteV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaConsumerGroupDeleteV3Response, error) + type CtgkafkaConsumerGroupDeleteV3Request struct + GroupName string + ProdInstId string + RegionId string + type CtgkafkaConsumerGroupDeleteV3Response struct + Error string + Message string + ReturnObj *CtgkafkaConsumerGroupDeleteV3ReturnObjResponse + StatusCode string + type CtgkafkaConsumerGroupDeleteV3ReturnObjResponse struct + Data string + type CtgkafkaConsumerGroupInstancesV3Api struct + func NewCtgkafkaConsumerGroupInstancesV3Api(client *core.CtyunClient) *CtgkafkaConsumerGroupInstancesV3Api + func (a *CtgkafkaConsumerGroupInstancesV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaConsumerGroupInstancesV3Response, error) + type CtgkafkaConsumerGroupInstancesV3Request struct + GroupName string + ProdInstId string + RegionId string + type CtgkafkaConsumerGroupInstancesV3Response struct + Error string + Message string + ReturnObj *CtgkafkaConsumerGroupInstancesV3ReturnObjResponse + StatusCode string + type CtgkafkaConsumerGroupInstancesV3ReturnObjDataResponse struct + ClientId string + ConsumerId string + Host string + TopicPartitions *CtgkafkaConsumerGroupInstancesV3ReturnObjDataTopicPartitionsResponse + type CtgkafkaConsumerGroupInstancesV3ReturnObjDataTopicPartitionsResponse struct + type CtgkafkaConsumerGroupInstancesV3ReturnObjResponse struct + Data []*CtgkafkaConsumerGroupInstancesV3ReturnObjDataResponse + type CtgkafkaConsumerGroupQueryV3Api struct + func NewCtgkafkaConsumerGroupQueryV3Api(client *core.CtyunClient) *CtgkafkaConsumerGroupQueryV3Api + func (a *CtgkafkaConsumerGroupQueryV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaConsumerGroupQueryV3Response, error) + type CtgkafkaConsumerGroupQueryV3Request struct + GroupName string + PageNum string + PageSize string + ProdInstId string + RegionId string + type CtgkafkaConsumerGroupQueryV3Response struct + Error string + Message string + ReturnObj *CtgkafkaConsumerGroupQueryV3ReturnObjResponse + StatusCode string + type CtgkafkaConsumerGroupQueryV3ReturnObjDataResponse struct + Ctime string + Description string + Id int32 + Name string + type CtgkafkaConsumerGroupQueryV3ReturnObjResponse struct + Data []*CtgkafkaConsumerGroupQueryV3ReturnObjDataResponse + Total int32 + type CtgkafkaConsumerGroupResetV3Api struct + func NewCtgkafkaConsumerGroupResetV3Api(client *core.CtyunClient) *CtgkafkaConsumerGroupResetV3Api + func (a *CtgkafkaConsumerGroupResetV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaConsumerGroupResetV3Response, error) + type CtgkafkaConsumerGroupResetV3PartitionShiftListRequest struct + Partition int32 + ShiftBy int64 + type CtgkafkaConsumerGroupResetV3Request struct + GroupName string + PartitionShiftList []*CtgkafkaConsumerGroupResetV3PartitionShiftListRequest + ProdInstId string + RawType int32 + RegionId string + Time int64 + TopicName string + type CtgkafkaConsumerGroupResetV3Response struct + Error string + Message string + ReturnObj *CtgkafkaConsumerGroupResetV3ReturnObjResponse + StatusCode string + type CtgkafkaConsumerGroupResetV3ReturnObjResponse struct + Data string + type CtgkafkaConsumerGroupStatusV3Api struct + func NewCtgkafkaConsumerGroupStatusV3Api(client *core.CtyunClient) *CtgkafkaConsumerGroupStatusV3Api + func (a *CtgkafkaConsumerGroupStatusV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaConsumerGroupStatusV3Response, error) + type CtgkafkaConsumerGroupStatusV3Request struct + GroupName string + ProdInstId string + RegionId string + TopicName string + type CtgkafkaConsumerGroupStatusV3Response struct + Error string + Message string + ReturnObj *CtgkafkaConsumerGroupStatusV3ReturnObjResponse + StatusCode string + type CtgkafkaConsumerGroupStatusV3ReturnObjDataOffsetsResponse struct + Begin int64 + Current int64 + End int64 + Hw int64 + Lag int64 + Total int64 + type CtgkafkaConsumerGroupStatusV3ReturnObjDataResponse struct + Offsets *CtgkafkaConsumerGroupStatusV3ReturnObjDataOffsetsResponse + PartitionId int32 + TopicName string + type CtgkafkaConsumerGroupStatusV3ReturnObjResponse struct + Data []*CtgkafkaConsumerGroupStatusV3ReturnObjDataResponse + Total int32 + type CtgkafkaConsumerGroupUpdateApi struct + func NewCtgkafkaConsumerGroupUpdateApi(client *core.CtyunClient) *CtgkafkaConsumerGroupUpdateApi + func (a *CtgkafkaConsumerGroupUpdateApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaConsumerGroupUpdateResponse, error) + type CtgkafkaConsumerGroupUpdateRequest struct + Description string + GroupName string + ProdInstId string + RegionId string + type CtgkafkaConsumerGroupUpdateResponse struct + Error string + Message string + ReturnObj *CtgkafkaConsumerGroupUpdateReturnObjResponse + StatusCode string + type CtgkafkaConsumerGroupUpdateReturnObjResponse struct + Data string + type CtgkafkaConsumerGroupUpdatetopicsV3Api struct + func NewCtgkafkaConsumerGroupUpdatetopicsV3Api(client *core.CtyunClient) *CtgkafkaConsumerGroupUpdatetopicsV3Api + func (a *CtgkafkaConsumerGroupUpdatetopicsV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaConsumerGroupUpdatetopicsV3Response, error) + type CtgkafkaConsumerGroupUpdatetopicsV3Request struct + AddTopicNames []string + DeleteTopicNames []string + GroupName string + ProdInstId string + RegionId string + type CtgkafkaConsumerGroupUpdatetopicsV3Response struct + Error string + Message string + ReturnObj *CtgkafkaConsumerGroupUpdatetopicsV3ReturnObjResponse + StatusCode string + type CtgkafkaConsumerGroupUpdatetopicsV3ReturnObjResponse struct + Data string + type CtgkafkaCreateOrderApi struct + func NewCtgkafkaCreateOrderApi(client *core.CtyunClient) *CtgkafkaCreateOrderApi + func (a *CtgkafkaCreateOrderApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaCreateOrderResponse, error) + type CtgkafkaCreateOrderRequest struct + AutoRenewCycleCount int32 + AutoRenewStatus *bool + ClusterName string + CycleCnt int32 + DiskSize int32 + DiskType string + EnableIpv6 *bool + EngineVersion string + HttpPort int32 + InstanceNum int32 + NodeNum int32 + PlainPort int32 + ProjectId string + RegionId string + RetentionHours int32 + SaslPort int32 + SecurityGroupId string + SpecName string + SslPort int32 + SubnetId string + VpcId string + ZoneList []string + type CtgkafkaCreateOrderResponse struct + Error string + Message string + ReturnObj *CtgkafkaCreateOrderReturnObjResponse + StatusCode string + type CtgkafkaCreateOrderReturnObjResponse struct + Data CtgkafkaCreateOrderReturnObjResponseData + type CtgkafkaCreateOrderReturnObjResponseData struct + NewOrderId string + NewOrderNo string + Submitted bool + type CtgkafkaCreatePostPayOrderApi struct + func NewCtgkafkaCreatePostPayOrderApi(client *core.CtyunClient) *CtgkafkaCreatePostPayOrderApi + func (a *CtgkafkaCreatePostPayOrderApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaCreatePostPayOrderResponse, error) + type CtgkafkaCreatePostPayOrderRequest struct + ClusterName string + DiskSize int32 + DiskType string + EnableIpv6 *bool + EngineVersion string + HttpPort int32 + InstanceNum int32 + NodeNum int32 + PlainPort int32 + ProjectId string + RegionId string + RetentionHours int32 + SaslPort int32 + SecurityGroupId string + SpecName string + SslPort int32 + SubnetId string + VpcId string + ZoneList []string + type CtgkafkaCreatePostPayOrderResponse struct + Error string + Message string + ReturnObj *CtgkafkaCreatePostPayOrderReturnObjResponse + StatusCode string + type CtgkafkaCreatePostPayOrderReturnObjResponse struct + Data CtgkafkaCreatePostPayOrderReturnObjResponseData + type CtgkafkaCreatePostPayOrderReturnObjResponseData struct + NewOrderId string + NewOrderNo string + Submitted bool + TotalPrice string + type CtgkafkaDeleteAuthorityApi struct + func NewCtgkafkaDeleteAuthorityApi(client *core.CtyunClient) *CtgkafkaDeleteAuthorityApi + func (a *CtgkafkaDeleteAuthorityApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaDeleteAuthorityResponse, error) + type CtgkafkaDeleteAuthorityRequest struct + DeleteReadAuthority []string + DeleteWriteAuthority []string + ProdInstId string + RegionId string + Username string + type CtgkafkaDeleteAuthorityResponse struct + Error string + Message string + ReturnObj *CtgkafkaDeleteAuthorityReturnObjResponse + StatusCode string + type CtgkafkaDeleteAuthorityReturnObjResponse struct + Data string + type CtgkafkaDiskExtendApi struct + func NewCtgkafkaDiskExtendApi(client *core.CtyunClient) *CtgkafkaDiskExtendApi + func (a *CtgkafkaDiskExtendApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaDiskExtendResponse, error) + type CtgkafkaDiskExtendRequest struct + AutoPay *bool + DiskExtendSize string + ProdInstId string + RegionId string + type CtgkafkaDiskExtendResponse struct + Error string + Message string + ReturnObj *CtgkafkaDiskExtendReturnObjResponse + StatusCode string + type CtgkafkaDiskExtendReturnObjResponse struct + type CtgkafkaDiskShrinkApi struct + func NewCtgkafkaDiskShrinkApi(client *core.CtyunClient) *CtgkafkaDiskShrinkApi + func (a *CtgkafkaDiskShrinkApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaDiskShrinkResponse, error) + type CtgkafkaDiskShrinkRequest struct + DiskSize string + ProdInstId string + RegionId string + type CtgkafkaDiskShrinkResponse struct + Error string + Message string + ReturnObj *CtgkafkaDiskShrinkReturnObjResponse + StatusCode string + type CtgkafkaDiskShrinkReturnObjResponse struct + type CtgkafkaElasticBandwidthApi struct + func NewCtgkafkaElasticBandwidthApi(client *core.CtyunClient) *CtgkafkaElasticBandwidthApi + func (a *CtgkafkaElasticBandwidthApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaElasticBandwidthResponse, error) + type CtgkafkaElasticBandwidthRequest struct + Enable int32 + ProdInstId string + RegionId string + type CtgkafkaElasticBandwidthResponse struct + Error string + Message string + ReturnObj *CtgkafkaElasticBandwidthReturnObjResponse + StatusCode string + type CtgkafkaElasticBandwidthReturnObjDataResponse struct + type CtgkafkaElasticBandwidthReturnObjResponse struct + Data *CtgkafkaElasticBandwidthReturnObjDataResponse + type CtgkafkaEnableAutoReassignApi struct + func NewCtgkafkaEnableAutoReassignApi(client *core.CtyunClient) *CtgkafkaEnableAutoReassignApi + func (a *CtgkafkaEnableAutoReassignApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaEnableAutoReassignResponse, error) + type CtgkafkaEnableAutoReassignRequest struct + Enable int32 + ProdInstId string + RegionId string + type CtgkafkaEnableAutoReassignResponse struct + Error string + Message string + ReturnObj *CtgkafkaEnableAutoReassignReturnObjResponse + StatusCode string + type CtgkafkaEnableAutoReassignReturnObjDataResponse struct + type CtgkafkaEnableAutoReassignReturnObjResponse struct + Data *CtgkafkaEnableAutoReassignReturnObjDataResponse + type CtgkafkaEndMessageApi struct + func NewCtgkafkaEndMessageApi(client *core.CtyunClient) *CtgkafkaEndMessageApi + func (a *CtgkafkaEndMessageApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaEndMessageResponse, error) + type CtgkafkaEndMessageRequest struct + PartitionId int32 + ProdInstId string + RegionId string + TopicName string + type CtgkafkaEndMessageResponse struct + Error string + Message string + ReturnObj *CtgkafkaEndMessageReturnObjResponse + StatusCode int32 + type CtgkafkaEndMessageReturnObjDataResponse struct + Offset int64 + Partition int32 + TimeStamp int64 + TopicName string + type CtgkafkaEndMessageReturnObjResponse struct + Data []*CtgkafkaEndMessageReturnObjDataResponse + type CtgkafkaGetAuthorityApi struct + func NewCtgkafkaGetAuthorityApi(client *core.CtyunClient) *CtgkafkaGetAuthorityApi + func (a *CtgkafkaGetAuthorityApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaGetAuthorityResponse, error) + type CtgkafkaGetAuthorityRequest struct + ProdInstId string + RegionId string + Username string + type CtgkafkaGetAuthorityResponse struct + Error string + Message string + ReturnObj *CtgkafkaGetAuthorityReturnObjResponse + StatusCode string + type CtgkafkaGetAuthorityReturnObjDataResponse struct + ReadAuthorityTopics []string + Username string + WriteAuthorityTopics []string + type CtgkafkaGetAuthorityReturnObjResponse struct + Data *CtgkafkaGetAuthorityReturnObjDataResponse + type CtgkafkaGetInstanceConfigApi struct + func NewCtgkafkaGetInstanceConfigApi(client *core.CtyunClient) *CtgkafkaGetInstanceConfigApi + func (a *CtgkafkaGetInstanceConfigApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaGetInstanceConfigResponse, error) + type CtgkafkaGetInstanceConfigRequest struct + ProdInstId string + RegionId string + type CtgkafkaGetInstanceConfigResponse struct + Error string + Message string + ReturnObj *CtgkafkaGetInstanceConfigReturnObjResponse + StatusCode string + type CtgkafkaGetInstanceConfigReturnObjDataResponse struct + Config_type string + Default_value string + Desc string + Name string + Valid_values string + Value string + VarType string + type CtgkafkaGetInstanceConfigReturnObjResponse struct + Data []*CtgkafkaGetInstanceConfigReturnObjDataResponse + type CtgkafkaGetTopicDetailsApi struct + func NewCtgkafkaGetTopicDetailsApi(client *core.CtyunClient) *CtgkafkaGetTopicDetailsApi + func (a *CtgkafkaGetTopicDetailsApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaGetTopicDetailsResponse, error) + type CtgkafkaGetTopicDetailsRequest struct + ProdInstId string + RegionId string + TopicName string + type CtgkafkaGetTopicDetailsResponse struct + Error string + Message string + ReturnObj *CtgkafkaGetTopicDetailsReturnObjResponse + StatusCode int32 + type CtgkafkaGetTopicDetailsReturnObjDataPartitionListOffsetsResponse struct + Begin int64 + End int64 + Hw int64 + Total int64 + UpdateTime int64 + type CtgkafkaGetTopicDetailsReturnObjDataPartitionListReplicasResponse struct + BrokerId int32 + InSync *bool + IsLeader *bool + Lag int64 + Size int64 + type CtgkafkaGetTopicDetailsReturnObjDataPartitionListResponse struct + Offsets *CtgkafkaGetTopicDetailsReturnObjDataPartitionListOffsetsResponse + PartitionId int32 + Replicas []*CtgkafkaGetTopicDetailsReturnObjDataPartitionListReplicasResponse + TopicName string + type CtgkafkaGetTopicDetailsReturnObjDataResponse struct + GroupSubscribed []string + PartitionList []*CtgkafkaGetTopicDetailsReturnObjDataPartitionListResponse + TopicName string + type CtgkafkaGetTopicDetailsReturnObjResponse struct + Data []*CtgkafkaGetTopicDetailsReturnObjDataResponse + type CtgkafkaInstQueryApi struct + func NewCtgkafkaInstQueryApi(client *core.CtyunClient) *CtgkafkaInstQueryApi + func (a *CtgkafkaInstQueryApi) Do(ctx context.Context, credential core.Credential, req *CtgkafkaInstQueryRequest) (*CtgkafkaInstQueryResponse, error) + type CtgkafkaInstQueryRequest struct + ExactMatchName *bool + Name string + OuterProjectId string + PageNum int32 + PageSize int32 + ProdInstId string + RegionId string + Status int32 + type CtgkafkaInstQueryResponse struct + Error string + Message string + ReturnObj *CtgkafkaInstQueryReturnObjResponse + StatusCode string + type CtgkafkaInstQueryReturnObjDataNodeListResponse struct + AzId string + AzName string + CreateTime string + DomainEndpoint string + EcsId string + ElasticIp string + ElasticIpState int32 + HttpPort string + Ipv6PlainPort string + Ipv6SaslPort string + Ipv6SslPort string + ListenNodePort string + SaslNodePort string + SaslPort string + ServerSeq int32 + State int32 + TenantId string + TenantName string + UpdateTime string + VpcIp string + VpcIpv6 string + VpcPort string + type CtgkafkaInstQueryReturnObjDataProtocolsResponse struct + DomainEndpointAddr string + EnableIPv6 *bool + HttpAddr string + HttpIpv6Addr string + PlainTextAddr string + PlainTextIpv6Addr string + PublicSaslTextAddr string + SaslPlainTextAddr string + SaslPlainTextIpv6Addr string + SaslSslAddr string + SaslSslIpv6Addr string + type CtgkafkaInstQueryReturnObjDataResponse struct + AutoReassign int32 + BillMode string + ClusterType int32 + CreateTime string + DiskType string + DomainEndpoint string + ElasticEnable string + ExpireTime string + InstanceName string + Ipv6Enable int32 + MqEngineType string + Network string + NodeList []*CtgkafkaInstQueryReturnObjDataNodeListResponse + OuterProjectId string + OuterProjectName string + PartitionNum int32 + ProdInstId string + Protocols *CtgkafkaInstQueryReturnObjDataProtocolsResponse + RegionCode string + RegionName string + Remark string + SecurityGroup string + Space string + Specifications string + Status int32 + Subnet string + SubnetId string + UpdateTime string + Version string + Vip string + Vipv6 string + VpcId string + type CtgkafkaInstQueryReturnObjResponse struct + Data []*CtgkafkaInstQueryReturnObjDataResponse + Total int32 + type CtgkafkaInstanceDeleteV3Api struct + func NewCtgkafkaInstanceDeleteV3Api(client *core.CtyunClient) *CtgkafkaInstanceDeleteV3Api + func (a *CtgkafkaInstanceDeleteV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaInstanceDeleteV3Response, error) + type CtgkafkaInstanceDeleteV3Request struct + ProdInstId string + RegionId string + type CtgkafkaInstanceDeleteV3Response struct + Error string + Message string + ReturnObj *CtgkafkaInstanceDeleteV3ReturnObjResponse + StatusCode string + type CtgkafkaInstanceDeleteV3ReturnObjResponse struct + Data string + type CtgkafkaInstancesModifyNameV3Api struct + func NewCtgkafkaInstancesModifyNameV3Api(client *core.CtyunClient) *CtgkafkaInstancesModifyNameV3Api + func (a *CtgkafkaInstancesModifyNameV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaInstancesModifyNameV3Response, error) + type CtgkafkaInstancesModifyNameV3Request struct + InstanceName string + ProdInstId string + RegionId string + type CtgkafkaInstancesModifyNameV3Response struct + Error string + Message string + ReturnObj *CtgkafkaInstancesModifyNameV3ReturnObjResponse + StatusCode string + type CtgkafkaInstancesModifyNameV3ReturnObjResponse struct + Data string + type CtgkafkaInstancesRestartV3Api struct + func NewCtgkafkaInstancesRestartV3Api(client *core.CtyunClient) *CtgkafkaInstancesRestartV3Api + func (a *CtgkafkaInstancesRestartV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaInstancesRestartV3Response, error) + type CtgkafkaInstancesRestartV3Request struct + ProdInstId string + RegionId string + type CtgkafkaInstancesRestartV3Response struct + Error string + Message string + ReturnObj *CtgkafkaInstancesRestartV3ReturnObjResponse + StatusCode string + type CtgkafkaInstancesRestartV3ReturnObjResponse struct + Data string + type CtgkafkaListResourceV3Api struct + func NewCtgkafkaListResourceV3Api(client *core.CtyunClient) *CtgkafkaListResourceV3Api + func (a *CtgkafkaListResourceV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaListResourceV3Response, error) + type CtgkafkaListResourceV3Request struct + RegionId string + TagId string + type CtgkafkaListResourceV3Response struct + Error string + Message string + StatusCode string + type CtgkafkaListTagV3Api struct + func NewCtgkafkaListTagV3Api(client *core.CtyunClient) *CtgkafkaListTagV3Api + func (a *CtgkafkaListTagV3Api) Do(ctx context.Context, credential core.Credential, req *CtgkafkaListTagV3Request) (*CtgkafkaListTagV3Response, error) + type CtgkafkaListTagV3Request struct + PageNum string + PageSize string + RegionId string + TagName string + type CtgkafkaListTagV3Response struct + Error string + Message string + StatusCode string + type CtgkafkaMirrorTaskApi struct + func NewCtgkafkaMirrorTaskApi(client *core.CtyunClient) *CtgkafkaMirrorTaskApi + func (a *CtgkafkaMirrorTaskApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaMirrorTaskResponse, error) + type CtgkafkaMirrorTaskRequest struct + AutoStopTask string + DefaultReplica string + Groups string + ProdInstId string + RawType string + RegionId string + SourceAddr string + SourceClusterId string + SourceProtocol string + SourceSaslMechanism string + SourceSaslPwd string + SourceSaslUser string + SyncAcl string + SyncGroup string + TaskName string + TaskNum int32 + Topics string + type CtgkafkaMirrorTaskResponse struct + Error string + Message string + ReturnObj *CtgkafkaMirrorTaskReturnObjResponse + StatusCode string + type CtgkafkaMirrorTaskReturnObjResponse struct + Data string + type CtgkafkaModifyInstanceConfigApi struct + func NewCtgkafkaModifyInstanceConfigApi(client *core.CtyunClient) *CtgkafkaModifyInstanceConfigApi + func (a *CtgkafkaModifyInstanceConfigApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaModifyInstanceConfigResponse, error) + type CtgkafkaModifyInstanceConfigRequest struct + LogRetentionMs string + MessageMaxBytes string + ProdInstId string + RegionId string + type CtgkafkaModifyInstanceConfigResponse struct + Error string + Message string + StatusCode string + type CtgkafkaModifypartitionNumV3Api struct + func NewCtgkafkaModifypartitionNumV3Api(client *core.CtyunClient) *CtgkafkaModifypartitionNumV3Api + func (a *CtgkafkaModifypartitionNumV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaModifypartitionNumV3Response, error) + type CtgkafkaModifypartitionNumV3Request struct + PartitionNum int32 + ProdInstId string + RegionId string + TopicName string + type CtgkafkaModifypartitionNumV3Response struct + Error string + Message string + ReturnObj *CtgkafkaModifypartitionNumV3ReturnObjResponse + StatusCode string + type CtgkafkaModifypartitionNumV3ReturnObjResponse struct + Data string + type CtgkafkaMonitorMetricsV3Api struct + func NewCtgkafkaMonitorMetricsV3Api(client *core.CtyunClient) *CtgkafkaMonitorMetricsV3Api + func (a *CtgkafkaMonitorMetricsV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaMonitorMetricsV3Response, error) + type CtgkafkaMonitorMetricsV3Request struct + EndTime int32 + Labels string + MetricName string + ProdInstId string + RegionCode string + RegionId string + StartTime int32 + type CtgkafkaMonitorMetricsV3Response struct + Error string + Message string + ReturnObj []*CtgkafkaMonitorMetricsV3ReturnObjResponse + StatusCode string + type CtgkafkaMonitorMetricsV3ReturnObjMetricResponse struct + type CtgkafkaMonitorMetricsV3ReturnObjResponse struct + Metric *CtgkafkaMonitorMetricsV3ReturnObjMetricResponse + Values []*CtgkafkaMonitorMetricsV3ReturnObjValuesResponse + type CtgkafkaMonitorMetricsV3ReturnObjValuesResponse struct + MetricValues []string + type CtgkafkaNodeExtendApi struct + func NewCtgkafkaNodeExtendApi(client *core.CtyunClient) *CtgkafkaNodeExtendApi + func (a *CtgkafkaNodeExtendApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaNodeExtendResponse, error) + type CtgkafkaNodeExtendRequest struct + AutoPay *bool + ExtendNodeNum int32 + ProdInstId string + RegionId string + type CtgkafkaNodeExtendResponse struct + Error string + Message string + ReturnObj *CtgkafkaNodeExtendReturnObjResponse + StatusCode string + type CtgkafkaNodeExtendReturnObjResponse struct + type CtgkafkaNodeShrinkApi struct + func NewCtgkafkaNodeShrinkApi(client *core.CtyunClient) *CtgkafkaNodeShrinkApi + func (a *CtgkafkaNodeShrinkApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaNodeShrinkResponse, error) + type CtgkafkaNodeShrinkRequest struct + NodeNum string + ProdInstId string + RegionId string + type CtgkafkaNodeShrinkResponse struct + Error string + Message string + ReturnObj *CtgkafkaNodeShrinkReturnObjResponse + StatusCode string + type CtgkafkaNodeShrinkReturnObjResponse struct + type CtgkafkaNodeStatusV3Api struct + func NewCtgkafkaNodeStatusV3Api(client *core.CtyunClient) *CtgkafkaNodeStatusV3Api + func (a *CtgkafkaNodeStatusV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaNodeStatusV3Response, error) + type CtgkafkaNodeStatusV3Request struct + ProdInstId string + RegionId string + type CtgkafkaNodeStatusV3Response struct + Error string + Message string + ReturnObj *CtgkafkaNodeStatusV3ReturnObjResponse + StatusCode string + type CtgkafkaNodeStatusV3ReturnObjDataResponse struct + Ip string + Status *bool + type CtgkafkaNodeStatusV3ReturnObjResponse struct + Data []*CtgkafkaNodeStatusV3ReturnObjDataResponse + type CtgkafkaPageQueryFloatingipsApi struct + func NewCtgkafkaPageQueryFloatingipsApi(client *core.CtyunClient) *CtgkafkaPageQueryFloatingipsApi + func (a *CtgkafkaPageQueryFloatingipsApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaPageQueryFloatingipsResponse, error) + type CtgkafkaPageQueryFloatingipsRequest struct + PageNum int32 + PageSize int32 + RegionId string + type CtgkafkaPageQueryFloatingipsResponse struct + Error string + Message string + ReturnObj string + StatusCode string + type CtgkafkaProdDetailApi struct + func NewCtgkafkaProdDetailApi(client *core.CtyunClient) *CtgkafkaProdDetailApi + func (a *CtgkafkaProdDetailApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaProdDetailResponse, error) + type CtgkafkaProdDetailRequest struct + RegionId string + type CtgkafkaProdDetailResponse struct + Error string + Message string + RequestId string + ReturnObj *CtgkafkaProdDetailReturnObjResponse + StatusCode string + type CtgkafkaProdDetailReturnObjResponse struct + Data struct{ ... } + type CtgkafkaProdDetailReturnObjResponseSeries struct + ProdCode string + ProdId string + ProdName string + Sku []CtgkafkaProdDetailReturnObjResponseSku + type CtgkafkaProdDetailReturnObjResponseSku struct + DiskItem CtgkafkaProdDetailReturnObjResponseSkuDiskItem + ProdCode string + ProdId string + ProdName string + ResItem CtgkafkaProdDetailReturnObjResponseSkuResItem + type CtgkafkaProdDetailReturnObjResponseSkuDiskItem struct + ResItems []string + ResName string + ResType string + type CtgkafkaProdDetailReturnObjResponseSkuResItem struct + ResItems []struct{ ... } + ResName string + ResType string + type CtgkafkaProduceApi struct + func NewCtgkafkaProduceApi(client *core.CtyunClient) *CtgkafkaProduceApi + func (a *CtgkafkaProduceApi) Do(ctx context.Context, credential core.Credential, req *CtgkafkaProduceRequest) (*CtgkafkaProduceResponse, error) + type CtgkafkaProduceRequest struct + Key string + NumMessages int32 + PartitionId int32 + ProdInstId string + RegionId string + TopicName string + Value string + type CtgkafkaProduceResponse struct + Error string + Message string + ReturnObj *CtgkafkaProduceReturnObjResponse + StatusCode int32 + type CtgkafkaProduceReturnObjResponse struct + Data string + Result string + type CtgkafkaQueryCanUpdateVersionV3Api struct + func NewCtgkafkaQueryCanUpdateVersionV3Api(client *core.CtyunClient) *CtgkafkaQueryCanUpdateVersionV3Api + func (a *CtgkafkaQueryCanUpdateVersionV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQueryCanUpdateVersionV3Response, error) + type CtgkafkaQueryCanUpdateVersionV3Request struct + ProdInstId string + RegionId string + type CtgkafkaQueryCanUpdateVersionV3Response struct + Error string + Message string + ReturnObj *CtgkafkaQueryCanUpdateVersionV3ReturnObjResponse + StatusCode string + type CtgkafkaQueryCanUpdateVersionV3ReturnObjResponse struct + Data []string + type CtgkafkaQueryMessageApi struct + func NewCtgkafkaQueryMessageApi(client *core.CtyunClient) *CtgkafkaQueryMessageApi + func (a *CtgkafkaQueryMessageApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQueryMessageResponse, error) + type CtgkafkaQueryMessageByOffsetV3Api struct + func NewCtgkafkaQueryMessageByOffsetV3Api(client *core.CtyunClient) *CtgkafkaQueryMessageByOffsetV3Api + func (a *CtgkafkaQueryMessageByOffsetV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQueryMessageByOffsetV3Response, error) + type CtgkafkaQueryMessageByOffsetV3Request struct + Offset int64 + Partition int32 + ProdInstId string + RegionId string + TopicName string + type CtgkafkaQueryMessageByOffsetV3Response struct + Error string + Message string + ReturnObj *CtgkafkaQueryMessageByOffsetV3ReturnObjResponse + StatusCode string + type CtgkafkaQueryMessageByOffsetV3ReturnObjDataResponse struct + Key string + Offset int64 + Partition int32 + Size string + Timestamp int64 + Topic string + Value string + type CtgkafkaQueryMessageByOffsetV3ReturnObjResponse struct + Data []*CtgkafkaQueryMessageByOffsetV3ReturnObjDataResponse + type CtgkafkaQueryMessageByTimestampV3Api struct + func NewCtgkafkaQueryMessageByTimestampV3Api(client *core.CtyunClient) *CtgkafkaQueryMessageByTimestampV3Api + func (a *CtgkafkaQueryMessageByTimestampV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQueryMessageByTimestampV3Response, error) + type CtgkafkaQueryMessageByTimestampV3Request struct + Partition int32 + ProdInstId string + RegionId string + Timestamp string + TopicName string + type CtgkafkaQueryMessageByTimestampV3Response struct + Error string + Message string + ReturnObj *CtgkafkaQueryMessageByTimestampV3ReturnObjResponse + StatusCode string + type CtgkafkaQueryMessageByTimestampV3ReturnObjDataResponse struct + Key string + Offset int64 + Partition int32 + Size string + Timestamp int64 + Topic string + Value string + type CtgkafkaQueryMessageByTimestampV3ReturnObjResponse struct + Data []*CtgkafkaQueryMessageByTimestampV3ReturnObjDataResponse + type CtgkafkaQueryMessageRequest struct + Content string + EndTime int64 + PageNum int32 + PageSize int32 + PartitionId int32 + ProdInstId string + RegionId string + StartTime int64 + TopicName string + type CtgkafkaQueryMessageResponse struct + Error string + Message string + ReturnObj *CtgkafkaQueryMessageReturnObjResponse + StatusCode string + type CtgkafkaQueryMessageReturnObjDataMessagesResponse struct + Key string + Offset int64 + Partition int32 + Size int32 + Timestamp int64 + Topic string + Value string + type CtgkafkaQueryMessageReturnObjDataResponse struct + Messages []*CtgkafkaQueryMessageReturnObjDataMessagesResponse + type CtgkafkaQueryMessageReturnObjResponse struct + Data *CtgkafkaQueryMessageReturnObjDataResponse + type CtgkafkaQueryProducersApi struct + func NewCtgkafkaQueryProducersApi(client *core.CtyunClient) *CtgkafkaQueryProducersApi + func (a *CtgkafkaQueryProducersApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQueryProducersResponse, error) + type CtgkafkaQueryProducersRequest struct + ProdInstId string + RegionId string + TopicName string + type CtgkafkaQueryProducersResponse struct + Error string + Message string + ReturnObj *CtgkafkaQueryProducersReturnObjResponse + StatusCode int32 + type CtgkafkaQueryProducersReturnObjResponse struct + Address string + BrokerAddress string + Expire *bool + JoinTime int64 + Topic string + type CtgkafkaQuotaBrokerCreateApi struct + func NewCtgkafkaQuotaBrokerCreateApi(client *core.CtyunClient) *CtgkafkaQuotaBrokerCreateApi + func (a *CtgkafkaQuotaBrokerCreateApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQuotaBrokerCreateResponse, error) + type CtgkafkaQuotaBrokerCreateRequest struct + ConsumerByteRate int64 + ProdInstId string + ProducerByteRate int64 + RegionId string + type CtgkafkaQuotaBrokerCreateResponse struct + Message string + StatusCode int32 + type CtgkafkaQuotaBrokerDeleteApi struct + func NewCtgkafkaQuotaBrokerDeleteApi(client *core.CtyunClient) *CtgkafkaQuotaBrokerDeleteApi + func (a *CtgkafkaQuotaBrokerDeleteApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQuotaBrokerDeleteResponse, error) + type CtgkafkaQuotaBrokerDeleteRequest struct + ProdInstId string + RegionId string + type CtgkafkaQuotaBrokerDeleteResponse struct + Message string + StatusCode int32 + type CtgkafkaQuotaBrokerQueryApi struct + func NewCtgkafkaQuotaBrokerQueryApi(client *core.CtyunClient) *CtgkafkaQuotaBrokerQueryApi + func (a *CtgkafkaQuotaBrokerQueryApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQuotaBrokerQueryResponse, error) + type CtgkafkaQuotaBrokerQueryRequest struct + ProdInstId string + RegionId string + type CtgkafkaQuotaBrokerQueryResponse struct + Error string + Message string + ReturnObj *CtgkafkaQuotaBrokerQueryReturnObjResponse + StatusCode int32 + type CtgkafkaQuotaBrokerQueryReturnObjResponse struct + ConsumerByteRate int64 + ProducerByteRate int64 + type CtgkafkaQuotaBrokerUpdateApi struct + func NewCtgkafkaQuotaBrokerUpdateApi(client *core.CtyunClient) *CtgkafkaQuotaBrokerUpdateApi + func (a *CtgkafkaQuotaBrokerUpdateApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQuotaBrokerUpdateResponse, error) + type CtgkafkaQuotaBrokerUpdateRequest struct + ConsumerByteRate int64 + ProdInstId string + ProducerByteRate int64 + RegionId string + type CtgkafkaQuotaBrokerUpdateResponse struct + Message string + StatusCode int32 + type CtgkafkaQuotaClientCreateApi struct + func NewCtgkafkaQuotaClientCreateApi(client *core.CtyunClient) *CtgkafkaQuotaClientCreateApi + func (a *CtgkafkaQuotaClientCreateApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQuotaClientCreateResponse, error) + type CtgkafkaQuotaClientCreateRequest struct + Client string + ConsumerByteRate int64 + DefaultClient *bool + DefaultUser *bool + ProdInstId string + ProducerByteRate int64 + RegionId string + User string + type CtgkafkaQuotaClientCreateResponse struct + Message string + StatusCode int32 + type CtgkafkaQuotaClientDeleteApi struct + func NewCtgkafkaQuotaClientDeleteApi(client *core.CtyunClient) *CtgkafkaQuotaClientDeleteApi + func (a *CtgkafkaQuotaClientDeleteApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQuotaClientDeleteResponse, error) + type CtgkafkaQuotaClientDeleteRequest struct + Client string + DefaultClient *bool + DefaultUser *bool + ProdInstId string + RegionId string + User string + type CtgkafkaQuotaClientDeleteResponse struct + Message string + StatusCode int32 + type CtgkafkaQuotaClientListApi struct + func NewCtgkafkaQuotaClientListApi(client *core.CtyunClient) *CtgkafkaQuotaClientListApi + func (a *CtgkafkaQuotaClientListApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQuotaClientListResponse, error) + type CtgkafkaQuotaClientListRequest struct + ProdInstId string + type CtgkafkaQuotaClientListResponse struct + Error string + Message string + ReturnObj *CtgkafkaQuotaClientListReturnObjResponse + StatusCode int32 + type CtgkafkaQuotaClientListReturnObjResponse struct + ClientId string + ConsumerByteRate int64 + DefaultClient *bool + DefaultUser *bool + ProducerByteRate int64 + User string + type CtgkafkaQuotaClientUpdateApi struct + func NewCtgkafkaQuotaClientUpdateApi(client *core.CtyunClient) *CtgkafkaQuotaClientUpdateApi + func (a *CtgkafkaQuotaClientUpdateApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQuotaClientUpdateResponse, error) + type CtgkafkaQuotaClientUpdateRequest struct + Client string + ConsumerByteRate int32 + DefaultClient *bool + DefaultUser *bool + ProdInstId string + ProducerByteRate int32 + RegionId string + User string + type CtgkafkaQuotaClientUpdateResponse struct + Message string + StatusCode int32 + type CtgkafkaQuotaTopicCreateApi struct + func NewCtgkafkaQuotaTopicCreateApi(client *core.CtyunClient) *CtgkafkaQuotaTopicCreateApi + func (a *CtgkafkaQuotaTopicCreateApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQuotaTopicCreateResponse, error) + type CtgkafkaQuotaTopicCreateRequest struct + ConsumerByteRate int64 + ProdInstId string + ProducerByteRate int64 + RegionId string + Topic string + type CtgkafkaQuotaTopicCreateResponse struct + Message string + StatusCode int32 + type CtgkafkaQuotaTopicDeleteApi struct + func NewCtgkafkaQuotaTopicDeleteApi(client *core.CtyunClient) *CtgkafkaQuotaTopicDeleteApi + func (a *CtgkafkaQuotaTopicDeleteApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQuotaTopicDeleteResponse, error) + type CtgkafkaQuotaTopicDeleteRequest struct + ProdInstId string + RegionId string + Topic string + type CtgkafkaQuotaTopicDeleteResponse struct + Message string + StatusCode int32 + type CtgkafkaQuotaTopicListApi struct + func NewCtgkafkaQuotaTopicListApi(client *core.CtyunClient) *CtgkafkaQuotaTopicListApi + func (a *CtgkafkaQuotaTopicListApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQuotaTopicListResponse, error) + type CtgkafkaQuotaTopicListRequest struct + ProdInstId string + RegionId string + type CtgkafkaQuotaTopicListResponse struct + Error string + Message string + ReturnObj *CtgkafkaQuotaTopicListReturnObjResponse + StatusCode int32 + type CtgkafkaQuotaTopicListReturnObjResponse struct + ConsumerByteRate int64 + ProducerByteRate int64 + Topic string + type CtgkafkaQuotaTopicUpdateApi struct + func NewCtgkafkaQuotaTopicUpdateApi(client *core.CtyunClient) *CtgkafkaQuotaTopicUpdateApi + func (a *CtgkafkaQuotaTopicUpdateApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaQuotaTopicUpdateResponse, error) + type CtgkafkaQuotaTopicUpdateRequest struct + ConsumerByteRate int32 + ProdInstId string + ProducerByteRate int32 + RegionId string + Topic string + type CtgkafkaQuotaTopicUpdateResponse struct + Message string + StatusCode int32 + type CtgkafkaReassignmentsApi struct + func NewCtgkafkaReassignmentsApi(client *core.CtyunClient) *CtgkafkaReassignmentsApi + func (a *CtgkafkaReassignmentsApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaReassignmentsResponse, error) + type CtgkafkaReassignmentsPartitionBrokersRequest struct + type CtgkafkaReassignmentsRequest struct + Brokers []int32 + PartitionBrokers *CtgkafkaReassignmentsPartitionBrokersRequest + ProdInstId string + RawType int32 + RegionId string + ScheduleDate string + Throttle int32 + TopicName string + type CtgkafkaReassignmentsResponse struct + Error string + Message string + ReturnObj *CtgkafkaReassignmentsReturnObjResponse + StatusCode int32 + type CtgkafkaReassignmentsReturnObjResponse struct + Data string + type CtgkafkaResourceTagAddtagV3Api struct + func NewCtgkafkaResourceTagAddtagV3Api(client *core.CtyunClient) *CtgkafkaResourceTagAddtagV3Api + func (a *CtgkafkaResourceTagAddtagV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaResourceTagAddtagV3Response, error) + type CtgkafkaResourceTagAddtagV3Request struct + RegionId string + TagName string + type CtgkafkaResourceTagAddtagV3Response struct + Error string + Message string + StatusCode string + type CtgkafkaSaslUserCreateV3Api struct + func NewCtgkafkaSaslUserCreateV3Api(client *core.CtyunClient) *CtgkafkaSaslUserCreateV3Api + func (a *CtgkafkaSaslUserCreateV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaSaslUserCreateV3Response, error) + type CtgkafkaSaslUserCreateV3Request struct + Description string + Password string + ProdInstId string + RegionId string + Username string + type CtgkafkaSaslUserCreateV3Response struct + Error string + Message string + ReturnObj *CtgkafkaSaslUserCreateV3ReturnObjResponse + StatusCode string + type CtgkafkaSaslUserCreateV3ReturnObjResponse struct + Data string + type CtgkafkaSaslUserDeleteV3Api struct + func NewCtgkafkaSaslUserDeleteV3Api(client *core.CtyunClient) *CtgkafkaSaslUserDeleteV3Api + func (a *CtgkafkaSaslUserDeleteV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaSaslUserDeleteV3Response, error) + type CtgkafkaSaslUserDeleteV3Request struct + ProdInstId string + RegionId string + Username string + type CtgkafkaSaslUserDeleteV3Response struct + Error string + Message string + ReturnObj *CtgkafkaSaslUserDeleteV3ReturnObjResponse + StatusCode string + type CtgkafkaSaslUserDeleteV3ReturnObjResponse struct + Data string + type CtgkafkaSaslUserQueryV3Api struct + func NewCtgkafkaSaslUserQueryV3Api(client *core.CtyunClient) *CtgkafkaSaslUserQueryV3Api + func (a *CtgkafkaSaslUserQueryV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaSaslUserQueryV3Response, error) + type CtgkafkaSaslUserQueryV3Request struct + PageNum string + PageSize string + ProdInstId string + RegionId string + Username string + type CtgkafkaSaslUserQueryV3Response struct + Error string + Message string + ReturnObj *CtgkafkaSaslUserQueryV3ReturnObjResponse + StatusCode string + type CtgkafkaSaslUserQueryV3ReturnObjDataResponse struct + Ctime string + Description string + Id int32 + Username string + type CtgkafkaSaslUserQueryV3ReturnObjResponse struct + Data []*CtgkafkaSaslUserQueryV3ReturnObjDataResponse + Total int32 + type CtgkafkaSelectedTopicsV3Api struct + func NewCtgkafkaSelectedTopicsV3Api(client *core.CtyunClient) *CtgkafkaSelectedTopicsV3Api + func (a *CtgkafkaSelectedTopicsV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaSelectedTopicsV3Response, error) + type CtgkafkaSelectedTopicsV3Request struct + GroupName string + ProdInstId string + RegionId string + type CtgkafkaSelectedTopicsV3Response struct + Error string + Message string + ReturnObj *CtgkafkaSelectedTopicsV3ReturnObjResponse + StatusCode string + type CtgkafkaSelectedTopicsV3ReturnObjResponse struct + Data []string + type CtgkafkaSetAcrossVpcInfoApi struct + func NewCtgkafkaSetAcrossVpcInfoApi(client *core.CtyunClient) *CtgkafkaSetAcrossVpcInfoApi + func (a *CtgkafkaSetAcrossVpcInfoApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaSetAcrossVpcInfoResponse, error) + type CtgkafkaSetAcrossVpcInfoRequest struct + ProdInstId string + RegionId string + VpcInfoList []*CtgkafkaSetAcrossVpcInfoVpcInfoListRequest + type CtgkafkaSetAcrossVpcInfoResponse struct + Error string + Message string + ReturnObj *CtgkafkaSetAcrossVpcInfoReturnObjResponse + StatusCode string + type CtgkafkaSetAcrossVpcInfoReturnObjDataResponse struct + type CtgkafkaSetAcrossVpcInfoReturnObjResponse struct + Data *CtgkafkaSetAcrossVpcInfoReturnObjDataResponse + type CtgkafkaSetAcrossVpcInfoVpcInfoListRequest struct + AdvertiseListenerIp string + ListenerIp string + type CtgkafkaSpecExtendApi struct + func NewCtgkafkaSpecExtendApi(client *core.CtyunClient) *CtgkafkaSpecExtendApi + func (a *CtgkafkaSpecExtendApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaSpecExtendResponse, error) + type CtgkafkaSpecExtendRequest struct + AutoPay *bool + ProdInstId string + RegionId string + SpecName string + type CtgkafkaSpecExtendResponse struct + Error string + Message string + ReturnObj *CtgkafkaSpecExtendReturnObjResponse + StatusCode string + type CtgkafkaSpecExtendReturnObjResponse struct + type CtgkafkaSpecShrinkApi struct + func NewCtgkafkaSpecShrinkApi(client *core.CtyunClient) *CtgkafkaSpecShrinkApi + func (a *CtgkafkaSpecShrinkApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaSpecShrinkResponse, error) + type CtgkafkaSpecShrinkRequest struct + ProdInstId string + RegionId string + SpecName string + type CtgkafkaSpecShrinkResponse struct + Error string + Message string + ReturnObj *CtgkafkaSpecShrinkReturnObjResponse + StatusCode string + type CtgkafkaSpecShrinkReturnObjResponse struct + type CtgkafkaTagResourceV3Api struct + func NewCtgkafkaTagResourceV3Api(client *core.CtyunClient) *CtgkafkaTagResourceV3Api + func (a *CtgkafkaTagResourceV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaTagResourceV3Response, error) + type CtgkafkaTagResourceV3Request struct + ProdInstId string + RawType string + RegionId string + ResourceIdList []string + TagId string + type CtgkafkaTagResourceV3Response struct + Error string + Message string + StatusCode string + type CtgkafkaTopicBatchDeleteApi struct + func NewCtgkafkaTopicBatchDeleteApi(client *core.CtyunClient) *CtgkafkaTopicBatchDeleteApi + func (a *CtgkafkaTopicBatchDeleteApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaTopicBatchDeleteResponse, error) + type CtgkafkaTopicBatchDeleteRequest struct + ProdInstId string + RegionId string + TopicNames []string + type CtgkafkaTopicBatchDeleteResponse struct + Error string + Message string + ReturnObj *CtgkafkaTopicBatchDeleteReturnObjResponse + StatusCode int32 + type CtgkafkaTopicBatchDeleteReturnObjResponse struct + Data string + type CtgkafkaTopicCreateV3Api struct + func NewCtgkafkaTopicCreateV3Api(client *core.CtyunClient) *CtgkafkaTopicCreateV3Api + func (a *CtgkafkaTopicCreateV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaTopicCreateV3Response, error) + type CtgkafkaTopicCreateV3Request struct + Description string + FactorNum int32 + MaxMessage int32 + MinReplicas int32 + NeedFlush *bool + PartitionCapacity int32 + PartitionNum int32 + ProdInstId string + RegionId string + RetentionTime int32 + TimestampType string + TopicName string + type CtgkafkaTopicCreateV3Response struct + Error string + Message string + ReturnObj *CtgkafkaTopicCreateV3ReturnObjResponse + StatusCode string + type CtgkafkaTopicCreateV3ReturnObjResponse struct + Data string + type CtgkafkaTopicDeleteV3Api struct + func NewCtgkafkaTopicDeleteV3Api(client *core.CtyunClient) *CtgkafkaTopicDeleteV3Api + func (a *CtgkafkaTopicDeleteV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaTopicDeleteV3Response, error) + type CtgkafkaTopicDeleteV3Request struct + ProdInstId string + RegionId string + TopicName string + type CtgkafkaTopicDeleteV3Response struct + Error string + Message string + ReturnObj *CtgkafkaTopicDeleteV3ReturnObjResponse + StatusCode string + type CtgkafkaTopicDeleteV3ReturnObjResponse struct + Data string + type CtgkafkaTopicDiskusageApi struct + func NewCtgkafkaTopicDiskusageApi(client *core.CtyunClient) *CtgkafkaTopicDiskusageApi + func (a *CtgkafkaTopicDiskusageApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaTopicDiskusageResponse, error) + type CtgkafkaTopicDiskusageRequest struct + MinSize int32 + Percentage int32 + ProdInstId string + RegionId string + Top int32 + type CtgkafkaTopicDiskusageResponse struct + Error string + Message string + ReturnObj *CtgkafkaTopicDiskusageReturnObjResponse + StatusCode int32 + type CtgkafkaTopicDiskusageReturnObjDataResponse struct + BrokerName string + Free int64 + Rate float64 + TopicList []*CtgkafkaTopicDiskusageReturnObjDataTopicListResponse + Total int64 + Used int64 + type CtgkafkaTopicDiskusageReturnObjDataTopicListResponse struct + BrokerName string + DiskUsedRate float64 + PartitionId int32 + Size int64 + Topic string + type CtgkafkaTopicDiskusageReturnObjResponse struct + Data []*CtgkafkaTopicDiskusageReturnObjDataResponse + type CtgkafkaTopicModifyremarkV3Api struct + func NewCtgkafkaTopicModifyremarkV3Api(client *core.CtyunClient) *CtgkafkaTopicModifyremarkV3Api + func (a *CtgkafkaTopicModifyremarkV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaTopicModifyremarkV3Response, error) + type CtgkafkaTopicModifyremarkV3Request struct + ProdInstId string + RegionId string + Remark string + TopicName string + type CtgkafkaTopicModifyremarkV3Response struct + Error string + Message string + ReturnObj *CtgkafkaTopicModifyremarkV3ReturnObjResponse + StatusCode string + type CtgkafkaTopicModifyremarkV3ReturnObjResponse struct + Data string + type CtgkafkaTopicQueryV3Api struct + func NewCtgkafkaTopicQueryV3Api(client *core.CtyunClient) *CtgkafkaTopicQueryV3Api + func (a *CtgkafkaTopicQueryV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaTopicQueryV3Response, error) + type CtgkafkaTopicQueryV3Request struct + PageNum int32 + PageSize int32 + ProdInstId string + RegionId string + TopicName string + type CtgkafkaTopicQueryV3Response struct + Error string + Message string + ReturnObj *CtgkafkaTopicQueryV3ReturnObjResponse + StatusCode string + type CtgkafkaTopicQueryV3ReturnObjDataConfigsResponse struct + type CtgkafkaTopicQueryV3ReturnObjDataResponse struct + Configs *CtgkafkaTopicQueryV3ReturnObjDataConfigsResponse + Factor int32 + Name string + PartitionNum int32 + ProdInstId string + type CtgkafkaTopicQueryV3ReturnObjResponse struct + Data []*CtgkafkaTopicQueryV3ReturnObjDataResponse + MaxPartitions int32 + RemainPartitions int32 + TopicMaxPartitions int32 + Total int32 + type CtgkafkaTopicStatusV3Api struct + func NewCtgkafkaTopicStatusV3Api(client *core.CtyunClient) *CtgkafkaTopicStatusV3Api + func (a *CtgkafkaTopicStatusV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaTopicStatusV3Response, error) + type CtgkafkaTopicStatusV3Request struct + ProdInstId string + RegionId string + TopicName string + type CtgkafkaTopicStatusV3Response struct + Error string + Message string + ReturnObj *CtgkafkaTopicStatusV3ReturnObjResponse + StatusCode string + type CtgkafkaTopicStatusV3ReturnObjDataResponse struct + Begin int64 + End int64 + PartitionId int32 + Total int64 + type CtgkafkaTopicStatusV3ReturnObjResponse struct + Data []*CtgkafkaTopicStatusV3ReturnObjDataResponse + Total int32 + type CtgkafkaTransChargeTypeV3Api struct + func NewCtgkafkaTransChargeTypeV3Api(client *core.CtyunClient) *CtgkafkaTransChargeTypeV3Api + func (a *CtgkafkaTransChargeTypeV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaTransChargeTypeV3Response, error) + type CtgkafkaTransChargeTypeV3Request struct + AutoPay *bool + CycleCnt int32 + ProdInstId string + RegionId string + type CtgkafkaTransChargeTypeV3Response struct + Error string + Message string + ReturnObj *CtgkafkaTransChargeTypeV3ReturnObjResponse + StatusCode string + type CtgkafkaTransChargeTypeV3ReturnObjDataResponse struct + type CtgkafkaTransChargeTypeV3ReturnObjResponse struct + Data *CtgkafkaTransChargeTypeV3ReturnObjDataResponse + type CtgkafkaUnTagResourceV3Api struct + func NewCtgkafkaUnTagResourceV3Api(client *core.CtyunClient) *CtgkafkaUnTagResourceV3Api + func (a *CtgkafkaUnTagResourceV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaUnTagResourceV3Response, error) + type CtgkafkaUnTagResourceV3Request struct + ProdInstId string + RawType string + RegionId string + ResourceIdList []string + TagId string + type CtgkafkaUnTagResourceV3Response struct + Error string + Message string + StatusCode string + type CtgkafkaUnbindElasticIpApi struct + func NewCtgkafkaUnbindElasticIpApi(client *core.CtyunClient) *CtgkafkaUnbindElasticIpApi + func (a *CtgkafkaUnbindElasticIpApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaUnbindElasticIpResponse, error) + type CtgkafkaUnbindElasticIpRequest struct + ElasticIp string + PaasInstanceId string + RegionId string + type CtgkafkaUnbindElasticIpResponse struct + Error string + Message string + ReturnObj *CtgkafkaUnbindElasticIpReturnObjResponse + StatusCode string + type CtgkafkaUnbindElasticIpReturnObjResponse struct + Data string + type CtgkafkaUnsubscribeInstV3Api struct + func NewCtgkafkaUnsubscribeInstV3Api(client *core.CtyunClient) *CtgkafkaUnsubscribeInstV3Api + func (a *CtgkafkaUnsubscribeInstV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaUnsubscribeInstV3Response, error) + type CtgkafkaUnsubscribeInstV3Request struct + ProdInstId string + RegionId string + type CtgkafkaUnsubscribeInstV3Response struct + Error string + Message string + ReturnObj *CtgkafkaUnsubscribeInstV3ReturnObjResponse + StatusCode string + type CtgkafkaUnsubscribeInstV3ReturnObjBatchOrderPlacementResultsOrderPlacedEventsResponse struct + ErrorMessage string + NewOrderId string + NewOrderNo string + Submitted *bool + TotalPrice float64 + type CtgkafkaUnsubscribeInstV3ReturnObjBatchOrderPlacementResultsResponse struct + ErrorMessage string + OrderPlacedEvents []*CtgkafkaUnsubscribeInstV3ReturnObjBatchOrderPlacementResultsOrderPlacedEventsResponse + Submitted *bool + type CtgkafkaUnsubscribeInstV3ReturnObjResponse struct + BatchOrderPlacementResults []*CtgkafkaUnsubscribeInstV3ReturnObjBatchOrderPlacementResultsResponse + ErrorMessage string + type CtgkafkaUpdateInstanceConfigApi struct + func NewCtgkafkaUpdateInstanceConfigApi(client *core.CtyunClient) *CtgkafkaUpdateInstanceConfigApi + func (a *CtgkafkaUpdateInstanceConfigApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaUpdateInstanceConfigResponse, error) + type CtgkafkaUpdateInstanceConfigDynamicConfigsRequest struct + Name string + Value string + type CtgkafkaUpdateInstanceConfigRequest struct + DynamicConfigs []*CtgkafkaUpdateInstanceConfigDynamicConfigsRequest + ProdInstId string + RegionId string + StaticConfigs []*CtgkafkaUpdateInstanceConfigStaticConfigsRequest + type CtgkafkaUpdateInstanceConfigResponse struct + Error string + Message string + ReturnObj ... + StatusCode string + type CtgkafkaUpdateInstanceConfigStaticConfigsRequest struct + Name string + Value string + type CtgkafkaUpdateTopicApi struct + func NewCtgkafkaUpdateTopicApi(client *core.CtyunClient) *CtgkafkaUpdateTopicApi + func (a *CtgkafkaUpdateTopicApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaUpdateTopicResponse, error) + type CtgkafkaUpdateTopicRequest struct + MaxMessage int32 + PartitionCapacity int32 + ProdInstId string + RegionId string + RetentionTime int32 + TimestampType string + TopicName string + type CtgkafkaUpdateTopicResponse struct + Error string + Message string + ReturnObj *CtgkafkaUpdateTopicReturnObjResponse + StatusCode int32 + type CtgkafkaUpdateTopicReturnObjResponse struct + Data string + type CtgkafkaUpgradeInstanceVersionV3Api struct + func NewCtgkafkaUpgradeInstanceVersionV3Api(client *core.CtyunClient) *CtgkafkaUpgradeInstanceVersionV3Api + func (a *CtgkafkaUpgradeInstanceVersionV3Api) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaUpgradeInstanceVersionV3Response, error) + type CtgkafkaUpgradeInstanceVersionV3Request struct + ProdInstId string + RegionId string + UpdateVersion string + type CtgkafkaUpgradeInstanceVersionV3Response struct + Error string + Message string + ReturnObj *CtgkafkaUpgradeInstanceVersionV3ReturnObjResponse + StatusCode string + type CtgkafkaUpgradeInstanceVersionV3ReturnObjDataResponse struct + type CtgkafkaUpgradeInstanceVersionV3ReturnObjResponse struct + Data *CtgkafkaUpgradeInstanceVersionV3ReturnObjDataResponse + type CtgkafkaUserUpdateApi struct + func NewCtgkafkaUserUpdateApi(client *core.CtyunClient) *CtgkafkaUserUpdateApi + func (a *CtgkafkaUserUpdateApi) Do(ctx context.Context, credential core.Credential, ...) (*CtgkafkaUserUpdateResponse, error) + type CtgkafkaUserUpdateRequest struct + Description string + NewPassword string + ProdInstId string + RegionId string + Username string + type CtgkafkaUserUpdateResponse struct + Error string + Message string + ReturnObj *CtgkafkaUserUpdateReturnObjResponse + StatusCode string + type CtgkafkaUserUpdateReturnObjResponse struct + Data string v0 v0.0.1-test Sep 25, 2025
Go to main page