ceph

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

This section is empty.

Variables

View Source
var Ceph_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "template.Ceph",
	HandlerType: (*CephServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "storageScreen",
			Handler:    _Ceph_StorageScreen_Handler,
		},
		{
			MethodName: "dailyPowerScreen",
			Handler:    _Ceph_DailyPowerScreen_Handler,
		},
		{
			MethodName: "perCenterComputerPowerScreen",
			Handler:    _Ceph_PerCenterComputerPowerScreen_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pcm-ceph.proto",
}

Ceph_ServiceDesc is the grpc.ServiceDesc for Ceph 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 File_pcm_ceph_proto protoreflect.FileDescriptor

Functions

func RegisterCephServer

func RegisterCephServer(s grpc.ServiceRegistrar, srv CephServer)

Types

type AccOtJobInfo

type AccOtJobInfo struct {
	AccRunSec     int32   `protobuf:"varint,1,opt,name=accRunSec,proto3" json:"accRunSec,omitempty"`          // @gotags: copier:"AccRunSec"
	AccCardRunSec float32 `protobuf:"fixed32,2,opt,name=accCardRunSec,proto3" json:"accCardRunSec,omitempty"` // @gotags: copier:"AccCardRunSec"
	AccOtJobNum   int32   `protobuf:"varint,3,opt,name=accOtJobNum,proto3" json:"accOtJobNum,omitempty"`      // @gotags: copier:"AccOtJobNum"
	// contains filtered or unexported fields
}

func (*AccOtJobInfo) Descriptor deprecated

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

Deprecated: Use AccOtJobInfo.ProtoReflect.Descriptor instead.

func (*AccOtJobInfo) GetAccCardRunSec

func (x *AccOtJobInfo) GetAccCardRunSec() float32

func (*AccOtJobInfo) GetAccOtJobNum

func (x *AccOtJobInfo) GetAccOtJobNum() int32

func (*AccOtJobInfo) GetAccRunSec

func (x *AccOtJobInfo) GetAccRunSec() int32

func (*AccOtJobInfo) ProtoMessage

func (*AccOtJobInfo) ProtoMessage()

func (*AccOtJobInfo) ProtoReflect

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

func (*AccOtJobInfo) Reset

func (x *AccOtJobInfo) Reset()

func (*AccOtJobInfo) String

func (x *AccOtJobInfo) String() string

type AiCenterInfos

type AiCenterInfos struct {
	Id              string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                             // @gotags: copier:"Id"
	Name            string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                         // @gotags: copier:"Name"
	Desc            string `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"`                         // @gotags: copier:"Desc"
	Resource        string `protobuf:"bytes,4,opt,name=resource,proto3" json:"resource,omitempty"`                 //@gotags: copier:"resource"
	TrainJob        string `protobuf:"bytes,5,opt,name=trainJob,proto3" json:"trainJob,omitempty"`                 //@gotags: copier:"TrainJob"
	ComputeScale    int32  `protobuf:"varint,6,opt,name=computeScale,proto3" json:"computeScale,omitempty"`        //@gotags: copier:"ComputeScale"
	StorageScale    int32  `protobuf:"varint,7,opt,name=storageScale,proto3" json:"storageScale,omitempty"`        //@gotags: copier:"StorageScale"
	Province        string `protobuf:"bytes,8,opt,name=province,proto3" json:"province,omitempty"`                 //@gotags: copier:"Province"
	City            string `protobuf:"bytes,9,opt,name=city,proto3" json:"city,omitempty"`                         //@gotags: copier:"City"
	CoordinateX     int32  `protobuf:"varint,10,opt,name=coordinateX,proto3" json:"coordinateX,omitempty"`         //@gotags: copier:"CoordinateX"
	CoordinateY     int32  `protobuf:"varint,11,opt,name=coordinateY,proto3" json:"coordinateY,omitempty"`         //@gotags: copier:"CoordinateY"
	Type            int32  `protobuf:"varint,12,opt,name=type,proto3" json:"type,omitempty"`                       //@gotags: copier:"Type"
	Weight          int32  `protobuf:"varint,13,opt,name=weight,proto3" json:"weight,omitempty"`                   //@gotags: copier:"Weight"
	ConnectionState int32  `protobuf:"varint,14,opt,name=connectionState,proto3" json:"connectionState,omitempty"` //@gotags: copier:"ConnectionState"
	BusyState       int32  `protobuf:"varint,15,opt,name=busyState,proto3" json:"busyState,omitempty"`             //@gotags: copier:"BusyState"
	ImageUrl        string `protobuf:"bytes,16,opt,name=imageUrl,proto3" json:"imageUrl,omitempty"`                //@gotags: copier:"ImageUrl"
	AccDevices      string `protobuf:"bytes,17,opt,name=accDevices,proto3" json:"accDevices,omitempty"`            //@gotags: copier:"AccDevices"
	MarketTime      int64  `protobuf:"varint,18,opt,name=marketTime,proto3" json:"marketTime,omitempty"`           //@gotags: copier:"MarketTime"
	CreatedAt       int64  `protobuf:"varint,19,opt,name=createdAt,proto3" json:"createdAt,omitempty"`             //@gotags: copier:"CreatedAt"
	AccessTime      int32  `protobuf:"varint,20,opt,name=accessTime,proto3" json:"accessTime,omitempty"`           //@gotags: copier:"AccessTime"
	CardRunTime     int32  `protobuf:"varint,21,opt,name=cardRunTime,proto3" json:"cardRunTime,omitempty"`         //@gotags: copier:"CardRunTime"
	JobCount        int32  `protobuf:"varint,22,opt,name=jobCount,proto3" json:"jobCount,omitempty"`               //@gotags: copier:"JobCount"
	// contains filtered or unexported fields
}

func (*AiCenterInfos) Descriptor deprecated

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

Deprecated: Use AiCenterInfos.ProtoReflect.Descriptor instead.

func (*AiCenterInfos) GetAccDevices

func (x *AiCenterInfos) GetAccDevices() string

func (*AiCenterInfos) GetAccessTime

func (x *AiCenterInfos) GetAccessTime() int32

func (*AiCenterInfos) GetBusyState

func (x *AiCenterInfos) GetBusyState() int32

func (*AiCenterInfos) GetCardRunTime

func (x *AiCenterInfos) GetCardRunTime() int32

func (*AiCenterInfos) GetCity

func (x *AiCenterInfos) GetCity() string

func (*AiCenterInfos) GetComputeScale

func (x *AiCenterInfos) GetComputeScale() int32

func (*AiCenterInfos) GetConnectionState

func (x *AiCenterInfos) GetConnectionState() int32

func (*AiCenterInfos) GetCoordinateX

func (x *AiCenterInfos) GetCoordinateX() int32

func (*AiCenterInfos) GetCoordinateY

func (x *AiCenterInfos) GetCoordinateY() int32

func (*AiCenterInfos) GetCreatedAt

func (x *AiCenterInfos) GetCreatedAt() int64

func (*AiCenterInfos) GetDesc

func (x *AiCenterInfos) GetDesc() string

func (*AiCenterInfos) GetId

func (x *AiCenterInfos) GetId() string

func (*AiCenterInfos) GetImageUrl

func (x *AiCenterInfos) GetImageUrl() string

func (*AiCenterInfos) GetJobCount

func (x *AiCenterInfos) GetJobCount() int32

func (*AiCenterInfos) GetMarketTime

func (x *AiCenterInfos) GetMarketTime() int64

func (*AiCenterInfos) GetName

func (x *AiCenterInfos) GetName() string

func (*AiCenterInfos) GetProvince

func (x *AiCenterInfos) GetProvince() string

func (*AiCenterInfos) GetResource

func (x *AiCenterInfos) GetResource() string

func (*AiCenterInfos) GetStorageScale

func (x *AiCenterInfos) GetStorageScale() int32

func (*AiCenterInfos) GetTrainJob

func (x *AiCenterInfos) GetTrainJob() string

func (*AiCenterInfos) GetType

func (x *AiCenterInfos) GetType() int32

func (*AiCenterInfos) GetWeight

func (x *AiCenterInfos) GetWeight() int32

func (*AiCenterInfos) ProtoMessage

func (*AiCenterInfos) ProtoMessage()

func (*AiCenterInfos) ProtoReflect

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

func (*AiCenterInfos) Reset

func (x *AiCenterInfos) Reset()

func (*AiCenterInfos) String

func (x *AiCenterInfos) String() string

type CephClient

type CephClient interface {
	StorageScreen(ctx context.Context, in *StorageScreenReq, opts ...grpc.CallOption) (*StorageScreenResp, error)
	DailyPowerScreen(ctx context.Context, in *DailyPowerScreenReq, opts ...grpc.CallOption) (*DailyPowerScreenResp, error)
	PerCenterComputerPowerScreen(ctx context.Context, in *PerCenterComputerPowersReq, opts ...grpc.CallOption) (*PerCenterComputerPowersResp, error)
}

CephClient is the client API for Ceph 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 NewCephClient

func NewCephClient(cc grpc.ClientConnInterface) CephClient

