task

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: 12 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 {
	CreateTask(ctx context.Context, in *scheduler.SchedulerTask) (*CreateTaskResponse, error)
	DelTask(ctx context.Context, in *DelTaskRequest) (*types.Empty, error)
	GetTask(ctx context.Context, in *GetTaskRequest) (*scheduler.SchedulerTask, error)
	ListTask(ctx context.Context, in *ListTaskRequest) (*ListTaskResponse, error)
	UpdateTaskDetail(ctx context.Context, in *UpdateTaskDetailRequest) (*UpdateTaskDetailResponse, error)
}

Client is the client API for task 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 CreateTaskResponse 

type CreateTaskResponse 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                 *CreateTaskResponse_Data `protobuf:"bytes,3,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

CreateTask返回

func (*CreateTaskResponse) Descriptor 

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

func (*CreateTaskResponse) GetCode 

func (m *CreateTaskResponse) GetCode() int32

func (*CreateTaskResponse) GetData 

func (m *CreateTaskResponse) GetData() *CreateTaskResponse_Data

func (*CreateTaskResponse) GetMsg 

func (m *CreateTaskResponse) GetMsg() string

func (*CreateTaskResponse) ProtoMessage 

func (*CreateTaskResponse) ProtoMessage()

func (*CreateTaskResponse) Reset 

func (m *CreateTaskResponse) Reset()

func (*CreateTaskResponse) String 

func (m *CreateTaskResponse) String() string

func (*CreateTaskResponse) Validate 

func (this *CreateTaskResponse) Validate() error

func (*CreateTaskResponse) XXX_DiscardUnknown 

func (m *CreateTaskResponse) XXX_DiscardUnknown()

func (*CreateTaskResponse) XXX_Marshal 

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

func (*CreateTaskResponse) XXX_Merge 

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

func (*CreateTaskResponse) XXX_Size 

func (m *CreateTaskResponse) XXX_Size() int

func (*CreateTaskResponse) XXX_Unmarshal 

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

type CreateTaskResponseWrapper 

type CreateTaskResponseWrapper 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                 *CreateTaskResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

CreateTaskApi返回

func (*CreateTaskResponseWrapper) Descriptor 

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

func (*CreateTaskResponseWrapper) GetCode 

func (m *CreateTaskResponseWrapper) GetCode() int32

func (*CreateTaskResponseWrapper) GetCodeExplain 

func (m *CreateTaskResponseWrapper) GetCodeExplain() string

func (*CreateTaskResponseWrapper) GetData 

func (m *CreateTaskResponseWrapper) GetData() *CreateTaskResponse

func (*CreateTaskResponseWrapper) GetError 

func (m *CreateTaskResponseWrapper) GetError() string

func (*CreateTaskResponseWrapper) ProtoMessage 

func (*CreateTaskResponseWrapper) ProtoMessage()

func (*CreateTaskResponseWrapper) Reset 

func (m *CreateTaskResponseWrapper) Reset()

func (*CreateTaskResponseWrapper) String 

func (m *CreateTaskResponseWrapper) String() string

func (*CreateTaskResponseWrapper) Validate 

func (this *CreateTaskResponseWrapper) Validate() error

func (*CreateTaskResponseWrapper) XXX_DiscardUnknown 

func (m *CreateTaskResponseWrapper) XXX_DiscardUnknown()

func (*CreateTaskResponseWrapper) XXX_Marshal 

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

func (*CreateTaskResponseWrapper) XXX_Merge 

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

func (*CreateTaskResponseWrapper) XXX_Size 

func (m *CreateTaskResponseWrapper) XXX_Size() int

func (*CreateTaskResponseWrapper) XXX_Unmarshal 

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

type CreateTaskResponse_Data 

type CreateTaskResponse_Data struct {
	//
	//新建立的task_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 (*CreateTaskResponse_Data) Descriptor 

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

func (*CreateTaskResponse_Data) GetId 

func (m *CreateTaskResponse_Data) GetId() string

func (*CreateTaskResponse_Data) ProtoMessage 

func (*CreateTaskResponse_Data) ProtoMessage()

func (*CreateTaskResponse_Data) Reset 

func (m *CreateTaskResponse_Data) Reset()

func (*CreateTaskResponse_Data) String 

func (m *CreateTaskResponse_Data) String() string

func (*CreateTaskResponse_Data) Validate 

func (this *CreateTaskResponse_Data) Validate() error

func (*CreateTaskResponse_Data) XXX_DiscardUnknown 

func (m *CreateTaskResponse_Data) XXX_DiscardUnknown()

func (*CreateTaskResponse_Data) XXX_Marshal 

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

func (*CreateTaskResponse_Data) XXX_Merge 

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

func (*CreateTaskResponse_Data) XXX_Size 

func (m *CreateTaskResponse_Data) XXX_Size() int

func (*CreateTaskResponse_Data) XXX_Unmarshal 

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

type DelTaskRequest 

type DelTaskRequest 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DelTask请求

func (*DelTaskRequest) Descriptor 

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

func (*DelTaskRequest) GetName 

func (m *DelTaskRequest) GetName() string

func (*DelTaskRequest) GetTaskId 

func (m *DelTaskRequest) GetTaskId() string

func (*DelTaskRequest) ProtoMessage 

func (*DelTaskRequest) ProtoMessage()

func (*DelTaskRequest) Reset 

func (m *DelTaskRequest) Reset()

func (*DelTaskRequest) String 

func (m *DelTaskRequest) String() string

func (*DelTaskRequest) Validate 

func (this *DelTaskRequest) Validate() error

func (*DelTaskRequest) XXX_DiscardUnknown 

func (m *DelTaskRequest) XXX_DiscardUnknown()

func (*DelTaskRequest) XXX_Marshal 

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

func (*DelTaskRequest) XXX_Merge 

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

func (*DelTaskRequest) XXX_Size 

func (m *DelTaskRequest) XXX_Size() int

func (*DelTaskRequest) XXX_Unmarshal 

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

type DelTaskResponseWrapper 

type DelTaskResponseWrapper 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                 *types.Empty `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

