-
Notifications
You must be signed in to change notification settings - Fork 97
/
ckafka_client.js
536 lines (536 loc) · 14.6 KB
/
ckafka_client.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.Client = void 0;
/* eslint-disable @typescript-eslint/no-unused-vars */
/*
* Copyright (c) 2018 THL A29 Limited, a Tencent company. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
const abstract_client_1 = require("../../../common/abstract_client");
/**
* ckafka client
* @class
*/
class Client extends abstract_client_1.AbstractClient {
constructor(clientConfig) {
super("ckafka.tencentcloudapi.com", "2019-08-19", clientConfig);
}
/**
* 续费Ckafka实例, 目前只支持国内站包年包月实例续费
*/
async RenewCkafkaInstance(req, cb) {
return this.request("RenewCkafkaInstance", req, cb);
}
/**
* 查看路由信息
*/
async DescribeRoute(req, cb) {
return this.request("DescribeRoute", req, cb);
}
/**
* 获取消费分组信息
*/
async DescribeGroupInfo(req, cb) {
return this.request("DescribeGroupInfo", req, cb);
}
/**
* 创建消费者组
*/
async CreateConsumer(req, cb) {
return this.request("CreateConsumer", req, cb);
}
/**
* 查询消费分组信息
*/
async DescribeConsumerGroup(req, cb) {
return this.request("DescribeConsumerGroup", req, cb);
}
/**
* 查询Datahub连接源
*/
async DescribeConnectResource(req, cb) {
return this.request("DescribeConnectResource", req, cb);
}
/**
* 由于出参需要更新,当前接口将会在未来版本中废弃,建议用户迁移使用 CreatePostPaidInstance 接口。创建按量计费实例。通常用于 SDK 或云 API 控制台调用接口,创建后付费 CKafka 实例。调用接口与在 CKafka 控制台购买按量付费实例效果相同。
*/
async CreateInstancePost(req, cb) {
return this.request("CreateInstancePost", req, cb);
}
/**
* 查询ACL规则列表
*/
async DescribeAclRule(req, cb) {
return this.request("DescribeAclRule", req, cb);
}
/**
* 查询订阅某主题消息分组信息
*/
async DescribeTopicSubscribeGroup(req, cb) {
return this.request("DescribeTopicSubscribeGroup", req, cb);
}
/**
* 预付费实例变配接口,调整磁盘,带宽
*/
async ModifyInstancePre(req, cb) {
return this.request("ModifyInstancePre", req, cb);
}
/**
* 获取主题列表详情(仅控制台调用)
*/
async DescribeTopicDetail(req, cb) {
return this.request("DescribeTopicDetail", req, cb);
}
/**
* 批量设置主题属性
*/
async BatchModifyTopicAttributes(req, cb) {
return this.request("BatchModifyTopicAttributes", req, cb);
}
/**
* 删除路由
*/
async DeleteRoute(req, cb) {
return this.request("DeleteRoute", req, cb);
}
/**
* 通过HTTP接入层发送消息
*/
async SendMessage(req, cb) {
return this.request("SendMessage", req, cb);
}
/**
* 修改DIP主题属性
*/
async ModifyDatahubTopic(req, cb) {
return this.request("ModifyDatahubTopic", req, cb);
}
/**
* 设置自动化运维属性
*/
async ModifyRoutineMaintenanceTask(req, cb) {
return this.request("ModifyRoutineMaintenanceTask", req, cb);
}
/**
* 创建主题ip白名单
*/
async CreateTopicIpWhiteList(req, cb) {
return this.request("CreateTopicIpWhiteList", req, cb);
}
/**
* 删除Datahub连接源
*/
async DeleteConnectResource(req, cb) {
return this.request("DeleteConnectResource", req, cb);
}
/**
* 枚举消费分组(精简版)
*/
async DescribeGroup(req, cb) {
return this.request("DescribeGroup", req, cb);
}
/**
* 根据位点查询消息列表
*/
async FetchMessageListByOffset(req, cb) {
return this.request("FetchMessageListByOffset", req, cb);
}
/**
* 修改Datahub任务
*/
async ModifyDatahubTask(req, cb) {
return this.request("ModifyDatahubTask", req, cb);
}
/**
* 查询Datahub任务列表
*/
async DescribeDatahubTasks(req, cb) {
return this.request("DescribeDatahubTasks", req, cb);
}
/**
* 本接口(DescribeInstance)用于在用户账户下获取消息队列 CKafka 实例列表
*/
async DescribeInstances(req, cb) {
return this.request("DescribeInstances", req, cb);
}
/**
* 获取Topic 副本详情信息
*/
async DescribeTopicSyncReplica(req, cb) {
return this.request("DescribeTopicSyncReplica", req, cb);
}
/**
* 添加实例路由
*/
async CreateRoute(req, cb) {
return this.request("CreateRoute", req, cb);
}
/**
* 删除Dip任务
*/
async DeleteDatahubTask(req, cb) {
return this.request("DeleteDatahubTask", req, cb);
}
/**
* 删除消费组
*/
async DeleteGroup(req, cb) {
return this.request("DeleteGroup", req, cb);
}
/**
* 查询用户信息
*/
async DescribeUser(req, cb) {
return this.request("DescribeUser", req, cb);
}
/**
* 获取实例Prometheus信息
*/
async DescribePrometheus(req, cb) {
return this.request("DescribePrometheus", req, cb);
}
/**
* 创建DIP主题
*/
async CreateDatahubTopic(req, cb) {
return this.request("CreateDatahubTopic", req, cb);
}
/**
* 删除后付费实例
*/
async DeleteInstancePost(req, cb) {
return this.request("DeleteInstancePost", req, cb);
}
/**
* 枚举ACL
*/
async DescribeACL(req, cb) {
return this.request("DescribeACL", req, cb);
}
/**
* 查询DIP主题列表
*/
async DescribeDatahubTopics(req, cb) {
return this.request("DescribeDatahubTopics", req, cb);
}
/**
* 取消授权token
*/
async CancelAuthorizationToken(req, cb) {
return this.request("CancelAuthorizationToken", req, cb);
}
/**
* 创建实例(预付费包年包月), 仅支持创建专业版实例
*/
async CreateInstancePre(req, cb) {
return this.request("CreateInstancePre", req, cb);
}
/**
* 根据指定offset位置的消息
*/
async FetchMessageByOffset(req, cb) {
return this.request("FetchMessageByOffset", req, cb);
}
/**
* 删除Datahub主题
*/
async DeleteDatahubTopic(req, cb) {
return this.request("DeleteDatahubTopic", req, cb);
}
/**
* 删除主题IP白名单
*/
async DeleteTopicIpWhiteList(req, cb) {
return this.request("DeleteTopicIpWhiteList", req, cb);
}
/**
* 枚举地域,只支持广州地域
*/
async DescribeRegion(req, cb) {
return this.request("DescribeRegion", req, cb);
}
/**
* 设置Groups 消费分组offset
*/
async ModifyGroupOffsets(req, cb) {
return this.request("ModifyGroupOffsets", req, cb);
}
/**
* 添加 ACL 策略
*/
async CreateAcl(req, cb) {
return this.request("CreateAcl", req, cb);
}
/**
* 创建ckafka主题
*/
async CreateTopic(req, cb) {
return this.request("CreateTopic", req, cb);
}
/**
* 创建Datahub连接源
*/
async CreateConnectResource(req, cb) {
return this.request("CreateConnectResource", req, cb);
}
/**
* 查询Datahub任务信息
*/
async DescribeDatahubTask(req, cb) {
return this.request("DescribeDatahubTask", req, cb);
}
/**
* 用于查询cdc-ckafka任务状态
*/
async CheckCdcCluster(req, cb) {
return this.request("CheckCdcCluster", req, cb);
}
/**
* 获取Topic流量排行,消费者流量排行
*/
async DescribeTopicFlowRanking(req, cb) {
return this.request("DescribeTopicFlowRanking", req, cb);
}
/**
* 修改ACL策略,目前只支持预设规则的是否应用到新增topic这一项的修改
*/
async ModifyAclRule(req, cb) {
return this.request("ModifyAclRule", req, cb);
}
/**
* 本接口用于增加主题中的分区
*/
async CreatePartition(req, cb) {
return this.request("CreatePartition", req, cb);
}
/**
* 查询最新消息列表
*/
async FetchLatestDatahubMessageList(req, cb) {
return this.request("FetchLatestDatahubMessageList", req, cb);
}
/**
* 查询任务状态
*/
async DescribeTaskStatus(req, cb) {
return this.request("DescribeTaskStatus", req, cb);
}
/**
* 删除用户
*/
async DeleteUser(req, cb) {
return this.request("DeleteUser", req, cb);
}
/**
* 编辑Datahub连接源
*/
async ModifyConnectResource(req, cb) {
return this.request("ModifyConnectResource", req, cb);
}
/**
* 根据指定offset位置的消息
*/
async FetchDatahubMessageByOffset(req, cb) {
return this.request("FetchDatahubMessageByOffset", req, cb);
}
/**
* 创建最高权限的token
*/
async CreateToken(req, cb) {
return this.request("CreateToken", req, cb);
}
/**
* 获取Datahub消费分组offset
*/
async DescribeDatahubGroupOffsets(req, cb) {
return this.request("DescribeDatahubGroupOffsets", req, cb);
}
/**
* 删除ACL
*/
async DeleteAcl(req, cb) {
return this.request("DeleteAcl", req, cb);
}
/**
* 查询用户列表
*/
async DescribeAppInfo(req, cb) {
return this.request("DescribeAppInfo", req, cb);
}
/**
* 添加普罗米修斯监控1
*/
async CreatePrometheus(req, cb) {
return this.request("CreatePrometheus", req, cb);
}
/**
* 按量实例缩容
*/
async InstanceScalingDown(req, cb) {
return this.request("InstanceScalingDown", req, cb);
}
/**
* 获取主题属性
*/
async DescribeTopicAttributes(req, cb) {
return this.request("DescribeTopicAttributes", req, cb);
}
/**
* 删除预付费实例
*/
async DeleteInstancePre(req, cb) {
return this.request("DeleteInstancePre", req, cb);
}
/**
* 获取实例属性
*/
async DescribeInstanceAttributes(req, cb) {
return this.request("DescribeInstanceAttributes", req, cb);
}
/**
* 用户账户下获取实例列表详情
*/
async DescribeInstancesDetail(req, cb) {
return this.request("DescribeInstancesDetail", req, cb);
}
/**
* 批量添加ACL策略
*/
async BatchCreateAcl(req, cb) {
return this.request("BatchCreateAcl", req, cb);
}
/**
* 创建DIP转储任务
*/
async CreateDatahubTask(req, cb) {
return this.request("CreateDatahubTask", req, cb);
}
/**
* 删除ACL规则
*/
async DeleteAclRule(req, cb) {
return this.request("DeleteAclRule", req, cb);
}
/**
* 修改删除路由延迟触发时间
*/
async DeleteRouteTriggerTime(req, cb) {
return this.request("DeleteRouteTriggerTime", req, cb);
}
/**
* 批量修改消费组offset
*/
async BatchModifyGroupOffsets(req, cb) {
return this.request("BatchModifyGroupOffsets", req, cb);
}
/**
* 当前接口用来替代 CreateInstancePost 接口。创建按量计费实例。通常用于 SDK 或云 API 控制台调用接口,创建后付费 CKafka 实例。调用接口与在 CKafka 控制台购买按量付费实例效果相同。
*/
async CreatePostPaidInstance(req, cb) {
return this.request("CreatePostPaidInstance", req, cb);
}
/**
* 获取消费分组offset
*/
async DescribeGroupOffsets(req, cb) {
return this.request("DescribeGroupOffsets", req, cb);
}
/**
* 给实例授权token
*/
async AuthorizeToken(req, cb) {
return this.request("AuthorizeToken", req, cb);
}
/**
* 设置实例属性
*/
async ModifyInstanceAttributes(req, cb) {
return this.request("ModifyInstanceAttributes", req, cb);
}
/**
* 查询topic 生产端连接信息
*/
async DescribeTopicProduceConnection(req, cb) {
return this.request("DescribeTopicProduceConnection", req, cb);
}
/**
* 接口请求域名:https://ckafka.tencentcloudapi.com
本接口(DescribeTopic)用于在用户获取消息队列 CKafka 实例的主题列表
*/
async DescribeTopic(req, cb) {
return this.request("DescribeTopic", req, cb);
}
/**
* 添加 ACL 规则
*/
async CreateAclRule(req, cb) {
return this.request("CreateAclRule", req, cb);
}
/**
* 获取DIP主题属性
*/
async DescribeDatahubTopic(req, cb) {
return this.request("DescribeDatahubTopic", req, cb);
}
/**
* 用于查看ckafka的可用区列表
*/
async DescribeCkafkaZone(req, cb) {
return this.request("DescribeCkafkaZone", req, cb);
}
/**
* 查询Datahub连接源列表
*/
async DescribeConnectResources(req, cb) {
return this.request("DescribeConnectResources", req, cb);
}
/**
* 用于cdc的专用ckafka集群
*/
async CreateCdcCluster(req, cb) {
return this.request("CreateCdcCluster", req, cb);
}
/**
* 添加用户
*/
async CreateUser(req, cb) {
return this.request("CreateUser", req, cb);
}
/**
* 删除ckafka主题
*/
async DeleteTopic(req, cb) {
return this.request("DeleteTopic", req, cb);
}
/**
* 修改密码
*/
async ModifyPassword(req, cb) {
return this.request("ModifyPassword", req, cb);
}
/**
* Ckafka实例购买/续费询价
*/
async InquireCkafkaPrice(req, cb) {
return this.request("InquireCkafkaPrice", req, cb);
}
/**
* 本接口用于修改主题属性。
*/
async ModifyTopicAttributes(req, cb) {
return this.request("ModifyTopicAttributes", req, cb);
}
}
exports.Client = Client;