浏览代码

agCluster.erl改进

erlArango_v1
AICells 5 年前
父节点
当前提交
0fd1fb08d9
共有 2 个文件被更改,包括 64 次插入61 次删除
  1. +2
    -2
      src/agApi/agAdminMonitor.erl
  2. +62
    -59
      src/agApi/agCluster.erl

+ 2
- 2
src/agApi/agAdminMonitor.erl 查看文件

@ -178,7 +178,7 @@ modifyAdminLogLevel(PoolNameOrSocket, MapData) ->
% scheduler-threads线
% 线
% 线
getAdminStatistics(PoolNameOrSocket) ->
getAdminProps(PoolNameOrSocket) ->
agHttpCli:callAgency(PoolNameOrSocket, ?AgGet, <<"/_admin/statistics">>, [], undefined).
%
@ -285,7 +285,7 @@ getAdminServerAvailability(PoolNameOrSocket) ->
% 200
% 400ID
% 403
getAdminClusterStatistics(PoolNameOrSocket, DBserver) ->
getAdminClusterProps(PoolNameOrSocket, DBserver) ->
Path = <<"/_admin/clusterStatistics?DBserver=", (agMiscUtils:toBinary(DBserver))/binary>>,
agHttpCli:callAgency(PoolNameOrSocket, ?AgGet, Path, [], undefined).

+ 62
- 59
src/agApi/agCluster.erl 查看文件

@ -9,96 +9,99 @@
% HTTP接口
% ArangoDB群集的REST API
%
% ID
%
%
%
%
%
% distributeShardsLike集在描述修理章节
% ID
% ID
% GET /_admin/server/id
% ID
%
% 200
% 500
getServerId(PoolNameOrSocket) ->
% 200
% 500
serverId(PoolNameOrSocket) ->
agHttpCli:callAgency(PoolNameOrSocket, ?AgGet, <<"/_admin/server/id">>, [], undefined).
%
%GET /_admin/server/role
%role属性中返回
%SINGLE
%
%PRIMARYDBServer
%使
%
%UNDEFINEDUNDEFINED
%HTTP 200
%
%codeHTTP状态码200
%errorNum
%[ SINGLEPRIMARYSECONDARYAGENTUNDEFINED ]
getServerRole(PoolNameOrSocket) ->
%
% GET /_admin/server/role
% role属性中返回
% SINGLE
% COORDINATOR
% PRIMARYDB-Server
% SECONDARY使
% AGENT
% UNDEFINEDUNDEFINED
% HTTP 200
% error
% codeHTTP状态码200
% errorNum
% role[ SINGLECOORDINATORPRIMARYSECONDARYAGENTUNDEFINED ]
serverRole(PoolNameOrSocket) ->
agHttpCli:callAgency(PoolNameOrSocket, ?AgGet, <<"/_admin/server/role">>, [], undefined).
% DBserver查询统计
%
%
% DB-Server的统计信
% GET /_admin/clusterStatistics
%
% DBserverDBserver的统计信息
% DBserverDBspan>-Server的统计信息
%
% 200
% 400ID
% 403
getClusterStatistics(PoolNameOrSocket) ->
agHttpCli:callAgency(PoolNameOrSocket, ?AgGet, <<"/_admin/clusterStatistics">>, [], undefined).
% 200
% 400ID
% 403
clusterStats(PoolNameOrSocket, QueryPars) ->
QueryBinary = agMiscUtils:spellQueryPars(QueryPars),
agHttpCli:callAgency(PoolNameOrSocket, ?AgGet, <<"/_admin/clusterStatistics", QueryBinary/binary>>, [], undefined).
%
%
%
% GET /_admin/cluster/health
% JSON对象codeerrorerrorNumerrorMessage字段适当
% ClusterIdUUID字符串
% Health
% <nodeID>Health将由节点ID键入
% Endpoint
% Role"AGENT""COORDINATOR""DBSERVER"
% CanBeDeleted
% Version使ArangoDB的版本字符串
% Engine使
% Statusdbservers节点运行状况"GOOD""BAD"15"FAILED"
% ClusterIdUUID字符串
% Health
% <nodeID>Health将由节点ID键入
% Endpoint
% Role"AGENT""COORDINATOR""DBSERVER"
% CanBeDeleted
% Version使ArangoDB的版本字符串
% Engine使
% StatusDB-Servers节点运行状况"GOOD""BAD"15"FAILED"
%
%
% SyncStatusStatus"UNKNOWN""UNDEFINED""STARTUP""STOPPING""STOPPED""SERVING""SHUTDOWN"
% LastAckedTimeISO 8601
% ShortName"Coordinator0001"
% TimestampISO 8601
% Host
%
% AdvertisedEndpointIP地址或负载平衡器
%
% LeaderID
% Leadingtruefalse
% LastAckedTimeacked以秒为单位
% 200
getClusterHealth(PoolNameOrSocket) ->
%
% SyncStatusStatus"UNKNOWN""UNDEFINED""STARTUP""STOPPING""STOPPED""SERVING""SHUTDOWN"
% LastAckedTimeISO 8601
% ShortName"Coordinator0001"
% TimestampISO 8601
% Host
%
% AdvertisedEndpointIP地址或负载平衡器
%
% LeaderID
% Leadingtruefalse
% LastAckedTimeacked以秒为单位
%
% 200
clusterHealth(PoolNameOrSocket) ->
agHttpCli:callAgency(PoolNameOrSocket, ?AgGet, <<"/_admin/cluster/health">>, [], undefined).
%
%
%
% PUT /_admin/cluster/maintenance
% API60
% "on""off"
%
% 200
% 400
% 501
% 504
% 200
% 400
% 501
% 504
setClusterMaintenance(PoolNameOrSocket, OnOrOff) ->
agHttpCli:callAgency(PoolNameOrSocket, ?AgPut, <<"/_admin/cluster/maintenance">>, [], OnOrOff).
%%%%%%%%%%%%%%% Agency ??????????????????????????

正在加载...
取消
保存