timedjob

package
v0.1.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 27, 2024 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TimedManage_TaskGroupCreate_FullMethodName = "/timedjob.TimedManage/TaskGroupCreate"
	TimedManage_TaskGroupUpdate_FullMethodName = "/timedjob.TimedManage/TaskGroupUpdate"
	TimedManage_TaskGroupDelete_FullMethodName = "/timedjob.TimedManage/TaskGroupDelete"
	TimedManage_TaskGroupIndex_FullMethodName  = "/timedjob.TimedManage/TaskGroupIndex"
	TimedManage_TaskGroupRead_FullMethodName   = "/timedjob.TimedManage/TaskGroupRead"
	TimedManage_TaskInfoCreate_FullMethodName  = "/timedjob.TimedManage/TaskInfoCreate"
	TimedManage_TaskInfoUpdate_FullMethodName  = "/timedjob.TimedManage/TaskInfoUpdate"
	TimedManage_TaskInfoDelete_FullMethodName  = "/timedjob.TimedManage/TaskInfoDelete"
	TimedManage_TaskInfoIndex_FullMethodName   = "/timedjob.TimedManage/TaskInfoIndex"
	TimedManage_TaskInfoRead_FullMethodName    = "/timedjob.TimedManage/TaskInfoRead"
	TimedManage_TaskLogIndex_FullMethodName    = "/timedjob.TimedManage/TaskLogIndex"
	TimedManage_TaskSend_FullMethodName        = "/timedjob.TimedManage/TaskSend"
	TimedManage_TaskCancel_FullMethodName      = "/timedjob.TimedManage/TaskCancel"
)

Variables

View Source 
var File_proto_timedjob_proto protoreflect.FileDescriptor
View Source 
var TimedManage_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "timedjob.TimedManage",
	HandlerType: (*TimedManageServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "TaskGroupCreate",
			Handler:    _TimedManage_TaskGroupCreate_Handler,
		},
		{
			MethodName: "TaskGroupUpdate",
			Handler:    _TimedManage_TaskGroupUpdate_Handler,
		},
		{
			MethodName: "TaskGroupDelete",
			Handler:    _TimedManage_TaskGroupDelete_Handler,
		},
		{
			MethodName: "TaskGroupIndex",
			Handler:    _TimedManage_TaskGroupIndex_Handler,
		},
		{
			MethodName: "TaskGroupRead",
			Handler:    _TimedManage_TaskGroupRead_Handler,
		},
		{
			MethodName: "TaskInfoCreate",
			Handler:    _TimedManage_TaskInfoCreate_Handler,
		},
		{
			MethodName: "TaskInfoUpdate",
			Handler:    _TimedManage_TaskInfoUpdate_Handler,
		},
		{
			MethodName: "TaskInfoDelete",
			Handler:    _TimedManage_TaskInfoDelete_Handler,
		},
		{
			MethodName: "TaskInfoIndex",
			Handler:    _TimedManage_TaskInfoIndex_Handler,
		},
		{
			MethodName: "TaskInfoRead",
			Handler:    _TimedManage_TaskInfoRead_Handler,
		},
		{
			MethodName: "TaskLogIndex",
			Handler:    _TimedManage_TaskLogIndex_Handler,
		},
		{
			MethodName: "TaskSend",
			Handler:    _TimedManage_TaskSend_Handler,
		},
		{
			MethodName: "TaskCancel",
			Handler:    _TimedManage_TaskCancel_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/timedjob.proto",
}

TimedManage_ServiceDesc is the grpc.ServiceDesc for TimedManage service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTimedManageServer 

func RegisterTimedManageServer(s grpc.ServiceRegistrar, srv TimedManageServer)

Types

type PageInfo 

type PageInfo struct {
	Page int64 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	Size int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// 排序信息
	Orders []*PageInfo_OrderBy `protobuf:"bytes,3,rep,name=orders,proto3" json:"orders,omitempty"`
	// contains filtered or unexported fields
}

func (*PageInfo) Descriptor deprecated 

func (*PageInfo) Descriptor() ([]byte, []int)

Deprecated: Use PageInfo.ProtoReflect.Descriptor instead.

func (*PageInfo) GetOrders 

func (x *PageInfo) GetOrders() []*PageInfo_OrderBy

func (*PageInfo) GetPage 

func (x *PageInfo) GetPage() int64

func (*PageInfo) GetSize 

func (x *PageInfo) GetSize() int64

func (*PageInfo) ProtoMessage 

func (*PageInfo) ProtoMessage()

func (*PageInfo) ProtoReflect 

func (x *PageInfo) ProtoReflect() protoreflect.Message

func (*PageInfo) Reset 

func (x *PageInfo) Reset()

func (*PageInfo) String 

func (x *PageInfo) String() string

type PageInfo_OrderBy 

type PageInfo_OrderBy struct {

	// 排序的字段名
	Filed string `protobuf:"bytes,1,opt,name=filed,proto3" json:"filed,omitempty"`
	// 排序方式：0 aes, 1 desc
	Sort int64 `protobuf:"varint,2,opt,name=sort,proto3" json:"sort,omitempty"`
	// contains filtered or unexported fields
}

func (*PageInfo_OrderBy) Descriptor deprecated 

func (*PageInfo_OrderBy) Descriptor() ([]byte, []int)

Deprecated: Use PageInfo_OrderBy.ProtoReflect.Descriptor instead.

func (*PageInfo_OrderBy) GetFiled 

func (x *PageInfo_OrderBy) GetFiled() string

func (*PageInfo_OrderBy) GetSort 

func (x *PageInfo_OrderBy) GetSort() int64

func (*PageInfo_OrderBy) ProtoMessage 

func (*PageInfo_OrderBy) ProtoMessage()

func (*PageInfo_OrderBy) ProtoReflect 

func (x *PageInfo_OrderBy) ProtoReflect() protoreflect.Message

func (*PageInfo_OrderBy) Reset 

func (x *PageInfo_OrderBy) Reset()

func (*PageInfo_OrderBy) String 

func (x *PageInfo_OrderBy) String() string

type Response 

type Response struct {
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

func (*Response) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type TaskExecLog 

type TaskExecLog struct {
	Level       string `protobuf:"bytes,1,opt,name=level,proto3" json:"level,omitempty"`              //日志级别: info warn error
	Content     string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`          //日志内容
	CreatedTime int64  `protobuf:"varint,3,opt,name=createdTime,proto3" json:"createdTime,omitempty"` //日志创建时间
	// contains filtered or unexported fields
}

func (*TaskExecLog) Descriptor deprecated 

func (*TaskExecLog) Descriptor() ([]byte, []int)

Deprecated: Use TaskExecLog.ProtoReflect.Descriptor instead.

func (*TaskExecLog) GetContent 

func (x *TaskExecLog) GetContent() string

func (*TaskExecLog) GetCreatedTime 

func (x *TaskExecLog) GetCreatedTime() int64

func (*TaskExecLog) GetLevel 

func (x *TaskExecLog) GetLevel() string

func (*TaskExecLog) ProtoMessage 

func (*TaskExecLog) ProtoMessage()

func (*TaskExecLog) ProtoReflect 

func (x *TaskExecLog) ProtoReflect() protoreflect.Message

func (*TaskExecLog) Reset 

func (x *TaskExecLog) Reset()

func (*TaskExecLog) String 

func (x *TaskExecLog) String() string

type TaskGroup 

type TaskGroup struct {
	Code     string            `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`          //任务组编码
	Name     string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`          // 组名
	Type     string            `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`          //组类型:queue(消息队列消息发送)  sql(执行sql) script(脚本执行) email(邮件发送) http(http请求)
	SubType  string            `protobuf:"bytes,4,opt,name=subType,proto3" json:"subType,omitempty"`    //组子类型 natsJs nats                    js
	Priority int64             `protobuf:"varint,5,opt,name=priority,proto3" json:"priority,omitempty"` //组优先级: 6:critical 最高优先级  3: default 普通优先级 1:low 低优先级
	Env      map[string]string ``                                                                       //环境变量
	/* 147-byte string literal not displayed */
	// 组的配置, sql类型配置格式如下,key若为select,则select默认会选择该配置,exec:exec执行sql默认会选择这个,执行sql的函数也可以指定连接
	// database: map[string]TaskGroupDBConfig
	Config string `protobuf:"bytes,7,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskGroup) Descriptor deprecated 

func (*TaskGroup) Descriptor() ([]byte, []int)

Deprecated: Use TaskGroup.ProtoReflect.Descriptor instead.

func (*TaskGroup) GetCode 

func (x *TaskGroup) GetCode() string

func (*TaskGroup) GetConfig 

func (x *TaskGroup) GetConfig() string

func (*TaskGroup) GetEnv 

func (x *TaskGroup) GetEnv() map[string]string

func (*TaskGroup) GetName 

func (x *TaskGroup) GetName() string

func (*TaskGroup) GetPriority 

func (x *TaskGroup) GetPriority() int64

func (*TaskGroup) GetSubType 

func (x *TaskGroup) GetSubType() string

func (*TaskGroup) GetType 

func (x *TaskGroup) GetType() string

func (*TaskGroup) ProtoMessage 

func (*TaskGroup) ProtoMessage()

func (*TaskGroup) ProtoReflect 

func (x *TaskGroup) ProtoReflect() protoreflect.Message

func (*TaskGroup) Reset 

func (x *TaskGroup) Reset()

func (*TaskGroup) String 

func (x *TaskGroup) String() string

type TaskGroupIndexReq 

type TaskGroupIndexReq struct {
	Page *PageInfo `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` //分页信息 只获取一个则不填
	// contains filtered or unexported fields
}

func (*TaskGroupIndexReq) Descriptor deprecated 

func (*TaskGroupIndexReq) Descriptor() ([]byte, []int)

Deprecated: Use TaskGroupIndexReq.ProtoReflect.Descriptor instead.

func (*TaskGroupIndexReq) GetPage 

func (x *TaskGroupIndexReq) GetPage() *PageInfo

func (*TaskGroupIndexReq) ProtoMessage 

func (*TaskGroupIndexReq) ProtoMessage()

func (*TaskGroupIndexReq) ProtoReflect 

func (x *TaskGroupIndexReq) ProtoReflect() protoreflect.Message

func (*TaskGroupIndexReq) Reset 

func (x *TaskGroupIndexReq) Reset()

func (*TaskGroupIndexReq) String 

func (x *TaskGroupIndexReq) String() string

type TaskGroupIndexResp 

type TaskGroupIndexResp struct {
	List  []*TaskGroup `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	Total int64        `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"` //总数(只有分页的时候会返回)
	// contains filtered or unexported fields
}

func (*TaskGroupIndexResp) Descriptor deprecated 

func (*TaskGroupIndexResp) Descriptor() ([]byte, []int)

Deprecated: Use TaskGroupIndexResp.ProtoReflect.Descriptor instead.

func (*TaskGroupIndexResp) GetList 

func (x *TaskGroupIndexResp) GetList() []*TaskGroup

func (*TaskGroupIndexResp) GetTotal 

func (x *TaskGroupIndexResp) GetTotal() int64

func (*TaskGroupIndexResp) ProtoMessage 

func (*TaskGroupIndexResp) ProtoMessage()

func (*TaskGroupIndexResp) ProtoReflect 

func (x *TaskGroupIndexResp) ProtoReflect() protoreflect.Message

func (*TaskGroupIndexResp) Reset 

func (x *TaskGroupIndexResp) Reset()

func (*TaskGroupIndexResp) String 

func (x *TaskGroupIndexResp) String() string

type TaskInfo 

type TaskInfo struct {
	GroupCode string   `protobuf:"bytes,2,opt,name=groupCode,proto3" json:"groupCode,omitempty"` //组编码
	Type      int64    `protobuf:"varint,3,opt,name=type,proto3" json:"type,omitempty"`          //任务类型 1 定时任务 2 延时任务 3 消息队列触发
	Name      string   `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`           // 任务名称
	Code      string   `protobuf:"bytes,5,opt,name=code,proto3" json:"code,omitempty"`           //任务编码
	Topics    []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`       //触发topic列表
	Params    string   `protobuf:"bytes,6,opt,name=params,proto3" json:"params,omitempty"`       // 任务参数,延时任务如果没有传任务参数会拿数据库的参数来执行
	CronExpr  string   `protobuf:"bytes,7,opt,name=cronExpr,proto3" json:"cronExpr,omitempty"`   // cron执行表达式
	Status    int64    `protobuf:"varint,8,opt,name=status,proto3" json:"status,omitempty"`      // 状态
	Priority  int64    `protobuf:"varint,9,opt,name=priority,proto3" json:"priority,omitempty"`  //优先级: 10:critical 最高优先级  3: default 普通优先级 1:low 低优先级
	// contains filtered or unexported fields
}

func (*TaskInfo) Descriptor deprecated 

func (*TaskInfo) Descriptor() ([]byte, []int)

Deprecated: Use TaskInfo.ProtoReflect.Descriptor instead.

func (*TaskInfo) GetCode 

func (x *TaskInfo) GetCode() string

func (*TaskInfo) GetCronExpr 

func (x *TaskInfo) GetCronExpr() string

func (*TaskInfo) GetGroupCode 

func (x *TaskInfo) GetGroupCode() string

func (*TaskInfo) GetName 

func (x *TaskInfo) GetName() string

func (*TaskInfo) GetParams 

func (x *TaskInfo) GetParams() string

func (*TaskInfo) GetPriority 

func (x *TaskInfo) GetPriority() int64

func (*TaskInfo) GetStatus 

func (x *TaskInfo) GetStatus() int64

func (*TaskInfo) GetTopics 

func (x *TaskInfo) GetTopics() []string

func (*TaskInfo) GetType 

func (x *TaskInfo) GetType() int64

func (*TaskInfo) ProtoMessage 

func (*TaskInfo) ProtoMessage()

func (*TaskInfo) ProtoReflect 

func (x *TaskInfo) ProtoReflect() protoreflect.Message

func (*TaskInfo) Reset 

func (x *TaskInfo) Reset()

func (*TaskInfo) String 

func (x *TaskInfo) String() string

type TaskInfoIndexReq 

type TaskInfoIndexReq struct {
	Page      *PageInfo `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"`           //分页信息 只获取一个则不填
	GroupCode string    `protobuf:"bytes,2,opt,name=groupCode,proto3" json:"groupCode,omitempty"` //组编码
	// contains filtered or unexported fields
}

func (*TaskInfoIndexReq) Descriptor deprecated 

func (*TaskInfoIndexReq) Descriptor() ([]byte, []int)

Deprecated: Use TaskInfoIndexReq.ProtoReflect.Descriptor instead.

func (*TaskInfoIndexReq) GetGroupCode 

func (x *TaskInfoIndexReq) GetGroupCode() string

func (*TaskInfoIndexReq) GetPage 

func (x *TaskInfoIndexReq) GetPage() *PageInfo

func (*TaskInfoIndexReq) ProtoMessage 

func (*TaskInfoIndexReq) ProtoMessage()

func (*TaskInfoIndexReq) ProtoReflect 

func (x *TaskInfoIndexReq) ProtoReflect() protoreflect.Message

func (*TaskInfoIndexReq) Reset 

func (x *TaskInfoIndexReq) Reset()

func (*TaskInfoIndexReq) String 

func (x *TaskInfoIndexReq) String() string

type TaskInfoIndexResp 

type TaskInfoIndexResp struct {
	List  []*TaskInfo `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	Total int64       `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"` //总数(只有分页的时候会返回)
	// contains filtered or unexported fields
}

func (*TaskInfoIndexResp) Descriptor deprecated 

func (*TaskInfoIndexResp) Descriptor() ([]byte, []int)

Deprecated: Use TaskInfoIndexResp.ProtoReflect.Descriptor instead.

func (*TaskInfoIndexResp) GetList 

func (x *TaskInfoIndexResp) GetList() []*TaskInfo

func (*TaskInfoIndexResp) GetTotal 

func (x *TaskInfoIndexResp) GetTotal() int64

func (*TaskInfoIndexResp) ProtoMessage 

func (*TaskInfoIndexResp) ProtoMessage()

func (*TaskInfoIndexResp) ProtoReflect 

func (x *TaskInfoIndexResp) ProtoReflect() protoreflect.Message

func (*TaskInfoIndexResp) Reset 

func (x *TaskInfoIndexResp) Reset()

func (*TaskInfoIndexResp) String 

func (x *TaskInfoIndexResp) String() string

type TaskLog 

type TaskLog struct {
	Id          int64          `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	GroupCode   string         `protobuf:"bytes,2,opt,name=groupCode,proto3" json:"groupCode,omitempty"`    //组编码
	TaskCode    string         `protobuf:"bytes,3,opt,name=taskCode,proto3" json:"taskCode,omitempty"`      //任务编码
	Params      string         `protobuf:"bytes,4,opt,name=params,proto3" json:"params,omitempty"`          // 任务参数
	ResultCode  int64          `protobuf:"varint,5,opt,name=resultCode,proto3" json:"resultCode,omitempty"` //结果code
	ResultMsg   string         `protobuf:"bytes,6,opt,name=resultMsg,proto3" json:"resultMsg,omitempty"`    //结果消息
	CreatedTime int64          `protobuf:"varint,7,opt,name=createdTime,proto3" json:"createdTime,omitempty"`
	Sql         *TaskLogSql    `protobuf:"bytes,8,opt,name=sql,proto3" json:"sql,omitempty"`
	Script      *TaskLogScript `protobuf:"bytes,9,opt,name=script,proto3" json:"script,omitempty"` //脚本日志
	// contains filtered or unexported fields
}

func (*TaskLog) Descriptor deprecated 

func (*TaskLog) Descriptor() ([]byte, []int)

Deprecated: Use TaskLog.ProtoReflect.Descriptor instead.

func (*TaskLog) GetCreatedTime 

func (x *TaskLog) GetCreatedTime() int64

func (*TaskLog) GetGroupCode 

func (x *TaskLog) GetGroupCode() string

func (*TaskLog) GetId 

func (x *TaskLog) GetId() int64

func (*TaskLog) GetParams 

func (x *TaskLog) GetParams() string

func (*TaskLog) GetResultCode 

func (x *TaskLog) GetResultCode() int64

func (*TaskLog) GetResultMsg 

func (x *TaskLog) GetResultMsg() string

func (*TaskLog) GetScript 

func (x *TaskLog) GetScript() *TaskLogScript

func (*TaskLog) GetSql 

func (x *TaskLog) GetSql() *TaskLogSql

func (*TaskLog) GetTaskCode 

func (x *TaskLog) GetTaskCode() string

func (*TaskLog) ProtoMessage 

func (*TaskLog) ProtoMessage()

func (*TaskLog) ProtoReflect 

func (x *TaskLog) ProtoReflect() protoreflect.Message

func (*TaskLog) Reset 

func (x *TaskLog) Reset()

func (*TaskLog) String 

func (x *TaskLog) String() string

type TaskLogIndexReq 

type TaskLogIndexReq struct {
	Page      *PageInfo `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"`           //分页信息 只获取一个则不填
	GroupCode string    `protobuf:"bytes,2,opt,name=groupCode,proto3" json:"groupCode,omitempty"` //组编码
	TaskCode  string    `protobuf:"bytes,5,opt,name=taskCode,proto3" json:"taskCode,omitempty"`   //任务编码
	// contains filtered or unexported fields
}

func (*TaskLogIndexReq) Descriptor deprecated 

func (*TaskLogIndexReq) Descriptor() ([]byte, []int)

Deprecated: Use TaskLogIndexReq.ProtoReflect.Descriptor instead.

func (*TaskLogIndexReq) GetGroupCode 

func (x *TaskLogIndexReq) GetGroupCode() string

func (*TaskLogIndexReq) GetPage 

func (x *TaskLogIndexReq) GetPage() *PageInfo

func (*TaskLogIndexReq) GetTaskCode 

func (x *TaskLogIndexReq) GetTaskCode() string

func (*TaskLogIndexReq) ProtoMessage 

func (*TaskLogIndexReq) ProtoMessage()

func (*TaskLogIndexReq) ProtoReflect 

func (x *TaskLogIndexReq) ProtoReflect() protoreflect.Message

func (*TaskLogIndexReq) Reset 

func (x *TaskLogIndexReq) Reset()

func (*TaskLogIndexReq) String 

func (x *TaskLogIndexReq) String() string

type TaskLogIndexResp 

type TaskLogIndexResp struct {
	List  []*TaskLog `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	Total int64      `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"` //总数(只有分页的时候会返回)
	// contains filtered or unexported fields
}

func (*TaskLogIndexResp) Descriptor deprecated 

func (*TaskLogIndexResp) Descriptor() ([]byte, []int)

Deprecated: Use TaskLogIndexResp.ProtoReflect.Descriptor instead.

func (*TaskLogIndexResp) GetList 

func (x *TaskLogIndexResp) GetList() []*TaskLog

func (*TaskLogIndexResp) GetTotal 

func (x *TaskLogIndexResp) GetTotal() int64

func (*TaskLogIndexResp) ProtoMessage 

func (*TaskLogIndexResp) ProtoMessage()

func (*TaskLogIndexResp) ProtoReflect 

func (x *TaskLogIndexResp) ProtoReflect() protoreflect.Message

func (*TaskLogIndexResp) Reset 

func (x *TaskLogIndexResp) Reset()

func (*TaskLogIndexResp) String 

func (x *TaskLogIndexResp) String() string

type TaskLogScript 

type TaskLogScript struct {
	ExecLog []*TaskExecLog `protobuf:"bytes,9,rep,name=execLog,proto3" json:"execLog,omitempty"` //执行日志
	// contains filtered or unexported fields
}

func (*TaskLogScript) Descriptor deprecated 

func (*TaskLogScript) Descriptor() ([]byte, []int)

Deprecated: Use TaskLogScript.ProtoReflect.Descriptor instead.

func (*TaskLogScript) GetExecLog 

func (x *TaskLogScript) GetExecLog() []*TaskExecLog

func (*TaskLogScript) ProtoMessage 

func (*TaskLogScript) ProtoMessage()

func (*TaskLogScript) ProtoReflect 

func (x *TaskLogScript) ProtoReflect() protoreflect.Message

func (*TaskLogScript) Reset 

func (x *TaskLogScript) Reset()

func (*TaskLogScript) String 

func (x *TaskLogScript) String() string

type TaskLogSql 

type TaskLogSql struct {
	SelectNum int64 `protobuf:"varint,2,opt,name=selectNum,proto3" json:"selectNum,omitempty"` //查询的数量
	ExecNum   int64 `protobuf:"varint,3,opt,name=execNum,proto3" json:"execNum,omitempty"`     //执行的数量
	// contains filtered or unexported fields
}

func (*TaskLogSql) Descriptor deprecated 

func (*TaskLogSql) Descriptor() ([]byte, []int)

Deprecated: Use TaskLogSql.ProtoReflect.Descriptor instead.

func (*TaskLogSql) GetExecNum 

func (x *TaskLogSql) GetExecNum() int64

func (*TaskLogSql) GetSelectNum 

func (x *TaskLogSql) GetSelectNum() int64

func (*TaskLogSql) ProtoMessage 

func (*TaskLogSql) ProtoMessage()

func (*TaskLogSql) ProtoReflect 

func (x *TaskLogSql) ProtoReflect() protoreflect.Message

func (*TaskLogSql) Reset 

func (x *TaskLogSql) Reset()

func (*TaskLogSql) String 

func (x *TaskLogSql) String() string

type TaskParamQueue 

type TaskParamQueue struct {
	Topic   string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Payload string `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskParamQueue) Descriptor deprecated 

func (*TaskParamQueue) Descriptor() ([]byte, []int)

Deprecated: Use TaskParamQueue.ProtoReflect.Descriptor instead.

func (*TaskParamQueue) GetPayload 

func (x *TaskParamQueue) GetPayload() string

func (*TaskParamQueue) GetTopic 

func (x *TaskParamQueue) GetTopic() string

func (*TaskParamQueue) ProtoMessage 

func (*TaskParamQueue) ProtoMessage()

func (*TaskParamQueue) ProtoReflect 

func (x *TaskParamQueue) ProtoReflect() protoreflect.Message

func (*TaskParamQueue) Reset 

func (x *TaskParamQueue) Reset()

func (*TaskParamQueue) String 

func (x *TaskParamQueue) String() string

type TaskParamScript 

type TaskParamScript struct {
	ExecContent string            `protobuf:"bytes,1,opt,name=execContent,proto3" json:"execContent,omitempty"` //填写脚本内容,如果不填,则会使用数据库中第一次初始化的参数
	Param       map[string]string ``                                                                            //脚本参数,会通过函数入参传进去
	/* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TaskParamScript) Descriptor deprecated 

func (*TaskParamScript) Descriptor() ([]byte, []int)

Deprecated: Use TaskParamScript.ProtoReflect.Descriptor instead.

func (*TaskParamScript) GetExecContent 

func (x *TaskParamScript) GetExecContent() string

func (*TaskParamScript) GetParam 

func (x *TaskParamScript) GetParam() map[string]string

func (*TaskParamScript) ProtoMessage 

func (*TaskParamScript) ProtoMessage()

func (*TaskParamScript) ProtoReflect 

func (x *TaskParamScript) ProtoReflect() protoreflect.Message

func (*TaskParamScript) Reset 

func (x *TaskParamScript) Reset()

func (*TaskParamScript) String 

func (x *TaskParamScript) String() string

type TaskParamSql 

type TaskParamSql struct {
	Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"` //填写脚本内容,如果不填,则会使用数据库中第一次初始化的参数
	// contains filtered or unexported fields
}

func (*TaskParamSql) Descriptor deprecated 

func (*TaskParamSql) Descriptor() ([]byte, []int)

Deprecated: Use TaskParamSql.ProtoReflect.Descriptor instead.

func (*TaskParamSql) GetSql 

func (x *TaskParamSql) GetSql() string

func (*TaskParamSql) ProtoMessage 

func (*TaskParamSql) ProtoMessage()

func (*TaskParamSql) ProtoReflect 

func (x *TaskParamSql) ProtoReflect() protoreflect.Message

func (*TaskParamSql) Reset 

func (x *TaskParamSql) Reset()

func (*TaskParamSql) String 

func (x *TaskParamSql) String() string

type TaskSendOption 

type TaskSendOption struct {
	Priority int64 `protobuf:"varint,1,opt,name=priority,proto3" json:"priority,omitempty"` //优先级: 6:critical 最高优先级  3: default 普通优先级 1:low 低优先级
	// 以下两个参数优先使用ProcessIn
	ProcessIn int64  `protobuf:"varint,2,opt,name=processIn,proto3" json:"processIn,omitempty"` //多久之后发 秒数
	ProcessAt int64  `protobuf:"varint,3,opt,name=processAt,proto3" json:"processAt,omitempty"` // 固定时间发 秒时间戳
	Timeout   int64  `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`     //超时时间 优先使用 秒数
	Deadline  int64  `protobuf:"varint,5,opt,name=deadline,proto3" json:"deadline,omitempty"`   //截止时间  秒时间戳
	TaskID    string `protobuf:"bytes,6,opt,name=taskID,proto3" json:"taskID,omitempty"`        //指定taskID
	// contains filtered or unexported fields
}

func (*TaskSendOption) Descriptor deprecated 

func (*TaskSendOption) Descriptor() ([]byte, []int)

Deprecated: Use TaskSendOption.ProtoReflect.Descriptor instead.

func (*TaskSendOption) GetDeadline 

func (x *TaskSendOption) GetDeadline() int64

func (*TaskSendOption) GetPriority 

func (x *TaskSendOption) GetPriority() int64

func (*TaskSendOption) GetProcessAt 

func (x *TaskSendOption) GetProcessAt() int64

func (*TaskSendOption) GetProcessIn 

func (x *TaskSendOption) GetProcessIn() int64

func (*TaskSendOption) GetTaskID 

func (x *TaskSendOption) GetTaskID() string

func (*TaskSendOption) GetTimeout 

func (x *TaskSendOption) GetTimeout() int64

func (*TaskSendOption) ProtoMessage 

func (*TaskSendOption) ProtoMessage()

func (*TaskSendOption) ProtoReflect 

func (x *TaskSendOption) ProtoReflect() protoreflect.Message

func (*TaskSendOption) Reset 

func (x *TaskSendOption) Reset()

func (*TaskSendOption) String 

func (x *TaskSendOption) String() string

type TaskSendReq 

type TaskSendReq struct {
	GroupCode   string           `protobuf:"bytes,1,opt,name=groupCode,proto3" json:"groupCode,omitempty"`     //组需要提前创建好
	Code        string           `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`               //任务code
	Option      *TaskSendOption  `protobuf:"bytes,3,opt,name=option,proto3" json:"option,omitempty"`           //选项
	ParamQueue  *TaskParamQueue  `protobuf:"bytes,4,opt,name=paramQueue,proto3" json:"paramQueue,omitempty"`   //消息队列发送类型配置,如果不传则使用数据库定义的
	ParamSql    *TaskParamSql    `protobuf:"bytes,5,opt,name=paramSql,proto3" json:"paramSql,omitempty"`       //数据库执行类型配置,如果不传则使用数据库定义的
	ParamScript *TaskParamScript `protobuf:"bytes,7,opt,name=paramScript,proto3" json:"paramScript,omitempty"` //数据库执行类型配置,如果不传则使用数据库定义的
	// contains filtered or unexported fields
}

func (*TaskSendReq) Descriptor deprecated 

func (*TaskSendReq) Descriptor() ([]byte, []int)

Deprecated: Use TaskSendReq.ProtoReflect.Descriptor instead.

func (*TaskSendReq) GetCode 

func (x *TaskSendReq) GetCode() string

func (*TaskSendReq) GetGroupCode 

func (x *TaskSendReq) GetGroupCode() string

func (*TaskSendReq) GetOption 

func (x *TaskSendReq) GetOption() *TaskSendOption

func (*TaskSendReq) GetParamQueue 

func (x *TaskSendReq) GetParamQueue() *TaskParamQueue

func (*TaskSendReq) GetParamScript 

func (x *TaskSendReq) GetParamScript() *TaskParamScript

func (*TaskSendReq) GetParamSql 

func (x *TaskSendReq) GetParamSql() *TaskParamSql

func (*TaskSendReq) ProtoMessage 

func (*TaskSendReq) ProtoMessage()

func (*TaskSendReq) ProtoReflect 

func (x *TaskSendReq) ProtoReflect() protoreflect.Message

func (*TaskSendReq) Reset 

func (x *TaskSendReq) Reset()

func (*TaskSendReq) String 

func (x *TaskSendReq) String() string

type TaskWithTaskID 

type TaskWithTaskID struct {
	TaskID string `protobuf:"bytes,1,opt,name=taskID,proto3" json:"taskID,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskWithTaskID) Descriptor deprecated 

func (*TaskWithTaskID) Descriptor() ([]byte, []int)

Deprecated: Use TaskWithTaskID.ProtoReflect.Descriptor instead.

func (*TaskWithTaskID) GetTaskID 

func (x *TaskWithTaskID) GetTaskID() string

func (*TaskWithTaskID) ProtoMessage 

func (*TaskWithTaskID) ProtoMessage()

func (*TaskWithTaskID) ProtoReflect 

func (x *TaskWithTaskID) ProtoReflect() protoreflect.Message

func (*TaskWithTaskID) Reset 

func (x *TaskWithTaskID) Reset()

func (*TaskWithTaskID) String 

func (x *TaskWithTaskID) String() string

type TimedManageClient 

type TimedManageClient 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)
}

TimedManageClient is the client API for TimedManage service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTimedManageClient 

func NewTimedManageClient(cc grpc.ClientConnInterface) TimedManageClient

type TimedManageServer 

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

TimedManageServer is the server API for TimedManage service. All implementations must embed UnimplementedTimedManageServer for forward compatibility

type UnimplementedTimedManageServer 

type UnimplementedTimedManageServer struct {
}

UnimplementedTimedManageServer must be embedded to have forward compatible implementations.

func (UnimplementedTimedManageServer) TaskCancel 

func (UnimplementedTimedManageServer) TaskCancel(context.Context, *TaskWithTaskID) (*Response, error)

func (UnimplementedTimedManageServer) TaskGroupCreate 

func (UnimplementedTimedManageServer) TaskGroupCreate(context.Context, *TaskGroup) (*Response, error)

func (UnimplementedTimedManageServer) TaskGroupDelete 

func (UnimplementedTimedManageServer) TaskGroupDelete(context.Context, *WithCode) (*Response, error)

func (UnimplementedTimedManageServer) TaskGroupIndex 

func (UnimplementedTimedManageServer) TaskGroupIndex(context.Context, *TaskGroupIndexReq) (*TaskGroupIndexResp, error)

func (UnimplementedTimedManageServer) TaskGroupRead 

func (UnimplementedTimedManageServer) TaskGroupRead(context.Context, *WithCode) (*TaskGroup, error)

func (UnimplementedTimedManageServer) TaskGroupUpdate 

func (UnimplementedTimedManageServer) TaskGroupUpdate(context.Context, *TaskGroup) (*Response, error)

func (UnimplementedTimedManageServer) TaskInfoCreate 

func (UnimplementedTimedManageServer) TaskInfoCreate(context.Context, *TaskInfo) (*Response, error)

func (UnimplementedTimedManageServer) TaskInfoDelete 

func (UnimplementedTimedManageServer) TaskInfoDelete(context.Context, *WithGroupCode) (*Response, error)

func (UnimplementedTimedManageServer) TaskInfoIndex 

func (UnimplementedTimedManageServer) TaskInfoIndex(context.Context, *TaskInfoIndexReq) (*TaskInfoIndexResp, error)

func (UnimplementedTimedManageServer) TaskInfoRead 

func (UnimplementedTimedManageServer) TaskInfoRead(context.Context, *WithGroupCode) (*TaskInfo, error)

func (UnimplementedTimedManageServer) TaskInfoUpdate 

func (UnimplementedTimedManageServer) TaskInfoUpdate(context.Context, *TaskInfo) (*Response, error)

func (UnimplementedTimedManageServer) TaskLogIndex 

func (UnimplementedTimedManageServer) TaskLogIndex(context.Context, *TaskLogIndexReq) (*TaskLogIndexResp, error)

func (UnimplementedTimedManageServer) TaskSend 

func (UnimplementedTimedManageServer) TaskSend(context.Context, *TaskSendReq) (*TaskWithTaskID, error)

type UnsafeTimedManageServer 

type UnsafeTimedManageServer interface {
	// contains filtered or unexported methods
}

UnsafeTimedManageServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TimedManageServer will result in compilation errors.

type WithCode 

type WithCode struct {
	Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*WithCode) Descriptor deprecated 

func (*WithCode) Descriptor() ([]byte, []int)

Deprecated: Use WithCode.ProtoReflect.Descriptor instead.

func (*WithCode) GetCode 

func (x *WithCode) GetCode() string

func (*WithCode) ProtoMessage 

func (*WithCode) ProtoMessage()

func (*WithCode) ProtoReflect 

func (x *WithCode) ProtoReflect() protoreflect.Message

func (*WithCode) Reset 

func (x *WithCode) Reset()

func (*WithCode) String 

func (x *WithCode) String() string

type WithGroupCode 

type WithGroupCode struct {
	Code      string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	GroupCode string `protobuf:"bytes,2,opt,name=groupCode,proto3" json:"groupCode,omitempty"`
	// contains filtered or unexported fields
}

func (*WithGroupCode) Descriptor deprecated 

func (*WithGroupCode) Descriptor() ([]byte, []int)

Deprecated: Use WithGroupCode.ProtoReflect.Descriptor instead.

func (*WithGroupCode) GetCode 

func (x *WithGroupCode) GetCode() string

func (*WithGroupCode) GetGroupCode 

func (x *WithGroupCode) GetGroupCode() string

func (*WithGroupCode) ProtoMessage 

func (*WithGroupCode) ProtoMessage()

func (*WithGroupCode) ProtoReflect 

func (x *WithGroupCode) ProtoReflect() protoreflect.Message

func (*WithGroupCode) Reset 

func (x *WithGroupCode) Reset()

func (*WithGroupCode) String 

func (x *WithGroupCode) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.