grpcSchMet

package
v0.0.0-...-cee649a Latest Latest
Warning

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

 Go to latest Published: Apr 13, 2021 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterMeteringServiceServer 

func RegisterMeteringServiceServer(s *grpc.Server, srv MeteringServiceServer)

func RegisterSchedulingServiceServer 

func RegisterSchedulingServiceServer(s *grpc.Server, srv SchedulingServiceServer)

Types

type MeteringServiceClient 

type MeteringServiceClient interface {
	// Query Metering
	QueryMetering(ctx context.Context, in *QmRequest, opts ...grpc.CallOption) (*QmReply, error)
	ComputeMetering(ctx context.Context, in *QmRequest, opts ...grpc.CallOption) (*QmReply, error)
	// Register Cron Metering Task
	RegisterCronMeteringTask(ctx context.Context, in *RegCmtRequest, opts ...grpc.CallOption) (*RegCmtReply, error)
}

MeteringServiceClient is the client API for MeteringService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMeteringServiceClient 

func NewMeteringServiceClient(cc *grpc.ClientConn) MeteringServiceClient

type MeteringServiceServer 

type MeteringServiceServer interface {
	// Query Metering
	QueryMetering(context.Context, *QmRequest) (*QmReply, error)
	ComputeMetering(context.Context, *QmRequest) (*QmReply, error)
	// Register Cron Metering Task
	RegisterCronMeteringTask(context.Context, *RegCmtRequest) (*RegCmtReply, error)
}

MeteringServiceServer is the server API for MeteringService service.

type QmReply 

