timedmanage

Documentation

Index

• type PageInfo
• type PageInfo_OrderBy
• type Response
• type TaskExecLog
• type TaskGroup
• type TaskGroupIndexReq
• type TaskGroupIndexResp
• type TaskInfo
• type TaskInfoIndexReq
• type TaskInfoIndexResp
• type TaskLog
• type TaskLogIndexReq
• type TaskLogIndexResp
• type TaskLogScript
• type TaskLogSql
• type TaskParamQueue
• type TaskParamScript
• type TaskParamSql
• type TaskSendOption
• type TaskSendReq
• type TaskWithTaskID
• type TimedManage
  • func NewDirectTimedManage(svcCtx *svc.ServiceContext, svr timedjob.TimedManageServer) TimedManage
  • func NewTimedManage(cli zrpc.Client) TimedManage
• type WithCode
• type WithGroupCode

Types

type PageInfo

type PageInfo = timedjob.PageInfo

type PageInfo_OrderBy

type PageInfo_OrderBy = timedjob.PageInfo_OrderBy

type Response

type Response = timedjob.Response

type TaskExecLog

type TaskExecLog = timedjob.TaskExecLog

type TaskGroup

type TaskGroup = timedjob.TaskGroup

type TaskGroupIndexReq

type TaskGroupIndexReq = timedjob.TaskGroupIndexReq

type TaskGroupIndexResp

type TaskGroupIndexResp = timedjob.TaskGroupIndexResp

type TaskInfo

type TaskInfo = timedjob.TaskInfo

type TaskInfoIndexReq

type TaskInfoIndexReq = timedjob.TaskInfoIndexReq

type TaskInfoIndexResp

type TaskInfoIndexResp = timedjob.TaskInfoIndexResp

type TaskLog

type TaskLog = timedjob.TaskLog

type TaskLogIndexReq

type TaskLogIndexReq = timedjob.TaskLogIndexReq

type TaskLogIndexResp

type TaskLogIndexResp = timedjob.TaskLogIndexResp

type TaskLogScript

type TaskLogScript = timedjob.TaskLogScript

type TaskLogSql

type TaskLogSql = timedjob.TaskLogSql

type TaskParamQueue

type TaskParamQueue = timedjob.TaskParamQueue

type TaskParamScript

type TaskParamScript = timedjob.TaskParamScript

type TaskParamSql

type TaskParamSql = timedjob.TaskParamSql

type TaskSendOption

type TaskSendOption = timedjob.TaskSendOption

type TaskSendReq

type TaskSendReq = timedjob.TaskSendReq

type TaskWithTaskID

type TaskWithTaskID = timedjob.TaskWithTaskID

type TimedManage

type TimedManage interface {
	TaskGroupCreate(ctx context.Context, in *TaskGroup, opts ...grpc.CallOption) (*Response, error)
	TaskGroupUpdate(ctx context.Context, in *TaskGroup, opts ...grpc.CallOption) (*Response, error)
	TaskGroupDelete(ctx context.Context, in *WithCode, opts ...grpc.CallOption) (*Response, error)
	TaskGroupIndex(ctx context.Context, in *TaskGroupIndexReq, opts ...grpc.CallOption) (*TaskGroupIndexResp, error)
	TaskGroupRead(ctx context.Context, in *WithCode, opts ...grpc.CallOption) (*TaskGroup, error)
	TaskInfoCreate(ctx context.Context, in *TaskInfo, opts ...grpc.CallOption) (*Response, error)
	TaskInfoUpdate(ctx context.Context, in *TaskInfo, opts ...grpc.CallOption) (*Response, error)
	TaskInfoDelete(ctx context.Context, in *WithGroupCode, opts ...grpc.CallOption) (*Response, error)
	TaskInfoIndex(ctx context.Context, in *TaskInfoIndexReq, opts ...grpc.CallOption) (*TaskInfoIndexResp, error)
	TaskInfoRead(ctx context.Context, in *WithGroupCode, opts ...grpc.CallOption) (*TaskInfo, error)
	TaskLogIndex(ctx context.Context, in *TaskLogIndexReq, opts ...grpc.CallOption) (*TaskLogIndexResp, error)
	// 发送延时请求,如果任务不存在,则会自动创建,但是自动创建的需要填写param
	TaskSend(ctx context.Context, in *TaskSendReq, opts ...grpc.CallOption) (*TaskWithTaskID, error)
	TaskCancel(ctx context.Context, in *TaskWithTaskID, opts ...grpc.CallOption) (*Response, error)
}

func NewDirectTimedManage

func NewDirectTimedManage(svcCtx *svc.ServiceContext, svr timedjob.TimedManageServer) TimedManage

func NewTimedManage

func NewTimedManage(cli zrpc.Client) TimedManage

type WithCode

type WithCode = timedjob.WithCode

type WithGroupCode

type WithGroupCode = timedjob.WithGroupCode