DelTaskApi返回

func (*DelTaskResponseWrapper) Descriptor 

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

func (*DelTaskResponseWrapper) GetCode 

func (m *DelTaskResponseWrapper) GetCode() int32

func (*DelTaskResponseWrapper) GetCodeExplain 

func (m *DelTaskResponseWrapper) GetCodeExplain() string

func (*DelTaskResponseWrapper) GetData 

func (m *DelTaskResponseWrapper) GetData() *types.Empty

func (*DelTaskResponseWrapper) GetError 

func (m *DelTaskResponseWrapper) GetError() string

func (*DelTaskResponseWrapper) ProtoMessage 

func (*DelTaskResponseWrapper) ProtoMessage()

func (*DelTaskResponseWrapper) Reset 

func (m *DelTaskResponseWrapper) Reset()

func (*DelTaskResponseWrapper) String 

func (m *DelTaskResponseWrapper) String() string

func (*DelTaskResponseWrapper) Validate 

func (this *DelTaskResponseWrapper) Validate() error

func (*DelTaskResponseWrapper) XXX_DiscardUnknown 

func (m *DelTaskResponseWrapper) XXX_DiscardUnknown()

func (*DelTaskResponseWrapper) XXX_Marshal 

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

func (*DelTaskResponseWrapper) XXX_Merge 

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

func (*DelTaskResponseWrapper) XXX_Size 

func (m *DelTaskResponseWrapper) XXX_Size() int

func (*DelTaskResponseWrapper) XXX_Unmarshal 

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

type GetTaskRequest 

