| 600 | } |
| 601 | |
| 602 | func _Upstream_Checksums_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 603 | in := new(TouchPaths) |
| 604 | if err := dec(in); err != nil { |
| 605 | return nil, err |
| 606 | } |
| 607 | if interceptor == nil { |
| 608 | return srv.(UpstreamServer).Checksums(ctx, in) |
| 609 | } |
| 610 | info := &grpc.UnaryServerInfo{ |
| 611 | Server: srv, |
| 612 | FullMethod: "/remote.Upstream/Checksums", |
| 613 | } |
| 614 | handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| 615 | return srv.(UpstreamServer).Checksums(ctx, req.(*TouchPaths)) |
| 616 | } |
| 617 | return interceptor(ctx, in, info, handler) |
| 618 | } |
| 619 | |
| 620 | func _Upstream_Upload_Handler(srv interface{}, stream grpc.ServerStream) error { |
| 621 | return srv.(UpstreamServer).Upload(&upstreamUploadServer{stream}) |