app

Documentation

Index

• func New(c *conf.Config, hs *http.Server, gs *grpc.Server)
• type Log
  • func NewLog(conf *conf.Config) *Log
  • func (s *Log) GetLog(c context.Context, req *pb.GetLogRequest) (*pb.GetLogReply, error)
  • func (s *Log) ListLog(c context.Context, req *pb.ListLogRequest) (*pb.ListLogReply, error)
• type Task
  • func NewTask(conf *conf.Config) *Task
  • func (s *Task) CancelExecTask(c context.Context, req *pb.CancelExecTaskRequest) (*pb.CancelExecTaskReply, error)
  • func (s *Task) CreateTask(c context.Context, req *pb.CreateTaskRequest) (*pb.CreateTaskReply, error)
  • func (s *Task) CreateTaskGroup(c context.Context, req *pb.CreateTaskGroupRequest) (*pb.CreateTaskGroupReply, error)
  • func (s *Task) DeleteTask(c context.Context, req *pb.DeleteTaskRequest) (*pb.DeleteTaskReply, error)
  • func (s *Task) DeleteTaskGroup(c context.Context, req *pb.DeleteTaskGroupRequest) (*pb.DeleteTaskGroupReply, error)
  • func (s *Task) ExecTask(c context.Context, req *pb.ExecTaskRequest) (*pb.ExecTaskReply, error)
  • func (s *Task) GetTask(c context.Context, req *pb.GetTaskRequest) (*pb.GetTaskReply, error)
  • func (s *Task) GetTaskGroup(c context.Context, req *pb.GetTaskGroupRequest) (*pb.GetTaskGroupReply, error)
  • func (s *Task) ListTask(c context.Context, req *pb.ListTaskRequest) (*pb.ListTaskReply, error)
  • func (s *Task) ListTaskGroup(c context.Context, req *pb.ListTaskGroupRequest) (*pb.ListTaskGroupReply, error)
  • func (s *Task) UpdateTask(c context.Context, req *pb.UpdateTaskRequest) (*pb.UpdateTaskReply, error)
  • func (s *Task) UpdateTaskGroup(c context.Context, req *pb.UpdateTaskGroupRequest) (*pb.UpdateTaskGroupReply, error)
  • func (s *Task) UpdateTaskStatus(c context.Context, req *pb.UpdateTaskStatusRequest) (*pb.UpdateTaskStatusReply, error)
• type Worker
  • func NewWorker(conf *conf.Config) *Worker
  • func (s *Worker) CreateWorker(c context.Context, req *pb.CreateWorkerRequest) (*pb.CreateWorkerReply, error)
  • func (s *Worker) CreateWorkerGroup(c context.Context, req *pb.CreateWorkerGroupRequest) (*pb.CreateWorkerGroupReply, error)
  • func (s *Worker) DeleteWorker(c context.Context, req *pb.DeleteWorkerRequest) (*pb.DeleteWorkerReply, error)
  • func (s *Worker) DeleteWorkerGroup(c context.Context, req *pb.DeleteWorkerGroupRequest) (*pb.DeleteWorkerGroupReply, error)
  • func (s *Worker) GetWorker(c context.Context, req *pb.GetWorkerRequest) (*pb.GetWorkerReply, error)
  • func (s *Worker) GetWorkerGroup(c context.Context, req *pb.GetWorkerGroupRequest) (*pb.GetWorkerGroupReply, error)
  • func (s *Worker) ListWorker(c context.Context, req *pb.ListWorkerRequest) (*pb.ListWorkerReply, error)
  • func (s *Worker) ListWorkerGroup(c context.Context, req *pb.ListWorkerGroupRequest) (*pb.ListWorkerGroupReply, error)
  • func (s *Worker) UpdateWorker(c context.Context, req *pb.UpdateWorkerRequest) (*pb.UpdateWorkerReply, error)
  • func (s *Worker) UpdateWorkerGroup(c context.Context, req *pb.UpdateWorkerGroupRequest) (*pb.UpdateWorkerGroupReply, error)
  • func (s *Worker) UpdateWorkerStatus(c context.Context, req *pb.UpdateWorkerStatusRequest) (*pb.UpdateWorkerStatusReply, error)

Functions

func New

func New(c *conf.Config, hs *http.Server, gs *grpc.Server)

Types

type Log

type Log struct {
	pb.UnimplementedLogServer
	// contains filtered or unexported fields
}

func NewLog

func NewLog(conf *conf.Config) *Log

func (*Log) GetLog

func (s *Log) GetLog(c context.Context, req *pb.GetLogRequest) (*pb.GetLogReply, error)

GetLog 获取指定的日志信息

func (*Log) ListLog

func (s *Log) ListLog(c context.Context, req *pb.ListLogRequest) (*pb.ListLogReply, error)

ListLog 获取日志信息列表

type Task

type Task struct {
	pb.UnimplementedTaskServer
	// contains filtered or unexported fields
}

func NewTask

func NewTask(conf *conf.Config) *Task

func (*Task) CancelExecTask

func (s *Task) CancelExecTask(c context.Context, req *pb.CancelExecTaskRequest) (*pb.CancelExecTaskReply, error)

CancelExecTask 取消任务信息

func (*Task) CreateTask

