| 140 | } |
| 141 | |
| 142 | func (serv *MetadataServer) GetFeatureVariants(stream pb.Api_GetFeatureVariantsServer) error { |
| 143 | for { |
| 144 | nameVariant, err := stream.Recv() |
| 145 | if err == io.EOF { |
| 146 | return nil |
| 147 | } |
| 148 | if err != nil { |
| 149 | serv.Logger.Errorf("Failed to read client request: %v", err) |
| 150 | return err |
| 151 | } |
| 152 | proxyStream, err := serv.meta.GetFeatureVariants(stream.Context()) |
| 153 | if err != nil { |
| 154 | return err |
| 155 | } |
| 156 | sErr := proxyStream.Send(nameVariant) |
| 157 | if sErr != nil { |
| 158 | return sErr |
| 159 | } |
| 160 | res, err := proxyStream.Recv() |
| 161 | if err != nil { |
| 162 | return err |
| 163 | } |
| 164 | sendErr := stream.Send(res) |
| 165 | if sendErr != nil { |
| 166 | return sendErr |
| 167 | } |
| 168 | } |
| 169 | } |
| 170 | |
| 171 | func (serv *MetadataServer) GetLabels(stream pb.Api_GetLabelsServer) error { |
| 172 | for { |