job.proto

syntax = "proto3";

package job;
option go_package="./job";

message IDReq {
  uint64 id = 1;
}

message TaskListResp {
  uint64 total = 1;
  repeated TaskInfo data = 2;
}

message TaskLogListReq {
  uint64 page = 1;
  uint64 page_size = 2;
  optional uint64 task_id = 3;
  optional uint32 result = 4;
}

//  base message
message Empty {}

message TaskListReq {
  uint64 page = 1;
  uint64 page_size = 2;
  optional string name = 3;
  optional string task_group = 4;
}

message TaskLogInfo {
  optional uint64 id = 1;
  optional int64 created_at = 2;
  optional int64 updated_at = 3;
  optional int64 started_at = 4;
  optional int64 finished_at = 5;
  optional uint32 result = 6;
}

message TaskLogListResp {
  uint64 total = 1;
  repeated TaskLogInfo data = 2;
}

message TaskInfo {
  optional uint64 id = 1;
  optional int64 created_at = 2;
  optional int64 updated_at = 3;
  optional uint32 status = 4;
  optional string name = 5;
  optional string task_group = 6;
  optional string cron_expression = 7;
  optional string pattern = 8;
  optional string payload = 9;
}

message UUIDsReq {
  repeated string ids = 1;
}

message UUIDReq {
  string id = 1;
}

message BaseResp {
  string msg = 1;
}

message PageInfoReq {
  uint64 page = 1;
  uint64 page_size = 2;
}

message IDsReq {
  repeated uint64 ids = 1;
}

message BaseUUIDResp {
  string id = 1;
  string msg = 2;
}

message BaseIDResp {
  uint64 id = 1;
  string msg = 2;
}

service Job {
  //  group: base
  rpc initDatabase(Empty) returns (BaseResp);
  //  Task management
  //  group: task
  rpc createTask(TaskInfo) returns (BaseIDResp);
  //  group: task
  rpc updateTask(TaskInfo) returns (BaseResp);
  //  group: task
  rpc getTaskList(TaskListReq) returns (TaskListResp);
  //  group: task
  rpc getTaskById(IDReq) returns (TaskInfo);
  //  group: task
  rpc deleteTask(IDsReq) returns (BaseResp);
  //  TaskLog management
  //  group: tasklog
  rpc createTaskLog(TaskLogInfo) returns (BaseIDResp);
  //  group: tasklog
  rpc updateTaskLog(TaskLogInfo) returns (BaseResp);
  //  group: tasklog
  rpc getTaskLogList(TaskLogListReq) returns (TaskLogListResp);
  //  group: tasklog
  rpc getTaskLogById(IDReq) returns (TaskLogInfo);
  //  group: tasklog
  rpc deleteTaskLog(IDsReq) returns (BaseResp);
}