type GetTaskRequest struct {
	//
	//任务id
	TaskId               string   `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId" form:"taskId"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetTask请求

func (*GetTaskRequest) Descriptor 

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

func (*GetTaskRequest) GetTaskId 

func (m *GetTaskRequest) GetTaskId() string

func (*GetTaskRequest) ProtoMessage 

func (*GetTaskRequest) ProtoMessage()

func (*GetTaskRequest) Reset 

func (m *GetTaskRequest) Reset()

func (*GetTaskRequest) String 

func (m *GetTaskRequest) String() string

func (*GetTaskRequest) Validate 

func (this *GetTaskRequest) Validate() error

func (*GetTaskRequest) XXX_DiscardUnknown 

func (m *GetTaskRequest) XXX_DiscardUnknown()

func (*GetTaskRequest) XXX_Marshal 

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

func (*GetTaskRequest) XXX_Merge 

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

func (*GetTaskRequest) XXX_Size 

func (m *GetTaskRequest) XXX_Size() int

func (*GetTaskRequest) XXX_Unmarshal 

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

type GetTaskResponseWrapper 

type GetTaskResponseWrapper 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                 *scheduler.SchedulerTask `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

GetTaskApi返回

func (*GetTaskResponseWrapper) Descriptor 

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

func (*GetTaskResponseWrapper) GetCode 

func (m *GetTaskResponseWrapper) GetCode() int32

func (*GetTaskResponseWrapper) GetCodeExplain 

func (m *GetTaskResponseWrapper) GetCodeExplain() string

func (*GetTaskResponseWrapper) GetData 

func (m *GetTaskResponseWrapper) GetData() *scheduler.SchedulerTask

func (*GetTaskResponseWrapper) GetError 

func (m *GetTaskResponseWrapper) GetError() string

func (*GetTaskResponseWrapper) ProtoMessage 

func (*GetTaskResponseWrapper) ProtoMessage()

func (*GetTaskResponseWrapper) Reset 

func (m *GetTaskResponseWrapper) Reset()

func (*GetTaskResponseWrapper) String 

func (m *GetTaskResponseWrapper) String() string

func (*GetTaskResponseWrapper) Validate 

func (this *GetTaskResponseWrapper) Validate() error

func (*GetTaskResponseWrapper) XXX_DiscardUnknown 

func (m *GetTaskResponseWrapper) XXX_DiscardUnknown()

func (*GetTaskResponseWrapper) XXX_Marshal 

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

func (*GetTaskResponseWrapper) XXX_Merge 

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

func (*GetTaskResponseWrapper) XXX_Size 

func (m *GetTaskResponseWrapper) XXX_Size() int

func (*GetTaskResponseWrapper) XXX_Unmarshal 

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

type ListTaskRequest 

type ListTaskRequest 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"`
	//
	//0表示不禁用，1 表示禁用定时任务
	Disable int32 `protobuf:"varint,6,opt,name=disable,proto3" json:"disable" form:"disable"`
	//
	//调用方的名字服务
	Assignner string `protobuf:"bytes,7,opt,name=assignner,proto3" json:"assignner" form:"assignner"`
	//
	//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:"-"`
}

ListTask请求

func (*ListTaskRequest) Descriptor 

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

func (*ListTaskRequest) GetAssignner 

func (m *ListTaskRequest) GetAssignner() string

func (*ListTaskRequest) GetDisable 

func (m *ListTaskRequest) GetDisable() int32

func (*ListTaskRequest) GetPage 

func (m *ListTaskRequest) GetPage() int32

func (*ListTaskRequest) GetPageSize 

func (m *ListTaskRequest) GetPageSize() int32

func (*ListTaskRequest) GetSrcId 

func (m *ListTaskRequest) GetSrcId() string

func (*ListTaskRequest) GetXSelect__ 

func (m *ListTaskRequest) GetXSelect__() string

func (*ListTaskRequest) GetXSortby__ 

func (m *ListTaskRequest) GetXSortby__() string

func (*ListTaskRequest) GetXXX_RestFieldMask 

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

func (*ListTaskRequest) ProtoMessage 

func (*ListTaskRequest) ProtoMessage()

func (*ListTaskRequest) Reset 

func (m *ListTaskRequest) Reset()

func (*ListTaskRequest) String 

func (m *ListTaskRequest) String() string

func (*ListTaskRequest) Validate 

func (this *ListTaskRequest) Validate() error

func (*ListTaskRequest) XXX_DiscardUnknown 

func (m *ListTaskRequest) XXX_DiscardUnknown()

func (*ListTaskRequest) XXX_Marshal 

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

func (*ListTaskRequest) XXX_Merge 

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

func (*ListTaskRequest) XXX_Size 

