分发节点

June 24, 2022About 17 min

分发节点

SDK类名:/distributor/DistributorNode

分发节点 - 【字段说明】

SDK方法名:readme;

URL

//distribution/node/readme

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
node_uuidString节点UUID278D0E2C-2156-3F7F-D75F-2628E46F6B35
node_nameString节点名称
node_versionString节点版本号4.0-19110518
log_dayNumber日志保留天数10
os_typeNumber节点系统类型0
group_uuidString组别UUID
group_nameString组别名称
user_uuidString用户UUID278D0E2C-2156-3F7F-D75F-2628E46F6B35
usernameString用户名称xxx
system_timeNumber节点系统当前时间,时间戳1577160228
create_timeNumber节点创建时间,时间戳1577160228
node_typeNumber节点类型,0文件节点,1流节点1
node_roleNumber节点角色,1主节点,2子节点,3终端节点,0:不启用1
node_addrArray节点地址
  ipString节点IP172.20.2.75
  portNumber节点端口1234
parent_addrArray父节点(原parent_node / gateway)
  ipString父节点IP172.20.2.75
  portNumber父节点端口1234
  ip_configObject
    target_idString父节点网关ID
    target_pwdString父节点校验密码(原auth_id)
    market_typeString流 行情类别
    resend_portNumber流 重传端口
    gwNumber流 是否网关
    i2Number流 是否英方
work_timeString工作时间,形如:00:00:00|23:59:5900:00:00|23:59:59
target_maxNumber最大子节点数100
node_numberNumber当前下级节点数2
send_bytesNumber发送字节数2
update_timeNumber更新时间1577160228
last_time_lagNumber上次更新时间戳1577160228
statusString状态:ONLINE、OFFLINE、WARN、EXCEPTION:在线、离线、警告、异常WARN
res_monitorObject进程状态
  cpu_transitString流 节点占用CPU
  memory_transitString流 节点占用内存
  process_transitString流 节点进程状态
  cpu_serverString文件 服务端占用CPU
  memory_serverString文件 服务端占用内存
  process_serverString文件 服务进程状态
  cpu_clientString文件 客户端占用CPU
  memory_clientString文件 客户端占用内存
  process_clientString文件 客户端进程状态
write_blockString文件 写入类型
last_recv_fileString文件 最后接收文件
last_recv_timeString文件 最后接收时间(时间戳)
last_send_fileString文件 最后发送文件
last_send_timeString文件 最后发送时间(时间戳)
send_filesArray文件 发送列表
  market_typeString类别名称港交所行情
  groupNumber类别分组0
  enableNumber启用开关0
  dirNumber目录开关0
  recursiveNumber递归开关0
  pathString路径C:\HGInfo\HGHQ.DBF
  filter_by_fnString文件过滤
  event_triggerNumber扫描方式0
  time_checkNumber属性对比(文件对比)0
  checksum_funcString对比方式,固定值blockblock
  scanNumber扫描间隔200
  compressNumber压缩等级4
  filter_by_ftString时间过滤0|0
  work_timeString工作时间00-00-00|23-59-59
  playNumber是否回放0
recv_filesArray文件 接收列表
  market_typeString类别名称港交所行情
  pathString保存至本地目录
  timeoutNumber阈值0
  chk_tm_amString上午检查时段09-00-00|11-30-00
  chk_tm_pmString下午检查时段13-00-00|15-30-00
  recordNumber是否录制0
  groupNumber分组1
  enableNumber是否开启0
  guardNumber是否回切0
  watchNumber是否监控0
send_statusArray文件 发送类别状态?
  market_typeStringxxxx
  file_nameString
  file_sizeNumber0
  update_timeNumber1577160228
  send_bytesNumber0
recv_statusArray文件 接收类别状态?
  market_typeStringxxxx
  file_nameString
  file_sizeNumber0
  update_timeNumber1577160228
  send_bytesNumber0
