| 6448 | } |
| 6449 | |
| 6450 | func _Worker_Sort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 6451 | in := new(SortMessage) |
| 6452 | if err := dec(in); err != nil { |
| 6453 | return nil, err |
| 6454 | } |
| 6455 | if interceptor == nil { |
| 6456 | return srv.(WorkerServer).Sort(ctx, in) |
| 6457 | } |
| 6458 | info := &grpc.UnaryServerInfo{ |
| 6459 | Server: srv, |
| 6460 | FullMethod: "/pb.Worker/Sort", |
| 6461 | } |
| 6462 | handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| 6463 | return srv.(WorkerServer).Sort(ctx, req.(*SortMessage)) |
| 6464 | } |
| 6465 | return interceptor(ctx, in, info, handler) |
| 6466 | } |
| 6467 | |
| 6468 | func _Worker_Schema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 6469 | in := new(SchemaRequest) |