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

pkg/rpc/pb/service_node_task.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_node_task.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 FindNodeTasksRequest struct {
 	state         protoimpl.MessageState
@@ -1152,427 +1143,3 @@ func file_service_node_task_proto_init() {
 	file_service_node_task_proto_goTypes = nil
 	file_service_node_task_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
-
-// NodeTaskServiceClient is the client API for NodeTaskService service.
-//
-// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
-type NodeTaskServiceClient interface {
-	// 获取单节点同步任务
-	FindNodeTasks(ctx context.Context, in *FindNodeTasksRequest, opts ...grpc.CallOption) (*FindNodeTasksResponse, error)
-	// 报告同步任务结果
-	ReportNodeTaskDone(ctx context.Context, in *ReportNodeTaskDoneRequest, opts ...grpc.CallOption) (*RPCSuccess, error)
-	// 获取所有正在同步的集群信息
-	FindNodeClusterTasks(ctx context.Context, in *FindNodeClusterTasksRequest, opts ...grpc.CallOption) (*FindNodeClusterTasksResponse, error)
-	// 检查是否有正在执行的任务
-	ExistsNodeTasks(ctx context.Context, in *ExistsNodeTasksRequest, opts ...grpc.CallOption) (*ExistsNodeTasksResponse, error)
-	// 删除任务
-	DeleteNodeTask(ctx context.Context, in *DeleteNodeTaskRequest, opts ...grpc.CallOption) (*RPCSuccess, error)
-	// 批量删除任务
-	DeleteNodeTasks(ctx context.Context, in *DeleteNodeTasksRequest, opts ...grpc.CallOption) (*RPCSuccess, error)
-	// 删除所有任务
-	DeleteAllNodeTasks(ctx context.Context, in *DeleteAllNodeTasksRequest, opts ...grpc.CallOption) (*RPCSuccess, error)
-	// 计算正在执行的任务数量
-	CountDoingNodeTasks(ctx context.Context, in *CountDoingNodeTasksRequest, opts ...grpc.CallOption) (*RPCCountResponse, error)
-	// 查找需要通知的任务
-	FindNotifyingNodeTasks(ctx context.Context, in *FindNotifyingNodeTasksRequest, opts ...grpc.CallOption) (*FindNotifyingNodeTasksResponse, error)
-	// 设置任务已通知
-	UpdateNodeTasksNotified(ctx context.Context, in *UpdateNodeTasksNotifiedRequest, opts ...grpc.CallOption) (*RPCSuccess, error)
-}
-
-type nodeTaskServiceClient struct {
-	cc grpc.ClientConnInterface
-}
-
-func NewNodeTaskServiceClient(cc grpc.ClientConnInterface) NodeTaskServiceClient {
-	return &nodeTaskServiceClient{cc}
-}
-
-func (c *nodeTaskServiceClient) FindNodeTasks(ctx context.Context, in *FindNodeTasksRequest, opts ...grpc.CallOption) (*FindNodeTasksResponse, error) {
-	out := new(FindNodeTasksResponse)
-	err := c.cc.Invoke(ctx, "/pb.NodeTaskService/findNodeTasks", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *nodeTaskServiceClient) ReportNodeTaskDone(ctx context.Context, in *ReportNodeTaskDoneRequest, opts ...grpc.CallOption) (*RPCSuccess, error) {
-	out := new(RPCSuccess)
-	err := c.cc.Invoke(ctx, "/pb.NodeTaskService/reportNodeTaskDone", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *nodeTaskServiceClient) FindNodeClusterTasks(ctx context.Context, in *FindNodeClusterTasksRequest, opts ...grpc.CallOption) (*FindNodeClusterTasksResponse, error) {
-	out := new(FindNodeClusterTasksResponse)
-	err := c.cc.Invoke(ctx, "/pb.NodeTaskService/findNodeClusterTasks", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *nodeTaskServiceClient) ExistsNodeTasks(ctx context.Context, in *ExistsNodeTasksRequest, opts ...grpc.CallOption) (*ExistsNodeTasksResponse, error) {
-	out := new(ExistsNodeTasksResponse)
-	err := c.cc.Invoke(ctx, "/pb.NodeTaskService/existsNodeTasks", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *nodeTaskServiceClient) DeleteNodeTask(ctx context.Context, in *DeleteNodeTaskRequest, opts ...grpc.CallOption) (*RPCSuccess, error) {
-	out := new(RPCSuccess)
-	err := c.cc.Invoke(ctx, "/pb.NodeTaskService/deleteNodeTask", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *nodeTaskServiceClient) DeleteNodeTasks(ctx context.Context, in *DeleteNodeTasksRequest, opts ...grpc.CallOption) (*RPCSuccess, error) {
-	out := new(RPCSuccess)
-	err := c.cc.Invoke(ctx, "/pb.NodeTaskService/deleteNodeTasks", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *nodeTaskServiceClient) DeleteAllNodeTasks(ctx context.Context, in *DeleteAllNodeTasksRequest, opts ...grpc.CallOption) (*RPCSuccess, error) {
-	out := new(RPCSuccess)
-	err := c.cc.Invoke(ctx, "/pb.NodeTaskService/deleteAllNodeTasks", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *nodeTaskServiceClient) CountDoingNodeTasks(ctx context.Context, in *CountDoingNodeTasksRequest, opts ...grpc.CallOption) (*RPCCountResponse, error) {
-	out := new(RPCCountResponse)
-	err := c.cc.Invoke(ctx, "/pb.NodeTaskService/countDoingNodeTasks", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *nodeTaskServiceClient) FindNotifyingNodeTasks(ctx context.Context, in *FindNotifyingNodeTasksRequest, opts ...grpc.CallOption) (*FindNotifyingNodeTasksResponse, error) {
-	out := new(FindNotifyingNodeTasksResponse)
-	err := c.cc.Invoke(ctx, "/pb.NodeTaskService/findNotifyingNodeTasks", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *nodeTaskServiceClient) UpdateNodeTasksNotified(ctx context.Context, in *UpdateNodeTasksNotifiedRequest, opts ...grpc.CallOption) (*RPCSuccess, error) {
-	out := new(RPCSuccess)
-	err := c.cc.Invoke(ctx, "/pb.NodeTaskService/updateNodeTasksNotified", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-// NodeTaskServiceServer is the server API for NodeTaskService service.
-type NodeTaskServiceServer interface {
-	// 获取单节点同步任务
-	FindNodeTasks(context.Context, *FindNodeTasksRequest) (*FindNodeTasksResponse, error)
-	// 报告同步任务结果
-	ReportNodeTaskDone(context.Context, *ReportNodeTaskDoneRequest) (*RPCSuccess, error)
-	// 获取所有正在同步的集群信息
-	FindNodeClusterTasks(context.Context, *FindNodeClusterTasksRequest) (*FindNodeClusterTasksResponse, error)
-	// 检查是否有正在执行的任务
-	ExistsNodeTasks(context.Context, *ExistsNodeTasksRequest) (*ExistsNodeTasksResponse, error)
-	// 删除任务
-	DeleteNodeTask(context.Context, *DeleteNodeTaskRequest) (*RPCSuccess, error)
-	// 批量删除任务
-	DeleteNodeTasks(context.Context, *DeleteNodeTasksRequest) (*RPCSuccess, error)
-	// 删除所有任务
-	DeleteAllNodeTasks(context.Context, *DeleteAllNodeTasksRequest) (*RPCSuccess, error)
-	// 计算正在执行的任务数量
-	CountDoingNodeTasks(context.Context, *CountDoingNodeTasksRequest) (*RPCCountResponse, error)
-	// 查找需要通知的任务
-	FindNotifyingNodeTasks(context.Context, *FindNotifyingNodeTasksRequest) (*FindNotifyingNodeTasksResponse, error)
-	// 设置任务已通知
-	UpdateNodeTasksNotified(context.Context, *UpdateNodeTasksNotifiedRequest) (*RPCSuccess, error)
-}
-
-// UnimplementedNodeTaskServiceServer can be embedded to have forward compatible implementations.
-type UnimplementedNodeTaskServiceServer struct {
-}
-
-func (*UnimplementedNodeTaskServiceServer) FindNodeTasks(context.Context, *FindNodeTasksRequest) (*FindNodeTasksResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method FindNodeTasks not implemented")
-}
-func (*UnimplementedNodeTaskServiceServer) ReportNodeTaskDone(context.Context, *ReportNodeTaskDoneRequest) (*RPCSuccess, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method ReportNodeTaskDone not implemented")
-}
-func (*UnimplementedNodeTaskServiceServer) FindNodeClusterTasks(context.Context, *FindNodeClusterTasksRequest) (*FindNodeClusterTasksResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method FindNodeClusterTasks not implemented")
-}
-func (*UnimplementedNodeTaskServiceServer) ExistsNodeTasks(context.Context, *ExistsNodeTasksRequest) (*ExistsNodeTasksResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method ExistsNodeTasks not implemented")
-}
-func (*UnimplementedNodeTaskServiceServer) DeleteNodeTask(context.Context, *DeleteNodeTaskRequest) (*RPCSuccess, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method DeleteNodeTask not implemented")
-}
-func (*UnimplementedNodeTaskServiceServer) DeleteNodeTasks(context.Context, *DeleteNodeTasksRequest) (*RPCSuccess, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method DeleteNodeTasks not implemented")
-}
-func (*UnimplementedNodeTaskServiceServer) DeleteAllNodeTasks(context.Context, *DeleteAllNodeTasksRequest) (*RPCSuccess, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method DeleteAllNodeTasks not implemented")
-}
-func (*UnimplementedNodeTaskServiceServer) CountDoingNodeTasks(context.Context, *CountDoingNodeTasksRequest) (*RPCCountResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method CountDoingNodeTasks not implemented")
-}
-func (*UnimplementedNodeTaskServiceServer) FindNotifyingNodeTasks(context.Context, *FindNotifyingNodeTasksRequest) (*FindNotifyingNodeTasksResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method FindNotifyingNodeTasks not implemented")
-}
-func (*UnimplementedNodeTaskServiceServer) UpdateNodeTasksNotified(context.Context, *UpdateNodeTasksNotifiedRequest) (*RPCSuccess, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method UpdateNodeTasksNotified not implemented")
-}
-
-func RegisterNodeTaskServiceServer(s *grpc.Server, srv NodeTaskServiceServer) {
-	s.RegisterService(&_NodeTaskService_serviceDesc, srv)
-}
-
-func _NodeTaskService_FindNodeTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(FindNodeTasksRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(NodeTaskServiceServer).FindNodeTasks(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.NodeTaskService/FindNodeTasks",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(NodeTaskServiceServer).FindNodeTasks(ctx, req.(*FindNodeTasksRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _NodeTaskService_ReportNodeTaskDone_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(ReportNodeTaskDoneRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(NodeTaskServiceServer).ReportNodeTaskDone(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.NodeTaskService/ReportNodeTaskDone",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(NodeTaskServiceServer).ReportNodeTaskDone(ctx, req.(*ReportNodeTaskDoneRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _NodeTaskService_FindNodeClusterTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(FindNodeClusterTasksRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(NodeTaskServiceServer).FindNodeClusterTasks(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.NodeTaskService/FindNodeClusterTasks",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(NodeTaskServiceServer).FindNodeClusterTasks(ctx, req.(*FindNodeClusterTasksRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _NodeTaskService_ExistsNodeTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(ExistsNodeTasksRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(NodeTaskServiceServer).ExistsNodeTasks(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.NodeTaskService/ExistsNodeTasks",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(NodeTaskServiceServer).ExistsNodeTasks(ctx, req.(*ExistsNodeTasksRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _NodeTaskService_DeleteNodeTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(DeleteNodeTaskRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(NodeTaskServiceServer).DeleteNodeTask(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.NodeTaskService/DeleteNodeTask",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(NodeTaskServiceServer).DeleteNodeTask(ctx, req.(*DeleteNodeTaskRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _NodeTaskService_DeleteNodeTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(DeleteNodeTasksRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(NodeTaskServiceServer).DeleteNodeTasks(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.NodeTaskService/DeleteNodeTasks",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(NodeTaskServiceServer).DeleteNodeTasks(ctx, req.(*DeleteNodeTasksRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _NodeTaskService_DeleteAllNodeTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(DeleteAllNodeTasksRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(NodeTaskServiceServer).DeleteAllNodeTasks(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.NodeTaskService/DeleteAllNodeTasks",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(NodeTaskServiceServer).DeleteAllNodeTasks(ctx, req.(*DeleteAllNodeTasksRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _NodeTaskService_CountDoingNodeTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(CountDoingNodeTasksRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(NodeTaskServiceServer).CountDoingNodeTasks(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.NodeTaskService/CountDoingNodeTasks",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(NodeTaskServiceServer).CountDoingNodeTasks(ctx, req.(*CountDoingNodeTasksRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _NodeTaskService_FindNotifyingNodeTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(FindNotifyingNodeTasksRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(NodeTaskServiceServer).FindNotifyingNodeTasks(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.NodeTaskService/FindNotifyingNodeTasks",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(NodeTaskServiceServer).FindNotifyingNodeTasks(ctx, req.(*FindNotifyingNodeTasksRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _NodeTaskService_UpdateNodeTasksNotified_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(UpdateNodeTasksNotifiedRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(NodeTaskServiceServer).UpdateNodeTasksNotified(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/pb.NodeTaskService/UpdateNodeTasksNotified",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(NodeTaskServiceServer).UpdateNodeTasksNotified(ctx, req.(*UpdateNodeTasksNotifiedRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-var _NodeTaskService_serviceDesc = grpc.ServiceDesc{
-	ServiceName: "pb.NodeTaskService",
-	HandlerType: (*NodeTaskServiceServer)(nil),
-	Methods: []grpc.MethodDesc{
-		{
-			MethodName: "findNodeTasks",
-			Handler:    _NodeTaskService_FindNodeTasks_Handler,
-		},
-		{
-			MethodName: "reportNodeTaskDone",
-			Handler:    _NodeTaskService_ReportNodeTaskDone_Handler,
-		},
-		{
-			MethodName: "findNodeClusterTasks",
-			Handler:    _NodeTaskService_FindNodeClusterTasks_Handler,
-		},
-		{
-			MethodName: "existsNodeTasks",
-			Handler:    _NodeTaskService_ExistsNodeTasks_Handler,
-		},
-		{
-			MethodName: "deleteNodeTask",
-			Handler:    _NodeTaskService_DeleteNodeTask_Handler,
-		},
-		{
-			MethodName: "deleteNodeTasks",
-			Handler:    _NodeTaskService_DeleteNodeTasks_Handler,
-		},
-		{
-			MethodName: "deleteAllNodeTasks",
-			Handler:    _NodeTaskService_DeleteAllNodeTasks_Handler,
-		},
-		{
-			MethodName: "countDoingNodeTasks",
-			Handler:    _NodeTaskService_CountDoingNodeTasks_Handler,
-		},
-		{
-			MethodName: "findNotifyingNodeTasks",
-			Handler:    _NodeTaskService_FindNotifyingNodeTasks_Handler,
-		},
-		{
-			MethodName: "updateNodeTasksNotified",
-			Handler:    _NodeTaskService_UpdateNodeTasksNotified_Handler,
-		},
-	},
-	Streams:  []grpc.StreamDesc{},
-	Metadata: "service_node_task.proto",
-}