todo in router ack

DmitryRomanov · DmitryRomanov · commit a69f8df6b34b · 2025-09-03T13:31:10.000+07:00
diff --git a/pipeline/router.go b/pipeline/router.go
@@ -23,7 +23,7 @@ func (r *Router) SetDeadQueueOutput(info *OutputPluginInfo) {
 }
 
 func (r *Router) Ack(event *Event) {
-
+	// TODO: send commit to input after receiving all acks from outputs
 }
 
 func (r *Router) Fail(event *Event) {

Original file line number	Diff line number	Diff line change
`@@ -23,7 +23,7 @@ func (r Router) SetDeadQueueOutput(info OutputPluginInfo) {`
`23`	`23`	`}`
`24`	`24`
`25`	`25`	`func (r Router) Ack(event Event) {`
`26`		`-`
	`26`	`+ // TODO: send commit to input after receiving all acks from outputs`
`27`	`27`	`}`
`28`	`28`
`29`	`29`	`func (r Router) Fail(event Event) {`