Function readLogStream

pkg/client/clientimplementation/proxy_client.go:388–414

(reader io.Reader, logger log.Logger)

}

func readLogStream(reader io.Reader, logger log.Logger) {
	scan := scanner.NewScanner(reader)
	for scan.Scan() {
		line := scan.Bytes()

		lineObject := &log.Line{}
		err := json.Unmarshal(line, lineObject)
		if err == nil && lineObject.Message != "" {
			switch lineObject.Level {
			case logrus.TraceLevel:
				logger.Debug(lineObject.Message)
			case logrus.DebugLevel:
				logger.Debug(lineObject.Message)
			case logrus.InfoLevel:
				logger.Info(lineObject.Message)
			case logrus.WarnLevel:
				logger.Warn(lineObject.Message)
			case logrus.ErrorLevel:
				logger.Error(lineObject.Message)
			case logrus.PanicLevel:
				logger.Error(lineObject.Message)
			case logrus.FatalLevel:
				logger.Error(lineObject.Message)
			}
		}
	}
}