// 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", }