Method GetSources

api/main.go:229–256

(stream pb.Api_GetSourcesServer)

}

func (serv *MetadataServer) GetSources(stream pb.Api_GetSourcesServer) error {
	for {
		name, err := stream.Recv()
		if err == io.EOF {
			return nil
		}
		if err != nil {
			serv.Logger.Errorf("Failed to read client request: %v", err)
			return err
		}
		proxyStream, err := serv.meta.GetSources(stream.Context())
		if err != nil {
			return err
		}
		sErr := proxyStream.Send(name)
		if sErr != nil {
			return sErr
		}
		res, err := proxyStream.Recv()
		if err != nil {
			return err
		}
		sendErr := stream.Send(res)
		if sendErr != nil {
			return sendErr
		}
	}
}

func (serv *MetadataServer) GetSourceVariants(stream pb.Api_GetSourceVariantsServer) error {
	for {