func (m *ListTaskRequest) XXX_Size() int

func (*ListTaskRequest) XXX_Unmarshal 

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

type ListTaskResponse 

type ListTaskResponse 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.SchedulerTask `protobuf:"bytes,6,rep,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

ListTask返回

func (*ListTaskResponse) Descriptor 

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

func (*ListTaskResponse) GetCode 

func (m *ListTaskResponse) GetCode() int32

func (*ListTaskResponse) GetData 

func (m *ListTaskResponse) GetData() []*scheduler.SchedulerTask

func (*ListTaskResponse) GetMsg 

func (m *ListTaskResponse) GetMsg() string

func (*ListTaskResponse) GetPage 

func (m *ListTaskResponse) GetPage() int32

func (*ListTaskResponse) GetPageSize 

func (m *ListTaskResponse) GetPageSize() int32

func (*ListTaskResponse) GetTotal 

func (m *ListTaskResponse) GetTotal() int32

func (*ListTaskResponse) ProtoMessage 

func (*ListTaskResponse) ProtoMessage()

func (*ListTaskResponse) Reset 

func (m *ListTaskResponse) Reset()

func (*ListTaskResponse) String 

func (m *ListTaskResponse) String() string

func (*ListTaskResponse) Validate 

func (this *ListTaskResponse) Validate() error

func (*ListTaskResponse) XXX_DiscardUnknown 

func (m *ListTaskResponse) XXX_DiscardUnknown()

func (*ListTaskResponse) XXX_Marshal 

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

func (*ListTaskResponse) XXX_Merge 

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

func (*ListTaskResponse) XXX_Size 

func (m *ListTaskResponse) XXX_Size() int

func (*ListTaskResponse) XXX_Unmarshal 

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

type ListTaskResponseWrapper 

type ListTaskResponseWrapper 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                 *ListTaskResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

ListTaskApi返回

func (*ListTaskResponseWrapper) Descriptor 

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

func (*ListTaskResponseWrapper) GetCode 

func (m *ListTaskResponseWrapper) GetCode() int32

func (*ListTaskResponseWrapper) GetCodeExplain 

func (m *ListTaskResponseWrapper) GetCodeExplain() string

func (*ListTaskResponseWrapper) GetData 

func (m *ListTaskResponseWrapper) GetData() *ListTaskResponse

func (*ListTaskResponseWrapper) GetError 

func (m *ListTaskResponseWrapper) GetError() string

func (*ListTaskResponseWrapper) ProtoMessage 

func (*ListTaskResponseWrapper) ProtoMessage()

func (*ListTaskResponseWrapper) Reset 

func (m *ListTaskResponseWrapper) Reset()

func (*ListTaskResponseWrapper) String 

func (m *ListTaskResponseWrapper) String() string

func (*ListTaskResponseWrapper) Validate 

func (this *ListTaskResponseWrapper) Validate() error

func (*ListTaskResponseWrapper) XXX_DiscardUnknown 

func (m *ListTaskResponseWrapper) XXX_DiscardUnknown()

func (*ListTaskResponseWrapper) XXX_Marshal 

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

func (*ListTaskResponseWrapper) XXX_Merge 

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

func (*ListTaskResponseWrapper) XXX_Size 

func (m *ListTaskResponseWrapper) XXX_Size() int

func (*ListTaskResponseWrapper) XXX_Unmarshal 

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

type Service 

type Service interface {
	CreateTask(context.Context, *scheduler.SchedulerTask) (*CreateTaskResponse, error)
	DelTask(context.Context, *DelTaskRequest) (*types.Empty, error)
	GetTask(context.Context, *GetTaskRequest) (*scheduler.SchedulerTask, error)
	ListTask(context.Context, *ListTaskRequest) (*ListTaskResponse, error)
	UpdateTaskDetail(context.Context, *UpdateTaskDetailRequest) (*UpdateTaskDetailResponse, error)
}

Service is the server API for task service.

type UpdateTaskDetailRequest 

type UpdateTaskDetailRequest struct {
	//
	//任务id
	TaskId string `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId" form:"taskId"`
	//
	//0 在页面可见，1 不可见
	Invisible int32 `protobuf:"varint,2,opt,name=invisible,proto3" json:"invisible" form:"invisible"`
	//
	//0 表示不禁用, 1 表示禁用
	Disable int32 `protobuf:"varint,3,opt,name=disable,proto3" json:"disable" form:"disable"`
	//
	//运行状态
	Status int32 `protobuf:"varint,4,opt,name=status,proto3" json:"status" form:"status"`
	//
	//调度结果信息。{u'message': u'Success', u'code': 0, u'data': {u'execId': u'201809_task155123648b640b916475'}, u'error': u'\u6210\u529f\u3002Success'}
	Error string `protobuf:"bytes,5,opt,name=error,proto3" json:"error" form:"error"`
	//
	//任务对象类型
	JobType string `protobuf:"bytes,6,opt,name=job_type,json=jobType,proto3" json:"job_type" form:"job_type"`
	//
	//相关参数
	Annotations *UpdateTaskDetailRequest_Annotations `protobuf:"bytes,7,opt,name=annotations,proto3" json:"annotations" form:"annotations"`
	//
	//定时任务执行周期类型
	TaskType string `protobuf:"bytes,8,opt,name=task_type,json=taskType,proto3" json:"task_type" form:"task_type"`
	//
	//定时任务名称
	Name string `protobuf:"bytes,9,opt,name=name,proto3" json:"name" form:"name"`
	//
	//任务的具体配置, http或脚本
	CmdConfig *UpdateTaskDetailRequest_CmdConfig `protobuf:"bytes,10,opt,name=cmd_config,json=cmdConfig,proto3" json:"cmd_config" form:"cmd_config"`
	//
	//定时时间：x/5 x x x x， 2018-09-04 15:56:23
	TaskScheduler string `protobuf:"bytes,11,opt,name=task_scheduler,json=taskScheduler,proto3" json:"task_scheduler" form:"task_scheduler"`
	//
	//回调
	Callback *UpdateTaskDetailRequest_Callback `protobuf:"bytes,12,opt,name=callback,proto3" json:"callback" form:"callback"`
	//
	//更新权限
	UpdateAuthorizers []string `protobuf:"bytes,13,rep,name=updateAuthorizers,proto3" json:"updateAuthorizers" form:"updateAuthorizers"`
	//
	//操作权限
	OperateAuthorizers []string `protobuf:"bytes,14,rep,name=operateAuthorizers,proto3" json:"operateAuthorizers" form:"operateAuthorizers"`
	//
	//删除权限
	DeleteAuthorizers    []string `protobuf:"bytes,15,rep,name=deleteAuthorizers,proto3" json:"deleteAuthorizers" form:"deleteAuthorizers"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

UpdateTaskDetail请求

func (*UpdateTaskDetailRequest) Descriptor 

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

func (*UpdateTaskDetailRequest) GetAnnotations 

func (m *UpdateTaskDetailRequest) GetAnnotations() *UpdateTaskDetailRequest_Annotations

func (*UpdateTaskDetailRequest) GetCallback 

func (m *UpdateTaskDetailRequest) GetCallback() *UpdateTaskDetailRequest_Callback

func (*UpdateTaskDetailRequest) GetCmdConfig 

func (m *UpdateTaskDetailRequest) GetCmdConfig() *UpdateTaskDetailRequest_CmdConfig

func (*UpdateTaskDetailRequest) GetDeleteAuthorizers 

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

func (*UpdateTaskDetailRequest) GetDisable 

func (m *UpdateTaskDetailRequest) GetDisable() int32

func (*UpdateTaskDetailRequest) GetError 

func (m *UpdateTaskDetailRequest) GetError() string

func (*UpdateTaskDetailRequest) GetInvisible 

func (m *UpdateTaskDetailRequest) GetInvisible() int32

func (*UpdateTaskDetailRequest) GetJobType 

func (m *UpdateTaskDetailRequest) GetJobType() string

func (*UpdateTaskDetailRequest) GetName 

func (m *UpdateTaskDetailRequest) GetName() string

func (*UpdateTaskDetailRequest) GetOperateAuthorizers 

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

func (*UpdateTaskDetailRequest) GetStatus 

func (m *UpdateTaskDetailRequest) GetStatus() int32

func (*UpdateTaskDetailRequest) GetTaskId 

func (m *UpdateTaskDetailRequest) GetTaskId() string

func (*UpdateTaskDetailRequest) GetTaskScheduler 

func (m *UpdateTaskDetailRequest) GetTaskScheduler() string

func (*UpdateTaskDetailRequest) GetTaskType 

func (m *UpdateTaskDetailRequest) GetTaskType() string

func (*UpdateTaskDetailRequest) GetUpdateAuthorizers 

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

func (*UpdateTaskDetailRequest) ProtoMessage 

func (*UpdateTaskDetailRequest) ProtoMessage()

func (*UpdateTaskDetailRequest) Reset 

func (m *UpdateTaskDetailRequest) Reset()

func (*UpdateTaskDetailRequest) String 

func (m *UpdateTaskDetailRequest) String() string

func (*UpdateTaskDetailRequest) Validate 

func (this *UpdateTaskDetailRequest) Validate() error

func (*UpdateTaskDetailRequest) XXX_DiscardUnknown 

func (m *UpdateTaskDetailRequest) XXX_DiscardUnknown()

func (*UpdateTaskDetailRequest) XXX_Marshal 

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

func (*UpdateTaskDetailRequest) XXX_Merge 

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

func (*UpdateTaskDetailRequest) XXX_Size 

func (m *UpdateTaskDetailRequest) XXX_Size() int

func (*UpdateTaskDetailRequest) XXX_Unmarshal 

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

type UpdateTaskDetailRequest_Annotations 

type UpdateTaskDetailRequest_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 (*UpdateTaskDetailRequest_Annotations) Descriptor 

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

func (*UpdateTaskDetailRequest_Annotations) GetAppId 

func (m *UpdateTaskDetailRequest_Annotations) GetAppId() string

func (*UpdateTaskDetailRequest_Annotations) ProtoMessage 

func (*UpdateTaskDetailRequest_Annotations) ProtoMessage()

func (*UpdateTaskDetailRequest_Annotations) Reset 

func (m *UpdateTaskDetailRequest_Annotations) Reset()

func (*UpdateTaskDetailRequest_Annotations) String 

func (m *UpdateTaskDetailRequest_Annotations) String() string

func (*UpdateTaskDetailRequest_Annotations) Validate 

func (this *UpdateTaskDetailRequest_Annotations) Validate() error

func (*UpdateTaskDetailRequest_Annotations) XXX_DiscardUnknown 

func (m *UpdateTaskDetailRequest_Annotations) XXX_DiscardUnknown()

func (*UpdateTaskDetailRequest_Annotations) XXX_Marshal 

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

func (*UpdateTaskDetailRequest_Annotations) XXX_Merge 

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

func (*UpdateTaskDetailRequest_Annotations) XXX_Size 

func (m *UpdateTaskDetailRequest_Annotations) XXX_Size() int

func (*UpdateTaskDetailRequest_Annotations) XXX_Unmarshal 

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

type UpdateTaskDetailRequest_Callback 

type UpdateTaskDetailRequest_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 (*UpdateTaskDetailRequest_Callback) Descriptor 

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

func (*UpdateTaskDetailRequest_Callback) GetEnsName 

func (m *UpdateTaskDetailRequest_Callback) GetEnsName() string

func (*UpdateTaskDetailRequest_Callback) GetHost 

func (m *UpdateTaskDetailRequest_Callback) GetHost() string

func (*UpdateTaskDetailRequest_Callback) GetUrl 

func (m *UpdateTaskDetailRequest_Callback) GetUrl() string

func (*UpdateTaskDetailRequest_Callback) ProtoMessage 

func (*UpdateTaskDetailRequest_Callback) ProtoMessage()

func (*UpdateTaskDetailRequest_Callback) Reset 

func (m *UpdateTaskDetailRequest_Callback) Reset()

func (*UpdateTaskDetailRequest_Callback) String 

func (m *UpdateTaskDetailRequest_Callback) String() string

func (*UpdateTaskDetailRequest_Callback) Validate 

func (this *UpdateTaskDetailRequest_Callback) Validate() error

func (*UpdateTaskDetailRequest_Callback) XXX_DiscardUnknown 

func (m *UpdateTaskDetailRequest_Callback) XXX_DiscardUnknown()

func (*UpdateTaskDetailRequest_Callback) XXX_Marshal 

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

func (*UpdateTaskDetailRequest_Callback) XXX_Merge 

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

func (*UpdateTaskDetailRequest_Callback) XXX_Size 

func (m *UpdateTaskDetailRequest_Callback) XXX_Size() int

func (*UpdateTaskDetailRequest_Callback) XXX_Unmarshal 

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

type UpdateTaskDetailRequest_CmdConfig 

type UpdateTaskDetailRequest_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 (*UpdateTaskDetailRequest_CmdConfig) Descriptor 

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

func (*UpdateTaskDetailRequest_CmdConfig) GetHeaders 

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

func (*UpdateTaskDetailRequest_CmdConfig) GetHost 

func (m *UpdateTaskDetailRequest_CmdConfig) GetHost() string

func (*UpdateTaskDetailRequest_CmdConfig) GetMethod 

func (m *UpdateTaskDetailRequest_CmdConfig) GetMethod() string

func (*UpdateTaskDetailRequest_CmdConfig) GetParams 

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

func (*UpdateTaskDetailRequest_CmdConfig) GetPort 

func (m *UpdateTaskDetailRequest_CmdConfig) GetPort() int32

func (*UpdateTaskDetailRequest_CmdConfig) GetServiceName 

func (m *UpdateTaskDetailRequest_CmdConfig) GetServiceName() string

func (*UpdateTaskDetailRequest_CmdConfig) GetUrl 

func (m *UpdateTaskDetailRequest_CmdConfig) GetUrl() string

func (*UpdateTaskDetailRequest_CmdConfig) ProtoMessage 

func (*UpdateTaskDetailRequest_CmdConfig) ProtoMessage()

func (*UpdateTaskDetailRequest_CmdConfig) Reset 

func (m *UpdateTaskDetailRequest_CmdConfig) Reset()

func (*UpdateTaskDetailRequest_CmdConfig) String 

func (m *UpdateTaskDetailRequest_CmdConfig) String() string

func (*UpdateTaskDetailRequest_CmdConfig) Validate 

func (this *UpdateTaskDetailRequest_CmdConfig) Validate() error

func (*UpdateTaskDetailRequest_CmdConfig) XXX_DiscardUnknown 

func (m *UpdateTaskDetailRequest_CmdConfig) XXX_DiscardUnknown()

func (*UpdateTaskDetailRequest_CmdConfig) XXX_Marshal 

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

func (*UpdateTaskDetailRequest_CmdConfig) XXX_Merge 

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

func (*UpdateTaskDetailRequest_CmdConfig) XXX_Size 

func (m *UpdateTaskDetailRequest_CmdConfig) XXX_Size() int

func (*UpdateTaskDetailRequest_CmdConfig) XXX_Unmarshal 

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

type UpdateTaskDetailResponse 

type UpdateTaskDetailResponse 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                 *UpdateTaskDetailResponse_Data `protobuf:"bytes,3,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

