jobs

package
v0.0.0-...-6ba990e Latest Latest
Warning

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

 Go to latest Published: Nov 17, 2025 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Overview

Package jobs is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	InstanceState_name = map[int32]string{
		0: "start",
		1: "run",
		2: "stop",
	}
	InstanceState_value = map[string]int32{
		"start": 0,
		"run":   1,
		"stop":  2,
	}
)

Enum value maps for InstanceState.

View Source 
var File_jmash_jobs_jobs_rpc_proto protoreflect.FileDescriptor
View Source 
var File_jmash_jobs_protobuf_job_define_message_proto protoreflect.FileDescriptor
View Source 
var File_jmash_jobs_protobuf_job_instance_message_proto protoreflect.FileDescriptor
View Source 
var File_jmash_jobs_protobuf_job_record_message_proto protoreflect.FileDescriptor
View Source 
var File_jmash_jobs_protobuf_job_trigger_message_proto protoreflect.FileDescriptor
View Source 
var Jobs_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jmash.jobs.Jobs",
	HandlerType: (*JobsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "version",
			Handler:    _Jobs_Version_Handler,
		},
		{
			MethodName: "findEnumList",
			Handler:    _Jobs_FindEnumList_Handler,
		},
		{
			MethodName: "findEnumMap",
			Handler:    _Jobs_FindEnumMap_Handler,
		},
		{
			MethodName: "findEnumEntry",
			Handler:    _Jobs_FindEnumEntry_Handler,
		},
		{
			MethodName: "findJobInstancePage",
			Handler:    _Jobs_FindJobInstancePage_Handler,
		},
		{
			MethodName: "findJobInstanceList",
			Handler:    _Jobs_FindJobInstanceList_Handler,
		},
		{
			MethodName: "findJobInstanceById",
			Handler:    _Jobs_FindJobInstanceById_Handler,
		},
		{
			MethodName: "initJobInstance",
			Handler:    _Jobs_InitJobInstance_Handler,
		},
		{
			MethodName: "heartbeatJobInstance",
			Handler:    _Jobs_HeartbeatJobInstance_Handler,
		},
		{
			MethodName: "assignJobs",
			Handler:    _Jobs_AssignJobs_Handler,
		},
		{
			MethodName: "deleteJobInstance",
			Handler:    _Jobs_DeleteJobInstance_Handler,
		},
		{
			MethodName: "findClassify",
			Handler:    _Jobs_FindClassify_Handler,
		},
		{
			MethodName: "findJobDefinePage",
			Handler:    _Jobs_FindJobDefinePage_Handler,
		},
		{
			MethodName: "findJobDefineList",
			Handler:    _Jobs_FindJobDefineList_Handler,
		},
		{
			MethodName: "findJobDefineById",
			Handler:    _Jobs_FindJobDefineById_Handler,
		},
		{
			MethodName: "createJobDefine",
			Handler:    _Jobs_CreateJobDefine_Handler,
		},
		{
			MethodName: "updateJobDefine",
			Handler:    _Jobs_UpdateJobDefine_Handler,
		},
		{
			MethodName: "enableJobDefine",
			Handler:    _Jobs_EnableJobDefine_Handler,
		},
		{
			MethodName: "deleteJobDefine",
			Handler:    _Jobs_DeleteJobDefine_Handler,
		},
		{
			MethodName: "batchDeleteJobDefine",
			Handler:    _Jobs_BatchDeleteJobDefine_Handler,
		},
		{
			MethodName: "findJobRecordPage",
			Handler:    _Jobs_FindJobRecordPage_Handler,
		},
		{
			MethodName: "findJobRecordList",
			Handler:    _Jobs_FindJobRecordList_Handler,
		},
		{
			MethodName: "findJobRecordById",
			Handler:    _Jobs_FindJobRecordById_Handler,
		},
		{
			MethodName: "createJobRecord",
			Handler:    _Jobs_CreateJobRecord_Handler,
		},
		{
			MethodName: "deleteJobRecord",
			Handler:    _Jobs_DeleteJobRecord_Handler,
		},
		{
			MethodName: "batchDeleteJobRecord",
			Handler:    _Jobs_BatchDeleteJobRecord_Handler,
		},
		{
			MethodName: "findJobTriggerList",
			Handler:    _Jobs_FindJobTriggerList_Handler,
		},
		{
			MethodName: "findJobTriggerById",
			Handler:    _Jobs_FindJobTriggerById_Handler,
		},
		{
			MethodName: "createJobTrigger",
			Handler:    _Jobs_CreateJobTrigger_Handler,
		},
		{
			MethodName: "updateJobTrigger",
			Handler:    _Jobs_UpdateJobTrigger_Handler,
		},
		{
			MethodName: "deleteJobTrigger",
			Handler:    _Jobs_DeleteJobTrigger_Handler,
		},
		{
			MethodName: "batchDeleteJobTrigger",
			Handler:    _Jobs_BatchDeleteJobTrigger_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "jmash/jobs/jobs_rpc.proto",
}

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

Functions

func RegisterJobsHandler 

func RegisterJobsHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterJobsHandler registers the http handlers for service Jobs to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterJobsHandlerClient 

func RegisterJobsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobsClient) error

RegisterJobsHandlerClient registers the http handlers for service Jobs to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "JobsClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "JobsClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "JobsClient" to call the correct interceptors.

func RegisterJobsHandlerFromEndpoint 

func RegisterJobsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterJobsHandlerFromEndpoint is same as RegisterJobsHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterJobsHandlerServer 

func RegisterJobsHandlerServer(ctx context.Context, mux *runtime.ServeMux, server JobsServer) error

RegisterJobsHandlerServer registers the http handlers for service Jobs to "mux". UnaryRPC :call JobsServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterJobsHandlerFromEndpoint instead.

func RegisterJobsServer 

func RegisterJobsServer(s grpc.ServiceRegistrar, srv JobsServer)

Types

type InstanceState 

type InstanceState int32

实例状态. 

const (
	// 已开始
	InstanceState_start InstanceState = 0
	// 运行中
	InstanceState_run InstanceState = 1
	// 已停止
	InstanceState_stop InstanceState = 2
)

func (InstanceState) Descriptor 

func (InstanceState) Descriptor() protoreflect.EnumDescriptor

func (InstanceState) Enum 

func (x InstanceState) Enum() *InstanceState

func (InstanceState) EnumDescriptor deprecated 

func (InstanceState) EnumDescriptor() ([]byte, []int)

Deprecated: Use InstanceState.Descriptor instead.

func (InstanceState) Number 

func (x InstanceState) Number() protoreflect.EnumNumber

func (InstanceState) String 

func (x InstanceState) String() string

func (InstanceState) Type 

func (InstanceState) Type() protoreflect.EnumType

type JobDefineCreateReq 

type JobDefineCreateReq struct {
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// 用于检测重复请求的唯一字符串ID
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// 如果为true，则表示给定的请求仅需要被检验，而不是被执行
	ValidateOnly bool `protobuf:"varint,3,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// 分类
	Classify_ string `protobuf:"bytes,4,opt,name=classify_,json=classify,proto3" json:"classify_,omitempty"`
	// 计划任务中文名称
	JobCnName string `protobuf:"bytes,5,opt,name=job_cn_name,json=jobCnName,proto3" json:"job_cn_name,omitempty"`
	// 计划任务描述
	JobDescribe string `protobuf:"bytes,6,opt,name=job_describe,json=jobDescribe,proto3" json:"job_describe,omitempty"`
	// 任务运行权重
	Weight_ int32 `protobuf:"varint,7,opt,name=weight_,json=weight,proto3" json:"weight_,omitempty"`
	// 任务触发事件名称
	EventName string `protobuf:"bytes,8,opt,name=event_name,json=eventName,proto3" json:"event_name,omitempty"`
	// 任务触发事件JOSN
	EventBody string `protobuf:"bytes,9,opt,name=event_body,json=eventBody,proto3" json:"event_body,omitempty"`
	// 是否启用
	Enable_ bool `protobuf:"varint,10,opt,name=enable_,json=enable,proto3" json:"enable_,omitempty"`
	// contains filtered or unexported fields
}

计划任务定义新增实体

func (*JobDefineCreateReq) Descriptor deprecated 

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

Deprecated: Use JobDefineCreateReq.ProtoReflect.Descriptor instead.

func (*JobDefineCreateReq) GetClassify_ 

func (x *JobDefineCreateReq) GetClassify_() string

func (*JobDefineCreateReq) GetEnable_ 

func (x *JobDefineCreateReq) GetEnable_() bool

func (*JobDefineCreateReq) GetEventBody 

func (x *JobDefineCreateReq) GetEventBody() string

func (*JobDefineCreateReq) GetEventName 

func (x *JobDefineCreateReq) GetEventName() string

func (*JobDefineCreateReq) GetJobCnName 

func (x *JobDefineCreateReq) GetJobCnName() string

func (*JobDefineCreateReq) GetJobDescribe 

func (x *JobDefineCreateReq) GetJobDescribe() string

func (*JobDefineCreateReq) GetRequestId 

func (x *JobDefineCreateReq) GetRequestId() string

func (*JobDefineCreateReq) GetTenant 

func (x *JobDefineCreateReq) GetTenant() string

func (*JobDefineCreateReq) GetValidateOnly 

func (x *JobDefineCreateReq) GetValidateOnly() bool

func (*JobDefineCreateReq) GetWeight_ 

func (x *JobDefineCreateReq) GetWeight_() int32

func (*JobDefineCreateReq) ProtoMessage 

func (*JobDefineCreateReq) ProtoMessage()

func (*JobDefineCreateReq) ProtoReflect 

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

func (*JobDefineCreateReq) Reset 

func (x *JobDefineCreateReq) Reset()

func (*JobDefineCreateReq) String 

func (x *JobDefineCreateReq) String() string

type JobDefineEnableKey 

type JobDefineEnableKey struct {
	Tenant  string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	JobName string `protobuf:"bytes,2,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	Enable  bool   `protobuf:"varint,3,opt,name=enable,proto3" json:"enable,omitempty"`
	// contains filtered or unexported fields
}

启用/禁用

func (*JobDefineEnableKey) Descriptor deprecated 

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

Deprecated: Use JobDefineEnableKey.ProtoReflect.Descriptor instead.

