| 6386 | } |
| 6387 | |
| 6388 | func _Worker_Mutate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 6389 | in := new(Mutations) |
| 6390 | if err := dec(in); err != nil { |
| 6391 | return nil, err |
| 6392 | } |
| 6393 | if interceptor == nil { |
| 6394 | return srv.(WorkerServer).Mutate(ctx, in) |
| 6395 | } |
| 6396 | info := &grpc.UnaryServerInfo{ |
| 6397 | Server: srv, |
| 6398 | FullMethod: "/pb.Worker/Mutate", |
| 6399 | } |
| 6400 | handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| 6401 | return srv.(WorkerServer).Mutate(ctx, req.(*Mutations)) |
| 6402 | } |
| 6403 | return interceptor(ctx, in, info, handler) |
| 6404 | } |
| 6405 | |
| 6406 | func _Worker_ServeTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 6407 | in := new(Query) |