UpdateTaskDetail返回

func (*UpdateTaskDetailResponse) Descriptor 

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

func (*UpdateTaskDetailResponse) GetCode 

func (m *UpdateTaskDetailResponse) GetCode() int32

func (*UpdateTaskDetailResponse) GetData 

func (m *UpdateTaskDetailResponse) GetData() *UpdateTaskDetailResponse_Data

func (*UpdateTaskDetailResponse) GetMsg 

func (m *UpdateTaskDetailResponse) GetMsg() string

func (*UpdateTaskDetailResponse) ProtoMessage 

func (*UpdateTaskDetailResponse) ProtoMessage()

func (*UpdateTaskDetailResponse) Reset 

func (m *UpdateTaskDetailResponse) Reset()

func (*UpdateTaskDetailResponse) String 

func (m *UpdateTaskDetailResponse) String() string

func (*UpdateTaskDetailResponse) Validate 

func (this *UpdateTaskDetailResponse) Validate() error

func (*UpdateTaskDetailResponse) XXX_DiscardUnknown 

func (m *UpdateTaskDetailResponse) XXX_DiscardUnknown()

func (*UpdateTaskDetailResponse) XXX_Marshal 

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

func (*UpdateTaskDetailResponse) XXX_Merge 

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

func (*UpdateTaskDetailResponse) XXX_Size 

