pcmCore

package
v0.1.7 Latest Latest
Warning

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

 Go to latest Published: Jul 27, 2023 License: Apache-2.0 Imports: 8 Imported by: 3

Documentation

Index

Constants

View Source 
const (
	PcmCore_SyncInfo_FullMethodName = "/pcmCore.pcmCore/SyncInfo"
	PcmCore_InfoList_FullMethodName = "/pcmCore.pcmCore/InfoList"
)
View Source 
const (
	ParticipantService_RegisterParticipant_FullMethodName = "/pcmCore.participantService/registerParticipant"
	ParticipantService_ReportHeartbeat_FullMethodName     = "/pcmCore.participantService/reportHeartbeat"
	ParticipantService_ReportAvailable_FullMethodName     = "/pcmCore.participantService/reportAvailable"
)

Variables

View Source 
var (
	MessageStatus_name = map[int32]string{
		0: "FAIL",
		1: "SUCCESS",
		2: "UNKNOWN",
	}
	MessageStatus_value = map[string]int32{
		"FAIL":    0,
		"SUCCESS": 1,
		"UNKNOWN": 2,
	}
)

Enum value maps for MessageStatus.

View Source 
var File_pcmCore_proto protoreflect.FileDescriptor
View Source 
var ParticipantService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pcmCore.participantService",
	HandlerType: (*ParticipantServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "registerParticipant",
			Handler:    _ParticipantService_RegisterParticipant_Handler,
		},
		{
			MethodName: "reportHeartbeat",
			Handler:    _ParticipantService_ReportHeartbeat_Handler,
		},
		{
			MethodName: "reportAvailable",
			Handler:    _ParticipantService_ReportAvailable_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pcmCore.proto",
}

ParticipantService_ServiceDesc is the grpc.ServiceDesc for ParticipantService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var PcmCore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pcmCore.pcmCore",
	HandlerType: (*PcmCoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SyncInfo",
			Handler:    _PcmCore_SyncInfo_Handler,
		},
		{
			MethodName: "InfoList",
			Handler:    _PcmCore_InfoList_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pcmCore.proto",
}

PcmCore_ServiceDesc is the grpc.ServiceDesc for PcmCore service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterParticipantServiceServer added in v0.1.7 

func RegisterParticipantServiceServer(s grpc.ServiceRegistrar, srv ParticipantServiceServer)

func RegisterPcmCoreServer 

func RegisterPcmCoreServer(s grpc.ServiceRegistrar, srv PcmCoreServer)

Types

type AiInfo 

type AiInfo struct {
	ParticipantId  int64  `protobuf:"varint,1,opt,name=participantId,proto3" json:"participantId,omitempty"`
	TaskId         int64  `protobuf:"varint,2,opt,name=taskId,proto3" json:"taskId,omitempty"`
	ProjectId      string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Name           string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Status         string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	StartTime      string `protobuf:"bytes,6,opt,name=startTime,proto3" json:"startTime,omitempty"`
	RunningTime    int64  `protobuf:"varint,7,opt,name=runningTime,proto3" json:"runningTime,omitempty"`
	Result         string `protobuf:"bytes,8,opt,name=result,proto3" json:"result,omitempty"`
	JobId          string `protobuf:"bytes,9,opt,name=jobId,proto3" json:"jobId,omitempty"`
	CreateTime     string `protobuf:"bytes,10,opt,name=createTime,proto3" json:"createTime,omitempty"`
	ImageUrl       string `protobuf:"bytes,11,opt,name=imageUrl,proto3" json:"imageUrl,omitempty"`
	Command        string `protobuf:"bytes,12,opt,name=command,proto3" json:"command,omitempty"`
	FlavorId       string `protobuf:"bytes,13,opt,name=flavorId,proto3" json:"flavorId,omitempty"`
	SubscriptionId string `protobuf:"bytes,14,opt,name=subscriptionId,proto3" json:"subscriptionId,omitempty"`
	ItemVersionId  string `protobuf:"bytes,15,opt,name=itemVersionId,proto3" json:"itemVersionId,omitempty"`
	// contains filtered or unexported fields
}

func (*AiInfo) Descriptor deprecated 

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

Deprecated: Use AiInfo.ProtoReflect.Descriptor instead.

func (*AiInfo) GetCommand 

func (x *AiInfo) GetCommand() string

func (*AiInfo) GetCreateTime 

func (x *AiInfo) GetCreateTime() string

func (*AiInfo) GetFlavorId 

func (x *AiInfo) GetFlavorId() string

func (*AiInfo) GetImageUrl 

func (x *AiInfo) GetImageUrl() string

func (*AiInfo) GetItemVersionId 

func (x *AiInfo) GetItemVersionId() string

func (*AiInfo) GetJobId 

func (x *AiInfo) GetJobId() string

func (*AiInfo) GetName 

func (x *AiInfo) GetName() string

func (*AiInfo) GetParticipantId added in v0.1.7 

func (x *AiInfo) GetParticipantId() int64

func (*AiInfo) GetProjectId 

func (x *AiInfo) GetProjectId() string

func (*AiInfo) GetResult 

func (x *AiInfo) GetResult() string

func (*AiInfo) GetRunningTime 

func (x *AiInfo) GetRunningTime() int64

func (*AiInfo) GetStartTime 

func (x *AiInfo) GetStartTime() string

func (*AiInfo) GetStatus 

func (x *AiInfo) GetStatus() string

func (*AiInfo) GetSubscriptionId 

func (x *AiInfo) GetSubscriptionId() string

