scheduler

package
v0.0.0-...-b63aa1a Latest Latest
Warning

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

Go to latest
Published: Dec 18, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SchedulerHistory

type SchedulerHistory struct {
	//
	//history id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id" form:"id"`
	//
	//任务名称
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name" form:"name"`
	//
	//执行返回码
	Code int32 `protobuf:"varint,3,opt,name=code,proto3" json:"code" form:"code"`
	//
	//调度结果信息
	Msg string `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg" form:"msg"`
	//
	//任务执行总时间, 单位 s
	TotalTime int32 `protobuf:"varint,5,opt,name=total_time,json=totalTime,proto3" json:"total_time" form:"total_time"`
	//
	//总状态
	TotalStatus string `protobuf:"bytes,6,opt,name=total_status,json=totalStatus,proto3" json:"total_status" form:"total_status"`
	//
	//task id
	TaskId string `protobuf:"bytes,7,opt,name=task_id,json=taskId,proto3" json:"task_id" form:"task_id"`
	//
	//工具/流程/流水线/巡检 任务id
	ToolExecId string `protobuf:"bytes,8,opt,name=tool_exec_id,json=toolExecId,proto3" json:"tool_exec_id" form:"tool_exec_id"`
	//
	//启动时间
	StartTime string `protobuf:"bytes,9,opt,name=start_time,json=startTime,proto3" json:"start_time" form:"start_time"`
	//
	//结束时间
	EndTime string `protobuf:"bytes,10,opt,name=end_time,json=endTime,proto3" json:"end_time" form:"end_time"`
	//
	//创建用户
	User string `protobuf:"bytes,11,opt,name=user,proto3" json:"user" form:"user"`
	//
	//org
	Org int32 `protobuf:"varint,12,opt,name=org,proto3" json:"org" form:"org"`
	//
	//发起定时任务的源 id
	SrcId string `protobuf:"bytes,13,opt,name=src_id,json=srcId,proto3" json:"src_id" form:"src_id"`
	//
	//任务对象类型
	JobType string `protobuf:"bytes,14,opt,name=job_type,json=jobType,proto3" json:"job_type" form:"job_type"`
	//
	//相关参数
	Annotations          *SchedulerHistory_Annotations `protobuf:"bytes,15,opt,name=annotations,proto3" json:"annotations" form:"annotations"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

定时任务

func (*SchedulerHistory) Descriptor

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

func (*SchedulerHistory) GetAnnotations

func (m *SchedulerHistory) GetAnnotations() *SchedulerHistory_Annotations

func (*SchedulerHistory) GetCode

func (m *SchedulerHistory) GetCode() int32

func (*SchedulerHistory) GetEndTime

func (m *SchedulerHistory) GetEndTime() string

func (*SchedulerHistory) GetId

func (m *SchedulerHistory) GetId() string

func (*SchedulerHistory) GetJobType

func (m *SchedulerHistory) GetJobType() string

func (*SchedulerHistory) GetMsg

func (m *SchedulerHistory) GetMsg() string

func (*SchedulerHistory) GetName

func (m *SchedulerHistory) GetName() string

func (*SchedulerHistory) GetOrg

func (m *SchedulerHistory) GetOrg() int32

func (*SchedulerHistory) GetSrcId

func (m *SchedulerHistory) GetSrcId() string

func (*SchedulerHistory) GetStartTime

func (m *SchedulerHistory) GetStartTime() string

func (*SchedulerHistory) GetTaskId

func (m *SchedulerHistory) GetTaskId() string

func (*SchedulerHistory) GetToolExecId

func (m *SchedulerHistory) GetToolExecId() string

func (*SchedulerHistory) GetTotalStatus

func (m *SchedulerHistory) GetTotalStatus() string

func (*SchedulerHistory) GetTotalTime

func (m *SchedulerHistory) GetTotalTime() int32

func (*SchedulerHistory) GetUser

func (m *SchedulerHistory) GetUser() string

func (*SchedulerHistory) ProtoMessage

func (*SchedulerHistory) ProtoMessage()

func (*SchedulerHistory) Reset

func (m *SchedulerHistory) Reset()

func (*SchedulerHistory) String

func (m *SchedulerHistory) String() string

func (*SchedulerHistory) Validate

func (this *SchedulerHistory) Validate() error

func (*SchedulerHistory) XXX_DiscardUnknown

func (m *SchedulerHistory) XXX_DiscardUnknown()

func (*SchedulerHistory) XXX_Marshal

func (m *SchedulerHistory) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchedulerHistory) XXX_Merge

func (m *SchedulerHistory) XXX_Merge(src proto.Message)

func (*SchedulerHistory) XXX_Size

func (m *SchedulerHistory) XXX_Size() int

func (*SchedulerHistory) XXX_Unmarshal

func (m *SchedulerHistory) XXX_Unmarshal(b []byte) error

type SchedulerHistory_Annotations

type SchedulerHistory_Annotations struct {
	//
	//应用ID
	AppId                string   `protobuf:"bytes,1,opt,name=appId,proto3" json:"appId" form:"appId"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SchedulerHistory_Annotations) Descriptor

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

