Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterPcmCoreServer(s grpc.ServiceRegistrar, srv PcmCoreServer)
- type AiInfo
- func (*AiInfo) Descriptor() ([]byte, []int)deprecated
- 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 (*AiInfo) ProtoMessage()
- func (x *AiInfo) ProtoReflect() protoreflect.Message
- func (x *AiInfo) Reset()
- func (x *AiInfo) String() string
- type CloudInfo
- func (*CloudInfo) Descriptor() ([]byte, []int)deprecated
- 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 (*CloudInfo) ProtoMessage()
- func (x *CloudInfo) ProtoReflect() protoreflect.Message
- func (x *CloudInfo) Reset()
- func (x *CloudInfo) String() string
- type HpcInfo
- func (*HpcInfo) Descriptor() ([]byte, []int)deprecated
- 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 (*HpcInfo) ProtoMessage()
- func (x *HpcInfo) ProtoReflect() protoreflect.Message
- func (x *HpcInfo) Reset()
- func (x *HpcInfo) String() string
- type InfoListReq
- func (*InfoListReq) Descriptor() ([]byte, []int)deprecated
- func (x *InfoListReq) GetKind() string
- func (x *InfoListReq) GetServiceName() string
- func (*InfoListReq) ProtoMessage()
- func (x *InfoListReq) ProtoReflect() protoreflect.Message
- func (x *InfoListReq) Reset()
- func (x *InfoListReq) String() string
- type InfoListResp
- func (*InfoListResp) Descriptor() ([]byte, []int)deprecated
- func (x *InfoListResp) GetAiInfoList() []*AiInfo
- func (x *InfoListResp) GetCloudInfoList() []*CloudInfo
- func (x *InfoListResp) GetHpcInfoList() []*HpcInfo
- func (*InfoListResp) ProtoMessage()
- func (x *InfoListResp) ProtoReflect() protoreflect.Message
- func (x *InfoListResp) Reset()
- func (x *InfoListResp) String() string
- type PcmCoreClient
- type PcmCoreServer
- type SyncInfoReq
- func (*SyncInfoReq) Descriptor() ([]byte, []int)deprecated
- 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 (*SyncInfoReq) ProtoMessage()
- func (x *SyncInfoReq) ProtoReflect() protoreflect.Message
- func (x *SyncInfoReq) Reset()
- func (x *SyncInfoReq) String() string
- type SyncInfoResp
- func (*SyncInfoResp) Descriptor() ([]byte, []int)deprecated
- func (x *SyncInfoResp) GetCode() int64
- func (x *SyncInfoResp) GetMsg() string
- func (*SyncInfoResp) ProtoMessage()
- func (x *SyncInfoResp) ProtoReflect() protoreflect.Message
- func (x *SyncInfoResp) Reset()
- func (x *SyncInfoResp) String() string
- type UnimplementedPcmCoreServer
- type UnsafePcmCoreServer
Constants ¶
const ( PcmCore_SyncInfo_FullMethodName = "/pcmCore.pcmCore/SyncInfo" PcmCore_InfoList_FullMethodName = "/pcmCore.pcmCore/InfoList" )
Variables ¶
var File_pcmCore_proto protoreflect.FileDescriptor
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 RegisterPcmCoreServer ¶
func RegisterPcmCoreServer(s grpc.ServiceRegistrar, srv PcmCoreServer)
Types ¶
type AiInfo ¶
type AiInfo struct { ServiceName string `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,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) GetCommand ¶
func (*AiInfo) GetCreateTime ¶
func (*AiInfo) GetFlavorId ¶
func (*AiInfo) GetImageUrl ¶
func (*AiInfo) GetItemVersionId ¶
func (*AiInfo) GetProjectId ¶
func (*AiInfo) GetRunningTime ¶
func (*AiInfo) GetServiceName ¶
func (*AiInfo) GetStartTime ¶
func (*AiInfo) GetSubscriptionId ¶
func (*AiInfo) ProtoMessage ¶
func (*AiInfo) ProtoMessage()
func (*AiInfo) ProtoReflect ¶
func (x *AiInfo) ProtoReflect() protoreflect.Message
type CloudInfo ¶
type CloudInfo struct { ServiceName string `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,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) GetApiVersion ¶
func (*CloudInfo) GetNamespace ¶
func (*CloudInfo) GetRunningTime ¶
func (*CloudInfo) GetServiceName ¶
func (*CloudInfo) GetStartTime ¶
func (*CloudInfo) GetYamlString ¶
func (*CloudInfo) ProtoMessage ¶
func (*CloudInfo) ProtoMessage()
func (*CloudInfo) ProtoReflect ¶
func (x *CloudInfo) ProtoReflect() protoreflect.Message
type HpcInfo ¶
type HpcInfo struct { ServiceName string `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,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) GetAccount ¶
func (*HpcInfo) GetAllocCpu ¶
func (*HpcInfo) GetAllocNodes ¶
func (*HpcInfo) GetAssocId ¶
func (*HpcInfo) GetBlockId ¶
func (*HpcInfo) GetCluster ¶
func (*HpcInfo) GetCmdScript ¶
func (*HpcInfo) GetDerivedEs ¶
func (*HpcInfo) GetExitCode ¶
func (*HpcInfo) GetRunningTime ¶
func (*HpcInfo) GetServiceName ¶
func (*HpcInfo) GetStartTime ¶
func (*HpcInfo) GetVersion ¶
func (*HpcInfo) GetWallTime ¶
func (*HpcInfo) GetWorkDir ¶
func (*HpcInfo) ProtoMessage ¶
func (*HpcInfo) ProtoMessage()
func (*HpcInfo) ProtoReflect ¶
func (x *HpcInfo) ProtoReflect() protoreflect.Message
type InfoListReq ¶
type InfoListReq struct { Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"` ServiceName string `protobuf:"bytes,2,opt,name=serviceName,proto3" json:"serviceName,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) GetServiceName ¶
func (x *InfoListReq) GetServiceName() string
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 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 { ServiceName string `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,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) GetServiceName ¶
func (x *SyncInfoReq) GetServiceName() string
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 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 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.