func (*AiInfo) GetTaskId 

func (x *AiInfo) GetTaskId() int64

func (*AiInfo) ProtoMessage 

func (*AiInfo) ProtoMessage()

func (*AiInfo) ProtoReflect 

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

func (*AiInfo) Reset 

func (x *AiInfo) Reset()

func (*AiInfo) String 

func (x *AiInfo) String() string

type CloudInfo 

type CloudInfo struct {
	Participant int64  `protobuf:"varint,1,opt,name=participant,proto3" json:"participant,omitempty"`
	TaskId      int64  `protobuf:"varint,2,opt,name=taskId,proto3" json:"taskId,omitempty"`
	ApiVersion  string `protobuf:"bytes,3,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"`
	Kind        string `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
	Namespace   string `protobuf:"bytes,5,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name        string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	Status      string `protobuf:"bytes,7,opt,name=status,proto3" json:"status,omitempty"`
	StartTime   string `protobuf:"bytes,8,opt,name=startTime,proto3" json:"startTime,omitempty"`
	RunningTime int64  `protobuf:"varint,9,opt,name=runningTime,proto3" json:"runningTime,omitempty"`
	Result      string `protobuf:"bytes,10,opt,name=result,proto3" json:"result,omitempty"`
	YamlString  string `protobuf:"bytes,11,opt,name=yamlString,proto3" json:"yamlString,omitempty"`
	// contains filtered or unexported fields
}

func (*CloudInfo) Descriptor deprecated 

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

Deprecated: Use CloudInfo.ProtoReflect.Descriptor instead.

func (*CloudInfo) GetApiVersion 

func (x *CloudInfo) GetApiVersion() string

func (*CloudInfo) GetKind 

func (x *CloudInfo) GetKind() string

func (*CloudInfo) GetName 

func (x *CloudInfo) GetName() string

func (*CloudInfo) GetNamespace 

func (x *CloudInfo) GetNamespace() string

func (*CloudInfo) GetParticipant added in v0.1.7 

func (x *CloudInfo) GetParticipant() int64

func (*CloudInfo) GetResult 

func (x *CloudInfo) GetResult() string

func (*CloudInfo) GetRunningTime 

func (x *CloudInfo) GetRunningTime() int64

func (*CloudInfo) GetStartTime 

func (x *CloudInfo) GetStartTime() string

func (*CloudInfo) GetStatus 

func (x *CloudInfo) GetStatus() string

func (*CloudInfo) GetTaskId 

func (x *CloudInfo) GetTaskId() int64

func (*CloudInfo) GetYamlString 

func (x *CloudInfo) GetYamlString() string

func (*CloudInfo) ProtoMessage 

func (*CloudInfo) ProtoMessage()

func (*CloudInfo) ProtoReflect 

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

func (*CloudInfo) Reset 

func (x *CloudInfo) Reset()

func (*CloudInfo) String 

func (x *CloudInfo) String() string

type HealthCheckResp added in v0.1.7 

type HealthCheckResp struct {
	MessageStatus MessageStatus `protobuf:"varint,1,opt,name=messageStatus,proto3,enum=pcmCore.MessageStatus" json:"messageStatus,omitempty"`
	Code          int64         `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	Msg           string        `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckResp) Descriptor deprecated added in v0.1.7 

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

Deprecated: Use HealthCheckResp.ProtoReflect.Descriptor instead.

func (*HealthCheckResp) GetCode added in v0.1.7 

func (x *HealthCheckResp) GetCode() int64

func (*HealthCheckResp) GetMessageStatus added in v0.1.7 

func (x *HealthCheckResp) GetMessageStatus() MessageStatus

func (*HealthCheckResp) GetMsg added in v0.1.7 

func (x *HealthCheckResp) GetMsg() string

func (*HealthCheckResp) ProtoMessage added in v0.1.7 

func (*HealthCheckResp) ProtoMessage()

func (*HealthCheckResp) ProtoReflect added in v0.1.7 

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

func (*HealthCheckResp) Reset added in v0.1.7 

func (x *HealthCheckResp) Reset()

func (*HealthCheckResp) String added in v0.1.7 

func (x *HealthCheckResp) String() string

type HpcInfo 

type HpcInfo struct {
	ParticipantId int64  `protobuf:"varint,1,opt,name=participantId,proto3" json:"participantId,omitempty"`
	TaskId        int64  `protobuf:"varint,2,opt,name=taskId,proto3" json:"taskId,omitempty"`
	JobId         string `protobuf:"bytes,3,opt,name=jobId,proto3" json:"jobId,omitempty"`
	Name          string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Status        string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	StartTime     string `protobuf:"bytes,6,opt,name=startTime,proto3" json:"startTime,omitempty"`
	RunningTime   int64  `protobuf:"varint,7,opt,name=runningTime,proto3" json:"runningTime,omitempty"`
	Result        string `protobuf:"bytes,8,opt,name=result,proto3" json:"result,omitempty"`
	WorkDir       string `protobuf:"bytes,9,opt,name=workDir,proto3" json:"workDir,omitempty"`
	WallTime      string `protobuf:"bytes,10,opt,name=wallTime,proto3" json:"wallTime,omitempty"`
	CmdScript     string `protobuf:"bytes,11,opt,name=cmdScript,proto3" json:"cmdScript,omitempty"`
	DerivedEs     string `protobuf:"bytes,12,opt,name=derivedEs,proto3" json:"derivedEs,omitempty"`
	Cluster       string `protobuf:"bytes,13,opt,name=cluster,proto3" json:"cluster,omitempty"`
	BlockId       string `protobuf:"bytes,14,opt,name=blockId,proto3" json:"blockId,omitempty"`
	AllocNodes    uint32 `protobuf:"varint,15,opt,name=allocNodes,proto3" json:"allocNodes,omitempty"`
	AllocCpu      uint32 `protobuf:"varint,16,opt,name=allocCpu,proto3" json:"allocCpu,omitempty"`
	Version       string `protobuf:"bytes,17,opt,name=version,proto3" json:"version,omitempty"`
	Account       string `protobuf:"bytes,18,opt,name=account,proto3" json:"account,omitempty"`
	ExitCode      uint32 `protobuf:"varint,19,opt,name=exitCode,proto3" json:"exitCode,omitempty"`
	AssocId       uint32 `protobuf:"varint,20,opt,name=assocId,proto3" json:"assocId,omitempty"`
	// contains filtered or unexported fields
}

