easy_command

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 Action 

type Action struct {
	//
	//创建任务时设置的action名称
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name" form:"name"`
	//
	//action类型，一般不用设置
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type" form:"type"`
	//
	//设置的action动作
	Action string `protobuf:"bytes,3,opt,name=action,proto3" json:"action" form:"action"`
	//
	//设置的action超时时间，单位为秒。设置为0时不超时
	Timeout int32 `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout" form:"timeout"`
	//
	//设置的action参数。见 CmdActionParam FileActionParam
	Param                *types.Struct `protobuf:"bytes,5,opt,name=param,proto3" json:"param" form:"param"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Action规格

func (*Action) Descriptor 

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

func (*Action) GetAction 

func (m *Action) GetAction() string

func (*Action) GetName 

func (m *Action) GetName() string

func (*Action) GetParam 

func (m *Action) GetParam() *types.Struct

func (*Action) GetTimeout 

func (m *Action) GetTimeout() int32

func (*Action) GetType 

func (m *Action) GetType() string

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) Reset 

func (m *Action) Reset()

func (*Action) String 

func (m *Action) String() string

func (*Action) Validate 

func (this *Action) Validate() error

func (*Action) XXX_DiscardUnknown 

func (m *Action) XXX_DiscardUnknown()

func (*Action) XXX_Marshal 

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

func (*Action) XXX_Merge 

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

func (*Action) XXX_Size 

func (m *Action) XXX_Size() int

func (*Action) XXX_Unmarshal 

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

type ActionLog 

type ActionLog struct {
	//
	//action在action列表里的序号。从0开始
	ActionSeq int32 `protobuf:"varint,1,opt,name=actionSeq,proto3" json:"actionSeq" form:"actionSeq"`
	//
	//actionSeq的字符串版本
	ActionId string `protobuf:"bytes,2,opt,name=actionId,proto3" json:"actionId" form:"actionId"`
	//
	//创建任务时设置的action名称
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name" form:"name"`
	//
	//action类型，一般不用设置
	Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type" form:"type"`
	//
	//设置的action动作
	Action string `protobuf:"bytes,5,opt,name=action,proto3" json:"action" form:"action"`
	//
	//设置的action超时时间，单位为秒。设置为0时不超时
	Timeout int32 `protobuf:"varint,6,opt,name=timeout,proto3" json:"timeout" form:"timeout"`
	//
	//设置的action参数。见 CmdActionParam FileActionParam
	Param *types.Struct `protobuf:"bytes,7,opt,name=param,proto3" json:"param" form:"param"`
	//
	//action执行结果状态
	Status string `protobuf:"bytes,8,opt,name=status,proto3" json:"status" form:"status"`
	//
	//action进程的退出码
	Code int32 `protobuf:"varint,9,opt,name=code,proto3" json:"code" form:"code"`
	//
	//action进程的标准输出。action的标准错误输出也会重定向到标准输出
	Msg string `protobuf:"bytes,10,opt,name=msg,proto3" json:"msg" form:"msg"`
	//
	//action进程执行耗时，单位为秒
	UsedTime int32 `protobuf:"varint,11,opt,name=usedTime,proto3" json:"usedTime" form:"usedTime"`
	//
	//action开始执行时间
	StartTime string `protobuf:"bytes,12,opt,name=startTime,proto3" json:"startTime" form:"startTime"`
	//
	//action状态更新时间
	UpdateTime string `protobuf:"bytes,13,opt,name=updateTime,proto3" json:"updateTime" form:"updateTime"`
	//
	//action结束时间
	EndTime              string   `protobuf:"bytes,14,opt,name=endTime,proto3" json:"endTime" form:"endTime"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

目标机器单个action的执行结果

func (*ActionLog) Descriptor 

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

func (*ActionLog) GetAction 

func (m *ActionLog) GetAction() string

func (*ActionLog) GetActionId 

func (m *ActionLog) GetActionId() string

func (*ActionLog) GetActionSeq 

func (m *ActionLog) GetActionSeq() int32

func (*ActionLog) GetCode 

func (m *ActionLog) GetCode() int32

func (*ActionLog) GetEndTime 

func (m *ActionLog) GetEndTime() string

func (*ActionLog) GetMsg 

func (m *ActionLog) GetMsg() string

func (*ActionLog) GetName 

func (m *ActionLog) GetName() string

func (*ActionLog) GetParam 

func (m *ActionLog) GetParam() *types.Struct

func (*ActionLog) GetStartTime 

func (m *ActionLog) GetStartTime() string

func (*ActionLog) GetStatus 

func (m *ActionLog) GetStatus() string

func (*ActionLog) GetTimeout 

func (m *ActionLog) GetTimeout() int32

func (*ActionLog) GetType 

func (m *ActionLog) GetType() string

func (*ActionLog) GetUpdateTime 

func (m *ActionLog) GetUpdateTime() string

func (*ActionLog) GetUsedTime 

func (m *ActionLog) GetUsedTime() int32

func (*ActionLog) ProtoMessage 

func (*ActionLog) ProtoMessage()

func (*ActionLog) Reset 

func (m *ActionLog) Reset()

func (*ActionLog) String 

func (m *ActionLog) String() string

func (*ActionLog) Validate 

func (this *ActionLog) Validate() error

func (*ActionLog) XXX_DiscardUnknown 

func (m *ActionLog) XXX_DiscardUnknown()

func (*ActionLog) XXX_Marshal 

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

func (*ActionLog) XXX_Merge 

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

func (*ActionLog) XXX_Size 

func (m *ActionLog) XXX_Size() int

func (*ActionLog) XXX_Unmarshal 

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

type ActionParamCustom 

type ActionParamCustom struct {
	//
	//对动作为 "runCmd" 的action，为要运行的脚本的差异化内容，会拼在该action的 CmdActionParam.cmd 之前
	Param                string   `protobuf:"bytes,1,opt,name=param,proto3" json:"param" form:"param"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

一个action在一个target上的差异化参数

func (*ActionParamCustom) Descriptor 

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

func (*ActionParamCustom) GetParam 

func (m *ActionParamCustom) GetParam() string

func (*ActionParamCustom) ProtoMessage 

func (*ActionParamCustom) ProtoMessage()

func (*ActionParamCustom) Reset 

func (m *ActionParamCustom) Reset()

func (*ActionParamCustom) String 

func (m *ActionParamCustom) String() string

func (*ActionParamCustom) Validate 

func (this *ActionParamCustom) Validate() error

func (*ActionParamCustom) XXX_DiscardUnknown 

func (m *ActionParamCustom) XXX_DiscardUnknown()

func (*ActionParamCustom) XXX_Marshal 

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

func (*ActionParamCustom) XXX_Merge 

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

func (*ActionParamCustom) XXX_Size 

func (m *ActionParamCustom) XXX_Size() int

func (*ActionParamCustom) XXX_Unmarshal 

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

type CmdActionParam 

type CmdActionParam struct {
	//
	//要运行的脚本内容
	Cmd string `protobuf:"bytes,1,opt,name=cmd,proto3" json:"cmd" form:"cmd"`
	//
	//执行用户
	ExecUser string `protobuf:"bytes,2,opt,name=execUser,proto3" json:"execUser" form:"execUser"`
	//
	//脚本类型
	ScriptType string `protobuf:"bytes,3,opt,name=scriptType,proto3" json:"scriptType" form:"scriptType"`
	//
	//指定脚本解析器，如用 /usr/bin/python 执行 python 脚本。不指定会用默认的
	Parser string `protobuf:"bytes,4,opt,name=parser,proto3" json:"parser" form:"parser"`
	//
	//脚本执行超时时间，单位为秒。超时会触发agent去kill脚本的进程
	Timeout              int32    `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout" form:"timeout"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

动作为 "runCmd" 的action的参数

func (*CmdActionParam) Descriptor 

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

func (*CmdActionParam) GetCmd 

func (m *CmdActionParam) GetCmd() string

func (*CmdActionParam) GetExecUser 

func (m *CmdActionParam) GetExecUser() string

func (*CmdActionParam) GetParser 

func (m *CmdActionParam) GetParser() string

func (*CmdActionParam) GetScriptType 

func (m *CmdActionParam) GetScriptType() string

func (*CmdActionParam) GetTimeout 

func (m *CmdActionParam) GetTimeout() int32

func (*CmdActionParam) ProtoMessage 

func (*CmdActionParam) ProtoMessage()

func (*CmdActionParam) Reset 

func (m *CmdActionParam) Reset()

func (*CmdActionParam) String 

func (m *CmdActionParam) String() string

func (*CmdActionParam) Validate 

func (this *CmdActionParam) Validate() error

func (*CmdActionParam) XXX_DiscardUnknown 

func (m *CmdActionParam) XXX_DiscardUnknown()

func (*CmdActionParam) XXX_Marshal 

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

func (*CmdActionParam) XXX_Merge 

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

func (*CmdActionParam) XXX_Size 

func (m *CmdActionParam) XXX_Size() int

func (*CmdActionParam) XXX_Unmarshal 

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

type FileActionParam 

type FileActionParam struct {
	//
	//文件内容 base64 编码字符串
	Content string `protobuf:"bytes,1,opt,name=content,proto3" json:"content" form:"content"`
	//
	//保存到目标机器的绝对路径，如 /tmp/foo/bar.tar.gz
	DstFile              string   `protobuf:"bytes,2,opt,name=dst_file,json=dstFile,proto3" json:"dst_file" form:"dst_file"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

动作为 "saveFile" 的action的参数

func (*FileActionParam) Descriptor 

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

func (*FileActionParam) GetContent 

func (m *FileActionParam) GetContent() string

func (*FileActionParam) GetDstFile 

func (m *FileActionParam) GetDstFile() string

func (*FileActionParam) ProtoMessage 

func (*FileActionParam) ProtoMessage()

func (*FileActionParam) Reset 

func (m *FileActionParam) Reset()

func (*FileActionParam) String 

func (m *FileActionParam) String() string

func (*FileActionParam) Validate 

func (this *FileActionParam) Validate() error

func (*FileActionParam) XXX_DiscardUnknown 

func (m *FileActionParam) XXX_DiscardUnknown()

func (*FileActionParam) XXX_Marshal 

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

func (*FileActionParam) XXX_Merge 

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

func (*FileActionParam) XXX_Size 

func (m *FileActionParam) XXX_Size() int

func (*FileActionParam) XXX_Unmarshal 

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

type Target 

type Target struct {
	//
	//目标机器ID (cmdb系统的instanceId)
	TargetId string `protobuf:"bytes,1,opt,name=targetId,proto3" json:"targetId" form:"targetId"`
	//
	//目标机器名称
	TargetName string `protobuf:"bytes,2,opt,name=targetName,proto3" json:"targetName" form:"targetName"`
	//
	//任务的各个action在本target上的差异化参数信息。如果传了，则列表长度必须跟该任务的 actions 列表长度一致
	ActionParams         []*ActionParamCustom `protobuf:"bytes,3,rep,name=actionParams,proto3" json:"actionParams" form:"actionParams"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

任务目标机器

func (*Target) Descriptor 

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

func (*Target) GetActionParams 

func (m *Target) GetActionParams() []*ActionParamCustom

func (*Target) GetTargetId 

func (m *Target) GetTargetId() string

func (*Target) GetTargetName 

func (m *Target) GetTargetName() string

func (*Target) ProtoMessage 

func (*Target) ProtoMessage()

func (*Target) Reset 

func (m *Target) Reset()

func (*Target) String 

func (m *Target) String() string

func (*Target) Validate 

func (this *Target) Validate() error

func (*Target) XXX_DiscardUnknown 

func (m *Target) XXX_DiscardUnknown()

func (*Target) XXX_Marshal 

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

func (*Target) XXX_Merge 

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

func (*Target) XXX_Size 

func (m *Target) XXX_Size() int

func (*Target) XXX_Unmarshal 

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

type TargetLog 

type TargetLog struct {
	//
	//目标机器ID (cmdb系统的instanceId)
	TargetId string `protobuf:"bytes,1,opt,name=targetId,proto3" json:"targetId" form:"targetId"`
	//
	//目标机器名称
	TargetName string `protobuf:"bytes,2,opt,name=targetName,proto3" json:"targetName" form:"targetName"`
	//
	//目标机器上多个action的整体执行结果状态
	Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status" form:"status"`
	//
	//系统状态，发生系统错误时，状态记录在此字段
	SysStatus string `protobuf:"bytes,4,opt,name=sysStatus,proto3" json:"sysStatus" form:"sysStatus"`
	//
	//目标机器上最后一个已结束的action的进程退出码
	Code int32 `protobuf:"varint,5,opt,name=code,proto3" json:"code" form:"code"`
	//
	//目标机器上多个action的标准输出的拼接。action的标准错误输出也会重定向到标准输出
	Msg string `protobuf:"bytes,6,opt,name=msg,proto3" json:"msg" form:"msg"`
	//
	//目标机器上多个action的执行结果详情
	ActionsLog []*ActionLog `protobuf:"bytes,7,rep,name=actionsLog,proto3" json:"actionsLog" form:"actionsLog"`
	//
	//目标机器上多个action的执行用时。单位为秒
	UsedTime int32 `protobuf:"varint,8,opt,name=usedTime,proto3" json:"usedTime" form:"usedTime"`
	//
	//目标机器的开始执行时间（第一个action）
	StartTime string `protobuf:"bytes,9,opt,name=startTime,proto3" json:"startTime" form:"startTime"`
	//
	//目标机器的执行状态更新时间
	UpdateTime string `protobuf:"bytes,10,opt,name=updateTime,proto3" json:"updateTime" form:"updateTime"`
	//
	//目标机器的执行结束时间
	EndTime              string   `protobuf:"bytes,11,opt,name=endTime,proto3" json:"endTime" form:"endTime"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

单个目标机器的任务执行结果

func (*TargetLog) Descriptor 

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

func (*TargetLog) GetActionsLog 

func (m *TargetLog) GetActionsLog() []*ActionLog

func (*TargetLog) GetCode 

func (m *TargetLog) GetCode() int32

func (*TargetLog) GetEndTime 

func (m *TargetLog) GetEndTime() string

func (*TargetLog) GetMsg 

func (m *TargetLog) GetMsg() string

func (*TargetLog) GetStartTime 

func (m *TargetLog) GetStartTime() string

func (*TargetLog) GetStatus 

func (m *TargetLog) GetStatus() string

func (*TargetLog) GetSysStatus 

func (m *TargetLog) GetSysStatus() string

func (*TargetLog) GetTargetId 

func (m *TargetLog) GetTargetId() string

func (*TargetLog) GetTargetName 

func (m *TargetLog) GetTargetName() string

func (*TargetLog) GetUpdateTime 

func (m *TargetLog) GetUpdateTime() string

func (*TargetLog) GetUsedTime 

func (m *TargetLog) GetUsedTime() int32

func (*TargetLog) ProtoMessage 

func (*TargetLog) ProtoMessage()

func (*TargetLog) Reset 

func (m *TargetLog) Reset()

func (*TargetLog) String 

func (m *TargetLog) String() string

func (*TargetLog) Validate 

func (this *TargetLog) Validate() error

func (*TargetLog) XXX_DiscardUnknown 

func (m *TargetLog) XXX_DiscardUnknown()

func (*TargetLog) XXX_Marshal 

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

func (*TargetLog) XXX_Merge 

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

func (*TargetLog) XXX_Size 

func (m *TargetLog) XXX_Size() int

func (*TargetLog) XXX_Unmarshal 

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

type TaskCallback 

type TaskCallback struct {
	//
	//回调接口的 http url
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url" form:"url"`
	//
	//回调接口组件的 ens 名字
	EnsName string `protobuf:"bytes,2,opt,name=ensName,proto3" json:"ensName" form:"ensName"`
	//
	//指定回调接口的IP
	Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip" form:"ip"`
	//
	//指定回调接口的端口
	Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port" form:"port"`
	//
	//指定调用回调接口的 Host header
	Host                 string   `protobuf:"bytes,5,opt,name=host,proto3" json:"host" form:"host"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

任务回调设置

func (*TaskCallback) Descriptor 

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

func (*TaskCallback) GetEnsName 

func (m *TaskCallback) GetEnsName() string

func (*TaskCallback) GetHost 

func (m *TaskCallback) GetHost() string

func (*TaskCallback) GetIp 

func (m *TaskCallback) GetIp() string

func (*TaskCallback) GetPort 

func (m *TaskCallback) GetPort() int32

func (*TaskCallback) GetUrl 

func (m *TaskCallback) GetUrl() string

func (*TaskCallback) ProtoMessage 

func (*TaskCallback) ProtoMessage()

func (*TaskCallback) Reset 

func (m *TaskCallback) Reset()

func (*TaskCallback) String 

func (m *TaskCallback) String() string

func (*TaskCallback) Validate 

func (this *TaskCallback) Validate() error

func (*TaskCallback) XXX_DiscardUnknown 

func (m *TaskCallback) XXX_DiscardUnknown()

func (*TaskCallback) XXX_Marshal 

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

func (*TaskCallback) XXX_Merge 

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

func (*TaskCallback) XXX_Size 

func (m *TaskCallback) XXX_Size() int

func (*TaskCallback) XXX_Unmarshal 

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

type TaskDetail 

type TaskDetail struct {
	//
	//任务ID
	TaskId string `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId" form:"taskId"`
	//
	//任务名称
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name" form:"name"`
	//
	//任务类型。例如 agent_admin cmd command database_deliver deploy test tool
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type" form:"type"`
	//
	//操作。例如 database.check deployPreCheck instance.checkPackage instance.deploy instance.deployStrategy instance.fileDelivery instance.fileUninstall instance.restart instance.start instance.stop instance.uninstall plugin.deploy plugin.report task.run test
	Operation string `protobuf:"bytes,4,opt,name=operation,proto3" json:"operation" form:"operation"`
	//
	//任务分组id。作用不明
	GroupId string `protobuf:"bytes,5,opt,name=groupId,proto3" json:"groupId" form:"groupId"`
	//
	//关联的appId
	AppId string `protobuf:"bytes,6,opt,name=appId,proto3" json:"appId" form:"appId"`
	//
	//关联的clusterId
	ClusterId string `protobuf:"bytes,7,opt,name=clusterId,proto3" json:"clusterId" form:"clusterId"`
	//
	//关联的packageId
	PackageId string `protobuf:"bytes,8,opt,name=packageId,proto3" json:"packageId" form:"packageId"`
	//
	//关联的versionId
	VersionId string `protobuf:"bytes,9,opt,name=versionId,proto3" json:"versionId" form:"versionId"`
	//
	//是否需要发送状态变更通知到 logic.notify
	NeedNotify bool `protobuf:"varint,10,opt,name=needNotify,proto3" json:"needNotify" form:"needNotify"`
	//
	//设置的任务回调接口
	Callback *TaskCallback `protobuf:"bytes,11,opt,name=callback,proto3" json:"callback" form:"callback"`
	//
	//设置的目标机器分批执行的每批数量
	BatchNum int32 `protobuf:"varint,12,opt,name=batchNum,proto3" json:"batchNum" form:"batchNum"`
	//
	//设置的目标机器分批执行的每批之间的间隔秒数
	BatchInterval int32 `protobuf:"varint,13,opt,name=batchInterval,proto3" json:"batchInterval" form:"batchInterval"`
	//
	//如果某个目标机器的action执行失败，是否停止整个task
	FailedStop bool `protobuf:"varint,14,opt,name=failedStop,proto3" json:"failedStop" form:"failedStop"`
	//
	//租户org
	Org int32 `protobuf:"varint,15,opt,name=org,proto3" json:"org" form:"org"`
	//
	//创建任务的操作用户
	Operator string `protobuf:"bytes,16,opt,name=operator,proto3" json:"operator" form:"operator"`
	//
	//任务执行状态
	Status string `protobuf:"bytes,17,opt,name=status,proto3" json:"status" form:"status"`
	//
	//最后一个出错的目标机器action的退出码
	Code int32 `protobuf:"varint,18,opt,name=code,proto3" json:"code" form:"code"`
	//
	//整个任务当前的用时，单位为秒
	UsedTime int32 `protobuf:"varint,19,opt,name=usedTime,proto3" json:"usedTime" form:"usedTime"`
	//
	//任务开始时间
	StartTime string `protobuf:"bytes,20,opt,name=startTime,proto3" json:"startTime" form:"startTime"`
	//
	//任务状态更新时间
	UpdateTime string `protobuf:"bytes,21,opt,name=updateTime,proto3" json:"updateTime" form:"updateTime"`
	//
	//任务结束时间
	EndTime string `protobuf:"bytes,22,opt,name=endTime,proto3" json:"endTime" form:"endTime"`
	//
	//任务的各个目标机器的执行结果详情
	TargetsLog           []*TargetLog `protobuf:"bytes,23,rep,name=targetsLog,proto3" json:"targetsLog" form:"targetsLog"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

任务详情

func (*TaskDetail) Descriptor 

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

func (*TaskDetail) GetAppId 

func (m *TaskDetail) GetAppId() string

func (*TaskDetail) GetBatchInterval 

func (m *TaskDetail) GetBatchInterval() int32

func (*TaskDetail) GetBatchNum 

func (m *TaskDetail) GetBatchNum() int32

func (*TaskDetail) GetCallback 

func (m *TaskDetail) GetCallback() *TaskCallback

func (*TaskDetail) GetClusterId 

func (m *TaskDetail) GetClusterId() string

func (*TaskDetail) GetCode 

func (m *TaskDetail) GetCode() int32

func (*TaskDetail) GetEndTime 

func (m *TaskDetail) GetEndTime() string

func (*TaskDetail) GetFailedStop 

func (m *TaskDetail) GetFailedStop() bool

func (*TaskDetail) GetGroupId 

func (m *TaskDetail) GetGroupId() string

func (*TaskDetail) GetName 

func (m *TaskDetail) GetName() string

func (*TaskDetail) GetNeedNotify 

func (m *TaskDetail) GetNeedNotify() bool

func (*TaskDetail) GetOperation 

func (m *TaskDetail) GetOperation() string

func (*TaskDetail) GetOperator 

func (m *TaskDetail) GetOperator() string

func (*TaskDetail) GetOrg 

func (m *TaskDetail) GetOrg() int32

func (*TaskDetail) GetPackageId 

func (m *TaskDetail) GetPackageId() string

func (*TaskDetail) GetStartTime 

func (m *TaskDetail) GetStartTime() string

func (*TaskDetail) GetStatus 

func (m *TaskDetail) GetStatus() string

func (*TaskDetail) GetTargetsLog 

func (m *TaskDetail) GetTargetsLog() []*TargetLog

func (*TaskDetail) GetTaskId 

func (m *TaskDetail) GetTaskId() string

func (*TaskDetail) GetType 

func (m *TaskDetail) GetType() string

func (*TaskDetail) GetUpdateTime 

func (m *TaskDetail) GetUpdateTime() string

func (*TaskDetail) GetUsedTime 

func (m *TaskDetail) GetUsedTime() int32

func (*TaskDetail) GetVersionId 

func (m *TaskDetail) GetVersionId() string

func (*TaskDetail) ProtoMessage 

func (*TaskDetail) ProtoMessage()

func (*TaskDetail) Reset 

func (m *TaskDetail) Reset()

func (*TaskDetail) String 

func (m *TaskDetail) String() string

func (*TaskDetail) Validate 

func (this *TaskDetail) Validate() error

func (*TaskDetail) XXX_DiscardUnknown 

func (m *TaskDetail) XXX_DiscardUnknown()

func (*TaskDetail) XXX_Marshal 

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

func (*TaskDetail) XXX_Merge 

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

func (*TaskDetail) XXX_Size 

func (m *TaskDetail) XXX_Size() int

func (*TaskDetail) XXX_Unmarshal 

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

type TaskSpec 

type TaskSpec struct {
	//
	//任务ID。如无特殊需求不用指定，让后台自动生成，生成的格式为 {当前年月}_task[0-9a-f]{16,20} ，见正则校验。如果调用方需要指定任务ID，传入的任务ID也必须是此种格式
	TaskId string `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId" form:"taskId"`
	//
	//任务名称
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name" form:"name"`
	//
	//任务类型。例如 agent_admin cmd command database_deliver deploy test tool
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type" form:"type"`
	//
	//操作。例如 database.check deployPreCheck instance.checkPackage instance.deploy instance.deployStrategy instance.fileDelivery instance.fileUninstall instance.restart instance.start instance.stop instance.uninstall plugin.deploy plugin.report task.run test
	Operation string `protobuf:"bytes,4,opt,name=operation,proto3" json:"operation" form:"operation"`
	//
	//任务分组id。作用不明
	GroupId string `protobuf:"bytes,5,opt,name=groupId,proto3" json:"groupId" form:"groupId"`
	//
	//任务的具体action
	Actions []*Action `protobuf:"bytes,6,rep,name=actions,proto3" json:"actions" form:"actions"`
	//
	//任务的目标机器。
	Targets []*Target `protobuf:"bytes,7,rep,name=targets,proto3" json:"targets" form:"targets"`
	//
	//关联的appId
	AppId string `protobuf:"bytes,8,opt,name=appId,proto3" json:"appId" form:"appId"`
	//
	//关联的clusterId
	ClusterId string `protobuf:"bytes,9,opt,name=clusterId,proto3" json:"clusterId" form:"clusterId"`
	//
	//关联的packageId
	PackageId string `protobuf:"bytes,10,opt,name=packageId,proto3" json:"packageId" form:"packageId"`
	//
	//关联的versionId
	VersionId string `protobuf:"bytes,11,opt,name=versionId,proto3" json:"versionId" form:"versionId"`
	//
	//是否需要发送状态变更通知到 logic.notify
	NeedNotify bool `protobuf:"varint,12,opt,name=needNotify,proto3" json:"needNotify" form:"needNotify"`
	//
	//设置的任务回调接口
	Callback *TaskCallback `protobuf:"bytes,13,opt,name=callback,proto3" json:"callback" form:"callback"`
	//
	//设置的目标机器分批执行的每批数量
	BatchNum int32 `protobuf:"varint,14,opt,name=batchNum,proto3" json:"batchNum" form:"batchNum"`
	//
	//设置的目标机器分批执行的每批之间的间隔秒数
	BatchInterval int32 `protobuf:"varint,15,opt,name=batchInterval,proto3" json:"batchInterval" form:"batchInterval"`
	//
	//如果某个目标机器的action执行失败，是否停止整个task
	FailedStop           bool     `protobuf:"varint,16,opt,name=failedStop,proto3" json:"failedStop" form:"failedStop"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

任务规格

func (*TaskSpec) Descriptor 

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

func (*TaskSpec) GetActions 

func (m *TaskSpec) GetActions() []*Action

func (*TaskSpec) GetAppId 

func (m *TaskSpec) GetAppId() string

func (*TaskSpec) GetBatchInterval 

func (m *TaskSpec) GetBatchInterval() int32

func (*TaskSpec) GetBatchNum 

func (m *TaskSpec) GetBatchNum() int32

func (*TaskSpec) GetCallback 

func (m *TaskSpec) GetCallback() *TaskCallback

func (*TaskSpec) GetClusterId 

func (m *TaskSpec) GetClusterId() string

func (*TaskSpec) GetFailedStop 

func (m *TaskSpec) GetFailedStop() bool

func (*TaskSpec) GetGroupId 

func (m *TaskSpec) GetGroupId() string

func (*TaskSpec) GetName 

func (m *TaskSpec) GetName() string

func (*TaskSpec) GetNeedNotify 

func (m *TaskSpec) GetNeedNotify() bool

func (*TaskSpec) GetOperation 

func (m *TaskSpec) GetOperation() string

func (*TaskSpec) GetPackageId 

func (m *TaskSpec) GetPackageId() string

func (*TaskSpec) GetTargets 

func (m *TaskSpec) GetTargets() []*Target

func (*TaskSpec) GetTaskId 

func (m *TaskSpec) GetTaskId() string

func (*TaskSpec) GetType 

func (m *TaskSpec) GetType() string

func (*TaskSpec) GetVersionId 

func (m *TaskSpec) GetVersionId() string

func (*TaskSpec) ProtoMessage 

func (*TaskSpec) ProtoMessage()

func (*TaskSpec) Reset 

func (m *TaskSpec) Reset()

func (*TaskSpec) String 

func (m *TaskSpec) String() string

func (*TaskSpec) Validate 

func (this *TaskSpec) Validate() error

func (*TaskSpec) XXX_DiscardUnknown 

func (m *TaskSpec) XXX_DiscardUnknown()

func (*TaskSpec) XXX_Marshal 

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

func (*TaskSpec) XXX_Merge 

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

func (*TaskSpec) XXX_Size 

func (m *TaskSpec) XXX_Size() int

func (*TaskSpec) XXX_Unmarshal 

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

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.