task

package
v2.3.3 Latest Latest
Warning

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

 Go to latest Published: Mar 7, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_mpc_virtual_service_platform_task_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ActionOnTaskRequest added in v2.2.0 

type ActionOnTaskRequest struct {
	Base      *task.ActionOnTaskRequest `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	Schedules []*cron.Cron_Schedule     `protobuf:"bytes,2,rep,name=schedules,proto3" json:"schedules,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) GetBase added in v2.2.0 

func (x *ActionOnTaskRequest) GetBase() *task.ActionOnTaskRequest

func (*ActionOnTaskRequest) GetSchedules added in v2.2.0 

func (x *ActionOnTaskRequest) GetSchedules() []*cron.Cron_Schedule

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 AdditionalTaskInfo 

type AdditionalTaskInfo struct {
	AplId      uint64 `protobuf:"varint,1,opt,name=apl_id,json=aplId,proto3" json:"apl_id,omitempty"`
	Deprecated bool   `protobuf:"varint,2,opt,name=deprecated,proto3" json:"deprecated,omitempty"`
	// 当任务需要审核时，提供对应审核方
	Reviewers []*apl.Reviewer `protobuf:"bytes,3,rep,name=reviewers,proto3" json:"reviewers,omitempty"`
	// 审批日志，默认只返回callback出现异常的最后一条记录
	ApplicationLog *apl.CallbackLog `protobuf:"bytes,4,opt,name=application_log,json=applicationLog,proto3" json:"application_log,omitempty"`
	// type是"预测任务"时，返回父任务信息
	SourceTaskInfo *SourceTaskInfo `protobuf:"bytes,5,opt,name=source_task_info,json=sourceTaskInfo,proto3" json:"source_task_info,omitempty"`
	ClientPartyId  string          `protobuf:"bytes,6,opt,name=client_party_id,json=clientPartyId,proto3" json:"client_party_id,omitempty"`
	// 在线服务列表
	OnlineServices []*online_service.ServiceModel `protobuf:"bytes,7,rep,name=online_services,json=onlineServices,proto3" json:"online_services,omitempty"`
	// task versioning
	AutoTune     bool   `protobuf:"varint,8,opt,name=auto_tune,json=autoTune,proto3" json:"auto_tune,omitempty"`
	MajorVersion uint64 `protobuf:"varint,9,opt,name=major_version,json=majorVersion,proto3" json:"major_version,omitempty"`
	MinorVersion uint64 `protobuf:"varint,10,opt,name=minor_version,json=minorVersion,proto3" json:"minor_version,omitempty"`
	// cron task schedule
	Schedules []*cron.Cron_Schedule `protobuf:"bytes,11,rep,name=schedules,proto3" json:"schedules,omitempty"`
	// contains filtered or unexported fields
}

func (*AdditionalTaskInfo) Descriptor deprecated 

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

Deprecated: Use AdditionalTaskInfo.ProtoReflect.Descriptor instead.

func (*AdditionalTaskInfo) GetAplId 

func (x *AdditionalTaskInfo) GetAplId() uint64

func (*AdditionalTaskInfo) GetApplicationLog 

func (x *AdditionalTaskInfo) GetApplicationLog() *apl.CallbackLog

func (*AdditionalTaskInfo) GetAutoTune 

func (x *AdditionalTaskInfo) GetAutoTune() bool

func (*AdditionalTaskInfo) GetClientPartyId 

func (x *AdditionalTaskInfo) GetClientPartyId() string

func (*AdditionalTaskInfo) GetDeprecated 

func (x *AdditionalTaskInfo) GetDeprecated() bool

func (*AdditionalTaskInfo) GetMajorVersion 

func (x *AdditionalTaskInfo) GetMajorVersion() uint64

func (*AdditionalTaskInfo) GetMinorVersion 

func (x *AdditionalTaskInfo) GetMinorVersion() uint64

func (*AdditionalTaskInfo) GetOnlineServices 

func (x *AdditionalTaskInfo) GetOnlineServices() []*online_service.ServiceModel

func (*AdditionalTaskInfo) GetReviewers 

func (x *AdditionalTaskInfo) GetReviewers() []*apl.Reviewer

func (*AdditionalTaskInfo) GetSchedules 

func (x *AdditionalTaskInfo) GetSchedules() []*cron.Cron_Schedule

func (*AdditionalTaskInfo) GetSourceTaskInfo 

func (x *AdditionalTaskInfo) GetSourceTaskInfo() *SourceTaskInfo

func (*AdditionalTaskInfo) ProtoMessage 

func (*AdditionalTaskInfo) ProtoMessage()

func (*AdditionalTaskInfo) ProtoReflect 

func (x *AdditionalTaskInfo) ProtoReflect() protoreflect.Message

func (*AdditionalTaskInfo) Reset 

func (x *AdditionalTaskInfo) Reset()

func (*AdditionalTaskInfo) String 

func (x *AdditionalTaskInfo) String() string

type BaseTaskResponse 

type BaseTaskResponse struct {
	Base      *task.Task `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	OwnerUser *user.User `protobuf:"bytes,2,opt,name=owner_user,json=ownerUser,proto3" json:"owner_user,omitempty"`
	// contains filtered or unexported fields
}

func (*BaseTaskResponse) Descriptor deprecated 

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

Deprecated: Use BaseTaskResponse.ProtoReflect.Descriptor instead.

func (*BaseTaskResponse) GetBase 

func (x *BaseTaskResponse) GetBase() *task.Task

func (*BaseTaskResponse) GetOwnerUser 

func (x *BaseTaskResponse) GetOwnerUser() *user.User

func (*BaseTaskResponse) ProtoMessage 

func (*BaseTaskResponse) ProtoMessage()

func (*BaseTaskResponse) ProtoReflect 

func (x *BaseTaskResponse) ProtoReflect() protoreflect.Message

func (*BaseTaskResponse) Reset 

func (x *BaseTaskResponse) Reset()

func (*BaseTaskResponse) String 

func (x *BaseTaskResponse) String() string

type CPUUsage 

type CPUUsage struct {
	UsageSecondsTotal []*SamplePair `protobuf:"bytes,1,rep,name=usage_seconds_total,json=usageSecondsTotal,proto3" json:"usage_seconds_total,omitempty"`
	// contains filtered or unexported fields
}

func (*CPUUsage) Descriptor deprecated 

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

Deprecated: Use CPUUsage.ProtoReflect.Descriptor instead.

func (*CPUUsage) GetUsageSecondsTotal 

func (x *CPUUsage) GetUsageSecondsTotal() []*SamplePair

func (*CPUUsage) ProtoMessage 

func (*CPUUsage) ProtoMessage()

func (*CPUUsage) ProtoReflect 

func (x *CPUUsage) ProtoReflect() protoreflect.Message

func (*CPUUsage) Reset 

func (x *CPUUsage) Reset()

func (*CPUUsage) String 

func (x *CPUUsage) String() string

type GetStageDashboardRequest 

type GetStageDashboardRequest struct {
	StageId      uint64   `protobuf:"varint,1,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	ExcludeParty []string `protobuf:"bytes,2,rep,name=exclude_party,json=excludeParty,proto3" json:"exclude_party,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStageDashboardRequest) Descriptor deprecated 

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

Deprecated: Use GetStageDashboardRequest.ProtoReflect.Descriptor instead.

func (*GetStageDashboardRequest) GetExcludeParty 

func (x *GetStageDashboardRequest) GetExcludeParty() []string

func (*GetStageDashboardRequest) GetStageId 

func (x *GetStageDashboardRequest) GetStageId() uint64

func (*GetStageDashboardRequest) ProtoMessage 

func (*GetStageDashboardRequest) ProtoMessage()

func (*GetStageDashboardRequest) ProtoReflect 

func (x *GetStageDashboardRequest) ProtoReflect() protoreflect.Message

func (*GetStageDashboardRequest) Reset 

func (x *GetStageDashboardRequest) Reset()

func (*GetStageDashboardRequest) String 

func (x *GetStageDashboardRequest) String() string

type GetStageDashboardResponse 

type GetStageDashboardResponse struct {
	Dashboards map[string]*PartyStageDashboard `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetStageDashboardResponse) Descriptor deprecated 

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

Deprecated: Use GetStageDashboardResponse.ProtoReflect.Descriptor instead.

func (*GetStageDashboardResponse) GetDashboards 

func (x *GetStageDashboardResponse) GetDashboards() map[string]*PartyStageDashboard

func (*GetStageDashboardResponse) ProtoMessage 

func (*GetStageDashboardResponse) ProtoMessage()

func (*GetStageDashboardResponse) ProtoReflect 

func (x *GetStageDashboardResponse) ProtoReflect() protoreflect.Message

func (*GetStageDashboardResponse) Reset 

func (x *GetStageDashboardResponse) Reset()

func (*GetStageDashboardResponse) String 

func (x *GetStageDashboardResponse) 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 Matrix 

type Matrix struct {
	Values []*SampleStream `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*Matrix) Descriptor deprecated 

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

Deprecated: Use Matrix.ProtoReflect.Descriptor instead.

func (*Matrix) GetValues 

func (x *Matrix) GetValues() []*SampleStream

func (*Matrix) ProtoMessage 

func (*Matrix) ProtoMessage()

func (*Matrix) ProtoReflect 

func (x *Matrix) ProtoReflect() protoreflect.Message

func (*Matrix) Reset 

func (x *Matrix) Reset()

func (*Matrix) String 

func (x *Matrix) String() string

type MemoryUsage 

type MemoryUsage struct {
	Total      uint64  `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Used       uint64  `protobuf:"varint,2,opt,name=used,proto3" json:"used,omitempty"`
	UsageBytes *Matrix `protobuf:"bytes,3,opt,name=usage_bytes,json=usageBytes,proto3" json:"usage_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*MemoryUsage) Descriptor deprecated 

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

Deprecated: Use MemoryUsage.ProtoReflect.Descriptor instead.

func (*MemoryUsage) GetTotal 

func (x *MemoryUsage) GetTotal() uint64

func (*MemoryUsage) GetUsageBytes 

func (x *MemoryUsage) GetUsageBytes() *Matrix

func (*MemoryUsage) GetUsed 

func (x *MemoryUsage) GetUsed() uint64

func (*MemoryUsage) ProtoMessage 

func (*MemoryUsage) ProtoMessage()

func (*MemoryUsage) ProtoReflect 

func (x *MemoryUsage) ProtoReflect() protoreflect.Message

func (*MemoryUsage) Reset 

func (x *MemoryUsage) Reset()

func (*MemoryUsage) String 

func (x *MemoryUsage) String() string

type NetworkUsage 

type NetworkUsage struct {
	ReceiveBytesTotal  []*SamplePair `protobuf:"bytes,1,rep,name=receive_bytes_total,json=receiveBytesTotal,proto3" json:"receive_bytes_total,omitempty"`
	TransmitBytesTotal []*SamplePair `protobuf:"bytes,2,rep,name=transmit_bytes_total,json=transmitBytesTotal,proto3" json:"transmit_bytes_total,omitempty"`
	// contains filtered or unexported fields
}

func (*NetworkUsage) Descriptor deprecated 

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

Deprecated: Use NetworkUsage.ProtoReflect.Descriptor instead.

func (*NetworkUsage) GetReceiveBytesTotal 

func (x *NetworkUsage) GetReceiveBytesTotal() []*SamplePair

func (*NetworkUsage) GetTransmitBytesTotal 

func (x *NetworkUsage) GetTransmitBytesTotal() []*SamplePair

func (*NetworkUsage) ProtoMessage 

func (*NetworkUsage) ProtoMessage()

func (*NetworkUsage) ProtoReflect 

func (x *NetworkUsage) ProtoReflect() protoreflect.Message

func (*NetworkUsage) Reset 

func (x *NetworkUsage) Reset()

func (*NetworkUsage) String 

func (x *NetworkUsage) String() string

type PartyStageDashboard 

type PartyStageDashboard struct {
	Cpus     map[string]*CPUUsage     `` /* 149-byte string literal not displayed */
	Mems     map[string]*MemoryUsage  `` /* 149-byte string literal not displayed */
	Networks map[string]*NetworkUsage `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PartyStageDashboard) Descriptor deprecated 

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

Deprecated: Use PartyStageDashboard.ProtoReflect.Descriptor instead.

func (*PartyStageDashboard) GetCpus 

func (x *PartyStageDashboard) GetCpus() map[string]*CPUUsage

func (*PartyStageDashboard) GetMems 

func (x *PartyStageDashboard) GetMems() map[string]*MemoryUsage

func (*PartyStageDashboard) GetNetworks 

func (x *PartyStageDashboard) GetNetworks() map[string]*NetworkUsage

func (*PartyStageDashboard) ProtoMessage 

func (*PartyStageDashboard) ProtoMessage()

func (*PartyStageDashboard) ProtoReflect 

func (x *PartyStageDashboard) ProtoReflect() protoreflect.Message

func (*PartyStageDashboard) Reset 

func (x *PartyStageDashboard) Reset()

func (*PartyStageDashboard) String 

func (x *PartyStageDashboard) String() string

type SamplePair 

type SamplePair struct {
	Timestamp int64   `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     float32 `protobuf:"fixed32,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SamplePair) Descriptor deprecated 

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

Deprecated: Use SamplePair.ProtoReflect.Descriptor instead.

func (*SamplePair) GetTimestamp 

func (x *SamplePair) GetTimestamp() int64

func (*SamplePair) GetValue 

func (x *SamplePair) GetValue() float32

func (*SamplePair) ProtoMessage 

func (*SamplePair) ProtoMessage()

func (*SamplePair) ProtoReflect 

func (x *SamplePair) ProtoReflect() protoreflect.Message

func (*SamplePair) Reset 

func (x *SamplePair) Reset()

func (*SamplePair) String 

func (x *SamplePair) String() string

type SampleStream 

type SampleStream struct {
	Values []*SamplePair `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*SampleStream) Descriptor deprecated 

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

Deprecated: Use SampleStream.ProtoReflect.Descriptor instead.

func (*SampleStream) GetValues 

func (x *SampleStream) GetValues() []*SamplePair

func (*SampleStream) ProtoMessage 

func (*SampleStream) ProtoMessage()

func (*SampleStream) ProtoReflect 

func (x *SampleStream) ProtoReflect() protoreflect.Message

func (*SampleStream) Reset 

func (x *SampleStream) Reset()

func (*SampleStream) String 

func (x *SampleStream) String() string

type SourceTaskInfo 

type SourceTaskInfo struct {
	TaskId       uint64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Name         string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	BeHidden     bool   `protobuf:"varint,3,opt,name=be_hidden,json=beHidden,proto3" json:"be_hidden,omitempty"`
	MajorVersion uint64 `protobuf:"varint,4,opt,name=major_version,json=majorVersion,proto3" json:"major_version,omitempty"`
	MinorVersion uint64 `protobuf:"varint,5,opt,name=minor_version,json=minorVersion,proto3" json:"minor_version,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceTaskInfo) Descriptor deprecated 

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

Deprecated: Use SourceTaskInfo.ProtoReflect.Descriptor instead.

func (*SourceTaskInfo) GetBeHidden 

func (x *SourceTaskInfo) GetBeHidden() bool

func (*SourceTaskInfo) GetMajorVersion 

func (x *SourceTaskInfo) GetMajorVersion() uint64

func (*SourceTaskInfo) GetMinorVersion 

func (x *SourceTaskInfo) GetMinorVersion() uint64

func (*SourceTaskInfo) GetName 

func (x *SourceTaskInfo) GetName() string

func (*SourceTaskInfo) GetTaskId 

func (x *SourceTaskInfo) GetTaskId() uint64

func (*SourceTaskInfo) ProtoMessage 

func (*SourceTaskInfo) ProtoMessage()

func (*SourceTaskInfo) ProtoReflect 

func (x *SourceTaskInfo) ProtoReflect() protoreflect.Message

func (*SourceTaskInfo) Reset 

func (x *SourceTaskInfo) Reset()

func (*SourceTaskInfo) String 

func (x *SourceTaskInfo) String() string

type TaskResponse 

type TaskResponse struct {
	Base           *BaseTaskResponse   `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	AdditionalInfo *AdditionalTaskInfo `protobuf:"bytes,2,opt,name=additional_info,json=additionalInfo,proto3" json:"additional_info,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskResponse) Descriptor deprecated 

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

Deprecated: Use TaskResponse.ProtoReflect.Descriptor instead.

func (*TaskResponse) GetAdditionalInfo 

func (x *TaskResponse) GetAdditionalInfo() *AdditionalTaskInfo

func (*TaskResponse) GetBase 

func (x *TaskResponse) GetBase() *BaseTaskResponse

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

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.