| 6520 | } |
| 6521 | |
| 6522 | func _Worker_Export_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 6523 | in := new(ExportRequest) |
| 6524 | if err := dec(in); err != nil { |
| 6525 | return nil, err |
| 6526 | } |
| 6527 | if interceptor == nil { |
| 6528 | return srv.(WorkerServer).Export(ctx, in) |
| 6529 | } |
| 6530 | info := &grpc.UnaryServerInfo{ |
| 6531 | Server: srv, |
| 6532 | FullMethod: "/pb.Worker/Export", |
| 6533 | } |
| 6534 | handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| 6535 | return srv.(WorkerServer).Export(ctx, req.(*ExportRequest)) |
| 6536 | } |
| 6537 | return interceptor(ctx, in, info, handler) |
| 6538 | } |
| 6539 | |
| 6540 | func _Worker_ReceivePredicate_Handler(srv interface{}, stream grpc.ServerStream) error { |
| 6541 | return srv.(WorkerServer).ReceivePredicate(&workerReceivePredicateServer{stream}) |