func (s *Task) CreateTask(c context.Context, req *pb.CreateTaskRequest) (*pb.CreateTaskReply, error)

CreateTask 创建任务信息

func (*Task) CreateTaskGroup

func (s *Task) CreateTaskGroup(c context.Context, req *pb.CreateTaskGroupRequest) (*pb.CreateTaskGroupReply, error)

CreateTaskGroup 创建任务分组

func (*Task) DeleteTask

func (s *Task) DeleteTask(c context.Context, req *pb.DeleteTaskRequest) (*pb.DeleteTaskReply, error)

DeleteTask 删除任务信息

func (*Task) DeleteTaskGroup

func (s *Task) DeleteTaskGroup(c context.Context, req *pb.DeleteTaskGroupRequest) (*pb.DeleteTaskGroupReply, error)

DeleteTaskGroup 删除任务分组

func (*Task) ExecTask

func (s *Task) ExecTask(c context.Context, req *pb.ExecTaskRequest) (*pb.ExecTaskReply, error)

ExecTask 执行任务信息

func (*Task) GetTask

func (s *Task) GetTask(c context.Context, req *pb.GetTaskRequest) (*pb.GetTaskReply, error)

GetTask 获取指定的任务信息

func (*Task) GetTaskGroup

func (s *Task) GetTaskGroup(c context.Context, req *pb.GetTaskGroupRequest) (*pb.GetTaskGroupReply, error)

GetTaskGroup 获取指定的任务分组

func (*Task) ListTask

func (s *Task) ListTask(c context.Context, req *pb.ListTaskRequest) (*pb.ListTaskReply, error)

ListTask 获取任务信息列表

func (*Task) ListTaskGroup

func (s *Task) ListTaskGroup(c context.Context, req *pb.ListTaskGroupRequest) (*pb.ListTaskGroupReply, error)

ListTaskGroup 获取任务分组列表

func (*Task) UpdateTask

func (s *Task) UpdateTask(c context.Context, req *pb.UpdateTaskRequest) (*pb.UpdateTaskReply, error)

UpdateTask 更新任务信息

func (*Task) UpdateTaskGroup

func (s *Task) UpdateTaskGroup(c context.Context, req *pb.UpdateTaskGroupRequest) (*pb.UpdateTaskGroupReply, error)

UpdateTaskGroup 更新任务分组

func (*Task) UpdateTaskStatus

func (s *Task) UpdateTaskStatus(c context.Context, req *pb.UpdateTaskStatusRequest) (*pb.UpdateTaskStatusReply, error)

UpdateTaskStatus 更新任务信息状态

type Worker

type Worker struct {
	pb.UnimplementedWorkerServer
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(conf *conf.Config) *Worker

func (*Worker) CreateWorker

func (s *Worker) CreateWorker(c context.Context, req *pb.CreateWorkerRequest) (*pb.CreateWorkerReply, error)

CreateWorker 创建节点信息

func (*Worker) CreateWorkerGroup

func (s *Worker) CreateWorkerGroup(c context.Context, req *pb.CreateWorkerGroupRequest) (*pb.CreateWorkerGroupReply, error)

CreateWorkerGroup 创建节点分组

func (*Worker) DeleteWorker

func (s *Worker) DeleteWorker(c context.Context, req *pb.DeleteWorkerRequest) (*pb.DeleteWorkerReply, error)

DeleteWorker 删除节点信息

func (*Worker) DeleteWorkerGroup

func (s *Worker) DeleteWorkerGroup(c context.Context, req *pb.DeleteWorkerGroupRequest) (*pb.DeleteWorkerGroupReply, error)

DeleteWorkerGroup 删除节点分组

func (*Worker) GetWorker

func (s *Worker) GetWorker(c context.Context, req *pb.GetWorkerRequest) (*pb.GetWorkerReply, error)

GetWorker 获取指定的节点信息

func (*Worker) GetWorkerGroup

func (s *Worker) GetWorkerGroup(c context.Context, req *pb.GetWorkerGroupRequest) (*pb.GetWorkerGroupReply, error)

GetWorkerGroup 获取指定的节点分组

func (*Worker) ListWorker

func (s *Worker) ListWorker(c context.Context, req *pb.ListWorkerRequest) (*pb.ListWorkerReply, error)

ListWorker 获取节点信息列表

func (*Worker) ListWorkerGroup

func (s *Worker) ListWorkerGroup(c context.Context, req *pb.ListWorkerGroupRequest) (*pb.ListWorkerGroupReply, error)

ListWorkerGroup 获取节点分组列表

func (*Worker) UpdateWorker

func (s *Worker) UpdateWorker(c context.Context, req *pb.UpdateWorkerRequest) (*pb.UpdateWorkerReply, error)

UpdateWorker 更新节点信息

func (*Worker) UpdateWorkerGroup

func (s *Worker) UpdateWorkerGroup(c context.Context, req *pb.UpdateWorkerGroupRequest) (*pb.UpdateWorkerGroupReply, error)

UpdateWorkerGroup 更新节点分组

func (*Worker) UpdateWorkerStatus

func (s *Worker) UpdateWorkerStatus(c context.Context, req *pb.UpdateWorkerStatusRequest) (*pb.UpdateWorkerStatusReply, error)

UpdateWorkerStatus 更新节点信息状态