INNER CODE UNIT · Go
startLogger
kserve/kserve · cmd/agent/main.go:275
func startLogger(workers int, logStorePath *string, marshallerUrl string, marshallerPort int,
batchSize int, batchInterval time.Duration, log *zap.SugaredLogger,
) *loggerArgs {
loggingMode := v1beta1.LoggerType(*logMode)
switch loggingMode {
case v1beta1.LogAll, v1beta1.LogRequest, v1beta1.LogResponse:
default:
log.Errorf("Malformed log-mode %s", *logMode)
os.Exit(-1)
}
logUrlParsed, err := url.Parse(*logUrl)
if err != nil {
log.Errorf("Malformed log-url %s", *logUrl)
os.Exit(-1)
}
if *sourceUri == "" {