server

Documentation

Index

• type JobServer
  • func NewJobServer(svcCtx *svc.ServiceContext) *JobServer
  • func (s *JobServer) CreateTask(ctx context.Context, in *job.TaskInfo) (*job.BaseIDResp, error)
  • func (s *JobServer) CreateTaskLog(ctx context.Context, in *job.TaskLogInfo) (*job.BaseIDResp, error)
  • func (s *JobServer) DeleteTask(ctx context.Context, in *job.IDsReq) (*job.BaseResp, error)
  • func (s *JobServer) DeleteTaskLog(ctx context.Context, in *job.IDsReq) (*job.BaseResp, error)
  • func (s *JobServer) GetTaskById(ctx context.Context, in *job.IDReq) (*job.TaskInfo, error)
  • func (s *JobServer) GetTaskList(ctx context.Context, in *job.TaskListReq) (*job.TaskListResp, error)
  • func (s *JobServer) GetTaskLogById(ctx context.Context, in *job.IDReq) (*job.TaskLogInfo, error)
  • func (s *JobServer) GetTaskLogList(ctx context.Context, in *job.TaskLogListReq) (*job.TaskLogListResp, error)
  • func (s *JobServer) InitDatabase(ctx context.Context, in *job.Empty) (*job.BaseResp, error)
  • func (s *JobServer) UpdateTask(ctx context.Context, in *job.TaskInfo) (*job.BaseResp, error)
  • func (s *JobServer) UpdateTaskLog(ctx context.Context, in *job.TaskLogInfo) (*job.BaseResp, error)

Types

type JobServer

type JobServer struct {
	job.UnimplementedJobServer
	// contains filtered or unexported fields
}

func NewJobServer

func NewJobServer(svcCtx *svc.ServiceContext) *JobServer

func (*JobServer) CreateTask

func (s *JobServer) CreateTask(ctx context.Context, in *job.TaskInfo) (*job.BaseIDResp, error)

Task management

func (*JobServer) CreateTaskLog

func (s *JobServer) CreateTaskLog(ctx context.Context, in *job.TaskLogInfo) (*job.BaseIDResp, error)

TaskLog management

func (*JobServer) DeleteTask

func (s *JobServer) DeleteTask(ctx context.Context, in *job.IDsReq) (*job.BaseResp, error)

func (*JobServer) DeleteTaskLog

func (s *JobServer) DeleteTaskLog(ctx context.Context, in *job.IDsReq) (*job.BaseResp, error)

func (*JobServer) GetTaskById

func (s *JobServer) GetTaskById(ctx context.Context, in *job.IDReq) (*job.TaskInfo, error)

func (*JobServer) GetTaskList

func (s *JobServer) GetTaskList(ctx context.Context, in *job.TaskListReq) (*job.TaskListResp, error)

func (*JobServer) GetTaskLogById

func (s *JobServer) GetTaskLogById(ctx context.Context, in *job.IDReq) (*job.TaskLogInfo, error)

func (*JobServer) GetTaskLogList

func (s *JobServer) GetTaskLogList(ctx context.Context, in *job.TaskLogListReq) (*job.TaskLogListResp, error)

func (*JobServer) InitDatabase

func (s *JobServer) InitDatabase(ctx context.Context, in *job.Empty) (*job.BaseResp, error)

func (*JobServer) UpdateTask

func (s *JobServer) UpdateTask(ctx context.Context, in *job.TaskInfo) (*job.BaseResp, error)

func (*JobServer) UpdateTaskLog

func (s *JobServer) UpdateTaskLog(ctx context.Context, in *job.TaskLogInfo) (*job.BaseResp, error)