func (*HpcInfo) Descriptor deprecated 

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

Deprecated: Use HpcInfo.ProtoReflect.Descriptor instead.

func (*HpcInfo) GetAccount 

func (x *HpcInfo) GetAccount() string

func (*HpcInfo) GetAllocCpu 

func (x *HpcInfo) GetAllocCpu() uint32

func (*HpcInfo) GetAllocNodes 

func (x *HpcInfo) GetAllocNodes() uint32

func (*HpcInfo) GetAssocId 

func (x *HpcInfo) GetAssocId() uint32

func (*HpcInfo) GetBlockId 

func (x *HpcInfo) GetBlockId() string

func (*HpcInfo) GetCluster 

func (x *HpcInfo) GetCluster() string

func (*HpcInfo) GetCmdScript 

func (x *HpcInfo) GetCmdScript() string

func (*HpcInfo) GetDerivedEs 

func (x *HpcInfo) GetDerivedEs() string

func (*HpcInfo) GetExitCode 

func (x *HpcInfo) GetExitCode() uint32

func (*HpcInfo) GetJobId 

func (x *HpcInfo) GetJobId() string

func (*HpcInfo) GetName 

func (x *HpcInfo) GetName() string

func (*HpcInfo) GetParticipantId added in v0.1.7 

func (x *HpcInfo) GetParticipantId() int64

func (*HpcInfo) GetResult 

func (x *HpcInfo) GetResult() string

func (*HpcInfo) GetRunningTime 

func (x *HpcInfo) GetRunningTime() int64

func (*HpcInfo) GetStartTime 

func (x *HpcInfo) GetStartTime() string

func (*HpcInfo) GetStatus 

func (x *HpcInfo) GetStatus() string

func (*HpcInfo) GetTaskId 

func (x *HpcInfo) GetTaskId() int64

func (*HpcInfo) GetVersion 

func (x *HpcInfo) GetVersion() string

func (*HpcInfo) GetWallTime 

func (x *HpcInfo) GetWallTime() string

func (*HpcInfo) GetWorkDir 

func (x *HpcInfo) GetWorkDir() string

func (*HpcInfo) ProtoMessage 

func (*HpcInfo) ProtoMessage()

func (*HpcInfo) ProtoReflect 

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

func (*HpcInfo) Reset 

func (x *HpcInfo) Reset()

func (*HpcInfo) String 

func (x *HpcInfo) String() string

type InfoListReq 

