Documentation ¶
Index ¶
- Variables
- type ActionOnTaskRequest
- func (*ActionOnTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ActionOnTaskRequest) GetAction() *ActionParam
- func (x *ActionOnTaskRequest) GetTask() *Task
- func (x *ActionOnTaskRequest) GetToTusita() string
- func (*ActionOnTaskRequest) ProtoMessage()
- func (x *ActionOnTaskRequest) ProtoReflect() protoreflect.Message
- func (x *ActionOnTaskRequest) Reset()
- func (x *ActionOnTaskRequest) String() string
- type ActionOnTaskResponse
- func (*ActionOnTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ActionOnTaskResponse) GetTask() *Task
- func (*ActionOnTaskResponse) ProtoMessage()
- func (x *ActionOnTaskResponse) ProtoReflect() protoreflect.Message
- func (x *ActionOnTaskResponse) Reset()
- func (x *ActionOnTaskResponse) String() string
- type ActionParam
- func (*ActionParam) Descriptor() ([]byte, []int)deprecated
- func (x *ActionParam) GetIndex() uint64
- func (x *ActionParam) GetIndexes() []uint64
- func (x *ActionParam) GetType() enums.Dag_Graph_Action
- func (x *ActionParam) GetUserType() enums.Project_User_Type
- func (*ActionParam) ProtoMessage()
- func (x *ActionParam) ProtoReflect() protoreflect.Message
- func (x *ActionParam) Reset()
- func (x *ActionParam) String() string
- type GetStageOutputRequest
- func (*GetStageOutputRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetStageOutputRequest) GetInnerId() uint64
- func (x *GetStageOutputRequest) GetPartyId() string
- func (x *GetStageOutputRequest) GetStageId() uint64
- func (x *GetStageOutputRequest) GetToTusita() string
- func (*GetStageOutputRequest) ProtoMessage()
- func (x *GetStageOutputRequest) ProtoReflect() protoreflect.Message
- func (x *GetStageOutputRequest) Reset()
- func (x *GetStageOutputRequest) String() string
- type GetStageOutputResponse
- func (*GetStageOutputResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetStageOutputResponse) GetVtables() map[string]*vtable.Vtable
- func (*GetStageOutputResponse) ProtoMessage()
- func (x *GetStageOutputResponse) ProtoReflect() protoreflect.Message
- func (x *GetStageOutputResponse) Reset()
- func (x *GetStageOutputResponse) String() string
- type GetTasksRequest
- func (*GetTasksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTasksRequest) GetClientPartyId() string
- func (x *GetTasksRequest) GetCreateAfter() int64
- func (x *GetTasksRequest) GetCreateBefore() int64
- func (x *GetTasksRequest) GetCreator() string
- func (x *GetTasksRequest) GetForCopy() bool
- func (x *GetTasksRequest) GetFromPredict() bool
- func (x *GetTasksRequest) GetFuzzyText() string
- func (x *GetTasksRequest) GetMajorVersion() uint64
- func (x *GetTasksRequest) GetMinorVersion() uint64
- func (x *GetTasksRequest) GetNoVersionInfo() bool
- func (x *GetTasksRequest) GetOwnerPartyId() string
- func (x *GetTasksRequest) GetOwnerUserIds() []uint64
- func (x *GetTasksRequest) GetPaginator() *paginator.Paginator
- func (x *GetTasksRequest) GetPriority() uint32
- func (x *GetTasksRequest) GetProjectId() uint64
- func (x *GetTasksRequest) GetStatus() enums.Task_Status
- func (x *GetTasksRequest) GetStatusIn() []uint64
- func (x *GetTasksRequest) GetTaskId() uint64
- func (x *GetTasksRequest) GetTaskIds() []uint64
- func (x *GetTasksRequest) GetToTusita() string
- func (x *GetTasksRequest) GetType() enums.Job_Type
- func (x *GetTasksRequest) GetWithHidden() bool
- func (x *GetTasksRequest) GetWithJobConfig() bool
- func (x *GetTasksRequest) GetWithLatestConfig() bool
- func (x *GetTasksRequest) GetWithProgress() bool
- func (x *GetTasksRequest) GetWithTaskRun() bool
- func (*GetTasksRequest) ProtoMessage()
- func (x *GetTasksRequest) ProtoReflect() protoreflect.Message
- func (x *GetTasksRequest) Reset()
- func (x *GetTasksRequest) String() string
- type GetTasksResponse
- func (*GetTasksResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTasksResponse) GetData() []*TaskResponse
- func (x *GetTasksResponse) GetTotal() int64
- func (*GetTasksResponse) ProtoMessage()
- func (x *GetTasksResponse) ProtoReflect() protoreflect.Message
- func (x *GetTasksResponse) Reset()
- func (x *GetTasksResponse) String() string
- type Graph
- type JobProgress
- func (*JobProgress) Descriptor() ([]byte, []int)deprecated
- func (x *JobProgress) GetCategory() protobuf.UpdateProgressRequest_Category
- func (x *JobProgress) GetInnerId() uint64
- func (x *JobProgress) GetMsg() string
- func (x *JobProgress) GetPartyId() string
- func (x *JobProgress) GetTs() int64
- func (*JobProgress) ProtoMessage()
- func (x *JobProgress) ProtoReflect() protoreflect.Message
- func (x *JobProgress) Reset()
- func (x *JobProgress) String() string
- type RequestItem
- func (*RequestItem) Descriptor() ([]byte, []int)deprecated
- func (x *RequestItem) GetUnit() enums.Resource_Unit
- func (x *RequestItem) GetValue() uint64
- func (*RequestItem) ProtoMessage()
- func (x *RequestItem) ProtoReflect() protoreflect.Message
- func (x *RequestItem) Reset()
- func (x *RequestItem) String() string
- type Resource
- type ResourceRequest
- func (*ResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceRequest) GetMode() enums.Resource_RequestMode
- func (x *ResourceRequest) GetResource() *Resource
- func (*ResourceRequest) ProtoMessage()
- func (x *ResourceRequest) ProtoReflect() protoreflect.Message
- func (x *ResourceRequest) Reset()
- func (x *ResourceRequest) String() string
- type SiteConfig
- func (*SiteConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SiteConfig) GetInputs() map[string]*infra_adapter.FurnaceProperty
- func (x *SiteConfig) GetOutputs() map[string]*infra_adapter.FurnaceProperty
- func (x *SiteConfig) GetParams() map[string]*structpb.Value
- func (x *SiteConfig) GetPartyId() string
- func (x *SiteConfig) GetResourceRequest() *ResourceRequest
- func (*SiteConfig) ProtoMessage()
- func (x *SiteConfig) ProtoReflect() protoreflect.Message
- func (x *SiteConfig) Reset()
- func (x *SiteConfig) String() string
- type Stage
- func (*Stage) Descriptor() ([]byte, []int)deprecated
- func (x *Stage) GetConfig() *StageParams
- func (x *Stage) GetDependencies() []uint64
- func (x *Stage) GetEndTs() int64
- func (x *Stage) GetHistoryProgress() map[uint64]*structpb.ListValue
- func (x *Stage) GetIndex() uint64
- func (x *Stage) GetJobId() uint64
- func (x *Stage) GetLeft() float32
- func (x *Stage) GetProgress() []*JobProgress
- func (x *Stage) GetStageName() string
- func (x *Stage) GetStageType() enums.Stage_Type
- func (x *Stage) GetStageTypeStr() string
- func (x *Stage) GetStartTs() int64
- func (x *Stage) GetStatus() enums.Dag_Job_Status
- func (x *Stage) GetTaskId() uint64
- func (x *Stage) GetTop() float32
- func (x *Stage) GetVersion() string
- func (*Stage) ProtoMessage()
- func (x *Stage) ProtoReflect() protoreflect.Message
- func (x *Stage) Reset()
- func (x *Stage) String() string
- type StageParams
- func (*StageParams) Descriptor() ([]byte, []int)deprecated
- func (x *StageParams) GetClientConfig() *SiteConfig
- func (x *StageParams) GetServerConfigs() []*SiteConfig
- func (x *StageParams) GetSharedParams() map[string]*structpb.Value
- func (*StageParams) ProtoMessage()
- func (x *StageParams) ProtoReflect() protoreflect.Message
- func (x *StageParams) Reset()
- func (x *StageParams) String() string
- type Task
- func (*Task) Descriptor() ([]byte, []int)deprecated
- func (x *Task) GetBeHidden() bool
- func (x *Task) GetComputeMode() enums.Job_ComputeMode
- func (x *Task) GetCreatedTs() int64
- func (x *Task) GetDescription() string
- func (x *Task) GetEndTs() int64
- func (x *Task) GetGraph() *Graph
- func (x *Task) GetHiddenTs() int64
- func (x *Task) GetHiddenUserId() uint64
- func (x *Task) GetMaxIndex() uint64
- func (x *Task) GetName() string
- func (x *Task) GetOwnerParty() string
- func (x *Task) GetOwnerUserId() uint64
- func (x *Task) GetPriority() uint32
- func (x *Task) GetProjectId() uint64
- func (x *Task) GetProjectIdStr() string
- func (x *Task) GetResourceRequest() *ResourceRequest
- func (x *Task) GetStages() []*Stage
- func (x *Task) GetStatus() enums.Task_Status
- func (x *Task) GetSubmittedTs() int64
- func (x *Task) GetTaskId() uint64
- func (x *Task) GetTaskIdStr() string
- func (x *Task) GetType() enums.Job_Type
- func (x *Task) GetUpdatedTs() int64
- func (*Task) ProtoMessage()
- func (x *Task) ProtoReflect() protoreflect.Message
- func (x *Task) Reset()
- func (x *Task) String() string
- type TaskResponse
- func (*TaskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TaskResponse) GetBase() *Task
- func (x *TaskResponse) GetOwnerUser() *user.UserBase
- func (*TaskResponse) ProtoMessage()
- func (x *TaskResponse) ProtoReflect() protoreflect.Message
- func (x *TaskResponse) Reset()
- func (x *TaskResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var File_sudo_mpc_virtual_service_platform_task_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type ActionOnTaskRequest ¶ added in v2.2.0
type ActionOnTaskRequest struct { Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` Action *ActionParam `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"` // 请求会转发到的中心节点ID // 若非空,则覆盖grpc metadata中设置的to-tusita ToTusita string `protobuf:"bytes,3,opt,name=to_tusita,json=toTusita,proto3" json:"to_tusita,omitempty"` // contains filtered or unexported fields }
func (*ActionOnTaskRequest) Descriptor
deprecated
added in
v2.2.0
func (*ActionOnTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use ActionOnTaskRequest.ProtoReflect.Descriptor instead.
func (*ActionOnTaskRequest) GetAction ¶ added in v2.2.0
func (x *ActionOnTaskRequest) GetAction() *ActionParam
func (*ActionOnTaskRequest) GetTask ¶ added in v2.2.0
func (x *ActionOnTaskRequest) GetTask() *Task
func (*ActionOnTaskRequest) GetToTusita ¶ added in v2.2.0
func (x *ActionOnTaskRequest) GetToTusita() string
func (*ActionOnTaskRequest) ProtoMessage ¶ added in v2.2.0
func (*ActionOnTaskRequest) ProtoMessage()
func (*ActionOnTaskRequest) ProtoReflect ¶ added in v2.2.0
func (x *ActionOnTaskRequest) ProtoReflect() protoreflect.Message
func (*ActionOnTaskRequest) Reset ¶ added in v2.2.0
func (x *ActionOnTaskRequest) Reset()
func (*ActionOnTaskRequest) String ¶ added in v2.2.0
func (x *ActionOnTaskRequest) String() string
type ActionOnTaskResponse ¶ added in v2.2.0
type ActionOnTaskResponse struct { Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` // contains filtered or unexported fields }
func (*ActionOnTaskResponse) Descriptor
deprecated
added in
v2.2.0
func (*ActionOnTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use ActionOnTaskResponse.ProtoReflect.Descriptor instead.
func (*ActionOnTaskResponse) GetTask ¶ added in v2.2.0
func (x *ActionOnTaskResponse) GetTask() *Task
func (*ActionOnTaskResponse) ProtoMessage ¶ added in v2.2.0
func (*ActionOnTaskResponse) ProtoMessage()
func (*ActionOnTaskResponse) ProtoReflect ¶ added in v2.2.0
func (x *ActionOnTaskResponse) ProtoReflect() protoreflect.Message
func (*ActionOnTaskResponse) Reset ¶ added in v2.2.0
func (x *ActionOnTaskResponse) Reset()
func (*ActionOnTaskResponse) String ¶ added in v2.2.0
func (x *ActionOnTaskResponse) String() string
type ActionParam ¶ added in v2.2.0
type ActionParam struct { Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` Indexes []uint64 `protobuf:"varint,2,rep,packed,name=indexes,proto3" json:"indexes,omitempty"` Type enums.Dag_Graph_Action `protobuf:"varint,3,opt,name=type,proto3,enum=sudo.protobuf.enums.Dag_Graph_Action" json:"type,omitempty"` UserType enums.Project_User_Type `` /* 129-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ActionParam) Descriptor
deprecated
added in
v2.2.0
func (*ActionParam) Descriptor() ([]byte, []int)
Deprecated: Use ActionParam.ProtoReflect.Descriptor instead.
func (*ActionParam) GetIndex ¶ added in v2.2.0
func (x *ActionParam) GetIndex() uint64
func (*ActionParam) GetIndexes ¶ added in v2.2.0
func (x *ActionParam) GetIndexes() []uint64
func (*ActionParam) GetType ¶ added in v2.2.0
func (x *ActionParam) GetType() enums.Dag_Graph_Action
func (*ActionParam) GetUserType ¶ added in v2.2.0
func (x *ActionParam) GetUserType() enums.Project_User_Type
func (*ActionParam) ProtoMessage ¶ added in v2.2.0
func (*ActionParam) ProtoMessage()
func (*ActionParam) ProtoReflect ¶ added in v2.2.0
func (x *ActionParam) ProtoReflect() protoreflect.Message
func (*ActionParam) Reset ¶ added in v2.2.0
func (x *ActionParam) Reset()
func (*ActionParam) String ¶ added in v2.2.0
func (x *ActionParam) String() string
type GetStageOutputRequest ¶ added in v2.2.0
type GetStageOutputRequest struct { StageId uint64 `protobuf:"varint,1,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"` PartyId string `protobuf:"bytes,2,opt,name=party_id,json=partyId,proto3" json:"party_id,omitempty"` InnerId uint64 `protobuf:"varint,3,opt,name=inner_id,json=innerId,proto3" json:"inner_id,omitempty"` // 请求会转发到的中心节点ID // 若非空,则覆盖grpc metadata中设置的to-tusita ToTusita string `protobuf:"bytes,4,opt,name=to_tusita,json=toTusita,proto3" json:"to_tusita,omitempty"` // contains filtered or unexported fields }
func (*GetStageOutputRequest) Descriptor
deprecated
added in
v2.2.0
func (*GetStageOutputRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetStageOutputRequest.ProtoReflect.Descriptor instead.
func (*GetStageOutputRequest) GetInnerId ¶ added in v2.2.0
func (x *GetStageOutputRequest) GetInnerId() uint64
func (*GetStageOutputRequest) GetPartyId ¶ added in v2.2.0
func (x *GetStageOutputRequest) GetPartyId() string
func (*GetStageOutputRequest) GetStageId ¶ added in v2.2.0
func (x *GetStageOutputRequest) GetStageId() uint64
func (*GetStageOutputRequest) GetToTusita ¶ added in v2.2.0
func (x *GetStageOutputRequest) GetToTusita() string
func (*GetStageOutputRequest) ProtoMessage ¶ added in v2.2.0
func (*GetStageOutputRequest) ProtoMessage()
func (*GetStageOutputRequest) ProtoReflect ¶ added in v2.2.0
func (x *GetStageOutputRequest) ProtoReflect() protoreflect.Message
func (*GetStageOutputRequest) Reset ¶ added in v2.2.0
func (x *GetStageOutputRequest) Reset()
func (*GetStageOutputRequest) String ¶ added in v2.2.0
func (x *GetStageOutputRequest) String() string
type GetStageOutputResponse ¶ added in v2.2.0
type GetStageOutputResponse struct { Vtables map[string]*vtable.Vtable `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetStageOutputResponse) Descriptor
deprecated
added in
v2.2.0
func (*GetStageOutputResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetStageOutputResponse.ProtoReflect.Descriptor instead.
func (*GetStageOutputResponse) GetVtables ¶ added in v2.2.0
func (x *GetStageOutputResponse) GetVtables() map[string]*vtable.Vtable
func (*GetStageOutputResponse) ProtoMessage ¶ added in v2.2.0
func (*GetStageOutputResponse) ProtoMessage()
func (*GetStageOutputResponse) ProtoReflect ¶ added in v2.2.0
func (x *GetStageOutputResponse) ProtoReflect() protoreflect.Message
func (*GetStageOutputResponse) Reset ¶ added in v2.2.0
func (x *GetStageOutputResponse) Reset()
func (*GetStageOutputResponse) String ¶ added in v2.2.0
func (x *GetStageOutputResponse) String() string
type GetTasksRequest ¶
type GetTasksRequest struct { Paginator *paginator.Paginator `protobuf:"bytes,1,opt,name=paginator,proto3" json:"paginator,omitempty"` TaskId uint64 `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` TaskIds []uint64 `protobuf:"varint,3,rep,packed,name=task_ids,json=taskIds,proto3" json:"task_ids,omitempty"` ProjectId uint64 `protobuf:"varint,4,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` WithLatestConfig bool `protobuf:"varint,5,opt,name=with_latest_config,json=withLatestConfig,proto3" json:"with_latest_config,omitempty"` WithTaskRun bool `protobuf:"varint,6,opt,name=with_task_run,json=withTaskRun,proto3" json:"with_task_run,omitempty"` WithJobConfig bool `protobuf:"varint,7,opt,name=with_job_config,json=withJobConfig,proto3" json:"with_job_config,omitempty"` WithProgress bool `protobuf:"varint,8,opt,name=with_progress,json=withProgress,proto3" json:"with_progress,omitempty"` ForCopy bool `protobuf:"varint,9,opt,name=for_copy,json=forCopy,proto3" json:"for_copy,omitempty"` WithHidden bool `protobuf:"varint,10,opt,name=with_hidden,json=withHidden,proto3" json:"with_hidden,omitempty"` NoVersionInfo bool `protobuf:"varint,11,opt,name=no_version_info,json=noVersionInfo,proto3" json:"no_version_info,omitempty"` // UI Filter options Status enums.Task_Status `protobuf:"varint,12,opt,name=status,proto3,enum=sudo.protobuf.enums.Task_Status" json:"status,omitempty"` StatusIn []uint64 `protobuf:"varint,13,rep,packed,name=status_in,json=statusIn,proto3" json:"status_in,omitempty"` Priority uint32 `protobuf:"varint,14,opt,name=priority,proto3" json:"priority,omitempty"` Type enums.Job_Type `protobuf:"varint,15,opt,name=type,proto3,enum=sudo.protobuf.enums.Job_Type" json:"type,omitempty"` CreateAfter int64 `protobuf:"varint,16,opt,name=create_after,json=createAfter,proto3" json:"create_after,omitempty"` CreateBefore int64 `protobuf:"varint,17,opt,name=create_before,json=createBefore,proto3" json:"create_before,omitempty"` OwnerPartyId string `protobuf:"bytes,18,opt,name=owner_party_id,json=ownerPartyId,proto3" json:"owner_party_id,omitempty"` OwnerUserIds []uint64 `protobuf:"varint,19,rep,packed,name=owner_user_ids,json=ownerUserIds,proto3" json:"owner_user_ids,omitempty"` FuzzyText string `protobuf:"bytes,20,opt,name=fuzzy_text,json=fuzzyText,proto3" json:"fuzzy_text,omitempty"` FromPredict bool `protobuf:"varint,21,opt,name=from_predict,json=fromPredict,proto3" json:"from_predict,omitempty"` MajorVersion uint64 `protobuf:"varint,22,opt,name=major_version,json=majorVersion,proto3" json:"major_version,omitempty"` MinorVersion uint64 `protobuf:"varint,23,opt,name=minor_version,json=minorVersion,proto3" json:"minor_version,omitempty"` ClientPartyId string `protobuf:"bytes,24,opt,name=client_party_id,json=clientPartyId,proto3" json:"client_party_id,omitempty"` Creator string `protobuf:"bytes,25,opt,name=creator,proto3" json:"creator,omitempty"` // 请求会转发到的中心节点ID // 若非空,则覆盖grpc metadata中设置的to-tusita ToTusita string `protobuf:"bytes,26,opt,name=to_tusita,json=toTusita,proto3" json:"to_tusita,omitempty"` // contains filtered or unexported fields }
func (*GetTasksRequest) Descriptor
deprecated
func (*GetTasksRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTasksRequest.ProtoReflect.Descriptor instead.
func (*GetTasksRequest) GetClientPartyId ¶
func (x *GetTasksRequest) GetClientPartyId() string
func (*GetTasksRequest) GetCreateAfter ¶
func (x *GetTasksRequest) GetCreateAfter() int64
func (*GetTasksRequest) GetCreateBefore ¶
func (x *GetTasksRequest) GetCreateBefore() int64
func (*GetTasksRequest) GetCreator ¶
func (x *GetTasksRequest) GetCreator() string
func (*GetTasksRequest) GetForCopy ¶
func (x *GetTasksRequest) GetForCopy() bool
func (*GetTasksRequest) GetFromPredict ¶
func (x *GetTasksRequest) GetFromPredict() bool
func (*GetTasksRequest) GetFuzzyText ¶
func (x *GetTasksRequest) GetFuzzyText() string
func (*GetTasksRequest) GetMajorVersion ¶
func (x *GetTasksRequest) GetMajorVersion() uint64
func (*GetTasksRequest) GetMinorVersion ¶
func (x *GetTasksRequest) GetMinorVersion() uint64
func (*GetTasksRequest) GetNoVersionInfo ¶
func (x *GetTasksRequest) GetNoVersionInfo() bool
func (*GetTasksRequest) GetOwnerPartyId ¶
func (x *GetTasksRequest) GetOwnerPartyId() string
func (*GetTasksRequest) GetOwnerUserIds ¶
func (x *GetTasksRequest) GetOwnerUserIds() []uint64
func (*GetTasksRequest) GetPaginator ¶
func (x *GetTasksRequest) GetPaginator() *paginator.Paginator
func (*GetTasksRequest) GetPriority ¶
func (x *GetTasksRequest) GetPriority() uint32
func (*GetTasksRequest) GetProjectId ¶
func (x *GetTasksRequest) GetProjectId() uint64
func (*GetTasksRequest) GetStatus ¶
func (x *GetTasksRequest) GetStatus() enums.Task_Status
func (*GetTasksRequest) GetStatusIn ¶
func (x *GetTasksRequest) GetStatusIn() []uint64
func (*GetTasksRequest) GetTaskId ¶
func (x *GetTasksRequest) GetTaskId() uint64
func (*GetTasksRequest) GetTaskIds ¶
func (x *GetTasksRequest) GetTaskIds() []uint64
func (*GetTasksRequest) GetToTusita ¶
func (x *GetTasksRequest) GetToTusita() string
func (*GetTasksRequest) GetType ¶
func (x *GetTasksRequest) GetType() enums.Job_Type
func (*GetTasksRequest) GetWithHidden ¶
func (x *GetTasksRequest) GetWithHidden() bool
func (*GetTasksRequest) GetWithJobConfig ¶
func (x *GetTasksRequest) GetWithJobConfig() bool
func (*GetTasksRequest) GetWithLatestConfig ¶
func (x *GetTasksRequest) GetWithLatestConfig() bool
func (*GetTasksRequest) GetWithProgress ¶
func (x *GetTasksRequest) GetWithProgress() bool
func (*GetTasksRequest) GetWithTaskRun ¶
func (x *GetTasksRequest) GetWithTaskRun() bool
func (*GetTasksRequest) ProtoMessage ¶
func (*GetTasksRequest) ProtoMessage()
func (*GetTasksRequest) ProtoReflect ¶
func (x *GetTasksRequest) ProtoReflect() protoreflect.Message
func (*GetTasksRequest) Reset ¶
func (x *GetTasksRequest) Reset()
func (*GetTasksRequest) String ¶
func (x *GetTasksRequest) String() string
type GetTasksResponse ¶
type GetTasksResponse struct { Data []*TaskResponse `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` Total int64 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"` // contains filtered or unexported fields }
func (*GetTasksResponse) Descriptor
deprecated
func (*GetTasksResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTasksResponse.ProtoReflect.Descriptor instead.
func (*GetTasksResponse) GetData ¶
func (x *GetTasksResponse) GetData() []*TaskResponse
func (*GetTasksResponse) GetTotal ¶
func (x *GetTasksResponse) GetTotal() int64
func (*GetTasksResponse) ProtoMessage ¶
func (*GetTasksResponse) ProtoMessage()
func (*GetTasksResponse) ProtoReflect ¶
func (x *GetTasksResponse) ProtoReflect() protoreflect.Message
func (*GetTasksResponse) Reset ¶
func (x *GetTasksResponse) Reset()
func (*GetTasksResponse) String ¶
func (x *GetTasksResponse) String() string
type Graph ¶
type Graph struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // TODO:add edit-version // # of times the graph has been executed TotalRun uint64 `protobuf:"varint,2,opt,name=total_run,json=totalRun,proto3" json:"total_run,omitempty"` Frozen bool `protobuf:"varint,3,opt,name=frozen,proto3" json:"frozen,omitempty"` // contains filtered or unexported fields }
func (*Graph) Descriptor
deprecated
func (*Graph) GetTotalRun ¶
func (*Graph) ProtoMessage ¶
func (*Graph) ProtoMessage()
func (*Graph) ProtoReflect ¶
func (x *Graph) ProtoReflect() protoreflect.Message
type JobProgress ¶
type JobProgress struct { Ts int64 `protobuf:"varint,1,opt,name=ts,proto3" json:"ts,omitempty"` InnerId uint64 `protobuf:"varint,2,opt,name=inner_id,json=innerId,proto3" json:"inner_id,omitempty"` PartyId string `protobuf:"bytes,3,opt,name=party_id,json=partyId,proto3" json:"party_id,omitempty"` Msg string `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"` Category protobuf.UpdateProgressRequest_Category `` /* 134-byte string literal not displayed */ // contains filtered or unexported fields }
func (*JobProgress) Descriptor
deprecated
func (*JobProgress) Descriptor() ([]byte, []int)
Deprecated: Use JobProgress.ProtoReflect.Descriptor instead.
func (*JobProgress) GetCategory ¶
func (x *JobProgress) GetCategory() protobuf.UpdateProgressRequest_Category
func (*JobProgress) GetInnerId ¶
func (x *JobProgress) GetInnerId() uint64
func (*JobProgress) GetMsg ¶
func (x *JobProgress) GetMsg() string
func (*JobProgress) GetPartyId ¶
func (x *JobProgress) GetPartyId() string
func (*JobProgress) GetTs ¶
func (x *JobProgress) GetTs() int64
func (*JobProgress) ProtoMessage ¶
func (*JobProgress) ProtoMessage()
func (*JobProgress) ProtoReflect ¶
func (x *JobProgress) ProtoReflect() protoreflect.Message
func (*JobProgress) Reset ¶
func (x *JobProgress) Reset()
func (*JobProgress) String ¶
func (x *JobProgress) String() string
type RequestItem ¶
type RequestItem struct { Value uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` Unit enums.Resource_Unit `protobuf:"varint,2,opt,name=unit,proto3,enum=sudo.protobuf.enums.Resource_Unit" json:"unit,omitempty"` // contains filtered or unexported fields }
func (*RequestItem) Descriptor
deprecated
func (*RequestItem) Descriptor() ([]byte, []int)
Deprecated: Use RequestItem.ProtoReflect.Descriptor instead.
func (*RequestItem) GetUnit ¶
func (x *RequestItem) GetUnit() enums.Resource_Unit
func (*RequestItem) GetValue ¶
func (x *RequestItem) GetValue() uint64
func (*RequestItem) ProtoMessage ¶
func (*RequestItem) ProtoMessage()
func (*RequestItem) ProtoReflect ¶
func (x *RequestItem) ProtoReflect() protoreflect.Message
func (*RequestItem) Reset ¶
func (x *RequestItem) Reset()
func (*RequestItem) String ¶
func (x *RequestItem) String() string
type Resource ¶
type Resource struct { Cpu *RequestItem `protobuf:"bytes,1,opt,name=cpu,proto3" json:"cpu,omitempty"` Memory *RequestItem `protobuf:"bytes,2,opt,name=memory,proto3" json:"memory,omitempty"` // contains filtered or unexported fields }
func (*Resource) Descriptor
deprecated
func (*Resource) GetCpu ¶
func (x *Resource) GetCpu() *RequestItem
func (*Resource) GetMemory ¶
func (x *Resource) GetMemory() *RequestItem
func (*Resource) ProtoMessage ¶
func (*Resource) ProtoMessage()
func (*Resource) ProtoReflect ¶
func (x *Resource) ProtoReflect() protoreflect.Message
type ResourceRequest ¶
type ResourceRequest struct { Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` Mode enums.Resource_RequestMode `protobuf:"varint,2,opt,name=mode,proto3,enum=sudo.protobuf.enums.Resource_RequestMode" json:"mode,omitempty"` // contains filtered or unexported fields }
func (*ResourceRequest) Descriptor
deprecated
func (*ResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResourceRequest.ProtoReflect.Descriptor instead.
func (*ResourceRequest) GetMode ¶
func (x *ResourceRequest) GetMode() enums.Resource_RequestMode
func (*ResourceRequest) GetResource ¶
func (x *ResourceRequest) GetResource() *Resource
func (*ResourceRequest) ProtoMessage ¶
func (*ResourceRequest) ProtoMessage()
func (*ResourceRequest) ProtoReflect ¶
func (x *ResourceRequest) ProtoReflect() protoreflect.Message
func (*ResourceRequest) Reset ¶
func (x *ResourceRequest) Reset()
func (*ResourceRequest) String ¶
func (x *ResourceRequest) String() string
type SiteConfig ¶
type SiteConfig struct { PartyId string `protobuf:"bytes,1,opt,name=party_id,json=partyId,proto3" json:"party_id,omitempty"` // OpParams Params map[string]*structpb.Value `` /* 153-byte string literal not displayed */ ResourceRequest *ResourceRequest `protobuf:"bytes,3,opt,name=resource_request,json=resourceRequest,proto3" json:"resource_request,omitempty"` Inputs map[string]*infra_adapter.FurnaceProperty `` /* 153-byte string literal not displayed */ Outputs map[string]*infra_adapter.FurnaceProperty `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*SiteConfig) Descriptor
deprecated
func (*SiteConfig) Descriptor() ([]byte, []int)
Deprecated: Use SiteConfig.ProtoReflect.Descriptor instead.
func (*SiteConfig) GetInputs ¶
func (x *SiteConfig) GetInputs() map[string]*infra_adapter.FurnaceProperty
func (*SiteConfig) GetOutputs ¶
func (x *SiteConfig) GetOutputs() map[string]*infra_adapter.FurnaceProperty
func (*SiteConfig) GetPartyId ¶
func (x *SiteConfig) GetPartyId() string
func (*SiteConfig) GetResourceRequest ¶
func (x *SiteConfig) GetResourceRequest() *ResourceRequest
func (*SiteConfig) ProtoMessage ¶
func (*SiteConfig) ProtoMessage()
func (*SiteConfig) ProtoReflect ¶
func (x *SiteConfig) ProtoReflect() protoreflect.Message
func (*SiteConfig) Reset ¶
func (x *SiteConfig) Reset()
func (*SiteConfig) String ¶
func (x *SiteConfig) String() string
type Stage ¶
type Stage struct { // filled when Task.DoAction TaskId uint64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // filled when GetTask, most likely be 0 in other cases,not persisted in config(because id is created when config is saved) JobId uint64 `protobuf:"varint,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` // generated by front end, should be unique in task Index uint64 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"` StageType enums.Stage_Type `protobuf:"varint,4,opt,name=stage_type,json=stageType,proto3,enum=sudo.protobuf.enums.Stage_Type" json:"stage_type,omitempty"` StageName string `protobuf:"bytes,5,opt,name=stage_name,json=stageName,proto3" json:"stage_name,omitempty"` Dependencies []uint64 `protobuf:"varint,6,rep,packed,name=dependencies,proto3" json:"dependencies,omitempty"` Status enums.Dag_Job_Status `protobuf:"varint,7,opt,name=status,proto3,enum=sudo.protobuf.enums.Dag_Job_Status" json:"status,omitempty"` Progress []*JobProgress `protobuf:"bytes,8,rep,name=progress,proto3" json:"progress,omitempty"` // execution history group by job id(latest 2 executions by default) // listValue中的保存的类型为JobProgress HistoryProgress map[uint64]*structpb.ListValue `` /* 195-byte string literal not displayed */ // stage location on canvas Top float32 `protobuf:"fixed32,10,opt,name=top,proto3" json:"top,omitempty"` Left float32 `protobuf:"fixed32,11,opt,name=left,proto3" json:"left,omitempty"` Config *StageParams `protobuf:"bytes,12,opt,name=config,proto3" json:"config,omitempty"` // 可能会修改的字段存到stage info里 StartTs int64 `protobuf:"varint,13,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"` EndTs int64 `protobuf:"varint,14,opt,name=end_ts,json=endTs,proto3" json:"end_ts,omitempty"` Version string `protobuf:"bytes,15,opt,name=version,proto3" json:"version,omitempty"` StageTypeStr string `protobuf:"bytes,16,opt,name=stage_type_str,json=stageTypeStr,proto3" json:"stage_type_str,omitempty"` // contains filtered or unexported fields }
func (*Stage) Descriptor
deprecated
func (*Stage) GetConfig ¶
func (x *Stage) GetConfig() *StageParams
func (*Stage) GetDependencies ¶
func (*Stage) GetHistoryProgress ¶
func (*Stage) GetProgress ¶
func (x *Stage) GetProgress() []*JobProgress
func (*Stage) GetStageName ¶
func (*Stage) GetStageType ¶
func (x *Stage) GetStageType() enums.Stage_Type
func (*Stage) GetStageTypeStr ¶
func (*Stage) GetStartTs ¶
func (*Stage) GetStatus ¶
func (x *Stage) GetStatus() enums.Dag_Job_Status
func (*Stage) GetVersion ¶
func (*Stage) ProtoMessage ¶
func (*Stage) ProtoMessage()
func (*Stage) ProtoReflect ¶
func (x *Stage) ProtoReflect() protoreflect.Message
type StageParams ¶
type StageParams struct { // OpParams ClientConfig *SiteConfig `protobuf:"bytes,2,opt,name=client_config,json=clientConfig,proto3" json:"client_config,omitempty"` ServerConfigs []*SiteConfig `protobuf:"bytes,3,rep,name=server_configs,json=serverConfigs,proto3" json:"server_configs,omitempty"` // contains filtered or unexported fields }
func (*StageParams) Descriptor
deprecated
func (*StageParams) Descriptor() ([]byte, []int)
Deprecated: Use StageParams.ProtoReflect.Descriptor instead.
func (*StageParams) GetClientConfig ¶
func (x *StageParams) GetClientConfig() *SiteConfig
func (*StageParams) GetServerConfigs ¶
func (x *StageParams) GetServerConfigs() []*SiteConfig
func (*StageParams) GetSharedParams ¶
func (x *StageParams) GetSharedParams() map[string]*structpb.Value
func (*StageParams) ProtoMessage ¶
func (*StageParams) ProtoMessage()
func (*StageParams) ProtoReflect ¶
func (x *StageParams) ProtoReflect() protoreflect.Message
func (*StageParams) Reset ¶
func (x *StageParams) Reset()
func (*StageParams) String ¶
func (x *StageParams) String() string
type Task ¶
type Task struct { // TODO: change this field to be private after refactoring. Graph *Graph `protobuf:"bytes,1,opt,name=graph,proto3" json:"graph,omitempty"` // TaskID // // 变更历史 // Phase-1 // 使用model.TaskModel(已被废弃),自增ID(未被使用),雪花TaskID(被当做"主键"使用) // // Phase-2 // 引入无限编辑,复用之前的表, 但是使用新的ORM描述. // 新的描述没有ID字段,有TaskID字段,TaskID字段创建的时候始终引用GraphID(GraphID本身为graph的自增主键) // // Phase-3 // 引入版本,TaskID需要与Graph ID解耦,与Phase-2相同,引用第一个graph的ID,不过在初次赋值后不再更改(db read only field) TaskId uint64 `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` ProjectId uint64 `protobuf:"varint,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"` Status enums.Task_Status `protobuf:"varint,6,opt,name=status,proto3,enum=sudo.protobuf.enums.Task_Status" json:"status,omitempty"` OwnerParty string `protobuf:"bytes,7,opt,name=owner_party,json=ownerParty,proto3" json:"owner_party,omitempty"` OwnerUserId uint64 `protobuf:"varint,8,opt,name=owner_user_id,json=ownerUserId,proto3" json:"owner_user_id,omitempty"` Type enums.Job_Type `protobuf:"varint,9,opt,name=type,proto3,enum=sudo.protobuf.enums.Job_Type" json:"type,omitempty"` Priority uint32 `protobuf:"varint,10,opt,name=priority,proto3" json:"priority,omitempty"` Stages []*Stage `protobuf:"bytes,11,rep,name=stages,proto3" json:"stages,omitempty"` CreatedTs int64 `protobuf:"varint,12,opt,name=created_ts,json=createdTs,proto3" json:"created_ts,omitempty"` UpdatedTs int64 `protobuf:"varint,13,opt,name=updated_ts,json=updatedTs,proto3" json:"updated_ts,omitempty"` SubmittedTs int64 `protobuf:"varint,14,opt,name=submitted_ts,json=submittedTs,proto3" json:"submitted_ts,omitempty"` HiddenTs int64 `protobuf:"varint,15,opt,name=hidden_ts,json=hiddenTs,proto3" json:"hidden_ts,omitempty"` EndTs int64 `protobuf:"varint,16,opt,name=end_ts,json=endTs,proto3" json:"end_ts,omitempty"` ComputeMode enums.Job_ComputeMode `` /* 137-byte string literal not displayed */ BeHidden bool `protobuf:"varint,18,opt,name=be_hidden,json=beHidden,proto3" json:"be_hidden,omitempty"` HiddenUserId uint64 `protobuf:"varint,19,opt,name=hidden_user_id,json=hiddenUserId,proto3" json:"hidden_user_id,omitempty"` MaxIndex uint64 `protobuf:"varint,20,opt,name=max_index,json=maxIndex,proto3" json:"max_index,omitempty"` ResourceRequest *ResourceRequest `protobuf:"bytes,21,opt,name=resource_request,json=resourceRequest,proto3" json:"resource_request,omitempty"` TaskIdStr string `protobuf:"bytes,22,opt,name=task_id_str,json=taskIdStr,proto3" json:"task_id_str,omitempty"` ProjectIdStr string `protobuf:"bytes,23,opt,name=project_id_str,json=projectIdStr,proto3" json:"project_id_str,omitempty"` // contains filtered or unexported fields }
func (*Task) Descriptor
deprecated
func (*Task) GetBeHidden ¶
func (*Task) GetComputeMode ¶
func (x *Task) GetComputeMode() enums.Job_ComputeMode
func (*Task) GetCreatedTs ¶
func (*Task) GetDescription ¶
func (*Task) GetHiddenTs ¶
func (*Task) GetHiddenUserId ¶
func (*Task) GetMaxIndex ¶
func (*Task) GetOwnerParty ¶
func (*Task) GetOwnerUserId ¶
func (*Task) GetPriority ¶
func (*Task) GetProjectId ¶
func (*Task) GetProjectIdStr ¶ added in v2.2.0
func (*Task) GetResourceRequest ¶
func (x *Task) GetResourceRequest() *ResourceRequest
func (*Task) GetStatus ¶
func (x *Task) GetStatus() enums.Task_Status
func (*Task) GetSubmittedTs ¶
func (*Task) GetTaskIdStr ¶ added in v2.2.0
func (*Task) GetUpdatedTs ¶
func (*Task) ProtoMessage ¶
func (*Task) ProtoMessage()
func (*Task) ProtoReflect ¶
func (x *Task) ProtoReflect() protoreflect.Message
type TaskResponse ¶
type TaskResponse struct { Base *Task `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"` OwnerUser *user.UserBase `protobuf:"bytes,2,opt,name=owner_user,json=ownerUser,proto3" json:"owner_user,omitempty"` // contains filtered or unexported fields }
func (*TaskResponse) Descriptor
deprecated
func (*TaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use TaskResponse.ProtoReflect.Descriptor instead.
func (*TaskResponse) GetBase ¶
func (x *TaskResponse) GetBase() *Task
func (*TaskResponse) GetOwnerUser ¶
func (x *TaskResponse) GetOwnerUser() *user.UserBase
func (*TaskResponse) ProtoMessage ¶
func (*TaskResponse) ProtoMessage()
func (*TaskResponse) ProtoReflect ¶
func (x *TaskResponse) ProtoReflect() protoreflect.Message
func (*TaskResponse) Reset ¶
func (x *TaskResponse) Reset()
func (*TaskResponse) String ¶
func (x *TaskResponse) String() string