INNER CODE UNIT · Go

httpClient

kserve/kserve · cmd/agent/main.go:351

			httpClient := &http.Client{Timeout: 30 * time.Second}
			marshaller := kfslogger.NewHTTPMarshaller(marshallerUrl, httpClient)

			log.Infow("Logger storage is enabled", "path", *logStorePath, "marshallerUrl", marshallerUrl)
			store, err = kfslogger.NewStoreForScheme(logUrlParsed.Scheme, *logStorePath, marshaller, log)
			if err != nil {
				log.Errorw("Error creating logger store", zap.Error(err))
				os.Exit(-1)
			}
		}
	}

	log.Info("Starting the log dispatcher")
	kfslogger.StartDispatcher(workers, store, batchStrategy, log)
	return &loggerArgs{
		loggerType:       loggingMode,
		logUrl:           logUrlParsed,
		sourceUrl:        sourceUriParsed,

View source record →