task_history

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: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterService

func RegisterService(s giraffe_micro.Server, srv Service)

Types

type Client

type Client interface {
	CreateHistory(ctx context.Context, in *CreateHistoryRequest) (*CreateHistoryResponse, error)
	ListHistory(ctx context.Context, in *ListHistoryRequest) (*ListHistoryResponse, error)
}

Client is the client API for task_history service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClient

func NewClient(c giraffe_micro.Client) Client

type CreateHistoryRequest

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

CreateHistory请求

func (*CreateHistoryRequest) Descriptor

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

func (*CreateHistoryRequest) GetAnnotations

func (*CreateHistoryRequest) GetCode

func (m *CreateHistoryRequest) GetCode() int32

func (*CreateHistoryRequest) GetEndTime

func (m *CreateHistoryRequest) GetEndTime() string

func (*CreateHistoryRequest) GetJobType

func (m *CreateHistoryRequest) GetJobType() string

func (*CreateHistoryRequest) GetMsg

func (m *CreateHistoryRequest) GetMsg() string

func (*CreateHistoryRequest) GetName

func (m *CreateHistoryRequest) GetName() string

func (*CreateHistoryRequest) GetOrg

func (m *CreateHistoryRequest) GetOrg() int32

func (*CreateHistoryRequest) GetSrcId

func (m *CreateHistoryRequest) GetSrcId() string

func (*CreateHistoryRequest) GetStartTime

func (m *CreateHistoryRequest) GetStartTime() string

func (*CreateHistoryRequest) GetTaskId

func (m *CreateHistoryRequest) GetTaskId() string

func (*CreateHistoryRequest) GetToolExecId

func (m *CreateHistoryRequest) GetToolExecId() string

func (*CreateHistoryRequest) GetUser

func (m *CreateHistoryRequest) GetUser() string

func (*CreateHistoryRequest) ProtoMessage

func (*CreateHistoryRequest) ProtoMessage()

func (*CreateHistoryRequest) Reset

func (m *CreateHistoryRequest) Reset()

func (*CreateHistoryRequest) String

func (m *CreateHistoryRequest) String() string

func (*CreateHistoryRequest) Validate

func (this *CreateHistoryRequest) Validate() error

func (*CreateHistoryRequest) XXX_DiscardUnknown

func (m *CreateHistoryRequest) XXX_DiscardUnknown()

func (*CreateHistoryRequest) XXX_Marshal

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

func (*CreateHistoryRequest) XXX_Merge

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

func (*CreateHistoryRequest) XXX_Size

func (m *CreateHistoryRequest) XXX_Size() int

func (*CreateHistoryRequest) XXX_Unmarshal

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

type CreateHistoryRequest_Annotations

type CreateHistoryRequest_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 (*CreateHistoryRequest_Annotations) Descriptor

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

func (*CreateHistoryRequest_Annotations) GetAppId

func (*CreateHistoryRequest_Annotations) ProtoMessage

func (*CreateHistoryRequest_Annotations) ProtoMessage()

func (*CreateHistoryRequest_Annotations) Reset

func (*CreateHistoryRequest_Annotations) String

func (*CreateHistoryRequest_Annotations) Validate

func (this *CreateHistoryRequest_Annotations) Validate() error

func (*CreateHistoryRequest_Annotations) XXX_DiscardUnknown

func (m *CreateHistoryRequest_Annotations) XXX_DiscardUnknown()

func (*CreateHistoryRequest_Annotations) XXX_Marshal

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

func (*CreateHistoryRequest_Annotations) XXX_Merge

func (*CreateHistoryRequest_Annotations) XXX_Size

func (m *CreateHistoryRequest_Annotations) XXX_Size() int

func (*CreateHistoryRequest_Annotations) XXX_Unmarshal

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

type CreateHistoryResponse

