(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
| 1512 | } |
| 1513 | |
| 1514 | func _Worker_TaskStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 1515 | in := new(TaskStatusRequest) |
| 1516 | if err := dec(in); err != nil { |
| 1517 | return nil, err |
| 1518 | } |
| 1519 | if interceptor == nil { |
| 1520 | return srv.(WorkerServer).TaskStatus(ctx, in) |
| 1521 | } |
| 1522 | info := &grpc.UnaryServerInfo{ |
| 1523 | Server: srv, |
| 1524 | FullMethod: Worker_TaskStatus_FullMethodName, |
| 1525 | } |
| 1526 | handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| 1527 | return srv.(WorkerServer).TaskStatus(ctx, req.(*TaskStatusRequest)) |
| 1528 | } |
| 1529 | return interceptor(ctx, in, info, handler) |
| 1530 | } |
| 1531 | |
| 1532 | func _Worker_UpdateExtSnapshotStreamingState_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 1533 | in := new(api.UpdateExtSnapshotStreamingStateRequest) |
nothing calls this directly
no test coverage detected
searching dependent graphs…