type QmReply struct {
	ProjectID            int64    `protobuf:"varint,1,opt,name=projectID,proto3" json:"projectID,omitempty"`
	MeteringType         int64    `protobuf:"varint,2,opt,name=meteringType,proto3" json:"meteringType,omitempty"`
	MeteringTypeInfo     string   `protobuf:"bytes,3,opt,name=MeteringTypeInfo,proto3" json:"MeteringTypeInfo,omitempty"`
	CpuAmountInDays      int64    `protobuf:"varint,4,opt,name=CpuAmountInDays,proto3" json:"CpuAmountInDays,omitempty"`
	GpuAmountInDays      int64    `protobuf:"varint,5,opt,name=GpuAmountInDays,proto3" json:"GpuAmountInDays,omitempty"`
	StorageAmountInDays  int64    `protobuf:"varint,6,opt,name=StorageAmountInDays,proto3" json:"StorageAmountInDays,omitempty"`
	CpuAmountInHours     int64    `protobuf:"varint,7,opt,name=CpuAmountInHours,proto3" json:"CpuAmountInHours,omitempty"`
	GpuAmountInHours     int64    `protobuf:"varint,8,opt,name=GpuAmountInHours,proto3" json:"GpuAmountInHours,omitempty"`
	StorageAmountInHours int64    `protobuf:"varint,9,opt,name=StorageAmountInHours,proto3" json:"StorageAmountInHours,omitempty"`
	CpuNodeMeteringJson  string   `protobuf:"bytes,10,opt,name=CpuNodeMeteringJson,proto3" json:"CpuNodeMeteringJson,omitempty"`
	GpuNodeMeteringJson  string   `protobuf:"bytes,11,opt,name=GpuNodeMeteringJson,proto3" json:"GpuNodeMeteringJson,omitempty"`
	StorageMeteringJson  string   `protobuf:"bytes,12,opt,name=StorageMeteringJson,proto3" json:"StorageMeteringJson,omitempty"`
	CreatedAt            string   `protobuf:"bytes,13,opt,name=CreatedAt,proto3" json:"CreatedAt,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QmReply) Descriptor 

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

func (*QmReply) GetCpuAmountInDays 

func (m *QmReply) GetCpuAmountInDays() int64

func (*QmReply) GetCpuAmountInHours 

func (m *QmReply) GetCpuAmountInHours() int64

func (*QmReply) GetCpuNodeMeteringJson 

func (m *QmReply) GetCpuNodeMeteringJson() string

func (*QmReply) GetCreatedAt 

func (m *QmReply) GetCreatedAt() string

func (*QmReply) GetGpuAmountInDays 

func (m *QmReply) GetGpuAmountInDays() int64

func (*QmReply) GetGpuAmountInHours 

func (m *QmReply) GetGpuAmountInHours() int64

func (*QmReply) GetGpuNodeMeteringJson 

func (m *QmReply) GetGpuNodeMeteringJson() string

func (*QmReply) GetMeteringType 

func (m *QmReply) GetMeteringType() int64

func (*QmReply) GetMeteringTypeInfo 

func (m *QmReply) GetMeteringTypeInfo() string

func (*QmReply) GetProjectID 

func (m *QmReply) GetProjectID() int64

func (*QmReply) GetStorageAmountInDays 

func (m *QmReply) GetStorageAmountInDays() int64

func (*QmReply) GetStorageAmountInHours 

func (m *QmReply) GetStorageAmountInHours() int64

func (*QmReply) GetStorageMeteringJson 

func (m *QmReply) GetStorageMeteringJson() string

func (*QmReply) ProtoMessage 

func (*QmReply) ProtoMessage()

func (*QmReply) Reset 

func (m *QmReply) Reset()

func (*QmReply) String 

func (m *QmReply) String() string

func (*QmReply) XXX_DiscardUnknown 

func (m *QmReply) XXX_DiscardUnknown()

func (*QmReply) XXX_Marshal 

func (m *QmReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QmReply) XXX_Merge 

func (m *QmReply) XXX_Merge(src proto.Message)

func (*QmReply) XXX_Size 

func (m *QmReply) XXX_Size() int

func (*QmReply) XXX_Unmarshal 

func (m *QmReply) XXX_Unmarshal(b []byte) error

type QmRequest 

type QmRequest struct {
	ProjectID            int64    `protobuf:"varint,1,opt,name=projectID,proto3" json:"projectID,omitempty"`
	MeteringType         int64    `protobuf:"varint,2,opt,name=meteringType,proto3" json:"meteringType,omitempty"`
	TypeInfo             string   `protobuf:"bytes,3,opt,name=typeInfo,proto3" json:"typeInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QmRequest) Descriptor 

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

func (*QmRequest) GetMeteringType 

func (m *QmRequest) GetMeteringType() int64

func (*QmRequest) GetProjectID 

func (m *QmRequest) GetProjectID() int64

func (*QmRequest) GetTypeInfo 

func (m *QmRequest) GetTypeInfo() string

func (*QmRequest) ProtoMessage 

func (*QmRequest) ProtoMessage()

func (*QmRequest) Reset 

func (m *QmRequest) Reset()

func (*QmRequest) String 

func (m *QmRequest) String() string

func (*QmRequest) XXX_DiscardUnknown 

func (m *QmRequest) XXX_DiscardUnknown()

func (*QmRequest) XXX_Marshal 

func (m *QmRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QmRequest) XXX_Merge 

func (m *QmRequest) XXX_Merge(src proto.Message)

func (*QmRequest) XXX_Size 

func (m *QmRequest) XXX_Size() int

func (*QmRequest) XXX_Unmarshal 

func (m *QmRequest) XXX_Unmarshal(b []byte) error

type QueryProjectResLiteReply 

type QueryProjectResLiteReply struct {
	ProjectID            int64    `protobuf:"varint,1,opt,name=projectID,proto3" json:"projectID,omitempty"`
	CpuNodesAcquired     int64    `protobuf:"varint,2,opt,name=cpuNodesAcquired,proto3" json:"cpuNodesAcquired,omitempty"`
	GpuNodesAcquired     int64    `protobuf:"varint,3,opt,name=gpuNodesAcquired,proto3" json:"gpuNodesAcquired,omitempty"`
	StorageSizeAcquired  int64    `protobuf:"varint,4,opt,name=storageSizeAcquired,proto3" json:"storageSizeAcquired,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryProjectResLiteReply) Descriptor 

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

func (*QueryProjectResLiteReply) GetCpuNodesAcquired 

func (m *QueryProjectResLiteReply) GetCpuNodesAcquired() int64

func (*QueryProjectResLiteReply) GetGpuNodesAcquired 

func (m *QueryProjectResLiteReply) GetGpuNodesAcquired() int64

func (*QueryProjectResLiteReply) GetProjectID 

func (m *QueryProjectResLiteReply) GetProjectID() int64

func (*QueryProjectResLiteReply) GetStorageSizeAcquired 

func (m *QueryProjectResLiteReply) GetStorageSizeAcquired() int64

func (*QueryProjectResLiteReply) ProtoMessage 

func (*QueryProjectResLiteReply) ProtoMessage()

func (*QueryProjectResLiteReply) Reset 

func (m *QueryProjectResLiteReply) Reset()

func (*QueryProjectResLiteReply) String 

func (m *QueryProjectResLiteReply) String() string

func (*QueryProjectResLiteReply) XXX_DiscardUnknown 

func (m *QueryProjectResLiteReply) XXX_DiscardUnknown()

func (*QueryProjectResLiteReply) XXX_Marshal 

func (m *QueryProjectResLiteReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryProjectResLiteReply) XXX_Merge 

func (m *QueryProjectResLiteReply) XXX_Merge(src proto.Message)

func (*QueryProjectResLiteReply) XXX_Size 

func (m *QueryProjectResLiteReply) XXX_Size() int

func (*QueryProjectResLiteReply) XXX_Unmarshal 

func (m *QueryProjectResLiteReply) XXX_Unmarshal(b []byte) error

type QueryProjectResReply 

type QueryProjectResReply struct {
	ProjectID            int64    `protobuf:"varint,1,opt,name=projectID,proto3" json:"projectID,omitempty"`
	CpuNodesAcquired     int64    `protobuf:"varint,2,opt,name=cpuNodesAcquired,proto3" json:"cpuNodesAcquired,omitempty"`
	GpuNodesAcquired     int64    `protobuf:"varint,3,opt,name=gpuNodesAcquired,proto3" json:"gpuNodesAcquired,omitempty"`
	StorageSizeAcquired  int64    `protobuf:"varint,4,opt,name=storageSizeAcquired,proto3" json:"storageSizeAcquired,omitempty"`
	CpuNodesArray        []int64  `protobuf:"varint,5,rep,packed,name=cpuNodesArray,proto3" json:"cpuNodesArray,omitempty"`
	CpuNodesStr          string   `protobuf:"bytes,6,opt,name=cpuNodesStr,proto3" json:"cpuNodesStr,omitempty"`
	GpuNodesArray        []int64  `protobuf:"varint,7,rep,packed,name=gpuNodesArray,proto3" json:"gpuNodesArray,omitempty"`
	GpuNodesStr          string   `protobuf:"bytes,8,opt,name=gpuNodesStr,proto3" json:"gpuNodesStr,omitempty"`
	StorageAllocInfo     string   `protobuf:"bytes,9,opt,name=storageAllocInfo,proto3" json:"storageAllocInfo,omitempty"`
	CreatedAt            string   `protobuf:"bytes,10,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	UpdatedAt            string   `protobuf:"bytes,11,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryProjectResReply) Descriptor 

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

func (*QueryProjectResReply) GetCpuNodesAcquired 

func (m *QueryProjectResReply) GetCpuNodesAcquired() int64

func (*QueryProjectResReply) GetCpuNodesArray 

func (m *QueryProjectResReply) GetCpuNodesArray() []int64

func (*QueryProjectResReply) GetCpuNodesStr 

func (m *QueryProjectResReply) GetCpuNodesStr() string

func (*QueryProjectResReply) GetCreatedAt 

func (m *QueryProjectResReply) GetCreatedAt() string

func (*QueryProjectResReply) GetGpuNodesAcquired 

func (m *QueryProjectResReply) GetGpuNodesAcquired() int64

func (*QueryProjectResReply) GetGpuNodesArray 

func (m *QueryProjectResReply) GetGpuNodesArray() []int64

func (*QueryProjectResReply) GetGpuNodesStr 

func (m *QueryProjectResReply) GetGpuNodesStr() string

func (*QueryProjectResReply) GetProjectID 

func (m *QueryProjectResReply) GetProjectID() int64

func (*QueryProjectResReply) GetStorageAllocInfo 

func (m *QueryProjectResReply) GetStorageAllocInfo() string

func (*QueryProjectResReply) GetStorageSizeAcquired 

func (m *QueryProjectResReply) GetStorageSizeAcquired() int64

func (*QueryProjectResReply) GetUpdatedAt 

func (m *QueryProjectResReply) GetUpdatedAt() string

func (*QueryProjectResReply) ProtoMessage 

func (*QueryProjectResReply) ProtoMessage()

func (*QueryProjectResReply) Reset 

func (m *QueryProjectResReply) Reset()

func (*QueryProjectResReply) String 

func (m *QueryProjectResReply) String() string

func (*QueryProjectResReply) XXX_DiscardUnknown 

func (m *QueryProjectResReply) XXX_DiscardUnknown()

func (*QueryProjectResReply) XXX_Marshal 

func (m *QueryProjectResReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryProjectResReply) XXX_Merge 

func (m *QueryProjectResReply) XXX_Merge(src proto.Message)

func (*QueryProjectResReply) XXX_Size 

func (m *QueryProjectResReply) XXX_Size() int

func (*QueryProjectResReply) XXX_Unmarshal 

func (m *QueryProjectResReply) XXX_Unmarshal(b []byte) error

type QueryProjectResRequest 

type QueryProjectResRequest struct {
	ProjectID            int64    `protobuf:"varint,1,opt,name=projectID,proto3" json:"projectID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

/////////////////////////////////////////////////////////

func (*QueryProjectResRequest) Descriptor 

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

func (*QueryProjectResRequest) GetProjectID 

func (m *QueryProjectResRequest) GetProjectID() int64

func (*QueryProjectResRequest) ProtoMessage 

func (*QueryProjectResRequest) ProtoMessage()

func (*QueryProjectResRequest) Reset 

func (m *QueryProjectResRequest) Reset()

func (*QueryProjectResRequest) String 

func (m *QueryProjectResRequest) String() string

func (*QueryProjectResRequest) XXX_DiscardUnknown 

func (m *QueryProjectResRequest) XXX_DiscardUnknown()

func (*QueryProjectResRequest) XXX_Marshal 

func (m *QueryProjectResRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryProjectResRequest) XXX_Merge 

func (m *QueryProjectResRequest) XXX_Merge(src proto.Message)

func (*QueryProjectResRequest) XXX_Size 

func (m *QueryProjectResRequest) XXX_Size() int

func (*QueryProjectResRequest) XXX_Unmarshal 

func (m *QueryProjectResRequest) XXX_Unmarshal(b []byte) error

type QueryTreeReply 

type QueryTreeReply struct {
	JsonTree             string   `protobuf:"bytes,1,opt,name=jsonTree,proto3" json:"jsonTree,omitempty"`
	NodesNum             int64    `protobuf:"varint,2,opt,name=nodesNum,proto3" json:"nodesNum,omitempty"`
	Selected             []int64  `protobuf:"varint,3,rep,packed,name=selected,proto3" json:"selected,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryTreeReply) Descriptor 

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

func (*QueryTreeReply) GetJsonTree 

func (m *QueryTreeReply) GetJsonTree() string

func (*QueryTreeReply) GetNodesNum 

func (m *QueryTreeReply) GetNodesNum() int64

func (*QueryTreeReply) GetSelected 

func (m *QueryTreeReply) GetSelected() []int64

func (*QueryTreeReply) ProtoMessage 

func (*QueryTreeReply) ProtoMessage()

func (*QueryTreeReply) Reset 

func (m *QueryTreeReply) Reset()

func (*QueryTreeReply) String 

func (m *QueryTreeReply) String() string

func (*QueryTreeReply) XXX_DiscardUnknown 

func (m *QueryTreeReply) XXX_DiscardUnknown()

func (*QueryTreeReply) XXX_Marshal 

func (m *QueryTreeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryTreeReply) XXX_Merge 

func (m *QueryTreeReply) XXX_Merge(src proto.Message)

func (*QueryTreeReply) XXX_Size 

func (m *QueryTreeReply) XXX_Size() int

func (*QueryTreeReply) XXX_Unmarshal 

func (m *QueryTreeReply) XXX_Unmarshal(b []byte) error

type QueryTreeRequest 

type QueryTreeRequest struct {
	ProjectID            int64    `protobuf:"varint,1,opt,name=projectID,proto3" json:"projectID,omitempty"`
	CgpuType             int64    `protobuf:"varint,2,opt,name=cgpuType,proto3" json:"cgpuType,omitempty"`
	QueryType            int64    `protobuf:"varint,3,opt,name=queryType,proto3" json:"queryType,omitempty"`
	TreeFormat           int64    `protobuf:"varint,4,opt,name=treeFormat,proto3" json:"treeFormat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

/////////////////////////////////////////////////////////

func (*QueryTreeRequest) Descriptor 

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

func (*QueryTreeRequest) GetCgpuType 

func (m *QueryTreeRequest) GetCgpuType() int64

func (*QueryTreeRequest) GetProjectID 

func (m *QueryTreeRequest) GetProjectID() int64

func (*QueryTreeRequest) GetQueryType 

func (m *QueryTreeRequest) GetQueryType() int64

func (*QueryTreeRequest) GetTreeFormat 

func (m *QueryTreeRequest) GetTreeFormat() int64

func (*QueryTreeRequest) ProtoMessage 

func (*QueryTreeRequest) ProtoMessage()

func (*QueryTreeRequest) Reset 

func (m *QueryTreeRequest) Reset()

func (*QueryTreeRequest) String 

func (m *QueryTreeRequest) String() string

func (*QueryTreeRequest) XXX_DiscardUnknown 

func (m *QueryTreeRequest) XXX_DiscardUnknown()

func (*QueryTreeRequest) XXX_Marshal 

func (m *QueryTreeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryTreeRequest) XXX_Merge 

func (m *QueryTreeRequest) XXX_Merge(src proto.Message)

func (*QueryTreeRequest) XXX_Size 

func (m *QueryTreeRequest) XXX_Size() int

func (*QueryTreeRequest) XXX_Unmarshal 

func (m *QueryTreeRequest) XXX_Unmarshal(b []byte) error

type RegCmtReply 

type RegCmtReply struct {
	Msg                  string   `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegCmtReply) Descriptor 

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

func (*RegCmtReply) GetMsg 

func (m *RegCmtReply) GetMsg() string

func (*RegCmtReply) ProtoMessage 

func (*RegCmtReply) ProtoMessage()

func (*RegCmtReply) Reset 

func (m *RegCmtReply) Reset()

func (*RegCmtReply) String 

func (m *RegCmtReply) String() string

func (*RegCmtReply) XXX_DiscardUnknown 

func (m *RegCmtReply) XXX_DiscardUnknown()

func (*RegCmtReply) XXX_Marshal 

func (m *RegCmtReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegCmtReply) XXX_Merge 

func (m *RegCmtReply) XXX_Merge(src proto.Message)

func (*RegCmtReply) XXX_Size 

func (m *RegCmtReply) XXX_Size() int

func (*RegCmtReply) XXX_Unmarshal 

func (m *RegCmtReply) XXX_Unmarshal(b []byte) error

type RegCmtRequest 

type RegCmtRequest struct {
	MeteringType         int64    `protobuf:"varint,1,opt,name=meteringType,proto3" json:"meteringType,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegCmtRequest) Descriptor 

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

func (*RegCmtRequest) GetMeteringType 

func (m *RegCmtRequest) GetMeteringType() int64

func (*RegCmtRequest) ProtoMessage 

func (*RegCmtRequest) ProtoMessage()

func (*RegCmtRequest) Reset 

func (m *RegCmtRequest) Reset()

func (*RegCmtRequest) String 

func (m *RegCmtRequest) String() string

func (*RegCmtRequest) XXX_DiscardUnknown 

func (m *RegCmtRequest) XXX_DiscardUnknown()

func (*RegCmtRequest) XXX_Marshal 

func (m *RegCmtRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegCmtRequest) XXX_Merge 

func (m *RegCmtRequest) XXX_Merge(src proto.Message)

func (*RegCmtRequest) XXX_Size 

func (m *RegCmtRequest) XXX_Size() int

func (*RegCmtRequest) XXX_Unmarshal 

func (m *RegCmtRequest) XXX_Unmarshal(b []byte) error

type SchedulingCGpuRequest 

type SchedulingCGpuRequest struct {
	ProjectID            int64    `protobuf:"varint,1,opt,name=projectID,proto3" json:"projectID,omitempty"`
	CgpuType             int64    `protobuf:"varint,2,opt,name=cgpuType,proto3" json:"cgpuType,omitempty"`
	NodesAfter           []int64  `protobuf:"varint,3,rep,packed,name=nodesAfter,proto3" json:"nodesAfter,omitempty"`
	CtrlID               int64    `protobuf:"varint,4,opt,name=ctrlID,proto3" json:"ctrlID,omitempty"`
	CtrlCN               string   `protobuf:"bytes,5,opt,name=ctrlCN,proto3" json:"ctrlCN,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SchedulingCGpuRequest) Descriptor 

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

func (*SchedulingCGpuRequest) GetCgpuType 

func (m *SchedulingCGpuRequest) GetCgpuType() int64

func (*SchedulingCGpuRequest) GetCtrlCN 

func (m *SchedulingCGpuRequest) GetCtrlCN() string

func (*SchedulingCGpuRequest) GetCtrlID 

func (m *SchedulingCGpuRequest) GetCtrlID() int64

func (*SchedulingCGpuRequest) GetNodesAfter 

func (m *SchedulingCGpuRequest) GetNodesAfter() []int64

func (*SchedulingCGpuRequest) GetProjectID 

func (m *SchedulingCGpuRequest) GetProjectID() int64

func (*SchedulingCGpuRequest) ProtoMessage 

func (*SchedulingCGpuRequest) ProtoMessage()

func (*SchedulingCGpuRequest) Reset 

func (m *SchedulingCGpuRequest) Reset()

func (*SchedulingCGpuRequest) String 

func (m *SchedulingCGpuRequest) String() string

func (*SchedulingCGpuRequest) XXX_DiscardUnknown 

func (m *SchedulingCGpuRequest) XXX_DiscardUnknown()

func (*SchedulingCGpuRequest) XXX_Marshal 

func (m *SchedulingCGpuRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchedulingCGpuRequest) XXX_Merge 

func (m *SchedulingCGpuRequest) XXX_Merge(src proto.Message)

func (*SchedulingCGpuRequest) XXX_Size 

func (m *SchedulingCGpuRequest) XXX_Size() int

func (*SchedulingCGpuRequest) XXX_Unmarshal 

func (m *SchedulingCGpuRequest) XXX_Unmarshal(b []byte) error

type SchedulingReply 

type SchedulingReply struct {
	ProjectID            int64    `protobuf:"varint,1,opt,name=projectID,proto3" json:"projectID,omitempty"`
	CpuNodesAcquired     int64    `protobuf:"varint,2,opt,name=cpuNodesAcquired,proto3" json:"cpuNodesAcquired,omitempty"`
	GpuNodesAcquired     int64    `protobuf:"varint,3,opt,name=gpuNodesAcquired,proto3" json:"gpuNodesAcquired,omitempty"`
	StorageSizeAcquired  int64    `protobuf:"varint,4,opt,name=storageSizeAcquired,proto3" json:"storageSizeAcquired,omitempty"`
	Msg                  string   `protobuf:"bytes,5,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SchedulingReply) Descriptor 

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

func (*SchedulingReply) GetCpuNodesAcquired 

func (m *SchedulingReply) GetCpuNodesAcquired() int64

func (*SchedulingReply) GetGpuNodesAcquired 

func (m *SchedulingReply) GetGpuNodesAcquired() int64

func (*SchedulingReply) GetMsg 

func (m *SchedulingReply) GetMsg() string

func (*SchedulingReply) GetProjectID 

func (m *SchedulingReply) GetProjectID() int64

func (*SchedulingReply) GetStorageSizeAcquired 

func (m *SchedulingReply) GetStorageSizeAcquired() int64

func (*SchedulingReply) ProtoMessage 

func (*SchedulingReply) ProtoMessage()

func (*SchedulingReply) Reset 

func (m *SchedulingReply) Reset()

func (*SchedulingReply) String 

func (m *SchedulingReply) String() string

func (*SchedulingReply) XXX_DiscardUnknown 

func (m *SchedulingReply) XXX_DiscardUnknown()

func (*SchedulingReply) XXX_Marshal 

func (m *SchedulingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchedulingReply) XXX_Merge 

func (m *SchedulingReply) XXX_Merge(src proto.Message)

func (*SchedulingReply) XXX_Size 

func (m *SchedulingReply) XXX_Size() int

func (*SchedulingReply) XXX_Unmarshal 

func (m *SchedulingReply) XXX_Unmarshal(b []byte) error

type SchedulingServiceClient 

type SchedulingServiceClient interface {
	// Scheduling Resource
	SchedulingCGpu(ctx context.Context, in *SchedulingCGpuRequest, opts ...grpc.CallOption) (*SchedulingReply, error)
	SchedulingStorage(ctx context.Context, in *SchedulingStorageRequest, opts ...grpc.CallOption) (*SchedulingReply, error)
	// Query Resource Tree
	QueryCGpuTree(ctx context.Context, in *QueryTreeRequest, opts ...grpc.CallOption) (*QueryTreeReply, error)
	// Query Project Resource
	QueryProjectRes(ctx context.Context, in *QueryProjectResRequest, opts ...grpc.CallOption) (*QueryProjectResReply, error)
	QueryProjectResLite(ctx context.Context, in *QueryProjectResRequest, opts ...grpc.CallOption) (*QueryProjectResLiteReply, error)
}

SchedulingServiceClient is the client API for SchedulingService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSchedulingServiceClient 

func NewSchedulingServiceClient(cc *grpc.ClientConn) SchedulingServiceClient

type SchedulingServiceServer 

type SchedulingServiceServer interface {
	// Scheduling Resource
	SchedulingCGpu(context.Context, *SchedulingCGpuRequest) (*SchedulingReply, error)
	SchedulingStorage(context.Context, *SchedulingStorageRequest) (*SchedulingReply, error)
	// Query Resource Tree
	QueryCGpuTree(context.Context, *QueryTreeRequest) (*QueryTreeReply, error)
	// Query Project Resource
	QueryProjectRes(context.Context, *QueryProjectResRequest) (*QueryProjectResReply, error)
	QueryProjectResLite(context.Context, *QueryProjectResRequest) (*QueryProjectResLiteReply, error)
}

SchedulingServiceServer is the server API for SchedulingService service.

type SchedulingStorageRequest 

type SchedulingStorageRequest struct {
	ProjectID             int64    `protobuf:"varint,1,opt,name=projectID,proto3" json:"projectID,omitempty"`
	StorageSizeAfter      int64    `protobuf:"varint,2,opt,name=storageSizeAfter,proto3" json:"storageSizeAfter,omitempty"`
	StorageAllocInfoAfter string   `protobuf:"bytes,3,opt,name=storageAllocInfoAfter,proto3" json:"storageAllocInfoAfter,omitempty"`
	CtrlID                int64    `protobuf:"varint,4,opt,name=ctrlID,proto3" json:"ctrlID,omitempty"`
	CtrlCN                string   `protobuf:"bytes,5,opt,name=ctrlCN,proto3" json:"ctrlCN,omitempty"`
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

func (*SchedulingStorageRequest) Descriptor 

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

func (*SchedulingStorageRequest) GetCtrlCN 

func (m *SchedulingStorageRequest) GetCtrlCN() string

func (*SchedulingStorageRequest) GetCtrlID 

func (m *SchedulingStorageRequest) GetCtrlID() int64

func (*SchedulingStorageRequest) GetProjectID 

func (m *SchedulingStorageRequest) GetProjectID() int64

func (*SchedulingStorageRequest) GetStorageAllocInfoAfter 

func (m *SchedulingStorageRequest) GetStorageAllocInfoAfter() string

func (*SchedulingStorageRequest) GetStorageSizeAfter 

func (m *SchedulingStorageRequest) GetStorageSizeAfter() int64

func (*SchedulingStorageRequest) ProtoMessage 

func (*SchedulingStorageRequest) ProtoMessage()

func (*SchedulingStorageRequest) Reset 

func (m *SchedulingStorageRequest) Reset()

func (*SchedulingStorageRequest) String 

func (m *SchedulingStorageRequest) String() string

func (*SchedulingStorageRequest) XXX_DiscardUnknown 

func (m *SchedulingStorageRequest) XXX_DiscardUnknown()

func (*SchedulingStorageRequest) XXX_Marshal 

func (m *SchedulingStorageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchedulingStorageRequest) XXX_Merge 

func (m *SchedulingStorageRequest) XXX_Merge(src proto.Message)

func (*SchedulingStorageRequest) XXX_Size 

func (m *SchedulingStorageRequest) XXX_Size() int

func (*SchedulingStorageRequest) XXX_Unmarshal 

func (m *SchedulingStorageRequest) XXX_Unmarshal(b []byte) error

type UnimplementedMeteringServiceServer 

type UnimplementedMeteringServiceServer struct {
}

UnimplementedMeteringServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMeteringServiceServer) ComputeMetering 

func (*UnimplementedMeteringServiceServer) ComputeMetering(ctx context.Context, req *QmRequest) (*QmReply, error)

func (*UnimplementedMeteringServiceServer) QueryMetering 

func (*UnimplementedMeteringServiceServer) QueryMetering(ctx context.Context, req *QmRequest) (*QmReply, error)

func (*UnimplementedMeteringServiceServer) RegisterCronMeteringTask 

func (*UnimplementedMeteringServiceServer) RegisterCronMeteringTask(ctx context.Context, req *RegCmtRequest) (*RegCmtReply, error)

type UnimplementedSchedulingServiceServer 

type UnimplementedSchedulingServiceServer struct {
}

UnimplementedSchedulingServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSchedulingServiceServer) QueryCGpuTree 

func (*UnimplementedSchedulingServiceServer) QueryCGpuTree(ctx context.Context, req *QueryTreeRequest) (*QueryTreeReply, error)

func (*UnimplementedSchedulingServiceServer) QueryProjectRes 

func (*UnimplementedSchedulingServiceServer) QueryProjectRes(ctx context.Context, req *QueryProjectResRequest) (*QueryProjectResReply, error)

func (*UnimplementedSchedulingServiceServer) QueryProjectResLite 

func (*UnimplementedSchedulingServiceServer) QueryProjectResLite(ctx context.Context, req *QueryProjectResRequest) (*QueryProjectResLiteReply, error)

func (*UnimplementedSchedulingServiceServer) SchedulingCGpu 

func (*UnimplementedSchedulingServiceServer) SchedulingCGpu(ctx context.Context, req *SchedulingCGpuRequest) (*SchedulingReply, error)

func (*UnimplementedSchedulingServiceServer) SchedulingStorage 

func (*UnimplementedSchedulingServiceServer) SchedulingStorage(ctx context.Context, req *SchedulingStorageRequest) (*SchedulingReply, error)

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.