service

Documentation

Index

• type Service
  • func New(conf *conf.Config) *Service
  • func (s *Service) AddTask(ctx context.Context, in *v1.AddTaskRequest) (*v1.AddTaskReply, error)
  • func (s *Service) AddTaskGroup(ctx context.Context, in *v1.AddTaskGroupRequest) (*v1.AddTaskGroupReply, error)
  • func (s *Service) AddWorker(ctx context.Context, in *v1.AddWorkerRequest) (*v1.AddWorkerReply, error)
  • func (s *Service) AddWorkerGroup(ctx context.Context, in *v1.AddWorkerGroupRequest) (*v1.AddWorkerGroupReply, error)
  • func (s *Service) AllTaskGroup(ctx context.Context, _ *emptypb.Empty) (*v1.AllTaskGroupReply, error)
  • func (s *Service) AllWorkerGroup(ctx context.Context, _ *emptypb.Empty) (*v1.AllWorkerGroupReply, error)
  • func (s *Service) CancelExecTask(ctx context.Context, in *v1.CancelExecTaskRequest) (*emptypb.Empty, error)
  • func (s *Service) DeleteTask(ctx context.Context, in *v1.DeleteTaskRequest) (*emptypb.Empty, error)
  • func (s *Service) DeleteTaskGroup(ctx context.Context, in *v1.DeleteTaskGroupRequest) (*emptypb.Empty, error)
  • func (s *Service) DeleteWorker(ctx context.Context, in *v1.DeleteWorkerRequest) (*emptypb.Empty, error)
  • func (s *Service) DeleteWorkerGroup(ctx context.Context, in *v1.DeleteWorkerGroupRequest) (*emptypb.Empty, error)
  • func (s *Service) DisableTask(ctx context.Context, in *v1.DisableTaskRequest) (*emptypb.Empty, error)
  • func (s *Service) DisableWorker(ctx context.Context, in *v1.DisableWorkerRequest) (*emptypb.Empty, error)
  • func (s *Service) EnableTask(ctx context.Context, in *v1.EnableTaskRequest) (*emptypb.Empty, error)
  • func (s *Service) EnableWorker(ctx context.Context, in *v1.EnableWorkerRequest) (*emptypb.Empty, error)
  • func (s *Service) ExecTask(ctx context.Context, in *v1.ExecTaskRequest) (*emptypb.Empty, error)
  • func (s *Service) GetLog(ctx context.Context, in *v1.GetLogRequest) (*v1.Log, error)
  • func (s *Service) PageLog(ctx context.Context, in *v1.PageLogRequest) (*v1.PageLogReply, error)
  • func (s *Service) PageTask(ctx context.Context, in *v1.PageTaskRequest) (*v1.PageTaskReply, error)
  • func (s *Service) PageWorker(ctx context.Context, in *v1.PageWorkerRequest) (*v1.PageWorkerReply, error)
  • func (s *Service) UpdateTask(ctx context.Context, in *v1.UpdateTaskRequest) (*emptypb.Empty, error)
  • func (s *Service) UpdateTaskGroup(ctx context.Context, in *v1.UpdateTaskGroupRequest) (*emptypb.Empty, error)
  • func (s *Service) UpdateWorker(ctx context.Context, in *v1.UpdateWorkerRequest) (*emptypb.Empty, error)
  • func (s *Service) UpdateWorkerGroup(ctx context.Context, in *v1.UpdateWorkerGroupRequest) (*emptypb.Empty, error)

Types

type Service

type Service struct {
	v1.UnimplementedServiceServer
	// contains filtered or unexported fields
}

func New

func New(conf *conf.Config) *Service

func (*Service) AddTask

func (s *Service) AddTask(ctx context.Context, in *v1.AddTaskRequest) (*v1.AddTaskReply, error)

func (*Service) AddTaskGroup

func (s *Service) AddTaskGroup(ctx context.Context, in *v1.AddTaskGroupRequest) (*v1.AddTaskGroupReply, error)

func (*Service) AddWorker

func (s *Service) AddWorker(ctx context.Context, in *v1.AddWorkerRequest) (*v1.AddWorkerReply, error)

func (*Service) AddWorkerGroup

func (s *Service) AddWorkerGroup(ctx context.Context, in *v1.AddWorkerGroupRequest) (*v1.AddWorkerGroupReply, error)

func (*Service) AllTaskGroup

func (s *Service) AllTaskGroup(ctx context.Context, _ *emptypb.Empty) (*v1.AllTaskGroupReply, error)

func (*Service) AllWorkerGroup

func (s *Service) AllWorkerGroup(ctx context.Context, _ *emptypb.Empty) (*v1.AllWorkerGroupReply, error)

func (*Service) CancelExecTask

func (s *Service) CancelExecTask(ctx context.Context, in *v1.CancelExecTaskRequest) (*emptypb.Empty, error)

func (*Service) DeleteTask

func (s *Service) DeleteTask(ctx context.Context, in *v1.DeleteTaskRequest) (*emptypb.Empty, error)

func (*Service) DeleteTaskGroup

func (s *Service) DeleteTaskGroup(ctx context.Context, in *v1.DeleteTaskGroupRequest) (*emptypb.Empty, error)

func (*Service) DeleteWorker

func (s *Service) DeleteWorker(ctx context.Context, in *v1.DeleteWorkerRequest) (*emptypb.Empty, error)

func (*Service) DeleteWorkerGroup

func (s *Service) DeleteWorkerGroup(ctx context.Context, in *v1.DeleteWorkerGroupRequest) (*emptypb.Empty, error)

func (*Service) DisableTask

func (s *Service) DisableTask(ctx context.Context, in *v1.DisableTaskRequest) (*emptypb.Empty, error)

func (*Service) DisableWorker

func (s *Service) DisableWorker(ctx context.Context, in *v1.DisableWorkerRequest) (*emptypb.Empty, error)

func (*Service) EnableTask

func (s *Service) EnableTask(ctx context.Context, in *v1.EnableTaskRequest) (*emptypb.Empty, error)

func (*Service) EnableWorker

func (s *Service) EnableWorker(ctx context.Context, in *v1.EnableWorkerRequest) (*emptypb.Empty, error)

func (*Service) ExecTask

func (s *Service) ExecTask(ctx context.Context, in *v1.ExecTaskRequest) (*emptypb.Empty, error)

func (*Service) GetLog

func (s *Service) GetLog(ctx context.Context, in *v1.GetLogRequest) (*v1.Log, error)

func (*Service) PageLog

func (s *Service) PageLog(ctx context.Context, in *v1.PageLogRequest) (*v1.PageLogReply, error)

func (*Service) PageTask

func (s *Service) PageTask(ctx context.Context, in *v1.PageTaskRequest) (*v1.PageTaskReply, error)

func (*Service) PageWorker

func (s *Service) PageWorker(ctx context.Context, in *v1.PageWorkerRequest) (*v1.PageWorkerReply, error)

func (*Service) UpdateTask

func (s *Service) UpdateTask(ctx context.Context, in *v1.UpdateTaskRequest) (*emptypb.Empty, error)

func (*Service) UpdateTaskGroup

func (s *Service) UpdateTaskGroup(ctx context.Context, in *v1.UpdateTaskGroupRequest) (*emptypb.Empty, error)

func (*Service) UpdateWorker

func (s *Service) UpdateWorker(ctx context.Context, in *v1.UpdateWorkerRequest) (*emptypb.Empty, error)

func (*Service) UpdateWorkerGroup

func (s *Service) UpdateWorkerGroup(ctx context.Context, in *v1.UpdateWorkerGroupRequest) (*emptypb.Empty, error)