Files
2025-11-18 03:36:49 +08:00

4.9 KiB
Raw Permalink Blame History

NodeTaskService

节点同步任务相关服务


countDoingNodeTasks

计算正在执行的任务数量

  • 角色:admin
  • HTTPPOST https://backend.dooki.cloud/NodeTaskService/countDoingNodeTasks
  • RPCrpc countDoingNodeTasks (CountDoingNodeTasksRequest) returns (RPCCountResponse);

请求对象 (CountDoingNodeTasksRequest)

{}

响应对象 (RPCCountResponse)

{
  "count": "int64 // 数量"
}

调用示例

curl -X POST "https://backend.dooki.cloud/NodeTaskService/countDoingNodeTasks" \
  -H "Content-Type: application/json" \
  -H "X-Edge-Access-Token: <YOUR_TOKEN>" \
  -d '{
    ...
  }'

deleteAllNodeTasks

删除所有任务

  • 角色:admin
  • HTTPPOST https://backend.dooki.cloud/NodeTaskService/deleteAllNodeTasks
  • RPCrpc deleteAllNodeTasks(DeleteAllNodeTasksRequest) returns (RPCSuccess);

请求对象 (DeleteAllNodeTasksRequest)

{}

响应对象 (RPCSuccess)

{}

调用示例

curl -X POST "https://backend.dooki.cloud/NodeTaskService/deleteAllNodeTasks" \
  -H "Content-Type: application/json" \
  -H "X-Edge-Access-Token: <YOUR_TOKEN>" \
  -d '{
    ...
  }'

deleteNodeTask

删除任务

  • 角色:admin
  • HTTPPOST https://backend.dooki.cloud/NodeTaskService/deleteNodeTask
  • RPCrpc deleteNodeTask (DeleteNodeTaskRequest) returns (RPCSuccess);

请求对象 (DeleteNodeTaskRequest)

{
  "nodeTaskId": "int64"
}

响应对象 (RPCSuccess)

{}

调用示例

curl -X POST "https://backend.dooki.cloud/NodeTaskService/deleteNodeTask" \
  -H "Content-Type: application/json" \
  -H "X-Edge-Access-Token: <YOUR_TOKEN>" \
  -d '{
    ...
  }'

deleteNodeTasks

批量删除任务

  • 角色:admin
  • HTTPPOST https://backend.dooki.cloud/NodeTaskService/deleteNodeTasks
  • RPCrpc deleteNodeTasks (DeleteNodeTasksRequest) returns (RPCSuccess);

请求对象 (DeleteNodeTasksRequest)

{
  "nodeTaskIds": "[]int64"
}

响应对象 (RPCSuccess)

{}

调用示例

curl -X POST "https://backend.dooki.cloud/NodeTaskService/deleteNodeTasks" \
  -H "Content-Type: application/json" \
  -H "X-Edge-Access-Token: <YOUR_TOKEN>" \
  -d '{
    ...
  }'

existsNodeTasks

检查是否有正在执行的任务

  • 角色:admin
  • HTTPPOST https://backend.dooki.cloud/NodeTaskService/existsNodeTasks
  • RPCrpc existsNodeTasks (ExistsNodeTasksRequest) returns (ExistsNodeTasksResponse);

请求对象 (ExistsNodeTasksRequest)

{
  "excludeTypes": "[]string"
}

响应对象 (ExistsNodeTasksResponse)

{
  "existTasks": "bool",
  "existError": "bool"
}

调用示例

curl -X POST "https://backend.dooki.cloud/NodeTaskService/existsNodeTasks" \
  -H "Content-Type: application/json" \
  -H "X-Edge-Access-Token: <YOUR_TOKEN>" \
  -d '{
    ...
  }'

findNodeClusterTasks

获取所有正在同步的集群信息

  • 角色:admin
  • HTTPPOST https://backend.dooki.cloud/NodeTaskService/findNodeClusterTasks
  • RPCrpc findNodeClusterTasks (FindNodeClusterTasksRequest) returns (FindNodeClusterTasksResponse);

请求对象 (FindNodeClusterTasksRequest)

{}

响应对象 (FindNodeClusterTasksResponse)

{
  "clusterTasks": "[]ClusterTask"
}

调用示例

curl -X POST "https://backend.dooki.cloud/NodeTaskService/findNodeClusterTasks" \
  -H "Content-Type: application/json" \
  -H "X-Edge-Access-Token: <YOUR_TOKEN>" \
  -d '{
    ...
  }'

findNotifyingNodeTasks

查找需要通知的任务

  • 角色:admin
  • HTTPPOST https://backend.dooki.cloud/NodeTaskService/findNotifyingNodeTasks
  • RPCrpc findNotifyingNodeTasks (FindNotifyingNodeTasksRequest) returns (FindNotifyingNodeTasksResponse);

请求对象 (FindNotifyingNodeTasksRequest)

{
  "size": "int64 // 数量通常不能小于0"
}

响应对象 (FindNotifyingNodeTasksResponse)

{
  "nodeTasks": "[]NodeTask"
}

调用示例

curl -X POST "https://backend.dooki.cloud/NodeTaskService/findNotifyingNodeTasks" \
  -H "Content-Type: application/json" \
  -H "X-Edge-Access-Token: <YOUR_TOKEN>" \
  -d '{
    ...
  }'

updateNodeTasksNotified

设置任务已通知

  • 角色:admin
  • HTTPPOST https://backend.dooki.cloud/NodeTaskService/updateNodeTasksNotified
  • RPCrpc updateNodeTasksNotified (UpdateNodeTasksNotifiedRequest) returns (RPCSuccess);

请求对象 (UpdateNodeTasksNotifiedRequest)

{
  "nodeTaskIds": "[]int64"
}

响应对象 (RPCSuccess)

{}

调用示例

curl -X POST "https://backend.dooki.cloud/NodeTaskService/updateNodeTasksNotified" \
  -H "Content-Type: application/json" \
  -H "X-Edge-Access-Token: <YOUR_TOKEN>" \
  -d '{
    ...
  }'