Fix after merge build errors

pipeline/processor.go

@@ -352,16 +352,16 @@ func (p *processor) Propagate(event *Event) {
 // Any attempts to ActionHold or ActionCollapse the event will be suppressed by timeout events.
 func (p *processor) Spawn(parent *Event, nodes []*insaneJSON.Node) {
 	parent.SetChildParentKind()
-	nextActionIdx := parent.action.Load() + 1
+	nextActionIdx := parent.action + 1
 
 	for _, node := range nodes {
 		child := newEvent()
 		parent.children = append(parent.children, child)
 		child.Root.MutateToNode(node)
 		child.SetChildKind()
-		child.action.Store(nextActionIdx)
+		child.action = nextActionIdx
 
-		ok := p.doActions(child)
+		ok, _ := p.doActions(child)
 		if ok {
 			child.stage = eventStageOutput
 			p.output.Out(child)
@@ -378,7 +378,7 @@ func (p *processor) Spawn(parent *Event, nodes []*insaneJSON.Node) {
 		}
 
 		timeout := newTimeoutEvent(parent.stream)
-		timeout.action.Store(int64(i))
+		timeout.action = i
 		p.doActions(timeout)
 	}
 }

plugin/action/split/split.go

@@ -4,7 +4,6 @@ import (
 	"github.com/ozontech/file.d/cfg"
 	"github.com/ozontech/file.d/fd"
 	"github.com/ozontech/file.d/pipeline"
-	"github.com/ozontech/file.d/plugin"
 	insaneJSON "github.com/vitkovskii/insane-json"
 	"go.uber.org/zap"
 )
@@ -38,7 +37,6 @@ type Plugin struct {
 	config           *Config
 	logger           *zap.Logger
 	pluginController pipeline.ActionPluginController
-	plugin.NoMetricsPlugin
 }
 
 // ! config-params

plugin/output/clickhouse/clickhouse.go

@@ -412,7 +412,8 @@ func (p *Plugin) out(workerData *pipeline.WorkerData, batch *pipeline.Batch) {
 	data := (*workerData).(data)
 	data.reset()
 
-	for _, event := range batch.Events {
+	for batch.Next() {
+		event := batch.Value()
 		for _, col := range data.cols {
 			node := event.Root.Dig(col.Name)