# 异构管理

kafka监控 kafka消费

# 示例接口

示例接口描述

# URL

//example/1571888297732

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则
foo String @ctitle 请求属性示例

# Response

名称 类型 必选 初始值 简介 Mock规则
string String 字符串属性示例 1-10
number Number 1 数字属性示例 1-100
boolean Boolean true 布尔属性示例 1-2
regexp RegExp /[a-z][A-Z][0-9]/ 正则属性示例
function Function () => Math.random() 函数属性示例
array Array 数组属性示例 1-10
  foo Number 1 数组元素示例 +1
  bar String 数组元素示例 1-10
items Array [1, true, 'hello', /\w{10}/] 自定义数组元素示例
object Object 对象属性示例
  foo Number 1 对象属性示例 +1
  bar String 对象属性示例 1-10
placeholder String @title 占位符示例

# ===============分割线==================

# URL

//example

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则

# Response

名称 类型 必选 初始值 简介 Mock规则

# 异构-新建

# URL

//hetero/rule

# Method

POST

# Request

名称 类型 必选 初始值 简介 Mock规则
name String
kfk_ver String
dst_node String 备端节点
conn_type String 连接方式 zookepper broker
host String zookeeper主机
port String zookeeper 端口
broker String
tabmap Object
consumer_thread_num Number 2
actload_thread_num Number 4

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0

# 异构-删除

# URL

//hetero

# Method

DELETE

# Request

名称 类型 必选 初始值 简介 Mock规则
uuids Array

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0

# 异构-获取列表

# URL

//hetero/rule

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则
page Number 1
limit Number 10
search_field String kafka_name
search_value String

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0
  info_list Array
    name String 测试kafka集群
    dst_node String 1
    conn_type String 2.0
    broker String 192.168.28.90:58080
    kfk_ver String 3.0
    uuid String @uuid
    is_biz_admin Number 1
    can_op Number 1
    can_up Number 1
    can_del Number 1
    broker_id String 1

# 异构-查看topic

# URL

//hetero/topic

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则
uuid String

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0
  info_list Array
    topicList Array "topic1","topic2","topic3" "topic1","topic2","topic3"

# 异构-查看消费者

查看消费者

# URL

//hetero/view_consumer

# Method

POST

# Request

名称 类型 必选 初始值 简介 Mock规则
uuid String

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0
  info_list Array
    consumer String 111
    topic String 222
    partition String 333
    current_offest String 444
    logend_offset String 5555
  total Number 10

# 异构-消费

消费者新建

# URL

//hetero/consumer

# Method

POST

# Request

名称 类型 必选 初始值 简介 Mock规则
topic String
offset String
lines String
show_foward Number

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0

# ===============分割线==================

# URL

//example/com

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则

# Response

名称 类型 必选 初始值 简介 Mock规则

# 异构-消费-新建

# URL

//hetero/consumer/rule

# Method

POST

# Request

名称 类型 必选 初始值 简介 Mock规则
name String
src_db_uuid String
tgt_type String
init_offset Array
  topic String
  offset String
  partition String
modify String false
topic String
dst_topic String
tgt_db_uuid String oracle 类型时
init_offset_type String earlist latest,seek
tabmap String {111:222}
consumer_thread_num String 2
actload_thread_num String 4

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0

# 异构-消费-删除

# URL

//hetero/consumer/rule

# Method

DELETE

# Request

名称 类型 必选 初始值 简介 Mock规则
uuid Array

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0

# 异构-消费-状态

# URL

//hetero/consumer/status

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则
uuids Array

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  code Number 0
  message String
  info_list Array
    uuid String C038DE5A-CDB2-F26D-FA5F-93E3FF266A87
    run Object
      status String ACTIVE_RULE_DOING
      progress String 80

# 异构-消费-操作

stop | resume

# URL

//hetero/consumer/operate

# Method

POST

# Request

名称 类型 必选 初始值 简介 Mock规则
uuid String
operate String stop resume

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0

# 异构-消费-查看获取规则列表

查看类型

# URL

//hetero/consumer/viewtype

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则
search_field String tgt_type
limit Number
page Number
search_value String
where_args Object
  uuid String

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0
  info_list Array
    name String @name
    dst_node String 1
    conn_type String 1
    uuid String C038DE5A-CDB2-F26D-FA5F-93E3FF266A87
    tgt_type String kudu
    tarip String 172.168.42.114
    port String 58080
    kfk_ver String 2.0
    dst_topic String
    dst_bootstrap_server String
    bootstrap_server String
    is_biz_admin Number 1
    can_op Number 1
    can_up Number 1
    can_del Number 1
    topic String
    data_info Object
      src Object
        db_ip Array [192.167.111.111]
        log_read_type String file
        orcl String orcl
        node_name String src1
        node_ip String 192.167.111.111
      dst Object
        db_ip Array [192.167.111.112]
        log_read_type String file
        orcl String orcl
        node_name String dst1
        node_ip String 192.167.111.112
    dst_broker_server Array
      ip String 199.199.222.222
      port String 213
    src_broker_server Array
      ip String 199.199.222.222
      port String 123
    src_db_name String 12344
    tgt_db_name String 5513

# 异构-消费-查看

查看消费规则

# URL

//hetero/consumer/rule

# Method

PUT

# Request

名称 类型 必选 初始值 简介 Mock规则

# Response

名称 类型 必选 初始值 简介 Mock规则

# 异构-消费-获取单条规则

查看消费规则

# URL