func (m *UpdateTaskDetailResponse) XXX_Size() int

func (*UpdateTaskDetailResponse) XXX_Unmarshal 

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

type UpdateTaskDetailResponseWrapper 

type UpdateTaskDetailResponseWrapper 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                 *UpdateTaskDetailResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

UpdateTaskDetailApi返回

func (*UpdateTaskDetailResponseWrapper) Descriptor 

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

func (*UpdateTaskDetailResponseWrapper) GetCode 

func (m *UpdateTaskDetailResponseWrapper) GetCode() int32

func (*UpdateTaskDetailResponseWrapper) GetCodeExplain 

func (m *UpdateTaskDetailResponseWrapper) GetCodeExplain() string

func (*UpdateTaskDetailResponseWrapper) GetData 

func (m *UpdateTaskDetailResponseWrapper) GetData() *UpdateTaskDetailResponse

func (*UpdateTaskDetailResponseWrapper) GetError 

func (m *UpdateTaskDetailResponseWrapper) GetError() string

func (*UpdateTaskDetailResponseWrapper) ProtoMessage 

func (*UpdateTaskDetailResponseWrapper) ProtoMessage()

func (*UpdateTaskDetailResponseWrapper) Reset 

func (m *UpdateTaskDetailResponseWrapper) Reset()

