From 7bdce1af58eec5b7a9009584e224ba3a1b0fe5b6 Mon Sep 17 00:00:00 2001 From: Marvin Zhang Date: Wed, 26 Jun 2024 23:23:14 +0800 Subject: [PATCH] feat: added metrics service v2 --- core/grpc/client/client_v2.go | 43 ++--- core/grpc/server/metrics_server_v2.go | 78 +++++++- core/grpc/server/server_v2.go | 3 + core/models/client/model_service_v2.go | 7 +- core/node/service/worker_service_v2.go | 5 +- core/task/handler/service_v2.go | 5 +- grpc/dependencies_service_v2.pb.go | 2 +- grpc/dependencies_service_v2_grpc.pb.go | 33 ++-- grpc/message_service.pb.go | 2 +- grpc/message_service_grpc.pb.go | 19 +- grpc/metrics_service_v2.pb.go | 180 ++++++------------- grpc/metrics_service_v2_grpc.pb.go | 19 +- grpc/model_base_service.pb.go | 2 +- grpc/model_base_service_grpc.pb.go | 83 +++------ grpc/model_base_service_v2.pb.go | 2 +- grpc/model_base_service_v2_grpc.pb.go | 95 ++++------ grpc/model_delegate.pb.go | 2 +- grpc/model_delegate_grpc.pb.go | 17 +- grpc/model_service_v2_request.pb.go | 2 +- grpc/node.pb.go | 2 +- grpc/node_info.pb.go | 2 +- grpc/node_service.pb.go | 2 +- grpc/node_service_grpc.pb.go | 43 ++--- grpc/plugin_request.pb.go | 2 +- grpc/plugin_service.pb.go | 2 +- grpc/plugin_service_grpc.pb.go | 33 ++-- grpc/proto/services/metrics_service_v2.proto | 7 +- grpc/request.pb.go | 2 +- grpc/response.pb.go | 2 +- grpc/response_code.pb.go | 2 +- grpc/stream_message.pb.go | 2 +- grpc/stream_message_code.pb.go | 2 +- grpc/stream_message_data_task.pb.go | 2 +- grpc/task.pb.go | 2 +- grpc/task_service.pb.go | 2 +- grpc/task_service_grpc.pb.go | 31 ++-- 36 files changed, 302 insertions(+), 437 deletions(-) diff --git a/core/grpc/client/client_v2.go b/core/grpc/client/client_v2.go index f4ddc2e3..1e49733f 100644 --- a/core/grpc/client/client_v2.go +++ b/core/grpc/client/client_v2.go @@ -19,6 +19,7 @@ import ( "google.golang.org/grpc/connectivity" "google.golang.org/grpc/credentials/insecure" "io" + "sync" "time" ) @@ -41,10 +42,7 @@ type GrpcClientV2 struct { TaskClient grpc2.TaskServiceClient ModelBaseServiceV2Client grpc2.ModelBaseServiceV2Client DependenciesClient grpc2.DependenciesServiceV2Client -} - -func (c *GrpcClientV2) Init() (err error) { - return nil + MetricsClient grpc2.MetricsServiceV2Client } func (c *GrpcClientV2) Start() (err error) { @@ -96,11 +94,7 @@ func (c *GrpcClientV2) Register() { c.ModelBaseServiceV2Client = grpc2.NewModelBaseServiceV2Client(c.conn) c.TaskClient = grpc2.NewTaskServiceClient(c.conn) c.DependenciesClient = grpc2.NewDependenciesServiceV2Client(c.conn) - - // log - log.Infof("[GrpcClient] grpc client registered client services") - log.Debugf("[GrpcClient] NodeClient: %v", c.NodeClient) - log.Debugf("[GrpcClient] ModelBaseServiceV2Client: %v", c.ModelBaseServiceV2Client) + c.MetricsClient = grpc2.NewMetricsServiceV2Client(c.conn) } func (c *GrpcClientV2) Context() (ctx context.Context, cancel context.CancelFunc) { @@ -248,7 +242,7 @@ func (c *GrpcClientV2) handleStreamMessage() { } } -func NewGrpcClientV2() (c *GrpcClientV2, err error) { +func newGrpcClientV2() (c *GrpcClientV2) { client := &GrpcClientV2{ address: entity.NewAddress(&entity.AddressOptions{ Host: constants.DefaultGrpcClientRemoteHost, @@ -260,28 +254,23 @@ func NewGrpcClientV2() (c *GrpcClientV2, err error) { client.nodeCfgSvc = nodeconfig.GetNodeConfigService() if viper.GetString("grpc.address") != "" { - client.address, err = entity.NewAddressFromString(viper.GetString("grpc.address")) + address, err := entity.NewAddressFromString(viper.GetString("grpc.address")) if err != nil { - return nil, trace.TraceError(err) + log.Errorf("failed to parse grpc address: %s", viper.GetString("grpc.address")) + panic(err) } + client.address = address } - if err := client.Init(); err != nil { - return nil, err - } - - return client, nil + return client } -var _clientV2 *GrpcClientV2 +var clientV2 *GrpcClientV2 +var clientV2Once sync.Once -func GetGrpcClientV2() (client *GrpcClientV2, err error) { - if _clientV2 != nil { - return _clientV2, nil - } - _clientV2, err = NewGrpcClientV2() - if err != nil { - return nil, err - } - return _clientV2, nil +func GetGrpcClientV2() *GrpcClientV2 { + clientV2Once.Do(func() { + clientV2 = newGrpcClientV2() + }) + return clientV2 } diff --git a/core/grpc/server/metrics_server_v2.go b/core/grpc/server/metrics_server_v2.go index 19a0a0d5..c694b2ab 100644 --- a/core/grpc/server/metrics_server_v2.go +++ b/core/grpc/server/metrics_server_v2.go @@ -1,12 +1,86 @@ package server import ( + "errors" + "github.com/apex/log" "github.com/crawlab-team/crawlab/grpc" + "io" "sync" ) type MetricsServerV2 struct { grpc.UnimplementedMetricsServiceV2Server - mu *sync.Mutex - streams map[string]*grpc.MetricsServiceV2_ConnectServer + mu *sync.Mutex + streams map[string]*grpc.MetricsServiceV2_ConnectServer + channels map[string]chan []*grpc.Metric +} + +func (svr MetricsServerV2) Connect(stream grpc.MetricsServiceV2_ConnectServer) (err error) { + // receive first message + req, err := stream.Recv() + if err != nil { + log.Errorf("[MetricsServerV2] receive error: %v", err) + return err + } + + // save stream and channel + svr.mu.Lock() + svr.streams[req.NodeKey] = &stream + svr.channels[req.NodeKey] = make(chan []*grpc.Metric) + svr.mu.Unlock() + + log.Info("[MetricsServerV2] connected: " + req.NodeKey) + + for { + // receive metrics + req, err = stream.Recv() + if errors.Is(err, io.EOF) { + log.Errorf("[MetricsServerV2] receive EOF: %v", err) + return + } + + // send metrics to channel + svr.channels[req.NodeKey] <- req.Metrics + + // keep this scope alive because once this scope exits - the stream is closed + select { + case <-stream.Context().Done(): + log.Info("[MetricsServerV2] disconnected: " + req.NodeKey) + delete(svr.streams, req.NodeKey) + delete(svr.channels, req.NodeKey) + return nil + } + } +} + +func (svr MetricsServerV2) GetStream(nodeKey string) (stream *grpc.MetricsServiceV2_ConnectServer, ok bool) { + svr.mu.Lock() + defer svr.mu.Unlock() + stream, ok = svr.streams[nodeKey] + return stream, ok +} + +func (svr MetricsServerV2) GetChannel(nodeKey string) (ch chan []*grpc.Metric, ok bool) { + svr.mu.Lock() + defer svr.mu.Unlock() + ch, ok = svr.channels[nodeKey] + return ch, ok +} + +func NewMetricsServerV2() *MetricsServerV2 { + return &MetricsServerV2{ + mu: new(sync.Mutex), + streams: make(map[string]*grpc.MetricsServiceV2_ConnectServer), + channels: make(map[string]chan []*grpc.Metric), + } +} + +var metricsServerV2 *MetricsServerV2 + +func GetMetricsServerV2() *MetricsServerV2 { + if metricsServerV2 != nil { + return metricsServerV2 + } + metricsServerV2 = NewMetricsServerV2() + return metricsServerV2 } diff --git a/core/grpc/server/server_v2.go b/core/grpc/server/server_v2.go index ad04c5a0..e8c8ba06 100644 --- a/core/grpc/server/server_v2.go +++ b/core/grpc/server/server_v2.go @@ -46,6 +46,7 @@ type GrpcServerV2 struct { TaskSvr *TaskServerV2 ModelBaseServiceSvr *ModelBaseServiceServerV2 DependenciesSvr *DependenciesServerV2 + MetricsSvr *MetricsServerV2 } func (svr *GrpcServerV2) GetConfigPath() (path string) { @@ -119,6 +120,7 @@ func (svr *GrpcServerV2) Register() (err error) { grpc2.RegisterModelBaseServiceV2Server(svr.svr, *svr.ModelBaseServiceSvr) grpc2.RegisterTaskServiceServer(svr.svr, *svr.TaskSvr) grpc2.RegisterDependenciesServiceV2Server(svr.svr, *svr.DependenciesSvr) + grpc2.RegisterMetricsServiceV2Server(svr.svr, *svr.MetricsSvr) return nil } @@ -217,6 +219,7 @@ func NewGrpcServerV2() (svr *GrpcServerV2, err error) { return nil, err } svr.DependenciesSvr = GetDependenciesServerV2() + svr.MetricsSvr = GetMetricsServerV2() // recovery options recoveryOpts := []grpc_recovery.Option{ diff --git a/core/models/client/model_service_v2.go b/core/models/client/model_service_v2.go index 049f584e..d8921ab5 100644 --- a/core/models/client/model_service_v2.go +++ b/core/models/client/model_service_v2.go @@ -336,12 +336,9 @@ func NewModelServiceV2[T any]() *ModelServiceV2[T] { var instance *ModelServiceV2[T] - c, err := client.GetGrpcClientV2() - if err != nil { - panic(err) - } + c := client.GetGrpcClientV2() if !c.IsStarted() { - err = c.Start() + err := c.Start() if err != nil { panic(err) } diff --git a/core/node/service/worker_service_v2.go b/core/node/service/worker_service_v2.go index 0134c54d..e8340523 100644 --- a/core/node/service/worker_service_v2.go +++ b/core/node/service/worker_service_v2.go @@ -205,10 +205,7 @@ func NewWorkerServiceV2() (res *WorkerServiceV2, err error) { } // grpc client - svc.client, err = client.NewGrpcClientV2() - if err != nil { - return nil, err - } + svc.client = client.GetGrpcClientV2() // handler service svc.handlerSvc, err = handler.GetTaskHandlerServiceV2() diff --git a/core/task/handler/service_v2.go b/core/task/handler/service_v2.go index 4635ef48..50afc781 100644 --- a/core/task/handler/service_v2.go +++ b/core/task/handler/service_v2.go @@ -405,10 +405,7 @@ func NewTaskHandlerServiceV2() (svc2 *ServiceV2, err error) { svc.cfgSvc = nodeconfig.GetNodeConfigService() // grpc client - svc.c, err = grpcclient.NewGrpcClientV2() - if err != nil { - return nil, err - } + svc.c = grpcclient.GetGrpcClientV2() log.Debugf("[NewTaskHandlerService] svc[cfgPath: %s]", svc.cfgSvc.GetConfigPath()) diff --git a/grpc/dependencies_service_v2.pb.go b/grpc/dependencies_service_v2.pb.go index 00e716da..f703c5e7 100644 --- a/grpc/dependencies_service_v2.pb.go +++ b/grpc/dependencies_service_v2.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: services/dependencies_service_v2.proto package grpc diff --git a/grpc/dependencies_service_v2_grpc.pb.go b/grpc/dependencies_service_v2_grpc.pb.go index 7afcf167..90aa999b 100644 --- a/grpc/dependencies_service_v2_grpc.pb.go +++ b/grpc/dependencies_service_v2_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.4.0 -// - protoc v3.12.4 +// - protoc-gen-go-grpc v1.2.0 +// - protoc v5.27.2 // source: services/dependencies_service_v2.proto package grpc @@ -15,14 +15,8 @@ import ( // 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.62.0 or later. -const _ = grpc.SupportPackageIsVersion8 - -const ( - DependenciesServiceV2_Connect_FullMethodName = "/grpc.DependenciesServiceV2/Connect" - DependenciesServiceV2_Sync_FullMethodName = "/grpc.DependenciesServiceV2/Sync" - DependenciesServiceV2_UpdateTaskLog_FullMethodName = "/grpc.DependenciesServiceV2/UpdateTaskLog" -) +// Requires gRPC-Go v1.32.0 or later. +const _ = grpc.SupportPackageIsVersion7 // DependenciesServiceV2Client is the client API for DependenciesServiceV2 service. // @@ -42,12 +36,11 @@ func NewDependenciesServiceV2Client(cc grpc.ClientConnInterface) DependenciesSer } func (c *dependenciesServiceV2Client) Connect(ctx context.Context, in *DependenciesServiceV2ConnectRequest, opts ...grpc.CallOption) (DependenciesServiceV2_ConnectClient, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - stream, err := c.cc.NewStream(ctx, &DependenciesServiceV2_ServiceDesc.Streams[0], DependenciesServiceV2_Connect_FullMethodName, cOpts...) + stream, err := c.cc.NewStream(ctx, &DependenciesServiceV2_ServiceDesc.Streams[0], "/grpc.DependenciesServiceV2/Connect", opts...) if err != nil { return nil, err } - x := &dependenciesServiceV2ConnectClient{ClientStream: stream} + x := &dependenciesServiceV2ConnectClient{stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -75,9 +68,8 @@ func (x *dependenciesServiceV2ConnectClient) Recv() (*DependenciesServiceV2Conne } func (c *dependenciesServiceV2Client) Sync(ctx context.Context, in *DependenciesServiceV2SyncRequest, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, DependenciesServiceV2_Sync_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.DependenciesServiceV2/Sync", in, out, opts...) if err != nil { return nil, err } @@ -85,12 +77,11 @@ func (c *dependenciesServiceV2Client) Sync(ctx context.Context, in *Dependencies } func (c *dependenciesServiceV2Client) UpdateTaskLog(ctx context.Context, opts ...grpc.CallOption) (DependenciesServiceV2_UpdateTaskLogClient, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - stream, err := c.cc.NewStream(ctx, &DependenciesServiceV2_ServiceDesc.Streams[1], DependenciesServiceV2_UpdateTaskLog_FullMethodName, cOpts...) + stream, err := c.cc.NewStream(ctx, &DependenciesServiceV2_ServiceDesc.Streams[1], "/grpc.DependenciesServiceV2/UpdateTaskLog", opts...) if err != nil { return nil, err } - x := &dependenciesServiceV2UpdateTaskLogClient{ClientStream: stream} + x := &dependenciesServiceV2UpdateTaskLogClient{stream} return x, nil } @@ -160,7 +151,7 @@ func _DependenciesServiceV2_Connect_Handler(srv interface{}, stream grpc.ServerS if err := stream.RecvMsg(m); err != nil { return err } - return srv.(DependenciesServiceV2Server).Connect(m, &dependenciesServiceV2ConnectServer{ServerStream: stream}) + return srv.(DependenciesServiceV2Server).Connect(m, &dependenciesServiceV2ConnectServer{stream}) } type DependenciesServiceV2_ConnectServer interface { @@ -186,7 +177,7 @@ func _DependenciesServiceV2_Sync_Handler(srv interface{}, ctx context.Context, d } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: DependenciesServiceV2_Sync_FullMethodName, + FullMethod: "/grpc.DependenciesServiceV2/Sync", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(DependenciesServiceV2Server).Sync(ctx, req.(*DependenciesServiceV2SyncRequest)) @@ -195,7 +186,7 @@ func _DependenciesServiceV2_Sync_Handler(srv interface{}, ctx context.Context, d } func _DependenciesServiceV2_UpdateTaskLog_Handler(srv interface{}, stream grpc.ServerStream) error { - return srv.(DependenciesServiceV2Server).UpdateTaskLog(&dependenciesServiceV2UpdateTaskLogServer{ServerStream: stream}) + return srv.(DependenciesServiceV2Server).UpdateTaskLog(&dependenciesServiceV2UpdateTaskLogServer{stream}) } type DependenciesServiceV2_UpdateTaskLogServer interface { diff --git a/grpc/message_service.pb.go b/grpc/message_service.pb.go index a651f61d..ef667f2e 100644 --- a/grpc/message_service.pb.go +++ b/grpc/message_service.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: services/message_service.proto package grpc diff --git a/grpc/message_service_grpc.pb.go b/grpc/message_service_grpc.pb.go index cc6dc28f..ab488b00 100644 --- a/grpc/message_service_grpc.pb.go +++ b/grpc/message_service_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.4.0 -// - protoc v3.12.4 +// - protoc-gen-go-grpc v1.2.0 +// - protoc v5.27.2 // source: services/message_service.proto package grpc @@ -15,12 +15,8 @@ import ( // 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.62.0 or later. -const _ = grpc.SupportPackageIsVersion8 - -const ( - MessageService_Connect_FullMethodName = "/grpc.MessageService/Connect" -) +// Requires gRPC-Go v1.32.0 or later. +const _ = grpc.SupportPackageIsVersion7 // MessageServiceClient is the client API for MessageService service. // @@ -38,12 +34,11 @@ func NewMessageServiceClient(cc grpc.ClientConnInterface) MessageServiceClient { } func (c *messageServiceClient) Connect(ctx context.Context, opts ...grpc.CallOption) (MessageService_ConnectClient, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - stream, err := c.cc.NewStream(ctx, &MessageService_ServiceDesc.Streams[0], MessageService_Connect_FullMethodName, cOpts...) + stream, err := c.cc.NewStream(ctx, &MessageService_ServiceDesc.Streams[0], "/grpc.MessageService/Connect", opts...) if err != nil { return nil, err } - x := &messageServiceConnectClient{ClientStream: stream} + x := &messageServiceConnectClient{stream} return x, nil } @@ -98,7 +93,7 @@ func RegisterMessageServiceServer(s grpc.ServiceRegistrar, srv MessageServiceSer } func _MessageService_Connect_Handler(srv interface{}, stream grpc.ServerStream) error { - return srv.(MessageServiceServer).Connect(&messageServiceConnectServer{ServerStream: stream}) + return srv.(MessageServiceServer).Connect(&messageServiceConnectServer{stream}) } type MessageService_ConnectServer interface { diff --git a/grpc/metrics_service_v2.pb.go b/grpc/metrics_service_v2.pb.go index 6ab0e542..62a37ecf 100644 --- a/grpc/metrics_service_v2.pb.go +++ b/grpc/metrics_service_v2.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: services/metrics_service_v2.proto package grpc @@ -68,14 +68,13 @@ type Metric struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` - Subsystem string `protobuf:"bytes,2,opt,name=subsystem,proto3" json:"subsystem,omitempty"` - Module string `protobuf:"bytes,3,opt,name=module,proto3" json:"module,omitempty"` - Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` - Value float32 `protobuf:"fixed32,5,opt,name=value,proto3" json:"value,omitempty"` - Help string `protobuf:"bytes,6,opt,name=help,proto3" json:"help,omitempty"` - Labels string `protobuf:"bytes,7,opt,name=labels,proto3" json:"labels,omitempty"` - Process *MetricProcess `protobuf:"bytes,8,opt,name=process,proto3" json:"process,omitempty"` + Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` + Subsystem string `protobuf:"bytes,2,opt,name=subsystem,proto3" json:"subsystem,omitempty"` + Module string `protobuf:"bytes,3,opt,name=module,proto3" json:"module,omitempty"` + Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` + Value float32 `protobuf:"fixed32,5,opt,name=value,proto3" json:"value,omitempty"` + Help string `protobuf:"bytes,6,opt,name=help,proto3" json:"help,omitempty"` + Labels []byte `protobuf:"bytes,7,opt,name=labels,proto3" json:"labels,omitempty"` } func (x *Metric) Reset() { @@ -152,67 +151,13 @@ func (x *Metric) GetHelp() string { return "" } -func (x *Metric) GetLabels() string { +func (x *Metric) GetLabels() []byte { if x != nil { return x.Labels } - return "" -} - -func (x *Metric) GetProcess() *MetricProcess { - if x != nil { - return x.Process - } return nil } -type MetricProcess struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"` -} - -func (x *MetricProcess) Reset() { - *x = MetricProcess{} - if protoimpl.UnsafeEnabled { - mi := &file_services_metrics_service_v2_proto_msgTypes[1] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *MetricProcess) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*MetricProcess) ProtoMessage() {} - -func (x *MetricProcess) ProtoReflect() protoreflect.Message { - mi := &file_services_metrics_service_v2_proto_msgTypes[1] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use MetricProcess.ProtoReflect.Descriptor instead. -func (*MetricProcess) Descriptor() ([]byte, []int) { - return file_services_metrics_service_v2_proto_rawDescGZIP(), []int{1} -} - -func (x *MetricProcess) GetPid() int32 { - if x != nil { - return x.Pid - } - return 0 -} - type MetricsServiceV2ConnectRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -225,7 +170,7 @@ type MetricsServiceV2ConnectRequest struct { func (x *MetricsServiceV2ConnectRequest) Reset() { *x = MetricsServiceV2ConnectRequest{} if protoimpl.UnsafeEnabled { - mi := &file_services_metrics_service_v2_proto_msgTypes[2] + mi := &file_services_metrics_service_v2_proto_msgTypes[1] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -238,7 +183,7 @@ func (x *MetricsServiceV2ConnectRequest) String() string { func (*MetricsServiceV2ConnectRequest) ProtoMessage() {} func (x *MetricsServiceV2ConnectRequest) ProtoReflect() protoreflect.Message { - mi := &file_services_metrics_service_v2_proto_msgTypes[2] + mi := &file_services_metrics_service_v2_proto_msgTypes[1] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -251,7 +196,7 @@ func (x *MetricsServiceV2ConnectRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use MetricsServiceV2ConnectRequest.ProtoReflect.Descriptor instead. func (*MetricsServiceV2ConnectRequest) Descriptor() ([]byte, []int) { - return file_services_metrics_service_v2_proto_rawDescGZIP(), []int{2} + return file_services_metrics_service_v2_proto_rawDescGZIP(), []int{1} } func (x *MetricsServiceV2ConnectRequest) GetNodeKey() string { @@ -279,7 +224,7 @@ type MetricsServiceV2ConnectResponse struct { func (x *MetricsServiceV2ConnectResponse) Reset() { *x = MetricsServiceV2ConnectResponse{} if protoimpl.UnsafeEnabled { - mi := &file_services_metrics_service_v2_proto_msgTypes[3] + mi := &file_services_metrics_service_v2_proto_msgTypes[2] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -292,7 +237,7 @@ func (x *MetricsServiceV2ConnectResponse) String() string { func (*MetricsServiceV2ConnectResponse) ProtoMessage() {} func (x *MetricsServiceV2ConnectResponse) ProtoReflect() protoreflect.Message { - mi := &file_services_metrics_service_v2_proto_msgTypes[3] + mi := &file_services_metrics_service_v2_proto_msgTypes[2] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -305,7 +250,7 @@ func (x *MetricsServiceV2ConnectResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use MetricsServiceV2ConnectResponse.ProtoReflect.Descriptor instead. func (*MetricsServiceV2ConnectResponse) Descriptor() ([]byte, []int) { - return file_services_metrics_service_v2_proto_rawDescGZIP(), []int{3} + return file_services_metrics_service_v2_proto_rawDescGZIP(), []int{2} } func (x *MetricsServiceV2ConnectResponse) GetCode() MetricsServiceV2Code { @@ -320,7 +265,7 @@ var File_services_metrics_service_v2_proto protoreflect.FileDescriptor var file_services_metrics_service_v2_proto_rawDesc = []byte{ 0x0a, 0x21, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x73, 0x2f, 0x6d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x5f, 0x76, 0x32, 0x2e, 0x70, 0x72, - 0x6f, 0x74, 0x6f, 0x12, 0x04, 0x67, 0x72, 0x70, 0x63, 0x22, 0xe1, 0x01, 0x0a, 0x06, 0x4d, 0x65, + 0x6f, 0x74, 0x6f, 0x12, 0x04, 0x67, 0x72, 0x70, 0x63, 0x22, 0xb2, 0x01, 0x0a, 0x06, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x12, 0x1c, 0x0a, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x75, 0x62, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x18, @@ -331,35 +276,30 @@ var file_services_metrics_service_v2_proto_rawDesc = []byte{ 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x02, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x68, 0x65, 0x6c, 0x70, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x68, 0x65, 0x6c, 0x70, 0x12, 0x16, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, - 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x2d, - 0x0a, 0x07, 0x70, 0x72, 0x6f, 0x63, 0x65, 0x73, 0x73, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32, - 0x13, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x50, 0x72, 0x6f, - 0x63, 0x65, 0x73, 0x73, 0x52, 0x07, 0x70, 0x72, 0x6f, 0x63, 0x65, 0x73, 0x73, 0x22, 0x21, 0x0a, - 0x0d, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x50, 0x72, 0x6f, 0x63, 0x65, 0x73, 0x73, 0x12, 0x10, - 0x0a, 0x03, 0x70, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x03, 0x70, 0x69, 0x64, - 0x22, 0x63, 0x0a, 0x1e, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x53, 0x65, 0x72, 0x76, 0x69, - 0x63, 0x65, 0x56, 0x32, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, - 0x73, 0x74, 0x12, 0x19, 0x0a, 0x08, 0x6e, 0x6f, 0x64, 0x65, 0x5f, 0x6b, 0x65, 0x79, 0x18, 0x01, - 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6e, 0x6f, 0x64, 0x65, 0x4b, 0x65, 0x79, 0x12, 0x26, 0x0a, - 0x07, 0x6d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0c, - 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x52, 0x07, 0x6d, 0x65, - 0x74, 0x72, 0x69, 0x63, 0x73, 0x22, 0x51, 0x0a, 0x1f, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, - 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x56, 0x32, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, - 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2e, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, - 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1a, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x4d, 0x65, - 0x74, 0x72, 0x69, 0x63, 0x73, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x56, 0x32, 0x43, 0x6f, - 0x64, 0x65, 0x52, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x2a, 0x28, 0x0a, 0x14, 0x4d, 0x65, 0x74, 0x72, + 0x18, 0x07, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x22, 0x63, + 0x0a, 0x1e, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, + 0x56, 0x32, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, + 0x12, 0x19, 0x0a, 0x08, 0x6e, 0x6f, 0x64, 0x65, 0x5f, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x07, 0x6e, 0x6f, 0x64, 0x65, 0x4b, 0x65, 0x79, 0x12, 0x26, 0x0a, 0x07, 0x6d, + 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x67, + 0x72, 0x70, 0x63, 0x2e, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x52, 0x07, 0x6d, 0x65, 0x74, 0x72, + 0x69, 0x63, 0x73, 0x22, 0x51, 0x0a, 0x1f, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x53, 0x65, + 0x72, 0x76, 0x69, 0x63, 0x65, 0x56, 0x32, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x52, 0x65, + 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2e, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, + 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1a, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x56, 0x32, 0x43, 0x6f, 0x64, 0x65, - 0x12, 0x10, 0x0a, 0x0c, 0x53, 0x59, 0x4e, 0x43, 0x5f, 0x4d, 0x45, 0x54, 0x52, 0x49, 0x43, 0x53, - 0x10, 0x00, 0x32, 0x70, 0x0a, 0x10, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x53, 0x65, 0x72, - 0x76, 0x69, 0x63, 0x65, 0x56, 0x32, 0x12, 0x5c, 0x0a, 0x07, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, - 0x74, 0x12, 0x24, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, - 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x56, 0x32, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, - 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x4d, - 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x56, 0x32, 0x43, - 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, - 0x28, 0x01, 0x30, 0x01, 0x42, 0x08, 0x5a, 0x06, 0x2e, 0x3b, 0x67, 0x72, 0x70, 0x63, 0x62, 0x06, - 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, + 0x52, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x2a, 0x28, 0x0a, 0x14, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, + 0x73, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x56, 0x32, 0x43, 0x6f, 0x64, 0x65, 0x12, 0x10, + 0x0a, 0x0c, 0x53, 0x59, 0x4e, 0x43, 0x5f, 0x4d, 0x45, 0x54, 0x52, 0x49, 0x43, 0x53, 0x10, 0x00, + 0x32, 0x70, 0x0a, 0x10, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x53, 0x65, 0x72, 0x76, 0x69, + 0x63, 0x65, 0x56, 0x32, 0x12, 0x5c, 0x0a, 0x07, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x12, + 0x24, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x53, 0x65, + 0x72, 0x76, 0x69, 0x63, 0x65, 0x56, 0x32, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x52, 0x65, + 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x4d, 0x65, 0x74, + 0x72, 0x69, 0x63, 0x73, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x56, 0x32, 0x43, 0x6f, 0x6e, + 0x6e, 0x65, 0x63, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, + 0x30, 0x01, 0x42, 0x08, 0x5a, 0x06, 0x2e, 0x3b, 0x67, 0x72, 0x70, 0x63, 0x62, 0x06, 0x70, 0x72, + 0x6f, 0x74, 0x6f, 0x33, } var ( @@ -375,25 +315,23 @@ func file_services_metrics_service_v2_proto_rawDescGZIP() []byte { } var file_services_metrics_service_v2_proto_enumTypes = make([]protoimpl.EnumInfo, 1) -var file_services_metrics_service_v2_proto_msgTypes = make([]protoimpl.MessageInfo, 4) +var file_services_metrics_service_v2_proto_msgTypes = make([]protoimpl.MessageInfo, 3) var file_services_metrics_service_v2_proto_goTypes = []any{ (MetricsServiceV2Code)(0), // 0: grpc.MetricsServiceV2Code (*Metric)(nil), // 1: grpc.Metric - (*MetricProcess)(nil), // 2: grpc.MetricProcess - (*MetricsServiceV2ConnectRequest)(nil), // 3: grpc.MetricsServiceV2ConnectRequest - (*MetricsServiceV2ConnectResponse)(nil), // 4: grpc.MetricsServiceV2ConnectResponse + (*MetricsServiceV2ConnectRequest)(nil), // 2: grpc.MetricsServiceV2ConnectRequest + (*MetricsServiceV2ConnectResponse)(nil), // 3: grpc.MetricsServiceV2ConnectResponse } var file_services_metrics_service_v2_proto_depIdxs = []int32{ - 2, // 0: grpc.Metric.process:type_name -> grpc.MetricProcess - 1, // 1: grpc.MetricsServiceV2ConnectRequest.metrics:type_name -> grpc.Metric - 0, // 2: grpc.MetricsServiceV2ConnectResponse.code:type_name -> grpc.MetricsServiceV2Code - 3, // 3: grpc.MetricsServiceV2.Connect:input_type -> grpc.MetricsServiceV2ConnectRequest - 4, // 4: grpc.MetricsServiceV2.Connect:output_type -> grpc.MetricsServiceV2ConnectResponse - 4, // [4:5] is the sub-list for method output_type - 3, // [3:4] is the sub-list for method input_type - 3, // [3:3] is the sub-list for extension type_name - 3, // [3:3] is the sub-list for extension extendee - 0, // [0:3] is the sub-list for field type_name + 1, // 0: grpc.MetricsServiceV2ConnectRequest.metrics:type_name -> grpc.Metric + 0, // 1: grpc.MetricsServiceV2ConnectResponse.code:type_name -> grpc.MetricsServiceV2Code + 2, // 2: grpc.MetricsServiceV2.Connect:input_type -> grpc.MetricsServiceV2ConnectRequest + 3, // 3: grpc.MetricsServiceV2.Connect:output_type -> grpc.MetricsServiceV2ConnectResponse + 3, // [3:4] is the sub-list for method output_type + 2, // [2:3] is the sub-list for method input_type + 2, // [2:2] is the sub-list for extension type_name + 2, // [2:2] is the sub-list for extension extendee + 0, // [0:2] is the sub-list for field type_name } func init() { file_services_metrics_service_v2_proto_init() } @@ -415,18 +353,6 @@ func file_services_metrics_service_v2_proto_init() { } } file_services_metrics_service_v2_proto_msgTypes[1].Exporter = func(v any, i int) any { - switch v := v.(*MetricProcess); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_services_metrics_service_v2_proto_msgTypes[2].Exporter = func(v any, i int) any { switch v := v.(*MetricsServiceV2ConnectRequest); i { case 0: return &v.state @@ -438,7 +364,7 @@ func file_services_metrics_service_v2_proto_init() { return nil } } - file_services_metrics_service_v2_proto_msgTypes[3].Exporter = func(v any, i int) any { + file_services_metrics_service_v2_proto_msgTypes[2].Exporter = func(v any, i int) any { switch v := v.(*MetricsServiceV2ConnectResponse); i { case 0: return &v.state @@ -457,7 +383,7 @@ func file_services_metrics_service_v2_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_services_metrics_service_v2_proto_rawDesc, NumEnums: 1, - NumMessages: 4, + NumMessages: 3, NumExtensions: 0, NumServices: 1, }, diff --git a/grpc/metrics_service_v2_grpc.pb.go b/grpc/metrics_service_v2_grpc.pb.go index e381d8db..23fe5c83 100644 --- a/grpc/metrics_service_v2_grpc.pb.go +++ b/grpc/metrics_service_v2_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.4.0 -// - protoc v3.12.4 +// - protoc-gen-go-grpc v1.2.0 +// - protoc v5.27.2 // source: services/metrics_service_v2.proto package grpc @@ -15,12 +15,8 @@ import ( // 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.62.0 or later. -const _ = grpc.SupportPackageIsVersion8 - -const ( - MetricsServiceV2_Connect_FullMethodName = "/grpc.MetricsServiceV2/Connect" -) +// Requires gRPC-Go v1.32.0 or later. +const _ = grpc.SupportPackageIsVersion7 // MetricsServiceV2Client is the client API for MetricsServiceV2 service. // @@ -38,12 +34,11 @@ func NewMetricsServiceV2Client(cc grpc.ClientConnInterface) MetricsServiceV2Clie } func (c *metricsServiceV2Client) Connect(ctx context.Context, opts ...grpc.CallOption) (MetricsServiceV2_ConnectClient, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - stream, err := c.cc.NewStream(ctx, &MetricsServiceV2_ServiceDesc.Streams[0], MetricsServiceV2_Connect_FullMethodName, cOpts...) + stream, err := c.cc.NewStream(ctx, &MetricsServiceV2_ServiceDesc.Streams[0], "/grpc.MetricsServiceV2/Connect", opts...) if err != nil { return nil, err } - x := &metricsServiceV2ConnectClient{ClientStream: stream} + x := &metricsServiceV2ConnectClient{stream} return x, nil } @@ -98,7 +93,7 @@ func RegisterMetricsServiceV2Server(s grpc.ServiceRegistrar, srv MetricsServiceV } func _MetricsServiceV2_Connect_Handler(srv interface{}, stream grpc.ServerStream) error { - return srv.(MetricsServiceV2Server).Connect(&metricsServiceV2ConnectServer{ServerStream: stream}) + return srv.(MetricsServiceV2Server).Connect(&metricsServiceV2ConnectServer{stream}) } type MetricsServiceV2_ConnectServer interface { diff --git a/grpc/model_base_service.pb.go b/grpc/model_base_service.pb.go index f3994f62..6d6bde70 100644 --- a/grpc/model_base_service.pb.go +++ b/grpc/model_base_service.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: services/model_base_service.proto package grpc diff --git a/grpc/model_base_service_grpc.pb.go b/grpc/model_base_service_grpc.pb.go index f512986d..efca7906 100644 --- a/grpc/model_base_service_grpc.pb.go +++ b/grpc/model_base_service_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.4.0 -// - protoc v3.12.4 +// - protoc-gen-go-grpc v1.2.0 +// - protoc v5.27.2 // source: services/model_base_service.proto package grpc @@ -15,23 +15,8 @@ import ( // 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.62.0 or later. -const _ = grpc.SupportPackageIsVersion8 - -const ( - ModelBaseService_GetById_FullMethodName = "/grpc.ModelBaseService/GetById" - ModelBaseService_Get_FullMethodName = "/grpc.ModelBaseService/Get" - ModelBaseService_GetList_FullMethodName = "/grpc.ModelBaseService/GetList" - ModelBaseService_DeleteById_FullMethodName = "/grpc.ModelBaseService/DeleteById" - ModelBaseService_Delete_FullMethodName = "/grpc.ModelBaseService/Delete" - ModelBaseService_DeleteList_FullMethodName = "/grpc.ModelBaseService/DeleteList" - ModelBaseService_ForceDeleteList_FullMethodName = "/grpc.ModelBaseService/ForceDeleteList" - ModelBaseService_UpdateById_FullMethodName = "/grpc.ModelBaseService/UpdateById" - ModelBaseService_Update_FullMethodName = "/grpc.ModelBaseService/Update" - ModelBaseService_UpdateDoc_FullMethodName = "/grpc.ModelBaseService/UpdateDoc" - ModelBaseService_Insert_FullMethodName = "/grpc.ModelBaseService/Insert" - ModelBaseService_Count_FullMethodName = "/grpc.ModelBaseService/Count" -) +// Requires gRPC-Go v1.32.0 or later. +const _ = grpc.SupportPackageIsVersion7 // ModelBaseServiceClient is the client API for ModelBaseService service. // @@ -60,9 +45,8 @@ func NewModelBaseServiceClient(cc grpc.ClientConnInterface) ModelBaseServiceClie } func (c *modelBaseServiceClient) GetById(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseService_GetById_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseService/GetById", in, out, opts...) if err != nil { return nil, err } @@ -70,9 +54,8 @@ func (c *modelBaseServiceClient) GetById(ctx context.Context, in *Request, opts } func (c *modelBaseServiceClient) Get(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseService_Get_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseService/Get", in, out, opts...) if err != nil { return nil, err } @@ -80,9 +63,8 @@ func (c *modelBaseServiceClient) Get(ctx context.Context, in *Request, opts ...g } func (c *modelBaseServiceClient) GetList(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseService_GetList_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseService/GetList", in, out, opts...) if err != nil { return nil, err } @@ -90,9 +72,8 @@ func (c *modelBaseServiceClient) GetList(ctx context.Context, in *Request, opts } func (c *modelBaseServiceClient) DeleteById(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseService_DeleteById_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseService/DeleteById", in, out, opts...) if err != nil { return nil, err } @@ -100,9 +81,8 @@ func (c *modelBaseServiceClient) DeleteById(ctx context.Context, in *Request, op } func (c *modelBaseServiceClient) Delete(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseService_Delete_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseService/Delete", in, out, opts...) if err != nil { return nil, err } @@ -110,9 +90,8 @@ func (c *modelBaseServiceClient) Delete(ctx context.Context, in *Request, opts . } func (c *modelBaseServiceClient) DeleteList(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseService_DeleteList_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseService/DeleteList", in, out, opts...) if err != nil { return nil, err } @@ -120,9 +99,8 @@ func (c *modelBaseServiceClient) DeleteList(ctx context.Context, in *Request, op } func (c *modelBaseServiceClient) ForceDeleteList(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseService_ForceDeleteList_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseService/ForceDeleteList", in, out, opts...) if err != nil { return nil, err } @@ -130,9 +108,8 @@ func (c *modelBaseServiceClient) ForceDeleteList(ctx context.Context, in *Reques } func (c *modelBaseServiceClient) UpdateById(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseService_UpdateById_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseService/UpdateById", in, out, opts...) if err != nil { return nil, err } @@ -140,9 +117,8 @@ func (c *modelBaseServiceClient) UpdateById(ctx context.Context, in *Request, op } func (c *modelBaseServiceClient) Update(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseService_Update_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseService/Update", in, out, opts...) if err != nil { return nil, err } @@ -150,9 +126,8 @@ func (c *modelBaseServiceClient) Update(ctx context.Context, in *Request, opts . } func (c *modelBaseServiceClient) UpdateDoc(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseService_UpdateDoc_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseService/UpdateDoc", in, out, opts...) if err != nil { return nil, err } @@ -160,9 +135,8 @@ func (c *modelBaseServiceClient) UpdateDoc(ctx context.Context, in *Request, opt } func (c *modelBaseServiceClient) Insert(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseService_Insert_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseService/Insert", in, out, opts...) if err != nil { return nil, err } @@ -170,9 +144,8 @@ func (c *modelBaseServiceClient) Insert(ctx context.Context, in *Request, opts . } func (c *modelBaseServiceClient) Count(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseService_Count_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseService/Count", in, out, opts...) if err != nil { return nil, err } @@ -261,7 +234,7 @@ func _ModelBaseService_GetById_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseService_GetById_FullMethodName, + FullMethod: "/grpc.ModelBaseService/GetById", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceServer).GetById(ctx, req.(*Request)) @@ -279,7 +252,7 @@ func _ModelBaseService_Get_Handler(srv interface{}, ctx context.Context, dec fun } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseService_Get_FullMethodName, + FullMethod: "/grpc.ModelBaseService/Get", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceServer).Get(ctx, req.(*Request)) @@ -297,7 +270,7 @@ func _ModelBaseService_GetList_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseService_GetList_FullMethodName, + FullMethod: "/grpc.ModelBaseService/GetList", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceServer).GetList(ctx, req.(*Request)) @@ -315,7 +288,7 @@ func _ModelBaseService_DeleteById_Handler(srv interface{}, ctx context.Context, } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseService_DeleteById_FullMethodName, + FullMethod: "/grpc.ModelBaseService/DeleteById", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceServer).DeleteById(ctx, req.(*Request)) @@ -333,7 +306,7 @@ func _ModelBaseService_Delete_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseService_Delete_FullMethodName, + FullMethod: "/grpc.ModelBaseService/Delete", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceServer).Delete(ctx, req.(*Request)) @@ -351,7 +324,7 @@ func _ModelBaseService_DeleteList_Handler(srv interface{}, ctx context.Context, } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseService_DeleteList_FullMethodName, + FullMethod: "/grpc.ModelBaseService/DeleteList", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceServer).DeleteList(ctx, req.(*Request)) @@ -369,7 +342,7 @@ func _ModelBaseService_ForceDeleteList_Handler(srv interface{}, ctx context.Cont } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseService_ForceDeleteList_FullMethodName, + FullMethod: "/grpc.ModelBaseService/ForceDeleteList", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceServer).ForceDeleteList(ctx, req.(*Request)) @@ -387,7 +360,7 @@ func _ModelBaseService_UpdateById_Handler(srv interface{}, ctx context.Context, } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseService_UpdateById_FullMethodName, + FullMethod: "/grpc.ModelBaseService/UpdateById", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceServer).UpdateById(ctx, req.(*Request)) @@ -405,7 +378,7 @@ func _ModelBaseService_Update_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseService_Update_FullMethodName, + FullMethod: "/grpc.ModelBaseService/Update", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceServer).Update(ctx, req.(*Request)) @@ -423,7 +396,7 @@ func _ModelBaseService_UpdateDoc_Handler(srv interface{}, ctx context.Context, d } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseService_UpdateDoc_FullMethodName, + FullMethod: "/grpc.ModelBaseService/UpdateDoc", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceServer).UpdateDoc(ctx, req.(*Request)) @@ -441,7 +414,7 @@ func _ModelBaseService_Insert_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseService_Insert_FullMethodName, + FullMethod: "/grpc.ModelBaseService/Insert", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceServer).Insert(ctx, req.(*Request)) @@ -459,7 +432,7 @@ func _ModelBaseService_Count_Handler(srv interface{}, ctx context.Context, dec f } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseService_Count_FullMethodName, + FullMethod: "/grpc.ModelBaseService/Count", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceServer).Count(ctx, req.(*Request)) diff --git a/grpc/model_base_service_v2.pb.go b/grpc/model_base_service_v2.pb.go index e29db893..c6eca7cb 100644 --- a/grpc/model_base_service_v2.pb.go +++ b/grpc/model_base_service_v2.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: services/model_base_service_v2.proto package grpc diff --git a/grpc/model_base_service_v2_grpc.pb.go b/grpc/model_base_service_v2_grpc.pb.go index 805475d3..203049d7 100644 --- a/grpc/model_base_service_v2_grpc.pb.go +++ b/grpc/model_base_service_v2_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.4.0 -// - protoc v3.12.4 +// - protoc-gen-go-grpc v1.2.0 +// - protoc v5.27.2 // source: services/model_base_service_v2.proto package grpc @@ -15,25 +15,8 @@ import ( // 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.62.0 or later. -const _ = grpc.SupportPackageIsVersion8 - -const ( - ModelBaseServiceV2_GetById_FullMethodName = "/grpc.ModelBaseServiceV2/GetById" - ModelBaseServiceV2_GetOne_FullMethodName = "/grpc.ModelBaseServiceV2/GetOne" - ModelBaseServiceV2_GetMany_FullMethodName = "/grpc.ModelBaseServiceV2/GetMany" - ModelBaseServiceV2_DeleteById_FullMethodName = "/grpc.ModelBaseServiceV2/DeleteById" - ModelBaseServiceV2_DeleteOne_FullMethodName = "/grpc.ModelBaseServiceV2/DeleteOne" - ModelBaseServiceV2_DeleteMany_FullMethodName = "/grpc.ModelBaseServiceV2/DeleteMany" - ModelBaseServiceV2_UpdateById_FullMethodName = "/grpc.ModelBaseServiceV2/UpdateById" - ModelBaseServiceV2_UpdateOne_FullMethodName = "/grpc.ModelBaseServiceV2/UpdateOne" - ModelBaseServiceV2_UpdateMany_FullMethodName = "/grpc.ModelBaseServiceV2/UpdateMany" - ModelBaseServiceV2_ReplaceById_FullMethodName = "/grpc.ModelBaseServiceV2/ReplaceById" - ModelBaseServiceV2_ReplaceOne_FullMethodName = "/grpc.ModelBaseServiceV2/ReplaceOne" - ModelBaseServiceV2_InsertOne_FullMethodName = "/grpc.ModelBaseServiceV2/InsertOne" - ModelBaseServiceV2_InsertMany_FullMethodName = "/grpc.ModelBaseServiceV2/InsertMany" - ModelBaseServiceV2_Count_FullMethodName = "/grpc.ModelBaseServiceV2/Count" -) +// Requires gRPC-Go v1.32.0 or later. +const _ = grpc.SupportPackageIsVersion7 // ModelBaseServiceV2Client is the client API for ModelBaseServiceV2 service. // @@ -64,9 +47,8 @@ func NewModelBaseServiceV2Client(cc grpc.ClientConnInterface) ModelBaseServiceV2 } func (c *modelBaseServiceV2Client) GetById(ctx context.Context, in *ModelServiceV2GetByIdRequest, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseServiceV2_GetById_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseServiceV2/GetById", in, out, opts...) if err != nil { return nil, err } @@ -74,9 +56,8 @@ func (c *modelBaseServiceV2Client) GetById(ctx context.Context, in *ModelService } func (c *modelBaseServiceV2Client) GetOne(ctx context.Context, in *ModelServiceV2GetOneRequest, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseServiceV2_GetOne_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseServiceV2/GetOne", in, out, opts...) if err != nil { return nil, err } @@ -84,9 +65,8 @@ func (c *modelBaseServiceV2Client) GetOne(ctx context.Context, in *ModelServiceV } func (c *modelBaseServiceV2Client) GetMany(ctx context.Context, in *ModelServiceV2GetManyRequest, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseServiceV2_GetMany_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseServiceV2/GetMany", in, out, opts...) if err != nil { return nil, err } @@ -94,9 +74,8 @@ func (c *modelBaseServiceV2Client) GetMany(ctx context.Context, in *ModelService } func (c *modelBaseServiceV2Client) DeleteById(ctx context.Context, in *ModelServiceV2DeleteByIdRequest, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseServiceV2_DeleteById_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseServiceV2/DeleteById", in, out, opts...) if err != nil { return nil, err } @@ -104,9 +83,8 @@ func (c *modelBaseServiceV2Client) DeleteById(ctx context.Context, in *ModelServ } func (c *modelBaseServiceV2Client) DeleteOne(ctx context.Context, in *ModelServiceV2DeleteOneRequest, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseServiceV2_DeleteOne_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseServiceV2/DeleteOne", in, out, opts...) if err != nil { return nil, err } @@ -114,9 +92,8 @@ func (c *modelBaseServiceV2Client) DeleteOne(ctx context.Context, in *ModelServi } func (c *modelBaseServiceV2Client) DeleteMany(ctx context.Context, in *ModelServiceV2DeleteManyRequest, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseServiceV2_DeleteMany_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseServiceV2/DeleteMany", in, out, opts...) if err != nil { return nil, err } @@ -124,9 +101,8 @@ func (c *modelBaseServiceV2Client) DeleteMany(ctx context.Context, in *ModelServ } func (c *modelBaseServiceV2Client) UpdateById(ctx context.Context, in *ModelServiceV2UpdateByIdRequest, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseServiceV2_UpdateById_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseServiceV2/UpdateById", in, out, opts...) if err != nil { return nil, err } @@ -134,9 +110,8 @@ func (c *modelBaseServiceV2Client) UpdateById(ctx context.Context, in *ModelServ } func (c *modelBaseServiceV2Client) UpdateOne(ctx context.Context, in *ModelServiceV2UpdateOneRequest, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseServiceV2_UpdateOne_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseServiceV2/UpdateOne", in, out, opts...) if err != nil { return nil, err } @@ -144,9 +119,8 @@ func (c *modelBaseServiceV2Client) UpdateOne(ctx context.Context, in *ModelServi } func (c *modelBaseServiceV2Client) UpdateMany(ctx context.Context, in *ModelServiceV2UpdateManyRequest, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseServiceV2_UpdateMany_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseServiceV2/UpdateMany", in, out, opts...) if err != nil { return nil, err } @@ -154,9 +128,8 @@ func (c *modelBaseServiceV2Client) UpdateMany(ctx context.Context, in *ModelServ } func (c *modelBaseServiceV2Client) ReplaceById(ctx context.Context, in *ModelServiceV2ReplaceByIdRequest, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseServiceV2_ReplaceById_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseServiceV2/ReplaceById", in, out, opts...) if err != nil { return nil, err } @@ -164,9 +137,8 @@ func (c *modelBaseServiceV2Client) ReplaceById(ctx context.Context, in *ModelSer } func (c *modelBaseServiceV2Client) ReplaceOne(ctx context.Context, in *ModelServiceV2ReplaceOneRequest, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseServiceV2_ReplaceOne_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseServiceV2/ReplaceOne", in, out, opts...) if err != nil { return nil, err } @@ -174,9 +146,8 @@ func (c *modelBaseServiceV2Client) ReplaceOne(ctx context.Context, in *ModelServ } func (c *modelBaseServiceV2Client) InsertOne(ctx context.Context, in *ModelServiceV2InsertOneRequest, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseServiceV2_InsertOne_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseServiceV2/InsertOne", in, out, opts...) if err != nil { return nil, err } @@ -184,9 +155,8 @@ func (c *modelBaseServiceV2Client) InsertOne(ctx context.Context, in *ModelServi } func (c *modelBaseServiceV2Client) InsertMany(ctx context.Context, in *ModelServiceV2InsertManyRequest, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseServiceV2_InsertMany_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseServiceV2/InsertMany", in, out, opts...) if err != nil { return nil, err } @@ -194,9 +164,8 @@ func (c *modelBaseServiceV2Client) InsertMany(ctx context.Context, in *ModelServ } func (c *modelBaseServiceV2Client) Count(ctx context.Context, in *ModelServiceV2CountRequest, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelBaseServiceV2_Count_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelBaseServiceV2/Count", in, out, opts...) if err != nil { return nil, err } @@ -293,7 +262,7 @@ func _ModelBaseServiceV2_GetById_Handler(srv interface{}, ctx context.Context, d } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseServiceV2_GetById_FullMethodName, + FullMethod: "/grpc.ModelBaseServiceV2/GetById", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceV2Server).GetById(ctx, req.(*ModelServiceV2GetByIdRequest)) @@ -311,7 +280,7 @@ func _ModelBaseServiceV2_GetOne_Handler(srv interface{}, ctx context.Context, de } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseServiceV2_GetOne_FullMethodName, + FullMethod: "/grpc.ModelBaseServiceV2/GetOne", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceV2Server).GetOne(ctx, req.(*ModelServiceV2GetOneRequest)) @@ -329,7 +298,7 @@ func _ModelBaseServiceV2_GetMany_Handler(srv interface{}, ctx context.Context, d } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseServiceV2_GetMany_FullMethodName, + FullMethod: "/grpc.ModelBaseServiceV2/GetMany", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceV2Server).GetMany(ctx, req.(*ModelServiceV2GetManyRequest)) @@ -347,7 +316,7 @@ func _ModelBaseServiceV2_DeleteById_Handler(srv interface{}, ctx context.Context } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseServiceV2_DeleteById_FullMethodName, + FullMethod: "/grpc.ModelBaseServiceV2/DeleteById", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceV2Server).DeleteById(ctx, req.(*ModelServiceV2DeleteByIdRequest)) @@ -365,7 +334,7 @@ func _ModelBaseServiceV2_DeleteOne_Handler(srv interface{}, ctx context.Context, } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseServiceV2_DeleteOne_FullMethodName, + FullMethod: "/grpc.ModelBaseServiceV2/DeleteOne", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceV2Server).DeleteOne(ctx, req.(*ModelServiceV2DeleteOneRequest)) @@ -383,7 +352,7 @@ func _ModelBaseServiceV2_DeleteMany_Handler(srv interface{}, ctx context.Context } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseServiceV2_DeleteMany_FullMethodName, + FullMethod: "/grpc.ModelBaseServiceV2/DeleteMany", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceV2Server).DeleteMany(ctx, req.(*ModelServiceV2DeleteManyRequest)) @@ -401,7 +370,7 @@ func _ModelBaseServiceV2_UpdateById_Handler(srv interface{}, ctx context.Context } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseServiceV2_UpdateById_FullMethodName, + FullMethod: "/grpc.ModelBaseServiceV2/UpdateById", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceV2Server).UpdateById(ctx, req.(*ModelServiceV2UpdateByIdRequest)) @@ -419,7 +388,7 @@ func _ModelBaseServiceV2_UpdateOne_Handler(srv interface{}, ctx context.Context, } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseServiceV2_UpdateOne_FullMethodName, + FullMethod: "/grpc.ModelBaseServiceV2/UpdateOne", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceV2Server).UpdateOne(ctx, req.(*ModelServiceV2UpdateOneRequest)) @@ -437,7 +406,7 @@ func _ModelBaseServiceV2_UpdateMany_Handler(srv interface{}, ctx context.Context } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseServiceV2_UpdateMany_FullMethodName, + FullMethod: "/grpc.ModelBaseServiceV2/UpdateMany", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceV2Server).UpdateMany(ctx, req.(*ModelServiceV2UpdateManyRequest)) @@ -455,7 +424,7 @@ func _ModelBaseServiceV2_ReplaceById_Handler(srv interface{}, ctx context.Contex } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseServiceV2_ReplaceById_FullMethodName, + FullMethod: "/grpc.ModelBaseServiceV2/ReplaceById", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceV2Server).ReplaceById(ctx, req.(*ModelServiceV2ReplaceByIdRequest)) @@ -473,7 +442,7 @@ func _ModelBaseServiceV2_ReplaceOne_Handler(srv interface{}, ctx context.Context } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseServiceV2_ReplaceOne_FullMethodName, + FullMethod: "/grpc.ModelBaseServiceV2/ReplaceOne", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceV2Server).ReplaceOne(ctx, req.(*ModelServiceV2ReplaceOneRequest)) @@ -491,7 +460,7 @@ func _ModelBaseServiceV2_InsertOne_Handler(srv interface{}, ctx context.Context, } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseServiceV2_InsertOne_FullMethodName, + FullMethod: "/grpc.ModelBaseServiceV2/InsertOne", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceV2Server).InsertOne(ctx, req.(*ModelServiceV2InsertOneRequest)) @@ -509,7 +478,7 @@ func _ModelBaseServiceV2_InsertMany_Handler(srv interface{}, ctx context.Context } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseServiceV2_InsertMany_FullMethodName, + FullMethod: "/grpc.ModelBaseServiceV2/InsertMany", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceV2Server).InsertMany(ctx, req.(*ModelServiceV2InsertManyRequest)) @@ -527,7 +496,7 @@ func _ModelBaseServiceV2_Count_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelBaseServiceV2_Count_FullMethodName, + FullMethod: "/grpc.ModelBaseServiceV2/Count", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelBaseServiceV2Server).Count(ctx, req.(*ModelServiceV2CountRequest)) diff --git a/grpc/model_delegate.pb.go b/grpc/model_delegate.pb.go index 158ed775..c0c4c9f4 100644 --- a/grpc/model_delegate.pb.go +++ b/grpc/model_delegate.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: services/model_delegate.proto package grpc diff --git a/grpc/model_delegate_grpc.pb.go b/grpc/model_delegate_grpc.pb.go index a0614e45..c8da4cc3 100644 --- a/grpc/model_delegate_grpc.pb.go +++ b/grpc/model_delegate_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.4.0 -// - protoc v3.12.4 +// - protoc-gen-go-grpc v1.2.0 +// - protoc v5.27.2 // source: services/model_delegate.proto package grpc @@ -15,12 +15,8 @@ import ( // 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.62.0 or later. -const _ = grpc.SupportPackageIsVersion8 - -const ( - ModelDelegate_Do_FullMethodName = "/grpc.ModelDelegate/Do" -) +// Requires gRPC-Go v1.32.0 or later. +const _ = grpc.SupportPackageIsVersion7 // ModelDelegateClient is the client API for ModelDelegate service. // @@ -38,9 +34,8 @@ func NewModelDelegateClient(cc grpc.ClientConnInterface) ModelDelegateClient { } func (c *modelDelegateClient) Do(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, ModelDelegate_Do_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.ModelDelegate/Do", in, out, opts...) if err != nil { return nil, err } @@ -85,7 +80,7 @@ func _ModelDelegate_Do_Handler(srv interface{}, ctx context.Context, dec func(in } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ModelDelegate_Do_FullMethodName, + FullMethod: "/grpc.ModelDelegate/Do", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ModelDelegateServer).Do(ctx, req.(*Request)) diff --git a/grpc/model_service_v2_request.pb.go b/grpc/model_service_v2_request.pb.go index e56d8d8d..c3a51f20 100644 --- a/grpc/model_service_v2_request.pb.go +++ b/grpc/model_service_v2_request.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: entity/model_service_v2_request.proto package grpc diff --git a/grpc/node.pb.go b/grpc/node.pb.go index 4285a4b5..6db136bc 100644 --- a/grpc/node.pb.go +++ b/grpc/node.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: models/node.proto package grpc diff --git a/grpc/node_info.pb.go b/grpc/node_info.pb.go index d2f36793..00ccac73 100644 --- a/grpc/node_info.pb.go +++ b/grpc/node_info.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: entity/node_info.proto package grpc diff --git a/grpc/node_service.pb.go b/grpc/node_service.pb.go index 3d344f0a..b5efe6c3 100644 --- a/grpc/node_service.pb.go +++ b/grpc/node_service.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: services/node_service.proto package grpc diff --git a/grpc/node_service_grpc.pb.go b/grpc/node_service_grpc.pb.go index e097cb97..dbff3b28 100644 --- a/grpc/node_service_grpc.pb.go +++ b/grpc/node_service_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.4.0 -// - protoc v3.12.4 +// - protoc-gen-go-grpc v1.2.0 +// - protoc v5.27.2 // source: services/node_service.proto package grpc @@ -15,16 +15,8 @@ import ( // 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.62.0 or later. -const _ = grpc.SupportPackageIsVersion8 - -const ( - NodeService_Register_FullMethodName = "/grpc.NodeService/Register" - NodeService_SendHeartbeat_FullMethodName = "/grpc.NodeService/SendHeartbeat" - NodeService_Ping_FullMethodName = "/grpc.NodeService/Ping" - NodeService_Subscribe_FullMethodName = "/grpc.NodeService/Subscribe" - NodeService_Unsubscribe_FullMethodName = "/grpc.NodeService/Unsubscribe" -) +// Requires gRPC-Go v1.32.0 or later. +const _ = grpc.SupportPackageIsVersion7 // NodeServiceClient is the client API for NodeService service. // @@ -46,9 +38,8 @@ func NewNodeServiceClient(cc grpc.ClientConnInterface) NodeServiceClient { } func (c *nodeServiceClient) Register(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, NodeService_Register_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.NodeService/Register", in, out, opts...) if err != nil { return nil, err } @@ -56,9 +47,8 @@ func (c *nodeServiceClient) Register(ctx context.Context, in *Request, opts ...g } func (c *nodeServiceClient) SendHeartbeat(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, NodeService_SendHeartbeat_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.NodeService/SendHeartbeat", in, out, opts...) if err != nil { return nil, err } @@ -66,9 +56,8 @@ func (c *nodeServiceClient) SendHeartbeat(ctx context.Context, in *Request, opts } func (c *nodeServiceClient) Ping(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, NodeService_Ping_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.NodeService/Ping", in, out, opts...) if err != nil { return nil, err } @@ -76,12 +65,11 @@ func (c *nodeServiceClient) Ping(ctx context.Context, in *Request, opts ...grpc. } func (c *nodeServiceClient) Subscribe(ctx context.Context, in *Request, opts ...grpc.CallOption) (NodeService_SubscribeClient, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - stream, err := c.cc.NewStream(ctx, &NodeService_ServiceDesc.Streams[0], NodeService_Subscribe_FullMethodName, cOpts...) + stream, err := c.cc.NewStream(ctx, &NodeService_ServiceDesc.Streams[0], "/grpc.NodeService/Subscribe", opts...) if err != nil { return nil, err } - x := &nodeServiceSubscribeClient{ClientStream: stream} + x := &nodeServiceSubscribeClient{stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -109,9 +97,8 @@ func (x *nodeServiceSubscribeClient) Recv() (*StreamMessage, error) { } func (c *nodeServiceClient) Unsubscribe(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, NodeService_Unsubscribe_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.NodeService/Unsubscribe", in, out, opts...) if err != nil { return nil, err } @@ -172,7 +159,7 @@ func _NodeService_Register_Handler(srv interface{}, ctx context.Context, dec fun } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: NodeService_Register_FullMethodName, + FullMethod: "/grpc.NodeService/Register", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(NodeServiceServer).Register(ctx, req.(*Request)) @@ -190,7 +177,7 @@ func _NodeService_SendHeartbeat_Handler(srv interface{}, ctx context.Context, de } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: NodeService_SendHeartbeat_FullMethodName, + FullMethod: "/grpc.NodeService/SendHeartbeat", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(NodeServiceServer).SendHeartbeat(ctx, req.(*Request)) @@ -208,7 +195,7 @@ func _NodeService_Ping_Handler(srv interface{}, ctx context.Context, dec func(in } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: NodeService_Ping_FullMethodName, + FullMethod: "/grpc.NodeService/Ping", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(NodeServiceServer).Ping(ctx, req.(*Request)) @@ -221,7 +208,7 @@ func _NodeService_Subscribe_Handler(srv interface{}, stream grpc.ServerStream) e if err := stream.RecvMsg(m); err != nil { return err } - return srv.(NodeServiceServer).Subscribe(m, &nodeServiceSubscribeServer{ServerStream: stream}) + return srv.(NodeServiceServer).Subscribe(m, &nodeServiceSubscribeServer{stream}) } type NodeService_SubscribeServer interface { @@ -247,7 +234,7 @@ func _NodeService_Unsubscribe_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: NodeService_Unsubscribe_FullMethodName, + FullMethod: "/grpc.NodeService/Unsubscribe", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(NodeServiceServer).Unsubscribe(ctx, req.(*Request)) diff --git a/grpc/plugin_request.pb.go b/grpc/plugin_request.pb.go index 0e6931f7..d002b825 100644 --- a/grpc/plugin_request.pb.go +++ b/grpc/plugin_request.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: entity/plugin_request.proto package grpc diff --git a/grpc/plugin_service.pb.go b/grpc/plugin_service.pb.go index dbf71d19..dbae4923 100644 --- a/grpc/plugin_service.pb.go +++ b/grpc/plugin_service.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: services/plugin_service.proto package grpc diff --git a/grpc/plugin_service_grpc.pb.go b/grpc/plugin_service_grpc.pb.go index 02acf339..5ddd329d 100644 --- a/grpc/plugin_service_grpc.pb.go +++ b/grpc/plugin_service_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.4.0 -// - protoc v3.12.4 +// - protoc-gen-go-grpc v1.2.0 +// - protoc v5.27.2 // source: services/plugin_service.proto package grpc @@ -15,14 +15,8 @@ import ( // 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.62.0 or later. -const _ = grpc.SupportPackageIsVersion8 - -const ( - PluginService_Register_FullMethodName = "/grpc.PluginService/Register" - PluginService_Subscribe_FullMethodName = "/grpc.PluginService/Subscribe" - PluginService_Poll_FullMethodName = "/grpc.PluginService/Poll" -) +// Requires gRPC-Go v1.32.0 or later. +const _ = grpc.SupportPackageIsVersion7 // PluginServiceClient is the client API for PluginService service. // @@ -42,9 +36,8 @@ func NewPluginServiceClient(cc grpc.ClientConnInterface) PluginServiceClient { } func (c *pluginServiceClient) Register(ctx context.Context, in *PluginRequest, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, PluginService_Register_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.PluginService/Register", in, out, opts...) if err != nil { return nil, err } @@ -52,12 +45,11 @@ func (c *pluginServiceClient) Register(ctx context.Context, in *PluginRequest, o } func (c *pluginServiceClient) Subscribe(ctx context.Context, in *PluginRequest, opts ...grpc.CallOption) (PluginService_SubscribeClient, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - stream, err := c.cc.NewStream(ctx, &PluginService_ServiceDesc.Streams[0], PluginService_Subscribe_FullMethodName, cOpts...) + stream, err := c.cc.NewStream(ctx, &PluginService_ServiceDesc.Streams[0], "/grpc.PluginService/Subscribe", opts...) if err != nil { return nil, err } - x := &pluginServiceSubscribeClient{ClientStream: stream} + x := &pluginServiceSubscribeClient{stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -85,12 +77,11 @@ func (x *pluginServiceSubscribeClient) Recv() (*StreamMessage, error) { } func (c *pluginServiceClient) Poll(ctx context.Context, opts ...grpc.CallOption) (PluginService_PollClient, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - stream, err := c.cc.NewStream(ctx, &PluginService_ServiceDesc.Streams[1], PluginService_Poll_FullMethodName, cOpts...) + stream, err := c.cc.NewStream(ctx, &PluginService_ServiceDesc.Streams[1], "/grpc.PluginService/Poll", opts...) if err != nil { return nil, err } - x := &pluginServicePollClient{ClientStream: stream} + x := &pluginServicePollClient{stream} return x, nil } @@ -162,7 +153,7 @@ func _PluginService_Register_Handler(srv interface{}, ctx context.Context, dec f } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: PluginService_Register_FullMethodName, + FullMethod: "/grpc.PluginService/Register", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(PluginServiceServer).Register(ctx, req.(*PluginRequest)) @@ -175,7 +166,7 @@ func _PluginService_Subscribe_Handler(srv interface{}, stream grpc.ServerStream) if err := stream.RecvMsg(m); err != nil { return err } - return srv.(PluginServiceServer).Subscribe(m, &pluginServiceSubscribeServer{ServerStream: stream}) + return srv.(PluginServiceServer).Subscribe(m, &pluginServiceSubscribeServer{stream}) } type PluginService_SubscribeServer interface { @@ -192,7 +183,7 @@ func (x *pluginServiceSubscribeServer) Send(m *StreamMessage) error { } func _PluginService_Poll_Handler(srv interface{}, stream grpc.ServerStream) error { - return srv.(PluginServiceServer).Poll(&pluginServicePollServer{ServerStream: stream}) + return srv.(PluginServiceServer).Poll(&pluginServicePollServer{stream}) } type PluginService_PollServer interface { diff --git a/grpc/proto/services/metrics_service_v2.proto b/grpc/proto/services/metrics_service_v2.proto index 4dd0618c..ea63c1c6 100644 --- a/grpc/proto/services/metrics_service_v2.proto +++ b/grpc/proto/services/metrics_service_v2.proto @@ -10,12 +10,7 @@ message Metric { string name = 4; float value = 5; string help = 6; - string labels = 7; - MetricProcess process = 8; -} - -message MetricProcess { - int32 pid = 1; + bytes labels = 7; } message MetricsServiceV2ConnectRequest { diff --git a/grpc/request.pb.go b/grpc/request.pb.go index 345df3a0..1dc5d262 100644 --- a/grpc/request.pb.go +++ b/grpc/request.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: entity/request.proto package grpc diff --git a/grpc/response.pb.go b/grpc/response.pb.go index f3aa7614..88908a72 100644 --- a/grpc/response.pb.go +++ b/grpc/response.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: entity/response.proto package grpc diff --git a/grpc/response_code.pb.go b/grpc/response_code.pb.go index 817353ce..60b05167 100644 --- a/grpc/response_code.pb.go +++ b/grpc/response_code.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: entity/response_code.proto package grpc diff --git a/grpc/stream_message.pb.go b/grpc/stream_message.pb.go index 6960039a..a1158803 100644 --- a/grpc/stream_message.pb.go +++ b/grpc/stream_message.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: entity/stream_message.proto package grpc diff --git a/grpc/stream_message_code.pb.go b/grpc/stream_message_code.pb.go index d2296acb..a961e58c 100644 --- a/grpc/stream_message_code.pb.go +++ b/grpc/stream_message_code.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: entity/stream_message_code.proto package grpc diff --git a/grpc/stream_message_data_task.pb.go b/grpc/stream_message_data_task.pb.go index dbbd97c6..5533cb28 100644 --- a/grpc/stream_message_data_task.pb.go +++ b/grpc/stream_message_data_task.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: entity/stream_message_data_task.proto package grpc diff --git a/grpc/task.pb.go b/grpc/task.pb.go index cf12e9e7..d15cfbf6 100644 --- a/grpc/task.pb.go +++ b/grpc/task.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: models/task.proto package grpc diff --git a/grpc/task_service.pb.go b/grpc/task_service.pb.go index a8c2258d..5d03cbb3 100644 --- a/grpc/task_service.pb.go +++ b/grpc/task_service.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.34.2 -// protoc v3.12.4 +// protoc v5.27.2 // source: services/task_service.proto package grpc diff --git a/grpc/task_service_grpc.pb.go b/grpc/task_service_grpc.pb.go index a4b40dc3..d71adef3 100644 --- a/grpc/task_service_grpc.pb.go +++ b/grpc/task_service_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.4.0 -// - protoc v3.12.4 +// - protoc-gen-go-grpc v1.2.0 +// - protoc v5.27.2 // source: services/task_service.proto package grpc @@ -15,14 +15,8 @@ import ( // 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.62.0 or later. -const _ = grpc.SupportPackageIsVersion8 - -const ( - TaskService_Subscribe_FullMethodName = "/grpc.TaskService/Subscribe" - TaskService_Fetch_FullMethodName = "/grpc.TaskService/Fetch" - TaskService_SendNotification_FullMethodName = "/grpc.TaskService/SendNotification" -) +// Requires gRPC-Go v1.32.0 or later. +const _ = grpc.SupportPackageIsVersion7 // TaskServiceClient is the client API for TaskService service. // @@ -42,12 +36,11 @@ func NewTaskServiceClient(cc grpc.ClientConnInterface) TaskServiceClient { } func (c *taskServiceClient) Subscribe(ctx context.Context, opts ...grpc.CallOption) (TaskService_SubscribeClient, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - stream, err := c.cc.NewStream(ctx, &TaskService_ServiceDesc.Streams[0], TaskService_Subscribe_FullMethodName, cOpts...) + stream, err := c.cc.NewStream(ctx, &TaskService_ServiceDesc.Streams[0], "/grpc.TaskService/Subscribe", opts...) if err != nil { return nil, err } - x := &taskServiceSubscribeClient{ClientStream: stream} + x := &taskServiceSubscribeClient{stream} return x, nil } @@ -77,9 +70,8 @@ func (x *taskServiceSubscribeClient) CloseAndRecv() (*Response, error) { } func (c *taskServiceClient) Fetch(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, TaskService_Fetch_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.TaskService/Fetch", in, out, opts...) if err != nil { return nil, err } @@ -87,9 +79,8 @@ func (c *taskServiceClient) Fetch(ctx context.Context, in *Request, opts ...grpc } func (c *taskServiceClient) SendNotification(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, TaskService_SendNotification_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, "/grpc.TaskService/SendNotification", in, out, opts...) if err != nil { return nil, err } @@ -133,7 +124,7 @@ func RegisterTaskServiceServer(s grpc.ServiceRegistrar, srv TaskServiceServer) { } func _TaskService_Subscribe_Handler(srv interface{}, stream grpc.ServerStream) error { - return srv.(TaskServiceServer).Subscribe(&taskServiceSubscribeServer{ServerStream: stream}) + return srv.(TaskServiceServer).Subscribe(&taskServiceSubscribeServer{stream}) } type TaskService_SubscribeServer interface { @@ -168,7 +159,7 @@ func _TaskService_Fetch_Handler(srv interface{}, ctx context.Context, dec func(i } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: TaskService_Fetch_FullMethodName, + FullMethod: "/grpc.TaskService/Fetch", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(TaskServiceServer).Fetch(ctx, req.(*Request)) @@ -186,7 +177,7 @@ func _TaskService_SendNotification_Handler(srv interface{}, ctx context.Context, } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: TaskService_SendNotification_FullMethodName, + FullMethod: "/grpc.TaskService/SendNotification", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(TaskServiceServer).SendNotification(ctx, req.(*Request))