pcmCore

package
v0.1.4 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source
const (
	PcmCore_SyncInfo_FullMethodName = "/pcmCore.pcmCore/SyncInfo"
	PcmCore_InfoList_FullMethodName = "/pcmCore.pcmCore/InfoList"
)

Variables

View Source
var File_pcmCore_proto protoreflect.FileDescriptor
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 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) 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) GetProjectId

func (x *AiInfo) GetProjectId() string

func (*AiInfo) GetResult

func (x *AiInfo) GetResult() string

func (*AiInfo) GetRunningTime

func (x *AiInfo) GetRunningTime() int64

func (*AiInfo) GetServiceName

func (x *AiInfo) GetServiceName() string

func (*AiInfo) GetStartTime

func (x *AiInfo) GetStartTime() string

func (*AiInfo) GetStatus

func (x *AiInfo) GetStatus() string

func (*AiInfo) GetSubscriptionId

func (x *AiInfo) GetSubscriptionId() string

func (*AiInfo) GetTaskId

func (x *AiInfo) GetTaskId() int64

func (*AiInfo) ProtoMessage

func (*AiInfo) ProtoMessage()

func (*AiInfo) ProtoReflect

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

func (*AiInfo) Reset

func (x *AiInfo) Reset()

func (*AiInfo) String

func (x *AiInfo) String() string

type CloudInfo

type CloudInfo struct {
	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) 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) GetResult

func (x *CloudInfo) GetResult() string

func (*CloudInfo) GetRunningTime

func (x *CloudInfo) GetRunningTime() int64

func (*CloudInfo) GetServiceName

func (x *CloudInfo) GetServiceName() string

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 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) Descriptor() ([]byte, []int)

Deprecated: Use HpcInfo.ProtoReflect.Descriptor instead.

func (*HpcInfo) GetAccount

func (x *HpcInfo) GetAccount() string

func (*HpcInfo) GetAllocCpu

func (x *HpcInfo) GetAllocCpu() uint32

func (*HpcInfo) GetAllocNodes

func (x *HpcInfo) GetAllocNodes() uint32

func (*HpcInfo) GetAssocId

func (x *HpcInfo) GetAssocId() uint32

func (*HpcInfo) GetBlockId

func (x *HpcInfo) GetBlockId() string

func (*HpcInfo) GetCluster

func (x *HpcInfo) GetCluster() string

func (*HpcInfo) GetCmdScript

func (x *HpcInfo) GetCmdScript() string

func (*HpcInfo) GetDerivedEs

func (x *HpcInfo) GetDerivedEs() string

func (*HpcInfo) GetExitCode

func (x *HpcInfo) GetExitCode() uint32

func (*HpcInfo) GetJobId

func (x *HpcInfo) GetJobId() string

func (*HpcInfo) GetName

func (x *HpcInfo) GetName() string

func (*HpcInfo) GetResult

func (x *HpcInfo) GetResult() string

func (*HpcInfo) GetRunningTime

func (x *HpcInfo) GetRunningTime() int64

func (*HpcInfo) GetServiceName

func (x *HpcInfo) GetServiceName() string

func (*HpcInfo) GetStartTime

func (x *HpcInfo) GetStartTime() string

func (*HpcInfo) GetStatus

func (x *HpcInfo) GetStatus() string

func (*HpcInfo) GetTaskId

func (x *HpcInfo) GetTaskId() int64

func (*HpcInfo) GetVersion

func (x *HpcInfo) GetVersion() string

func (*HpcInfo) GetWallTime

func (x *HpcInfo) GetWallTime() string

func (*HpcInfo) GetWorkDir

func (x *HpcInfo) GetWorkDir() string

func (*HpcInfo) ProtoMessage

func (*HpcInfo) ProtoMessage()

func (*HpcInfo) ProtoReflect

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

func (*HpcInfo) Reset

func (x *HpcInfo) Reset()

func (*HpcInfo) String

func (x *HpcInfo) String() string

type InfoListReq

type InfoListReq struct {
	Kind        string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	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) SyncInfo

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.

Jump to

Keyboard shortcuts

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