func (*SchedulerHistory_Annotations) GetAppId

func (m *SchedulerHistory_Annotations) GetAppId() string

func (*SchedulerHistory_Annotations) ProtoMessage

func (*SchedulerHistory_Annotations) ProtoMessage()

func (*SchedulerHistory_Annotations) Reset

func (m *SchedulerHistory_Annotations) Reset()

func (*SchedulerHistory_Annotations) String

func (*SchedulerHistory_Annotations) Validate

func (this *SchedulerHistory_Annotations) Validate() error

func (*SchedulerHistory_Annotations) XXX_DiscardUnknown

func (m *SchedulerHistory_Annotations) XXX_DiscardUnknown()

func (*SchedulerHistory_Annotations) XXX_Marshal

func (m *SchedulerHistory_Annotations) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchedulerHistory_Annotations) XXX_Merge

func (m *SchedulerHistory_Annotations) XXX_Merge(src proto.Message)

func (*SchedulerHistory_Annotations) XXX_Size

func (m *SchedulerHistory_Annotations) XXX_Size() int

func (*SchedulerHistory_Annotations) XXX_Unmarshal

func (m *SchedulerHistory_Annotations) XXX_Unmarshal(b []byte) error

type SchedulerTask

type SchedulerTask struct {
	//
	//scheduler task id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id" form:"id"`
	//
	//定时任务名称
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name" form:"name"`
	//
	//任务对象类型
	JobType string `protobuf:"bytes,3,opt,name=job_type,json=jobType,proto3" json:"job_type" form:"job_type"`
	//
	//定时任务执行周期类型
	TaskType string `protobuf:"bytes,4,opt,name=task_type,json=taskType,proto3" json:"task_type" form:"task_type"`
	//
	//任务执行方式,目前只使用到了http
	CmdType string `protobuf:"bytes,5,opt,name=cmd_type,json=cmdType,proto3" json:"cmd_type" form:"cmd_type"`
	//
	//定时时间:x/5 x x x x, 2018-09-04 15:56:23
	TaskScheduler string `protobuf:"bytes,6,opt,name=task_scheduler,json=taskScheduler,proto3" json:"task_scheduler" form:"task_scheduler"`
	//
	//相关参数
	Annotations *SchedulerTask_Annotations `protobuf:"bytes,7,opt,name=annotations,proto3" json:"annotations" form:"annotations"`
	//
	//发起定时任务的源 id
	SrcId string `protobuf:"bytes,8,opt,name=src_id,json=srcId,proto3" json:"src_id" form:"src_id"`
	//
	//任务的具体配置, http或脚本
	CmdConfig *SchedulerTask_CmdConfig `protobuf:"bytes,9,opt,name=cmd_config,json=cmdConfig,proto3" json:"cmd_config" form:"cmd_config"`
	//
	//任务创建者来源
	Assignner string `protobuf:"bytes,10,opt,name=assignner,proto3" json:"assignner" form:"assignner"`
	//
	//0 表示不禁用, 1 表示禁用
	Disable int32 `protobuf:"varint,11,opt,name=disable,proto3" json:"disable" form:"disable"`
	//
	//0 在页面可见,1 不可见
	Invisible int32 `protobuf:"varint,12,opt,name=invisible,proto3" json:"invisible" form:"invisible"`
	//
	//org
	Org int32 `protobuf:"varint,13,opt,name=org,proto3" json:"org" form:"org"`
	//
	//创建用户
	User string `protobuf:"bytes,14,opt,name=user,proto3" json:"user" form:"user"`
	//
	//操作权限
	OperateAuthorizers []string `protobuf:"bytes,15,rep,name=operateAuthorizers,proto3" json:"operateAuthorizers" form:"operateAuthorizers"`
	//
	//删除权限
	DeleteAuthorizers []string `protobuf:"bytes,16,rep,name=deleteAuthorizers,proto3" json:"deleteAuthorizers" form:"deleteAuthorizers"`
	//
	//更新权限
	UpdateAuthorizers []string `protobuf:"bytes,17,rep,name=updateAuthorizers,proto3" json:"updateAuthorizers" form:"updateAuthorizers"`
	//
	//创建时间
	CreateTime string `protobuf:"bytes,18,opt,name=create_time,json=createTime,proto3" json:"create_time" form:"create_time"`
	//
	//更新时间
	UpdateTime string `protobuf:"bytes,19,opt,name=update_time,json=updateTime,proto3" json:"update_time" form:"update_time"`
	//
	//job id
	JobId string `protobuf:"bytes,20,opt,name=job_id,json=jobId,proto3" json:"job_id" form:"job_id"`
	//
	//运行状态
	Status int32 `protobuf:"varint,21,opt,name=status,proto3" json:"status" form:"status"`
	//
	//回调
	Callback *SchedulerTask_Callback `protobuf:"bytes,22,opt,name=callback,proto3" json:"callback" form:"callback"`
	//
	//调度结果信息。{u'message': u'Success', u'code': 0, u'data': {u'execId': u'201809_task155123648b640b916475'}, u'error': u'\u6210\u529f\u3002Success'}
	Error                string   `protobuf:"bytes,23,opt,name=error,proto3" json:"error" form:"error"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

定时任务

func (*SchedulerTask) Descriptor

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

func (*SchedulerTask) GetAnnotations

func (m *SchedulerTask) GetAnnotations() *SchedulerTask_Annotations

func (*SchedulerTask) GetAssignner

func (m *SchedulerTask) GetAssignner() string

func (*SchedulerTask) GetCallback

func (m *SchedulerTask) GetCallback() *SchedulerTask_Callback

func (*SchedulerTask) GetCmdConfig

func (m *SchedulerTask) GetCmdConfig() *SchedulerTask_CmdConfig

func (*SchedulerTask) GetCmdType

func (m *SchedulerTask) GetCmdType() string

func (*SchedulerTask) GetCreateTime

func (m *SchedulerTask) GetCreateTime() string

func (*SchedulerTask) GetDeleteAuthorizers

func (m *SchedulerTask) GetDeleteAuthorizers() []string

func (*SchedulerTask) GetDisable

func (m *SchedulerTask) GetDisable() int32

func (*SchedulerTask) GetError

func (m *SchedulerTask) GetError() string

func (*SchedulerTask) GetId

func (m *SchedulerTask) GetId() string

func (*SchedulerTask) GetInvisible

func (m *SchedulerTask) GetInvisible() int32

func (*SchedulerTask) GetJobId

func (m *SchedulerTask) GetJobId() string

func (*SchedulerTask) GetJobType

func (m *SchedulerTask) GetJobType() string

func (*SchedulerTask) GetName

func (m *SchedulerTask) GetName() string

func (*SchedulerTask) GetOperateAuthorizers

func (m *SchedulerTask) GetOperateAuthorizers() []string

func (*SchedulerTask) GetOrg

func (m *SchedulerTask) GetOrg() int32

func (*SchedulerTask) GetSrcId

func (m *SchedulerTask) GetSrcId() string

func (*SchedulerTask) GetStatus

func (m *SchedulerTask) GetStatus() int32

func (*SchedulerTask) GetTaskScheduler

func (m *SchedulerTask) GetTaskScheduler() string

func (*SchedulerTask) GetTaskType

func (m *SchedulerTask) GetTaskType() string

func (*SchedulerTask) GetUpdateAuthorizers

func (m *SchedulerTask) GetUpdateAuthorizers() []string

func (*SchedulerTask) GetUpdateTime

func (m *SchedulerTask) GetUpdateTime() string

func (*SchedulerTask) GetUser

func (m *SchedulerTask) GetUser() string

func (*SchedulerTask) ProtoMessage

func (*SchedulerTask) ProtoMessage()

func (*SchedulerTask) Reset

func (m *SchedulerTask) Reset()

func (*SchedulerTask) String

func (m *SchedulerTask) String() string

func (*SchedulerTask) Validate

func (this *SchedulerTask) Validate() error

func (*SchedulerTask) XXX_DiscardUnknown

func (m *SchedulerTask) XXX_DiscardUnknown()

func (*SchedulerTask) XXX_Marshal

func (m *SchedulerTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchedulerTask) XXX_Merge

func (m *SchedulerTask) XXX_Merge(src proto.Message)

func (*SchedulerTask) XXX_Size

func (m *SchedulerTask) XXX_Size() int

func (*SchedulerTask) XXX_Unmarshal

func (m *SchedulerTask) XXX_Unmarshal(b []byte) error

type SchedulerTask_Annotations

type SchedulerTask_Annotations struct {
	//
	//应用ID
	AppId                string   `protobuf:"bytes,1,opt,name=appId,proto3" json:"appId" form:"appId"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SchedulerTask_Annotations) Descriptor

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

func (*SchedulerTask_Annotations) GetAppId

func (m *SchedulerTask_Annotations) GetAppId() string

func (*SchedulerTask_Annotations) ProtoMessage

func (*SchedulerTask_Annotations) ProtoMessage()

func (*SchedulerTask_Annotations) Reset

func (m *SchedulerTask_Annotations) Reset()

func (*SchedulerTask_Annotations) String

func (m *SchedulerTask_Annotations) String() string

func (*SchedulerTask_Annotations) Validate

func (this *SchedulerTask_Annotations) Validate() error

func (*SchedulerTask_Annotations) XXX_DiscardUnknown

func (m *SchedulerTask_Annotations) XXX_DiscardUnknown()

func (*SchedulerTask_Annotations) XXX_Marshal

func (m *SchedulerTask_Annotations) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchedulerTask_Annotations) XXX_Merge

func (m *SchedulerTask_Annotations) XXX_Merge(src proto.Message)

func (*SchedulerTask_Annotations) XXX_Size

func (m *SchedulerTask_Annotations) XXX_Size() int

func (*SchedulerTask_Annotations) XXX_Unmarshal

func (m *SchedulerTask_Annotations) XXX_Unmarshal(b []byte) error

type SchedulerTask_Callback

type SchedulerTask_Callback struct {
	//
	//url
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url" form:"url"`
	//
	//header host
	Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host" form:"host"`
	//
	//名字服务
	EnsName              string   `protobuf:"bytes,3,opt,name=ensName,proto3" json:"ensName" form:"ensName"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SchedulerTask_Callback) Descriptor

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

func (*SchedulerTask_Callback) GetEnsName

func (m *SchedulerTask_Callback) GetEnsName() string

func (*SchedulerTask_Callback) GetHost

func (m *SchedulerTask_Callback) GetHost() string

func (*SchedulerTask_Callback) GetUrl

func (m *SchedulerTask_Callback) GetUrl() string

func (*SchedulerTask_Callback) ProtoMessage

func (*SchedulerTask_Callback) ProtoMessage()

func (*SchedulerTask_Callback) Reset

func (m *SchedulerTask_Callback) Reset()

func (*SchedulerTask_Callback) String

func (m *SchedulerTask_Callback) String() string

func (*SchedulerTask_Callback) Validate

func (this *SchedulerTask_Callback) Validate() error

func (*SchedulerTask_Callback) XXX_DiscardUnknown

func (m *SchedulerTask_Callback) XXX_DiscardUnknown()

func (*SchedulerTask_Callback) XXX_Marshal

func (m *SchedulerTask_Callback) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchedulerTask_Callback) XXX_Merge

func (m *SchedulerTask_Callback) XXX_Merge(src proto.Message)

func (*SchedulerTask_Callback) XXX_Size

func (m *SchedulerTask_Callback) XXX_Size() int

func (*SchedulerTask_Callback) XXX_Unmarshal

func (m *SchedulerTask_Callback) XXX_Unmarshal(b []byte) error

type SchedulerTask_CmdConfig

type SchedulerTask_CmdConfig struct {
	//
	//uri
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url" form:"url"`
	//
	//名字服务
	ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name" form:"service_name"`
	//
	//端口
	Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port" form:"port"`
	//
	//名字服务
	Host string `protobuf:"bytes,4,opt,name=host,proto3" json:"host" form:"host"`
	//
	//http 请求
	Method string `protobuf:"bytes,5,opt,name=method,proto3" json:"method" form:"method"`
	//
	//请求头
	Headers *types.Struct `protobuf:"bytes,6,opt,name=headers,proto3" json:"headers" form:"headers"`
	//
	//参数
	Params               *types.Struct `protobuf:"bytes,7,opt,name=params,proto3" json:"params" form:"params"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*SchedulerTask_CmdConfig) Descriptor

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

func (*SchedulerTask_CmdConfig) GetHeaders

func (m *SchedulerTask_CmdConfig) GetHeaders() *types.Struct

func (*SchedulerTask_CmdConfig) GetHost

func (m *SchedulerTask_CmdConfig) GetHost() string

func (*SchedulerTask_CmdConfig) GetMethod

func (m *SchedulerTask_CmdConfig) GetMethod() string

func (*SchedulerTask_CmdConfig) GetParams

func (m *SchedulerTask_CmdConfig) GetParams() *types.Struct

func (*SchedulerTask_CmdConfig) GetPort

func (m *SchedulerTask_CmdConfig) GetPort() int32

func (*SchedulerTask_CmdConfig) GetServiceName

func (m *SchedulerTask_CmdConfig) GetServiceName() string

func (*SchedulerTask_CmdConfig) GetUrl

func (m *SchedulerTask_CmdConfig) GetUrl() string

func (*SchedulerTask_CmdConfig) ProtoMessage

func (*SchedulerTask_CmdConfig) ProtoMessage()

func (*SchedulerTask_CmdConfig) Reset

func (m *SchedulerTask_CmdConfig) Reset()

func (*SchedulerTask_CmdConfig) String

func (m *SchedulerTask_CmdConfig) String() string

func (*SchedulerTask_CmdConfig) Validate

func (this *SchedulerTask_CmdConfig) Validate() error

func (*SchedulerTask_CmdConfig) XXX_DiscardUnknown

func (m *SchedulerTask_CmdConfig) XXX_DiscardUnknown()

func (*SchedulerTask_CmdConfig) XXX_Marshal

func (m *SchedulerTask_CmdConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchedulerTask_CmdConfig) XXX_Merge

func (m *SchedulerTask_CmdConfig) XXX_Merge(src proto.Message)

func (*SchedulerTask_CmdConfig) XXX_Size

func (m *SchedulerTask_CmdConfig) XXX_Size() int

func (*SchedulerTask_CmdConfig) XXX_Unmarshal

func (m *SchedulerTask_CmdConfig) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL