From b4aff74b597ad5604694903cd6b36f355bdfd2a2 Mon Sep 17 00:00:00 2001 From: zhangqian <zhangqian@123.com> Date: 星期一, 27 十一月 2023 14:35:11 +0800 Subject: [PATCH] srm同步用户改成同步本公司全部用户 --- proto/user/user_grpc.pb.go | 86 ++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 84 insertions(+), 2 deletions(-) diff --git a/proto/user/user_grpc.pb.go b/proto/user/user_grpc.pb.go index 2825eb1..cea2535 100644 --- a/proto/user/user_grpc.pb.go +++ b/proto/user/user_grpc.pb.go @@ -1,4 +1,8 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. +// versions: +// - protoc-gen-go-grpc v1.3.0 +// - protoc v3.19.0 +// source: user.proto package user @@ -14,11 +18,19 @@ // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + UserService_SyncUser_FullMethodName = "/user.UserService/SyncUser" + UserService_UserMenuCheck_FullMethodName = "/user.UserService/UserMenuCheck" + UserService_SyncAllUser_FullMethodName = "/user.UserService/SyncAllUser" +) + // UserServiceClient is the client API for UserService service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. type UserServiceClient interface { SyncUser(ctx context.Context, in *UserRequest, opts ...grpc.CallOption) (*UserResponse, error) + UserMenuCheck(ctx context.Context, in *CheckRequest, opts ...grpc.CallOption) (*CheckResponse, error) + SyncAllUser(ctx context.Context, in *AllUserRequest, opts ...grpc.CallOption) (*AllUserResponse, error) } type userServiceClient struct { @@ -31,7 +43,25 @@ func (c *userServiceClient) SyncUser(ctx context.Context, in *UserRequest, opts ...grpc.CallOption) (*UserResponse, error) { out := new(UserResponse) - err := c.cc.Invoke(ctx, "/user.UserService/SyncUser", in, out, opts...) + err := c.cc.Invoke(ctx, UserService_SyncUser_FullMethodName, in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *userServiceClient) UserMenuCheck(ctx context.Context, in *CheckRequest, opts ...grpc.CallOption) (*CheckResponse, error) { + out := new(CheckResponse) + err := c.cc.Invoke(ctx, UserService_UserMenuCheck_FullMethodName, in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *userServiceClient) SyncAllUser(ctx context.Context, in *AllUserRequest, opts ...grpc.CallOption) (*AllUserResponse, error) { + out := new(AllUserResponse) + err := c.cc.Invoke(ctx, UserService_SyncAllUser_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -43,6 +73,8 @@ // for forward compatibility type UserServiceServer interface { SyncUser(context.Context, *UserRequest) (*UserResponse, error) + UserMenuCheck(context.Context, *CheckRequest) (*CheckResponse, error) + SyncAllUser(context.Context, *AllUserRequest) (*AllUserResponse, error) mustEmbedUnimplementedUserServiceServer() } @@ -52,6 +84,12 @@ func (UnimplementedUserServiceServer) SyncUser(context.Context, *UserRequest) (*UserResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SyncUser not implemented") +} +func (UnimplementedUserServiceServer) UserMenuCheck(context.Context, *CheckRequest) (*CheckResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method UserMenuCheck not implemented") +} +func (UnimplementedUserServiceServer) SyncAllUser(context.Context, *AllUserRequest) (*AllUserResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method SyncAllUser not implemented") } func (UnimplementedUserServiceServer) mustEmbedUnimplementedUserServiceServer() {} @@ -76,10 +114,46 @@ } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/user.UserService/SyncUser", + FullMethod: UserService_SyncUser_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(UserServiceServer).SyncUser(ctx, req.(*UserRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _UserService_UserMenuCheck_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(CheckRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(UserServiceServer).UserMenuCheck(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: UserService_UserMenuCheck_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(UserServiceServer).UserMenuCheck(ctx, req.(*CheckRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _UserService_SyncAllUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(AllUserRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(UserServiceServer).SyncAllUser(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: UserService_SyncAllUser_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(UserServiceServer).SyncAllUser(ctx, req.(*AllUserRequest)) } return interceptor(ctx, in, info, handler) } @@ -95,6 +169,14 @@ MethodName: "SyncUser", Handler: _UserService_SyncUser_Handler, }, + { + MethodName: "UserMenuCheck", + Handler: _UserService_UserMenuCheck_Handler, + }, + { + MethodName: "SyncAllUser", + Handler: _UserService_SyncAllUser_Handler, + }, }, Streams: []grpc.StreamDesc{}, Metadata: "user.proto", -- Gitblit v1.8.0