Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterCedanaGPUServer(s grpc.ServiceRegistrar, srv CedanaGPUServer)
- type CedanaGPUClient
- type CedanaGPUServer
- type CheckpointRequest
- type CheckpointResponse
- func (*CheckpointResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckpointResponse) GetCkptPath() string
- func (x *CheckpointResponse) GetMemPath() string
- func (x *CheckpointResponse) GetSuccess() bool
- func (*CheckpointResponse) ProtoMessage()
- func (x *CheckpointResponse) ProtoReflect() protoreflect.Message
- func (x *CheckpointResponse) Reset()
- func (x *CheckpointResponse) String() string
- type RestoreRequest
- type RestoreResponse
- type UnimplementedCedanaGPUServer
- type UnsafeCedanaGPUServer
Constants ¶
View Source
const ( CedanaGPU_Checkpoint_FullMethodName = "/cedanagpu.CedanaGPU/Checkpoint" CedanaGPU_Restore_FullMethodName = "/cedanagpu.CedanaGPU/Restore" )
Variables ¶
View Source
var CedanaGPU_ServiceDesc = grpc.ServiceDesc{ ServiceName: "cedanagpu.CedanaGPU", HandlerType: (*CedanaGPUServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Checkpoint", Handler: _CedanaGPU_Checkpoint_Handler, }, { MethodName: "Restore", Handler: _CedanaGPU_Restore_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/services/gpu/gpu.proto", }
CedanaGPU_ServiceDesc is the grpc.ServiceDesc for CedanaGPU 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_api_services_gpu_gpu_proto protoreflect.FileDescriptor
Functions ¶
func RegisterCedanaGPUServer ¶
func RegisterCedanaGPUServer(s grpc.ServiceRegistrar, srv CedanaGPUServer)
Types ¶
type CedanaGPUClient ¶
type CedanaGPUClient interface {
Checkpoint(ctx context.Context, in *CheckpointRequest, opts ...grpc.CallOption) (*CheckpointResponse, error)
Restore(ctx context.Context, in *RestoreRequest, opts ...grpc.CallOption) (*RestoreResponse, error)
}
CedanaGPUClient is the client API for CedanaGPU 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 NewCedanaGPUClient ¶
func NewCedanaGPUClient(cc grpc.ClientConnInterface) CedanaGPUClient
type CedanaGPUServer ¶
type CedanaGPUServer interface {
Checkpoint(context.Context, *CheckpointRequest) (*CheckpointResponse, error)
Restore(context.Context, *RestoreRequest) (*RestoreResponse, error)
// contains filtered or unexported methods
}
CedanaGPUServer is the server API for CedanaGPU service. All implementations must embed UnimplementedCedanaGPUServer for forward compatibility
type CheckpointRequest ¶
type CheckpointRequest struct {
Directory string `protobuf:"bytes,1,opt,name=directory,proto3" json:"directory,omitempty"`
// contains filtered or unexported fields
}
func (*CheckpointRequest) Descriptor
deprecated
func (*CheckpointRequest) Descriptor() ([]byte, []int)
Deprecated: Use CheckpointRequest.ProtoReflect.Descriptor instead.
func (*CheckpointRequest) GetDirectory ¶ added in v0.9.5
func (x *CheckpointRequest) GetDirectory() string
func (*CheckpointRequest) ProtoMessage ¶
func (*CheckpointRequest) ProtoMessage()
func (*CheckpointRequest) ProtoReflect ¶
func (x *CheckpointRequest) ProtoReflect() protoreflect.Message
func (*CheckpointRequest) Reset ¶
func (x *CheckpointRequest) Reset()
func (*CheckpointRequest) String ¶
func (x *CheckpointRequest) String() string
type CheckpointResponse ¶
type CheckpointResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
MemPath string `protobuf:"bytes,2,opt,name=memPath,proto3" json:"memPath,omitempty"`
CkptPath string `protobuf:"bytes,3,opt,name=ckptPath,proto3" json:"ckptPath,omitempty"`
// contains filtered or unexported fields
}
func (*CheckpointResponse) Descriptor
deprecated
func (*CheckpointResponse) Descriptor() ([]byte, []int)
Deprecated: Use CheckpointResponse.ProtoReflect.Descriptor instead.
func (*CheckpointResponse) GetCkptPath ¶ added in v0.9.98
func (x *CheckpointResponse) GetCkptPath() string
func (*CheckpointResponse) GetMemPath ¶ added in v0.9.98
func (x *CheckpointResponse) GetMemPath() string
func (*CheckpointResponse) GetSuccess ¶
func (x *CheckpointResponse) GetSuccess() bool
func (*CheckpointResponse) ProtoMessage ¶
func (*CheckpointResponse) ProtoMessage()
func (*CheckpointResponse) ProtoReflect ¶
func (x *CheckpointResponse) ProtoReflect() protoreflect.Message
func (*CheckpointResponse) Reset ¶
func (x *CheckpointResponse) Reset()
func (*CheckpointResponse) String ¶
func (x *CheckpointResponse) String() string
type RestoreRequest ¶
type RestoreRequest struct {
Directory string `protobuf:"bytes,1,opt,name=directory,proto3" json:"directory,omitempty"`
// contains filtered or unexported fields
}
func (*RestoreRequest) Descriptor
deprecated
func (*RestoreRequest) Descriptor() ([]byte, []int)
Deprecated: Use RestoreRequest.ProtoReflect.Descriptor instead.
func (*RestoreRequest) GetDirectory ¶ added in v0.9.5
func (x *RestoreRequest) GetDirectory() string
func (*RestoreRequest) ProtoMessage ¶
func (*RestoreRequest) ProtoMessage()
func (*RestoreRequest) ProtoReflect ¶
func (x *RestoreRequest) ProtoReflect() protoreflect.Message
func (*RestoreRequest) Reset ¶
func (x *RestoreRequest) Reset()
func (*RestoreRequest) String ¶
func (x *RestoreRequest) String() string
type RestoreResponse ¶
type RestoreResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
// contains filtered or unexported fields
}
func (*RestoreResponse) Descriptor
deprecated
func (*RestoreResponse) Descriptor() ([]byte, []int)
Deprecated: Use RestoreResponse.ProtoReflect.Descriptor instead.
func (*RestoreResponse) GetSuccess ¶
func (x *RestoreResponse) GetSuccess() bool
func (*RestoreResponse) ProtoMessage ¶
func (*RestoreResponse) ProtoMessage()
func (*RestoreResponse) ProtoReflect ¶
func (x *RestoreResponse) ProtoReflect() protoreflect.Message
func (*RestoreResponse) Reset ¶
func (x *RestoreResponse) Reset()
func (*RestoreResponse) String ¶
func (x *RestoreResponse) String() string
type UnimplementedCedanaGPUServer ¶
type UnimplementedCedanaGPUServer struct {
}
UnimplementedCedanaGPUServer must be embedded to have forward compatible implementations.
func (UnimplementedCedanaGPUServer) Checkpoint ¶
func (UnimplementedCedanaGPUServer) Checkpoint(context.Context, *CheckpointRequest) (*CheckpointResponse, error)
func (UnimplementedCedanaGPUServer) Restore ¶
func (UnimplementedCedanaGPUServer) Restore(context.Context, *RestoreRequest) (*RestoreResponse, error)
type UnsafeCedanaGPUServer ¶
type UnsafeCedanaGPUServer interface {
// contains filtered or unexported methods
}
UnsafeCedanaGPUServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CedanaGPUServer will result in compilation errors.
Source Files
Click to show internal directories.
Click to hide internal directories.