pcmCore

package
v0.1.8 Latest Latest
Warning

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

 Go to latest Published: Nov 3, 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"
	ParticipantService_ListParticipant_FullMethodName     = "/pcmCore.participantService/listParticipant"
	ParticipantService_ListPhyAvailable_FullMethodName    = "/pcmCore.participantService/listPhyAvailable"
	ParticipantService_ListPhyInformation_FullMethodName  = "/pcmCore.participantService/listPhyInformation"
	ParticipantService_RegisterTenant_FullMethodName      = "/pcmCore.participantService/registerTenant"
	ParticipantService_ListTenant_FullMethodName          = "/pcmCore.participantService/listTenant"
)

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,
		},
		{
			MethodName: "listParticipant",
			Handler:    _ParticipantService_ListParticipant_Handler,
		},
		{
			MethodName: "listPhyAvailable",
			Handler:    _ParticipantService_ListPhyAvailable_Handler,
		},
		{
			MethodName: "listPhyInformation",
			Handler:    _ParticipantService_ListPhyInformation_Handler,
		},
		{
			MethodName: "registerTenant",
			Handler:    _ParticipantService_RegisterTenant_Handler,
		},
		{
			MethodName: "listTenant",
			Handler:    _ParticipantService_ListTenant_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 ClientInfo added in v0.1.8 

type ClientInfo struct {
	Address       string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`              // @gotags: redis:"address"
	ParticipantId int64  `protobuf:"varint,2,opt,name=participantId,proto3" json:"participantId,omitempty"` // @gotags: redis:"participantId"
	ClientState   string `protobuf:"bytes,3,opt,name=clientState,proto3" json:"clientState,omitempty"`      // @gotags: redis:"clientState"
	LastHeartbeat int64  `protobuf:"varint,4,opt,name=lastHeartbeat,proto3" json:"lastHeartbeat,omitempty"` // @gotags: redis:"lastHeartbeat"
	// contains filtered or unexported fields
}

func (*ClientInfo) Descriptor deprecated added in v0.1.8 

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

Deprecated: Use ClientInfo.ProtoReflect.Descriptor instead.

func (*ClientInfo) GetAddress added in v0.1.8 

func (x *ClientInfo) GetAddress() string

func (*ClientInfo) GetClientState added in v0.1.8 

func (x *ClientInfo) GetClientState() string

func (*ClientInfo) GetLastHeartbeat added in v0.1.8 

func (x *ClientInfo) GetLastHeartbeat() int64

func (*ClientInfo) GetParticipantId added in v0.1.8 

func (x *ClientInfo) GetParticipantId() int64

func (*ClientInfo) ProtoMessage added in v0.1.8 

func (*ClientInfo) ProtoMessage()

func (*ClientInfo) ProtoReflect added in v0.1.8 

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

func (*ClientInfo) Reset added in v0.1.8 

func (x *ClientInfo) Reset()

func (*ClientInfo) String added in v0.1.8 

func (x *ClientInfo) 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"`
	AppType       string `protobuf:"bytes,21,opt,name=appType,proto3" json:"appType,omitempty"`
	AppName       string `protobuf:"bytes,22,opt,name=appName,proto3" json:"appName,omitempty"`
	Queue         string `protobuf:"bytes,23,opt,name=queue,proto3" json:"queue,omitempty"`
	SubmitType    string `protobuf:"bytes,24,opt,name=submitType,proto3" json:"submitType,omitempty"`
	NNode         string `protobuf:"bytes,25,opt,name=nNode,proto3" json:"nNode,omitempty"`
	StdOutFile    string `protobuf:"bytes,26,opt,name=stdOutFile,proto3" json:"stdOutFile,omitempty"`
	StdErrFile    string `protobuf:"bytes,27,opt,name=stdErrFile,proto3" json:"stdErrFile,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) GetAppName added in v0.1.8 

func (x *HpcInfo) GetAppName() string

func (*HpcInfo) GetAppType added in v0.1.8 

func (x *HpcInfo) GetAppType() string

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) GetNNode added in v0.1.8 

func (x *HpcInfo) GetNNode() string

func (*HpcInfo) GetName 

func (x *HpcInfo) GetName() string

func (*HpcInfo) GetParticipantId added in v0.1.7 

func (x *HpcInfo) GetParticipantId() int64

func (*HpcInfo) GetQueue added in v0.1.8 

func (x *HpcInfo) GetQueue() string

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) GetStdErrFile added in v0.1.8 

func (x *HpcInfo) GetStdErrFile() string

func (*HpcInfo) GetStdOutFile added in v0.1.8 

func (x *HpcInfo) GetStdOutFile() string

func (*HpcInfo) GetSubmitType added in v0.1.8 

func (x *HpcInfo) GetSubmitType() 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 {
	ParticipantId int64 `protobuf:"varint,1,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) 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 ListParticipantAvailResp added in v0.1.8 

type ListParticipantAvailResp 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"`
	ParticipantAvails []*ParticipantAvailReq `protobuf:"bytes,3,rep,name=ParticipantAvails,proto3" json:"ParticipantAvails,omitempty"`
	// contains filtered or unexported fields
}

集群可用信息

func (*ListParticipantAvailResp) Descriptor deprecated added in v0.1.8 

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

Deprecated: Use ListParticipantAvailResp.ProtoReflect.Descriptor instead.

func (*ListParticipantAvailResp) GetCode added in v0.1.8 

func (x *ListParticipantAvailResp) GetCode() int64

func (*ListParticipantAvailResp) GetMsg added in v0.1.8 

func (x *ListParticipantAvailResp) GetMsg() string

func (*ListParticipantAvailResp) GetParticipantAvails added in v0.1.8 

func (x *ListParticipantAvailResp) GetParticipantAvails() []*ParticipantAvailReq

func (*ListParticipantAvailResp) ProtoMessage added in v0.1.8 

func (*ListParticipantAvailResp) ProtoMessage()

func (*ListParticipantAvailResp) ProtoReflect added in v0.1.8 

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

func (*ListParticipantAvailResp) Reset added in v0.1.8 

func (x *ListParticipantAvailResp) Reset()

func (*ListParticipantAvailResp) String added in v0.1.8 

func (x *ListParticipantAvailResp) String() string

type ListParticipantPhyResp added in v0.1.8 

type ListParticipantPhyResp 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"`
	ParticipantPhys []*ParticipantPhyReq `protobuf:"bytes,3,rep,name=ParticipantPhys,proto3" json:"ParticipantPhys,omitempty"`
	// contains filtered or unexported fields
}