type CephServer

type CephServer interface {
	StorageScreen(context.Context, *StorageScreenReq) (*StorageScreenResp, error)
	DailyPowerScreen(context.Context, *DailyPowerScreenReq) (*DailyPowerScreenResp, error)
	PerCenterComputerPowerScreen(context.Context, *PerCenterComputerPowersReq) (*PerCenterComputerPowersResp, error)
	// contains filtered or unexported methods
}

CephServer is the server API for Ceph service. All implementations must embed UnimplementedCephServer for forward compatibility

type DailyComputerPowers

type DailyComputerPowers struct {
	Date          string  `protobuf:"bytes,1,opt,name=date,proto3" json:"date,omitempty"`                     // @gotags: copier:"Date"
	ComputerPower float32 `protobuf:"fixed32,2,opt,name=computerPower,proto3" json:"computerPower,omitempty"` // @gotags: copier:"ComputerPower"
	// contains filtered or unexported fields
}

func (*DailyComputerPowers) Descriptor deprecated

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

Deprecated: Use DailyComputerPowers.ProtoReflect.Descriptor instead.

func (*DailyComputerPowers) GetComputerPower

func (x *DailyComputerPowers) GetComputerPower() float32

func (*DailyComputerPowers) GetDate

func (x *DailyComputerPowers) GetDate() string

func (*DailyComputerPowers) ProtoMessage

func (*DailyComputerPowers) ProtoMessage()

func (*DailyComputerPowers) ProtoReflect

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

func (*DailyComputerPowers) Reset

func (x *DailyComputerPowers) Reset()

func (*DailyComputerPowers) String

func (x *DailyComputerPowers) String() string

type DailyPowerScreenReq

type DailyPowerScreenReq struct {
	// contains filtered or unexported fields
}

*****************screen computing power Start************************

func (*DailyPowerScreenReq) Descriptor deprecated

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

Deprecated: Use DailyPowerScreenReq.ProtoReflect.Descriptor instead.

func (*DailyPowerScreenReq) ProtoMessage

func (*DailyPowerScreenReq) ProtoMessage()

func (*DailyPowerScreenReq) ProtoReflect

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

func (*DailyPowerScreenReq) Reset

func (x *DailyPowerScreenReq) Reset()

func (*DailyPowerScreenReq) String

func (x *DailyPowerScreenReq) String() string

type DailyPowerScreenResp

type DailyPowerScreenResp struct {
	TotalSize           int32                  `protobuf:"varint,1,opt,name=totalSize,proto3" json:"totalSize,omitempty"`                    // @gotags: copier:"TotalSize"
	DailyComputerPowers []*DailyComputerPowers `protobuf:"bytes,2,rep,name=dailyComputerPowers,proto3" json:"dailyComputerPowers,omitempty"` // @gotags: copier:"DailyComputerPowers"
	Code                int32                  `protobuf:"varint,3,opt,name=code,proto3" json:"code,omitempty"`                              // @gotags: copier:"Code"
	Msg                 string                 `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"`                                 // @gotags: copier:"Msg"
	ErrorMsg            string                 `protobuf:"bytes,5,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`       // @gotags: copier:"ErrorMsg"
	// contains filtered or unexported fields
}

func (*DailyPowerScreenResp) Descriptor deprecated

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

Deprecated: Use DailyPowerScreenResp.ProtoReflect.Descriptor instead.

func (*DailyPowerScreenResp) GetCode

func (x *DailyPowerScreenResp) GetCode() int32

func (*DailyPowerScreenResp) GetDailyComputerPowers

func (x *DailyPowerScreenResp) GetDailyComputerPowers() []*DailyComputerPowers

func (*DailyPowerScreenResp) GetErrorMsg

func (x *DailyPowerScreenResp) GetErrorMsg() string

func (*DailyPowerScreenResp) GetMsg

func (x *DailyPowerScreenResp) GetMsg() string

func (*DailyPowerScreenResp) GetTotalSize

func (x *DailyPowerScreenResp) GetTotalSize() int32

func (*DailyPowerScreenResp) ProtoMessage

func (*DailyPowerScreenResp) ProtoMessage()

func (*DailyPowerScreenResp) ProtoReflect

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

func (*DailyPowerScreenResp) Reset

func (x *DailyPowerScreenResp) Reset()

func (*DailyPowerScreenResp) String

func (x *DailyPowerScreenResp) String() string

type PerCenterComputerPowers

