| 378 | } |
| 379 | |
| 380 | func _Downstream_Ping_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 381 | in := new(Empty) |
| 382 | if err := dec(in); err != nil { |
| 383 | return nil, err |
| 384 | } |
| 385 | if interceptor == nil { |
| 386 | return srv.(DownstreamServer).Ping(ctx, in) |
| 387 | } |
| 388 | info := &grpc.UnaryServerInfo{ |
| 389 | Server: srv, |
| 390 | FullMethod: "/remote.Downstream/Ping", |
| 391 | } |
| 392 | handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| 393 | return srv.(DownstreamServer).Ping(ctx, req.(*Empty)) |
| 394 | } |
| 395 | return interceptor(ctx, in, info, handler) |
| 396 | } |
| 397 | |
| 398 | // Downstream_ServiceDesc is the grpc.ServiceDesc for Downstream service. |
| 399 | // It's only intended for direct use with grpc.RegisterService, |