集群静态信息返回

func (*ListParticipantPhyResp) Descriptor deprecated added in v0.1.8 

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

Deprecated: Use ListParticipantPhyResp.ProtoReflect.Descriptor instead.

func (*ListParticipantPhyResp) GetCode added in v0.1.8 

func (x *ListParticipantPhyResp) GetCode() int64

func (*ListParticipantPhyResp) GetMsg added in v0.1.8 

func (x *ListParticipantPhyResp) GetMsg() string

func (*ListParticipantPhyResp) GetParticipantPhys added in v0.1.8 

func (x *ListParticipantPhyResp) GetParticipantPhys() []*ParticipantPhyReq

func (*ListParticipantPhyResp) ProtoMessage added in v0.1.8 

func (*ListParticipantPhyResp) ProtoMessage()

func (*ListParticipantPhyResp) ProtoReflect added in v0.1.8 

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

func (*ListParticipantPhyResp) Reset added in v0.1.8 

func (x *ListParticipantPhyResp) Reset()

func (*ListParticipantPhyResp) String added in v0.1.8 

func (x *ListParticipantPhyResp) String() string

type ListTenantResp added in v0.1.8 

type ListTenantResp 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"`
	TenantInfos []*TenantInfo `protobuf:"bytes,3,rep,name=tenantInfos,proto3" json:"tenantInfos,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTenantResp) Descriptor deprecated added in v0.1.8 

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

Deprecated: Use ListTenantResp.ProtoReflect.Descriptor instead.

func (*ListTenantResp) GetCode added in v0.1.8 

func (x *ListTenantResp) GetCode() int64

func (*ListTenantResp) GetMsg added in v0.1.8 

func (x *ListTenantResp) GetMsg() string

func (*ListTenantResp) GetTenantInfos added in v0.1.8 

func (x *ListTenantResp) GetTenantInfos() []*TenantInfo

func (*ListTenantResp) ProtoMessage added in v0.1.8 

func (*ListTenantResp) ProtoMessage()

func (*ListTenantResp) ProtoReflect added in v0.1.8 

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

func (*ListTenantResp) Reset added in v0.1.8 

func (x *ListTenantResp) Reset()

func (*ListTenantResp) String added in v0.1.8 

func (x *ListTenantResp) 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可用数
	ParticipantId int64   `protobuf:"varint,11,opt,name=participantId,proto3" json:"participantId,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) GetParticipantId added in v0.1.8 

func (x *NodeAvailInfo) GetParticipantId() 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
	Address       string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// 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) GetAddress added in v0.1.8 

func (x *ParticipantHeartbeatReq) GetAddress() string

func (*ParticipantHeartbeatReq) GetParticipantId added in v0.1.7 

func (x *ParticipantHeartbeatReq) GetParticipantId() int64

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"`                           // 名称
	Address           string              `protobuf:"bytes,2,opt,name=address,proto3" json:"address,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"`                // 标签信息
	QueueInfo         []*QueuePhyInfo     `protobuf:"bytes,16,rep,name=queueInfo,proto3" json:"queueInfo,omitempty"`                // 队列信息
	Id                int64               `protobuf:"varint,17,opt,name=id,proto3" json:"id,omitempty"`                             // id
	MetricsUrl        string              `protobuf:"bytes,18,opt,name=MetricsUrl,proto3" json:"MetricsUrl,omitempty"`              //监控url
	RpcAddress        string              `protobuf:"bytes,19,opt,name=RpcAddress,proto3" json:"RpcAddress,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) GetAddress added in v0.1.8 

func (x *ParticipantPhyReq) GetAddress() string

func (*ParticipantPhyReq) GetId added in v0.1.8 

func (x *ParticipantPhyReq) GetId() int64

func (*ParticipantPhyReq) GetLabelInfo added in v0.1.7 

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

func (*ParticipantPhyReq) GetMetricsUrl added in v0.1.8 

func (x *ParticipantPhyReq) GetMetricsUrl() string

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) GetQueueInfo added in v0.1.8 

func (x *ParticipantPhyReq) GetQueueInfo() []*QueuePhyInfo

func (*ParticipantPhyReq) GetRpcAddress added in v0.1.8 

func (x *ParticipantPhyReq) GetRpcAddress() 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)
	// listParticipant 服务列表
	ListParticipant(ctx context.Context, in *ParticipantTenant, opts ...grpc.CallOption) (*ParticipantServiceResp, error)
	// listAvailable 集群动态信息列表
	ListPhyAvailable(ctx context.Context, in *ParticipantTenant, opts ...grpc.CallOption) (*ListParticipantAvailResp, error)
	// listPhyInformation 集群静态信息列表
	ListPhyInformation(ctx context.Context, in *ParticipantTenant, opts ...grpc.CallOption) (*ListParticipantPhyResp, error)
	// registerTenant 注册租户信息
	RegisterTenant(ctx context.Context, in *TenantInfo, opts ...grpc.CallOption) (*TenantResp, error)
	// listTenant 租户列表信息
	ListTenant(ctx context.Context, in *TenantInfo, opts ...grpc.CallOption) (*ListTenantResp, 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 ParticipantServiceResp added in v0.1.8 

type ParticipantServiceResp 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"`
	Data []*ClientInfo `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ParticipantServiceResp) Descriptor deprecated added in v0.1.8 

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

Deprecated: Use ParticipantServiceResp.ProtoReflect.Descriptor instead.

func (*ParticipantServiceResp) GetCode added in v0.1.8 

func (x *ParticipantServiceResp) GetCode() int64

func (*ParticipantServiceResp) GetData added in v0.1.8 

func (x *ParticipantServiceResp) GetData() []*ClientInfo

func (*ParticipantServiceResp) GetMsg added in v0.1.8 

func (x *ParticipantServiceResp) GetMsg() string

func (*ParticipantServiceResp) ProtoMessage added in v0.1.8 

func (*ParticipantServiceResp) ProtoMessage()

func (*ParticipantServiceResp) ProtoReflect added in v0.1.8 

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

func (*ParticipantServiceResp) Reset added in v0.1.8 

func (x *ParticipantServiceResp) Reset()

func (*ParticipantServiceResp) String added in v0.1.8 

func (x *ParticipantServiceResp) String() string

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)
	// listParticipant 服务列表
	ListParticipant(context.Context, *ParticipantTenant) (*ParticipantServiceResp, error)
	// listAvailable 集群动态信息列表
	ListPhyAvailable(context.Context, *ParticipantTenant) (*ListParticipantAvailResp, error)
	// listPhyInformation 集群静态信息列表
	ListPhyInformation(context.Context, *ParticipantTenant) (*ListParticipantPhyResp, error)
	// registerTenant 注册租户信息
	RegisterTenant(context.Context, *TenantInfo) (*TenantResp, error)
	// listTenant 租户列表信息
	ListTenant(context.Context, *TenantInfo) (*ListTenantResp, 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 QueuePhyInfo added in v0.1.8 

type QueuePhyInfo struct {
	Id             int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`                         // id
	AclHosts       string `protobuf:"bytes,2,opt,name=aclHosts,proto3" json:"aclHosts,omitempty"`              // 可用节点，多个节点用逗号隔开
	QueueId        string `protobuf:"bytes,3,opt,name=queueId,proto3" json:"queueId,omitempty"`                // 队列名称
	Text           string `protobuf:"bytes,4,opt,name=text,proto3" json:"text,omitempty"`                      // 队列名称
	QueueName      string `protobuf:"bytes,5,opt,name=queueName,proto3" json:"queueName,omitempty"`            //队列名称
	QueNodes       string `protobuf:"bytes,6,opt,name=queNodes,proto3" json:"queNodes,omitempty"`              // 队列节点总数
	QueMinNodect   string `protobuf:"bytes,7,opt,name=queMinNodect,proto3" json:"queMinNodect,omitempty"`      // 队列最小节点数
	QueMaxNgpus    string `protobuf:"bytes,8,opt,name=queMaxNgpus,proto3" json:"queMaxNgpus,omitempty"`        // 队列最大GPU卡数
	QueMaxPpn      string `protobuf:"bytes,9,opt,name=queMaxPpn,proto3" json:"queMaxPpn,omitempty"`            // 使用该队列作业最大CPU核心数
	QueChargeRate  string `protobuf:"bytes,10,opt,name=queChargeRate,proto3" json:"queChargeRate,omitempty"`   // 费率
	QueMaxNcpus    string `protobuf:"bytes,11,opt,name=queMaxNcpus,proto3" json:"queMaxNcpus,omitempty"`       // 用户最大可用核心数
	QueMaxNdcus    string `protobuf:"bytes,12,opt,name=queMaxNdcus,proto3" json:"queMaxNdcus,omitempty"`       // 队列总DCU卡数
	QueMinNcpus    string `protobuf:"bytes,13,opt,name=queMinNcpus,proto3" json:"queMinNcpus,omitempty"`       // 队列最小CPU核数
	QueFreeNodes   string `protobuf:"bytes,14,opt,name=queFreeNodes,proto3" json:"queFreeNodes,omitempty"`     // 队列空闲节点数
	QueMaxNodect   string `protobuf:"bytes,15,opt,name=queMaxNodect,proto3" json:"queMaxNodect,omitempty"`     // 队列作业最大节点数
	QueMaxGpuPN    string `protobuf:"bytes,16,opt,name=queMaxGpuPN,proto3" json:"queMaxGpuPN,omitempty"`       // 队列单作业最大GPU卡数
	QueMaxWalltime string `protobuf:"bytes,17,opt,name=queMaxWalltime,proto3" json:"queMaxWalltime,omitempty"` // 队列最大运行时间
	QueMaxDcuPN    string `protobuf:"bytes,18,opt,name=queMaxDcuPN,proto3" json:"queMaxDcuPN,omitempty"`       // 队列单作业最大DCU卡数
	QueNcpus       string `protobuf:"bytes,19,opt,name=queNcpus,proto3" json:"queNcpus,omitempty"`             //队列cpu数
	QueFreeNcpus   string `protobuf:"bytes,20,opt,name=queFreeNcpus,proto3" json:"queFreeNcpus,omitempty"`     //队列空闲cpu数
	// contains filtered or unexported fields
}

QueuePhyInfo 队列信息

func (*QueuePhyInfo) Descriptor deprecated added in v0.1.8 

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

Deprecated: Use QueuePhyInfo.ProtoReflect.Descriptor instead.

func (*QueuePhyInfo) GetAclHosts added in v0.1.8 

func (x *QueuePhyInfo) GetAclHosts() string

func (*QueuePhyInfo) GetId added in v0.1.8 

func (x *QueuePhyInfo) GetId() int64

func (*QueuePhyInfo) GetQueChargeRate added in v0.1.8 

func (x *QueuePhyInfo) GetQueChargeRate() string

func (*QueuePhyInfo) GetQueFreeNcpus added in v0.1.8 

func (x *QueuePhyInfo) GetQueFreeNcpus() string

func (*QueuePhyInfo) GetQueFreeNodes added in v0.1.8 

func (x *QueuePhyInfo) GetQueFreeNodes() string

func (*QueuePhyInfo) GetQueMaxDcuPN added in v0.1.8 

func (x *QueuePhyInfo) GetQueMaxDcuPN() string

func (*QueuePhyInfo) GetQueMaxGpuPN added in v0.1.8 

func (x *QueuePhyInfo) GetQueMaxGpuPN() string

func (*QueuePhyInfo) GetQueMaxNcpus added in v0.1.8 

