Documentation ¶
Index ¶
- func New(c *conf.Config, hs *http.Server, gs *grpc.Server)
- type LogService
- type TaskService
- func (s *TaskService) CancelExecTask(c context.Context, req *pb.CancelExecTaskRequest) (*pb.CancelExecTaskReply, error)
- func (s *TaskService) CreateTask(c context.Context, req *pb.CreateTaskRequest) (*pb.CreateTaskReply, error)
- func (s *TaskService) CreateTaskGroup(c context.Context, req *pb.CreateTaskGroupRequest) (*pb.CreateTaskGroupReply, error)
- func (s *TaskService) DeleteTask(c context.Context, req *pb.DeleteTaskRequest) (*pb.DeleteTaskReply, error)
- func (s *TaskService) DeleteTaskGroup(c context.Context, req *pb.DeleteTaskGroupRequest) (*pb.DeleteTaskGroupReply, error)
- func (s *TaskService) ExecTask(c context.Context, req *pb.ExecTaskRequest) (*pb.ExecTaskReply, error)
- func (s *TaskService) GetTask(c context.Context, req *pb.GetTaskRequest) (*pb.GetTaskReply, error)
- func (s *TaskService) GetTaskGroup(c context.Context, req *pb.GetTaskGroupRequest) (*pb.GetTaskGroupReply, error)
- func (s *TaskService) ListTask(c context.Context, req *pb.ListTaskRequest) (*pb.ListTaskReply, error)
- func (s *TaskService) ListTaskGroup(c context.Context, req *pb.ListTaskGroupRequest) (*pb.ListTaskGroupReply, error)
- func (s *TaskService) UpdateTask(c context.Context, req *pb.UpdateTaskRequest) (*pb.UpdateTaskReply, error)
- func (s *TaskService) UpdateTaskGroup(c context.Context, req *pb.UpdateTaskGroupRequest) (*pb.UpdateTaskGroupReply, error)
- func (s *TaskService) UpdateTaskStatus(c context.Context, req *pb.UpdateTaskStatusRequest) (*pb.UpdateTaskStatusReply, error)
- type WorkerService
- func (s *WorkerService) CreateWorker(c context.Context, req *pb.CreateWorkerRequest) (*pb.CreateWorkerReply, error)
- func (s *WorkerService) CreateWorkerGroup(c context.Context, req *pb.CreateWorkerGroupRequest) (*pb.CreateWorkerGroupReply, error)
- func (s *WorkerService) DeleteWorker(c context.Context, req *pb.DeleteWorkerRequest) (*pb.DeleteWorkerReply, error)
- func (s *WorkerService) DeleteWorkerGroup(c context.Context, req *pb.DeleteWorkerGroupRequest) (*pb.DeleteWorkerGroupReply, error)
- func (s *WorkerService) GetWorker(c context.Context, req *pb.GetWorkerRequest) (*pb.GetWorkerReply, error)
- func (s *WorkerService) GetWorkerGroup(c context.Context, req *pb.GetWorkerGroupRequest) (*pb.GetWorkerGroupReply, error)
- func (s *WorkerService) ListWorker(c context.Context, req *pb.ListWorkerRequest) (*pb.ListWorkerReply, error)
- func (s *WorkerService) ListWorkerGroup(c context.Context, req *pb.ListWorkerGroupRequest) (*pb.ListWorkerGroupReply, error)
- func (s *WorkerService) UpdateWorker(c context.Context, req *pb.UpdateWorkerRequest) (*pb.UpdateWorkerReply, error)
- func (s *WorkerService) UpdateWorkerGroup(c context.Context, req *pb.UpdateWorkerGroupRequest) (*pb.UpdateWorkerGroupReply, error)
- func (s *WorkerService) UpdateWorkerStatus(c context.Context, req *pb.UpdateWorkerStatusRequest) (*pb.UpdateWorkerStatusReply, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type LogService ¶ added in v1.0.7
type LogService struct { pb.UnimplementedLogServer // contains filtered or unexported fields }
func NewLogService ¶ added in v1.0.7
func NewLogService(conf *conf.Config) *LogService
func (*LogService) DeleteLog ¶ added in v1.0.7
func (s *LogService) DeleteLog(c context.Context, req *pb.DeleteLogRequest) (*pb.DeleteLogReply, error)
DeleteLog 删除日志信息
func (*LogService) GetLog ¶ added in v1.0.7
func (s *LogService) GetLog(c context.Context, req *pb.GetLogRequest) (*pb.GetLogReply, error)
GetLog 获取指定的日志信息
func (*LogService) ListLog ¶ added in v1.0.7
func (s *LogService) ListLog(c context.Context, req *pb.ListLogRequest) (*pb.ListLogReply, error)
ListLog 获取日志信息列表
type TaskService ¶ added in v1.0.7
type TaskService struct { pb.UnimplementedTaskServer // contains filtered or unexported fields }
func NewTaskService ¶ added in v1.0.7
func NewTaskService(conf *conf.Config) *TaskService
func (*TaskService) CancelExecTask ¶ added in v1.0.7
func (s *TaskService) CancelExecTask(c context.Context, req *pb.CancelExecTaskRequest) (*pb.CancelExecTaskReply, error)
CancelExecTask 取消任务信息
func (*TaskService) CreateTask ¶ added in v1.0.7
func (s *TaskService) CreateTask(c context.Context, req *pb.CreateTaskRequest) (*pb.CreateTaskReply, error)
CreateTask 创建任务信息
func (*TaskService) CreateTaskGroup ¶ added in v1.0.7
func (s *TaskService) CreateTaskGroup(c context.Context, req *pb.CreateTaskGroupRequest) (*pb.CreateTaskGroupReply, error)
CreateTaskGroup 创建任务分组
func (*TaskService) DeleteTask ¶ added in v1.0.7
func (s *TaskService) DeleteTask(c context.Context, req *pb.DeleteTaskRequest) (*pb.DeleteTaskReply, error)
DeleteTask 删除任务信息
func (*TaskService) DeleteTaskGroup ¶ added in v1.0.7
func (s *TaskService) DeleteTaskGroup(c context.Context, req *pb.DeleteTaskGroupRequest) (*pb.DeleteTaskGroupReply, error)
DeleteTaskGroup 删除任务分组
func (*TaskService) ExecTask ¶ added in v1.0.7
func (s *TaskService) ExecTask(c context.Context, req *pb.ExecTaskRequest) (*pb.ExecTaskReply, error)
ExecTask 执行任务信息
func (*TaskService) GetTask ¶ added in v1.0.7
func (s *TaskService) GetTask(c context.Context, req *pb.GetTaskRequest) (*pb.GetTaskReply, error)
GetTask 获取指定的任务信息
func (*TaskService) GetTaskGroup ¶ added in v1.0.7
func (s *TaskService) GetTaskGroup(c context.Context, req *pb.GetTaskGroupRequest) (*pb.GetTaskGroupReply, error)
GetTaskGroup 获取指定的任务分组
func (*TaskService) ListTask ¶ added in v1.0.7
func (s *TaskService) ListTask(c context.Context, req *pb.ListTaskRequest) (*pb.ListTaskReply, error)
ListTask 获取任务信息列表
func (*TaskService) ListTaskGroup ¶ added in v1.0.7
func (s *TaskService) ListTaskGroup(c context.Context, req *pb.ListTaskGroupRequest) (*pb.ListTaskGroupReply, error)
ListTaskGroup 获取任务分组列表
func (*TaskService) UpdateTask ¶ added in v1.0.7
func (s *TaskService) UpdateTask(c context.Context, req *pb.UpdateTaskRequest) (*pb.UpdateTaskReply, error)
UpdateTask 更新任务信息
func (*TaskService) UpdateTaskGroup ¶ added in v1.0.7
func (s *TaskService) UpdateTaskGroup(c context.Context, req *pb.UpdateTaskGroupRequest) (*pb.UpdateTaskGroupReply, error)
UpdateTaskGroup 更新任务分组
func (*TaskService) UpdateTaskStatus ¶ added in v1.0.7
func (s *TaskService) UpdateTaskStatus(c context.Context, req *pb.UpdateTaskStatusRequest) (*pb.UpdateTaskStatusReply, error)
UpdateTaskStatus 更新任务信息状态
type WorkerService ¶ added in v1.0.7
type WorkerService struct { pb.UnimplementedWorkerServer // contains filtered or unexported fields }
func NewWorkerService ¶ added in v1.0.7
func NewWorkerService(conf *conf.Config) *WorkerService
func (*WorkerService) CreateWorker ¶ added in v1.0.7
func (s *WorkerService) CreateWorker(c context.Context, req *pb.CreateWorkerRequest) (*pb.CreateWorkerReply, error)
CreateWorker 创建节点信息
func (*WorkerService) CreateWorkerGroup ¶ added in v1.0.7
func (s *WorkerService) CreateWorkerGroup(c context.Context, req *pb.CreateWorkerGroupRequest) (*pb.CreateWorkerGroupReply, error)
CreateWorkerGroup 创建节点分组
func (*WorkerService) DeleteWorker ¶ added in v1.0.7
func (s *WorkerService) DeleteWorker(c context.Context, req *pb.DeleteWorkerRequest) (*pb.DeleteWorkerReply, error)
DeleteWorker 删除节点信息
func (*WorkerService) DeleteWorkerGroup ¶ added in v1.0.7
func (s *WorkerService) DeleteWorkerGroup(c context.Context, req *pb.DeleteWorkerGroupRequest) (*pb.DeleteWorkerGroupReply, error)
DeleteWorkerGroup 删除节点分组
func (*WorkerService) GetWorker ¶ added in v1.0.7
func (s *WorkerService) GetWorker(c context.Context, req *pb.GetWorkerRequest) (*pb.GetWorkerReply, error)
GetWorker 获取指定的节点信息
func (*WorkerService) GetWorkerGroup ¶ added in v1.0.7
func (s *WorkerService) GetWorkerGroup(c context.Context, req *pb.GetWorkerGroupRequest) (*pb.GetWorkerGroupReply, error)
GetWorkerGroup 获取指定的节点分组
func (*WorkerService) ListWorker ¶ added in v1.0.7
func (s *WorkerService) ListWorker(c context.Context, req *pb.ListWorkerRequest) (*pb.ListWorkerReply, error)
ListWorker 获取节点信息列表
func (*WorkerService) ListWorkerGroup ¶ added in v1.0.7
func (s *WorkerService) ListWorkerGroup(c context.Context, req *pb.ListWorkerGroupRequest) (*pb.ListWorkerGroupReply, error)
ListWorkerGroup 获取节点分组列表
func (*WorkerService) UpdateWorker ¶ added in v1.0.7
func (s *WorkerService) UpdateWorker(c context.Context, req *pb.UpdateWorkerRequest) (*pb.UpdateWorkerReply, error)
UpdateWorker 更新节点信息
func (*WorkerService) UpdateWorkerGroup ¶ added in v1.0.7
func (s *WorkerService) UpdateWorkerGroup(c context.Context, req *pb.UpdateWorkerGroupRequest) (*pb.UpdateWorkerGroupReply, error)
UpdateWorkerGroup 更新节点分组
func (*WorkerService) UpdateWorkerStatus ¶ added in v1.0.7
func (s *WorkerService) UpdateWorkerStatus(c context.Context, req *pb.UpdateWorkerStatusRequest) (*pb.UpdateWorkerStatusReply, error)
UpdateWorkerStatus 更新节点信息状态
Click to show internal directories.
Click to hide internal directories.