579 lines
22 KiB
Go
579 lines
22 KiB
Go
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
|
// versions:
|
|
// - protoc-gen-go-grpc v1.6.1
|
|
// - protoc v7.34.0
|
|
// source: proto/coredeno.proto
|
|
|
|
package proto
|
|
|
|
import (
|
|
context "context"
|
|
grpc "google.golang.org/grpc"
|
|
codes "google.golang.org/grpc/codes"
|
|
status "google.golang.org/grpc/status"
|
|
)
|
|
|
|
// This is a compile-time assertion to ensure that this generated file
|
|
// is compatible with the grpc package it is being compiled against.
|
|
// Requires gRPC-Go v1.64.0 or later.
|
|
const _ = grpc.SupportPackageIsVersion9
|
|
|
|
const (
|
|
CoreService_FileRead_FullMethodName = "/coredeno.CoreService/FileRead"
|
|
CoreService_FileWrite_FullMethodName = "/coredeno.CoreService/FileWrite"
|
|
CoreService_FileList_FullMethodName = "/coredeno.CoreService/FileList"
|
|
CoreService_FileDelete_FullMethodName = "/coredeno.CoreService/FileDelete"
|
|
CoreService_StoreGet_FullMethodName = "/coredeno.CoreService/StoreGet"
|
|
CoreService_StoreSet_FullMethodName = "/coredeno.CoreService/StoreSet"
|
|
CoreService_ProcessStart_FullMethodName = "/coredeno.CoreService/ProcessStart"
|
|
CoreService_ProcessStop_FullMethodName = "/coredeno.CoreService/ProcessStop"
|
|
)
|
|
|
|
// CoreServiceClient is the client API for CoreService 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.
|
|
//
|
|
// CoreService is implemented by CoreGO — Deno calls this for I/O.
|
|
type CoreServiceClient interface {
|
|
// Filesystem (gated by manifest permissions)
|
|
FileRead(ctx context.Context, in *FileReadRequest, opts ...grpc.CallOption) (*FileReadResponse, error)
|
|
FileWrite(ctx context.Context, in *FileWriteRequest, opts ...grpc.CallOption) (*FileWriteResponse, error)
|
|
FileList(ctx context.Context, in *FileListRequest, opts ...grpc.CallOption) (*FileListResponse, error)
|
|
FileDelete(ctx context.Context, in *FileDeleteRequest, opts ...grpc.CallOption) (*FileDeleteResponse, error)
|
|
// Object store
|
|
StoreGet(ctx context.Context, in *StoreGetRequest, opts ...grpc.CallOption) (*StoreGetResponse, error)
|
|
StoreSet(ctx context.Context, in *StoreSetRequest, opts ...grpc.CallOption) (*StoreSetResponse, error)
|
|
// Process management
|
|
ProcessStart(ctx context.Context, in *ProcessStartRequest, opts ...grpc.CallOption) (*ProcessStartResponse, error)
|
|
ProcessStop(ctx context.Context, in *ProcessStopRequest, opts ...grpc.CallOption) (*ProcessStopResponse, error)
|
|
}
|
|
|
|
type coreServiceClient struct {
|
|
cc grpc.ClientConnInterface
|
|
}
|
|
|
|
func NewCoreServiceClient(cc grpc.ClientConnInterface) CoreServiceClient {
|
|
return &coreServiceClient{cc}
|
|
}
|
|
|
|
func (c *coreServiceClient) FileRead(ctx context.Context, in *FileReadRequest, opts ...grpc.CallOption) (*FileReadResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(FileReadResponse)
|
|
err := c.cc.Invoke(ctx, CoreService_FileRead_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *coreServiceClient) FileWrite(ctx context.Context, in *FileWriteRequest, opts ...grpc.CallOption) (*FileWriteResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(FileWriteResponse)
|
|
err := c.cc.Invoke(ctx, CoreService_FileWrite_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *coreServiceClient) FileList(ctx context.Context, in *FileListRequest, opts ...grpc.CallOption) (*FileListResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(FileListResponse)
|
|
err := c.cc.Invoke(ctx, CoreService_FileList_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *coreServiceClient) FileDelete(ctx context.Context, in *FileDeleteRequest, opts ...grpc.CallOption) (*FileDeleteResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(FileDeleteResponse)
|
|
err := c.cc.Invoke(ctx, CoreService_FileDelete_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *coreServiceClient) StoreGet(ctx context.Context, in *StoreGetRequest, opts ...grpc.CallOption) (*StoreGetResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(StoreGetResponse)
|
|
err := c.cc.Invoke(ctx, CoreService_StoreGet_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *coreServiceClient) StoreSet(ctx context.Context, in *StoreSetRequest, opts ...grpc.CallOption) (*StoreSetResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(StoreSetResponse)
|
|
err := c.cc.Invoke(ctx, CoreService_StoreSet_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *coreServiceClient) ProcessStart(ctx context.Context, in *ProcessStartRequest, opts ...grpc.CallOption) (*ProcessStartResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(ProcessStartResponse)
|
|
err := c.cc.Invoke(ctx, CoreService_ProcessStart_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *coreServiceClient) ProcessStop(ctx context.Context, in *ProcessStopRequest, opts ...grpc.CallOption) (*ProcessStopResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(ProcessStopResponse)
|
|
err := c.cc.Invoke(ctx, CoreService_ProcessStop_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
// CoreServiceServer is the server API for CoreService service.
|
|
// All implementations must embed UnimplementedCoreServiceServer
|
|
// for forward compatibility.
|
|
//
|
|
// CoreService is implemented by CoreGO — Deno calls this for I/O.
|
|
type CoreServiceServer interface {
|
|
// Filesystem (gated by manifest permissions)
|
|
FileRead(context.Context, *FileReadRequest) (*FileReadResponse, error)
|
|
FileWrite(context.Context, *FileWriteRequest) (*FileWriteResponse, error)
|
|
FileList(context.Context, *FileListRequest) (*FileListResponse, error)
|
|
FileDelete(context.Context, *FileDeleteRequest) (*FileDeleteResponse, error)
|
|
// Object store
|
|
StoreGet(context.Context, *StoreGetRequest) (*StoreGetResponse, error)
|
|
StoreSet(context.Context, *StoreSetRequest) (*StoreSetResponse, error)
|
|
// Process management
|
|
ProcessStart(context.Context, *ProcessStartRequest) (*ProcessStartResponse, error)
|
|
ProcessStop(context.Context, *ProcessStopRequest) (*ProcessStopResponse, error)
|
|
mustEmbedUnimplementedCoreServiceServer()
|
|
}
|
|
|
|
// UnimplementedCoreServiceServer must be embedded to have
|
|
// forward compatible implementations.
|
|
//
|
|
// NOTE: this should be embedded by value instead of pointer to avoid a nil
|
|
// pointer dereference when methods are called.
|
|
type UnimplementedCoreServiceServer struct{}
|
|
|
|
func (UnimplementedCoreServiceServer) FileRead(context.Context, *FileReadRequest) (*FileReadResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method FileRead not implemented")
|
|
}
|
|
func (UnimplementedCoreServiceServer) FileWrite(context.Context, *FileWriteRequest) (*FileWriteResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method FileWrite not implemented")
|
|
}
|
|
func (UnimplementedCoreServiceServer) FileList(context.Context, *FileListRequest) (*FileListResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method FileList not implemented")
|
|
}
|
|
func (UnimplementedCoreServiceServer) FileDelete(context.Context, *FileDeleteRequest) (*FileDeleteResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method FileDelete not implemented")
|
|
}
|
|
func (UnimplementedCoreServiceServer) StoreGet(context.Context, *StoreGetRequest) (*StoreGetResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method StoreGet not implemented")
|
|
}
|
|
func (UnimplementedCoreServiceServer) StoreSet(context.Context, *StoreSetRequest) (*StoreSetResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method StoreSet not implemented")
|
|
}
|
|
func (UnimplementedCoreServiceServer) ProcessStart(context.Context, *ProcessStartRequest) (*ProcessStartResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method ProcessStart not implemented")
|
|
}
|
|
func (UnimplementedCoreServiceServer) ProcessStop(context.Context, *ProcessStopRequest) (*ProcessStopResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method ProcessStop not implemented")
|
|
}
|
|
func (UnimplementedCoreServiceServer) mustEmbedUnimplementedCoreServiceServer() {}
|
|
func (UnimplementedCoreServiceServer) testEmbeddedByValue() {}
|
|
|
|
// UnsafeCoreServiceServer may be embedded to opt out of forward compatibility for this service.
|
|
// Use of this interface is not recommended, as added methods to CoreServiceServer will
|
|
// result in compilation errors.
|
|
type UnsafeCoreServiceServer interface {
|
|
mustEmbedUnimplementedCoreServiceServer()
|
|
}
|
|
|
|
func RegisterCoreServiceServer(s grpc.ServiceRegistrar, srv CoreServiceServer) {
|
|
// If the following call panics, it indicates UnimplementedCoreServiceServer was
|
|
// embedded by pointer and is nil. This will cause panics if an
|
|
// unimplemented method is ever invoked, so we test this at initialization
|
|
// time to prevent it from happening at runtime later due to I/O.
|
|
if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
|
|
t.testEmbeddedByValue()
|
|
}
|
|
s.RegisterService(&CoreService_ServiceDesc, srv)
|
|
}
|
|
|
|
func _CoreService_FileRead_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(FileReadRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(CoreServiceServer).FileRead(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: CoreService_FileRead_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(CoreServiceServer).FileRead(ctx, req.(*FileReadRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _CoreService_FileWrite_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(FileWriteRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(CoreServiceServer).FileWrite(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: CoreService_FileWrite_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(CoreServiceServer).FileWrite(ctx, req.(*FileWriteRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _CoreService_FileList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(FileListRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(CoreServiceServer).FileList(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: CoreService_FileList_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(CoreServiceServer).FileList(ctx, req.(*FileListRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _CoreService_FileDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(FileDeleteRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(CoreServiceServer).FileDelete(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: CoreService_FileDelete_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(CoreServiceServer).FileDelete(ctx, req.(*FileDeleteRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _CoreService_StoreGet_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(StoreGetRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(CoreServiceServer).StoreGet(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: CoreService_StoreGet_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(CoreServiceServer).StoreGet(ctx, req.(*StoreGetRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _CoreService_StoreSet_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(StoreSetRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(CoreServiceServer).StoreSet(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: CoreService_StoreSet_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(CoreServiceServer).StoreSet(ctx, req.(*StoreSetRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _CoreService_ProcessStart_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ProcessStartRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(CoreServiceServer).ProcessStart(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: CoreService_ProcessStart_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(CoreServiceServer).ProcessStart(ctx, req.(*ProcessStartRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _CoreService_ProcessStop_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ProcessStopRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(CoreServiceServer).ProcessStop(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: CoreService_ProcessStop_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(CoreServiceServer).ProcessStop(ctx, req.(*ProcessStopRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
// CoreService_ServiceDesc is the grpc.ServiceDesc for CoreService service.
|
|
// It's only intended for direct use with grpc.RegisterService,
|
|
// and not to be introspected or modified (even as a copy)
|
|
var CoreService_ServiceDesc = grpc.ServiceDesc{
|
|
ServiceName: "coredeno.CoreService",
|
|
HandlerType: (*CoreServiceServer)(nil),
|
|
Methods: []grpc.MethodDesc{
|
|
{
|
|
MethodName: "FileRead",
|
|
Handler: _CoreService_FileRead_Handler,
|
|
},
|
|
{
|
|
MethodName: "FileWrite",
|
|
Handler: _CoreService_FileWrite_Handler,
|
|
},
|
|
{
|
|
MethodName: "FileList",
|
|
Handler: _CoreService_FileList_Handler,
|
|
},
|
|
{
|
|
MethodName: "FileDelete",
|
|
Handler: _CoreService_FileDelete_Handler,
|
|
},
|
|
{
|
|
MethodName: "StoreGet",
|
|
Handler: _CoreService_StoreGet_Handler,
|
|
},
|
|
{
|
|
MethodName: "StoreSet",
|
|
Handler: _CoreService_StoreSet_Handler,
|
|
},
|
|
{
|
|
MethodName: "ProcessStart",
|
|
Handler: _CoreService_ProcessStart_Handler,
|
|
},
|
|
{
|
|
MethodName: "ProcessStop",
|
|
Handler: _CoreService_ProcessStop_Handler,
|
|
},
|
|
},
|
|
Streams: []grpc.StreamDesc{},
|
|
Metadata: "proto/coredeno.proto",
|
|
}
|
|
|
|
const (
|
|
DenoService_LoadModule_FullMethodName = "/coredeno.DenoService/LoadModule"
|
|
DenoService_UnloadModule_FullMethodName = "/coredeno.DenoService/UnloadModule"
|
|
DenoService_ModuleStatus_FullMethodName = "/coredeno.DenoService/ModuleStatus"
|
|
)
|
|
|
|
// DenoServiceClient is the client API for DenoService 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.
|
|
//
|
|
// DenoService is implemented by CoreDeno — Go calls this for module lifecycle.
|
|
type DenoServiceClient interface {
|
|
LoadModule(ctx context.Context, in *LoadModuleRequest, opts ...grpc.CallOption) (*LoadModuleResponse, error)
|
|
UnloadModule(ctx context.Context, in *UnloadModuleRequest, opts ...grpc.CallOption) (*UnloadModuleResponse, error)
|
|
ModuleStatus(ctx context.Context, in *ModuleStatusRequest, opts ...grpc.CallOption) (*ModuleStatusResponse, error)
|
|
}
|
|
|
|
type denoServiceClient struct {
|
|
cc grpc.ClientConnInterface
|
|
}
|
|
|
|
func NewDenoServiceClient(cc grpc.ClientConnInterface) DenoServiceClient {
|
|
return &denoServiceClient{cc}
|
|
}
|
|
|
|
func (c *denoServiceClient) LoadModule(ctx context.Context, in *LoadModuleRequest, opts ...grpc.CallOption) (*LoadModuleResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(LoadModuleResponse)
|
|
err := c.cc.Invoke(ctx, DenoService_LoadModule_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *denoServiceClient) UnloadModule(ctx context.Context, in *UnloadModuleRequest, opts ...grpc.CallOption) (*UnloadModuleResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(UnloadModuleResponse)
|
|
err := c.cc.Invoke(ctx, DenoService_UnloadModule_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *denoServiceClient) ModuleStatus(ctx context.Context, in *ModuleStatusRequest, opts ...grpc.CallOption) (*ModuleStatusResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(ModuleStatusResponse)
|
|
err := c.cc.Invoke(ctx, DenoService_ModuleStatus_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
// DenoServiceServer is the server API for DenoService service.
|
|
// All implementations must embed UnimplementedDenoServiceServer
|
|
// for forward compatibility.
|
|
//
|
|
// DenoService is implemented by CoreDeno — Go calls this for module lifecycle.
|
|
type DenoServiceServer interface {
|
|
LoadModule(context.Context, *LoadModuleRequest) (*LoadModuleResponse, error)
|
|
UnloadModule(context.Context, *UnloadModuleRequest) (*UnloadModuleResponse, error)
|
|
ModuleStatus(context.Context, *ModuleStatusRequest) (*ModuleStatusResponse, error)
|
|
mustEmbedUnimplementedDenoServiceServer()
|
|
}
|
|
|
|
// UnimplementedDenoServiceServer must be embedded to have
|
|
// forward compatible implementations.
|
|
//
|
|
// NOTE: this should be embedded by value instead of pointer to avoid a nil
|
|
// pointer dereference when methods are called.
|
|
type UnimplementedDenoServiceServer struct{}
|
|
|
|
func (UnimplementedDenoServiceServer) LoadModule(context.Context, *LoadModuleRequest) (*LoadModuleResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method LoadModule not implemented")
|
|
}
|
|
func (UnimplementedDenoServiceServer) UnloadModule(context.Context, *UnloadModuleRequest) (*UnloadModuleResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method UnloadModule not implemented")
|
|
}
|
|
func (UnimplementedDenoServiceServer) ModuleStatus(context.Context, *ModuleStatusRequest) (*ModuleStatusResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method ModuleStatus not implemented")
|
|
}
|
|
func (UnimplementedDenoServiceServer) mustEmbedUnimplementedDenoServiceServer() {}
|
|
func (UnimplementedDenoServiceServer) testEmbeddedByValue() {}
|
|
|
|
// UnsafeDenoServiceServer may be embedded to opt out of forward compatibility for this service.
|
|
// Use of this interface is not recommended, as added methods to DenoServiceServer will
|
|
// result in compilation errors.
|
|
type UnsafeDenoServiceServer interface {
|
|
mustEmbedUnimplementedDenoServiceServer()
|
|
}
|
|
|
|
func RegisterDenoServiceServer(s grpc.ServiceRegistrar, srv DenoServiceServer) {
|
|
// If the following call panics, it indicates UnimplementedDenoServiceServer was
|
|
// embedded by pointer and is nil. This will cause panics if an
|
|
// unimplemented method is ever invoked, so we test this at initialization
|
|
// time to prevent it from happening at runtime later due to I/O.
|
|
if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
|
|
t.testEmbeddedByValue()
|
|
}
|
|
s.RegisterService(&DenoService_ServiceDesc, srv)
|
|
}
|
|
|
|
func _DenoService_LoadModule_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(LoadModuleRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(DenoServiceServer).LoadModule(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: DenoService_LoadModule_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(DenoServiceServer).LoadModule(ctx, req.(*LoadModuleRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _DenoService_UnloadModule_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(UnloadModuleRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(DenoServiceServer).UnloadModule(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: DenoService_UnloadModule_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(DenoServiceServer).UnloadModule(ctx, req.(*UnloadModuleRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _DenoService_ModuleStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ModuleStatusRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(DenoServiceServer).ModuleStatus(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: DenoService_ModuleStatus_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(DenoServiceServer).ModuleStatus(ctx, req.(*ModuleStatusRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
// DenoService_ServiceDesc is the grpc.ServiceDesc for DenoService service.
|
|
// It's only intended for direct use with grpc.RegisterService,
|
|
// and not to be introspected or modified (even as a copy)
|
|
var DenoService_ServiceDesc = grpc.ServiceDesc{
|
|
ServiceName: "coredeno.DenoService",
|
|
HandlerType: (*DenoServiceServer)(nil),
|
|
Methods: []grpc.MethodDesc{
|
|
{
|
|
MethodName: "LoadModule",
|
|
Handler: _DenoService_LoadModule_Handler,
|
|
},
|
|
{
|
|
MethodName: "UnloadModule",
|
|
Handler: _DenoService_UnloadModule_Handler,
|
|
},
|
|
{
|
|
MethodName: "ModuleStatus",
|
|
Handler: _DenoService_ModuleStatus_Handler,
|
|
},
|
|
},
|
|
Streams: []grpc.StreamDesc{},
|
|
Metadata: "proto/coredeno.proto",
|
|
}
|