INNER CODE UNIT · Go

LoadPipeline

alibaba/loongcollector · plugin_main/plugin_export.go:186

func LoadPipeline(project string, logstore string, configName string, logstoreKey int64, jsonStr string) int {
	logger.Debug(context.Background(), "load config", configName, logstoreKey, "\n"+jsonStr)
	defer func() {
		if err := recover(); err != nil {
			trace := make([]byte, 2048)
			runtime.Stack(trace, true)
			logger.Critical(context.Background(), selfmonitor.PluginRuntimeAlarm, "panicked", err, "stack", string(trace))
		}
	}()

	err := pluginmanager.LoadLogstoreConfig(util.StringDeepCopy(project),
		util.StringDeepCopy(logstore), util.StringDeepCopy(configName),
		// Make deep copy if you want to save it in Go in the future.
		logstoreKey, jsonStr)
	if err != nil {
		logger.Critical(context.Background(), selfmonitor.ConfigLoadAlarm, "load config error, project",
			project, "logstore", logstore, "config", configName, "error", err)
		return 1

View source record →