func (x *QueuePhyInfo) GetQueMaxNcpus() string

func (*QueuePhyInfo) GetQueMaxNdcus added in v0.1.8 

func (x *QueuePhyInfo) GetQueMaxNdcus() string

func (*QueuePhyInfo) GetQueMaxNgpus added in v0.1.8 

func (x *QueuePhyInfo) GetQueMaxNgpus() string

func (*QueuePhyInfo) GetQueMaxNodect added in v0.1.8 

func (x *QueuePhyInfo) GetQueMaxNodect() string

func (*QueuePhyInfo) GetQueMaxPpn added in v0.1.8 

func (x *QueuePhyInfo) GetQueMaxPpn() string

func (*QueuePhyInfo) GetQueMaxWalltime added in v0.1.8 

func (x *QueuePhyInfo) GetQueMaxWalltime() string

func (*QueuePhyInfo) GetQueMinNcpus added in v0.1.8 

func (x *QueuePhyInfo) GetQueMinNcpus() string

func (*QueuePhyInfo) GetQueMinNodect added in v0.1.8 

func (x *QueuePhyInfo) GetQueMinNodect() string

func (*QueuePhyInfo) GetQueNcpus added in v0.1.8 

func (x *QueuePhyInfo) GetQueNcpus() string

func (*QueuePhyInfo) GetQueNodes added in v0.1.8 

func (x *QueuePhyInfo) GetQueNodes() string

func (*QueuePhyInfo) GetQueueId added in v0.1.8 

func (x *QueuePhyInfo) GetQueueId() string

func (*QueuePhyInfo) GetQueueName added in v0.1.8 

func (x *QueuePhyInfo) GetQueueName() string

func (*QueuePhyInfo) GetText added in v0.1.8 

func (x *QueuePhyInfo) GetText() string

func (*QueuePhyInfo) ProtoMessage added in v0.1.8 

func (*QueuePhyInfo) ProtoMessage()

func (*QueuePhyInfo) ProtoReflect added in v0.1.8 

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

func (*QueuePhyInfo) Reset added in v0.1.8 

func (x *QueuePhyInfo) Reset()

func (*QueuePhyInfo) String added in v0.1.8 

func (x *QueuePhyInfo) String() string

type SyncInfoReq 