type CreateHistoryResponse struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//结果信息
	Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg" form:"msg"`
	//
	//返回数据
	Data                 *CreateHistoryResponse_Data `protobuf:"bytes,3,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

CreateHistory返回

func (*CreateHistoryResponse) Descriptor

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

func (*CreateHistoryResponse) GetCode

func (m *CreateHistoryResponse) GetCode() int32

func (*CreateHistoryResponse) GetData

func (*CreateHistoryResponse) GetMsg

func (m *CreateHistoryResponse) GetMsg() string

func (*CreateHistoryResponse) ProtoMessage

func (*CreateHistoryResponse) ProtoMessage()

func (*CreateHistoryResponse) Reset

func (m *CreateHistoryResponse) Reset()

func (*CreateHistoryResponse) String

func (m *CreateHistoryResponse) String() string

func (*CreateHistoryResponse) Validate

func (this *CreateHistoryResponse) Validate() error

func (*CreateHistoryResponse) XXX_DiscardUnknown

func (m *CreateHistoryResponse) XXX_DiscardUnknown()

func (*CreateHistoryResponse) XXX_Marshal

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

func (*CreateHistoryResponse) XXX_Merge

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

func (*CreateHistoryResponse) XXX_Size

func (m *CreateHistoryResponse) XXX_Size() int

func (*CreateHistoryResponse) XXX_Unmarshal

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

type CreateHistoryResponseWrapper

type CreateHistoryResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *CreateHistoryResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

CreateHistoryApi返回

func (*CreateHistoryResponseWrapper) Descriptor

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

func (*CreateHistoryResponseWrapper) GetCode

func (m *CreateHistoryResponseWrapper) GetCode() int32

func (*CreateHistoryResponseWrapper) GetCodeExplain

func (m *CreateHistoryResponseWrapper) GetCodeExplain() string

func (*CreateHistoryResponseWrapper) GetData

func (*CreateHistoryResponseWrapper) GetError

func (m *CreateHistoryResponseWrapper) GetError() string

func (*CreateHistoryResponseWrapper) ProtoMessage

func (*CreateHistoryResponseWrapper) ProtoMessage()

func (*CreateHistoryResponseWrapper) Reset

func (m *CreateHistoryResponseWrapper) Reset()

func (*CreateHistoryResponseWrapper) String

func (*CreateHistoryResponseWrapper) Validate

func (this *CreateHistoryResponseWrapper) Validate() error

func (*CreateHistoryResponseWrapper) XXX_DiscardUnknown

func (m *CreateHistoryResponseWrapper) XXX_DiscardUnknown()

func (*CreateHistoryResponseWrapper) XXX_Marshal

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

func (*CreateHistoryResponseWrapper) XXX_Merge

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

func (*CreateHistoryResponseWrapper) XXX_Size

func (m *CreateHistoryResponseWrapper) XXX_Size() int

func (*CreateHistoryResponseWrapper) XXX_Unmarshal

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

type CreateHistoryResponse_Data

type CreateHistoryResponse_Data struct {
	//
	//新建立的id
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id" form:"id"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateHistoryResponse_Data) Descriptor

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

func (*CreateHistoryResponse_Data) GetId

func (*CreateHistoryResponse_Data) ProtoMessage

func (*CreateHistoryResponse_Data) ProtoMessage()

func (*CreateHistoryResponse_Data) Reset

func (m *CreateHistoryResponse_Data) Reset()

func (*CreateHistoryResponse_Data) String

func (m *CreateHistoryResponse_Data) String() string

func (*CreateHistoryResponse_Data) Validate

func (this *CreateHistoryResponse_Data) Validate() error

func (*CreateHistoryResponse_Data) XXX_DiscardUnknown

func (m *CreateHistoryResponse_Data) XXX_DiscardUnknown()

func (*CreateHistoryResponse_Data) XXX_Marshal

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

func (*CreateHistoryResponse_Data) XXX_Merge

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

func (*CreateHistoryResponse_Data) XXX_Size

func (m *CreateHistoryResponse_Data) XXX_Size() int

func (*CreateHistoryResponse_Data) XXX_Unmarshal

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

type ListHistoryRequest

type ListHistoryRequest struct {
	//
	//页码
	Page int32 `protobuf:"varint,1,opt,name=page,proto3" json:"page" form:"page"`
	//
	//每页大小
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size" form:"page_size"`
	//
	//列选择,英文逗号分隔
	XSelect__ string `protobuf:"bytes,3,opt,name=__select__,json=Select,proto3" json:"__select__" form:"__select__"`
	//
	//根据指定字段排序
	XSortby__ string `protobuf:"bytes,4,opt,name=__sortby__,json=Sortby,proto3" json:"__sortby__" form:"__sortby__"`
	//
	//源 id
	SrcId string `protobuf:"bytes,5,opt,name=src_id,json=srcId,proto3" json:"src_id" form:"src_id"`
	//
	//history id
	Id string `protobuf:"bytes,6,opt,name=id,proto3" json:"id" form:"id"`
	//
	//task id
	TaskId string `protobuf:"bytes,7,opt,name=task_id,json=taskId,proto3" json:"task_id" form:"task_id"`
	//
	//sdk限制字段使用
	XXX_RestFieldMask    []string `protobuf:"bytes,8,rep,name=XXX_RestFieldMask,json=XXXRestFieldMask,proto3" json:"XXX_RestFieldMask" form:"XXX_RestFieldMask"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ListHistory请求

func (*ListHistoryRequest) Descriptor

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

func (*ListHistoryRequest) GetId

func (m *ListHistoryRequest) GetId() string

func (*ListHistoryRequest) GetPage

func (m *ListHistoryRequest) GetPage() int32

func (*ListHistoryRequest) GetPageSize

func (m *ListHistoryRequest) GetPageSize() int32

func (*ListHistoryRequest) GetSrcId

func (m *ListHistoryRequest) GetSrcId() string

func (*ListHistoryRequest) GetTaskId

func (m *ListHistoryRequest) GetTaskId() string

func (*ListHistoryRequest) GetXSelect__

func (m *ListHistoryRequest) GetXSelect__() string

func (*ListHistoryRequest) GetXSortby__

func (m *ListHistoryRequest) GetXSortby__() string

func (*ListHistoryRequest) GetXXX_RestFieldMask

func (m *ListHistoryRequest) GetXXX_RestFieldMask() []string

func (*ListHistoryRequest) ProtoMessage

func (*ListHistoryRequest) ProtoMessage()

func (*ListHistoryRequest) Reset

func (m *ListHistoryRequest) Reset()

func (*ListHistoryRequest) String

func (m *ListHistoryRequest) String() string

func (*ListHistoryRequest) Validate

func (this *ListHistoryRequest) Validate() error

func (*ListHistoryRequest) XXX_DiscardUnknown

func (m *ListHistoryRequest) XXX_DiscardUnknown()

func (*ListHistoryRequest) XXX_Marshal

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

func (*ListHistoryRequest) XXX_Merge

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

func (*ListHistoryRequest) XXX_Size

func (m *ListHistoryRequest) XXX_Size() int

func (*ListHistoryRequest) XXX_Unmarshal

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

type ListHistoryResponse

type ListHistoryResponse struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//初始页面
	Page int32 `protobuf:"varint,2,opt,name=page,proto3" json:"page" form:"page"`
	//
	//页面大小
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size" form:"page_size"`
	//
	//返回信息。get success
	Msg string `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg" form:"msg"`
	//
	//总大小
	Total int32 `protobuf:"varint,5,opt,name=total,proto3" json:"total" form:"total"`
	//
	//执行历史记录
	Data                 []*scheduler.SchedulerHistory `protobuf:"bytes,6,rep,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

ListHistory返回

func (*ListHistoryResponse) Descriptor

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

func (*ListHistoryResponse) GetCode

func (m *ListHistoryResponse) GetCode() int32

func (*ListHistoryResponse) GetData

func (*ListHistoryResponse) GetMsg

func (m *ListHistoryResponse) GetMsg() string

func (*ListHistoryResponse) GetPage

func (m *ListHistoryResponse) GetPage() int32

func (*ListHistoryResponse) GetPageSize

func (m *ListHistoryResponse) GetPageSize() int32

func (*ListHistoryResponse) GetTotal

func (m *ListHistoryResponse) GetTotal() int32

func (*ListHistoryResponse) ProtoMessage

func (*ListHistoryResponse) ProtoMessage()

func (*ListHistoryResponse) Reset

func (m *ListHistoryResponse) Reset()

func (*ListHistoryResponse) String

func (m *ListHistoryResponse) String() string

func (*ListHistoryResponse) Validate

func (this *ListHistoryResponse) Validate() error

func (*ListHistoryResponse) XXX_DiscardUnknown

func (m *ListHistoryResponse) XXX_DiscardUnknown()

func (*ListHistoryResponse) XXX_Marshal

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

func (*ListHistoryResponse) XXX_Merge

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

func (*ListHistoryResponse) XXX_Size

func (m *ListHistoryResponse) XXX_Size() int

func (*ListHistoryResponse) XXX_Unmarshal

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

type ListHistoryResponseWrapper

type ListHistoryResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *ListHistoryResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

ListHistoryApi返回

func (*ListHistoryResponseWrapper) Descriptor

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

func (*ListHistoryResponseWrapper) GetCode

func (m *ListHistoryResponseWrapper) GetCode() int32

func (*ListHistoryResponseWrapper) GetCodeExplain

func (m *ListHistoryResponseWrapper) GetCodeExplain() string

func (*ListHistoryResponseWrapper) GetData

func (*ListHistoryResponseWrapper) GetError

func (m *ListHistoryResponseWrapper) GetError() string

func (*ListHistoryResponseWrapper) ProtoMessage

func (*ListHistoryResponseWrapper) ProtoMessage()

func (*ListHistoryResponseWrapper) Reset

func (m *ListHistoryResponseWrapper) Reset()

func (*ListHistoryResponseWrapper) String

func (m *ListHistoryResponseWrapper) String() string

func (*ListHistoryResponseWrapper) Validate

func (this *ListHistoryResponseWrapper) Validate() error

func (*ListHistoryResponseWrapper) XXX_DiscardUnknown

func (m *ListHistoryResponseWrapper) XXX_DiscardUnknown()

func (*ListHistoryResponseWrapper) XXX_Marshal

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

func (*ListHistoryResponseWrapper) XXX_Merge

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

func (*ListHistoryResponseWrapper) XXX_Size

func (m *ListHistoryResponseWrapper) XXX_Size() int

func (*ListHistoryResponseWrapper) XXX_Unmarshal

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

type Service

type Service interface {
	CreateHistory(context.Context, *CreateHistoryRequest) (*CreateHistoryResponse, error)
	ListHistory(context.Context, *ListHistoryRequest) (*ListHistoryResponse, error)
}

Service is the server API for task_history service.

Jump to

Keyboard shortcuts

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