type PerCenterComputerPowers struct {
	CenterName    string  `protobuf:"bytes,1,opt,name=centerName,proto3" json:"centerName,omitempty"`         // @gotags: copier:"CenterName"
	ComputerPower float32 `protobuf:"fixed32,2,opt,name=computerPower,proto3" json:"computerPower,omitempty"` // @gotags: copier:"ComputerPower"
	JobCount      int32   `protobuf:"varint,3,opt,name=jobCount,proto3" json:"jobCount,omitempty"`            // @gotags: copier:"JobCount"
	CenterId      string  `protobuf:"bytes,4,opt,name=centerId,proto3" json:"centerId,omitempty"`             // @gotags: copier:"CenterId"
	// contains filtered or unexported fields
}

func (*PerCenterComputerPowers) Descriptor deprecated

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

Deprecated: Use PerCenterComputerPowers.ProtoReflect.Descriptor instead.

func (*PerCenterComputerPowers) GetCenterId

func (x *PerCenterComputerPowers) GetCenterId() string

func (*PerCenterComputerPowers) GetCenterName

func (x *PerCenterComputerPowers) GetCenterName() string

func (*PerCenterComputerPowers) GetComputerPower

func (x *PerCenterComputerPowers) GetComputerPower() float32

func (*PerCenterComputerPowers) GetJobCount

func (x *PerCenterComputerPowers) GetJobCount() int32

func (*PerCenterComputerPowers) ProtoMessage

func (*PerCenterComputerPowers) ProtoMessage()

func (*PerCenterComputerPowers) ProtoReflect

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

func (*PerCenterComputerPowers) Reset

func (x *PerCenterComputerPowers) Reset()

func (*PerCenterComputerPowers) String

func (x *PerCenterComputerPowers) String() string

type PerCenterComputerPowersReq

type PerCenterComputerPowersReq struct {
	// contains filtered or unexported fields
}

func (*PerCenterComputerPowersReq) Descriptor deprecated

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

Deprecated: Use PerCenterComputerPowersReq.ProtoReflect.Descriptor instead.

func (*PerCenterComputerPowersReq) ProtoMessage

func (*PerCenterComputerPowersReq) ProtoMessage()

func (*PerCenterComputerPowersReq) ProtoReflect

func (*PerCenterComputerPowersReq) Reset

func (x *PerCenterComputerPowersReq) Reset()

func (*PerCenterComputerPowersReq) String

func (x *PerCenterComputerPowersReq) String() string

type PerCenterComputerPowersResp

type PerCenterComputerPowersResp struct {
	TotalSize               int32                      `protobuf:"varint,1,opt,name=totalSize,proto3" json:"totalSize,omitempty"`                            // @gotags: copier:"TotalSize"
	PerCenterComputerPowers []*PerCenterComputerPowers `protobuf:"bytes,2,rep,name=perCenterComputerPowers,proto3" json:"perCenterComputerPowers,omitempty"` // @gotags: copier:"DailyComputerPowers"
	AccOtJobInfo            *AccOtJobInfo              `protobuf:"bytes,3,opt,name=accOtJobInfo,proto3" json:"accOtJobInfo,omitempty"`
	Code                    int32                      `protobuf:"varint,4,opt,name=code,proto3" json:"code,omitempty"`                        // @gotags: copier:"Code"
	Msg                     string                     `protobuf:"bytes,5,opt,name=msg,proto3" json:"msg,omitempty"`                           // @gotags: copier:"Msg"
	ErrorMsg                string                     `protobuf:"bytes,6,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"` // @gotags: copier:"ErrorMsg"
	// contains filtered or unexported fields
}

func (*PerCenterComputerPowersResp) Descriptor deprecated

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

Deprecated: Use PerCenterComputerPowersResp.ProtoReflect.Descriptor instead.

func (*PerCenterComputerPowersResp) GetAccOtJobInfo

func (x *PerCenterComputerPowersResp) GetAccOtJobInfo() *AccOtJobInfo

func (*PerCenterComputerPowersResp) GetCode

func (x *PerCenterComputerPowersResp) GetCode() int32

func (*PerCenterComputerPowersResp) GetErrorMsg

func (x *PerCenterComputerPowersResp) GetErrorMsg() string

func (*PerCenterComputerPowersResp) GetMsg

func (x *PerCenterComputerPowersResp) GetMsg() string

func (*PerCenterComputerPowersResp) GetPerCenterComputerPowers

func (x *PerCenterComputerPowersResp) GetPerCenterComputerPowers() []*PerCenterComputerPowers

func (*PerCenterComputerPowersResp) GetTotalSize

func (x *PerCenterComputerPowersResp) GetTotalSize() int32

func (*PerCenterComputerPowersResp) ProtoMessage