func (*JobDefineEnableKey) GetEnable 

func (x *JobDefineEnableKey) GetEnable() bool

func (*JobDefineEnableKey) GetJobName 

func (x *JobDefineEnableKey) GetJobName() string

func (*JobDefineEnableKey) GetTenant 

func (x *JobDefineEnableKey) GetTenant() string

func (*JobDefineEnableKey) ProtoMessage 

func (*JobDefineEnableKey) ProtoMessage()

func (*JobDefineEnableKey) ProtoReflect 

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

func (*JobDefineEnableKey) Reset 

func (x *JobDefineEnableKey) Reset()

func (*JobDefineEnableKey) String 

func (x *JobDefineEnableKey) String() string

type JobDefineKey 

type JobDefineKey struct {
	Tenant  string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	JobName string `protobuf:"bytes,2,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// contains filtered or unexported fields
}

计划任务定义主键

func (*JobDefineKey) Descriptor deprecated 

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

Deprecated: Use JobDefineKey.ProtoReflect.Descriptor instead.

func (*JobDefineKey) GetJobName 

func (x *JobDefineKey) GetJobName() string

func (*JobDefineKey) GetTenant 

func (x *JobDefineKey) GetTenant() string

func (*JobDefineKey) ProtoMessage 

func (*JobDefineKey) ProtoMessage()

func (*JobDefineKey) ProtoReflect 

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

func (*JobDefineKey) Reset 

func (x *JobDefineKey) Reset()

func (*JobDefineKey) String 

func (x *JobDefineKey) String() string

type JobDefineKeyList 

type JobDefineKeyList struct {
	Tenant  string   `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	JobName []string `protobuf:"bytes,2,rep,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// contains filtered or unexported fields
}

计划任务定义List

func (*JobDefineKeyList) Descriptor deprecated 

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

Deprecated: Use JobDefineKeyList.ProtoReflect.Descriptor instead.

func (*JobDefineKeyList) GetJobName 

func (x *JobDefineKeyList) GetJobName() []string

func (*JobDefineKeyList) GetTenant 

func (x *JobDefineKeyList) GetTenant() string

func (*JobDefineKeyList) ProtoMessage 

func (*JobDefineKeyList) ProtoMessage()

func (*JobDefineKeyList) ProtoReflect 

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

func (*JobDefineKeyList) Reset 

func (x *JobDefineKeyList) Reset()

func (*JobDefineKeyList) String 

func (x *JobDefineKeyList) String() string

type JobDefineList 

type JobDefineList struct {

	// 当前页内容
	Results []*JobDefineModel `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

计划任务定义列表

func (*JobDefineList) Descriptor deprecated 

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

Deprecated: Use JobDefineList.ProtoReflect.Descriptor instead.

func (*JobDefineList) GetResults 

func (x *JobDefineList) GetResults() []*JobDefineModel

func (*JobDefineList) ProtoMessage 

func (*JobDefineList) ProtoMessage()

func (*JobDefineList) ProtoReflect 

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

func (*JobDefineList) Reset 

func (x *JobDefineList) Reset()

func (*JobDefineList) String 

func (x *JobDefineList) String() string

type JobDefineModel 

type JobDefineModel struct {

	// 计划名称
	JobName string `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// 分类
	Classify_ string `protobuf:"bytes,2,opt,name=classify_,json=classify,proto3" json:"classify_,omitempty"`
	// 计划任务中文名称
	JobCnName string `protobuf:"bytes,3,opt,name=job_cn_name,json=jobCnName,proto3" json:"job_cn_name,omitempty"`
	// 计划任务描述
	JobDescribe string `protobuf:"bytes,4,opt,name=job_describe,json=jobDescribe,proto3" json:"job_describe,omitempty"`
	// 任务运行权重
	Weight_ int32 `protobuf:"varint,5,opt,name=weight_,json=weight,proto3" json:"weight_,omitempty"`
	// 任务触发事件名称
	EventName string `protobuf:"bytes,6,opt,name=event_name,json=eventName,proto3" json:"event_name,omitempty"`
	// 任务触发事件JOSN
	EventBody string `protobuf:"bytes,7,opt,name=event_body,json=eventBody,proto3" json:"event_body,omitempty"`
	// 运行实例
	InstanceName string `protobuf:"bytes,8,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	// 是否启用
	Enable_ bool `protobuf:"varint,9,opt,name=enable_,json=enable,proto3" json:"enable_,omitempty"`
	// 乐观锁
	Version_ int32 `protobuf:"varint,10,opt,name=version_,json=version,proto3" json:"version_,omitempty"`
	// 创建人
	CreateBy string `protobuf:"bytes,11,opt,name=create_by,json=createBy,proto3" json:"create_by,omitempty"`
	// 创建时间
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// 更新人
	UpdateBy string `protobuf:"bytes,13,opt,name=update_by,json=updateBy,proto3" json:"update_by,omitempty"`
	// 更新时间
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

计划任务定义实体

func (*JobDefineModel) Descriptor deprecated 

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

Deprecated: Use JobDefineModel.ProtoReflect.Descriptor instead.

func (*JobDefineModel) GetClassify_ 

func (x *JobDefineModel) GetClassify_() string

func (*JobDefineModel) GetCreateBy 

func (x *JobDefineModel) GetCreateBy() string

func (*JobDefineModel) GetCreateTime 

func (x *JobDefineModel) GetCreateTime() *timestamppb.Timestamp

func (*JobDefineModel) GetEnable_ 

func (x *JobDefineModel) GetEnable_() bool

func (*JobDefineModel) GetEventBody 

func (x *JobDefineModel) GetEventBody() string

func (*JobDefineModel) GetEventName 

func (x *JobDefineModel) GetEventName() string

func (*JobDefineModel) GetInstanceName 

func (x *JobDefineModel) GetInstanceName() string

func (*JobDefineModel) GetJobCnName 

func (x *JobDefineModel) GetJobCnName() string

func (*JobDefineModel) GetJobDescribe 

func (x *JobDefineModel) GetJobDescribe() string

func (*JobDefineModel) GetJobName 

func (x *JobDefineModel) GetJobName() string

func (*JobDefineModel) GetUpdateBy 

func (x *JobDefineModel) GetUpdateBy() string

func (*JobDefineModel) GetUpdateTime 

func (x *JobDefineModel) GetUpdateTime() *timestamppb.Timestamp

func (*JobDefineModel) GetVersion_ 

func (x *JobDefineModel) GetVersion_() int32

func (*JobDefineModel) GetWeight_ 

func (x *JobDefineModel) GetWeight_() int32

func (*JobDefineModel) ProtoMessage 

func (*JobDefineModel) ProtoMessage()

func (*JobDefineModel) ProtoReflect 

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

func (*JobDefineModel) Reset 

func (x *JobDefineModel) Reset()

func (*JobDefineModel) String 

func (x *JobDefineModel) String() string

type JobDefineModelTotal 

type JobDefineModelTotal struct {

	// 总记录数
	TotalSize int32 `protobuf:"varint,1,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

合计

func (*JobDefineModelTotal) Descriptor deprecated 

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

Deprecated: Use JobDefineModelTotal.ProtoReflect.Descriptor instead.

func (*JobDefineModelTotal) GetTotalSize 

func (x *JobDefineModelTotal) GetTotalSize() int32

func (*JobDefineModelTotal) ProtoMessage 

func (*JobDefineModelTotal) ProtoMessage()

func (*JobDefineModelTotal) ProtoReflect 

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

func (*JobDefineModelTotal) Reset 

func (x *JobDefineModelTotal) Reset()

func (*JobDefineModelTotal) String 

func (x *JobDefineModelTotal) String() string

type JobDefinePage 

type JobDefinePage struct {

	// 当前页内容
	Results []*JobDefineModel `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// 当前页码
	CurPage int32 `protobuf:"varint,2,opt,name=cur_page,json=curPage,proto3" json:"cur_page,omitempty"`
	// 页尺寸
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// 总记录数
	TotalSize int32 `protobuf:"varint,4,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// 本页小计
	SubTotalDto *JobDefineModelTotal `protobuf:"bytes,5,opt,name=sub_total_dto,json=subTotalDto,proto3" json:"sub_total_dto,omitempty"`
	// 合计
	TotalDto *JobDefineModelTotal `protobuf:"bytes,6,opt,name=total_dto,json=totalDto,proto3" json:"total_dto,omitempty"`
	// contains filtered or unexported fields
}

计划任务定义分页

func (*JobDefinePage) Descriptor deprecated 

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

Deprecated: Use JobDefinePage.ProtoReflect.Descriptor instead.

func (*JobDefinePage) GetCurPage 

func (x *JobDefinePage) GetCurPage() int32

func (*JobDefinePage) GetPageSize 

func (x *JobDefinePage) GetPageSize() int32

func (*JobDefinePage) GetResults 

func (x *JobDefinePage) GetResults() []*JobDefineModel

func (*JobDefinePage) GetSubTotalDto 

func (x *JobDefinePage) GetSubTotalDto() *JobDefineModelTotal

func (*JobDefinePage) GetTotalDto 

func (x *JobDefinePage) GetTotalDto() *JobDefineModelTotal

func (*JobDefinePage) GetTotalSize 

func (x *JobDefinePage) GetTotalSize() int32

func (*JobDefinePage) ProtoMessage 

func (*JobDefinePage) ProtoMessage()

func (*JobDefinePage) ProtoReflect 

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

func (*JobDefinePage) Reset 

func (x *JobDefinePage) Reset()

func (*JobDefinePage) String 

func (x *JobDefinePage) String() string

type JobDefineReq 

type JobDefineReq struct {

	// 租户
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// 当前页码
	CurPage int32 `protobuf:"varint,2,opt,name=cur_page,json=curPage,proto3" json:"cur_page,omitempty"`
	// 页尺寸
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// 排序名称
	OrderName string `protobuf:"bytes,4,opt,name=order_name,json=orderName,proto3" json:"order_name,omitempty"`
	// 是否升序排序
	OrderAsc bool `protobuf:"varint,5,opt,name=order_asc,json=orderAsc,proto3" json:"order_asc,omitempty"`
	// 分类
	Classify string `protobuf:"bytes,6,opt,name=classify,proto3" json:"classify,omitempty"`
	// 是否启用
	HasEnable bool `protobuf:"varint,7,opt,name=has_enable,json=hasEnable,proto3" json:"has_enable,omitempty"`
	// 状态
	Enable bool `protobuf:"varint,8,opt,name=enable,proto3" json:"enable,omitempty"`
	// 是否包含分配参数
	HasAssign bool `protobuf:"varint,9,opt,name=has_assign,json=hasAssign,proto3" json:"has_assign,omitempty"`
	// 是否分配
	Assign bool `protobuf:"varint,10,opt,name=assign,proto3" json:"assign,omitempty"`
	// 运行实例
	InstanceName string `protobuf:"bytes,11,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	// contains filtered or unexported fields
}

计划任务定义查询

func (*JobDefineReq) Descriptor deprecated 

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

Deprecated: Use JobDefineReq.ProtoReflect.Descriptor instead.

func (*JobDefineReq) GetAssign 

func (x *JobDefineReq) GetAssign() bool

func (*JobDefineReq) GetClassify 

func (x *JobDefineReq) GetClassify() string

func (*JobDefineReq) GetCurPage 

func (x *JobDefineReq) GetCurPage() int32

func (*JobDefineReq) GetEnable 

func (x *JobDefineReq) GetEnable() bool

func (*JobDefineReq) GetHasAssign 

func (x *JobDefineReq) GetHasAssign() bool

func (*JobDefineReq) GetHasEnable 

func (x *JobDefineReq) GetHasEnable() bool

func (*JobDefineReq) GetInstanceName 

func (x *JobDefineReq) GetInstanceName() string

func (*JobDefineReq) GetOrderAsc 

func (x *JobDefineReq) GetOrderAsc() bool

func (*JobDefineReq) GetOrderName 

func (x *JobDefineReq) GetOrderName() string

func (*JobDefineReq) GetPageSize 

func (x *JobDefineReq) GetPageSize() int32

func (*JobDefineReq) GetTenant 

func (x *JobDefineReq) GetTenant() string

func (*JobDefineReq) ProtoMessage 

func (*JobDefineReq) ProtoMessage()

func (*JobDefineReq) ProtoReflect 

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

func (*JobDefineReq) Reset 

func (x *JobDefineReq) Reset()

func (*JobDefineReq) String 

func (x *JobDefineReq) String() string

type JobDefineUpdateReq 

type JobDefineUpdateReq struct {
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// 用于检测重复请求的唯一字符串ID
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// 如果为true，则表示给定的请求仅需要被检验，而不是被执行
	ValidateOnly bool `protobuf:"varint,3,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// 更新字段掩码.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,4,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// 计划名称
	JobName string `protobuf:"bytes,5,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// 计划任务中文名称
	JobCnName string `protobuf:"bytes,7,opt,name=job_cn_name,json=jobCnName,proto3" json:"job_cn_name,omitempty"`
	// 计划任务描述
	JobDescribe string `protobuf:"bytes,8,opt,name=job_describe,json=jobDescribe,proto3" json:"job_describe,omitempty"`
	// 任务运行权重
	Weight_ int32 `protobuf:"varint,9,opt,name=weight_,json=weight,proto3" json:"weight_,omitempty"`
	// 任务触发事件名称
	EventName string `protobuf:"bytes,10,opt,name=event_name,json=eventName,proto3" json:"event_name,omitempty"`
	// 任务触发事件JOSN
	EventBody string `protobuf:"bytes,11,opt,name=event_body,json=eventBody,proto3" json:"event_body,omitempty"`
	// 是否启用
	Enable_ bool `protobuf:"varint,12,opt,name=enable_,json=enable,proto3" json:"enable_,omitempty"`
	// contains filtered or unexported fields
}

计划任务定义修改实体

func (*JobDefineUpdateReq) Descriptor deprecated 

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

Deprecated: Use JobDefineUpdateReq.ProtoReflect.Descriptor instead.

func (*JobDefineUpdateReq) GetEnable_ 

func (x *JobDefineUpdateReq) GetEnable_() bool

func (*JobDefineUpdateReq) GetEventBody 

func (x *JobDefineUpdateReq) GetEventBody() string

func (*JobDefineUpdateReq) GetEventName 

func (x *JobDefineUpdateReq) GetEventName() string

func (*JobDefineUpdateReq) GetJobCnName 

func (x *JobDefineUpdateReq) GetJobCnName() string

func (*JobDefineUpdateReq) GetJobDescribe 

func (x *JobDefineUpdateReq) GetJobDescribe() string

func (*JobDefineUpdateReq) GetJobName 

func (x *JobDefineUpdateReq) GetJobName() string

func (*JobDefineUpdateReq) GetRequestId 

func (x *JobDefineUpdateReq) GetRequestId() string

func (*JobDefineUpdateReq) GetTenant 

func (x *JobDefineUpdateReq) GetTenant() string

func (*JobDefineUpdateReq) GetUpdateMask 

func (x *JobDefineUpdateReq) GetUpdateMask() *fieldmaskpb.FieldMask

func (*JobDefineUpdateReq) GetValidateOnly 

func (x *JobDefineUpdateReq) GetValidateOnly() bool

func (*JobDefineUpdateReq) GetWeight_ 

func (x *JobDefineUpdateReq) GetWeight_() int32

func (*JobDefineUpdateReq) ProtoMessage 

func (*JobDefineUpdateReq) ProtoMessage()

func (*JobDefineUpdateReq) ProtoReflect 

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

func (*JobDefineUpdateReq) Reset 

func (x *JobDefineUpdateReq) Reset()

func (*JobDefineUpdateReq) String 

func (x *JobDefineUpdateReq) String() string

type JobInstanceAssignJob 

type JobInstanceAssignJob struct {

	// 租户
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// 用于检测重复请求的唯一字符串ID
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// 分类
	Classify_ string `protobuf:"bytes,3,opt,name=classify_,json=classify,proto3" json:"classify_,omitempty"`
	// 实例
	InstanceName string `protobuf:"bytes,4,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	// contains filtered or unexported fields
}

任务分配

func (*JobInstanceAssignJob) Descriptor deprecated 

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

Deprecated: Use JobInstanceAssignJob.ProtoReflect.Descriptor instead.

func (*JobInstanceAssignJob) GetClassify_ 

func (x *JobInstanceAssignJob) GetClassify_() string

func (*JobInstanceAssignJob) GetInstanceName 

func (x *JobInstanceAssignJob) GetInstanceName() string

func (*JobInstanceAssignJob) GetRequestId 

func (x *JobInstanceAssignJob) GetRequestId() string

func (*JobInstanceAssignJob) GetTenant 

func (x *JobInstanceAssignJob) GetTenant() string

func (*JobInstanceAssignJob) ProtoMessage 

func (*JobInstanceAssignJob) ProtoMessage()

func (*JobInstanceAssignJob) ProtoReflect 

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

func (*JobInstanceAssignJob) Reset 

func (x *JobInstanceAssignJob) Reset()

func (*JobInstanceAssignJob) String 

func (x *JobInstanceAssignJob) String() string

type JobInstanceHeartbeat 

type JobInstanceHeartbeat struct {

	// 租户
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// 分类
	Classify_ string `protobuf:"bytes,2,opt,name=classify_,json=classify,proto3" json:"classify_,omitempty"`
	// 实例
	InstanceName string `protobuf:"bytes,3,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	// 心跳间隔（秒）
	Interval int32 `protobuf:"varint,4,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

心跳

func (*JobInstanceHeartbeat) Descriptor deprecated 

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

Deprecated: Use JobInstanceHeartbeat.ProtoReflect.Descriptor instead.

func (*JobInstanceHeartbeat) GetClassify_ 

func (x *JobInstanceHeartbeat) GetClassify_() string

func (*JobInstanceHeartbeat) GetInstanceName 

func (x *JobInstanceHeartbeat) GetInstanceName() string

func (*JobInstanceHeartbeat) GetInterval 

func (x *JobInstanceHeartbeat) GetInterval() int32

func (*JobInstanceHeartbeat) GetTenant 

func (x *JobInstanceHeartbeat) GetTenant() string

func (*JobInstanceHeartbeat) ProtoMessage 

func (*JobInstanceHeartbeat) ProtoMessage()

func (*JobInstanceHeartbeat) ProtoReflect 

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

func (*JobInstanceHeartbeat) Reset 

func (x *JobInstanceHeartbeat) Reset()

func (*JobInstanceHeartbeat) String 

func (x *JobInstanceHeartbeat) String() string

type JobInstanceInitReq 

type JobInstanceInitReq struct {

	// 租户
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// 用于检测重复请求的唯一字符串ID
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// 如果为true，则表示给定的请求仅需要被检验，而不是被执行
	ValidateOnly bool `protobuf:"varint,3,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// 运行实例
	InstanceName string `protobuf:"bytes,4,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	// 分类
	Classify_ string `protobuf:"bytes,5,opt,name=classify_,json=classify,proto3" json:"classify_,omitempty"`
	// contains filtered or unexported fields
}

运行实例新增实体

func (*JobInstanceInitReq) Descriptor deprecated 

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

Deprecated: Use JobInstanceInitReq.ProtoReflect.Descriptor instead.

func (*JobInstanceInitReq) GetClassify_ 

func (x *JobInstanceInitReq) GetClassify_() string

func (*JobInstanceInitReq) GetInstanceName 

func (x *JobInstanceInitReq) GetInstanceName() string

func (*JobInstanceInitReq) GetRequestId 

func (x *JobInstanceInitReq) GetRequestId() string

func (*JobInstanceInitReq) GetTenant 

func (x *JobInstanceInitReq) GetTenant() string

func (*JobInstanceInitReq) GetValidateOnly 

func (x *JobInstanceInitReq) GetValidateOnly() bool

func (*JobInstanceInitReq) ProtoMessage 

func (*JobInstanceInitReq) ProtoMessage()

func (*JobInstanceInitReq) ProtoReflect 

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

func (*JobInstanceInitReq) Reset 

func (x *JobInstanceInitReq) Reset()

func (*JobInstanceInitReq) String 

func (x *JobInstanceInitReq) String() string

type JobInstanceKey 

type JobInstanceKey struct {
	Tenant       string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Classify_    string `protobuf:"bytes,2,opt,name=classify_,json=classify,proto3" json:"classify_,omitempty"`
	InstanceName string `protobuf:"bytes,3,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	// contains filtered or unexported fields
}

运行实例主键

func (*JobInstanceKey) Descriptor deprecated 

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

Deprecated: Use JobInstanceKey.ProtoReflect.Descriptor instead.

func (*JobInstanceKey) GetClassify_ 

func (x *JobInstanceKey) GetClassify_() string

func (*JobInstanceKey) GetInstanceName 

func (x *JobInstanceKey) GetInstanceName() string

func (*JobInstanceKey) GetTenant 

func (x *JobInstanceKey) GetTenant() string

func (*JobInstanceKey) ProtoMessage 

func (*JobInstanceKey) ProtoMessage()

func (*JobInstanceKey) ProtoReflect 

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

func (*JobInstanceKey) Reset 

func (x *JobInstanceKey) Reset()

func (*JobInstanceKey) String 

func (x *JobInstanceKey) String() string

type JobInstanceKeyList 

type JobInstanceKeyList struct {
	Tenant         string            `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	JobInstanceKey []*JobInstanceKey `protobuf:"bytes,2,rep,name=job_instance_key,json=jobInstanceKey,proto3" json:"job_instance_key,omitempty"`
	// contains filtered or unexported fields
}

运行实例List

func (*JobInstanceKeyList) Descriptor deprecated 

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

Deprecated: Use JobInstanceKeyList.ProtoReflect.Descriptor instead.

func (*JobInstanceKeyList) GetJobInstanceKey 

func (x *JobInstanceKeyList) GetJobInstanceKey() []*JobInstanceKey

func (*JobInstanceKeyList) GetTenant 

func (x *JobInstanceKeyList) GetTenant() string

func (*JobInstanceKeyList) ProtoMessage 

func (*JobInstanceKeyList) ProtoMessage()

func (*JobInstanceKeyList) ProtoReflect 

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

func (*JobInstanceKeyList) Reset 

func (x *JobInstanceKeyList) Reset()

func (*JobInstanceKeyList) String 

func (x *JobInstanceKeyList) String() string

type JobInstanceList 

type JobInstanceList struct {

	// 当前页内容
	Results []*JobInstanceModel `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

运行实例列表

func (*JobInstanceList) Descriptor deprecated 

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

Deprecated: Use JobInstanceList.ProtoReflect.Descriptor instead.

func (*JobInstanceList) GetResults 

func (x *JobInstanceList) GetResults() []*JobInstanceModel

func (*JobInstanceList) ProtoMessage 

func (*JobInstanceList) ProtoMessage()

func (*JobInstanceList) ProtoReflect 

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

func (*JobInstanceList) Reset 

func (x *JobInstanceList) Reset()

func (*JobInstanceList) String 

func (x *JobInstanceList) String() string

type JobInstanceModel 

type JobInstanceModel struct {

	// 运行实例
	InstanceName string `protobuf:"bytes,1,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	// 分类
	Classify_ string `protobuf:"bytes,2,opt,name=classify_,json=classify,proto3" json:"classify_,omitempty"`
	// 心跳时间
	Heartbeat_ *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=heartbeat_,json=heartbeat,proto3" json:"heartbeat_,omitempty"`
	// 过期时间
	DueDate *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=due_date,json=dueDate,proto3" json:"due_date,omitempty"`
	// 状态
	State_ InstanceState `protobuf:"varint,5,opt,name=state_,json=state,proto3,enum=jmash.jobs.InstanceState" json:"state_,omitempty"`
	// contains filtered or unexported fields
}

运行实例实体

func (*JobInstanceModel) Descriptor deprecated 

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

Deprecated: Use JobInstanceModel.ProtoReflect.Descriptor instead.

func (*JobInstanceModel) GetClassify_ 

func (x *JobInstanceModel) GetClassify_() string

func (*JobInstanceModel) GetDueDate 

func (x *JobInstanceModel) GetDueDate() *timestamppb.Timestamp

func (*JobInstanceModel) GetHeartbeat_ 

func (x *JobInstanceModel) GetHeartbeat_() *timestamppb.Timestamp

func (*JobInstanceModel) GetInstanceName 

func (x *JobInstanceModel) GetInstanceName() string

func (*JobInstanceModel) GetState_ 

func (x *JobInstanceModel) GetState_() InstanceState

func (*JobInstanceModel) ProtoMessage 

func (*JobInstanceModel) ProtoMessage()

func (*JobInstanceModel) ProtoReflect 

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

func (*JobInstanceModel) Reset 

func (x *JobInstanceModel) Reset()

func (*JobInstanceModel) String 

func (x *JobInstanceModel) String() string

type JobInstanceModelTotal 

type JobInstanceModelTotal struct {

	// 总记录数
	TotalSize int32 `protobuf:"varint,1,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

合计

func (*JobInstanceModelTotal) Descriptor deprecated 

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

Deprecated: Use JobInstanceModelTotal.ProtoReflect.Descriptor instead.

func (*JobInstanceModelTotal) GetTotalSize 

func (x *JobInstanceModelTotal) GetTotalSize() int32

func (*JobInstanceModelTotal) ProtoMessage 

func (*JobInstanceModelTotal) ProtoMessage()

func (*JobInstanceModelTotal) ProtoReflect 

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

func (*JobInstanceModelTotal) Reset 

func (x *JobInstanceModelTotal) Reset()

func (*JobInstanceModelTotal) String 

func (x *JobInstanceModelTotal) String() string

type JobInstancePage 

type JobInstancePage struct {

	// 当前页内容
	Results []*JobInstanceModel `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// 当前页码
	CurPage int32 `protobuf:"varint,2,opt,name=cur_page,json=curPage,proto3" json:"cur_page,omitempty"`
	// 页尺寸
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// 总记录数
	TotalSize int32 `protobuf:"varint,4,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// 本页小计
	SubTotalDto *JobInstanceModelTotal `protobuf:"bytes,5,opt,name=sub_total_dto,json=subTotalDto,proto3" json:"sub_total_dto,omitempty"`
	// 合计
	TotalDto *JobInstanceModelTotal `protobuf:"bytes,6,opt,name=total_dto,json=totalDto,proto3" json:"total_dto,omitempty"`
	// contains filtered or unexported fields
}

运行实例分页

func (*JobInstancePage) Descriptor deprecated 

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

Deprecated: Use JobInstancePage.ProtoReflect.Descriptor instead.

func (*JobInstancePage) GetCurPage 

func (x *JobInstancePage) GetCurPage() int32

func (*JobInstancePage) GetPageSize 

func (x *JobInstancePage) GetPageSize() int32

func (*JobInstancePage) GetResults 

func (x *JobInstancePage) GetResults() []*JobInstanceModel

func (*JobInstancePage) GetSubTotalDto 

func (x *JobInstancePage) GetSubTotalDto() *JobInstanceModelTotal

func (*JobInstancePage) GetTotalDto 

func (x *JobInstancePage) GetTotalDto() *JobInstanceModelTotal

func (*JobInstancePage) GetTotalSize 

func (x *JobInstancePage) GetTotalSize() int32

func (*JobInstancePage) ProtoMessage 

func (*JobInstancePage) ProtoMessage()

func (*JobInstancePage) ProtoReflect 

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

func (*JobInstancePage) Reset 

func (x *JobInstancePage) Reset()

func (*JobInstancePage) String 

func (x *JobInstancePage) String() string

type JobInstanceReq 

type JobInstanceReq struct {

	// 租户
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// 当前页码
	CurPage int32 `protobuf:"varint,2,opt,name=cur_page,json=curPage,proto3" json:"cur_page,omitempty"`
	// 页尺寸
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// 排序名称
	OrderName string `protobuf:"bytes,4,opt,name=order_name,json=orderName,proto3" json:"order_name,omitempty"`
	// 是否升序排序
	OrderAsc bool `protobuf:"varint,5,opt,name=order_asc,json=orderAsc,proto3" json:"order_asc,omitempty"`
	// 分类
	Classify_ string `protobuf:"bytes,6,opt,name=classify_,json=classify,proto3" json:"classify_,omitempty"`
	// 是否包含状态
	HasState bool `protobuf:"varint,7,opt,name=has_state,json=hasState,proto3" json:"has_state,omitempty"`
	// 状态
	State_ InstanceState `protobuf:"varint,8,opt,name=state_,json=state,proto3,enum=jmash.jobs.InstanceState" json:"state_,omitempty"`
	// contains filtered or unexported fields
}

运行实例查询

func (*JobInstanceReq) Descriptor deprecated 

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

Deprecated: Use JobInstanceReq.ProtoReflect.Descriptor instead.

func (*JobInstanceReq) GetClassify_ 

func (x *JobInstanceReq) GetClassify_() string

func (*JobInstanceReq) GetCurPage 

func (x *JobInstanceReq) GetCurPage() int32

func (*JobInstanceReq) GetHasState 

func (x *JobInstanceReq) GetHasState() bool

func (*JobInstanceReq) GetOrderAsc 

func (x *JobInstanceReq) GetOrderAsc() bool

func (*JobInstanceReq) GetOrderName 

func (x *JobInstanceReq) GetOrderName() string

func (*JobInstanceReq) GetPageSize 

func (x *JobInstanceReq) GetPageSize() int32

func (*JobInstanceReq) GetState_ 

func (x *JobInstanceReq) GetState_() InstanceState

func (*JobInstanceReq) GetTenant 

func (x *JobInstanceReq) GetTenant() string

func (*JobInstanceReq) ProtoMessage 

func (*JobInstanceReq) ProtoMessage()

func (*JobInstanceReq) ProtoReflect 

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

func (*JobInstanceReq) Reset 

func (x *JobInstanceReq) Reset()

func (*JobInstanceReq) String 

func (x *JobInstanceReq) String() string

type JobRecordCreateReq 

type JobRecordCreateReq struct {
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// 用于检测重复请求的唯一字符串ID
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// 如果为true，则表示给定的请求仅需要被检验，而不是被执行
	ValidateOnly bool `protobuf:"varint,3,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// 计划名称
	JobName string `protobuf:"bytes,4,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// 开始时间
	StartDate *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=start_date,json=startDate,proto3" json:"start_date,omitempty"`
	// 结束时间
	EndDate *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=end_date,json=endDate,proto3" json:"end_date,omitempty"`
	// 错误信息
	ErrorMsg string `protobuf:"bytes,7,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// 状态
	State_ bool `protobuf:"varint,8,opt,name=state_,json=state,proto3" json:"state_,omitempty"`
	// contains filtered or unexported fields
}

计划任务记录新增实体

func (*JobRecordCreateReq) Descriptor deprecated 

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

Deprecated: Use JobRecordCreateReq.ProtoReflect.Descriptor instead.

func (*JobRecordCreateReq) GetEndDate 

func (x *JobRecordCreateReq) GetEndDate() *timestamppb.Timestamp

func (*JobRecordCreateReq) GetErrorMsg 

func (x *JobRecordCreateReq) GetErrorMsg() string

func (*JobRecordCreateReq) GetJobName 

func (x *JobRecordCreateReq) GetJobName() string

func (*JobRecordCreateReq) GetRequestId 

func (x *JobRecordCreateReq) GetRequestId() string

func (*JobRecordCreateReq) GetStartDate 

func (x *JobRecordCreateReq) GetStartDate() *timestamppb.Timestamp

func (*JobRecordCreateReq) GetState_ 

func (x *JobRecordCreateReq) GetState_() bool

func (*JobRecordCreateReq) GetTenant 

func (x *JobRecordCreateReq) GetTenant() string

func (*JobRecordCreateReq) GetValidateOnly 

func (x *JobRecordCreateReq) GetValidateOnly() bool

func (*JobRecordCreateReq) ProtoMessage 

func (*JobRecordCreateReq) ProtoMessage()

func (*JobRecordCreateReq) ProtoReflect 

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

func (*JobRecordCreateReq) Reset 

func (x *JobRecordCreateReq) Reset()

func (*JobRecordCreateReq) String 

func (x *JobRecordCreateReq) String() string

type JobRecordDelReq 

type JobRecordDelReq struct {

	// 租户
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// 仅能删除至少1年以前执行任务记录
	Year int32 `protobuf:"varint,2,opt,name=year,proto3" json:"year,omitempty"`
	// contains filtered or unexported fields
}

批量删除请求

func (*JobRecordDelReq) Descriptor deprecated 

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

Deprecated: Use JobRecordDelReq.ProtoReflect.Descriptor instead.

func (*JobRecordDelReq) GetTenant 

func (x *JobRecordDelReq) GetTenant() string

func (*JobRecordDelReq) GetYear 

func (x *JobRecordDelReq) GetYear() int32

func (*JobRecordDelReq) ProtoMessage 

func (*JobRecordDelReq) ProtoMessage()

func (*JobRecordDelReq) ProtoReflect 

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

func (*JobRecordDelReq) Reset 

func (x *JobRecordDelReq) Reset()

func (*JobRecordDelReq) String 

func (x *JobRecordDelReq) String() string

type JobRecordKey 

type JobRecordKey struct {
	Tenant   string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	RecordId string `protobuf:"bytes,2,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"`
	// contains filtered or unexported fields
}

计划任务记录主键

func (*JobRecordKey) Descriptor deprecated 

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

Deprecated: Use JobRecordKey.ProtoReflect.Descriptor instead.

func (*JobRecordKey) GetRecordId 

func (x *JobRecordKey) GetRecordId() string

func (*JobRecordKey) GetTenant 

func (x *JobRecordKey) GetTenant() string

func (*JobRecordKey) ProtoMessage 

func (*JobRecordKey) ProtoMessage()

func (*JobRecordKey) ProtoReflect 

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

func (*JobRecordKey) Reset 

func (x *JobRecordKey) Reset()

func (*JobRecordKey) String 

func (x *JobRecordKey) String() string

type JobRecordKeyList 

type JobRecordKeyList struct {
	Tenant   string   `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	RecordId []string `protobuf:"bytes,2,rep,name=record_id,json=recordId,proto3" json:"record_id,omitempty"`
	// contains filtered or unexported fields
}

计划任务记录List

func (*JobRecordKeyList) Descriptor deprecated 

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

Deprecated: Use JobRecordKeyList.ProtoReflect.Descriptor instead.

func (*JobRecordKeyList) GetRecordId 

func (x *JobRecordKeyList) GetRecordId() []string

func (*JobRecordKeyList) GetTenant 

func (x *JobRecordKeyList) GetTenant() string

func (*JobRecordKeyList) ProtoMessage 

func (*JobRecordKeyList) ProtoMessage()

func (*JobRecordKeyList) ProtoReflect 

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

func (*JobRecordKeyList) Reset 

func (x *JobRecordKeyList) Reset()

func (*JobRecordKeyList) String 

func (x *JobRecordKeyList) String() string

type JobRecordList 

type JobRecordList struct {

	// 当前页内容
	Results []*JobRecordModel `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

计划任务记录列表

func (*JobRecordList) Descriptor deprecated 

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

Deprecated: Use JobRecordList.ProtoReflect.Descriptor instead.

func (*JobRecordList) GetResults 

func (x *JobRecordList) GetResults() []*JobRecordModel

func (*JobRecordList) ProtoMessage 

func (*JobRecordList) ProtoMessage()

func (*JobRecordList) ProtoReflect 

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

func (*JobRecordList) Reset 

func (x *JobRecordList) Reset()

func (*JobRecordList) String 

func (x *JobRecordList) String() string

type JobRecordModel 

type JobRecordModel struct {

	// 计划执行ID
	RecordId string `protobuf:"bytes,1,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"`
	// 计划名称
	JobName string `protobuf:"bytes,2,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// 开始时间
	StartDate *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_date,json=startDate,proto3" json:"start_date,omitempty"`
	// 结束时间
	EndDate *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end_date,json=endDate,proto3" json:"end_date,omitempty"`
	// 错误信息
	ErrorMsg string `protobuf:"bytes,5,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// 状态
	State_ bool `protobuf:"varint,6,opt,name=state_,json=state,proto3" json:"state_,omitempty"`
	// contains filtered or unexported fields
}

计划任务记录实体

func (*JobRecordModel) Descriptor deprecated 

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

Deprecated: Use JobRecordModel.ProtoReflect.Descriptor instead.

func (*JobRecordModel) GetEndDate 

func (x *JobRecordModel) GetEndDate() *timestamppb.Timestamp

func (*JobRecordModel) GetErrorMsg 

func (x *JobRecordModel) GetErrorMsg() string

func (*JobRecordModel) GetJobName 

func (x *JobRecordModel) GetJobName() string

func (*JobRecordModel) GetRecordId 

func (x *JobRecordModel) GetRecordId() string

func (*JobRecordModel) GetStartDate 

func (x *JobRecordModel) GetStartDate() *timestamppb.Timestamp

func (*JobRecordModel) GetState_ 

func (x *JobRecordModel) GetState_() bool

func (*JobRecordModel) ProtoMessage 

func (*JobRecordModel) ProtoMessage()

func (*JobRecordModel) ProtoReflect 

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

func (*JobRecordModel) Reset 

func (x *JobRecordModel) Reset()

func (*JobRecordModel) String 

func (x *JobRecordModel) String() string

type JobRecordModelTotal 

type JobRecordModelTotal struct {

	// 总记录数
	TotalSize int32 `protobuf:"varint,1,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

合计

func (*JobRecordModelTotal) Descriptor deprecated 

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

Deprecated: Use JobRecordModelTotal.ProtoReflect.Descriptor instead.

func (*JobRecordModelTotal) GetTotalSize 

func (x *JobRecordModelTotal) GetTotalSize() int32

func (*JobRecordModelTotal) ProtoMessage 

func (*JobRecordModelTotal) ProtoMessage()

func (*JobRecordModelTotal) ProtoReflect 

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

func (*JobRecordModelTotal) Reset 

func (x *JobRecordModelTotal) Reset()

func (*JobRecordModelTotal) String 

func (x *JobRecordModelTotal) String() string

type JobRecordPage 

type JobRecordPage struct {

	// 当前页内容
	Results []*JobRecordModel `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// 当前页码
	CurPage int32 `protobuf:"varint,2,opt,name=cur_page,json=curPage,proto3" json:"cur_page,omitempty"`
	// 页尺寸
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// 总记录数
	TotalSize int32 `protobuf:"varint,4,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// 本页小计
	SubTotalDto *JobRecordModelTotal `protobuf:"bytes,5,opt,name=sub_total_dto,json=subTotalDto,proto3" json:"sub_total_dto,omitempty"`
	// 合计
	TotalDto *JobRecordModelTotal `protobuf:"bytes,6,opt,name=total_dto,json=totalDto,proto3" json:"total_dto,omitempty"`
	// contains filtered or unexported fields
}

计划任务记录分页

func (*JobRecordPage) Descriptor deprecated 

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

Deprecated: Use JobRecordPage.ProtoReflect.Descriptor instead.

func (*JobRecordPage) GetCurPage 

func (x *JobRecordPage) GetCurPage() int32

func (*JobRecordPage) GetPageSize 

func (x *JobRecordPage) GetPageSize() int32

func (*JobRecordPage) GetResults 

func (x *JobRecordPage) GetResults() []*JobRecordModel

func (*JobRecordPage) GetSubTotalDto 

func (x *JobRecordPage) GetSubTotalDto() *JobRecordModelTotal

func (*JobRecordPage) GetTotalDto 

func (x *JobRecordPage) GetTotalDto() *JobRecordModelTotal

func (*JobRecordPage) GetTotalSize 

func (x *JobRecordPage) GetTotalSize() int32

func (*JobRecordPage) ProtoMessage 

func (*JobRecordPage) ProtoMessage()

func (*JobRecordPage) ProtoReflect 

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

func (*JobRecordPage) Reset 

func (x *JobRecordPage) Reset()

func (*JobRecordPage) String 

func (x *JobRecordPage) String() string

type JobRecordReq 

type JobRecordReq struct {

	// 租户
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// 当前页码
	CurPage int32 `protobuf:"varint,2,opt,name=cur_page,json=curPage,proto3" json:"cur_page,omitempty"`
	// 页尺寸
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// 排序名称
	OrderName string `protobuf:"bytes,4,opt,name=order_name,json=orderName,proto3" json:"order_name,omitempty"`
	// 是否升序排序
	OrderAsc bool `protobuf:"varint,5,opt,name=order_asc,json=orderAsc,proto3" json:"order_asc,omitempty"`
	// 计划名称
	JobName string `protobuf:"bytes,6,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// 是否包含状态
	HasState bool `protobuf:"varint,7,opt,name=has_state,json=hasState,proto3" json:"has_state,omitempty"`
	// 状态
	State_ bool `protobuf:"varint,8,opt,name=state_,json=state,proto3" json:"state_,omitempty"`
	// 开始时间
	StartDate *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=start_date,json=startDate,proto3" json:"start_date,omitempty"`
	// 结束时间
	EndDate *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=end_date,json=endDate,proto3" json:"end_date,omitempty"`
	// contains filtered or unexported fields
}

计划任务记录查询

func (*JobRecordReq) Descriptor deprecated 

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

Deprecated: Use JobRecordReq.ProtoReflect.Descriptor instead.

func (*JobRecordReq) GetCurPage 

func (x *JobRecordReq) GetCurPage() int32

func (*JobRecordReq) GetEndDate 

func (x *JobRecordReq) GetEndDate() *timestamppb.Timestamp

func (*JobRecordReq) GetHasState 

func (x *JobRecordReq) GetHasState() bool

func (*JobRecordReq) GetJobName 

func (x *JobRecordReq) GetJobName() string

func (*JobRecordReq) GetOrderAsc 

func (x *JobRecordReq) GetOrderAsc() bool

func (*JobRecordReq) GetOrderName 

func (x *JobRecordReq) GetOrderName() string

func (*JobRecordReq) GetPageSize 

func (x *JobRecordReq) GetPageSize() int32

func (*JobRecordReq) GetStartDate 

func (x *JobRecordReq) GetStartDate() *timestamppb.Timestamp

func (*JobRecordReq) GetState_ 

func (x *JobRecordReq) GetState_() bool

func (*JobRecordReq) GetTenant 

func (x *JobRecordReq) GetTenant() string

func (*JobRecordReq) ProtoMessage 

func (*JobRecordReq) ProtoMessage()

func (*JobRecordReq) ProtoReflect 

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

func (*JobRecordReq) Reset 

func (x *JobRecordReq) Reset()

func (*JobRecordReq) String 

func (x *JobRecordReq) String() string

type JobTriggerCreateReq 

type JobTriggerCreateReq struct {
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// 用于检测重复请求的唯一字符串ID
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// 如果为true，则表示给定的请求仅需要被检验，而不是被执行
	ValidateOnly bool `protobuf:"varint,3,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// 计划名称
	JobName string `protobuf:"bytes,4,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// 是否当前日期开始
	StartNow bool `protobuf:"varint,5,opt,name=start_now,json=startNow,proto3" json:"start_now,omitempty"`
	// 启动时间
	StartDate *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=start_date,json=startDate,proto3" json:"start_date,omitempty"`
	// cron表达式
	Cron_ string `protobuf:"bytes,7,opt,name=cron_,json=cron,proto3" json:"cron_,omitempty"`
	// cron描述
	CronName string `protobuf:"bytes,8,opt,name=cron_name,json=cronName,proto3" json:"cron_name,omitempty"`
	// 是否自定义
	IsCustom bool `protobuf:"varint,9,opt,name=is_custom,json=isCustom,proto3" json:"is_custom,omitempty"`
	// contains filtered or unexported fields
}

任务触发器新增实体

func (*JobTriggerCreateReq) Descriptor deprecated 

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

Deprecated: Use JobTriggerCreateReq.ProtoReflect.Descriptor instead.

func (*JobTriggerCreateReq) GetCronName 

func (x *JobTriggerCreateReq) GetCronName() string

func (*JobTriggerCreateReq) GetCron_ 

func (x *JobTriggerCreateReq) GetCron_() string

func (*JobTriggerCreateReq) GetIsCustom 

func (x *JobTriggerCreateReq) GetIsCustom() bool

func (*JobTriggerCreateReq) GetJobName 

func (x *JobTriggerCreateReq) GetJobName() string

func (*JobTriggerCreateReq) GetRequestId 

func (x *JobTriggerCreateReq) GetRequestId() string

func (*JobTriggerCreateReq) GetStartDate 

func (x *JobTriggerCreateReq) GetStartDate() *timestamppb.Timestamp

func (*JobTriggerCreateReq) GetStartNow 

func (x *JobTriggerCreateReq) GetStartNow() bool

func (*JobTriggerCreateReq) GetTenant 

func (x *JobTriggerCreateReq) GetTenant() string

func (*JobTriggerCreateReq) GetValidateOnly 

func (x *JobTriggerCreateReq) GetValidateOnly() bool

func (*JobTriggerCreateReq) ProtoMessage 

func (*JobTriggerCreateReq) ProtoMessage()

func (*JobTriggerCreateReq) ProtoReflect 

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

func (*JobTriggerCreateReq) Reset 

func (x *JobTriggerCreateReq) Reset()

func (*JobTriggerCreateReq) String 

func (x *JobTriggerCreateReq) String() string

type JobTriggerKey 

type JobTriggerKey struct {
	Tenant    string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	TriggerId string `protobuf:"bytes,2,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// contains filtered or unexported fields
}

任务触发器主键

func (*JobTriggerKey) Descriptor deprecated 

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

Deprecated: Use JobTriggerKey.ProtoReflect.Descriptor instead.

func (*JobTriggerKey) GetTenant 

func (x *JobTriggerKey) GetTenant() string

func (*JobTriggerKey) GetTriggerId 

func (x *JobTriggerKey) GetTriggerId() string

func (*JobTriggerKey) ProtoMessage 

func (*JobTriggerKey) ProtoMessage()

func (*JobTriggerKey) ProtoReflect 

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

func (*JobTriggerKey) Reset 

func (x *JobTriggerKey) Reset()

func (*JobTriggerKey) String 

func (x *JobTriggerKey) String() string

type JobTriggerKeyList 

type JobTriggerKeyList struct {
	Tenant    string   `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	TriggerId []string `protobuf:"bytes,2,rep,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// contains filtered or unexported fields
}

任务触发器List

func (*JobTriggerKeyList) Descriptor deprecated 

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

Deprecated: Use JobTriggerKeyList.ProtoReflect.Descriptor instead.

func (*JobTriggerKeyList) GetTenant 

func (x *JobTriggerKeyList) GetTenant() string

func (*JobTriggerKeyList) GetTriggerId 

func (x *JobTriggerKeyList) GetTriggerId() []string

func (*JobTriggerKeyList) ProtoMessage 

func (*JobTriggerKeyList) ProtoMessage()

func (*JobTriggerKeyList) ProtoReflect 

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

func (*JobTriggerKeyList) Reset 

func (x *JobTriggerKeyList) Reset()

func (*JobTriggerKeyList) String 

func (x *JobTriggerKeyList) String() string

type JobTriggerList 

type JobTriggerList struct {

	// 当前页内容
	Results []*JobTriggerModel `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

任务触发器列表

func (*JobTriggerList) Descriptor deprecated 

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

Deprecated: Use JobTriggerList.ProtoReflect.Descriptor instead.

func (*JobTriggerList) GetResults 

func (x *JobTriggerList) GetResults() []*JobTriggerModel

func (*JobTriggerList) ProtoMessage 

func (*JobTriggerList) ProtoMessage()

func (*JobTriggerList) ProtoReflect 

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

func (*JobTriggerList) Reset 

func (x *JobTriggerList) Reset()

func (*JobTriggerList) String 

func (x *JobTriggerList) String() string

type JobTriggerModel 

type JobTriggerModel struct {

	// 触发ID
	TriggerId string `protobuf:"bytes,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// 计划名称
	JobName string `protobuf:"bytes,2,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// 是否当前日期开始
	StartNow bool `protobuf:"varint,3,opt,name=start_now,json=startNow,proto3" json:"start_now,omitempty"`
	// 启动时间
	StartDate *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_date,json=startDate,proto3" json:"start_date,omitempty"`
	// cron表达式
	Cron_ string `protobuf:"bytes,5,opt,name=cron_,json=cron,proto3" json:"cron_,omitempty"`
	// cron描述
	CronName string `protobuf:"bytes,6,opt,name=cron_name,json=cronName,proto3" json:"cron_name,omitempty"`
	// 是否自定义
	IsCustom bool `protobuf:"varint,7,opt,name=is_custom,json=isCustom,proto3" json:"is_custom,omitempty"`
	// contains filtered or unexported fields
}

任务触发器实体

func (*JobTriggerModel) Descriptor deprecated 

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

Deprecated: Use JobTriggerModel.ProtoReflect.Descriptor instead.

func (*JobTriggerModel) GetCronName 

func (x *JobTriggerModel) GetCronName() string

func (*JobTriggerModel) GetCron_ 

func (x *JobTriggerModel) GetCron_() string

func (*JobTriggerModel) GetIsCustom 

func (x *JobTriggerModel) GetIsCustom() bool

func (*JobTriggerModel) GetJobName 

func (x *JobTriggerModel) GetJobName() string

func (*JobTriggerModel) GetStartDate 

func (x *JobTriggerModel) GetStartDate() *timestamppb.Timestamp

func (*JobTriggerModel) GetStartNow 

func (x *JobTriggerModel) GetStartNow() bool

func (*JobTriggerModel) GetTriggerId 

func (x *JobTriggerModel) GetTriggerId() string

func (*JobTriggerModel) ProtoMessage 

func (*JobTriggerModel) ProtoMessage()

func (*JobTriggerModel) ProtoReflect 

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

func (*JobTriggerModel) Reset 

func (x *JobTriggerModel) Reset()

func (*JobTriggerModel) String 

func (x *JobTriggerModel) String() string

type JobTriggerReq 

type JobTriggerReq struct {
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// 当前页码
	CurPage int32 `protobuf:"varint,2,opt,name=cur_page,json=curPage,proto3" json:"cur_page,omitempty"`
	// 页尺寸
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// 排序名称
	OrderName string `protobuf:"bytes,4,opt,name=order_name,json=orderName,proto3" json:"order_name,omitempty"`
	// 是否升序排序
	OrderAsc bool `protobuf:"varint,5,opt,name=order_asc,json=orderAsc,proto3" json:"order_asc,omitempty"`
	// 计划名称
	JobName string `protobuf:"bytes,6,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// contains filtered or unexported fields
}

任务触发器查询

func (*JobTriggerReq) Descriptor deprecated 

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

Deprecated: Use JobTriggerReq.ProtoReflect.Descriptor instead.

func (*JobTriggerReq) GetCurPage 

func (x *JobTriggerReq) GetCurPage() int32

func (*JobTriggerReq) GetJobName 

func (x *JobTriggerReq) GetJobName() string

func (*JobTriggerReq) GetOrderAsc 

func (x *JobTriggerReq) GetOrderAsc() bool

func (*JobTriggerReq) GetOrderName 

func (x *JobTriggerReq) GetOrderName() string

func (*JobTriggerReq) GetPageSize 

func (x *JobTriggerReq) GetPageSize() int32

func (*JobTriggerReq) GetTenant 

func (x *JobTriggerReq) GetTenant() string

func (*JobTriggerReq) ProtoMessage 

func (*JobTriggerReq) ProtoMessage()

func (*JobTriggerReq) ProtoReflect 

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

func (*JobTriggerReq) Reset 

func (x *JobTriggerReq) Reset()

func (*JobTriggerReq) String 

func (x *JobTriggerReq) String() string

type JobTriggerUpdateReq 

type JobTriggerUpdateReq struct {
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// 用于检测重复请求的唯一字符串ID
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// 如果为true，则表示给定的请求仅需要被检验，而不是被执行
	ValidateOnly bool `protobuf:"varint,3,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// 更新字段掩码.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,4,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// 触发ID
	TriggerId string `protobuf:"bytes,5,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// 是否当前日期开始
	StartNow bool `protobuf:"varint,6,opt,name=start_now,json=startNow,proto3" json:"start_now,omitempty"`
	// 启动时间
	StartDate *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=start_date,json=startDate,proto3" json:"start_date,omitempty"`
	// cron表达式
	Cron_ string `protobuf:"bytes,8,opt,name=cron_,json=cron,proto3" json:"cron_,omitempty"`
	// cron描述
	CronName string `protobuf:"bytes,9,opt,name=cron_name,json=cronName,proto3" json:"cron_name,omitempty"`
	// 是否自定义
	IsCustom bool `protobuf:"varint,10,opt,name=is_custom,json=isCustom,proto3" json:"is_custom,omitempty"`
	// contains filtered or unexported fields
}

任务触发器修改实体

func (*JobTriggerUpdateReq) Descriptor deprecated 

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

Deprecated: Use JobTriggerUpdateReq.ProtoReflect.Descriptor instead.

func (*JobTriggerUpdateReq) GetCronName 

func (x *JobTriggerUpdateReq) GetCronName() string

func (*JobTriggerUpdateReq) GetCron_ 

func (x *JobTriggerUpdateReq) GetCron_() string

func (*JobTriggerUpdateReq) GetIsCustom 

func (x *JobTriggerUpdateReq) GetIsCustom() bool

func (*JobTriggerUpdateReq) GetRequestId 

func (x *JobTriggerUpdateReq) GetRequestId() string

func (*JobTriggerUpdateReq) GetStartDate 

func (x *JobTriggerUpdateReq) GetStartDate() *timestamppb.Timestamp

func (*JobTriggerUpdateReq) GetStartNow 

func (x *JobTriggerUpdateReq) GetStartNow() bool

func (*JobTriggerUpdateReq) GetTenant 

func (x *JobTriggerUpdateReq) GetTenant() string

func (*JobTriggerUpdateReq) GetTriggerId 

func (x *JobTriggerUpdateReq) GetTriggerId() string

func (*JobTriggerUpdateReq) GetUpdateMask 

func (x *JobTriggerUpdateReq) GetUpdateMask() *fieldmaskpb.FieldMask

func (*JobTriggerUpdateReq) GetValidateOnly 

func (x *JobTriggerUpdateReq) GetValidateOnly() bool

func (*JobTriggerUpdateReq) ProtoMessage 

func (*JobTriggerUpdateReq) ProtoMessage()

func (*JobTriggerUpdateReq) ProtoReflect 

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

func (*JobTriggerUpdateReq) Reset 

func (x *JobTriggerUpdateReq) Reset()

func (*JobTriggerUpdateReq) String 

func (x *JobTriggerUpdateReq) String() string

type JobsClient 

type JobsClient interface {
	// 版本
	Version(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*wrapperspb.StringValue, error)
	// 枚举值列表
	FindEnumList(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*basic.EnumValueList, error)
	// 枚举值Map
	FindEnumMap(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*basic.CustomEnumValueMap, error)
	// 枚举值
	FindEnumEntry(ctx context.Context, in *basic.EnumEntryReq, opts ...grpc.CallOption) (*basic.EntryList, error)
	// 查询翻页信息运行实例;
	FindJobInstancePage(ctx context.Context, in *JobInstanceReq, opts ...grpc.CallOption) (*JobInstancePage, error)
	// 查询列表信息运行实例;
	FindJobInstanceList(ctx context.Context, in *JobInstanceReq, opts ...grpc.CallOption) (*JobInstanceList, error)
	// 查询运行实例;
	FindJobInstanceById(ctx context.Context, in *JobInstanceKey, opts ...grpc.CallOption) (*JobInstanceModel, error)
	// 初始化运行实例.
	InitJobInstance(ctx context.Context, in *JobInstanceInitReq, opts ...grpc.CallOption) (*JobInstanceModel, error)
	// 运行实例心跳.
	HeartbeatJobInstance(ctx context.Context, in *JobInstanceHeartbeat, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)
	// 实例分配任务.
	AssignJobs(ctx context.Context, in *JobInstanceAssignJob, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)
	// 删除运行实例;
	DeleteJobInstance(ctx context.Context, in *JobInstanceKey, opts ...grpc.CallOption) (*JobInstanceModel, error)
	// 查询全部分类
	FindClassify(ctx context.Context, in *basic.TenantReq, opts ...grpc.CallOption) (*basic.EntryList, error)
	// 查询翻页信息计划任务定义;
	FindJobDefinePage(ctx context.Context, in *JobDefineReq, opts ...grpc.CallOption) (*JobDefinePage, error)
	// 查询列表信息计划任务定义;
	FindJobDefineList(ctx context.Context, in *JobDefineReq, opts ...grpc.CallOption) (*JobDefineList, error)
	// 查询计划任务定义;
	FindJobDefineById(ctx context.Context, in *JobDefineKey, opts ...grpc.CallOption) (*JobDefineModel, error)
	// 创建实体计划任务定义;
	CreateJobDefine(ctx context.Context, in *JobDefineCreateReq, opts ...grpc.CallOption) (*JobDefineModel, error)
	// 修改实体计划任务定义;
	UpdateJobDefine(ctx context.Context, in *JobDefineUpdateReq, opts ...grpc.CallOption) (*JobDefineModel, error)
	// 启用/禁用
	EnableJobDefine(ctx context.Context, in *JobDefineEnableKey, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)
	// 删除计划任务定义;
	DeleteJobDefine(ctx context.Context, in *JobDefineKey, opts ...grpc.CallOption) (*JobDefineModel, error)
	// 批量删除计划任务定义;
	BatchDeleteJobDefine(ctx context.Context, in *JobDefineKeyList, opts ...grpc.CallOption) (*wrapperspb.Int32Value, error)
	// 查询翻页信息计划任务记录;
	FindJobRecordPage(ctx context.Context, in *JobRecordReq, opts ...grpc.CallOption) (*JobRecordPage, error)
	// 查询列表信息计划任务记录;
	FindJobRecordList(ctx context.Context, in *JobRecordReq, opts ...grpc.CallOption) (*JobRecordList, error)
	// 查询计划任务记录;
	FindJobRecordById(ctx context.Context, in *JobRecordKey, opts ...grpc.CallOption) (*JobRecordModel, error)
	// 创建实体计划任务记录;
	CreateJobRecord(ctx context.Context, in *JobRecordCreateReq, opts ...grpc.CallOption) (*JobRecordModel, error)
	// 删除计划任务记录;
	DeleteJobRecord(ctx context.Context, in *JobRecordKey, opts ...grpc.CallOption) (*JobRecordModel, error)
	// 批量删除计划任务记录;
	BatchDeleteJobRecord(ctx context.Context, in *JobRecordDelReq, opts ...grpc.CallOption) (*wrapperspb.Int32Value, error)
	// 查询列表信息任务触发器;
	FindJobTriggerList(ctx context.Context, in *JobTriggerReq, opts ...grpc.CallOption) (*JobTriggerList, error)
	// 查询任务触发器;
	FindJobTriggerById(ctx context.Context, in *JobTriggerKey, opts ...grpc.CallOption) (*JobTriggerModel, error)
	// 创建实体任务触发器;
	CreateJobTrigger(ctx context.Context, in *JobTriggerCreateReq, opts ...grpc.CallOption) (*JobTriggerModel, error)
	// 修改实体任务触发器;
	UpdateJobTrigger(ctx context.Context, in *JobTriggerUpdateReq, opts ...grpc.CallOption) (*JobTriggerModel, error)
	// 删除任务触发器;
	DeleteJobTrigger(ctx context.Context, in *JobTriggerKey, opts ...grpc.CallOption) (*JobTriggerModel, error)
	// 批量删除任务触发器;
	BatchDeleteJobTrigger(ctx context.Context, in *JobTriggerKeyList, opts ...grpc.CallOption) (*wrapperspb.Int32Value, error)
}

JobsClient is the client API for Jobs 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 NewJobsClient 

func NewJobsClient(cc grpc.ClientConnInterface) JobsClient

type JobsServer 

type JobsServer interface {
	// 版本
	Version(context.Context, *emptypb.Empty) (*wrapperspb.StringValue, error)
	// 枚举值列表
	FindEnumList(context.Context, *wrapperspb.StringValue) (*basic.EnumValueList, error)
	// 枚举值Map
	FindEnumMap(context.Context, *wrapperspb.StringValue) (*basic.CustomEnumValueMap, error)
	// 枚举值
	FindEnumEntry(context.Context, *basic.EnumEntryReq) (*basic.EntryList, error)
	// 查询翻页信息运行实例;
	FindJobInstancePage(context.Context, *JobInstanceReq) (*JobInstancePage, error)
	// 查询列表信息运行实例;
	FindJobInstanceList(context.Context, *JobInstanceReq) (*JobInstanceList, error)
	// 查询运行实例;
	FindJobInstanceById(context.Context, *JobInstanceKey) (*JobInstanceModel, error)
	// 初始化运行实例.
	InitJobInstance(context.Context, *JobInstanceInitReq) (*JobInstanceModel, error)
	// 运行实例心跳.
	HeartbeatJobInstance(context.Context, *JobInstanceHeartbeat) (*wrapperspb.BoolValue, error)
	// 实例分配任务.
	AssignJobs(context.Context, *JobInstanceAssignJob) (*wrapperspb.BoolValue, error)
	// 删除运行实例;
	DeleteJobInstance(context.Context, *JobInstanceKey) (*JobInstanceModel, error)
	// 查询全部分类
	FindClassify(context.Context, *basic.TenantReq) (*basic.EntryList, error)
	// 查询翻页信息计划任务定义;
	FindJobDefinePage(context.Context, *JobDefineReq) (*JobDefinePage, error)
	// 查询列表信息计划任务定义;
	FindJobDefineList(context.Context, *JobDefineReq) (*JobDefineList, error)
	// 查询计划任务定义;
	FindJobDefineById(context.Context, *JobDefineKey) (*JobDefineModel, error)
	// 创建实体计划任务定义;
	CreateJobDefine(context.Context, *JobDefineCreateReq) (*JobDefineModel, error)
	// 修改实体计划任务定义;
	UpdateJobDefine(context.Context, *JobDefineUpdateReq) (*JobDefineModel, error)
	// 启用/禁用
	EnableJobDefine(context.Context, *JobDefineEnableKey) (*wrapperspb.BoolValue, error)
	// 删除计划任务定义;
	DeleteJobDefine(context.Context, *JobDefineKey) (*JobDefineModel, error)
	// 批量删除计划任务定义;
	BatchDeleteJobDefine(context.Context, *JobDefineKeyList) (*wrapperspb.Int32Value, error)
	// 查询翻页信息计划任务记录;
	FindJobRecordPage(context.Context, *JobRecordReq) (*JobRecordPage, error)
	// 查询列表信息计划任务记录;
	FindJobRecordList(context.Context, *JobRecordReq) (*JobRecordList, error)
	// 查询计划任务记录;
	FindJobRecordById(context.Context, *JobRecordKey) (*JobRecordModel, error)
	// 创建实体计划任务记录;
	CreateJobRecord(context.Context, *JobRecordCreateReq) (*JobRecordModel, error)
	// 删除计划任务记录;
	DeleteJobRecord(context.Context, *JobRecordKey) (*JobRecordModel, error)
	// 批量删除计划任务记录;
	BatchDeleteJobRecord(context.Context, *JobRecordDelReq) (*wrapperspb.Int32Value, error)
	// 查询列表信息任务触发器;
	FindJobTriggerList(context.Context, *JobTriggerReq) (*JobTriggerList, error)
	// 查询任务触发器;
	FindJobTriggerById(context.Context, *JobTriggerKey) (*JobTriggerModel, error)
	// 创建实体任务触发器;
	CreateJobTrigger(context.Context, *JobTriggerCreateReq) (*JobTriggerModel, error)
	// 修改实体任务触发器;
	UpdateJobTrigger(context.Context, *JobTriggerUpdateReq) (*JobTriggerModel, error)
	// 删除任务触发器;
	DeleteJobTrigger(context.Context, *JobTriggerKey) (*JobTriggerModel, error)
	// 批量删除任务触发器;
	BatchDeleteJobTrigger(context.Context, *JobTriggerKeyList) (*wrapperspb.Int32Value, error)
	// contains filtered or unexported methods
}

JobsServer is the server API for Jobs service. All implementations must embed UnimplementedJobsServer for forward compatibility

type UnimplementedJobsServer 

type UnimplementedJobsServer struct {
}

UnimplementedJobsServer must be embedded to have forward compatible implementations.

func (UnimplementedJobsServer) AssignJobs 

func (UnimplementedJobsServer) AssignJobs(context.Context, *JobInstanceAssignJob) (*wrapperspb.BoolValue, error)

func (UnimplementedJobsServer) BatchDeleteJobDefine 

func (UnimplementedJobsServer) BatchDeleteJobDefine(context.Context, *JobDefineKeyList) (*wrapperspb.Int32Value, error)

func (UnimplementedJobsServer) BatchDeleteJobRecord 

func (UnimplementedJobsServer) BatchDeleteJobRecord(context.Context, *JobRecordDelReq) (*wrapperspb.Int32Value, error)

func (UnimplementedJobsServer) BatchDeleteJobTrigger 

func (UnimplementedJobsServer) BatchDeleteJobTrigger(context.Context, *JobTriggerKeyList) (*wrapperspb.Int32Value, error)

func (UnimplementedJobsServer) CreateJobDefine 

func (UnimplementedJobsServer) CreateJobDefine(context.Context, *JobDefineCreateReq) (*JobDefineModel, error)

func (UnimplementedJobsServer) CreateJobRecord 

func (UnimplementedJobsServer) CreateJobRecord(context.Context, *JobRecordCreateReq) (*JobRecordModel, error)

func (UnimplementedJobsServer) CreateJobTrigger 

func (UnimplementedJobsServer) CreateJobTrigger(context.Context, *JobTriggerCreateReq) (*JobTriggerModel, error)

func (UnimplementedJobsServer) DeleteJobDefine 

func (UnimplementedJobsServer) DeleteJobDefine(context.Context, *JobDefineKey) (*JobDefineModel, error)

func (UnimplementedJobsServer) DeleteJobInstance 

func (UnimplementedJobsServer) DeleteJobInstance(context.Context, *JobInstanceKey) (*JobInstanceModel, error)

func (UnimplementedJobsServer) DeleteJobRecord 

func (UnimplementedJobsServer) DeleteJobRecord(context.Context, *JobRecordKey) (*JobRecordModel, error)

func (UnimplementedJobsServer) DeleteJobTrigger 

func (UnimplementedJobsServer) DeleteJobTrigger(context.Context, *JobTriggerKey) (*JobTriggerModel, error)

func (UnimplementedJobsServer) EnableJobDefine 

func (UnimplementedJobsServer) EnableJobDefine(context.Context, *JobDefineEnableKey) (*wrapperspb.BoolValue, error)

func (UnimplementedJobsServer) FindClassify 

func (UnimplementedJobsServer) FindClassify(context.Context, *basic.TenantReq) (*basic.EntryList, error)

func (UnimplementedJobsServer) FindEnumEntry 

func (UnimplementedJobsServer) FindEnumEntry(context.Context, *basic.EnumEntryReq) (*basic.EntryList, error)

func (UnimplementedJobsServer) FindEnumList 

func (UnimplementedJobsServer) FindEnumList(context.Context, *wrapperspb.StringValue) (*basic.EnumValueList, error)

func (UnimplementedJobsServer) FindEnumMap 

func (UnimplementedJobsServer) FindEnumMap(context.Context, *wrapperspb.StringValue) (*basic.CustomEnumValueMap, error)

func (UnimplementedJobsServer) FindJobDefineById 

func (UnimplementedJobsServer) FindJobDefineById(context.Context, *JobDefineKey) (*JobDefineModel, error)

func (UnimplementedJobsServer) FindJobDefineList 

func (UnimplementedJobsServer) FindJobDefineList(context.Context, *JobDefineReq) (*JobDefineList, error)

func (UnimplementedJobsServer) FindJobDefinePage 

func (UnimplementedJobsServer) FindJobDefinePage(context.Context, *JobDefineReq) (*JobDefinePage, error)

func (UnimplementedJobsServer) FindJobInstanceById 

func (UnimplementedJobsServer) FindJobInstanceById(context.Context, *JobInstanceKey) (*JobInstanceModel, error)

func (UnimplementedJobsServer) FindJobInstanceList 

func (UnimplementedJobsServer) FindJobInstanceList(context.Context, *JobInstanceReq) (*JobInstanceList, error)

func (UnimplementedJobsServer) FindJobInstancePage 

func (UnimplementedJobsServer) FindJobInstancePage(context.Context, *JobInstanceReq) (*JobInstancePage, error)

func (UnimplementedJobsServer) FindJobRecordById 

func (UnimplementedJobsServer) FindJobRecordById(context.Context, *JobRecordKey) (*JobRecordModel, error)

func (UnimplementedJobsServer) FindJobRecordList 

func (UnimplementedJobsServer) FindJobRecordList(context.Context, *JobRecordReq) (*JobRecordList, error)

func (UnimplementedJobsServer) FindJobRecordPage 

func (UnimplementedJobsServer) FindJobRecordPage(context.Context, *JobRecordReq) (*JobRecordPage, error)

func (UnimplementedJobsServer) FindJobTriggerById 

func (UnimplementedJobsServer) FindJobTriggerById(context.Context, *JobTriggerKey) (*JobTriggerModel, error)

func (UnimplementedJobsServer) FindJobTriggerList 

func (UnimplementedJobsServer) FindJobTriggerList(context.Context, *JobTriggerReq) (*JobTriggerList, error)

func (UnimplementedJobsServer) HeartbeatJobInstance 

func (UnimplementedJobsServer) HeartbeatJobInstance(context.Context, *JobInstanceHeartbeat) (*wrapperspb.BoolValue, error)

func (UnimplementedJobsServer) InitJobInstance 

func (UnimplementedJobsServer) InitJobInstance(context.Context, *JobInstanceInitReq) (*JobInstanceModel, error)

func (UnimplementedJobsServer) UpdateJobDefine 

func (UnimplementedJobsServer) UpdateJobDefine(context.Context, *JobDefineUpdateReq) (*JobDefineModel, error)

func (UnimplementedJobsServer) UpdateJobTrigger 

func (UnimplementedJobsServer) UpdateJobTrigger(context.Context, *JobTriggerUpdateReq) (*JobTriggerModel, error)

func (UnimplementedJobsServer) Version 

func (UnimplementedJobsServer) Version(context.Context, *emptypb.Empty) (*wrapperspb.StringValue, error)

type UnsafeJobsServer 

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

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

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.