| 256 | } |
| 257 | |
| 258 | func (serv *MetadataServer) GetSourceVariants(stream pb.Api_GetSourceVariantsServer) error { |
| 259 | for { |
| 260 | nameVariant, err := stream.Recv() |
| 261 | if err == io.EOF { |
| 262 | return nil |
| 263 | } |
| 264 | if err != nil { |
| 265 | serv.Logger.Errorf("Failed to read client request: %v", err) |
| 266 | return err |
| 267 | } |
| 268 | proxyStream, err := serv.meta.GetSourceVariants(stream.Context()) |
| 269 | if err != nil { |
| 270 | return err |
| 271 | } |
| 272 | sErr := proxyStream.Send(nameVariant) |
| 273 | if sErr != nil { |
| 274 | return sErr |
| 275 | } |
| 276 | res, err := proxyStream.Recv() |
| 277 | if err != nil { |
| 278 | return err |
| 279 | } |
| 280 | sendErr := stream.Send(res) |
| 281 | if sendErr != nil { |
| 282 | return sendErr |
| 283 | } |
| 284 | } |
| 285 | } |
| 286 | |
| 287 | func (serv *MetadataServer) GetTrainingSets(stream pb.Api_GetTrainingSetsServer) error { |
| 288 | for { |