type InfoListReq struct {
	Kind          string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	ParticipantId int64  `protobuf:"varint,2,opt,name=participantId,proto3" json:"participantId,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoListReq) Descriptor deprecated 

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

Deprecated: Use InfoListReq.ProtoReflect.Descriptor instead.

func (*InfoListReq) GetKind 

func (x *InfoListReq) GetKind() string

func (*InfoListReq) GetParticipantId added in v0.1.7 

func (x *InfoListReq) GetParticipantId() int64

func (*InfoListReq) ProtoMessage 

func (*InfoListReq) ProtoMessage()

func (*InfoListReq) ProtoReflect 

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

func (*InfoListReq) Reset 

func (x *InfoListReq) Reset()

func (*InfoListReq) String 

func (x *InfoListReq) String() string

type InfoListResp 

type InfoListResp struct {
	HpcInfoList   []*HpcInfo   `protobuf:"bytes,1,rep,name=HpcInfoList,proto3" json:"HpcInfoList,omitempty"`
	CloudInfoList []*CloudInfo `protobuf:"bytes,2,rep,name=CloudInfoList,proto3" json:"CloudInfoList,omitempty"`
	AiInfoList    []*AiInfo    `protobuf:"bytes,3,rep,name=AiInfoList,proto3" json:"AiInfoList,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoListResp) Descriptor deprecated 

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

Deprecated: Use InfoListResp.ProtoReflect.Descriptor instead.

func (*InfoListResp) GetAiInfoList 

func (x *InfoListResp) GetAiInfoList() []*AiInfo

func (*InfoListResp) GetCloudInfoList 

func (x *InfoListResp) GetCloudInfoList() []*CloudInfo

func (*InfoListResp) GetHpcInfoList 

func (x *InfoListResp) GetHpcInfoList() []*HpcInfo

func (*InfoListResp) ProtoMessage 

func (*InfoListResp) ProtoMessage()

func (*InfoListResp) ProtoReflect 

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

func (*InfoListResp) Reset 

func (x *InfoListResp) Reset()

func (*InfoListResp) String 

func (x *InfoListResp) String() string

type MessageStatus added in v0.1.7 

type MessageStatus int32
const (
	MessageStatus_FAIL    MessageStatus = 0
	MessageStatus_SUCCESS MessageStatus = 1
	MessageStatus_UNKNOWN MessageStatus = 2
)

func (MessageStatus) Descriptor added in v0.1.7 

func (MessageStatus) Descriptor() protoreflect.EnumDescriptor

func (MessageStatus) Enum added in v0.1.7 

func (x MessageStatus) Enum() *MessageStatus

func (MessageStatus) EnumDescriptor deprecated added in v0.1.7 

func (MessageStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use MessageStatus.Descriptor instead.

func (MessageStatus) Number added in v0.1.7 

func (x MessageStatus) Number() protoreflect.EnumNumber

func (MessageStatus) String added in v0.1.7 

func (x MessageStatus) String() string

func (MessageStatus) Type added in v0.1.7 

func (MessageStatus) Type() protoreflect.EnumType

type NodeAvailInfo added in v0.1.7 

type NodeAvailInfo struct {
	Id                 int64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`                                  //id
	NodeName           string  `protobuf:"bytes,2,opt,name=nodeName,proto3" json:"nodeName,omitempty"`                       //节点名称
	CpuTotal           int64   `protobuf:"varint,3,opt,name=cpuTotal,proto3" json:"cpuTotal,omitempty"`                      //cpu核数
	CpuUsable          float64 `protobuf:"fixed64,4,opt,name=cpuUsable,proto3" json:"cpuUsable,omitempty"`                   //cpu可用率
	DiskTotal          int64   `protobuf:"varint,5,opt,name=diskTotal,proto3" json:"diskTotal,omitempty"`                    //磁盘空间
	DiskAvail          int64   `protobuf:"varint,6,opt,name=diskAvail,proto3" json:"diskAvail,omitempty"`                    //磁盘可用空间
	MemTotal           int64   `protobuf:"varint,7,opt,name=memTotal,proto3" json:"memTotal,omitempty"`                      //内存总数
	MemAvail           int64   `protobuf:"varint,8,opt,name=memAvail,proto3" json:"memAvail,omitempty"`                      //内存可用数
	GpuTotal           int64   `protobuf:"varint,9,opt,name=gpuTotal,proto3" json:"gpuTotal,omitempty"`                      //gpu总数
	GpuAvail           int64   `protobuf:"varint,10,opt,name=gpuAvail,proto3" json:"gpuAvail,omitempty"`                     //gpu可用数
	ParticipantAvailId int64   `protobuf:"varint,11,opt,name=participantAvailId,proto3" json:"participantAvailId,omitempty"` //集群动态信息id
	// contains filtered or unexported fields
}

NodeAvailInfo 节点可用信息

func (*NodeAvailInfo) Descriptor deprecated added in v0.1.7 

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

Deprecated: Use NodeAvailInfo.ProtoReflect.Descriptor instead.

func (*NodeAvailInfo) GetCpuTotal added in v0.1.7 

func (x *NodeAvailInfo) GetCpuTotal() int64

func (*NodeAvailInfo) GetCpuUsable added in v0.1.7 

func (x *NodeAvailInfo) GetCpuUsable() float64

func (*NodeAvailInfo) GetDiskAvail added in v0.1.7 

func (x *NodeAvailInfo) GetDiskAvail() int64

func (*NodeAvailInfo) GetDiskTotal added in v0.1.7 

func (x *NodeAvailInfo) GetDiskTotal() int64

func (*NodeAvailInfo) GetGpuAvail added in v0.1.7 

func (x *NodeAvailInfo) GetGpuAvail() int64

func (*NodeAvailInfo) GetGpuTotal added in v0.1.7 

func (x *NodeAvailInfo) GetGpuTotal() int64

func (*NodeAvailInfo) GetId added in v0.1.7 

func (x *NodeAvailInfo) GetId() int64

func (*NodeAvailInfo) GetMemAvail added in v0.1.7 

func (x *NodeAvailInfo) GetMemAvail() int64

func (*NodeAvailInfo) GetMemTotal added in v0.1.7 

func (x *NodeAvailInfo) GetMemTotal() int64

func (*NodeAvailInfo) GetNodeName added in v0.1.7 

func (x *NodeAvailInfo) GetNodeName() string

func (*NodeAvailInfo) GetParticipantAvailId added in v0.1.7 

func (x *NodeAvailInfo) GetParticipantAvailId() int64

func (*NodeAvailInfo) ProtoMessage added in v0.1.7 

func (*NodeAvailInfo) ProtoMessage()

func (*NodeAvailInfo) ProtoReflect added in v0.1.7 

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

func (*NodeAvailInfo) Reset added in v0.1.7 

func (x *NodeAvailInfo) Reset()

func (*NodeAvailInfo) String added in v0.1.7 

func (x *NodeAvailInfo) String() string

type NodePhyInfo added in v0.1.7 

type NodePhyInfo struct {
	Id        int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	NodeName  string `protobuf:"bytes,2,opt,name=nodeName,proto3" json:"nodeName,omitempty"`   //节点名称
	OsName    string `protobuf:"bytes,3,opt,name=osName,proto3" json:"osName,omitempty"`       //系统名称
	OsVersion string `protobuf:"bytes,4,opt,name=osVersion,proto3" json:"osVersion,omitempty"` //系统版本
	ArchType  string `protobuf:"bytes,5,opt,name=archType,proto3" json:"archType,omitempty"`   //架构类型
	ArchName  string `protobuf:"bytes,6,opt,name=archName,proto3" json:"archName,omitempty"`   //架构名称
	ArchFreq  string `protobuf:"bytes,7,opt,name=archFreq,proto3" json:"archFreq,omitempty"`   //架构频率
	// contains filtered or unexported fields
}

NodePhyInfo 节点信息

func (*NodePhyInfo) Descriptor deprecated added in v0.1.7 

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

Deprecated: Use NodePhyInfo.ProtoReflect.Descriptor instead.

func (*NodePhyInfo) GetArchFreq added in v0.1.7 

func (x *NodePhyInfo) GetArchFreq() string

func (*NodePhyInfo) GetArchName added in v0.1.7 

func (x *NodePhyInfo) GetArchName() string

func (*NodePhyInfo) GetArchType added in v0.1.7 

func (x *NodePhyInfo) GetArchType() string

func (*NodePhyInfo) GetId added in v0.1.7 

func (x *NodePhyInfo) GetId() int64

func (*NodePhyInfo) GetNodeName added in v0.1.7 

func (x *NodePhyInfo) GetNodeName() string

func (*NodePhyInfo) GetOsName added in v0.1.7 

func (x *NodePhyInfo) GetOsName() string

func (*NodePhyInfo) GetOsVersion added in v0.1.7 

func (x *NodePhyInfo) GetOsVersion() string

func (*NodePhyInfo) ProtoMessage added in v0.1.7 

func (*NodePhyInfo) ProtoMessage()

func (*NodePhyInfo) ProtoReflect added in v0.1.7 

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

func (*NodePhyInfo) Reset added in v0.1.7 

func (x *NodePhyInfo) Reset()

func (*NodePhyInfo) String added in v0.1.7 

func (x *NodePhyInfo) String() string

type ParticipantAvailReq added in v0.1.7 

type ParticipantAvailReq struct {
	Id                int64            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`                               //id
	AvailStorageSpace int64            `protobuf:"varint,2,opt,name=availStorageSpace,proto3" json:"availStorageSpace,omitempty"` //集群存储可用空间
	UserNum           int64            `protobuf:"varint,3,opt,name=userNum,proto3" json:"userNum,omitempty"`                     //用户数量
	PendingJobNum     int64            `protobuf:"varint,4,opt,name=pendingJobNum,proto3" json:"pendingJobNum,omitempty"`         //待处理作业数量
	RunningJobNum     int64            `protobuf:"varint,5,opt,name=runningJobNum,proto3" json:"runningJobNum,omitempty"`         //运行作业数量
	ParticipantId     int64            `protobuf:"varint,6,opt,name=participantId,proto3" json:"participantId,omitempty"`         //集群静态信息id
	NodeAvailInfo     []*NodeAvailInfo `protobuf:"bytes,7,rep,name=nodeAvailInfo,proto3" json:"nodeAvailInfo,omitempty"`          //节点可用信息
	// contains filtered or unexported fields
}

ParticipantAvailInfo Participant可用信息

func (*ParticipantAvailReq) Descriptor deprecated added in v0.1.7 

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

Deprecated: Use ParticipantAvailReq.ProtoReflect.Descriptor instead.

func (*ParticipantAvailReq) GetAvailStorageSpace added in v0.1.7 

func (x *ParticipantAvailReq) GetAvailStorageSpace() int64

func (*ParticipantAvailReq) GetId added in v0.1.7 

func (x *ParticipantAvailReq) GetId() int64

func (*ParticipantAvailReq) GetNodeAvailInfo added in v0.1.7 

func (x *ParticipantAvailReq) GetNodeAvailInfo() []*NodeAvailInfo

func (*ParticipantAvailReq) GetParticipantId added in v0.1.7 

func (x *ParticipantAvailReq) GetParticipantId() int64

func (*ParticipantAvailReq) GetPendingJobNum added in v0.1.7 

func (x *ParticipantAvailReq) GetPendingJobNum() int64

func (*ParticipantAvailReq) GetRunningJobNum added in v0.1.7 

func (x *ParticipantAvailReq) GetRunningJobNum() int64

func (*ParticipantAvailReq) GetUserNum added in v0.1.7 

func (x *ParticipantAvailReq) GetUserNum() int64

func (*ParticipantAvailReq) ProtoMessage added in v0.1.7 

func (*ParticipantAvailReq) ProtoMessage()

func (*ParticipantAvailReq) ProtoReflect added in v0.1.7 

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

func (*ParticipantAvailReq) Reset added in v0.1.7 

func (x *ParticipantAvailReq) Reset()

func (*ParticipantAvailReq) String added in v0.1.7 

func (x *ParticipantAvailReq) String() string

type ParticipantHeartbeatReq added in v0.1.7 

type ParticipantHeartbeatReq struct {
	ParticipantId int64  `protobuf:"varint,1,opt,name=participantId,proto3" json:"participantId,omitempty"` //participantId
	Host          string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`                    //host
	Port          string `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"`                    //port
	// contains filtered or unexported fields
}

ParticipantHeartbeatReq 心跳请求

func (*ParticipantHeartbeatReq) Descriptor deprecated added in v0.1.7 

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

Deprecated: Use ParticipantHeartbeatReq.ProtoReflect.Descriptor instead.

func (*ParticipantHeartbeatReq) GetHost added in v0.1.7 

func (x *ParticipantHeartbeatReq) GetHost() string

func (*ParticipantHeartbeatReq) GetParticipantId added in v0.1.7 

func (x *ParticipantHeartbeatReq) GetParticipantId() int64

func (*ParticipantHeartbeatReq) GetPort added in v0.1.7 

func (x *ParticipantHeartbeatReq) GetPort() string

func (*ParticipantHeartbeatReq) ProtoMessage added in v0.1.7 

func (*ParticipantHeartbeatReq) ProtoMessage()

func (*ParticipantHeartbeatReq) ProtoReflect added in v0.1.7 

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

func (*ParticipantHeartbeatReq) Reset added in v0.1.7 

func (x *ParticipantHeartbeatReq) Reset()

func (*ParticipantHeartbeatReq) String added in v0.1.7 

func (x *ParticipantHeartbeatReq) String() string

type ParticipantLabel added in v0.1.7 

type ParticipantLabel struct {
	Id    int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`      //id
	Key   string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`     //标签名
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` //标签值
	// contains filtered or unexported fields
}

集群标签

func (*ParticipantLabel) Descriptor deprecated added in v0.1.7 

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

Deprecated: Use ParticipantLabel.ProtoReflect.Descriptor instead.

func (*ParticipantLabel) GetId added in v0.1.7 

func (x *ParticipantLabel) GetId() int64

func (*ParticipantLabel) GetKey added in v0.1.7 

func (x *ParticipantLabel) GetKey() string

func (*ParticipantLabel) GetValue added in v0.1.7 

func (x *ParticipantLabel) GetValue() string

func (*ParticipantLabel) ProtoMessage added in v0.1.7 

func (*ParticipantLabel) ProtoMessage()

func (*ParticipantLabel) ProtoReflect added in v0.1.7 

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

func (*ParticipantLabel) Reset added in v0.1.7 

func (x *ParticipantLabel) Reset()

func (*ParticipantLabel) String added in v0.1.7 

func (x *ParticipantLabel) String() string

type ParticipantPhyReq added in v0.1.7 

type ParticipantPhyReq struct {
	Name              string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                           //名称
	Host              string              `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`                           //host
	Port              string              `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"`                           //端口号
	NetworkType       string              `protobuf:"bytes,4,opt,name=networkType,proto3" json:"networkType,omitempty"`             //集群网络类型
	NetworkBandwidth  string              `protobuf:"bytes,5,opt,name=networkBandwidth,proto3" json:"networkBandwidth,omitempty"`   //集群网络带宽
	StorageType       string              `protobuf:"bytes,6,opt,name=storageType,proto3" json:"storageType,omitempty"`             //集群存储类型
	StorageSpace      string              `protobuf:"bytes,7,opt,name=storageSpace,proto3" json:"storageSpace,omitempty"`           //集群存储空间
	StorageAvailSpace string              `protobuf:"bytes,8,opt,name=storageAvailSpace,proto3" json:"storageAvailSpace,omitempty"` //集群存储可用空间
	StorageBandwidth  string              `protobuf:"bytes,9,opt,name=storageBandwidth,proto3" json:"storageBandwidth,omitempty"`   //集群存储带宽
	Type              string              `protobuf:"bytes,10,opt,name=type,proto3" json:"type,omitempty"`                          //参与者类型:0-数算集群；1-智算集群；2-超算集群
	TenantId          int64               `protobuf:"varint,11,opt,name=tenantId,proto3" json:"tenantId,omitempty"`                 //租户id
	TenantName        string              `protobuf:"bytes,12,opt,name=tenantName,proto3" json:"tenantName,omitempty"`              //租户名称
	NodeInfo          []*NodePhyInfo      `protobuf:"bytes,13,rep,name=nodeInfo,proto3" json:"nodeInfo,omitempty"`                  //节点信息
	ParticipantId     int64               `protobuf:"varint,14,opt,name=participantId,proto3" json:"participantId,omitempty"`       //participant id
	LabelInfo         []*ParticipantLabel `protobuf:"bytes,15,rep,name=labelInfo,proto3" json:"labelInfo,omitempty"`                //标签信息
	// contains filtered or unexported fields
}

participantPhy 静态信息

func (*ParticipantPhyReq) Descriptor deprecated added in v0.1.7 

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

Deprecated: Use ParticipantPhyReq.ProtoReflect.Descriptor instead.

func (*ParticipantPhyReq) GetHost added in v0.1.7 

func (x *ParticipantPhyReq) GetHost() string

func (*ParticipantPhyReq) GetLabelInfo added in v0.1.7 

func (x *ParticipantPhyReq) GetLabelInfo() []*ParticipantLabel

func (*ParticipantPhyReq) GetName added in v0.1.7 

func (x *ParticipantPhyReq) GetName() string

func (*ParticipantPhyReq) GetNetworkBandwidth added in v0.1.7 

func (x *ParticipantPhyReq) GetNetworkBandwidth() string

func (*ParticipantPhyReq) GetNetworkType added in v0.1.7 

func (x *ParticipantPhyReq) GetNetworkType() string

func (*ParticipantPhyReq) GetNodeInfo added in v0.1.7 

func (x *ParticipantPhyReq) GetNodeInfo() []*NodePhyInfo

func (*ParticipantPhyReq) GetParticipantId added in v0.1.7 

func (x *ParticipantPhyReq) GetParticipantId() int64

func (*ParticipantPhyReq) GetPort added in v0.1.7 

func (x *ParticipantPhyReq) GetPort() string

func (*ParticipantPhyReq) GetStorageAvailSpace added in v0.1.7 

func (x *ParticipantPhyReq) GetStorageAvailSpace() string

func (*ParticipantPhyReq) GetStorageBandwidth added in v0.1.7 

func (x *ParticipantPhyReq) GetStorageBandwidth() string

func (*ParticipantPhyReq) GetStorageSpace added in v0.1.7 

func (x *ParticipantPhyReq) GetStorageSpace() string

func (*ParticipantPhyReq) GetStorageType added in v0.1.7 

func (x *ParticipantPhyReq) GetStorageType() string

func (*ParticipantPhyReq) GetTenantId added in v0.1.7 

func (x *ParticipantPhyReq) GetTenantId() int64

func (*ParticipantPhyReq) GetTenantName added in v0.1.7 

func (x *ParticipantPhyReq) GetTenantName() string

func (*ParticipantPhyReq) GetType added in v0.1.7 

func (x *ParticipantPhyReq) GetType() string

func (*ParticipantPhyReq) ProtoMessage added in v0.1.7 

func (*ParticipantPhyReq) ProtoMessage()

func (*ParticipantPhyReq) ProtoReflect added in v0.1.7 

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

func (*ParticipantPhyReq) Reset added in v0.1.7 

func (x *ParticipantPhyReq) Reset()

func (*ParticipantPhyReq) String added in v0.1.7 

func (x *ParticipantPhyReq) String() string

type ParticipantPhyResp added in v0.1.7 

type ParticipantPhyResp struct {
	Code          int64  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg           string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	ParticipantId int64  `protobuf:"varint,3,opt,name=participantId,proto3" json:"participantId,omitempty"` //participant 唯一标识
	// contains filtered or unexported fields
}

func (*ParticipantPhyResp) Descriptor deprecated added in v0.1.7 

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

Deprecated: Use ParticipantPhyResp.ProtoReflect.Descriptor instead.

func (*ParticipantPhyResp) GetCode added in v0.1.7 

func (x *ParticipantPhyResp) GetCode() int64

func (*ParticipantPhyResp) GetMsg added in v0.1.7 

func (x *ParticipantPhyResp) GetMsg() string

func (*ParticipantPhyResp) GetParticipantId added in v0.1.7 

func (x *ParticipantPhyResp) GetParticipantId() int64

func (*ParticipantPhyResp) ProtoMessage added in v0.1.7 

func (*ParticipantPhyResp) ProtoMessage()

func (*ParticipantPhyResp) ProtoReflect added in v0.1.7 

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

func (*ParticipantPhyResp) Reset added in v0.1.7 

func (x *ParticipantPhyResp) Reset()

func (*ParticipantPhyResp) String added in v0.1.7 

func (x *ParticipantPhyResp) String() string

type ParticipantResp added in v0.1.7 

type ParticipantResp struct {
	Code int64  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg  string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*ParticipantResp) Descriptor deprecated added in v0.1.7 

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

Deprecated: Use ParticipantResp.ProtoReflect.Descriptor instead.

func (*ParticipantResp) GetCode added in v0.1.7 

func (x *ParticipantResp) GetCode() int64

func (*ParticipantResp) GetMsg added in v0.1.7 

func (x *ParticipantResp) GetMsg() string

func (*ParticipantResp) ProtoMessage added in v0.1.7 

func (*ParticipantResp) ProtoMessage()

func (*ParticipantResp) ProtoReflect added in v0.1.7 

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

func (*ParticipantResp) Reset added in v0.1.7 

func (x *ParticipantResp) Reset()

func (*ParticipantResp) String added in v0.1.7 

func (x *ParticipantResp) String() string

type ParticipantServiceClient added in v0.1.7 

type ParticipantServiceClient interface {
	// registerParticipant Participant注册接口
	RegisterParticipant(ctx context.Context, in *ParticipantPhyReq, opts ...grpc.CallOption) (*ParticipantPhyResp, error)
	// reportHeartbeat 心跳请求
	ReportHeartbeat(ctx context.Context, in *ParticipantHeartbeatReq, opts ...grpc.CallOption) (*HealthCheckResp, error)
	// reportAvailable 监控数据上报
	ReportAvailable(ctx context.Context, in *ParticipantAvailReq, opts ...grpc.CallOption) (*ParticipantResp, error)
}

ParticipantServiceClient is the client API for ParticipantService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewParticipantServiceClient added in v0.1.7 

func NewParticipantServiceClient(cc grpc.ClientConnInterface) ParticipantServiceClient

type ParticipantServiceServer added in v0.1.7 

type ParticipantServiceServer interface {
	// registerParticipant Participant注册接口
	RegisterParticipant(context.Context, *ParticipantPhyReq) (*ParticipantPhyResp, error)
	// reportHeartbeat 心跳请求
	ReportHeartbeat(context.Context, *ParticipantHeartbeatReq) (*HealthCheckResp, error)
	// reportAvailable 监控数据上报
	ReportAvailable(context.Context, *ParticipantAvailReq) (*ParticipantResp, error)
	// contains filtered or unexported methods
}

ParticipantServiceServer is the server API for ParticipantService service. All implementations must embed UnimplementedParticipantServiceServer for forward compatibility

type ParticipantTenant added in v0.1.7 

type ParticipantTenant struct {
	TenantName string `protobuf:"bytes,1,opt,name=tenantName,proto3" json:"tenantName,omitempty"` //租户名称
	// contains filtered or unexported fields
}

participantTenant 租户信息

func (*ParticipantTenant) Descriptor deprecated added in v0.1.7 

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

Deprecated: Use ParticipantTenant.ProtoReflect.Descriptor instead.

func (*ParticipantTenant) GetTenantName added in v0.1.7 

func (x *ParticipantTenant) GetTenantName() string

func (*ParticipantTenant) ProtoMessage added in v0.1.7 

func (*ParticipantTenant) ProtoMessage()

func (*ParticipantTenant) ProtoReflect added in v0.1.7 

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

func (*ParticipantTenant) Reset added in v0.1.7 

func (x *ParticipantTenant) Reset()

func (*ParticipantTenant) String added in v0.1.7 

func (x *ParticipantTenant) String() string

type PcmCoreClient 

type PcmCoreClient interface {
	// SyncInfo Synchronous data information
	SyncInfo(ctx context.Context, in *SyncInfoReq, opts ...grpc.CallOption) (*SyncInfoResp, error)
	// InfoList
	InfoList(ctx context.Context, in *InfoListReq, opts ...grpc.CallOption) (*InfoListResp, error)
}

PcmCoreClient is the client API for PcmCore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPcmCoreClient 

func NewPcmCoreClient(cc grpc.ClientConnInterface) PcmCoreClient

type PcmCoreServer 

type PcmCoreServer interface {
	// SyncInfo Synchronous data information
	SyncInfo(context.Context, *SyncInfoReq) (*SyncInfoResp, error)
	// InfoList
	InfoList(context.Context, *InfoListReq) (*InfoListResp, error)
	// contains filtered or unexported methods
}

PcmCoreServer is the server API for PcmCore service. All implementations must embed UnimplementedPcmCoreServer for forward compatibility

type SyncInfoReq 

type SyncInfoReq struct {
	ParticipantId int64        `protobuf:"varint,1,opt,name=participantId,proto3" json:"participantId,omitempty"`
	Kind          string       `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
	HpcInfoList   []*HpcInfo   `protobuf:"bytes,3,rep,name=HpcInfoList,proto3" json:"HpcInfoList,omitempty"`
	CloudInfoList []*CloudInfo `protobuf:"bytes,4,rep,name=CloudInfoList,proto3" json:"CloudInfoList,omitempty"`
	AiInfoList    []*AiInfo    `protobuf:"bytes,5,rep,name=AiInfoList,proto3" json:"AiInfoList,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncInfoReq) Descriptor deprecated 

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

Deprecated: Use SyncInfoReq.ProtoReflect.Descriptor instead.

func (*SyncInfoReq) GetAiInfoList 

func (x *SyncInfoReq) GetAiInfoList() []*AiInfo

func (*SyncInfoReq) GetCloudInfoList 

func (x *SyncInfoReq) GetCloudInfoList() []*CloudInfo

func (*SyncInfoReq) GetHpcInfoList 

func (x *SyncInfoReq) GetHpcInfoList() []*HpcInfo

func (*SyncInfoReq) GetKind 

func (x *SyncInfoReq) GetKind() string

func (*SyncInfoReq) GetParticipantId added in v0.1.7 

func (x *SyncInfoReq) GetParticipantId() int64

func (*SyncInfoReq) ProtoMessage 

func (*SyncInfoReq) ProtoMessage()

func (*SyncInfoReq) ProtoReflect 

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

func (*SyncInfoReq) Reset 

func (x *SyncInfoReq) Reset()

func (*SyncInfoReq) String 

func (x *SyncInfoReq) String() string

type SyncInfoResp 

type SyncInfoResp struct {
	Code int64  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg  string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncInfoResp) Descriptor deprecated 

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

Deprecated: Use SyncInfoResp.ProtoReflect.Descriptor instead.

func (*SyncInfoResp) GetCode 

func (x *SyncInfoResp) GetCode() int64

func (*SyncInfoResp) GetMsg 

func (x *SyncInfoResp) GetMsg() string

func (*SyncInfoResp) ProtoMessage 

func (*SyncInfoResp) ProtoMessage()

func (*SyncInfoResp) ProtoReflect 

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

func (*SyncInfoResp) Reset 

func (x *SyncInfoResp) Reset()

func (*SyncInfoResp) String 

func (x *SyncInfoResp) String() string

type UnimplementedParticipantServiceServer added in v0.1.7 

type UnimplementedParticipantServiceServer struct {
}

UnimplementedParticipantServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedParticipantServiceServer) RegisterParticipant added in v0.1.7 

func (UnimplementedParticipantServiceServer) RegisterParticipant(context.Context, *ParticipantPhyReq) (*ParticipantPhyResp, error)

func (UnimplementedParticipantServiceServer) ReportAvailable added in v0.1.7 

func (UnimplementedParticipantServiceServer) ReportAvailable(context.Context, *ParticipantAvailReq) (*ParticipantResp, error)

func (UnimplementedParticipantServiceServer) ReportHeartbeat added in v0.1.7 

func (UnimplementedParticipantServiceServer) ReportHeartbeat(context.Context, *ParticipantHeartbeatReq) (*HealthCheckResp, error)

type UnimplementedPcmCoreServer 

type UnimplementedPcmCoreServer struct {
}

UnimplementedPcmCoreServer must be embedded to have forward compatible implementations.

func (UnimplementedPcmCoreServer) InfoList 

func (UnimplementedPcmCoreServer) InfoList(context.Context, *InfoListReq) (*InfoListResp, error)

func (UnimplementedPcmCoreServer) SyncInfo 

func (UnimplementedPcmCoreServer) SyncInfo(context.Context, *SyncInfoReq) (*SyncInfoResp, error)

type UnsafeParticipantServiceServer added in v0.1.7 

type UnsafeParticipantServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeParticipantServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ParticipantServiceServer will result in compilation errors.

type UnsafePcmCoreServer 

type UnsafePcmCoreServer interface {
	// contains filtered or unexported methods
}

UnsafePcmCoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PcmCoreServer will result in compilation errors.

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.