pcmCore

package

Go to main page

Versions in this module

v0

v0.1.19

Jan 5, 2024

Changes in this version

type InfoListResp

+ VmInfoList []*VmInfo

+ func (x *InfoListResp) GetVmInfoList() []*VmInfo

v0.1.18

Jan 3, 2024

Changes in this version

+ const ParticipantService_PauseList_FullMethodName

+ const ParticipantService_StartList_FullMethodName

type ParticipantServiceClient

+ PauseList func(ctx context.Context, in *ApplyListReq, opts ...grpc.CallOption) (*ApplyListResp, error)

+ StartList func(ctx context.Context, in *ApplyListReq, opts ...grpc.CallOption) (*ApplyListResp, error)

type ParticipantServiceServer

+ PauseList func(context.Context, *ApplyListReq) (*ApplyListResp, error)

+ StartList func(context.Context, *ApplyListReq) (*ApplyListResp, error)

type UnimplementedParticipantServiceServer

+ func (UnimplementedParticipantServiceServer) PauseList(context.Context, *ApplyListReq) (*ApplyListResp, error)

+ func (UnimplementedParticipantServiceServer) StartList(context.Context, *ApplyListReq) (*ApplyListResp, error)

v0.1.17

Jan 3, 2024

Changes in this version

type ApplyInfo

+ Kind string

+ func (x *ApplyInfo) GetKind() string

v0.1.16

Jan 3, 2024

v0.1.15

Jan 3, 2024

Changes in this version

+ const ParticipantService_RestartList_FullMethodName

type ApplyInfo

+ Name string

+ Namespace string

+ func (x *ApplyInfo) GetName() string

+ func (x *ApplyInfo) GetNamespace() string

type ParticipantServiceClient

+ RestartList func(ctx context.Context, in *ApplyListReq, opts ...grpc.CallOption) (*ApplyListResp, error)

type ParticipantServiceServer

+ RestartList func(context.Context, *ApplyListReq) (*ApplyListResp, error)

type UnimplementedParticipantServiceServer

+ func (UnimplementedParticipantServiceServer) RestartList(context.Context, *ApplyListReq) (*ApplyListResp, error)

v0.1.14

Jan 3, 2024

Changes in this version

+ const ParticipantService_ApplyList_FullMethodName

+ const ParticipantService_DeleteList_FullMethodName

+ type ApplyInfo struct

+ ParticipantName string

+ YamlString string

+ func (*ApplyInfo) Descriptor() ([]byte, []int)

+ func (*ApplyInfo) ProtoMessage()

+ func (x *ApplyInfo) GetParticipantName() string

+ func (x *ApplyInfo) GetYamlString() string

+ func (x *ApplyInfo) ProtoReflect() protoreflect.Message

+ func (x *ApplyInfo) Reset()

+ func (x *ApplyInfo) String() string

+ type ApplyListReq struct

+ func (*ApplyListReq) Descriptor() ([]byte, []int)

+ func (*ApplyListReq) ProtoMessage()

+ func (x *ApplyListReq) ProtoReflect() protoreflect.Message

+ func (x *ApplyListReq) Reset()

+ func (x *ApplyListReq) String() string

+ type ApplyListResp struct

+ InfoList []*ApplyInfo

+ func (*ApplyListResp) Descriptor() ([]byte, []int)

+ func (*ApplyListResp) ProtoMessage()

+ func (x *ApplyListResp) GetInfoList() []*ApplyInfo

+ func (x *ApplyListResp) ProtoReflect() protoreflect.Message

+ func (x *ApplyListResp) Reset()

+ func (x *ApplyListResp) String() string

type CloudInfo

+ Id int64

+ func (x *CloudInfo) GetId() int64

type ParticipantServiceClient

+ ApplyList func(ctx context.Context, in *ApplyListReq, opts ...grpc.CallOption) (*ApplyListResp, error)

+ DeleteList func(ctx context.Context, in *ApplyListReq, opts ...grpc.CallOption) (*ApplyListResp, error)

type ParticipantServiceServer

+ ApplyList func(context.Context, *ApplyListReq) (*ApplyListResp, error)

+ DeleteList func(context.Context, *ApplyListReq) (*ApplyListResp, error)

type UnimplementedParticipantServiceServer

+ func (UnimplementedParticipantServiceServer) ApplyList(context.Context, *ApplyListReq) (*ApplyListResp, error)

+ func (UnimplementedParticipantServiceServer) DeleteList(context.Context, *ApplyListReq) (*ApplyListResp, error)

v0.1.13

Nov 23, 2023

Changes in this version

+ var File_pb_pcmCore_proto protoreflect.FileDescriptor

type HpcInfo

+ Environment string

+ StdInput string

+ func (x *HpcInfo) GetEnvironment() string

+ func (x *HpcInfo) GetStdInput() string

type ParticipantPhyReq

+ Token string

+ func (x *ParticipantPhyReq) GetToken() string

type VmInfo

+ State string

+ func (x *VmInfo) GetState() string

v0.1.12

Nov 14, 2023

Changes in this version

type SyncInfoReq

+ VmInfoList []*VmInfo

+ func (x *SyncInfoReq) GetVmInfoList() []*VmInfo

+ type VmInfo struct

+ BlockUuid string

+ DeleteOnTermination bool

+ FlavorRef string

+ ImageRef string

+ Name string

+ NetworkUuid string

+ ParticipantId int64

+ SourceType string

+ TaskId int64

+ func (*VmInfo) Descriptor() ([]byte, []int)

+ func (*VmInfo) ProtoMessage()

+ func (x *VmInfo) GetBlockUuid() string

+ func (x *VmInfo) GetDeleteOnTermination() bool

+ func (x *VmInfo) GetFlavorRef() string

+ func (x *VmInfo) GetImageRef() string

+ func (x *VmInfo) GetName() string

+ func (x *VmInfo) GetNetworkUuid() string

+ func (x *VmInfo) GetParticipantId() int64

+ func (x *VmInfo) GetSourceType() string

+ func (x *VmInfo) GetTaskId() int64

+ func (x *VmInfo) ProtoReflect() protoreflect.Message

+ func (x *VmInfo) Reset()

+ func (x *VmInfo) String() string

v0.1.11

Nov 8, 2023

v0.1.10

Nov 7, 2023

v0.1.9

Nov 7, 2023

v0.1.8

Nov 3, 2023

Changes in this version

+ const ParticipantService_ListParticipant_FullMethodName

+ const ParticipantService_ListPhyAvailable_FullMethodName

+ const ParticipantService_ListPhyInformation_FullMethodName

+ const ParticipantService_ListTenant_FullMethodName

+ const ParticipantService_RegisterTenant_FullMethodName

+ type ClientInfo struct

+ Address string

+ ClientState string

+ LastHeartbeat int64

+ ParticipantId int64

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

+ func (*ClientInfo) ProtoMessage()

+ func (x *ClientInfo) GetAddress() string

+ func (x *ClientInfo) GetClientState() string

+ func (x *ClientInfo) GetLastHeartbeat() int64

+ func (x *ClientInfo) GetParticipantId() int64

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

+ func (x *ClientInfo) Reset()

+ func (x *ClientInfo) String() string

type HpcInfo

+ AppName string

+ AppType string

+ NNode string

+ Queue string

+ StdErrFile string

+ StdOutFile string

+ SubmitType string

+ func (x *HpcInfo) GetAppName() string

+ func (x *HpcInfo) GetAppType() string

+ func (x *HpcInfo) GetNNode() string

+ func (x *HpcInfo) GetQueue() string

+ func (x *HpcInfo) GetStdErrFile() string

+ func (x *HpcInfo) GetStdOutFile() string

+ func (x *HpcInfo) GetSubmitType() string

+ type ListParticipantAvailResp struct

+ Code int64

+ Msg string

+ ParticipantAvails []*ParticipantAvailReq

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

+ func (*ListParticipantAvailResp) ProtoMessage()

+ func (x *ListParticipantAvailResp) GetCode() int64

+ func (x *ListParticipantAvailResp) GetMsg() string

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

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

+ func (x *ListParticipantAvailResp) Reset()

+ func (x *ListParticipantAvailResp) String() string

+ type ListParticipantPhyResp struct

+ Code int64

+ Msg string

+ ParticipantPhys []*ParticipantPhyReq

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

+ func (*ListParticipantPhyResp) ProtoMessage()

+ func (x *ListParticipantPhyResp) GetCode() int64

+ func (x *ListParticipantPhyResp) GetMsg() string

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

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