recv_packageNumber流 接收包数
send_packageNumber流 发送包数
send_speedNumber流 发送速度
recv_bytesNumber流 流接收字节数
recv_bytes_lastNumber流 流前次更新字节数
protocolString流 协议类型
version_idString流 协议版本号(网关版本ID)
sender_idString流 发送方ID(本机ID)
heart_beatNumber流 心跳间隔
auth_enableNumber流 是否启用下级校验
auth_idString流 校验ID
compressNumber流 压缩率
warn_configArray警告设置
  market_typeString类别
  file_nameString路径
  warn_tickNumber警告间隔(s)1
  error_tickNumber异常间隔(s)1
  check_beginStringAM检查时间,格式H:i:s,下同
  check_endStringAM检查时间
  check_begin_pmStringPM检查时间
  check_end_pmStringPM检查时间
  check_node_numberNumber子节点数量警告1
  traffic_beginStringAM流量监控时间
  traffic_endStringAM流量监控时间
  traffic_begin_pmStringPM流量监控时间
  traffic_end_pmStringPM流量监控时间
  traffic_upperStringAM流量报警范围
  traffic_lowerStringAM流量报警范围
  traffic_upper_pmStringPM流量报警范围
  traffic_lower_pmStringPM流量报警范围
  file_sizeNumber文件大小
  send_bytesNumber发送字节数
  system_timeNumber系统时间
  update_timeNumber更新时间
  warn_levelString警告状态,状态:ONLINE、OFFLINE、WARN、EXCEPTION:在线、离线、警告、异常

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。

分发节点 - 注册(底层)

SDK方法名:register;

URL

//distribution/node

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
commonObject
  node_uuidString278D0E2C-2156-3F7F-D75F-2628E46F6B35
  node_nameStringnode1
  node_versionString4.0-19110518
  log_dayNumber10
  os_typeNumber0
  group_uuidString
  system_timeNumber1577160228
node_listArray
  node_typeNumber1
  node_roleNumber1
  node_addrArray
    ipString172.20.2.75
    portNumber1234
  parent_addrArray
    ipString172.20.2.75
    portNumber1234
    ip_configObject
      target_idString
      target_pwdString
      market_typeString6666
      resend_portNumber-1
      gwNumber1
      i2Number0
  work_timeString00:00:00|23:59:59
  target_maxNumber100
  write_blockString
  send_filesArray
    market_typeString港交所行情
    groupNumber0
    enableNumber0
    dirNumber0
    recursiveNumber0
    pathStringC:\HGInfo\HGHQ.DBF
    filter_by_fnString
    event_triggerNumber0
    time_checkNumber0
    checksum_funcStringblock
    scanNumber200
    compressNumber4
    filter_by_ftString0|0
    work_timeString00-00-00|23-59-59
    playNumber0
  recv_filesArray
    market_typeString港交所行情
    pathString
    timeoutNumber0
    chk_tm_amString09-00-00|11-30-00
    chk_tm_pmString13-00-00|15-30-00
    recordNumber0
    groupNumber1
    enableNumber0
    guardNumber0
    watchNumber0
  protocolStringbinary
  version_idString1.01
  sender_idString0
  heart_beatNumber10
  auth_enableNumber0
  auth_idString0
  compressNumber0

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。

分发节点 - 更新状态(底层)

SDK方法名:updateStatus;

即原来的 alive 接口,

topography对应原来的collect_status,

URL

//distribution/node/:uuid([A-F0-9-]+)/status

Method

PUT

Request

名称类型必选简介Mock初始值Mock规则
node_typeNumber1
node_versionString4.0-19110518
system_timeNumber1577160228
last_time_lagNumber1577160228
node_numberNumber2
send_bytesNumber317146
res_monitorObject
  cpu_transitString0%
  memory_transitString8032KB
  process_transitNumber0
  cpu_serverString0%
  memory_serverString7448KB
  process_serverNumber0
  cpu_clientString0%
  memory_clientString0KB
  process_clientNumber0
last_recv_fileStringE:\test3\namelst-2019-01-28_05-07-28
last_recv_timeNumber1577160221
last_send_fileStringE:\test3\namelst-2019-01-28_05-07-28
last_send_timeNumber1577160219
send_statusArray
  market_typeString港交所行情
  file_nameStringC:\HGInfo\HGXXN.DBF
  file_sizeNumber123
  update_timeNumber1577160228
  send_bytesNumber3567
recv_statusArray
  market_typeString港交所行情
  file_nameStringC:\HGInfo\HGXXN.DBF
  file_sizeNumber123
  update_timeNumber1577160228
  send_bytesNumber3567
recv_packageNumber2
send_packageNumber3
send_speedNumber4
recv_bytesNumber5
recv_bytes_lastNumber6
topographyObject
  node_uuidString278D0E2C-2156-3F7F-D75F-2628E46F6B35
  byte_receiveNumber0
  byte_sendNumber47040
  consumeNumber0
  current_seqNumber0
  current_timeString20201111222222556
  market_timeString20201111222222664
  last_market_timeString20201111222222664
  last_seqNumber0
  pkt_receiveNumber34306
  pkt_sendNumber0
  node_listArray
    byte_sendNumber0
    ipString172.20.2.76
    portNumber41438
    speedNumber3
    target_idString66661111
    node_uuidString

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。
  system_timeNumber系统时间1577160228
  license_allowNumber3
  node_listObject当前更新的节点在数据库的内容,通获取单个节点接口返回的内容一样,只是这里会返回这个node_uuid下的所有节点

------------------

URL

//dash2

Method

GET

Request

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

Response

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

分发节点 - 列表

SDK方法名:listNode;

URL

//distribution/node

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
limitNumber
pageNumber
node_typeNumber1
node_roleNumber1
statusString

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。
  info_listArray3
    node_uuidString1525E087-972A-6FD2-AFD4-611403D68DC6
    node_nameStringter_node1
    node_versionString4.0-19110518
    log_dayNumber0
    os_typeNumber0
    group_uuidString
    user_uuidString1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
    system_timeNumber1577160228
    create_timeNumber1578881438
    random_strString01A8504C-AA26-C55F-A31D-6398EDCF0AB0
    node_typeNumber0
    node_roleNumber3
    statusStringOFFLINE
    node_numberNumber2
    update_timeNumber1578896550
    parent_addrArray
      ip_typeNumber1
      ipString172.20.2.76
      portNumber1234
      ip_configObject
    node_addrArray
      ip_typeNumber0
      ipString172.20.2.77
      portNumber1234
      ip_configObject
  totalNumber3

分发节点 - 状态

SDK方法名:listNodeStatus;

URL

//distribution/node/status

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
node_typeNumber1
node_uuidsArray节点UUID数组["@guid"]

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。
  statusArray
    node_uuidString@guid
    statusStringONLINE

分发节点 - 获取 节点

SDK方法名:describeNode;

原来的 get_send_files 接口也从这里拿

URL

//distribution/node/:uuid([A-F0-9-]+)

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。
  dist_nodeObject
    node_uuidString278D0E2C-2156-3F7F-D75F-2628E46F6B35
    node_nameString
    node_versionString4.0-19110518
    log_dayNumber10
    os_typeNumber0
    group_uuidString
    group_nameString
    user_uuidString278D0E2C-2156-3F7F-D75F-2628E46F6B35
    usernameStringxxx
    system_timeNumber1577160228
    create_timeNumber1577160228
    node_typeNumber0
    node_roleNumber1
    node_addrArray
      ipString172.20.2.75
      portNumber1234
    parent_addrArray2
      ipString172.20.2.75
      portNumber1234
      ip_configObject
        target_idString
        target_pwdString
        market_typeString
        resend_portNumber1
        gwNumber1
        i2Number1
    work_timeString00:00:00|23:59:59
    target_maxNumber100
    node_numberNumber2
    send_bytesNumber100
    update_timeNumber1577160228
    last_time_lagNumber1577160228
    statusStringWARN
    res_monitorObject
      cpu_transitString
      memory_transitString
      process_transitString
      cpu_serverString
      memory_serverString
      process_serverString
      cpu_clientString
      memory_clientString
      process_clientString
    write_blockString
    last_recv_fileString
    last_recv_timeString
    last_send_fileString
    last_send_timeString
    send_filesArray
      market_typeString港交所行情
      groupNumber0
      enableNumber0
      dirNumber0
      recursiveNumber0
      pathStringC:\HGInfo\HGHQ.DBF
      filter_by_fnString
      event_triggerNumber0
      time_checkNumber0
      checksum_funcStringblock
      scanNumber200
      compressNumber4
      filter_by_ftString0|0
      work_timeString00-00-00|23-59-59
      playNumber0
    recv_filesArray
      market_typeString港交所行情
      pathString
      timeoutNumber0
      chk_tm_amString09-00-00|11-30-00
      chk_tm_pmString13-00-00|15-30-00
      recordNumber0
      groupNumber1
      enableNumber0
      guardNumber0
      watchNumber0
    send_statusArray
    recv_statusArray
    recv_packageString
    send_packageString
    send_speedString
    recv_bytesString
    recv_bytes_lastString
    protocolString
    version_idString
    sender_idString
    heart_beatString
    auth_enableString
    auth_idString
    compressString
  warn_configArray
    market_typeString
    file_nameString
    warn_tickNumber1
    error_tickNumber1
    check_beginString
    check_endString
    check_begin_pmString
    check_end_pmString
    check_node_numberNumber1
    traffic_beginString
    traffic_endString
    traffic_begin_pmString
    traffic_end_pmString
    traffic_upperString
    traffic_lowerString
    traffic_upper_pmString
    traffic_lower_pmString