type SyncInfoReq struct {
	ParticipantId int64        `protobuf:"varint,1,opt,name=participantId,proto3" json:"participantId,omitempty"`
	HpcInfoList   []*HpcInfo   `protobuf:"bytes,2,rep,name=HpcInfoList,proto3" json:"HpcInfoList,omitempty"`
	CloudInfoList []*CloudInfo `protobuf:"bytes,3,rep,name=CloudInfoList,proto3" json:"CloudInfoList,omitempty"`
	AiInfoList    []*AiInfo    `protobuf:"bytes,4,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) 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 TenantInfo added in v0.1.8 

type TenantInfo struct {
	Id         int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	TenantName string `protobuf:"bytes,2,opt,name=tenantName,proto3" json:"tenantName,omitempty"`
	TenantDesc string `protobuf:"bytes,3,opt,name=tenantDesc,proto3" json:"tenantDesc,omitempty"`
	// contains filtered or unexported fields
}

func (*TenantInfo) Descriptor deprecated added in v0.1.8 

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

Deprecated: Use TenantInfo.ProtoReflect.Descriptor instead.

func (*TenantInfo) GetId added in v0.1.8 

func (x *TenantInfo) GetId() int64

func (*TenantInfo) GetTenantDesc added in v0.1.8 

func (x *TenantInfo) GetTenantDesc() string

func (*TenantInfo) GetTenantName added in v0.1.8 

func (x *TenantInfo) GetTenantName() string

func (*TenantInfo) ProtoMessage added in v0.1.8 

func (*TenantInfo) ProtoMessage()

func (*TenantInfo) ProtoReflect added in v0.1.8 

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

func (*TenantInfo) Reset added in v0.1.8 

func (x *TenantInfo) Reset()

func (*TenantInfo) String added in v0.1.8 

func (x *TenantInfo) String() string

type TenantResp added in v0.1.8 

type TenantResp 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"`
	Id   int64  `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*TenantResp) Descriptor deprecated added in v0.1.8 

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

Deprecated: Use TenantResp.ProtoReflect.Descriptor instead.

func (*TenantResp) GetCode added in v0.1.8 

func (x *TenantResp) GetCode() int64

func (*TenantResp) GetId added in v0.1.8 

func (x *TenantResp) GetId() int64

func (*TenantResp) GetMsg added in v0.1.8 

func (x *TenantResp) GetMsg() string

func (*TenantResp) ProtoMessage added in v0.1.8 

func (*TenantResp) ProtoMessage()

func (*TenantResp) ProtoReflect added in v0.1.8 

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

func (*TenantResp) Reset added in v0.1.8 

func (x *TenantResp) Reset()

func (*TenantResp) String added in v0.1.8 

func (x *TenantResp) String() string

type UnimplementedParticipantServiceServer added in v0.1.7 

type UnimplementedParticipantServiceServer struct {
}

UnimplementedParticipantServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedParticipantServiceServer) ListParticipant added in v0.1.8 

func (UnimplementedParticipantServiceServer) ListParticipant(context.Context, *ParticipantTenant) (*ParticipantServiceResp, error)

func (UnimplementedParticipantServiceServer) ListPhyAvailable added in v0.1.8 

func (UnimplementedParticipantServiceServer) ListPhyAvailable(context.Context, *ParticipantTenant) (*ListParticipantAvailResp, error)

func (UnimplementedParticipantServiceServer) ListPhyInformation added in v0.1.8 

func (UnimplementedParticipantServiceServer) ListPhyInformation(context.Context, *ParticipantTenant) (*ListParticipantPhyResp, error)

func (UnimplementedParticipantServiceServer) ListTenant added in v0.1.8 

func (UnimplementedParticipantServiceServer) ListTenant(context.Context, *TenantInfo) (*ListTenantResp, error)

func (UnimplementedParticipantServiceServer) RegisterParticipant added in v0.1.7 

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

func (UnimplementedParticipantServiceServer) RegisterTenant added in v0.1.8 

func (UnimplementedParticipantServiceServer) RegisterTenant(context.Context, *TenantInfo) (*TenantResp, 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.