(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
| 629 | } |
| 630 | |
| 631 | func _ReconnectService_Start_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 632 | in := new(ReconnectParams) |
| 633 | if err := dec(in); err != nil { |
| 634 | return nil, err |
| 635 | } |
| 636 | if interceptor == nil { |
| 637 | return srv.(ReconnectServiceServer).Start(ctx, in) |
| 638 | } |
| 639 | info := &grpc.UnaryServerInfo{ |
| 640 | Server: srv, |
| 641 | FullMethod: ReconnectService_Start_FullMethodName, |
| 642 | } |
| 643 | handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| 644 | return srv.(ReconnectServiceServer).Start(ctx, req.(*ReconnectParams)) |
| 645 | } |
| 646 | return interceptor(ctx, in, info, handler) |
| 647 | } |
| 648 | |
| 649 | func _ReconnectService_Stop_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 650 | in := new(Empty) |
nothing calls this directly
no test coverage detected