使用最新的protoc-gen-go和protoc-gen-go-grpc插件

pkg/rpc/pb/service_report_node.pb.go

@@ -1,17 +1,12 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
-// 	protoc-gen-go v1.25.0
+// 	protoc-gen-go v1.31.0
 // 	protoc        v3.19.4
 // source: service_report_node.proto
 
 package pb
 
 import (
-	context "context"
-	proto "github.com/golang/protobuf/proto"
-	grpc "google.golang.org/grpc"
-	codes "google.golang.org/grpc/codes"
-	status "google.golang.org/grpc/status"
 	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
 	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
 	reflect "reflect"
@@ -25,10 +20,6 @@ const (
 	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
 )
 
-// This is a compile-time assertion that a sufficiently up-to-date version
-// of the legacy proto package is being used.
-const _ = proto.ProtoPackageIsVersion4
-
 // 添加终端
 type CreateReportNodeRequest struct {
 	state         protoimpl.MessageState
@@ -1919,650 +1910,3 @@ func file_service_report_node_proto_init() {
 	file_service_report_node_proto_goTypes = nil
 	file_service_report_node_proto_depIdxs = nil
 }
-
-// Reference imports to suppress errors if they are not otherwise used.
-var _ context.Context
-var _ grpc.ClientConnInterface
-
-// This is a compile-time assertion to ensure that this generated file
-// is compatible with the grpc package it is being compiled against.
-const _ = grpc.SupportPackageIsVersion6
-
-// ReportNodeServiceClient is the client API for ReportNodeService service.
-//
-// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
-type ReportNodeServiceClient interface {
-	// 添加终端
-	CreateReportNode(ctx context.Context, in *CreateReportNodeRequest, opts ...grpc.CallOption) (*CreateReportNodeResponse, error)
-	// 删除终端
-	DeleteReportNode(ctx context.Context, in *DeleteReportNodeRequest, opts ...grpc.CallOption) (*RPCSuccess, error)
-	// 修改终端
-	UpdateReportNode(ctx context.Context, in *UpdateReportNodeRequest, opts ...grpc.CallOption) (*RPCSuccess, error)
-	// 计算终端数量
-	CountAllEnabledReportNodes(ctx context.Context, in *CountAllEnabledReportNodesRequest, opts ...grpc.CallOption) (*RPCCountResponse, error)
-	// 列出单页终端
-	ListEnabledReportNodes(ctx context.Context, in *ListEnabledReportNodesRequest, opts ...grpc.CallOption) (*ListEnabledReportNodesResponse, error)
-	// 查找单个终端
-	FindEnabledReportNode(ctx context.Context, in *FindEnabledReportNodeRequest, opts ...grpc.CallOption) (*FindEnabledReportNodeResponse, error)
-	// 终端stream
-	ReportNodeStream(ctx context.Context, opts ...grpc.CallOption) (ReportNodeService_ReportNodeStreamClient, error)
-	// 更新节点状态
-	UpdateReportNodeStatus(ctx context.Context, in *UpdateReportNodeStatusRequest, opts ...grpc.CallOption) (*RPCSuccess, error)
-	// 获取当前节点信息
-	FindCurrentReportNodeConfig(ctx context.Context, in *FindCurrentReportNodeConfigRequest, opts ...grpc.CallOption) (*FindCurrentReportNodeConfigResponse, error)
-	// 读取任务
-	FindReportNodeTasks(ctx context.Context, in *FindReportNodeTasksRequest, opts ...grpc.CallOption) (*FindReportNodeTasksResponse, error)
-	// 取得最新的版本号
-	FindLatestReportNodeVersion(ctx context.Context, in *FindLatestReportNodeVersionRequest, opts ...grpc.CallOption) (*FindLatestReportNodeVersionResponse, error)
-	// 计算任务数量
-	CountAllReportNodeTasks(ctx context.Context, in *CountAllReportNodeTasksRequest, opts ...grpc.CallOption) (*RPCCountResponse, error)
-	// 列出单页任务
-	ListReportNodeTasks(ctx context.Context, in *ListReportNodeTasksRequest, opts ...grpc.CallOption) (*ListReportNodeTasksResponse, error)
-	// 修改全局设置
-	UpdateReportNodeGlobalSetting(ctx context.Context, in *UpdateReportNodeGlobalSetting, opts ...grpc.CallOption) (*RPCSuccess, error)
-	// 读取全局设置
-	ReadReportNodeGlobalSetting(ctx context.Context, in *ReadReportNodeGlobalSettingRequest, opts ...grpc.CallOption) (*ReadReportNodeGlobalSettingResponse, error)
-}
-
-type reportNodeServiceClient struct {
-	cc grpc.ClientConnInterface
-}
-
-func NewReportNodeServiceClient(cc grpc.ClientConnInterface) ReportNodeServiceClient {
-	return &reportNodeServiceClient{cc}
-}
-
-func (c *reportNodeServiceClient) CreateReportNode(ctx context.Context, in *CreateReportNodeRequest, opts ...grpc.CallOption) (*CreateReportNodeResponse, error) {
-	out := new(CreateReportNodeResponse)
-	err := c.cc.Invoke(ctx, "/pb.ReportNodeService/createReportNode", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *reportNodeServiceClient) DeleteReportNode(ctx context.Context, in *DeleteReportNodeRequest, opts ...grpc.CallOption) (*RPCSuccess, error) {
-	out := new(RPCSuccess)
-	err := c.cc.Invoke(ctx, "/pb.ReportNodeService/deleteReportNode", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *reportNodeServiceClient) UpdateReportNode(ctx context.Context, in *UpdateReportNodeRequest, opts ...grpc.CallOption) (*RPCSuccess, error) {
-	out := new(RPCSuccess)
-	err := c.cc.Invoke(ctx, "/pb.ReportNodeService/updateReportNode", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *reportNodeServiceClient) CountAllEnabledReportNodes(ctx context.Context, in *CountAllEnabledReportNodesRequest, opts ...grpc.CallOption) (*RPCCountResponse, error) {
-	out := new(RPCCountResponse)
-	err := c.cc.Invoke(ctx, "/pb.ReportNodeService/countAllEnabledReportNodes", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *reportNodeServiceClient) ListEnabledReportNodes(ctx context.Context, in *ListEnabledReportNodesRequest, opts ...grpc.CallOption) (*ListEnabledReportNodesResponse, error) {
-	out := new(ListEnabledReportNodesResponse)
-	err := c.cc.Invoke(ctx, "/pb.ReportNodeService/listEnabledReportNodes", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *reportNodeServiceClient) FindEnabledReportNode(ctx context.Context, in *FindEnabledReportNodeRequest, opts ...grpc.CallOption) (*FindEnabledReportNodeResponse, error) {
-	out := new(FindEnabledReportNodeResponse)
-	err := c.cc.Invoke(ctx, "/pb.ReportNodeService/findEnabledReportNode", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *reportNodeServiceClient) ReportNodeStream(ctx context.Context, opts ...grpc.CallOption) (ReportNodeService_ReportNodeStreamClient, error) {
-	stream, err := c.cc.NewStream(ctx, &_ReportNodeService_serviceDesc.Streams[0], "/pb.ReportNodeService/reportNodeStream", opts...)
-	if err != nil {
-		return nil, err
-	}
-	x := &reportNodeServiceReportNodeStreamClient{stream}
-	return x, nil
-}
-
-type ReportNodeService_ReportNodeStreamClient interface {
-	Send(*ReportNodeStreamMessage) error
-	Recv() (*ReportNodeStreamMessage, error)
-	grpc.ClientStream
-}
-
-type reportNodeServiceReportNodeStreamClient struct {
-	grpc.ClientStream
-}
-
-func (x *reportNodeServiceReportNodeStreamClient) Send(m *ReportNodeStreamMessage) error {
-	return x.ClientStream.SendMsg(m)
-}
-
-func (x *reportNodeServiceReportNodeStreamClient) Recv() (*ReportNodeStreamMessage, error) {
-	m := new(ReportNodeStreamMessage)
-	if err := x.ClientStream.RecvMsg(m); err != nil {
-		return nil, err
-	}
-	return m, nil
-}
-
-func (c *reportNodeServiceClient) UpdateReportNodeStatus(ctx context.Context, in *UpdateReportNodeStatusRequest, opts ...grpc.CallOption) (*RPCSuccess, error) {
-	out := new(RPCSuccess)
-	err := c.cc.Invoke(ctx, "/pb.ReportNodeService/updateReportNodeStatus", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *reportNodeServiceClient) FindCurrentReportNodeConfig(ctx context.Context, in *FindCurrentReportNodeConfigRequest, opts ...grpc.CallOption) (*FindCurrentReportNodeConfigResponse, error) {
-	out := new(FindCurrentReportNodeConfigResponse)
-	err := c.cc.Invoke(ctx, "/pb.ReportNodeService/findCurrentReportNodeConfig", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *reportNodeServiceClient) FindReportNodeTasks(ctx context.Context, in *FindReportNodeTasksRequest, opts ...grpc.CallOption) (*FindReportNodeTasksResponse, error) {
-	out := new(FindReportNodeTasksResponse)
-	err := c.cc.Invoke(ctx, "/pb.ReportNodeService/findReportNodeTasks", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *reportNodeServiceClient) FindLatestReportNodeVersion(ctx context.Context, in *FindLatestReportNodeVersionRequest, opts ...grpc.CallOption) (*FindLatestReportNodeVersionResponse, error) {
-	out := new(FindLatestReportNodeVersionResponse)
-	err := c.cc.Invoke(ctx, "/pb.ReportNodeService/findLatestReportNodeVersion", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *reportNodeServiceClient) CountAllReportNodeTasks(ctx context.Context, in *CountAllReportNodeTasksRequest, opts ...grpc.CallOption) (*RPCCountResponse, error) {
-	out := new(RPCCountResponse)
-	err := c.cc.Invoke(ctx, "/pb.ReportNodeService/countAllReportNodeTasks", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *reportNodeServiceClient) ListReportNodeTasks(ctx context.Context, in *ListReportNodeTasksRequest, opts ...grpc.CallOption) (*ListReportNodeTasksResponse, error) {
-	out := new(ListReportNodeTasksResponse)
-	err := c.cc.Invoke(ctx, "/pb.ReportNodeService/listReportNodeTasks", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *reportNodeServiceClient) UpdateReportNodeGlobalSetting(ctx context.Context, in *UpdateReportNodeGlobalSetting, opts ...grpc.CallOption) (*RPCSuccess, error) {
-	out := new(RPCSuccess)
-	err := c.cc.Invoke(ctx, "/pb.ReportNodeService/updateReportNodeGlobalSetting", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *reportNodeServiceClient) ReadReportNodeGlobalSetting(ctx context.Context, in *ReadReportNodeGlobalSettingRequest, opts ...grpc.CallOption) (*ReadReportNodeGlobalSettingResponse, error) {
-	out := new(ReadReportNodeGlobalSettingResponse)
-	err := c.cc.Invoke(ctx, "/pb.ReportNodeService/readReportNodeGlobalSetting", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-// ReportNodeServiceServer is the server API for ReportNodeService service.
-type ReportNodeServiceServer interface {
-	// 添加终端
-	CreateReportNode(context.Context, *CreateReportNodeRequest) (*CreateReportNodeResponse, error)
-	// 删除终端
-	DeleteReportNode(context.Context, *DeleteReportNodeRequest) (*RPCSuccess, error)
-	// 修改终端
-	UpdateReportNode(context.Context, *UpdateReportNodeRequest) (*RPCSuccess, error)
-	// 计算终端数量
-	CountAllEnabledReportNodes(context.Context, *CountAllEnabledReportNodesRequest) (*RPCCountResponse, error)
-	// 列出单页终端
-	ListEnabledReportNodes(context.Context, *ListEnabledReportNodesRequest) (*ListEnabledReportNodesResponse, error)
-	// 查找单个终端
-	FindEnabledReportNode(context.Context, *FindEnabledReportNodeRequest) (*FindEnabledReportNodeResponse, error)
-	// 终端stream
-	ReportNodeStream(ReportNodeService_ReportNodeStreamServer) error
-	// 更新节点状态
-	UpdateReportNodeStatus(context.Context, *UpdateReportNodeStatusRequest) (*RPCSuccess, error)
-	// 获取当前节点信息
-	FindCurrentReportNodeConfig(context.Context, *FindCurrentReportNodeConfigRequest) (*FindCurrentReportNodeConfigResponse, error)
-	// 读取任务
-	FindReportNodeTasks(context.Context, *FindReportNodeTasksRequest) (*FindReportNodeTasksResponse, error)
-	// 取得最新的版本号
-	FindLatestReportNodeVersion(context.Context, *FindLatestReportNodeVersionRequest) (*FindLatestReportNodeVersionResponse, error)
-	// 计算任务数量
-	CountAllReportNodeTasks(context.Context, *CountAllReportNodeTasksRequest) (*RPCCountResponse, error)
-	// 列出单页任务
-	ListReportNodeTasks(context.Context, *ListReportNodeTasksRequest) (*ListReportNodeTasksResponse, error)
-	// 修改全局设置
-	UpdateReportNodeGlobalSetting(context.Context, *UpdateReportNodeGlobalSetting) (*RPCSuccess, error)
-	// 读取全局设置
-	ReadReportNodeGlobalSetting(context.Context, *ReadReportNodeGlobalSettingRequest) (*ReadReportNodeGlobalSettingResponse, error)
-}
-
-// UnimplementedReportNodeServiceServer can be embedded to have forward compatible implementations.
-type UnimplementedReportNodeServiceServer struct {
-}
-
-func (*UnimplementedReportNodeServiceServer) CreateReportNode(context.Context, *CreateReportNodeRequest) (*CreateReportNodeResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method CreateReportNode not implemented")
-}
-func (*UnimplementedReportNodeServiceServer) DeleteReportNode(context.Context, *DeleteReportNodeRequest) (*RPCSuccess, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method DeleteReportNode not implemented")
-}
-func (*UnimplementedReportNodeServiceServer) UpdateReportNode(context.Context, *UpdateReportNodeRequest) (*RPCSuccess, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method UpdateReportNode not implemented")
-}
-func (*UnimplementedReportNodeServiceServer) CountAllEnabledReportNodes(context.Context, *CountAllEnabledReportNodesRequest) (*RPCCountResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method CountAllEnabledReportNodes not implemented")
-}
-func (*UnimplementedReportNodeServiceServer) ListEnabledReportNodes(context.Context, *ListEnabledReportNodesRequest) (*ListEnabledReportNodesResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method ListEnabledReportNodes not implemented")
-}
-func (*UnimplementedReportNodeServiceServer) FindEnabledReportNode(context.Context, *FindEnabledReportNodeRequest) (*FindEnabledReportNodeResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method FindEnabledReportNode not implemented")
-}
-func (*UnimplementedReportNodeServiceServer) ReportNodeStream(ReportNodeService_ReportNodeStreamServer) error {
-	return status.Errorf(codes.Unimplemented, "method ReportNodeStream not implemented")
-}
-func (*UnimplementedReportNodeServiceServer) UpdateReportNodeStatus(context.Context, *UpdateReportNodeStatusRequest) (*RPCSuccess, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method UpdateReportNodeStatus not implemented")
-}
-func (*UnimplementedReportNodeServiceServer) FindCurrentReportNodeConfig(context.Context, *FindCurrentReportNodeConfigRequest) (*FindCurrentReportNodeConfigResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method FindCurrentReportNodeConfig not implemented")
-}
-func (*UnimplementedReportNodeServiceServer) FindReportNodeTasks(context.Context, *FindReportNodeTasksRequest) (*FindReportNodeTasksResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method FindReportNodeTasks not implemented")
-}
-func (*UnimplementedReportNodeServiceServer) FindLatestReportNodeVersion(context.Context, *FindLatestReportNodeVersionRequest) (*FindLatestReportNodeVersionResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method FindLatestReportNodeVersion not implemented")
-}
-func (*UnimplementedReportNodeServiceServer) CountAllReportNodeTasks(context.Context, *CountAllReportNodeTasksRequest) (*RPCCountResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method CountAllReportNodeTasks not implemented")
-}
-func (*UnimplementedReportNodeServiceServer) ListReportNodeTasks(context.Context, *ListReportNodeTasksRequest) (*ListReportNodeTasksResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method ListReportNodeTasks not implemented")
-}
-func (*UnimplementedReportNodeServiceServer) UpdateReportNodeGlobalSetting(context.Context, *UpdateReportNodeGlobalSetting) (*RPCSuccess, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method UpdateReportNodeGlobalSetting not implemented")
-}
-func (*UnimplementedReportNodeServiceServer) ReadReportNodeGlobalSetting(context.Context, *ReadReportNodeGlobalSettingRequest) (*ReadReportNodeGlobalSettingResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method ReadReportNodeGlobalSetting not implemented")
-}
-
-func RegisterReportNodeServiceServer(s *grpc.Server, srv ReportNodeServiceServer) {
-	s.RegisterService(&_ReportNodeService_serviceDesc, srv)
-}
-
-func _ReportNodeService_CreateReportNode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(CreateReportNodeRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ReportNodeServiceServer).CreateReportNode(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.ReportNodeService/CreateReportNode",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ReportNodeServiceServer).CreateReportNode(ctx, req.(*CreateReportNodeRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _ReportNodeService_DeleteReportNode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(DeleteReportNodeRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ReportNodeServiceServer).DeleteReportNode(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.ReportNodeService/DeleteReportNode",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ReportNodeServiceServer).DeleteReportNode(ctx, req.(*DeleteReportNodeRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _ReportNodeService_UpdateReportNode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(UpdateReportNodeRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ReportNodeServiceServer).UpdateReportNode(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.ReportNodeService/UpdateReportNode",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ReportNodeServiceServer).UpdateReportNode(ctx, req.(*UpdateReportNodeRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _ReportNodeService_CountAllEnabledReportNodes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(CountAllEnabledReportNodesRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ReportNodeServiceServer).CountAllEnabledReportNodes(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.ReportNodeService/CountAllEnabledReportNodes",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ReportNodeServiceServer).CountAllEnabledReportNodes(ctx, req.(*CountAllEnabledReportNodesRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _ReportNodeService_ListEnabledReportNodes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(ListEnabledReportNodesRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ReportNodeServiceServer).ListEnabledReportNodes(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.ReportNodeService/ListEnabledReportNodes",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ReportNodeServiceServer).ListEnabledReportNodes(ctx, req.(*ListEnabledReportNodesRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _ReportNodeService_FindEnabledReportNode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(FindEnabledReportNodeRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ReportNodeServiceServer).FindEnabledReportNode(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.ReportNodeService/FindEnabledReportNode",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ReportNodeServiceServer).FindEnabledReportNode(ctx, req.(*FindEnabledReportNodeRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _ReportNodeService_ReportNodeStream_Handler(srv interface{}, stream grpc.ServerStream) error {
-	return srv.(ReportNodeServiceServer).ReportNodeStream(&reportNodeServiceReportNodeStreamServer{stream})
-}
-
-type ReportNodeService_ReportNodeStreamServer interface {
-	Send(*ReportNodeStreamMessage) error
-	Recv() (*ReportNodeStreamMessage, error)
-	grpc.ServerStream
-}
-
-type reportNodeServiceReportNodeStreamServer struct {
-	grpc.ServerStream
-}
-
-func (x *reportNodeServiceReportNodeStreamServer) Send(m *ReportNodeStreamMessage) error {
-	return x.ServerStream.SendMsg(m)
-}
-
-func (x *reportNodeServiceReportNodeStreamServer) Recv() (*ReportNodeStreamMessage, error) {
-	m := new(ReportNodeStreamMessage)
-	if err := x.ServerStream.RecvMsg(m); err != nil {
-		return nil, err
-	}
-	return m, nil
-}
-
-func _ReportNodeService_UpdateReportNodeStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(UpdateReportNodeStatusRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ReportNodeServiceServer).UpdateReportNodeStatus(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.ReportNodeService/UpdateReportNodeStatus",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ReportNodeServiceServer).UpdateReportNodeStatus(ctx, req.(*UpdateReportNodeStatusRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _ReportNodeService_FindCurrentReportNodeConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(FindCurrentReportNodeConfigRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ReportNodeServiceServer).FindCurrentReportNodeConfig(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.ReportNodeService/FindCurrentReportNodeConfig",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ReportNodeServiceServer).FindCurrentReportNodeConfig(ctx, req.(*FindCurrentReportNodeConfigRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _ReportNodeService_FindReportNodeTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(FindReportNodeTasksRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ReportNodeServiceServer).FindReportNodeTasks(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.ReportNodeService/FindReportNodeTasks",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ReportNodeServiceServer).FindReportNodeTasks(ctx, req.(*FindReportNodeTasksRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _ReportNodeService_FindLatestReportNodeVersion_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(FindLatestReportNodeVersionRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ReportNodeServiceServer).FindLatestReportNodeVersion(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.ReportNodeService/FindLatestReportNodeVersion",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ReportNodeServiceServer).FindLatestReportNodeVersion(ctx, req.(*FindLatestReportNodeVersionRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _ReportNodeService_CountAllReportNodeTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(CountAllReportNodeTasksRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ReportNodeServiceServer).CountAllReportNodeTasks(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.ReportNodeService/CountAllReportNodeTasks",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ReportNodeServiceServer).CountAllReportNodeTasks(ctx, req.(*CountAllReportNodeTasksRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _ReportNodeService_ListReportNodeTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(ListReportNodeTasksRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ReportNodeServiceServer).ListReportNodeTasks(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.ReportNodeService/ListReportNodeTasks",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ReportNodeServiceServer).ListReportNodeTasks(ctx, req.(*ListReportNodeTasksRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _ReportNodeService_UpdateReportNodeGlobalSetting_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(UpdateReportNodeGlobalSetting)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ReportNodeServiceServer).UpdateReportNodeGlobalSetting(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.ReportNodeService/UpdateReportNodeGlobalSetting",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ReportNodeServiceServer).UpdateReportNodeGlobalSetting(ctx, req.(*UpdateReportNodeGlobalSetting))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _ReportNodeService_ReadReportNodeGlobalSetting_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(ReadReportNodeGlobalSettingRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(ReportNodeServiceServer).ReadReportNodeGlobalSetting(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.ReportNodeService/ReadReportNodeGlobalSetting",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ReportNodeServiceServer).ReadReportNodeGlobalSetting(ctx, req.(*ReadReportNodeGlobalSettingRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-var _ReportNodeService_serviceDesc = grpc.ServiceDesc{
-	ServiceName: "pb.ReportNodeService",
-	HandlerType: (*ReportNodeServiceServer)(nil),
-	Methods: []grpc.MethodDesc{
-		{
-			MethodName: "createReportNode",
-			Handler:    _ReportNodeService_CreateReportNode_Handler,
-		},
-		{
-			MethodName: "deleteReportNode",
-			Handler:    _ReportNodeService_DeleteReportNode_Handler,
-		},
-		{
-			MethodName: "updateReportNode",
-			Handler:    _ReportNodeService_UpdateReportNode_Handler,
-		},
-		{
-			MethodName: "countAllEnabledReportNodes",
-			Handler:    _ReportNodeService_CountAllEnabledReportNodes_Handler,
-		},
-		{
-			MethodName: "listEnabledReportNodes",
-			Handler:    _ReportNodeService_ListEnabledReportNodes_Handler,
-		},
-		{
-			MethodName: "findEnabledReportNode",
-			Handler:    _ReportNodeService_FindEnabledReportNode_Handler,
-		},
-		{
-			MethodName: "updateReportNodeStatus",
-			Handler:    _ReportNodeService_UpdateReportNodeStatus_Handler,
-		},
-		{
-			MethodName: "findCurrentReportNodeConfig",
-			Handler:    _ReportNodeService_FindCurrentReportNodeConfig_Handler,
-		},
-		{
-			MethodName: "findReportNodeTasks",
-			Handler:    _ReportNodeService_FindReportNodeTasks_Handler,
-		},
-		{
-			MethodName: "findLatestReportNodeVersion",
-			Handler:    _ReportNodeService_FindLatestReportNodeVersion_Handler,
-		},
-		{
-			MethodName: "countAllReportNodeTasks",
-			Handler:    _ReportNodeService_CountAllReportNodeTasks_Handler,
-		},
-		{
-			MethodName: "listReportNodeTasks",
-			Handler:    _ReportNodeService_ListReportNodeTasks_Handler,
-		},
-		{
-			MethodName: "updateReportNodeGlobalSetting",
-			Handler:    _ReportNodeService_UpdateReportNodeGlobalSetting_Handler,
-		},
-		{
-			MethodName: "readReportNodeGlobalSetting",
-			Handler:    _ReportNodeService_ReadReportNodeGlobalSetting_Handler,
-		},
-	},
-	Streams: []grpc.StreamDesc{
-		{
-			StreamName:    "reportNodeStream",
-			Handler:       _ReportNodeService_ReportNodeStream_Handler,
-			ServerStreams: true,
-			ClientStreams: true,
-		},
-	},
-	Metadata: "service_report_node.proto",
-}