INNER CODE UNIT · Go

err

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

			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,
		inferenceService: *inferenceService,
		endpoint:         *endpoint,
		namespace:        *namespace,
		component:        *component,

View source record →