func (*UpdateTaskDetailResponseWrapper) String 

func (m *UpdateTaskDetailResponseWrapper) String() string

func (*UpdateTaskDetailResponseWrapper) Validate 

func (this *UpdateTaskDetailResponseWrapper) Validate() error

func (*UpdateTaskDetailResponseWrapper) XXX_DiscardUnknown 

func (m *UpdateTaskDetailResponseWrapper) XXX_DiscardUnknown()

func (*UpdateTaskDetailResponseWrapper) XXX_Marshal 

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

func (*UpdateTaskDetailResponseWrapper) XXX_Merge 

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

func (*UpdateTaskDetailResponseWrapper) XXX_Size 

func (m *UpdateTaskDetailResponseWrapper) XXX_Size() int

func (*UpdateTaskDetailResponseWrapper) XXX_Unmarshal 

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

type UpdateTaskDetailResponse_Data 

type UpdateTaskDetailResponse_Data struct {
	//
	//修改成功的数目
	Count                int32    `protobuf:"varint,1,opt,name=count,proto3" json:"count" form:"count"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateTaskDetailResponse_Data) Descriptor 

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

func (*UpdateTaskDetailResponse_Data) GetCount 

func (m *UpdateTaskDetailResponse_Data) GetCount() int32

func (*UpdateTaskDetailResponse_Data) ProtoMessage 

func (*UpdateTaskDetailResponse_Data) ProtoMessage()

func (*UpdateTaskDetailResponse_Data) Reset 

func (m *UpdateTaskDetailResponse_Data) Reset()

func (*UpdateTaskDetailResponse_Data) String 

func (m *UpdateTaskDetailResponse_Data) String() string

func (*UpdateTaskDetailResponse_Data) Validate 

func (this *UpdateTaskDetailResponse_Data) Validate() error

func (*UpdateTaskDetailResponse_Data) XXX_DiscardUnknown 

func (m *UpdateTaskDetailResponse_Data) XXX_DiscardUnknown()

func (*UpdateTaskDetailResponse_Data) XXX_Marshal 

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

func (*UpdateTaskDetailResponse_Data) XXX_Merge 

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

func (*UpdateTaskDetailResponse_Data) XXX_Size 

func (m *UpdateTaskDetailResponse_Data) XXX_Size() int

func (*UpdateTaskDetailResponse_Data) XXX_Unmarshal 

func (m *UpdateTaskDetailResponse_Data) 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.