INNER CODE UNIT · Go
UnloadPipeline
alibaba/loongcollector · plugin_main/plugin_export.go:209
func UnloadPipeline(configName string) int {
logger.Debug(context.Background(), "unload config", configName)
err := pluginmanager.UnloadPartiallyLoadedConfig(util.StringDeepCopy(configName))
if err != nil {
return 1
}
return 0
}
//export ProcessPipelineEventGroup
func ProcessPipelineEventGroup(configName string, pbBytes []byte, packID string) int {
pluginmanager.LogtailConfigLock.RLock()
config, flag := pluginmanager.LogtailConfig[configName]
pluginmanager.LogtailConfigLock.RUnlock()
if !flag {
logger.Critical(context.Background(), selfmonitor.PluginAlarm, "config not found", configName)
return -1
}