浏览代码

agTasks.erl模块改进

erlArango_v1
AICells 5 年前
父节点
当前提交
529c9343e9
共有 1 个文件被更改,包括 42 次插入41 次删除
  1. +42
    -41
      src/agApi/agTasks.erl

+ 42
- 41
src/agApi/agTasks.erl 查看文件

@ -7,12 +7,11 @@
% doc_address:https://www.arangodb.com/docs/stable/http/traversal.html % doc_address:https://www.arangodb.com/docs/stable/http/traversal.html
%HTTP任务接口
%ArangoDB的任务HTTP接口
%API操作提供了一些示例
%
% HTTP任务接口
% ArangoDB的任务HTTP接口
% API操作提供了一些示例
%
%
% GET /_api/tasks/ % GET /_api/tasks/
% %
% HTTP 200 % HTTP 200
@ -23,9 +22,10 @@ getTaskList(PoolNameOrSocket) ->
% %
% GET /_api/tasks/{id} % GET /_api/tasks/{id}
% %
% idID
% idID
% ID指定的服务器上获取一个现有任务 % ID指定的服务器上获取一个现有任务
% HTTP 200 % HTTP 200
% **
getTask(PoolNameOrSocket, TaskId) -> getTask(PoolNameOrSocket, TaskId) ->
Path = <<"/_api/tasks/", (agMiscUtils:toBinary(TaskId))/binary>>, Path = <<"/_api/tasks/", (agMiscUtils:toBinary(TaskId))/binary>>,
agHttpCli:callAgency(PoolNameOrSocket, ?AgGet, Path, [], undefined). agHttpCli:callAgency(PoolNameOrSocket, ?AgGet, Path, [], undefined).
@ -33,25 +33,26 @@ getTask(PoolNameOrSocket, TaskId) ->
% %
% POST /_api/tasks % POST /_api/tasks
% JSON对象是必需的 % JSON对象是必需的
% name
% JavaScript代码
% params
% period
% offset
% name
% commandJavaScript代码
% params
% period
% offset
%
% ID创建一个新任务 % ID创建一个新任务
% HTTP 200
% id
% created
% [ periodictimed]
%
%
% period秒
% offset
% javascript函数
% database
% code200
% false
% 400HTTP 400
% HTTP 200
% id
% created
% type[ periodictimed]
%
%
% periodperiod秒
% offset
% commandjavascript函数
% database
% code200
% errorfalse
% 400HTTP 400
newTask(PoolNameOrSocket, MapData) -> newTask(PoolNameOrSocket, MapData) ->
BodyStr = jiffy:encode(MapData), BodyStr = jiffy:encode(MapData),
agHttpCli:callAgency(PoolNameOrSocket, ?AgPost, <<"/_api/tasks">>, [], BodyStr). agHttpCli:callAgency(PoolNameOrSocket, ?AgPost, <<"/_api/tasks">>, [], BodyStr).
@ -59,33 +60,33 @@ newTask(PoolNameOrSocket, MapData) ->
% ID的新任务 % ID的新任务
% PUT /_api/tasks/{id} % PUT /_api/tasks/{id}
% %
% idid
% idid
% JSON对象是必需的 % JSON对象是必需的
% name
% JavaScript代码
% params
% period
% offset
% name
% commandJavaScript代码
% params
% period
% offset
% ID的新任务 % ID的新任务
% %
% 400ID已经存在或其余主体不正确HTTP 400
% 400ID已经存在或其余主体不正确HTTP 400
newTask(PoolNameOrSocket, TaskId, MapData) -> newTask(PoolNameOrSocket, TaskId, MapData) ->
Path = <<"/_api/tasks/", (agMiscUtils:toBinary(TaskId))/binary>>, Path = <<"/_api/tasks/", (agMiscUtils:toBinary(TaskId))/binary>>,
BodyStr = jiffy:encode(MapData), BodyStr = jiffy:encode(MapData),
agHttpCli:callAgency(PoolNameOrSocket, ?AgPost, Path, [], BodyStr).
agHttpCli:callAgency(PoolNameOrSocket, ?AgPut, Path, [], BodyStr).
% %
% DELETE /_api/tasks/{id} % DELETE /_api/tasks/{id}
% %
% idid
% idid
% ID标识的任务 % ID标识的任务
% HTTP 200HTTP 200
% code200
% false
% HTTP 404ID未知HTTP 404
% code404
% true
% errorMessage
% HTTP 200HTTP 200
% code200
% errorfalse
% HTTP 404ID未知HTTP 404
% code404
% errortrue
% errorMessage
delTask(PoolNameOrSocket, TaskId) -> delTask(PoolNameOrSocket, TaskId) ->
Path = <<"/_api/tasks/", (agMiscUtils:toBinary(TaskId))/binary>>, Path = <<"/_api/tasks/", (agMiscUtils:toBinary(TaskId))/binary>>,
agHttpCli:callAgency(PoolNameOrSocket, ?AgDelete, Path, [], undefined). agHttpCli:callAgency(PoolNameOrSocket, ?AgDelete, Path, [], undefined).

正在加载...
取消
保存