//hetero/consumer/rule

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则
uuid String

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  code Number 0
  message String success
  info_list Object
    name String @name
    tgt_type String kafka
    src_db_uuid String 111
    tgt_db_uuid String 222
    topic String 4444,5555
    dst_topic String 321
    init_offset_type String seek
    init_offset Array
      topic String 111
      offset String 222
      partition String 333
    actload_thread_num String 4
    consumer_thread_num String 2
    tabmap Array
      src_table String 111
      dst_table String 222

# ===============分割线==================

# URL

/kafkaGraph

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则

# Response

名称 类型 必选 初始值 简介 Mock规则

# 异构-拓扑-新建

# URL

//hetero/graph

# Method

POST

# Request

名称 类型 必选 初始值 简介 Mock规则
graph_name String
is_parent String
is_rule String
consume_rule Array
  id String
  rule_name String
  src_type String
  src_uuid String
  dst_type String
  rule_number Number 1
  rule_status String
  rule_traffic String
  is_parent Boolean 0
  is_rule Boolean 0
  src_name String
  dst_name String
  dst_uuid String

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0

# 异构-拓扑-添加

# URL

//hetero/graph/add

# Method

POST

# Request

名称 类型 必选 初始值 简介 Mock规则
graph_uuid String
rule_number String
src_type String oracle,kafka,mysql
rule_uuid String

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0

# 异构-拓扑-获取列表

# URL

//hetero/graph/list

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则
page Number 1
limit Number 10

# Response

名称 类型 必选 初始值 简介 Mock规则
message String success
ret Number 200
msg String
data Object
  code Number 0
  info_list Array 2
    id Number 1
    graph_name String topo-o2k-kafka-oracle-test2
    graph_uuid String @uuid 1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC-Graph
    is_parent Boolean true
    is_rule Boolean 0
    consume_rule Array 4
      id Number 11 +1
      rule_name String o2k-kafka-oracle-test2
      rule_uuid String 3D7dFcd9-C176-d9ee-4FFB-f22bbd554944
      src_type String oracle
      src_uuid String 3D7dFcd9-C176-d9ee-4FFB-f22bbd554925
      dst_type String kafka
      rule_number Number 0 +1
      rule_status String stop
      rule_traffic String 31455
      is_parent Boolean false
      is_rule Boolean 0
      src_name String @name 源端名字
      dst_name String @name 备端名字
      dst_uuid String C038DE5A-CDB2-F26D-FA5F-93E3FF266A87
    can_op Number 1
    can_up Number 1
    can_del Number 0
    is_biz_admin Number 1
  message String

# 异构-拓扑-运行拓扑

# URL

//hetero/graph/run

# Method

POST

# Request

名称 类型 必选 初始值 简介 Mock规则
graphs Array
graph_uuid String
rule_uuids Array
  uuid String
  src_type String oracle,kafka,mysql

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0

# 异构-拓扑-停止拓扑

# URL

//hetero/graph/stop

# Method

POST

# Request

名称 类型 必选 初始值 简介 Mock规则
graphs Array
  graph_uuid String
  rule_uuids Array
    uuid String
    src_type String oracle,mysql,kafka

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0

# 异构-拓扑-状态

# URL

//hetero/graph/status

# Method

POST

# Request

名称 类型 必选 初始值 简介 Mock规则
rule_uuids Array
  uuid String
  src_type String oracle.mysql,kafka

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  code Number 0
  message String
  info_list Array
    rule_uuid String
    status String

# 异构-拓扑-删除拓扑

# URL

//hetero/graph

# Method

DELETE

# Request

名称 类型 必选 初始值 简介 Mock规则
graph_uuids Array
  graph_uuid String @uuid
  rule_uuids Array
    uuid String @uuid
    is_rule String 1
    rule_number String 4
    src_type String oracle
is_whole String 1

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0

# 异构-拓扑-拓扑详情

# URL

//hetero/graph/detail

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则
page Number 1
limit Number 10
start_time String
end_time String
graph_uuid String

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0
  info_list Array 2
    2019-10-11 Array 2
      uuid String 1c7DBA2b-A5AA-F1A6-1587-d5844db5BdAF
      name String @name
      number Number 1-100
  total Number 1

# ===============分割线==================

# URL

//example/

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则

# Response

名称 类型 必选 初始值 简介 Mock规则

# 异构-拓扑图-获取拓扑图

# URL

//hetero/graph/graph

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则
graph_uuid String

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 200
msg String
data Object
  message String
  code Number 0
  info_list Array
    src Object
      node Object
        name String oracle-kafka-199-266
        state String ok
        status String node_online node_online/node_error/node_ignore
        type String oracle
      kafka Object
        status String kafka_normal kafka_normal
        srcid String
        traffic String 10004956
        type String kafka
        name String kafka-oracle
        scntime String 06-25 11:26:19
    relay Object
      node Array
        name String 300kkkkkkkkkkkkkkkkkkkkkkkkkkkkkkk
        state String ok
        status String db_abnormal db_abnormal/db_ignore/db_normal
        traffic String N/A
        type String kafka
        scntime String N/A 06-25 11:26:58
    dst Object
      node Array 2
        name String kafka-oralce-6000123
        state String ok
        status String node_online
        traffic String 100564
        type String oracle
        scntime String 06-25 11:26:19 06-25 11:26:19
    summary Object
      name String 199-200
      state String 0 1/0
      stage String pause
      uuid String @guid
      status String rect_error rect_normal
      extract String 2019-06-25 11:26:10
Last Updated: 5/13/2020, 3:56:32 AM