server

Documentation

Index

• type TimedManageServer
  • func NewTimedManageServer(svcCtx *svc.ServiceContext) *TimedManageServer
  • func (s *TimedManageServer) TaskCancel(ctx context.Context, in *timedjob.TaskWithTaskID) (*timedjob.Response, error)
  • func (s *TimedManageServer) TaskGroupCreate(ctx context.Context, in *timedjob.TaskGroup) (*timedjob.Response, error)
  • func (s *TimedManageServer) TaskGroupDelete(ctx context.Context, in *timedjob.WithCode) (*timedjob.Response, error)
  • func (s *TimedManageServer) TaskGroupIndex(ctx context.Context, in *timedjob.TaskGroupIndexReq) (*timedjob.TaskGroupIndexResp, error)
  • func (s *TimedManageServer) TaskGroupRead(ctx context.Context, in *timedjob.WithCode) (*timedjob.TaskGroup, error)
  • func (s *TimedManageServer) TaskGroupUpdate(ctx context.Context, in *timedjob.TaskGroup) (*timedjob.Response, error)
  • func (s *TimedManageServer) TaskInfoCreate(ctx context.Context, in *timedjob.TaskInfo) (*timedjob.Response, error)
  • func (s *TimedManageServer) TaskInfoDelete(ctx context.Context, in *timedjob.WithGroupCode) (*timedjob.Response, error)
  • func (s *TimedManageServer) TaskInfoIndex(ctx context.Context, in *timedjob.TaskInfoIndexReq) (*timedjob.TaskInfoIndexResp, error)
  • func (s *TimedManageServer) TaskInfoRead(ctx context.Context, in *timedjob.WithGroupCode) (*timedjob.TaskInfo, error)
  • func (s *TimedManageServer) TaskInfoUpdate(ctx context.Context, in *timedjob.TaskInfo) (*timedjob.Response, error)
  • func (s *TimedManageServer) TaskLogIndex(ctx context.Context, in *timedjob.TaskLogIndexReq) (*timedjob.TaskLogIndexResp, error)
  • func (s *TimedManageServer) TaskSend(ctx context.Context, in *timedjob.TaskSendReq) (*timedjob.TaskWithTaskID, error)

Types

type TimedManageServer

type TimedManageServer struct {
	timedjob.UnimplementedTimedManageServer
	// contains filtered or unexported fields
}

func NewTimedManageServer

func NewTimedManageServer(svcCtx *svc.ServiceContext) *TimedManageServer

func (*TimedManageServer) TaskCancel

func (s *TimedManageServer) TaskCancel(ctx context.Context, in *timedjob.TaskWithTaskID) (*timedjob.Response, error)

func (*TimedManageServer) TaskGroupCreate

func (s *TimedManageServer) TaskGroupCreate(ctx context.Context, in *timedjob.TaskGroup) (*timedjob.Response, error)

func (*TimedManageServer) TaskGroupDelete

func (s *TimedManageServer) TaskGroupDelete(ctx context.Context, in *timedjob.WithCode) (*timedjob.Response, error)

func (*TimedManageServer) TaskGroupIndex

func (s *TimedManageServer) TaskGroupIndex(ctx context.Context, in *timedjob.TaskGroupIndexReq) (*timedjob.TaskGroupIndexResp, error)

func (*TimedManageServer) TaskGroupRead

func (s *TimedManageServer) TaskGroupRead(ctx context.Context, in *timedjob.WithCode) (*timedjob.TaskGroup, error)

func (*TimedManageServer) TaskGroupUpdate

func (s *TimedManageServer) TaskGroupUpdate(ctx context.Context, in *timedjob.TaskGroup) (*timedjob.Response, error)

func (*TimedManageServer) TaskInfoCreate

func (s *TimedManageServer) TaskInfoCreate(ctx context.Context, in *timedjob.TaskInfo) (*timedjob.Response, error)

func (*TimedManageServer) TaskInfoDelete

func (s *TimedManageServer) TaskInfoDelete(ctx context.Context, in *timedjob.WithGroupCode) (*timedjob.Response, error)

func (*TimedManageServer) TaskInfoIndex

func (s *TimedManageServer) TaskInfoIndex(ctx context.Context, in *timedjob.TaskInfoIndexReq) (*timedjob.TaskInfoIndexResp, error)

func (*TimedManageServer) TaskInfoRead

func (s *TimedManageServer) TaskInfoRead(ctx context.Context, in *timedjob.WithGroupCode) (*timedjob.TaskInfo, error)

func (*TimedManageServer) TaskInfoUpdate

func (s *TimedManageServer) TaskInfoUpdate(ctx context.Context, in *timedjob.TaskInfo) (*timedjob.Response, error)

func (*TimedManageServer) TaskLogIndex

func (s *TimedManageServer) TaskLogIndex(ctx context.Context, in *timedjob.TaskLogIndexReq) (*timedjob.TaskLogIndexResp, error)

func (*TimedManageServer) TaskSend

func (s *TimedManageServer) TaskSend(ctx context.Context, in *timedjob.TaskSendReq) (*timedjob.TaskWithTaskID, error)

发送延时请求,如果任务不存在,则会自动创建,但是自动创建的需要填写param