+ func (x *ListParticipantPhyResp) Reset()

+ func (x *ListParticipantPhyResp) String() string

+ type ListTenantResp struct

+ Code int64

+ Msg string

+ TenantInfos []*TenantInfo

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

+ func (*ListTenantResp) ProtoMessage()

+ func (x *ListTenantResp) GetCode() int64

+ func (x *ListTenantResp) GetMsg() string

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

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

+ func (x *ListTenantResp) Reset()

+ func (x *ListTenantResp) String() string

type NodeAvailInfo

+ ParticipantId int64

+ func (x *NodeAvailInfo) GetParticipantId() int64

type ParticipantHeartbeatReq

+ Address string

+ func (x *ParticipantHeartbeatReq) GetAddress() string

type ParticipantPhyReq

+ Address string

+ Id int64

+ MetricsUrl string

+ QueueInfo []*QueuePhyInfo

+ RpcAddress string

+ func (x *ParticipantPhyReq) GetAddress() string

+ func (x *ParticipantPhyReq) GetId() int64

+ func (x *ParticipantPhyReq) GetMetricsUrl() string

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

+ func (x *ParticipantPhyReq) GetRpcAddress() string

type ParticipantServiceClient

+ ListParticipant func(ctx context.Context, in *ParticipantTenant, opts ...grpc.CallOption) (*ParticipantServiceResp, error)

+ ListPhyAvailable func(ctx context.Context, in *ParticipantTenant, opts ...grpc.CallOption) (*ListParticipantAvailResp, error)

+ ListPhyInformation func(ctx context.Context, in *ParticipantTenant, opts ...grpc.CallOption) (*ListParticipantPhyResp, error)

+ ListTenant func(ctx context.Context, in *TenantInfo, opts ...grpc.CallOption) (*ListTenantResp, error)

+ RegisterTenant func(ctx context.Context, in *TenantInfo, opts ...grpc.CallOption) (*TenantResp, error)

+ type ParticipantServiceResp struct

+ Code int64

+ Data []*ClientInfo

+ Msg string

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

+ func (*ParticipantServiceResp) ProtoMessage()

+ func (x *ParticipantServiceResp) GetCode() int64

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

+ func (x *ParticipantServiceResp) GetMsg() string

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

+ func (x *ParticipantServiceResp) Reset()

+ func (x *ParticipantServiceResp) String() string

type ParticipantServiceServer

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

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

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

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

+ RegisterTenant func(context.Context, *TenantInfo) (*TenantResp, error)

+ type QueuePhyInfo struct

+ AclHosts string

+ Id int64

+ QueChargeRate string

+ QueFreeNcpus string

+ QueFreeNodes string

+ QueMaxDcuPN string

+ QueMaxGpuPN string

+ QueMaxNcpus string

+ QueMaxNdcus string

+ QueMaxNgpus string

+ QueMaxNodect string

+ QueMaxPpn string

+ QueMaxWalltime string

+ QueMinNcpus string

+ QueMinNodect string

+ QueNcpus string

+ QueNodes string

+ QueueId string

+ QueueName string

+ Text string

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

+ func (*QueuePhyInfo) ProtoMessage()

+ func (x *QueuePhyInfo) GetAclHosts() string

+ func (x *QueuePhyInfo) GetId() int64

+ func (x *QueuePhyInfo) GetQueChargeRate() string

+ func (x *QueuePhyInfo) GetQueFreeNcpus() string

+ func (x *QueuePhyInfo) GetQueFreeNodes() string

+ func (x *QueuePhyInfo) GetQueMaxDcuPN() string

+ func (x *QueuePhyInfo) GetQueMaxGpuPN() string

+ func (x *QueuePhyInfo) GetQueMaxNcpus() string

+ func (x *QueuePhyInfo) GetQueMaxNdcus() string

+ func (x *QueuePhyInfo) GetQueMaxNgpus() string

+ func (x *QueuePhyInfo) GetQueMaxNodect() string

+ func (x *QueuePhyInfo) GetQueMaxPpn() string

+ func (x *QueuePhyInfo) GetQueMaxWalltime() string

+ func (x *QueuePhyInfo) GetQueMinNcpus() string

+ func (x *QueuePhyInfo) GetQueMinNodect() string

+ func (x *QueuePhyInfo) GetQueNcpus() string

+ func (x *QueuePhyInfo) GetQueNodes() string

+ func (x *QueuePhyInfo) GetQueueId() string

+ func (x *QueuePhyInfo) GetQueueName() string

+ func (x *QueuePhyInfo) GetText() string

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

+ func (x *QueuePhyInfo) Reset()

+ func (x *QueuePhyInfo) String() string

+ type TenantInfo struct

+ Id int64

+ TenantDesc string

+ TenantName string

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

+ func (*TenantInfo) ProtoMessage()

+ func (x *TenantInfo) GetId() int64

+ func (x *TenantInfo) GetTenantDesc() string

+ func (x *TenantInfo) GetTenantName() string

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

+ func (x *TenantInfo) Reset()

+ func (x *TenantInfo) String() string

+ type TenantResp struct

+ Code int64

+ Id int64

+ Msg string

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

+ func (*TenantResp) ProtoMessage()

+ func (x *TenantResp) GetCode() int64

+ func (x *TenantResp) GetId() int64

+ func (x *TenantResp) GetMsg() string

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

+ func (x *TenantResp) Reset()

+ func (x *TenantResp) String() string

type UnimplementedParticipantServiceServer

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

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

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

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

+ func (UnimplementedParticipantServiceServer) RegisterTenant(context.Context, *TenantInfo) (*TenantResp, error)

v0.1.7

Jul 27, 2023

Changes in this version

+ const ParticipantService_RegisterParticipant_FullMethodName

+ const ParticipantService_ReportAvailable_FullMethodName

+ const ParticipantService_ReportHeartbeat_FullMethodName

+ var MessageStatus_name = map[int32]string

+ var MessageStatus_value = map[string]int32

+ var ParticipantService_ServiceDesc = grpc.ServiceDesc

+ func RegisterParticipantServiceServer(s grpc.ServiceRegistrar, srv ParticipantServiceServer)

type AiInfo

+ ParticipantId int64

+ func (x *AiInfo) GetParticipantId() int64

type CloudInfo

+ Participant int64

+ func (x *CloudInfo) GetParticipant() int64

+ type HealthCheckResp struct

+ Code int64

+ MessageStatus MessageStatus

+ Msg string

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

+ func (*HealthCheckResp) ProtoMessage()

+ func (x *HealthCheckResp) GetCode() int64

+ func (x *HealthCheckResp) GetMessageStatus() MessageStatus

+ func (x *HealthCheckResp) GetMsg() string

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

+ func (x *HealthCheckResp) Reset()

+ func (x *HealthCheckResp) String() string

type HpcInfo

+ ParticipantId int64

+ func (x *HpcInfo) GetParticipantId() int64

type InfoListReq

+ ParticipantId int64

+ func (x *InfoListReq) GetParticipantId() int64

+ type MessageStatus int32

+ const MessageStatus_FAIL

+ const MessageStatus_SUCCESS

+ const MessageStatus_UNKNOWN

+ func (MessageStatus) Descriptor() protoreflect.EnumDescriptor

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

+ func (MessageStatus) Type() protoreflect.EnumType

+ func (x MessageStatus) Enum() *MessageStatus

+ func (x MessageStatus) Number() protoreflect.EnumNumber

+ func (x MessageStatus) String() string

+ type NodeAvailInfo struct

+ CpuTotal int64

+ CpuUsable float64

+ DiskAvail int64

+ DiskTotal int64

+ GpuAvail int64

+ GpuTotal int64

+ Id int64

+ MemAvail int64

+ MemTotal int64

+ NodeName string

+ ParticipantAvailId int64

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

+ func (*NodeAvailInfo) ProtoMessage()

+ func (x *NodeAvailInfo) GetCpuTotal() int64

+ func (x *NodeAvailInfo) GetCpuUsable() float64

+ func (x *NodeAvailInfo) GetDiskAvail() int64

+ func (x *NodeAvailInfo) GetDiskTotal() int64

+ func (x *NodeAvailInfo) GetGpuAvail() int64

+ func (x *NodeAvailInfo) GetGpuTotal() int64

+ func (x *NodeAvailInfo) GetId() int64

+ func (x *NodeAvailInfo) GetMemAvail() int64

+ func (x *NodeAvailInfo) GetMemTotal() int64

+ func (x *NodeAvailInfo) GetNodeName() string

+ func (x *NodeAvailInfo) GetParticipantAvailId() int64

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

+ func (x *NodeAvailInfo) Reset()

+ func (x *NodeAvailInfo) String() string

+ type NodePhyInfo struct

+ ArchFreq string

+ ArchName string

+ ArchType string

+ Id int64

+ NodeName string

+ OsName string

+ OsVersion string

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

+ func (*NodePhyInfo) ProtoMessage()

+ func (x *NodePhyInfo) GetArchFreq() string

+ func (x *NodePhyInfo) GetArchName() string

+ func (x *NodePhyInfo) GetArchType() string

+ func (x *NodePhyInfo) GetId() int64

+ func (x *NodePhyInfo) GetNodeName() string

+ func (x *NodePhyInfo) GetOsName() string

+ func (x *NodePhyInfo) GetOsVersion() string

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

+ func (x *NodePhyInfo) Reset()

+ func (x *NodePhyInfo) String() string

+ type ParticipantAvailReq struct

+ AvailStorageSpace int64

+ Id int64

+ NodeAvailInfo []*NodeAvailInfo

+ ParticipantId int64

+ PendingJobNum int64

+ RunningJobNum int64

+ UserNum int64

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

+ func (*ParticipantAvailReq) ProtoMessage()

+ func (x *ParticipantAvailReq) GetAvailStorageSpace() int64

+ func (x *ParticipantAvailReq) GetId() int64

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

+ func (x *ParticipantAvailReq) GetParticipantId() int64

+ func (x *ParticipantAvailReq) GetPendingJobNum() int64

+ func (x *ParticipantAvailReq) GetRunningJobNum() int64

+ func (x *ParticipantAvailReq) GetUserNum() int64

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

+ func (x *ParticipantAvailReq) Reset()

+ func (x *ParticipantAvailReq) String() string

+ type ParticipantHeartbeatReq struct

+ Host string

+ ParticipantId int64

+ Port string

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

+ func (*ParticipantHeartbeatReq) ProtoMessage()

+ func (x *ParticipantHeartbeatReq) GetHost() string

+ func (x *ParticipantHeartbeatReq) GetParticipantId() int64

+ func (x *ParticipantHeartbeatReq) GetPort() string

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

+ func (x *ParticipantHeartbeatReq) Reset()

+ func (x *ParticipantHeartbeatReq) String() string

+ type ParticipantLabel struct

+ Id int64

+ Key string

+ Value string

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

+ func (*ParticipantLabel) ProtoMessage()

+ func (x *ParticipantLabel) GetId() int64

+ func (x *ParticipantLabel) GetKey() string

+ func (x *ParticipantLabel) GetValue() string

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

+ func (x *ParticipantLabel) Reset()

+ func (x *ParticipantLabel) String() string

+ type ParticipantPhyReq struct

+ Host string

+ LabelInfo []*ParticipantLabel

+ Name string

+ NetworkBandwidth string

+ NetworkType string

+ NodeInfo []*NodePhyInfo

+ ParticipantId int64

+ Port string

+ StorageAvailSpace string

+ StorageBandwidth string

+ StorageSpace string

+ StorageType string

+ TenantId int64

+ TenantName string

+ Type string

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

+ func (*ParticipantPhyReq) ProtoMessage()

+ func (x *ParticipantPhyReq) GetHost() string

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

+ func (x *ParticipantPhyReq) GetName() string

+ func (x *ParticipantPhyReq) GetNetworkBandwidth() string

+ func (x *ParticipantPhyReq) GetNetworkType() string

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

+ func (x *ParticipantPhyReq) GetParticipantId() int64

+ func (x *ParticipantPhyReq) GetPort() string

+ func (x *ParticipantPhyReq) GetStorageAvailSpace() string

+ func (x *ParticipantPhyReq) GetStorageBandwidth() string

+ func (x *ParticipantPhyReq) GetStorageSpace() string

+ func (x *ParticipantPhyReq) GetStorageType() string

+ func (x *ParticipantPhyReq) GetTenantId() int64

+ func (x *ParticipantPhyReq) GetTenantName() string

+ func (x *ParticipantPhyReq) GetType() string

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

+ func (x *ParticipantPhyReq) Reset()

+ func (x *ParticipantPhyReq) String() string

+ type ParticipantPhyResp struct

+ Code int64

+ Msg string

+ ParticipantId int64

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

+ func (*ParticipantPhyResp) ProtoMessage()

+ func (x *ParticipantPhyResp) GetCode() int64

+ func (x *ParticipantPhyResp) GetMsg() string

+ func (x *ParticipantPhyResp) GetParticipantId() int64

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

+ func (x *ParticipantPhyResp) Reset()

+ func (x *ParticipantPhyResp) String() string

+ type ParticipantResp struct

+ Code int64

+ Msg string

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

+ func (*ParticipantResp) ProtoMessage()

+ func (x *ParticipantResp) GetCode() int64

+ func (x *ParticipantResp) GetMsg() string

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

+ func (x *ParticipantResp) Reset()

+ func (x *ParticipantResp) String() string

+ type ParticipantServiceClient interface

+ RegisterParticipant func(ctx context.Context, in *ParticipantPhyReq, opts ...grpc.CallOption) (*ParticipantPhyResp, error)

+ ReportAvailable func(ctx context.Context, in *ParticipantAvailReq, opts ...grpc.CallOption) (*ParticipantResp, error)

+ ReportHeartbeat func(ctx context.Context, in *ParticipantHeartbeatReq, opts ...grpc.CallOption) (*HealthCheckResp, error)

+ func NewParticipantServiceClient(cc grpc.ClientConnInterface) ParticipantServiceClient

+ type ParticipantServiceServer interface

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

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

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

+ type ParticipantTenant struct

+ TenantName string

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

+ func (*ParticipantTenant) ProtoMessage()

+ func (x *ParticipantTenant) GetTenantName() string

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

+ func (x *ParticipantTenant) Reset()

+ func (x *ParticipantTenant) String() string

type SyncInfoReq

+ ParticipantId int64

+ func (x *SyncInfoReq) GetParticipantId() int64

+ type UnimplementedParticipantServiceServer struct

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

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

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

+ type UnsafeParticipantServiceServer interface

v0.1.6

Jul 21, 2023

v0.1.5

Jul 14, 2023

Changes in this version

+ const PcmCore_InfoList_FullMethodName

+ const PcmCore_SyncInfo_FullMethodName

+ var File_pcmCore_proto protoreflect.FileDescriptor

+ var PcmCore_ServiceDesc = grpc.ServiceDesc

+ func RegisterPcmCoreServer(s grpc.ServiceRegistrar, srv PcmCoreServer)

+ type AiInfo struct

+ Command string

+ CreateTime string

+ FlavorId string

+ ImageUrl string

+ ItemVersionId string

+ JobId string

+ Name string

+ ProjectId string

+ Result string

+ RunningTime int64

+ ServiceName string

+ StartTime string

+ Status string

+ SubscriptionId string

+ TaskId int64

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

+ func (*AiInfo) ProtoMessage()

+ func (x *AiInfo) GetCommand() string

+ func (x *AiInfo) GetCreateTime() string

+ func (x *AiInfo) GetFlavorId() string

+ func (x *AiInfo) GetImageUrl() string

+ func (x *AiInfo) GetItemVersionId() string

+ func (x *AiInfo) GetJobId() string

+ func (x *AiInfo) GetName() string

+ func (x *AiInfo) GetProjectId() string

+ func (x *AiInfo) GetResult() string

+ func (x *AiInfo) GetRunningTime() int64

+ func (x *AiInfo) GetServiceName() string

+ func (x *AiInfo) GetStartTime() string

+ func (x *AiInfo) GetStatus() string

+ func (x *AiInfo) GetSubscriptionId() string

+ func (x *AiInfo) GetTaskId() int64

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

+ func (x *AiInfo) Reset()

+ func (x *AiInfo) String() string

+ type CloudInfo struct

+ ApiVersion string

+ Kind string

+ Name string

+ Namespace string

+ Result string

+ RunningTime int64

+ ServiceName string

+ StartTime string

+ Status string

+ TaskId int64

+ YamlString string

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

+ func (*CloudInfo) ProtoMessage()

+ func (x *CloudInfo) GetApiVersion() string

+ func (x *CloudInfo) GetKind() string

+ func (x *CloudInfo) GetName() string

+ func (x *CloudInfo) GetNamespace() string

+ func (x *CloudInfo) GetResult() string

+ func (x *CloudInfo) GetRunningTime() int64

+ func (x *CloudInfo) GetServiceName() string

+ func (x *CloudInfo) GetStartTime() string

+ func (x *CloudInfo) GetStatus() string

+ func (x *CloudInfo) GetTaskId() int64

+ func (x *CloudInfo) GetYamlString() string

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

+ func (x *CloudInfo) Reset()

+ func (x *CloudInfo) String() string

+ type HpcInfo struct

+ Account string

+ AllocCpu uint32

+ AllocNodes uint32

+ AssocId uint32

+ BlockId string

+ Cluster string

+ CmdScript string

+ DerivedEs string

+ ExitCode uint32

+ JobId string

+ Name string

+ Result string

+ RunningTime int64

+ ServiceName string

+ StartTime string

+ Status string

+ TaskId int64

+ Version string

+ WallTime string

+ WorkDir string

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

+ func (*HpcInfo) ProtoMessage()

+ func (x *HpcInfo) GetAccount() string

+ func (x *HpcInfo) GetAllocCpu() uint32

+ func (x *HpcInfo) GetAllocNodes() uint32

+ func (x *HpcInfo) GetAssocId() uint32

+ func (x *HpcInfo) GetBlockId() string

+ func (x *HpcInfo) GetCluster() string

+ func (x *HpcInfo) GetCmdScript() string

+ func (x *HpcInfo) GetDerivedEs() string

+ func (x *HpcInfo) GetExitCode() uint32

+ func (x *HpcInfo) GetJobId() string

+ func (x *HpcInfo) GetName() string

+ func (x *HpcInfo) GetResult() string

+ func (x *HpcInfo) GetRunningTime() int64

+ func (x *HpcInfo) GetServiceName() string

+ func (x *HpcInfo) GetStartTime() string

+ func (x *HpcInfo) GetStatus() string

+ func (x *HpcInfo) GetTaskId() int64

+ func (x *HpcInfo) GetVersion() string

+ func (x *HpcInfo) GetWallTime() string

+ func (x *HpcInfo) GetWorkDir() string

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

+ func (x *HpcInfo) Reset()

+ func (x *HpcInfo) String() string

+ type InfoListReq struct

+ Kind string

+ ServiceName string

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

+ func (*InfoListReq) ProtoMessage()

+ func (x *InfoListReq) GetKind() string

+ func (x *InfoListReq) GetServiceName() string

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

+ func (x *InfoListReq) Reset()

+ func (x *InfoListReq) String() string

+ type InfoListResp struct

+ AiInfoList []*AiInfo

+ CloudInfoList []*CloudInfo

+ HpcInfoList []*HpcInfo

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

+ func (*InfoListResp) ProtoMessage()

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

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

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

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

+ func (x *InfoListResp) Reset()

+ func (x *InfoListResp) String() string

+ type PcmCoreClient interface

+ InfoList func(ctx context.Context, in *InfoListReq, opts ...grpc.CallOption) (*InfoListResp, error)

+ SyncInfo func(ctx context.Context, in *SyncInfoReq, opts ...grpc.CallOption) (*SyncInfoResp, error)

+ func NewPcmCoreClient(cc grpc.ClientConnInterface) PcmCoreClient

+ type PcmCoreServer interface

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

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

+ type SyncInfoReq struct

+ AiInfoList []*AiInfo

+ CloudInfoList []*CloudInfo

+ HpcInfoList []*HpcInfo

+ Kind string

+ ServiceName string

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

+ func (*SyncInfoReq) ProtoMessage()

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

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

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

+ func (x *SyncInfoReq) GetKind() string

+ func (x *SyncInfoReq) GetServiceName() string

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

+ func (x *SyncInfoReq) Reset()

+ func (x *SyncInfoReq) String() string

+ type SyncInfoResp struct

+ Code int64

+ Msg string

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

+ func (*SyncInfoResp) ProtoMessage()

+ func (x *SyncInfoResp) GetCode() int64

+ func (x *SyncInfoResp) GetMsg() string

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

+ func (x *SyncInfoResp) Reset()

+ func (x *SyncInfoResp) String() string

+ type UnimplementedPcmCoreServer struct

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

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

+ type UnsafePcmCoreServer interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL