import { AbstractClient } from "../../../common/abstract_client"; import { ClientConfig } from "../../../common/interface"; import { DescribeACLRequest, DescribeTopicSyncReplicaResponse, FetchMessageByOffsetRequest, AuthorizeTokenResponse, DescribeAclRuleResponse, CancelAuthorizationTokenRequest, DeleteTopicRequest, FetchMessageListByOffsetRequest, CreateAclRuleRequest, DescribeInstancesDetailResponse, DescribeTaskStatusRequest, DescribeAclRuleRequest, RestartDatahubTaskRequest, ModifyAclRuleResponse, FetchMessageListByOffsetResponse, DeleteRouteTriggerTimeRequest, CreatePostPaidInstanceRequest, AuthorizeTokenRequest, RenewCkafkaInstanceResponse, CreatePartitionResponse, DescribeTopicResponse, CreateTopicIpWhiteListResponse, CreateTopicRequest, DeleteAclResponse, DescribeDatahubGroupOffsetsResponse, DeleteConnectResourceResponse, RestartDatahubTaskResponse, DescribeTopicRequest, ModifyAclRuleRequest, ModifyRoutineMaintenanceTaskRequest, DescribeInstanceAttributesResponse, DescribeRegionResponse, CreateTopicResponse, UpgradeBrokerVersionResponse, DescribeConsumerGroupResponse, DeleteDatahubTaskResponse, DescribeDatahubTopicsResponse, BatchCreateAclResponse, DeleteRouteRequest, BatchModifyTopicAttributesResponse, DescribeTopicDetailRequest, DescribeGroupOffsetsResponse, DeleteGroupResponse, CreateTokenResponse, DescribeGroupOffsetsRequest, DescribeTopicDetailResponse, DeleteAclRequest, DescribeDatahubTaskResponse, FetchLatestDatahubMessageListRequest, PauseDatahubTaskResponse, CreateConnectResourceResponse, DescribeDatahubTasksResponse, FetchMessageByOffsetResponse, DescribeSecurityGroupRoutesResponse, DescribeACLResponse, InquireCkafkaPriceRequest, DescribeCkafkaZoneRequest, FetchMessageListByTimestampRequest, DeleteConnectResourceRequest, DescribeTopicAttributesResponse, CreateConsumerResponse, DescribeGroupResponse, DeleteUserResponse, CreateAclRequest, CreateConnectResourceRequest, ModifyInstanceAttributesResponse, DescribeRegionRequest, DescribeGroupInfoResponse, ModifyInstanceAttributesRequest, CreateAclRuleResponse, FetchDatahubMessageByOffsetResponse, DeleteDatahubTaskRequest, ModifyConnectResourceResponse, DescribeGroupRequest, InstanceScalingDownRequest, CreateCdcClusterRequest, DeleteTopicIpWhiteListResponse, DescribeInstancesDetailRequest, CreateConsumerRequest, CreateDatahubTopicResponse, FetchDatahubMessageByOffsetRequest, DescribeDatahubGroupOffsetsRequest, BatchModifyGroupOffsetsRequest, ModifyInstancePreRequest, DescribeTypeInstancesRequest, SendMessageRequest, BatchModifyTopicAttributesRequest, DescribePrometheusRequest, FetchMessageListByTimestampResponse, DeleteInstancePostResponse, ModifyDatahubTopicRequest, ModifyDatahubTaskResponse, DescribeConnectResourcesResponse, DescribeCkafkaVersionResponse, DeleteUserRequest, DescribeTopicAttributesRequest, DescribeDatahubTaskRequest, FetchLatestDatahubMessageListResponse, DescribeInstancesResponse, UpgradeBrokerVersionRequest, DescribeTopicSubscribeGroupResponse, DeleteAclRuleRequest, DescribeTypeInstancesResponse, ModifyConnectResourceRequest, CreateTokenRequest, DescribeCvmInfoRequest, DescribeTaskStatusResponse, DescribeModifyTypeRequest, CreateUserResponse, DeleteInstancePostRequest, DescribeTopicProduceConnectionRequest, DescribeTopicSubscribeGroupRequest, DeleteAclRuleResponse, DescribeGroupInfoRequest, DescribeDatahubTopicsRequest, DescribeUserResponse, DeleteInstancePreRequest, DeleteGroupSubscribeTopicRequest, PauseDatahubTaskRequest, DescribeInstancesRequest, DescribeCkafkaZoneResponse, ModifyInstancePreResponse, CreateUserRequest, CreateInstancePreResponse, CheckCdcClusterRequest, InstanceScalingDownResponse, DescribeRouteRequest, CreatePostPaidInstanceResponse, DescribeRouteResponse, ModifyDatahubTopicResponse, CreateTopicIpWhiteListRequest, ResumeDatahubTaskResponse, ModifyTopicAttributesRequest, CreateInstancePreRequest, DeleteTopicResponse, BatchCreateAclRequest, ResumeDatahubTaskRequest, DescribeConnectResourcesRequest, CreatePartitionRequest, DescribeInstanceAttributesRequest, CancelAuthorizationTokenResponse, CreateRouteRequest, DescribePrometheusResponse, CheckCdcClusterResponse, DescribeDatahubTasksRequest, DescribeTopicFlowRankingRequest, BatchModifyGroupOffsetsResponse, CreateDatahubTopicRequest, DescribeDatahubTopicResponse, CreateCdcClusterResponse, DeleteGroupRequest, DescribeConnectResourceRequest, DeleteRouteResponse, CreatePrometheusResponse, ModifyGroupOffsetsResponse, CreateAclResponse, DeleteInstancePreResponse, DescribeCvmInfoResponse, DeleteRouteTriggerTimeResponse, DescribeUserRequest, DescribeModifyTypeResponse, DescribeDatahubTopicRequest, ModifyPasswordRequest, DeleteDatahubTopicRequest, ModifyTopicAttributesResponse, DescribeConsumerGroupRequest, DescribeTopicProduceConnectionResponse, DeleteDatahubTopicResponse, SendMessageResponse, ModifyRoutineMaintenanceTaskResponse, DescribeConnectResourceResponse, DescribeSecurityGroupRoutesRequest, ModifyPasswordResponse, DeleteGroupSubscribeTopicResponse, InquireCkafkaPriceResponse, CreateRouteResponse, DescribeTopicFlowRankingResponse, CreateDatahubTaskRequest, ModifyGroupOffsetsRequest, RenewCkafkaInstanceRequest, DeleteTopicIpWhiteListRequest, CreateDatahubTaskResponse, DescribeTopicSyncReplicaRequest, ModifyDatahubTaskRequest, CreatePrometheusRequest, DescribeCkafkaVersionRequest } from "./ckafka_models"; /** * ckafka client * @class */ export declare class Client extends AbstractClient { constructor(clientConfig: ClientConfig); /** * 获取消费分组信息 */ DescribeGroupInfo(req: DescribeGroupInfoRequest, cb?: (error: string, rep: DescribeGroupInfoResponse) => void): Promise; /** * 本接口用于获取实例对应后端CVM信息,包括cvmId和ip等。用于专业版,标准版返回数据为空 */ DescribeCvmInfo(req: DescribeCvmInfoRequest, cb?: (error: string, rep: DescribeCvmInfoResponse) => void): Promise; /** * 预付费实例变配接口,调整磁盘,带宽, 分区 */ ModifyInstancePre(req: ModifyInstancePreRequest, cb?: (error: string, rep: ModifyInstancePreResponse) => void): Promise; /** * 通过HTTP接入层发送消息 */ SendMessage(req: SendMessageRequest, cb?: (error: string, rep: SendMessageResponse) => void): Promise; /** * 删除Datahub连接源 */ DeleteConnectResource(req: DeleteConnectResourceRequest, cb?: (error: string, rep: DeleteConnectResourceResponse) => void): Promise; /** * 删除消费分组订阅的topic(消费分组必须是Empty 状态) */ DeleteGroupSubscribeTopic(req: DeleteGroupSubscribeTopicRequest, cb?: (error: string, rep: DeleteGroupSubscribeTopicResponse) => void): Promise; /** * 查询用户信息 */ DescribeUser(req: DescribeUserRequest, cb?: (error: string, rep: DescribeUserResponse) => void): Promise; /** * 获取Datahub消费分组offset */ DescribeDatahubGroupOffsets(req: DescribeDatahubGroupOffsetsRequest, cb?: (error: string, rep: DescribeDatahubGroupOffsetsResponse) => void): Promise; /** * 查询消费分组信息 */ DescribeConsumerGroup(req: DescribeConsumerGroupRequest, cb?: (error: string, rep: DescribeConsumerGroupResponse) => void): Promise; /** * 创建ckafka主题 */ CreateTopic(req: CreateTopicRequest, cb?: (error: string, rep: CreateTopicResponse) => void): Promise; /** * 查询Datahub任务信息 */ DescribeDatahubTask(req: DescribeDatahubTaskRequest, cb?: (error: string, rep: DescribeDatahubTaskResponse) => void): Promise; /** * 用于查询cdc-ckafka任务状态 */ CheckCdcCluster(req: CheckCdcClusterRequest, cb?: (error: string, rep: CheckCdcClusterResponse) => void): Promise; /** * 获取Topic流量排行,消费者流量排行 */ DescribeTopicFlowRanking(req: DescribeTopicFlowRankingRequest, cb?: (error: string, rep: DescribeTopicFlowRankingResponse) => void): Promise; /** * 本接口用于增加主题中的分区 */ CreatePartition(req: CreatePartitionRequest, cb?: (error: string, rep: CreatePartitionResponse) => void): Promise; /** * 查询最新消息列表 */ FetchLatestDatahubMessageList(req: FetchLatestDatahubMessageListRequest, cb?: (error: string, rep: FetchLatestDatahubMessageListResponse) => void): Promise; /** * 创建最高权限的token */ CreateToken(req: CreateTokenRequest, cb?: (error: string, rep: CreateTokenResponse) => void): Promise; /** * 删除预付费实例,该接口会对实例执行隔离并删除的动作,执行成功后实例会被直接删除销毁。通过调用API删除不会对连接器和任务进行关联预检查,直接进行实例销毁。 */ DeleteInstancePre(req: DeleteInstancePreRequest, cb?: (error: string, rep: DeleteInstancePreResponse) => void): Promise; /** * 用户账户下获取实例列表详情 */ DescribeInstancesDetail(req: DescribeInstancesDetailRequest, cb?: (error: string, rep: DescribeInstancesDetailResponse) => void): Promise; /** * 按量实例缩容 */ InstanceScalingDown(req: InstanceScalingDownRequest, cb?: (error: string, rep: InstanceScalingDownResponse) => void): Promise; /** * 获取主题属性 */ DescribeTopicAttributes(req: DescribeTopicAttributesRequest, cb?: (error: string, rep: DescribeTopicAttributesResponse) => void): Promise; /** * 根据时间戳查询消息列表 */ FetchMessageListByTimestamp(req: FetchMessageListByTimestampRequest, cb?: (error: string, rep: FetchMessageListByTimestampResponse) => void): Promise; /** * 恢复Dip任务 */ ResumeDatahubTask(req: ResumeDatahubTaskRequest, cb?: (error: string, rep: ResumeDatahubTaskResponse) => void): Promise; /** * 添加 ACL 规则 */ CreateAclRule(req: CreateAclRuleRequest, cb?: (error: string, rep: CreateAclRuleResponse) => void): Promise; /** * 添加用户 */ CreateUser(req: CreateUserRequest, cb?: (error: string, rep: CreateUserResponse) => void): Promise; /** * 修改密码 */ ModifyPassword(req: ModifyPasswordRequest, cb?: (error: string, rep: ModifyPasswordResponse) => void): Promise; /** * 续费Ckafka实例, 目前只支持国内站包年包月实例续费 */ RenewCkafkaInstance(req: RenewCkafkaInstanceRequest, cb?: (error: string, rep: RenewCkafkaInstanceResponse) => void): Promise; /** * 查询ACL规则列表 */ DescribeAclRule(req: DescribeAclRuleRequest, cb?: (error: string, rep: DescribeAclRuleResponse) => void): Promise; /** * 获取实例Prometheus信息 */ DescribePrometheus(req: DescribePrometheusRequest, cb?: (error: string, rep: DescribePrometheusResponse) => void): Promise; /** * broker版本升级 */ UpgradeBrokerVersion(req: UpgradeBrokerVersionRequest, cb?: (error: string, rep: UpgradeBrokerVersionResponse) => void): Promise; /** * 查询Datahub任务列表 */ DescribeDatahubTasks(req: DescribeDatahubTasksRequest, cb?: (error: string, rep: DescribeDatahubTasksResponse) => void): Promise; /** * 修改DIP主题属性 */ ModifyDatahubTopic(req: ModifyDatahubTopicRequest, cb?: (error: string, rep: ModifyDatahubTopicResponse) => void): Promise; /** * 根据位点查询消息列表 */ FetchMessageListByOffset(req: FetchMessageListByOffsetRequest, cb?: (error: string, rep: FetchMessageListByOffsetResponse) => void): Promise; /** * 创建DIP主题 */ CreateDatahubTopic(req: CreateDatahubTopicRequest, cb?: (error: string, rep: CreateDatahubTopicResponse) => void): Promise; /** * 取消授权token */ CancelAuthorizationToken(req: CancelAuthorizationTokenRequest, cb?: (error: string, rep: CancelAuthorizationTokenResponse) => void): Promise; /** * 删除DIP主题 */ DeleteDatahubTopic(req: DeleteDatahubTopicRequest, cb?: (error: string, rep: DeleteDatahubTopicResponse) => void): Promise; /** * 创建Datahub连接源 */ CreateConnectResource(req: CreateConnectResourceRequest, cb?: (error: string, rep: CreateConnectResourceResponse) => void): Promise; /** * 根据指定offset位置的消息 */ FetchDatahubMessageByOffset(req: FetchDatahubMessageByOffsetRequest, cb?: (error: string, rep: FetchDatahubMessageByOffsetResponse) => void): Promise; /** * 删除ACL */ DeleteAcl(req: DeleteAclRequest, cb?: (error: string, rep: DeleteAclResponse) => void): Promise; /** * 获取实例属性 */ DescribeInstanceAttributes(req: DescribeInstanceAttributesRequest, cb?: (error: string, rep: DescribeInstanceAttributesResponse) => void): Promise; /** * 获取Topic 副本详情信息 */ DescribeTopicSyncReplica(req: DescribeTopicSyncReplicaRequest, cb?: (error: string, rep: DescribeTopicSyncReplicaResponse) => void): Promise; /** * 给实例授权token */ AuthorizeToken(req: AuthorizeTokenRequest, cb?: (error: string, rep: AuthorizeTokenResponse) => void): Promise; /** * 获取DIP主题属性 */ DescribeDatahubTopic(req: DescribeDatahubTopicRequest, cb?: (error: string, rep: DescribeDatahubTopicResponse) => void): Promise; /** * 用于查看ckafka的可用区列表 */ DescribeCkafkaZone(req: DescribeCkafkaZoneRequest, cb?: (error: string, rep: DescribeCkafkaZoneResponse) => void): Promise; /** * Datahub任务异常时,重启Datahub任务 */ RestartDatahubTask(req: RestartDatahubTaskRequest, cb?: (error: string, rep: RestartDatahubTaskResponse) => void): Promise; /** * 查看路由信息 */ DescribeRoute(req: DescribeRouteRequest, cb?: (error: string, rep: DescribeRouteResponse) => void): Promise; /** * 修改Datahub任务 */ ModifyDatahubTask(req: ModifyDatahubTaskRequest, cb?: (error: string, rep: ModifyDatahubTaskResponse) => void): Promise; /** * 查询Datahub连接源 */ DescribeConnectResource(req: DescribeConnectResourceRequest, cb?: (error: string, rep: DescribeConnectResourceResponse) => void): Promise; /** * 批量设置主题属性 */ BatchModifyTopicAttributes(req: BatchModifyTopicAttributesRequest, cb?: (error: string, rep: BatchModifyTopicAttributesResponse) => void): Promise; /** * 删除路由 */ DeleteRoute(req: DeleteRouteRequest, cb?: (error: string, rep: DeleteRouteResponse) => void): Promise; /** * 本接口用于修改主题属性。 */ ModifyTopicAttributes(req: ModifyTopicAttributesRequest, cb?: (error: string, rep: ModifyTopicAttributesResponse) => void): Promise; /** * 创建主题ip白名单 */ CreateTopicIpWhiteList(req: CreateTopicIpWhiteListRequest, cb?: (error: string, rep: CreateTopicIpWhiteListResponse) => void): Promise; /** * 查询实例版本信息 */ DescribeCkafkaVersion(req: DescribeCkafkaVersionRequest, cb?: (error: string, rep: DescribeCkafkaVersionResponse) => void): Promise; /** * 设置Groups 消费分组offset */ ModifyGroupOffsets(req: ModifyGroupOffsetsRequest, cb?: (error: string, rep: ModifyGroupOffsetsResponse) => void): Promise; /** * 设置实例属性 */ ModifyInstanceAttributes(req: ModifyInstanceAttributesRequest, cb?: (error: string, rep: ModifyInstanceAttributesResponse) => void): Promise; /** * 删除消费组 */ DeleteGroup(req: DeleteGroupRequest, cb?: (error: string, rep: DeleteGroupResponse) => void): Promise; /** * 删除后付费实例,通过调用API删除不会对连接器和任务进行关联预检查,直接进行实例销毁。 */ DeleteInstancePost(req: DeleteInstancePostRequest, cb?: (error: string, rep: DeleteInstancePostResponse) => void): Promise; /** * 枚举ACL */ DescribeACL(req: DescribeACLRequest, cb?: (error: string, rep: DescribeACLResponse) => void): Promise; /** * 创建实例(预付费包年包月), 仅支持创建专业版实例 */ CreateInstancePre(req: CreateInstancePreRequest, cb?: (error: string, rep: CreateInstancePreResponse) => void): Promise; /** * 删除主题IP白名单 */ DeleteTopicIpWhiteList(req: DeleteTopicIpWhiteListRequest, cb?: (error: string, rep: DeleteTopicIpWhiteListResponse) => void): Promise; /** * 查询任务状态 */ DescribeTaskStatus(req: DescribeTaskStatusRequest, cb?: (error: string, rep: DescribeTaskStatusResponse) => void): Promise; /** * 当前接口用来替代 CreateInstancePost 接口。创建按量计费实例。通常用于 SDK 或云 API 控制台调用接口,创建后付费 CKafka 实例。调用接口与在 CKafka 控制台购买按量付费实例效果相同。 */ CreatePostPaidInstance(req: CreatePostPaidInstanceRequest, cb?: (error: string, rep: CreatePostPaidInstanceResponse) => void): Promise; /** * 批量添加ACL策略 */ BatchCreateAcl(req: BatchCreateAclRequest, cb?: (error: string, rep: BatchCreateAclResponse) => void): Promise; /** * 创建DIP转储任务 */ CreateDatahubTask(req: CreateDatahubTaskRequest, cb?: (error: string, rep: CreateDatahubTaskResponse) => void): Promise; /** * 删除ACL规则 */ DeleteAclRule(req: DeleteAclRuleRequest, cb?: (error: string, rep: DeleteAclRuleResponse) => void): Promise; /** * 修改ACL策略,目前只支持预设规则的是否应用到新增topic这一项的修改 */ ModifyAclRule(req: ModifyAclRuleRequest, cb?: (error: string, rep: ModifyAclRuleResponse) => void): Promise; /** * 删除用户 */ DeleteUser(req: DeleteUserRequest, cb?: (error: string, rep: DeleteUserResponse) => void): Promise; /** * 查询topic 生产端连接信息 */ DescribeTopicProduceConnection(req: DescribeTopicProduceConnectionRequest, cb?: (error: string, rep: DescribeTopicProduceConnectionResponse) => void): Promise; /** * 接口请求域名:https://ckafka.tencentcloudapi.com 本接口(DescribeTopic)用于在用户获取消息队列 CKafka 实例的主题列表 */ DescribeTopic(req: DescribeTopicRequest, cb?: (error: string, rep: DescribeTopicResponse) => void): Promise; /** * 查询Datahub连接源列表 */ DescribeConnectResources(req: DescribeConnectResourcesRequest, cb?: (error: string, rep: DescribeConnectResourcesResponse) => void): Promise; /** * 查询实例变配类型 */ DescribeModifyType(req: DescribeModifyTypeRequest, cb?: (error: string, rep: DescribeModifyTypeResponse) => void): Promise; /** * 暂停Dip任务 */ PauseDatahubTask(req: PauseDatahubTaskRequest, cb?: (error: string, rep: PauseDatahubTaskResponse) => void): Promise; /** * 创建消费者组 */ CreateConsumer(req: CreateConsumerRequest, cb?: (error: string, rep: CreateConsumerResponse) => void): Promise; /** * 本接口(DescribeTypeInstances)用于在用户账户下获取指定类型消息队列 CKafka 实例列表 */ DescribeTypeInstances(req: DescribeTypeInstancesRequest, cb?: (error: string, rep: DescribeTypeInstancesResponse) => void): Promise; /** * 查询DIP主题列表 */ DescribeDatahubTopics(req: DescribeDatahubTopicsRequest, cb?: (error: string, rep: DescribeDatahubTopicsResponse) => void): Promise; /** * 获取安全组路由信息列表 */ DescribeSecurityGroupRoutes(req: DescribeSecurityGroupRoutesRequest, cb?: (error: string, rep: DescribeSecurityGroupRoutesResponse) => void): Promise; /** * 删除Dip任务 */ DeleteDatahubTask(req: DeleteDatahubTaskRequest, cb?: (error: string, rep: DeleteDatahubTaskResponse) => void): Promise; /** * 枚举消费分组(精简版) */ DescribeGroup(req: DescribeGroupRequest, cb?: (error: string, rep: DescribeGroupResponse) => void): Promise; /** * 本接口(DescribeInstances)用于在用户账户下获取消息队列 CKafka 实例列表 */ DescribeInstances(req: DescribeInstancesRequest, cb?: (error: string, rep: DescribeInstancesResponse) => void): Promise; /** * 添加实例路由 */ CreateRoute(req: CreateRouteRequest, cb?: (error: string, rep: CreateRouteResponse) => void): Promise; /** * 获取主题列表详情(仅控制台调用) */ DescribeTopicDetail(req: DescribeTopicDetailRequest, cb?: (error: string, rep: DescribeTopicDetailResponse) => void): Promise; /** * 根据指定offset位置的消息 */ FetchMessageByOffset(req: FetchMessageByOffsetRequest, cb?: (error: string, rep: FetchMessageByOffsetResponse) => void): Promise; /** * 编辑Datahub连接源 */ ModifyConnectResource(req: ModifyConnectResourceRequest, cb?: (error: string, rep: ModifyConnectResourceResponse) => void): Promise; /** * 添加 ACL 策略 */ CreateAcl(req: CreateAclRequest, cb?: (error: string, rep: CreateAclResponse) => void): Promise; /** * 查询订阅某主题消息分组信息 */ DescribeTopicSubscribeGroup(req: DescribeTopicSubscribeGroupRequest, cb?: (error: string, rep: DescribeTopicSubscribeGroupResponse) => void): Promise; /** * 设置自动化运维属性 */ ModifyRoutineMaintenanceTask(req: ModifyRoutineMaintenanceTaskRequest, cb?: (error: string, rep: ModifyRoutineMaintenanceTaskResponse) => void): Promise; /** * 添加普罗米修斯监控 */ CreatePrometheus(req: CreatePrometheusRequest, cb?: (error: string, rep: CreatePrometheusResponse) => void): Promise; /** * 修改删除路由延迟触发时间 */ DeleteRouteTriggerTime(req: DeleteRouteTriggerTimeRequest, cb?: (error: string, rep: DeleteRouteTriggerTimeResponse) => void): Promise; /** * 批量修改消费组offset */ BatchModifyGroupOffsets(req: BatchModifyGroupOffsetsRequest, cb?: (error: string, rep: BatchModifyGroupOffsetsResponse) => void): Promise; /** * 获取消费分组offset */ DescribeGroupOffsets(req: DescribeGroupOffsetsRequest, cb?: (error: string, rep: DescribeGroupOffsetsResponse) => void): Promise; /** * 枚举地域,只支持广州地域 */ DescribeRegion(req: DescribeRegionRequest, cb?: (error: string, rep: DescribeRegionResponse) => void): Promise; /** * 用于cdc的专用ckafka集群 */ CreateCdcCluster(req: CreateCdcClusterRequest, cb?: (error: string, rep: CreateCdcClusterResponse) => void): Promise; /** * 删除ckafka主题 */ DeleteTopic(req: DeleteTopicRequest, cb?: (error: string, rep: DeleteTopicResponse) => void): Promise; /** * Ckafka实例购买/续费询价 */ InquireCkafkaPrice(req: InquireCkafkaPriceRequest, cb?: (error: string, rep: InquireCkafkaPriceResponse) => void): Promise; }