func (*PerCenterComputerPowersResp) ProtoMessage()

func (*PerCenterComputerPowersResp) ProtoReflect

func (*PerCenterComputerPowersResp) Reset

func (x *PerCenterComputerPowersResp) Reset()

func (*PerCenterComputerPowersResp) String

func (x *PerCenterComputerPowersResp) String() string

type StorageScreenReq

type StorageScreenReq struct {
	// contains filtered or unexported fields
}

*****************screen storage Start************************

func (*StorageScreenReq) Descriptor deprecated

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

Deprecated: Use StorageScreenReq.ProtoReflect.Descriptor instead.

func (*StorageScreenReq) ProtoMessage

func (*StorageScreenReq) ProtoMessage()

func (*StorageScreenReq) ProtoReflect

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

func (*StorageScreenReq) Reset

func (x *StorageScreenReq) Reset()

func (*StorageScreenReq) String

func (x *StorageScreenReq) String() string

type StorageScreenResp

type StorageScreenResp struct {
	TotalSize     int32            `protobuf:"varint,1,opt,name=totalSize,proto3" json:"totalSize,omitempty"`              // @gotags: copier:"TotalSize"
	AiCenterInfos []*AiCenterInfos `protobuf:"bytes,2,rep,name=aiCenterInfos,proto3" json:"aiCenterInfos,omitempty"`       // @gotags: copier:"AiCenterInfos"
	StorageUsed   float32          `protobuf:"fixed32,3,opt,name=storageUsed,proto3" json:"storageUsed,omitempty"`         // @gotags: copier:"StorageUsed"
	StorageUsing  float32          `protobuf:"fixed32,4,opt,name=storageUsing,proto3" json:"storageUsing,omitempty"`       // @gotags: copier:"StorageUsing"
	UsageRate     float32          `protobuf:"fixed32,5,opt,name=usageRate,proto3" json:"usageRate,omitempty"`             // @gotags: copier:"UsageRate"
	UsingRate     float32          `protobuf:"fixed32,6,opt,name=usingRate,proto3" json:"usingRate,omitempty"`             // @gotags: copier:"UsingRate"
	Code          int32            `protobuf:"varint,7,opt,name=code,proto3" json:"code,omitempty"`                        // @gotags: copier:"Code"
	Msg           string           `protobuf:"bytes,8,opt,name=msg,proto3" json:"msg,omitempty"`                           // @gotags: copier:"Msg"
	ErrorMsg      string           `protobuf:"bytes,9,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"` // @gotags: copier:"ErrorMsg"
	// contains filtered or unexported fields
}

func (*StorageScreenResp) Descriptor deprecated

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

Deprecated: Use StorageScreenResp.ProtoReflect.Descriptor instead.

func (*StorageScreenResp) GetAiCenterInfos

func (x *StorageScreenResp) GetAiCenterInfos() []*AiCenterInfos

func (*StorageScreenResp) GetCode

func (x *StorageScreenResp) GetCode() int32

func (*StorageScreenResp) GetErrorMsg

func (x *StorageScreenResp) GetErrorMsg() string

func (*StorageScreenResp) GetMsg

func (x *StorageScreenResp) GetMsg() string

func (*StorageScreenResp) GetStorageUsed

func (x *StorageScreenResp) GetStorageUsed() float32

func (*StorageScreenResp) GetStorageUsing

func (x *StorageScreenResp) GetStorageUsing() float32

func (*StorageScreenResp) GetTotalSize

func (x *StorageScreenResp) GetTotalSize() int32

func (*StorageScreenResp) GetUsageRate

func (x *StorageScreenResp) GetUsageRate() float32

func (*StorageScreenResp) GetUsingRate

func (x *StorageScreenResp) GetUsingRate() float32

func (*StorageScreenResp) ProtoMessage

func (*StorageScreenResp) ProtoMessage()

func (*StorageScreenResp) ProtoReflect

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

func (*StorageScreenResp) Reset

func (x *StorageScreenResp) Reset()

func (*StorageScreenResp) String

func (x *StorageScreenResp) String() string

type UnimplementedCephServer

type UnimplementedCephServer struct {
}

UnimplementedCephServer must be embedded to have forward compatible implementations.

func (UnimplementedCephServer) DailyPowerScreen

func (UnimplementedCephServer) PerCenterComputerPowerScreen

func (UnimplementedCephServer) StorageScreen

type UnsafeCephServer

type UnsafeCephServer interface {
	// contains filtered or unexported methods
}

UnsafeCephServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CephServer will result in compilation errors.

Jump to

Keyboard shortcuts

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