INNER CODE UNIT · Go
ProcessPipelineEventGroup
alibaba/loongcollector · plugin_main/plugin_export.go:219
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
}
return config.ProcessPipelineEventGroup(pbBytes, util.StringDeepCopy(packID))
}
//export StopAllPipelines
func StopAllPipelines(withInputFlag int) {
logger.Info(context.Background(), "Stop all", "start", "with input", withInputFlag)
err := pluginmanager.StopAllPipelines(withInputFlag != 0)
if err != nil {
logger.Error(context.Background(), selfmonitor.PluginAlarm, "stop all error", err)
}