分发节点 - 设置 文件

SDK方法名:fileConfig;

URL

//distribution/node/:uuid([A-F0-9-]+)/file_config

Method

PUT

Request

名称类型必选简介Mock初始值Mock规则
send_filesArray
  market_typeString类别名称港交所行情
  groupNumber分组0
  enableNumber是否启用0
  dirNumber是否是目录0
  recursiveNumber是否递归0
  pathString路径C:\HGInfo\HGHQ.DBF
  filter_by_fnString扫描方式
  event_triggerNumber事件触发0
  time_checkNumber属性对比0
  checksum_funcString对比方式,固定值blockblock
  scanNumber扫描间隔200
  compressNumber压缩级别4
  filter_by_ftString时间过滤0|0
  work_timeString工作时间段00-00-00|23-59-59
  playNumber是否回放0
recv_filesArray
  market_typeString类别名称港交所行情
  pathString路径
  timeoutNumber阈值0
  chk_tm_amString上午检查时段09-00-00|11-30-00
  chk_tm_pmString下午检查时段13-00-00|15-30-00
  recordNumber是否录制0
  groupNumber分组1
  enableNumber是否开启0
  guardNumber是否回切0
  watchNumber是否监控0
random_strString
node_roleNumber

Response

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

分发节点 - 设置 警告

SDK方法名:warnConfig;

URL

//distribution/node/:uuid([A-F0-9-]+)/warn_config

Method

PUT

Request

名称类型必选简介Mock初始值Mock规则
node_typeString
node_roleNumber
random_strString
warn_configArray
  market_typeString
  file_nameString
  warn_tickNumber1
  error_tickNumber1
  check_beginString
  check_endString
  check_begin_pmString
  check_end_pmString
  check_node_numberNumber1
  traffic_beginString
  traffic_endString
  traffic_begin_pmString
  traffic_end_pmString
  traffic_upperString
  traffic_lowerString
  traffic_upper_pmString
  traffic_lower_pmString

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。

分发节点 - 升级

SDK方法名:upgrade;

URL

//distribution/node/:uuid([A-F0-9-]+)/upgrade

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
upgrade_typeNumber升级类型:0:升级当前节点;1:当前节点及其子节点;
node_typeString

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。

分发节点 - 删除

SDK方法名:delete;

URL

//distribution/node/:uuid([A-F0-9-]+)

Method

DELETE

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。

分发节点 - 拓扑图

SDK方法名:topography;

URL

//distribution/node/topography

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
is_staticNumber是否是静态图:0否1是;
node_uuidString

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。
  edgesArray
    sourceNumber0
    targetNumber1
  dataArray2
    node_nameStringnode1
    node_addrString172.20.2.75
    node_roleNumber0
    typeString是否为第三方节点,cloud第三方节点,app本地节点app
    codeStringi2
    statusStringONLINE OFFLINE,原healthONLINE
    protocolString原lineProtocolTCP
    consumeNumber延迟(底层送上来的),原lineTime0
    speedNumber原lineRpm0
    byte_receiveNumber原rpm0
    pkt_receiveNumber原epm327
    current_timeString原localTime
    market_timeString原time
    levelNumber节点在树中的层级,顶层为00+1

分发节点 - 延迟图

SDK方法名:latency;

URL

//distribution/node/latency

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
startNumber实时延迟只传这个,为当前时间点时间戳(第一次获取不传,默认最近10分钟),历史延迟传一月前的时间点
endNumber
typeStringreal,month

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。
  timeArray["9:21:11","9:22:32"]
  node_listArray2
    node_nameString邮件营销
    latencyArray[120,132,101,134,90,230,210]
Last update: 11/18/2022, 3:56:21 PM
Contributors: ganl